plugins/inputs/nats: Add a nats_server tag

Include the NATS server URL as a tag to allow multiple instances of the nats input plugin to be distinguished.
influxdata · Jan 16, 2018 · 3128c32 · 3128c32
1 parent 80b4e29
commit 3128c32
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
diff --git a/plugins/inputs/nats/nats.go b/plugins/inputs/nats/nats.go
@@ -78,7 +78,9 @@ func (n *Nats) Gather(acc telegraf.Accumulator) error {
 			"slow_consumers":    stats.SlowConsumers,
 			"routes":            stats.Routes,
 			"remotes":           stats.Remotes,
-		}, nil, time.Now())
+		},
+		map[string]string{"nats_server": n.Server},
+		time.Now())
 
 	return nil
 }

diff --git a/plugins/inputs/nats/nats_test.go b/plugins/inputs/nats/nats_test.go
@@ -90,7 +90,10 @@ func TestMetricsCorrect(t *testing.T) {
 		"routes":            int(1),
 		"remotes":           int(2),
 	}
-	acc.AssertContainsFields(t, "nats_varz", fields)
+	tags := map[string]string{
+		"nats_server": srv.URL,
+	}
+	acc.AssertContainsTaggedFields(t, "nats_varz", fields, tags)
 }
 
 func newTestNatsServer() *httptest.Server {