Method ProcessStatics

pkg/parser/runtime.go:223–231

(event *pipeline.Event, ectx EnricherCtx, logger *log.Entry, debug bool)

}

func (rg *RuntimeGrokPattern) ProcessStatics(event *pipeline.Event, ectx EnricherCtx, logger *log.Entry, debug bool) error {
	for _, rs := range rg.RuntimeStatics {
		if err := rs.Apply(event, ectx, logger, debug); err != nil {
			return fmt.Errorf("applying %s: %w", rs.Config.targetExpr(), err)
		}
	}

	return nil
}

func Parse(ctx UnixParserCtx, event pipeline.Event, nodes []Node, collector *StageParseCollector) (pipeline.Event, error) {
	/* the stage is undefined, probably line is freshly acquired, set to first stage !*/