diff --git a/plugins/inputs/suricata/suricata_test.go b/plugins/inputs/suricata/suricata_test.go index 9c9c2ddc3..3308f28b5 100644 --- a/plugins/inputs/suricata/suricata_test.go +++ b/plugins/inputs/suricata/suricata_test.go @@ -119,7 +119,7 @@ func TestThreadStats(t *testing.T) { c.Write([]byte(ex3)) c.Write([]byte("\n")) c.Close() - acc.Wait(1) + acc.Wait(2) expected := []telegraf.Metric{ testutil.MustMetric( diff --git a/testutil/accumulator.go b/testutil/accumulator.go index 6e754da45..c02f5092c 100644 --- a/testutil/accumulator.go +++ b/testutil/accumulator.go @@ -54,6 +54,8 @@ func (a *Accumulator) NMetrics() uint64 { return atomic.LoadUint64(&a.nMetrics) } +// GetTelegrafMetrics returns all the metrics collected by the accumulator +// If you are getting race conditions here then you are not waiting for all of your metrics to arrive: see Wait() func (a *Accumulator) GetTelegrafMetrics() []telegraf.Metric { metrics := []telegraf.Metric{} for _, m := range a.Metrics {