Add source tag to hddtemp plugin (#5955)

plugins/inputs/hddtemp/README.md

@@ -1,12 +1,10 @@
-# Hddtemp Input Plugin
+# HDDtemp Input Plugin
 
-This plugin reads data from hddtemp daemon
+This plugin reads data from hddtemp daemon.
 
-## Requirements
+Hddtemp should be installed and its daemon running.
 
-Hddtemp should be installed and its daemon running
-
-## Configuration
+### Configuration
 
 ```toml
 [[inputs.hddtemp]]
@@ -21,23 +19,23 @@ Hddtemp should be installed and its daemon running
   # devices = ["sda", "*"]
 ```
 
-## Measurements
+### Metrics
 
 - hddtemp
-  - temperature
-
-Tags:
+  - tags:
     - device
     - model
     - unit
     - status
+    - source
+  - fields:
+    - temperature
 
 
-
-## Example output
+### Example output
 
 ```
-> hddtemp,unit=C,status=,host=server1,device=sdb,model=WDC\ WD740GD-00FLA1 temperature=43i 1481655647000000000
-> hddtemp,device=sdc,model=SAMSUNG\ HD103UI,unit=C,status=,host=server1 temperature=38i 148165564700000000
-> hddtemp,device=sdd,model=SAMSUNG\ HD103UI,unit=C,status=,host=server1 temperature=36i 1481655647000000000
+hddtemp,source=server1,unit=C,status=,device=sdb,model=WDC\ WD740GD-00FLA1 temperature=43i 1481655647000000000
+hddtemp,device=sdc,model=SAMSUNG\ HD103UI,unit=C,source=server1,status= temperature=38i 148165564700000000
+hddtemp,device=sdd,model=SAMSUNG\ HD103UI,unit=C,source=server1,status= temperature=36i 1481655647000000000
 ```

plugins/inputs/hddtemp/hddtemp.go

@@ -1,6 +1,8 @@
 package hddtemp
 
 import (
+	"net"
+
 	"github.com/influxdata/telegraf"
 	"github.com/influxdata/telegraf/plugins/inputs"
 	gohddtemp "github.com/influxdata/telegraf/plugins/inputs/hddtemp/go-hddtemp"
@@ -42,8 +44,12 @@ func (h *HDDTemp) Gather(acc telegraf.Accumulator) error {
 	if h.fetcher == nil {
 		h.fetcher = gohddtemp.New()
 	}
-	disks, err := h.fetcher.Fetch(h.Address)
+	source, _, err := net.SplitHostPort(h.Address)
+	if err != nil {
+		source = h.Address
+	}
 
+	disks, err := h.fetcher.Fetch(h.Address)
 	if err != nil {
 		return err
 	}
@@ -56,6 +62,7 @@ func (h *HDDTemp) Gather(acc telegraf.Accumulator) error {
 					"model":  disk.Model,
 					"unit":   disk.Unit,
 					"status": disk.Status,
+					"source": source,
 				}
 
 				fields := map[string]interface{}{

plugins/inputs/hddtemp/hddtemp_test.go

@@ -36,6 +36,7 @@ func newMockFetcher() *mockFetcher {
 func TestFetch(t *testing.T) {
 	hddtemp := &HDDTemp{
 		fetcher: newMockFetcher(),
+		Address: "localhost",
 		Devices: []string{"*"},
 	}
 
@@ -58,6 +59,7 @@ func TestFetch(t *testing.T) {
 				"model":  "Model1",
 				"unit":   "C",
 				"status": "",
+				"source": "localhost",
 			},
 		},
 		{
@@ -69,6 +71,7 @@ func TestFetch(t *testing.T) {
 				"model":  "Model2",
 				"unit":   "C",
 				"status": "",
+				"source": "localhost",
 			},
 		},
 	}