fix(rabbitmq): fix concurrent map error

GuanceCloud · Sep 23, 2024 · 9463952 · 9463952
1 parent ab973f8
commit 9463952
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/internal/plugins/inputs/rabbitmq/input.go b/internal/plugins/inputs/rabbitmq/input.go
@@ -193,7 +193,9 @@ type MetricFunc func(n *Input)
 
 func (ipt *Input) getMetric() {
 	ipt.start = time.Now()
-	getFunc := []MetricFunc{getOverview, getNode, getQueues, getExchange}
+	// get overview first, to get cluster name
+	getOverview(ipt)
+	getFunc := []MetricFunc{getNode, getQueues, getExchange}
 	g := goroutine.NewGroup(goroutine.Option{Name: "inputs_rabbitmq"})
 	for _, v := range getFunc {
 		func(gf MetricFunc) {