diff --git a/plugins/inputs/diskio/diskio.go b/plugins/inputs/diskio/diskio.go index 79c58ea6606a3..daf97ad1de31b 100644 --- a/plugins/inputs/diskio/diskio.go +++ b/plugins/inputs/diskio/diskio.go @@ -118,7 +118,7 @@ func (d *DiskIO) Gather(acc telegraf.Accumulator) error { } } - fieldsC := map[string]interface{}{ + fields := map[string]interface{}{ "reads": io.ReadCount, "writes": io.WriteCount, "read_bytes": io.ReadBytes, @@ -135,20 +135,16 @@ func (d *DiskIO) Gather(acc telegraf.Accumulator) error { deltaRWCount := float64(io.ReadCount + io.WriteCount - lastValue.ReadCount - lastValue.WriteCount) deltaRWTime := float64(io.ReadTime + io.WriteTime - lastValue.ReadTime - lastValue.WriteTime) deltaIOTime := float64(io.IoTime - lastValue.IoTime) - fieldsG := make(map[string]interface{}) if deltaRWCount > 0 { - fieldsG["io_await"] = deltaRWTime / deltaRWCount - fieldsG["io_svctm"] = deltaIOTime / deltaRWCount + fields["io_await"] = deltaRWTime / deltaRWCount + fields["io_svctm"] = deltaIOTime / deltaRWCount } itv := float64(collectTime.Sub(d.lastCollectTime).Milliseconds()) if itv > 0 { - fieldsG["io_util"] = 100 * deltaIOTime / itv - } - if len(fieldsG) > 0 { - acc.AddGauge("diskio", fieldsG, tags) + fields["io_util"] = 100 * deltaIOTime / itv } } - acc.AddCounter("diskio", fieldsC, tags) + acc.AddCounter("diskio", fields, tags) } d.lastCollectTime = collectTime d.lastIOCounterStat = diskio