don't overwrite host tags in plugins

closes #1227 closes #1210
influxdata · May 19, 2016 · 36d6d9e · 36d6d9e
1 parent debf7bf
commit 36d6d9e
Showing 1 changed file with 9 additions and 5 deletions.
diff --git a/agent/accumulator.go b/agent/accumulator.go
@@ -84,13 +84,17 @@ func (ac *accumulator) AddFields(
 	if tags == nil {
 		tags = make(map[string]string)
 	}
-	// Apply daemon-wide tags if set
-	for k, v := range ac.defaultTags {
-		tags[k] = v
-	}
 	// Apply plugin-wide tags if set
 	for k, v := range ac.inputConfig.Tags {
-		tags[k] = v
+		if _, ok := tags[k]; !ok {
+			tags[k] = v
+		}
+	}
+	// Apply daemon-wide tags if set
+	for k, v := range ac.defaultTags {
+		if _, ok := tags[k]; !ok {
+			tags[k] = v
+		}
 	}
 	ac.inputConfig.Filter.FilterTags(tags)