Added telegraf tag to Riemann output

dhruvbansal · Feb 4, 2016 · fe92298 · fe92298
1 parent fff054c
commit fe92298
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/plugins/outputs/riemann/riemann.go b/plugins/outputs/riemann/riemann.go
@@ -77,6 +77,7 @@ func (r *Riemann) Write(metrics []telegraf.Metric) error {
 
 func buildEvents(p telegraf.Metric, s string) []*raidman.Event {
 	events := []*raidman.Event{}
+	telegrafTags := []string{"telegraf"}
 	for fieldName, value := range p.Fields() {
 		host, ok := p.Tags()["host"]
 		if !ok {
@@ -91,6 +92,7 @@ func buildEvents(p telegraf.Metric, s string) []*raidman.Event {
 		event := &raidman.Event{
 			Host:    host,
 			Service: serviceName(s, p.Name(),p.Tags(),fieldName),
+		        Tags:    telegrafTags,
 		}
 
 		switch value.(type) {