diff --git a/plugins/inputs/nginx_plus/nginx_plus.go b/plugins/inputs/nginx_plus/nginx_plus.go index ada9b512af535..2757ef03510d3 100644 --- a/plugins/inputs/nginx_plus/nginx_plus.go +++ b/plugins/inputs/nginx_plus/nginx_plus.go @@ -13,7 +13,6 @@ import ( "time" "github.com/influxdata/telegraf" - "github.com/influxdata/telegraf/internal/errchan" "github.com/influxdata/telegraf/plugins/inputs" ) @@ -36,23 +35,22 @@ func (n *NginxPlus) Description() string { func (n *NginxPlus) Gather(acc telegraf.Accumulator) error { var wg sync.WaitGroup - errChan := errchan.New(len(n.Urls)) for _, u := range n.Urls { addr, err := url.Parse(u) if err != nil { - return fmt.Errorf("Unable to parse address '%s': %s", u, err) + acc.AddError(fmt.Errorf("Unable to parse address '%s': %s", u, err)) } wg.Add(1) go func(addr *url.URL) { defer wg.Done() - errChan.C <- n.gatherUrl(addr, acc) + acc.AddError(n.gatherUrl(addr, acc)) }(addr) } wg.Wait() - return errChan.Error() + return nil } var tr = &http.Transport{