(event *pipeline.Event)
| 211 | } |
| 212 | |
| 213 | func (n *Node) ProcessStatics(event *pipeline.Event) error { |
| 214 | for _, rs := range n.RuntimeStatics { |
| 215 | if err := rs.Apply(event, n.EnrichFunctions, n.Logger, n.Debug); err != nil { |
| 216 | return fmt.Errorf("applying %s: %w", rs.Config.targetExpr(), err) |
| 217 | } |
| 218 | } |
| 219 | |
| 220 | return nil |
| 221 | } |
| 222 | |
| 223 | func (rg *RuntimeGrokPattern) ProcessStatics(event *pipeline.Event, ectx EnricherCtx, logger *log.Entry, debug bool) error { |
| 224 | for _, rs := range rg.RuntimeStatics { |
no test coverage detected