fix: 修复redis_sentinel标签异常 (#1109)

* fix: 修复redis_sentinel标签异常 * chore: 清理无用代码 --------- Co-authored-by: husheng <[email protected]>
flashcatcloud · Dec 16, 2024 · 7bb3d94 · 7bb3d94
1 parent 7b0de22
commit 7bb3d94
Showing 1 changed file with 16 additions and 4 deletions.
diff --git a/inputs/redis_sentinel/redis_sentinel.go b/inputs/redis_sentinel/redis_sentinel.go
@@ -183,7 +183,10 @@ func convertSentinelInfoOutput(
 	scanner := bufio.NewScanner(rdr)
 	rawFields := make(map[string]string)
 
-	tags := globalTags
+	tags := make(map[string]string, len(globalTags))
+	for k, v := range globalTags {
+		tags[k] = v
+	}
 
 	for scanner.Scan() {
 		line := scanner.Text()
@@ -268,7 +271,10 @@ func convertSentinelSentinelsOutput(
 	masterName string,
 	sentinelMaster map[string]string,
 ) (map[string]string, map[string]interface{}, error) {
-	tags := globalTags
+	tags := make(map[string]string, len(globalTags))
+	for k, v := range globalTags {
+		tags[k] = v
+	}
 
 	tags["sentinel_ip"] = sentinelMaster["ip"]
 	tags["sentinel_port"] = sentinelMaster["port"]
@@ -320,7 +326,10 @@ func convertSentinelReplicaOutput(
 	masterName string,
 	replica map[string]string,
 ) (map[string]string, map[string]interface{}, error) {
-	tags := globalTags
+	tags := make(map[string]string, len(globalTags))
+	for k, v := range globalTags {
+		tags[k] = v
+	}
 
 	tags["replica_ip"] = replica["ip"]
 	tags["replica_port"] = replica["port"]
@@ -383,7 +392,10 @@ func convertSentinelMastersOutput(
 	master map[string]string,
 	quorumErr error,
 ) (map[string]string, map[string]interface{}, error) {
-	tags := globalTags
+	tags := make(map[string]string, len(globalTags))
+	for k, v := range globalTags {
+		tags[k] = v
+	}
 
 	tags["master"] = master["name"]