CL-Softwares
/
telegraf
8
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(agent): Skip initialization of second processor state if requested (#16290)

This commit is contained in:
Sven Rebhan 2024-12-11 22:33:31 +01:00 committed by GitHub
parent e3ce01abf0
commit d2e032eb4a
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
agent/agent.go
View File

@ -231,10 +231,12 @@ func (a *Agent) InitPlugins() error {
return fmt.Errorf("could not initialize aggregator %s: %w", aggregator.LogName(), err) return fmt.Errorf("could not initialize aggregator %s: %w", aggregator.LogName(), err)
} }
} }
for _, processor := range a.Config.AggProcessors { if !a.Config.Agent.SkipProcessorsAfterAggregators {
err := processor.Init() for _, processor := range a.Config.AggProcessors {
if err != nil { err := processor.Init()
return fmt.Errorf("could not initialize processor %s: %w", processor.LogName(), err) if err != nil {
return fmt.Errorf("could not initialize processor %s: %w", processor.LogName(), err)
}
} }
} }
for _, output := range a.Config.Outputs { for _, output := range a.Config.Outputs {