dm: add dm hosts to node_exporter list (#1654)

AstroProfundis · web-flow · commit 77f54c2bcf0b · 2021-12-06T16:51:56.000+08:00
diff --git a/pkg/cluster/spec/monitoring.go b/pkg/cluster/spec/monitoring.go
@@ -271,6 +271,7 @@ func (i *MonitorInstance) InitConfig(
 		for i := 0; i < servers.Len(); i++ {
 			master := reflect.Indirect(servers.Index(i))
 			host, port := master.FieldByName("Host").String(), master.FieldByName("Port").Int()
+			uniqueHosts.Insert(host)
 			cfig.AddDMMaster(host, uint64(port))
 		}
 	}
@@ -279,6 +280,7 @@ func (i *MonitorInstance) InitConfig(
 		for i := 0; i < servers.Len(); i++ {
 			worker := reflect.Indirect(servers.Index(i))
 			host, port := worker.FieldByName("Host").String(), worker.FieldByName("Port").Int()
+			uniqueHosts.Insert(host)
 			cfig.AddDMWorker(host, uint64(port))
 		}
 	}

Original file line number	Diff line number	Diff line change
`@@ -271,6 +271,7 @@ func (i *MonitorInstance) InitConfig(`
`271`	`271`	`for i := 0; i < servers.Len(); i++ {`
`272`	`272`	`master := reflect.Indirect(servers.Index(i))`
`273`	`273`	`host, port := master.FieldByName("Host").String(), master.FieldByName("Port").Int()`
	`274`	`+ uniqueHosts.Insert(host)`
`274`	`275`	`cfig.AddDMMaster(host, uint64(port))`
`275`	`276`	`}`
`276`	`277`	`}`
`@@ -279,6 +280,7 @@ func (i *MonitorInstance) InitConfig(`
`279`	`280`	`for i := 0; i < servers.Len(); i++ {`
`280`	`281`	`worker := reflect.Indirect(servers.Index(i))`
`281`	`282`	`host, port := worker.FieldByName("Host").String(), worker.FieldByName("Port").Int()`
	`283`	`+ uniqueHosts.Insert(host)`
`282`	`284`	`cfig.AddDMWorker(host, uint64(port))`
`283`	`285`	`}`
`284`	`286`	`}`