fix(core):1. 重构 同步模块 2. 重构 remote 模块

README.md

@@ -85,4 +85,68 @@ docker build -t yourname/eventmesh-dashboard -f docker/Dockerfile .
 
 ```
 docker run -d --name eventmesh-dashboard -p 8080:8080 yourname/eventmesh-dashboard
-```
+```
+
+
+1. 注册中心的 创建，添加，删除， 扩容，缩容。
+2. runtime  创建，添加，删除， 扩容，缩容。
+3. 连接的 创建 ， 添加，删除，扩容，缩容。
+4. rocketmq 的 创建，添加，删除。
+
+### 基础页面
+1. 用户登录页面
+
+### 业务方面页面
+1. 用户欢迎页面
+   2. 基础统计信息
+   3. 常用 集群，关注集群
+   4. 事件
+2. eventmesh 集群
+   1. runtime
+      1. overview
+      2. 列表页面
+         1. 详情
+         2. topic
+         3. group
+         4. config
+      3. runtime操作
+   2. 注册中心
+      3. 列表
+      4. 添加注册中心
+      5. 删除注册中心
+      6. 
+   3. topic
+   4. 消费组
+   5. 安全
+   6. 消息
+      7. 消息生产与消费
+3. eventmesh 注册中心
+4. eventmesh runtime
+5. 
+
+5. 集群
+   1. 集群创建
+      1. eventmesh  and rocketmq
+         1. runtime 的 自动创建
+         2. 注册中心的创建
+         3. eventmesh 的 自动创建
+      2. 手动创建
+         1. 注册中心
+      3. k8s创建
+         1. 整体集群创建
+         2. 单个集群创建
+   2. 集群暂停
+      1. 需要解除依赖，才能暂停
+   3. 集群删除
+      1. 需要解除依赖，才能暂停
+   4. 集群的关联
+6. runtime group topic
+   1. 创建
+      1. 手动创建
+      2. 自动创建
+   2. 删除
+   3. 修改
+   4. config
+   5. 关联
+7. 集群元数据复制并创建
+8. 集群恢复

eventmesh-dashboard-common/pom.xml

@@ -26,7 +26,6 @@
         <version>0.0.1-SNAPSHOT</version>
     </parent>
 
-    <groupId>org.apache.eventmesh.dashboard.common</groupId>
     <artifactId>eventmesh-dashboard-common</artifactId>
 
     <properties>

eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/difference/topic/StorageTopicDifference.java

@@ -0,0 +1,8 @@
+package org.apache.eventmesh.dashboard.common.difference.topic;
+
+public class StorageTopicDifference {
+
+
+
+
+}

eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/enums/ClusterTrusteeshipType.java

@@ -0,0 +1,15 @@
+package org.apache.eventmesh.dashboard.common.enums;
+
+public enum ClusterTrusteeshipType {
+
+    //
+    FIRE_AND_FORGET_TRUSTEESHIP,
+
+    // 发现 or 长时间没有上线 cluster sync db
+    TRUSTEESHIP,
+
+    REVERSE,
+
+    NO_TRUSTEESHIP;
+
+}

eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/enums/ClusterType.java

@@ -0,0 +1,117 @@
+package org.apache.eventmesh.dashboard.common.enums;
+
+import lombok.Getter;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Objects;
+
+public enum ClusterType {
+
+    DEFAULT(1),
+
+    EVENTMESH(20),
+
+    STORAGE(21),
+
+    DEFAULT_TYPE_NAME(1),
+
+    CLUSTER(1),
+
+    META(2),
+
+    RUNTIME(3),
+
+
+    RUNTIME_EVENT_RUNTIME(ClusterType.META.code + 1),
+
+    RUNTIME_ROCKETMQ_BROKER(ClusterType.META.code + 31),
+
+    META_TYPE_ETCD(ClusterType.META.code + 1),
+
+    META_TYPE_NACOS(ClusterType.META.code + 2),
+
+    META_TYPE_ROCKETMQ_NAMESERVER(ClusterType.META.code + 31),
+
+
+    EVENTMESH_CLUSTER(EVENTMESH, EVENTMESH, CLUSTER, DEFAULT, RemotingType.EVENT_MESH_RUNTIME),
+
+    EVENTMESH_RUNTIME(EVENTMESH, EVENTMESH, RUNTIME, DEFAULT, RemotingType.EVENT_MESH_RUNTIME),
+
+    EVENTMESH_META_ETCD(EVENTMESH, EVENTMESH, META, META_TYPE_ETCD, RemotingType.EVENT_MESH_ETCD),
+
+    EVENTMESH_META_NACOS(EVENTMESH, EVENTMESH, META, META_TYPE_NACOS, RemotingType.EVENT_MESH_NACOS),
+
+    STORAGE_ROCKETMQ(ClusterType.STORAGE.code + 1),
+
+    STORAGE_ROCKETMQ_CLUSTER(STORAGE, STORAGE_ROCKETMQ, CLUSTER, DEFAULT, RemotingType.ROCKETMQ),
+
+    STORAGE_ROCKETMQ_NAMESERVER(STORAGE, STORAGE_ROCKETMQ, META, DEFAULT, RemotingType.ROCKETMQ_NAMESERVER),
+
+    STORAGE_ROCKETMQ_BROKER(STORAGE, STORAGE_ROCKETMQ, RUNTIME, DEFAULT, RemotingType.ROCKETMQ);
+
+
+    public static final List<ClusterType> STORAGE_TYPES = getStorage();
+
+
+    private static List<ClusterType> getStorage(){
+        List<ClusterType> list = new ArrayList<>();
+        for(ClusterType clusterType : ClusterType.values()){
+            if(Objects.equals(clusterType.eventmeshNodeType , ClusterType.STORAGE) && Objects.equals(clusterType.assemblyNodeType , ClusterType.CLUSTER)) {
+                list.add(clusterType);
+            }
+        }
+        return list;
+    }
+
+
+    @Getter
+    private ClusterType eventmeshNodeType;
+
+    @Getter
+    private ClusterType assemblyName;
+
+    @Getter
+    private ClusterType assemblyNodeType;
+
+    @Getter
+    private ClusterType assemblyBusiness;
+
+    @Getter
+    private RemotingType remotingType;
+
+    @Getter
+    private int code;
+
+
+
+    ClusterType(int code) {
+        this.code = code;
+    }
+
+    ClusterType(ClusterType eventmeshNodeType, ClusterType assemblyName, ClusterType assemblyNodeType, ClusterType assemblyBusiness, RemotingType remotingType) {
+        this.eventmeshNodeType = eventmeshNodeType;
+        this.assemblyName = assemblyName;
+        this.assemblyNodeType = assemblyNodeType;
+        this.assemblyBusiness = assemblyBusiness;
+        this.remotingType = remotingType;
+    }
+
+
+    public boolean isMainCluster(){
+        return Objects.equals(this, ClusterType.EVENTMESH_CLUSTER ) || Objects.equals(this.assemblyNodeType, ClusterType.CLUSTER );
+    }
+
+    public boolean isFirstLayer() {
+        return Objects.equals(this, ClusterType.EVENTMESH_META_NACOS)
+                || Objects.equals(this, ClusterType.EVENTMESH_META_ETCD)
+                || Objects.equals(this, ClusterType.EVENTMESH_RUNTIME)
+                || Objects.equals(this.getAssemblyNodeType(), ClusterType.CLUSTER);
+    }
+
+    public boolean isSecondFloor() {
+        return Objects.equals(eventmeshNodeType, ClusterType.STORAGE) ? (Objects.equals(assemblyNodeType, ClusterType.RUNTIME)
+                || Objects.equals(assemblyNodeType, ClusterType.META)) : false;
+    }
+
+}

eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/enums/RemotingType.java

@@ -0,0 +1,20 @@
+package org.apache.eventmesh.dashboard.common.enums;
+
+public enum RemotingType {
+
+    NOT,
+
+    META,
+
+    STORAGE,
+
+    EVENT_MESH_RUNTIME,
+
+    EVENT_MESH_NACOS,
+
+    EVENT_MESH_ETCD,
+
+    ROCKETMQ,
+    ROCKETMQ_NAMESERVER
+    ;
+}

eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/metadata/AclMetadata.java

@@ -18,8 +18,10 @@
 package org.apache.eventmesh.dashboard.common.model.metadata;
 
 import lombok.Data;
+import lombok.EqualsAndHashCode;
 
 @Data
+@EqualsAndHashCode(callSuper = true)
 public class AclMetadata extends MetadataConfig {
 
     private Long clusterId;

eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/metadata/ClientMetadata.java

@@ -18,8 +18,10 @@
 package org.apache.eventmesh.dashboard.common.model.metadata;
 
 import lombok.Data;
+import lombok.EqualsAndHashCode;
 
 @Data
+@EqualsAndHashCode(callSuper = true)
 public class ClientMetadata extends MetadataConfig {
 
     private String name;

eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/metadata/ClusterMetadata.java

@@ -17,15 +17,22 @@
 
 package org.apache.eventmesh.dashboard.common.model.metadata;
 
-import org.apache.eventmesh.dashboard.common.enums.StoreType;
-
 import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.apache.eventmesh.dashboard.common.enums.ClusterTrusteeshipType;
+import org.apache.eventmesh.dashboard.common.enums.ClusterType;
+import org.apache.eventmesh.dashboard.common.enums.StoreType;
 
 @Data
+@EqualsAndHashCode(callSuper = true)
 public class ClusterMetadata extends MetadataConfig {
 
     private String clusterName;
 
+    private ClusterTrusteeshipType trusteeshipType;
+
+    private ClusterType clusterType;
+
     private String registryAddress;
 
     private String bootstrapServers;

eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/metadata/ClusterRelationshipMetadata.java

@@ -0,0 +1,21 @@
+package org.apache.eventmesh.dashboard.common.model.metadata;
+
+import lombok.Data;
+import org.apache.eventmesh.dashboard.common.enums.ClusterType;
+
+@Data
+public class ClusterRelationshipMetadata extends MetadataConfig {
+
+    private ClusterType clusterType;
+
+    private Long relationshipId;
+
+    private ClusterType relationshipType;
+
+    private Integer status;
+
+    @Override
+    public String getUnique() {
+        return null;
+    }
+}

eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/metadata/ConfigMetadata.java

@@ -18,11 +18,13 @@
 package org.apache.eventmesh.dashboard.common.model.metadata;
 
 import lombok.Data;
+import lombok.EqualsAndHashCode;
 
 /**
  * Config metadata is a piece of config with key and value
  */
 @Data
+@EqualsAndHashCode(callSuper = true)
 public class ConfigMetadata extends MetadataConfig {
 
     /**

eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/metadata/GroupMetadata.java

@@ -18,8 +18,10 @@
 package org.apache.eventmesh.dashboard.common.model.metadata;
 
 import lombok.Data;
+import lombok.EqualsAndHashCode;
 
 @Data
+@EqualsAndHashCode(callSuper = true)
 public class GroupMetadata extends MetadataConfig {
 
     private String name;

eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/metadata/MetadataConfig.java

@@ -38,6 +38,9 @@ public abstract class MetadataConfig {
     //cluster id in database
     private Long clusterId;
 
+
+    private Long id;
+
     /**
      * @return A string that is unique to the source, usually a url
      */

eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/metadata/RegistryMetadata.java

@@ -17,6 +17,7 @@
 
 package org.apache.eventmesh.dashboard.common.model.metadata;
 
+import lombok.EqualsAndHashCode;
 import org.apache.eventmesh.dashboard.common.enums.RecordStatus;
 
 import lombok.Data;
@@ -26,6 +27,7 @@
 @Data
 @SuperBuilder
 @NoArgsConstructor
+@EqualsAndHashCode(callSuper = true)
 public class RegistryMetadata extends MetadataConfig {
 
 

eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/metadata/RuntimeMetadata.java

@@ -46,6 +46,8 @@ public class RuntimeMetadata extends MetadataConfig {
 
     private String clusterName;
 
+    private Integer status;
+
     @Override
     public String getUnique() {
         return host + ":" + port;

eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/metadata/TopicMetadata.java

@@ -47,6 +47,8 @@ public class TopicMetadata extends MetadataConfig {
 
     private String description;
 
+    private String topicConfig;
+
     @Override
     public String getUnique() {
         return topicName;