diff --git a/cmd/telegraf/telegraf.go b/cmd/telegraf/telegraf.go index 2e6ee3fe8..e3ab11028 100644 --- a/cmd/telegraf/telegraf.go +++ b/cmd/telegraf/telegraf.go @@ -166,8 +166,10 @@ func reloadLoop( }() log.Printf("I! Starting Telegraf %s\n", displayVersion()) - log.Printf("I! Loaded outputs: %s", strings.Join(c.OutputNames(), " ")) log.Printf("I! Loaded inputs: %s", strings.Join(c.InputNames(), " ")) + log.Printf("I! Loaded aggregators: %s", strings.Join(c.AggregatorNames(), " ")) + log.Printf("I! Loaded processors: %s", strings.Join(c.ProcessorNames(), " ")) + log.Printf("I! Loaded outputs: %s", strings.Join(c.OutputNames(), " ")) log.Printf("I! Tags enabled: %s", c.ListTags()) if *fPidfile != "" { diff --git a/internal/config/config.go b/internal/config/config.go index e7a008f4b..8a31c271e 100644 --- a/internal/config/config.go +++ b/internal/config/config.go @@ -156,6 +156,24 @@ func (c *Config) InputNames() []string { return name } +// Outputs returns a list of strings of the configured aggregators. +func (c *Config) AggregatorNames() []string { + var name []string + for _, aggregator := range c.Aggregators { + name = append(name, aggregator.Name()) + } + return name +} + +// Outputs returns a list of strings of the configured processors. +func (c *Config) ProcessorNames() []string { + var name []string + for _, processor := range c.Processors { + name = append(name, processor.Name) + } + return name +} + // Outputs returns a list of strings of the configured outputs. func (c *Config) OutputNames() []string { var name []string