(rocketmq-dashboard) branch rocketmq-studio updated: [ISSUE #1568] Report actual healthy cluster count (#1569)

[lizhimin]

This is an automated email from the ASF dual-hosted git repository.

lizhimins pushed a commit to branch rocketmq-studio
in repository https://gitbox.apache.org/repos/asf/rocketmq-dashboard.git


The following commit(s) were added to refs/heads/rocketmq-studio by this push:
     new bb998354 [ISSUE #1568] Report actual healthy cluster count (#1569)
bb998354 is described below

commit bb9983546ffbd8958ba096989b4e7ba9e4e34ef3
Author: youngkermit8-coder <youngkerm...@gmail.com>
AuthorDate: Tue Aug 11 20:24:32 2026 +0800

    [ISSUE #1568] Report actual healthy cluster count (#1569)
    
    Signed-off-by: youngkermit8-coder <youngkerm...@gmail.com>
---
 .../rocketmq/studio/provider/apache/RocketMQDashboardProvider.java  | 6 +++++-
 .../studio/provider/apache/RocketMQDashboardProviderTest.java       | 3 +++
 2 files changed, 8 insertions(+), 1 deletion(-)

diff --git 
a/server/src/main/java/org/apache/rocketmq/studio/provider/apache/RocketMQDashboardProvider.java
 
b/server/src/main/java/org/apache/rocketmq/studio/provider/apache/RocketMQDashboardProvider.java
index cd9fd14d..15488981 100644
--- 
a/server/src/main/java/org/apache/rocketmq/studio/provider/apache/RocketMQDashboardProvider.java
+++ 
b/server/src/main/java/org/apache/rocketmq/studio/provider/apache/RocketMQDashboardProvider.java
@@ -289,9 +289,13 @@ public class RocketMQDashboardProvider implements 
DashboardProvider {
 
         long messagesPerSecond = tpsIn + tpsOut;
 
+        int healthyClusters = Math.toIntExact(clusters.stream()
+                .filter(cluster -> cluster.getStatus() == 
ClusterStatus.healthy)
+                .count());
+
         DashboardStatsVO stats = DashboardStatsVO.builder()
                 .totalClusters(totalClusters)
-                .healthyClusters(totalClusters)
+                .healthyClusters(healthyClusters)
                 .totalBrokers(totalBrokers)
                 .totalProxies(0)
                 .totalNameServers(0)
diff --git 
a/server/src/test/java/org/apache/rocketmq/studio/provider/apache/RocketMQDashboardProviderTest.java
 
b/server/src/test/java/org/apache/rocketmq/studio/provider/apache/RocketMQDashboardProviderTest.java
index 9dbcb2b6..c2bb4b54 100644
--- 
a/server/src/test/java/org/apache/rocketmq/studio/provider/apache/RocketMQDashboardProviderTest.java
+++ 
b/server/src/test/java/org/apache/rocketmq/studio/provider/apache/RocketMQDashboardProviderTest.java
@@ -60,6 +60,7 @@ class RocketMQDashboardProviderTest {
         assertThat(dashboard.getClusters()).hasSize(1);
         
assertThat(dashboard.getClusters().get(0).getVersion()).isEqualTo("V5_3_3");
         
assertThat(dashboard.getClusters().get(0).getType()).isEqualTo(ClusterType.V5_PROXY_CLUSTER);
+        assertThat(dashboard.getStats().getHealthyClusters()).isEqualTo(1);
         verify(adminExt, times(1)).fetchBrokerRuntimeStats("10.0.0.11:10911");
     }
 
@@ -162,6 +163,8 @@ class RocketMQDashboardProviderTest {
         assertThat(dashboard.getClusters()).singleElement()
                 .extracting(cluster -> cluster.getStatus())
                 .isEqualTo(ClusterStatus.warning);
+        assertThat(dashboard.getStats().getTotalClusters()).isEqualTo(1);
+        assertThat(dashboard.getStats().getHealthyClusters()).isZero();
     }
 
     @Test