diff --git a/CHANGELOG.md b/CHANGELOG.md index f3dc99275ebe1..db446fb8a631e 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,6 +1,7 @@ ## v0.1.7 [unreleased] ### Features +- [#133](https://github.com/influxdb/telegraf/pull/133): Add plugin.Gather error logging. Thanks @nickscript0! ### Bigfixes - [#129](https://github.com/influxdb/telegraf/issues/129): Latest pkg url fix. diff --git a/agent.go b/agent.go index 1c90bf1a4fde4..b35fae39083f8 100644 --- a/agent.go +++ b/agent.go @@ -179,7 +179,10 @@ func (a *Agent) crankParallel() error { acc.Prefix = plugin.name + "_" acc.Config = plugin.config - plugin.plugin.Gather(&acc) + err := plugin.plugin.Gather(&acc) + if err != nil { + log.Printf("Error in plugin [%s]: %s", plugin.name, err) + } points <- &acc }(plugin) @@ -333,7 +336,10 @@ func (a *Agent) Run(shutdown chan struct{}) error { wg.Add(1) go func(plugin *runningPlugin) { defer wg.Done() - a.crankSeparate(shutdown, plugin) + err := a.crankSeparate(shutdown, plugin) + if err != nil { + log.Printf("Error in plugin [%s]: %s", plugin.name, err) + } }(plugin) } }