feat: modify the condition for cluster health

emqx · Aug 8, 2023 · 54abee3 · 54abee3
1 parent a1da2a4
commit 54abee3
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/client/client_4.x.go b/client/client_4.x.go
@@ -89,14 +89,14 @@ func (n *cluster4x) getClusterStatus() (cluster collector.ClusterStatus, err err
 		return
 	}
 
-	cluster.Status = healthy
+	cluster.Status = unhealthy
 	cluster.NodeUptime = make(map[string]int64)
 	cluster.NodeMaxFDs = make(map[string]int)
 	cluster.CPULoads = make(map[string]collector.CPULoad)
 
 	for _, data := range resp.Data {
-		if data.NodeStatus != "Running" {
-			cluster.Status = unhealthy
+		if data.NodeStatus == "Running" {
+			cluster.Status = healthy
 		}
 		nodeName := cutNodeName(data.Node)
 		cluster.NodeUptime[nodeName] = parseUptimeFor4x(data.Uptime)

diff --git a/client/client_5.x.go b/client/client_5.x.go
@@ -65,14 +65,14 @@ func (n *cluster5x) getClusterStatus() (cluster collector.ClusterStatus, err err
 		return
 	}
 
-	cluster.Status = healthy
+	cluster.Status = unhealthy
 	cluster.NodeUptime = make(map[string]int64)
 	cluster.NodeMaxFDs = make(map[string]int)
 	cluster.CPULoads = make(map[string]collector.CPULoad)
 
 	for _, data := range resp {
-		if data.NodeStatus != "running" {
-			cluster.Status = unhealthy
+		if data.NodeStatus == "running" {
+			cluster.Status = healthy
 		}
 		nodeName := cutNodeName(data.Node)
 		cluster.NodeUptime[nodeName] = data.Uptime / 1000