From ec1a8e84f731556b242007d985d2f8480151d33b Mon Sep 17 00:00:00 2001 From: Sanyam Arya Date: Tue, 19 Oct 2021 18:42:15 +0200 Subject: [PATCH] fix: internet_speed input plugin not collecting/reporting latency (#9957) (cherry picked from commit 62d5f635bbf68582150f7d4f27376ecaac61653a) --- plugins/inputs/internet_speed/internet_speed.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/plugins/inputs/internet_speed/internet_speed.go b/plugins/inputs/internet_speed/internet_speed.go index cf0c5cfb13117..58fb29c5949c1 100644 --- a/plugins/inputs/internet_speed/internet_speed.go +++ b/plugins/inputs/internet_speed/internet_speed.go @@ -2,6 +2,7 @@ package internet_speed import ( "fmt" + "time" "github.com/influxdata/telegraf" "github.com/influxdata/telegraf/plugins/inputs" @@ -68,7 +69,7 @@ func (is *InternetSpeed) Gather(acc telegraf.Accumulator) error { fields := make(map[string]interface{}) fields["download"] = s.DLSpeed fields["upload"] = s.ULSpeed - fields["latency"] = s.Latency + fields["latency"] = timeDurationMillisecondToFloat64(s.Latency) tags := make(map[string]string) @@ -80,3 +81,7 @@ func init() { return &InternetSpeed{} }) } + +func timeDurationMillisecondToFloat64(d time.Duration) float64 { + return float64(d) / float64(time.Millisecond) +}