(_ *pipeline.Event, cachedExprEnv map[string]any)
| 243 | } |
| 244 | |
| 245 | func (n *Node) processStash(_ *pipeline.Event, cachedExprEnv map[string]any) error { |
| 246 | for idx, stash := range n.RuntimeStashes { |
| 247 | stash.Apply(idx, cachedExprEnv, n.Logger, n.Debug) |
| 248 | } |
| 249 | |
| 250 | return nil |
| 251 | } |
| 252 | |
| 253 | func (n *Node) processLeaves( |
| 254 | p *pipeline.Event, |