From e6081f6d8fe99179bfa56cd6e5a185044fb2d6f7 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=91=A8=E5=80=AC=E8=B4=A4?=
 <14100340+zhou-zhuoxian@user.noreply.gitee.com>
Date: Fri, 8 Mar 2024 15:11:35 +0800
Subject: [PATCH] something rename

---
 .../mapper/connection/ConnectionMapper.java   |  3 ++
 .../console/mapper/storage/StoreMapper.java   |  2 +-
 ...oller.java => ConnectorConfigService.java} |  2 +-
 ...troller.java => RuntimeConfigService.java} |  2 +-
 ...ontroller.java => StoreConfigService.java} |  2 +-
 ...ontroller.java => TopicConfigService.java} |  2 +-
 ...Task.java => SyncConnectorConfigTask.java} | 11 ++--
 ...ceTask.java => SyncRuntimeConfigTask.java} | 12 +++--
 ...anceTask.java => SyncStoreConfigTask.java} | 54 ++++++++++---------
 ...anceTask.java => SyncTopicConfigTask.java} | 11 ++--
 .../connection/ConnectionDataService.java     |  7 ++-
 .../ConnectionDataServiceDatabaseImpl.java    |  9 ++++
 .../connector/ConnectorDataService.java       |  2 +-
 .../service/store/Impl/StoreServiceImpl.java  |  8 +--
 .../console/service/store/StoreService.java   |  4 +-
 .../console/service/topic/TopicService.java   |  3 ++
 .../service/topic/TopicServiceImpl.java       |  7 +++
 .../console/unit/store/TestStoreMapper.java   |  8 +--
 18 files changed, 96 insertions(+), 53 deletions(-)
 rename eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/instanceoperation/{ConnectorConfigController.java => ConnectorConfigService.java} (96%)
 rename eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/instanceoperation/{RuntimeConfigController.java => RuntimeConfigService.java} (96%)
 rename eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/instanceoperation/{StorageConfigController.java => StoreConfigService.java} (96%)
 rename eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/instanceoperation/{TopicConfigController.java => TopicConfigService.java} (96%)
 rename eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/synchronous/{SynchronousConnectorConfigDBToInstanceTask.java => SyncConnectorConfigTask.java} (92%)
 rename eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/synchronous/{SynchronousRuntimeConfigDBToInstanceTask.java => SyncRuntimeConfigTask.java} (93%)
 rename eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/synchronous/{SynchronousStorageConfigDBToInstanceTask.java => SyncStoreConfigTask.java} (54%)
 rename eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/synchronous/{SynchronousTopicConfigDBToInstanceTask.java => SyncTopicConfigTask.java} (93%)

diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/mapper/connection/ConnectionMapper.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/mapper/connection/ConnectionMapper.java
index fc6756a2..03dbfb05 100644
--- a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/mapper/connection/ConnectionMapper.java
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/mapper/connection/ConnectionMapper.java
@@ -35,6 +35,9 @@
 @Mapper
 public interface ConnectionMapper {
 
+    @Select("select COUNT(*) from connection where cluster_id=#{clusterId}")
+    Integer selectConnectionNumByCluster(ConnectionEntity connectionEntity);
+
     @Select("SELECT * FROM connection")
     List<ConnectionEntity> selectAll();
 
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/mapper/storage/StoreMapper.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/mapper/storage/StoreMapper.java
index 6ee1f509..0207903d 100644
--- a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/mapper/storage/StoreMapper.java
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/mapper/storage/StoreMapper.java
@@ -38,7 +38,7 @@ public interface StoreMapper {
         + "#{clusterId},#{storeId},#{storeType},#{host},#{runtimeId},#{topicList},#{diffType},#{port},#{jmxPort}"
         + ",#{startTimestamp},#{rack},#{status},#{endpointMap})")
     @Options(useGeneratedKeys = true, keyProperty = "id", keyColumn = "id")
-    void addStorage(StoreEntity storeEntity);
+    void addStore(StoreEntity storeEntity);
 
     @Update("UPDATE store SET is_delete=1 WHERE cluster_id=#{clusterId} AND store_id=#{storeId}")
     void deleteStoreByUnique(StoreEntity storeEntity);
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/instanceoperation/ConnectorConfigController.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/instanceoperation/ConnectorConfigService.java
similarity index 96%
rename from eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/instanceoperation/ConnectorConfigController.java
rename to eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/instanceoperation/ConnectorConfigService.java
index f0c433d6..ddecc476 100644
--- a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/instanceoperation/ConnectorConfigController.java
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/instanceoperation/ConnectorConfigService.java
@@ -25,7 +25,7 @@
 import org.springframework.stereotype.Service;
 
 @Service
-public class ConnectorConfigController {
+public class ConnectorConfigService {
 
     public List<ConfigEntity> getConnectorConfigFromInstance(Long clusterId, Long id) {
         return null;
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/instanceoperation/RuntimeConfigController.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/instanceoperation/RuntimeConfigService.java
similarity index 96%
rename from eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/instanceoperation/RuntimeConfigController.java
rename to eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/instanceoperation/RuntimeConfigService.java
index 4bf0e477..58903fa9 100644
--- a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/instanceoperation/RuntimeConfigController.java
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/instanceoperation/RuntimeConfigService.java
@@ -24,7 +24,7 @@
 import org.springframework.stereotype.Service;
 
 @Service
-public class RuntimeConfigController {
+public class RuntimeConfigService {
 
     public List<ConfigEntity> getRuntimeConfigFromInstance(Long clusterId, String host) {
         return null;
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/instanceoperation/StorageConfigController.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/instanceoperation/StoreConfigService.java
similarity index 96%
rename from eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/instanceoperation/StorageConfigController.java
rename to eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/instanceoperation/StoreConfigService.java
index 5269878b..1c653c78 100644
--- a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/instanceoperation/StorageConfigController.java
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/instanceoperation/StoreConfigService.java
@@ -24,7 +24,7 @@
 import org.springframework.stereotype.Service;
 
 @Service
-public class StorageConfigController {
+public class StoreConfigService {
 
     public List<ConfigEntity> getStorageConfigFromInstance(Long clusterId, String storeId) {
         return null;
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/instanceoperation/TopicConfigController.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/instanceoperation/TopicConfigService.java
similarity index 96%
rename from eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/instanceoperation/TopicConfigController.java
rename to eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/instanceoperation/TopicConfigService.java
index 1381d80a..821af5d4 100644
--- a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/instanceoperation/TopicConfigController.java
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/instanceoperation/TopicConfigService.java
@@ -24,7 +24,7 @@
 import org.springframework.stereotype.Service;
 
 @Service
-public class TopicConfigController {
+public class TopicConfigService {
 
     public List<ConfigEntity> getTopicConfigFromInstance(Long clusterId, String name) {
         return null;
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/synchronous/SynchronousConnectorConfigDBToInstanceTask.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/synchronous/SyncConnectorConfigTask.java
similarity index 92%
rename from eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/synchronous/SynchronousConnectorConfigDBToInstanceTask.java
rename to eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/synchronous/SyncConnectorConfigTask.java
index b6c08378..59351866 100644
--- a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/synchronous/SynchronousConnectorConfigDBToInstanceTask.java
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/synchronous/SyncConnectorConfigTask.java
@@ -20,7 +20,7 @@
 import org.apache.eventmesh.dashboard.console.entity.config.ConfigEntity;
 import org.apache.eventmesh.dashboard.console.entity.connector.ConnectorEntity;
 import org.apache.eventmesh.dashboard.console.service.config.ConfigService;
-import org.apache.eventmesh.dashboard.console.service.config.instanceoperation.ConnectorConfigController;
+import org.apache.eventmesh.dashboard.console.service.config.instanceoperation.ConnectorConfigService;
 import org.apache.eventmesh.dashboard.console.service.connector.ConnectorDataService;
 
 import java.util.List;
@@ -29,14 +29,17 @@
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+/**
+ * Synchronous DB To Instance
+ */
 @Service
-public class SynchronousConnectorConfigDBToInstanceTask {
+public class SyncConnectorConfigTask {
 
     @Autowired
     private ConnectorDataService connectorDataService;
 
     @Autowired
-    private ConnectorConfigController connectorConfigController;
+    private ConnectorConfigService connectorConfigService;
     @Autowired
     private ConfigService configService;
 
@@ -45,7 +48,7 @@ public void synchronousConnectorConfig(Long clusterId) {
         for (ConnectorEntity connectorEntity : connectorEntities) {
 
             ConcurrentHashMap<String, String> connectorConfigMapFromInstance = this.configListToMap(
-                connectorConfigController.getConnectorConfigFromInstance(clusterId, connectorEntity.getId()));
+                connectorConfigService.getConnectorConfigFromInstance(clusterId, connectorEntity.getId()));
 
             ConfigEntity configEntity = this.getConfigEntityBelongInstance(clusterId, connectorEntity.getId());
 
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/synchronous/SynchronousRuntimeConfigDBToInstanceTask.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/synchronous/SyncRuntimeConfigTask.java
similarity index 93%
rename from eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/synchronous/SynchronousRuntimeConfigDBToInstanceTask.java
rename to eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/synchronous/SyncRuntimeConfigTask.java
index 47eb2a51..51ee24f1 100644
--- a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/synchronous/SynchronousRuntimeConfigDBToInstanceTask.java
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/synchronous/SyncRuntimeConfigTask.java
@@ -20,7 +20,7 @@
 import org.apache.eventmesh.dashboard.console.entity.config.ConfigEntity;
 import org.apache.eventmesh.dashboard.console.entity.runtime.RuntimeEntity;
 import org.apache.eventmesh.dashboard.console.service.config.ConfigService;
-import org.apache.eventmesh.dashboard.console.service.config.instanceoperation.RuntimeConfigController;
+import org.apache.eventmesh.dashboard.console.service.config.instanceoperation.RuntimeConfigService;
 import org.apache.eventmesh.dashboard.console.service.runtime.RuntimeService;
 
 import java.util.List;
@@ -30,14 +30,18 @@
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+/**
+ * Synchronous DB To Instance
+ */
+
 @Service
-public class SynchronousRuntimeConfigDBToInstanceTask {
+public class SyncRuntimeConfigTask {
 
     @Autowired
     private RuntimeService runtimeService;
 
     @Autowired
-    private RuntimeConfigController runtimeConfigController;
+    private RuntimeConfigService runtimeConfigService;
 
     @Autowired
     private ConfigService configService;
@@ -47,7 +51,7 @@ public void synchronousRuntimeConfig(Long clusterId) {
         for (RuntimeEntity runtimeEntity : runtimeEntityList) {
 
             ConcurrentHashMap<String, String> runtimeConfigMapFromInstance = this.configListToMap(
-                runtimeConfigController.getRuntimeConfigFromInstance(clusterId, runtimeEntity.getHost()));
+                runtimeConfigService.getRuntimeConfigFromInstance(clusterId, runtimeEntity.getHost()));
 
             ConfigEntity configEntity = this.getConfigEntityBelongInstance(clusterId, runtimeEntity.getId());
 
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/synchronous/SynchronousStorageConfigDBToInstanceTask.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/synchronous/SyncStoreConfigTask.java
similarity index 54%
rename from eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/synchronous/SynchronousStorageConfigDBToInstanceTask.java
rename to eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/synchronous/SyncStoreConfigTask.java
index 68bab825..f5235b0a 100644
--- a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/synchronous/SynchronousStorageConfigDBToInstanceTask.java
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/synchronous/SyncStoreConfigTask.java
@@ -18,10 +18,10 @@
 package org.apache.eventmesh.dashboard.console.service.config.synchronous;
 
 import org.apache.eventmesh.dashboard.console.entity.config.ConfigEntity;
-import org.apache.eventmesh.dashboard.console.entity.runtime.RuntimeEntity;
+import org.apache.eventmesh.dashboard.console.entity.storage.StoreEntity;
 import org.apache.eventmesh.dashboard.console.service.config.ConfigService;
-import org.apache.eventmesh.dashboard.console.service.config.instanceoperation.StorageConfigController;
-import org.apache.eventmesh.dashboard.console.service.runtime.RuntimeService;
+import org.apache.eventmesh.dashboard.console.service.config.instanceoperation.StoreConfigService;
+import org.apache.eventmesh.dashboard.console.service.store.StoreService;
 
 import java.util.List;
 import java.util.concurrent.ConcurrentHashMap;
@@ -29,56 +29,60 @@
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+/**
+ * Synchronous DB To Instance
+ */
+
 @Service
-public class SynchronousStorageConfigDBToInstanceTask {
+public class SyncStoreConfigTask {
 
     @Autowired
-    private RuntimeService runtimeService;
+    private StoreService storeService;
 
     @Autowired
-    private StorageConfigController storageConfigController;
+    private StoreConfigService storeConfigService;
 
     @Autowired
     private ConfigService configService;
 
-    public void synchronousRuntimeConfig(Long clusterId) {
-        List<RuntimeEntity> runtimeEntityList = runtimeService.getRuntimeByClusterId(clusterId);
-        for (RuntimeEntity runtimeEntity : runtimeEntityList) {
+    public void synchronousStoreConfig(Long clusterId) {
+        List<StoreEntity> storeEntityList = storeService.selectStoreByCluster(clusterId);
+        for (StoreEntity storeEntity : storeEntityList) {
 
-            ConcurrentHashMap<String, String> runtimeConfigMapFromInstance = this.configListToMap(
-                storageConfigController.getStorageConfigFromInstance(clusterId, runtimeEntity.getHost()));
+            ConcurrentHashMap<String, String> storeConfigMapFromInstance = this.configListToMap(
+                storeConfigService.getStorageConfigFromInstance(clusterId, storeEntity.getHost()));
 
-            ConfigEntity configEntity = this.getConfigEntityBelongInstance(clusterId, runtimeEntity.getId());
+            ConfigEntity configEntity = this.getConfigEntityBelongInstance(clusterId, storeEntity.getId());
 
-            ConcurrentHashMap<String, String> runtimeConfigMapFromDb = this.configListToMap(configService.selectByInstanceId(configEntity));
+            ConcurrentHashMap<String, String> storeConfigMapFromDb = this.configListToMap(configService.selectByInstanceId(configEntity));
 
             ConcurrentHashMap<String, String> updateConfigMap = new ConcurrentHashMap<>();
 
-            runtimeConfigMapFromInstance.entrySet().forEach(n -> {
-                if (runtimeConfigMapFromDb.remove(n.getKey(), n.getValue())) {
-                    runtimeConfigMapFromInstance.remove(n.getKey());
+            storeConfigMapFromInstance.entrySet().forEach(n -> {
+                if (storeConfigMapFromDb.remove(n.getKey(), n.getValue())) {
+                    storeConfigMapFromInstance.remove(n.getKey());
                 }
-                if (runtimeConfigMapFromDb.get(n.getKey()) != null) {
-                    updateConfigMap.put(n.getKey(), runtimeConfigMapFromDb.get(n.getKey()));
-                    runtimeConfigMapFromInstance.remove(n.getKey());
-                    runtimeConfigMapFromDb.remove(n.getKey());
+                if (storeConfigMapFromDb.get(n.getKey()) != null) {
+                    updateConfigMap.put(n.getKey(), storeConfigMapFromDb.get(n.getKey()));
+                    storeConfigMapFromInstance.remove(n.getKey());
+                    storeConfigMapFromDb.remove(n.getKey());
                 }
             });
-            //add  runtimeConfigMapFromDb
+            //add  storeConfigMapFromDb
 
             //update  updateConfigMap
 
-            //delete runtimeConfigMapFromInstance
+            //delete storeConfigMapFromInstance
         }
     }
 
     private ConcurrentHashMap<String, String> configListToMap(List<ConfigEntity> configEntityList) {
-        ConcurrentHashMap<String, String> runtimeConfigMap = new ConcurrentHashMap<>();
+        ConcurrentHashMap<String, String> storeConfigMap = new ConcurrentHashMap<>();
         configEntityList.forEach(n -> {
-                runtimeConfigMap.put(n.getConfigName(), n.getConfigValue());
+                storeConfigMap.put(n.getConfigName(), n.getConfigValue());
             }
         );
-        return runtimeConfigMap;
+        return storeConfigMap;
     }
 
 
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/synchronous/SynchronousTopicConfigDBToInstanceTask.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/synchronous/SyncTopicConfigTask.java
similarity index 93%
rename from eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/synchronous/SynchronousTopicConfigDBToInstanceTask.java
rename to eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/synchronous/SyncTopicConfigTask.java
index 469786e6..eada0b97 100644
--- a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/synchronous/SynchronousTopicConfigDBToInstanceTask.java
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/synchronous/SyncTopicConfigTask.java
@@ -20,7 +20,7 @@
 import org.apache.eventmesh.dashboard.console.entity.config.ConfigEntity;
 import org.apache.eventmesh.dashboard.console.entity.topic.TopicEntity;
 import org.apache.eventmesh.dashboard.console.service.config.ConfigService;
-import org.apache.eventmesh.dashboard.console.service.config.instanceoperation.TopicConfigController;
+import org.apache.eventmesh.dashboard.console.service.config.instanceoperation.TopicConfigService;
 import org.apache.eventmesh.dashboard.console.service.topic.TopicService;
 
 import java.util.List;
@@ -29,15 +29,18 @@
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+/**
+ * Synchronous DB To Instance
+ */
 
 @Service
-public class SynchronousTopicConfigDBToInstanceTask {
+public class SyncTopicConfigTask {
 
     @Autowired
     private TopicService topicService;
 
     @Autowired
-    private TopicConfigController topicConfigController;
+    private TopicConfigService topicConfigService;
 
     @Autowired
     private ConfigService configService;
@@ -47,7 +50,7 @@ public void synchronousTopicConfig(Long clusterId) {
         for (TopicEntity topicEntity : topicEntityList) {
 
             ConcurrentHashMap<String, String> topicConfigMapFromInstance = this.configListToMap(
-                topicConfigController.getTopicConfigFromInstance(clusterId, topicEntity.getTopicName()));
+                topicConfigService.getTopicConfigFromInstance(clusterId, topicEntity.getTopicName()));
 
             ConfigEntity configEntity = this.getConfigEntityBelongInstance(clusterId, topicEntity.getId());
 
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/connection/ConnectionDataService.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/connection/ConnectionDataService.java
index 05361eb2..e4db317d 100644
--- a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/connection/ConnectionDataService.java
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/connection/ConnectionDataService.java
@@ -22,10 +22,15 @@
 import java.util.List;
 
 /**
- * Service providing data of connections.
+ * Service providing ConnectionEntity data.
  */
 public interface ConnectionDataService {
+
+    Integer selectConnectionNumByCluster(Long clusterId);
+
     List<ConnectionEntity> getAllConnections();
 
+    List<ConnectionEntity> getAllConnectionsByClusterId(Long clusterId);
+
     void replaceAllConnections(List<ConnectionEntity> connectionEntityList);
 }
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/connection/impl/ConnectionDataServiceDatabaseImpl.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/connection/impl/ConnectionDataServiceDatabaseImpl.java
index cf22a831..b8c66348 100644
--- a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/connection/impl/ConnectionDataServiceDatabaseImpl.java
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/connection/impl/ConnectionDataServiceDatabaseImpl.java
@@ -36,6 +36,8 @@ public class ConnectionDataServiceDatabaseImpl implements ConnectionDataService
     @Autowired
     private ConnectionMapper connectionMapper;
 
+
+    @Override
     public List<ConnectionEntity> getAllConnectionsByClusterId(Long clusterId) {
         ConnectionEntity connectionEntity = new ConnectionEntity();
         connectionEntity.setClusterId(clusterId);
@@ -43,6 +45,13 @@ public List<ConnectionEntity> getAllConnectionsByClusterId(Long clusterId) {
     }
 
 
+    @Override
+    public Integer selectConnectionNumByCluster(Long clusterId) {
+        ConnectionEntity connectionEntity = new ConnectionEntity();
+        connectionEntity.setClusterId(clusterId);
+        return connectionMapper.selectConnectionNumByCluster(connectionEntity);
+    }
+
     @Override
     public List<ConnectionEntity> getAllConnections() {
         return connectionMapper.selectAll();
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/connector/ConnectorDataService.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/connector/ConnectorDataService.java
index b56b450b..a32bbf9e 100644
--- a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/connector/ConnectorDataService.java
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/connector/ConnectorDataService.java
@@ -22,7 +22,7 @@
 import java.util.List;
 
 /**
- * Service providing data of connectors.
+ * Service providing ConnectorEntity data.
  */
 public interface ConnectorDataService {
 
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/store/Impl/StoreServiceImpl.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/store/Impl/StoreServiceImpl.java
index c4f65ef4..4e4469bb 100644
--- a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/store/Impl/StoreServiceImpl.java
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/store/Impl/StoreServiceImpl.java
@@ -33,8 +33,8 @@ public class StoreServiceImpl implements StoreService {
     private StoreMapper storeMapper;
 
     @Override
-    public void addStorage(StoreEntity storeEntity) {
-        storeMapper.addStorage(storeEntity);
+    public void addStore(StoreEntity storeEntity) {
+        storeMapper.addStore(storeEntity);
     }
 
     @Override
@@ -43,7 +43,9 @@ public void deleteStoreByUnique(StoreEntity storeEntity) {
     }
 
     @Override
-    public List<StoreEntity> selectStoreByCluster(StoreEntity storeEntity) {
+    public List<StoreEntity> selectStoreByCluster(Long clusterId) {
+        StoreEntity storeEntity = new StoreEntity();
+        storeEntity.setClusterId(clusterId);
         return storeMapper.selectStoreByCluster(storeEntity);
     }
 
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/store/StoreService.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/store/StoreService.java
index 24a60fd5..9fdaf4f8 100644
--- a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/store/StoreService.java
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/store/StoreService.java
@@ -26,11 +26,11 @@
  */
 public interface StoreService {
 
-    void addStorage(StoreEntity storeEntity);
+    void addStore(StoreEntity storeEntity);
 
     void deleteStoreByUnique(StoreEntity storeEntity);
 
-    List<StoreEntity> selectStoreByCluster(StoreEntity storeEntity);
+    List<StoreEntity> selectStoreByCluster(Long clusterId);
 
     void updateStoreByUnique(StoreEntity storeEntity);
 }
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/topic/TopicService.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/topic/TopicService.java
index bee4de72..2f8696da 100644
--- a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/topic/TopicService.java
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/topic/TopicService.java
@@ -25,6 +25,9 @@
  * Service about Topic
  */
 public interface TopicService {
+
+    Integer selectTopicNumByCluster(Long clusterId);
+
     List<TopicEntity> getTopicList(TopicEntity topicEntity);
 
     void addTopic(TopicEntity topicEntity);
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/topic/TopicServiceImpl.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/topic/TopicServiceImpl.java
index 0bd774d3..444de271 100644
--- a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/topic/TopicServiceImpl.java
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/topic/TopicServiceImpl.java
@@ -37,6 +37,13 @@ public class TopicServiceImpl implements TopicService {
     OprGroupMemberMapper oprGroupMemberMapper;
 
 
+    @Override
+    public Integer selectTopicNumByCluster(Long clusterId) {
+        TopicEntity topicEntity = new TopicEntity();
+        topicEntity.setClusterId(clusterId);
+        return topicMapper.selectTopicNumByCluster(topicEntity);
+    }
+
     @Override
     public List<TopicEntity> getTopicList(TopicEntity topicEntity) {
         return topicMapper.getTopicList(topicEntity);
diff --git a/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/unit/store/TestStoreMapper.java b/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/unit/store/TestStoreMapper.java
index 77e99186..5876f828 100644
--- a/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/unit/store/TestStoreMapper.java
+++ b/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/unit/store/TestStoreMapper.java
@@ -27,8 +27,8 @@ public void testAddStore() {
             new StoreEntity(null, 1l, 2, "rocketmq", "run1", 1l, "n,j", (short) -1, 1098, 1099, "nothing", (short) 1, null, null, "nothing", 1l);
         StoreEntity storeEntity1 =
             new StoreEntity(null, 1l, 1, "rocketmq", "run1", 1l, "n,j", (short) -1, 1098, 1099, "nothing", (short) 1, null, null, "nothing", 1l);
-        storeMapper.addStorage(storeEntity);
-        storeMapper.addStorage(storeEntity1);
+        storeMapper.addStore(storeEntity);
+        storeMapper.addStore(storeEntity1);
         List<StoreEntity> storeEntities = storeMapper.selectStoreByCluster(storeEntity);
         storeEntities.forEach(n -> {
             n.setUpdateTime(null);
@@ -42,7 +42,7 @@ public void testAddStore() {
     public void testDeleteStoreByUnique() {
         StoreEntity storeEntity =
             new StoreEntity(null, 1l, 2, "rocketmq", "run1", 1l, "n,j", (short) -1, 1098, 1099, "nothing", (short) 1, null, null, "nothing", 1l);
-        storeMapper.addStorage(storeEntity);
+        storeMapper.addStore(storeEntity);
         storeMapper.deleteStoreByUnique(storeEntity);
         List<StoreEntity> storeEntities = storeMapper.selectStoreByCluster(storeEntity);
         Assert.assertEquals(storeEntities.size(), 0);
@@ -52,7 +52,7 @@ public void testDeleteStoreByUnique() {
     public void testUpdateStoreByUnique() {
         StoreEntity storeEntity =
             new StoreEntity(null, 1l, 2, "rocketmq", "run1", 1l, "n,j", (short) -1, 1098, 1099, "nothing", (short) 1, null, null, "nothing", 1l);
-        storeMapper.addStorage(storeEntity);
+        storeMapper.addStore(storeEntity);
         storeEntity.setStatus((short) 5);
         storeMapper.updateStoreByUnique(storeEntity);
         List<StoreEntity> storeEntities = storeMapper.selectStoreByCluster(storeEntity);