Function LoadStages

pkg/parser/stage.go:39–65

(stageFiles []Stagefile, pctx *UnixParserCtx, ectx EnricherCtx)

}

func LoadStages(stageFiles []Stagefile, pctx *UnixParserCtx, ectx EnricherCtx) ([]Node, error) {
	var allNodes []Node

	tmpStages := make(map[string]bool)
	pctx.Stages = []string{}

	for _, sf := range stageFiles {
		nodes, err := processStageFile(sf, pctx, ectx)
		if err != nil {
			return nil, err
		}

		for _, n := range nodes { //nolint:gocritic // rangeValCopy
			allNodes = append(allNodes, n)
			tmpStages[n.Stage] = true
		}
	}

	for k := range tmpStages {
		pctx.Stages = append(pctx.Stages, k)
	}

	sort.Strings(pctx.Stages)
	log.Infof("Loaded %d nodes from %d stages", len(allNodes), len(pctx.Stages))

	return allNodes, nil
}

func processStageFile(stageFile Stagefile, pctx *UnixParserCtx, ectx EnricherCtx) ([]Node, error) {
	if !strings.HasSuffix(stageFile.Filename, ".yaml") && !strings.HasSuffix(stageFile.Filename, ".yml") {