This is an automated email from the ASF dual-hosted git repository.
xiatian pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/eventmesh-dashboard.git
from 5092504 chore(deps): bump
org.apache.maven.plugins:maven-checkstyle-plugin from 3.3.1 to 3.4.0 (#152)
add d3ffcb5 Refactor RemotingService and `SyncFrom...` interfaces (#146)
No new revisions were added by this update.
Summary of changes:
.mvn/wrapper/maven-wrapper.jar | Bin 0 -> 62547 bytes
README.md | 2 +-
README.zh-CN.md | 9 +
.../dashboard/common/constant/ApiPrefix.java | 1 +
.../common/constant/StoreTypeConstant.java | 1 +
.../common/constant/health/HealthConstant.java | 1 +
.../eventmesh/dashboard/common/dto/Result.java | 6 +-
.../dashboard/common/enums/BusinessType.java | 14 +-
.../ClusterTrusteeshipType.java} | 14 +-
.../dashboard/common/enums/ClusterType.java | 124 ++++
.../RemotingType.java} | 19 +-
.../ResetOffsetMode.java} | 12 +-
.../common/model/metadata/AclMetadata.java | 2 +
.../common/model/metadata/ClientMetadata.java | 2 +
.../common/model/metadata/ClusterMetadata.java | 8 +
...adata.java => ClusterRelationshipMetadata.java} | 17 +-
.../common/model/metadata/ConfigMetadata.java | 2 +
.../common/model/metadata/GroupMetadata.java | 2 +
.../common/model/metadata/MetadataConfig.java | 3 +
.../common/model/metadata/RegistryMetadata.java | 2 +
.../common/model/metadata/RuntimeMetadata.java | 2 +
.../common/model/metadata/TopicMetadata.java | 2 +
.../GetAclsResult.java => BaseGlobalResult.java} | 4 +-
.../GetRuntimeRequest.java => GlobalRequest.java} | 6 +-
.../GetConfigRequest.java => GlobalResult.java} | 20 +-
.../common/model/remoting/RemotingAction.java | 16 +-
.../GetAclsResult.java => RemotingOperate.java} | 9 +-
.../model/remoting/acl/CreateAclRequest.java | 1 +
.../common/model/remoting/acl/GetAclsRequest.java | 5 +-
.../common/model/remoting/acl/GetAclsResult.java | 8 +-
...GetConfigRequest.java => AddConfigRequest.java} | 15 +-
.../model/remoting/config/AddConfigResponse.java | 9 +-
.../AddConfigResult.java} | 4 +-
.../GetAclsResult.java => config/ConfigType.java} | 6 +-
...tConfigResult.java => DeleteConfigRequest.java} | 16 +-
.../DeleteConfigResponse.java} | 4 +-
.../DeleteConfigResult.java} | 4 +-
.../model/remoting/config/GetConfigRequest.java | 7 +-
.../model/remoting/config/GetConfigResult.java | 1 +
...tConfigResult.java => UpdateConfigRequest.java} | 15 +-
.../UpdateConfigResponse.java} | 4 +-
.../UpdateConfigResult.java} | 4 +-
.../model/remoting/group/GetGroupResult.java | 4 +-
.../model/remoting/offset/GetOffsetRequest.java | 1 +
.../model/remoting/offset/ResetOffsetRequest.java | 19 +-
.../model/remoting/offset/ResetOffsetResult.java | 1 +
.../model/remoting/runtime/GetRuntimeRequest.java | 4 +-
.../model/remoting/runtime/GetRuntimeResult.java | 4 +-
.../model/remoting/topic/CreateTopicRequest.java | 12 +-
.../model/remoting/topic/CreateTopicResponse.java | 1 +
.../model/remoting/topic/CreateTopicResult.java | 12 +-
.../model/remoting/topic/DeleteTopicRequest.java | 1 +
.../model/remoting/topic/DeleteTopicResponse.java | 1 +
.../model/remoting/topic/DeleteTopicResult.java | 12 +-
.../model/remoting/topic/GetTopicsRequest.java | 4 +-
.../model/remoting/topic/GetTopicsResponse.java | 2 +-
.../model/remoting/topic/GetTopicsResult.java | 14 +-
.../model/remoting/user/DeleteUserResponse.java | 1 +
.../common/model/remoting/user/GetUserRequest.java | 1 +
eventmesh-dashboard-console/pom.xml | 12 +-
.../dashboard/console/cache/ClusterCache.java | 99 ---
.../dashboard/console/cache/RuntimeCache.java | 60 --
.../console/controller/ConnectionController.java | 4 +-
.../console/controller/SubscriptionController.java | 11 +-
.../controller/{ => cluster}/AclController.java | 6 +-
.../ClientDataController.java} | 32 +-
.../controller/cluster/ClusterController.java | 106 ++++
.../cluster/ClusterRelationshipController.java | 59 ++
.../{ => cluster}/InstanceUserController.java | 6 +-
.../cluster/NetConnectionController.java} | 21 +-
.../controller/cluster/RuntimeController.java | 109 ++++
.../{ => function}/ConfigController.java | 6 +-
.../{ => function}/HealthController.java | 11 +-
.../controller/{ => function}/LogController.java | 6 +-
.../OverviewController.java} | 28 +-
.../GroupController.java} | 33 +-
.../GroupRelationshipController.java} | 30 +-
.../OffsetOperateController.java} | 43 +-
.../controller/{ => message}/TopicController.java | 53 +-
.../console/entity/{base => }/BaseEntity.java | 14 +-
.../entity/{config => }/DefaultConfigKey.java | 2 +-
.../console/entity/{storage => }/StoreEntity.java | 16 +-
.../console/entity/{acl => cluster}/AclEntity.java | 20 +-
.../entity/{client => cluster}/ClientEntity.java | 26 +-
.../cluster/ClusterAndRelationshipEntity.java | 22 +-
.../console/entity/cluster/ClusterEntity.java | 42 +-
.../entity/cluster/ClusterRelationshipEntity.java | 23 +-
.../{connection => cluster}/ConnectionEntity.java | 25 +-
.../InstanceUserEntity.java | 10 +-
.../NetConnectionEntity.java} | 38 +-
.../RuntimeEntity.java} | 32 +-
.../console/entity/config/ConfigEntity.java | 135 -----
.../console/entity/connector/ConnectorEntity.java | 8 +-
.../console/entity/function/ConfigEntity.java | 50 +-
.../HealthCheckResultEntity.java | 12 +-
.../entity/{log => function}/LogEntity.java | 6 +-
.../console/entity/group/GroupEntity.java | 68 ---
.../console/entity/message/GroupEntity.java | 18 +-
.../GroupMemberEntity.java | 16 +-
.../entity/{topic => message}/TopicEntity.java | 29 +-
.../dashboard/console/entity/meta/MetaEntity.java | 83 ---
.../console/entity/runtime/RuntimeEntity.java | 70 ---
.../console/exception/GlobalExceptionHandler.java | 3 +-
.../console/function/health/CheckResultCache.java | 8 +-
.../console/function/health/HealthExecutor.java | 12 +-
.../console/function/health/HealthService.java | 18 +-
.../health/annotation/HealthCheckType.java | 2 +
.../health/callback/HealthCheckCallback.java | 2 +
.../function/health/check/HealthCheckService.java | 8 +-
.../storage/rocketmq4/Rocketmq4BrokerCheck.java | 2 +-
.../rocketmq4/Rocketmq4NameServerCheck.java | 2 +-
.../storage/rocketmq4/Rocketmq4TopicCheck.java | 6 +-
.../console/function/metadata/MetadataManager.java | 222 -------
.../function/metadata/MetadataServiceWrapper.java | 8 +-
...terService.java => SyncRelationshipConfig.java} | 10 +-
.../metadata/handler/MetadataHandlerWrapper.java | 11 +-
.../handler/db/ClusterMetadataHandlerToDbImpl.java | 21 +-
.../handler/db/ConfigMetadataHandlerToDbImpl.java | 27 +-
.../db/ConnectionMetadataHandlerToDbImpl.java | 154 -----
.../handler/db/GroupMetadataHandlerToDbImpl.java | 25 +-
.../db/RegistryMetadataHandlerToDbImpl.java | 57 --
.../handler/db/RuntimeMetadataHandlerToDbImpl.java | 57 +-
.../handler/db/TopicMetadataHandlerToDbImpl.java | 21 +-
.../syncservice/SyncDataServiceWrapper.java | 17 +-
.../cluster/ConfigSyncFromClusterService.java | 97 ---
.../cluster/GroupSyncFromClusterService.java | 46 --
.../cluster/RuntimeSyncFromClusterService.java | 93 ---
.../cluster/TopicSyncFromClusterService.java | 87 ---
.../syncservice/db/TopicSyncFromDbService.java | 43 --
.../TopicMetadataHandlerToClusterImpl.java | 57 --
.../eventmesh/dashboard/console/log/OprLog.java | 7 +-
.../console/mapper/{acl => cluster}/AclMapper.java | 4 +-
.../mapper/{client => cluster}/ClientMapper.java | 6 +-
.../console/mapper/cluster/ClusterMapper.java | 56 +-
.../mapper/cluster/ClusterRelationshipMapper.java | 65 ++
.../{connection => cluster}/ConnectionMapper.java | 4 +-
.../InstanceUserMapper.java | 10 +-
.../cluster/NetConnectionMapper.java} | 24 +-
.../mapper/{runtime => cluster}/RuntimeMapper.java | 10 +-
.../mapper/{config => function}/ConfigMapper.java | 4 +-
.../HealthCheckResultMapper.java | 4 +-
.../mapper/{log => function}/OprLogMapper.java | 4 +-
.../mapper/{group => message}/OprGroupMapper.java | 36 +-
.../OprGroupMemberMapper.java | 4 +-
.../mapper/{topic => message}/TopicMapper.java | 77 +--
.../dashboard/console/mapper/meta/MetaMapper.java | 62 --
.../console/mapper/storage/StoreMapper.java | 2 +-
.../cluster/ClientDataControllerMapper.java} | 18 +-
.../cluster/ClusterControllerMapper.java} | 23 +-
.../cluster/GroupControllerMapper.java} | 21 +-
.../cluster/RuntimeControllerMapper.java} | 30 +-
.../message/TopicControllerMapper.java} | 30 +-
.../dashboard/console/modle/ClusterIdDTO.java | 9 +-
.../eventmesh/dashboard/console/modle/IdDTO.java | 8 +-
.../cluster/ClusterHomeListVO.java} | 18 +-
.../console/modle/cluster/CreateClusterDTO.java | 40 +-
.../modle/cluster/client/SelectByClusterIdDTO.java | 7 +-
.../modle/cluster/runtime/CrateRuntimeDTO.java | 23 +-
.../runtime/QueryRuntimeListByClusterIdDTO.java} | 8 +-
.../dto/connection/AddConnectorConfigDTO.java | 2 +-
.../OverviewDTO.java} | 17 +-
.../console/modle/function/OverviewType.java | 8 +-
.../offset/QueryOffsetByMessageMetadataDTO.java | 10 +-
.../modle/message/offset/ResetOffsetDTO.java | 27 +-
.../console/service/DataServiceWrapper.java | 20 +-
.../dashboard/console/service/OverviewService.java | 14 +-
.../service/{acl => cluster}/AclService.java | 4 +-
.../{client => cluster}/ClientDataService.java | 8 +-
...ervice.java => ClusterRelationshipService.java} | 24 +-
.../console/service/cluster/ClusterService.java | 19 +-
.../ConnectionDataService.java | 6 +-
.../InstanceUserService.java | 4 +-
.../{runtime => cluster}/RuntimeService.java | 13 +-
.../{acl/Impl => cluster/impl}/AclServiceImpl.java | 8 +-
.../impl}/ClientDataServiceImpl.java | 19 +-
.../impl/ClusterRelationshipServiceImpl.java | 60 ++
.../service/cluster/impl/ClusterServiceImpl.java | 72 +--
.../impl}/InstanceUserServiceImpl.java | 10 +-
.../Impl => cluster/impl}/RuntimeServiceImpl.java | 33 +-
.../instanceoperation/TopicConfigService.java | 36 --
.../synchronous/SyncConnectorConfigTask.java | 95 ---
.../config/synchronous/SyncRuntimeConfigTask.java | 97 ---
.../config/synchronous/SyncStoreConfigTask.java | 96 ---
.../config/synchronous/SyncTopicConfigTask.java | 97 ---
.../impl/ConnectionDataServiceDatabaseImpl.java | 201 -------
.../{config => function}/ConfigService.java | 5 +-
.../{health => function}/HealthDataService.java | 7 +-
.../HealthDataServiceMemoryStorage.java | 16 +-
.../Impl/ConfigServiceImpl.java | 10 +-
.../Impl}/HealthDataServiceDatabaseImpl.java | 19 +-
.../{log => function/Impl}/LogServiceImpl.java | 7 +-
.../service/{log => function}/LogService.java | 4 +-
.../GroupMemberService.java | 6 +-
.../service/{group => message}/GroupService.java | 6 +-
.../service/{topic => message}/TopicService.java | 22 +-
.../impl}/GroupMemberServiceImp.java | 10 +-
.../Impl => message/impl}/GroupServiceImpl.java | 22 +-
.../{topic => message/impl}/TopicServiceImpl.java | 70 +--
.../service/store/Impl/StoreServiceImpl.java | 2 +-
.../console/service/store/StoreService.java | 2 +-
.../console/spring/support/FunctionManager.java | 9 -
.../src/main/resources/eventmesh-dashboard.sql | 664 +++++++++------------
.../console/EventMeshDashboardApplicationTest.java | 31 +-
.../dashboard/console/cache/ClusterCacheBase.java | 46 --
.../dashboard/console/cache/ClusterCacheTest.java | 53 --
.../function/health/HealthExecutorTest.java | 15 +-
.../console/function/health/HealthServiceTest.java | 2 +-
.../function/metadata/MetadataManagerTest.java | 159 -----
.../db/ClusterMetadataHandlerToDbImplTest.java | 69 ---
.../db/ConfigMetadataHandlerToDbImplTest.java | 2 +-
.../db/ConnectionMetadataHandlerToDbImplTest.java | 10 +-
.../db/GroupMetadataHandlerToDbImplTest.java | 6 +-
.../db/RegistryMetadataHandlerToDbImplTest.java | 78 ---
.../db/RuntimeMetadataHandlerToDbImplTest.java | 6 +-
.../db/TopicMetadataHandlerToDbImplTest.java | 10 +-
.../cluster/TopicSyncFromClusterServiceTest.java | 82 ---
.../health/HealthServiceIntegrateTest.java | 20 +-
.../dashboard/console/linkage/log/TestOprLog.java | 21 +-
.../console/mapper/acl/AclMapperTest.java | 122 ----
.../console/mapper/client/ClientMapperTest.java | 95 ---
.../mapper/connection/ConnectionMapperTest.java | 123 ----
.../mapper/connector/ConnectorMapperTest.java | 127 ----
.../mapper/health/HealthCheckResultMapperTest.java | 142 -----
.../instanceuser/InstanceUserMapperTest.java | 89 ---
.../console/mapper/meta/MetaMapperTest.java | 49 --
.../ConnectionDataServiceDatabaseImplTest.java | 3 +-
.../spring/support/FunctionManagerTest.java | 1 -
.../console/unit/cluster/TestClusterMapper.java | 105 ----
.../console/unit/config/TestConfigMapper.java | 111 ----
.../console/unit/group/GroupMapperTest.java | 118 ----
.../unit/groupmember/GroupMemberMapperTest.java | 158 -----
.../console/unit/runtime/TestRuntimeMapper.java | 74 ---
.../console/unit/store/TestStoreMapper.java | 79 ---
.../console/unit/topic/TopicMapperTest.java | 133 -----
eventmesh-dashboard-core/pom.xml | 6 +-
.../dashboard/core/cluster/ClusterDO.java | 29 +-
.../dashboard/core/cluster/ClusterDoCache.java | 94 +++
.../eventmesh/dashboard/core/cluster/ColonyDO.java | 56 ++
.../dashboard/core/config/AdminProperties.java | 4 +
.../dashboard/core/function/SDK/SDKManager.java | 58 +-
.../dashboard/core/function/SDK/SDKTypeEnum.java | 2 +
.../SDK/config/CreateRocketmqAdminSDKConfig.java | 19 +-
.../function/SDK/config/CreateRocketmqConfig.java | 8 +-
.../function/SDK/operation/EtcdSDKOperation.java | 8 +-
.../RocketMQAdminOperation.java} | 19 +-
.../RocketMQProduceSDKOperation.java | 2 +-
.../RocketMQPushConsumerSDKOperation.java | 4 +-
.../RocketMQRemotingSDKOperation.java | 2 +-
.../RuntimeGrpcConsumerSDKOperation.java | 2 +-
.../RuntimeGrpcProducerSDKOperation.java | 2 +-
.../RuntimeHttpConsumerSDKOperation.java | 2 +-
.../RuntimeHttpProducerSDKOperation.java | 2 +-
.../{ => runtime}/RuntimeSDKOperation.java | 4 +-
.../RuntimeTcpCloudEventSDKOperation.java | 2 +-
.../RuntimeTcpEventMeshSDKOperation.java | 2 +-
.../RuntimeTcpOpenMessageSDKOperation.java | 2 +-
.../core/function/SDK/wrapper/NacosSDKWrapper.java | 6 +-
.../meta/subscription/NacosSubscriptionCore.java | 5 +-
.../dashboard/core/metadata}/MetadataHandler.java | 39 +-
.../core/metadata/MetadataSyncManager.java | 245 ++++++++
.../metadata/cluster/AbstractMetadataHandler.java | 57 ++
.../cluster/AclSyncFromClusterService.java | 30 +-
.../cluster/ConfigSyncFromClusterService.java | 49 +-
.../cluster/GroupSyncFromClusterService.java | 65 ++
.../cluster/InstanceUserFromClusterService.java | 2 +-
.../cluster/RuntimeSyncFromClusterService.java | 58 ++
.../cluster/TopicSyncFromClusterService.java | 36 +-
.../core/remoting/AbstractRemotingService.java | 99 +++
.../dashboard/core/remoting/RemotingManager.java | 391 ++++++++++++
.../remoting/RemotingServiceRuntimeConfig.java | 29 +-
.../rocketmq/AbstractRocketMQRemotingService.java | 112 ++++
.../rocketmq/RocketMQAclRemotingService.java | 31 +-
.../rocketmq/RocketMQClientRemotingService.java | 17 +-
.../rocketmq/RocketMQConfigRemotingService.java | 30 +-
.../rocketmq/RocketMQGroupRemotingService.java | 20 +-
.../rocketmq/RocketMQOffsetRemotingService.java | 26 +-
.../RocketMQSubscriptionRemotingService.java | 20 +-
.../rocketmq/RocketMQTopicRemotingService.java | 81 +++
.../rocketmq/RocketMQUserRemotingService.java | 42 ++
.../dashboard/core/store/RocketmqTopicCore.java | 17 +-
.../SDK/operation/EtcdSDKCreateOperationTest.java | 3 +-
.../RuntimeGrpcConsumerSDKOperationTest.java | 1 +
.../RuntimeGrpcProducerSDKOperationTest.java | 1 +
.../RuntimeHttpConsumerSDKOperationTest.java | 1 +
.../RuntimeHttpProducerSDKOperationTest.java | 1 +
.../SDK/operation/RuntimeSDKOperationTest.java | 1 +
.../RuntimeTcpCloudEventSDKOperationTest.java | 1 +
.../RuntimeTcpEventMeshSDKOperationTest.java | 1 +
.../RuntimeTcpOpenMessageSDKOperationTest.java | 2 +
.../core/meta/runtime/NacosRuntimeCoreTest.java | 5 +-
.../core/metadata/MetadataSyncManagerTest.java | 136 +++++
.../core/remoting/RemotingManagerTest.java | 166 ++++++
.../dashboard/service/meta/ConnectionCore.java | 5 +-
.../dashboard/service/meta/SubscriptionCore.java | 5 +-
.../service/remoting/ClientRemotingService.java | 4 +-
.../service/remoting/ConfigRemotingService.java | 26 +-
.../service/remoting/MetaRemotingService.java | 1 +
...ervice.java => RemotingIntegrationService.java} | 14 +-
.../service/remoting/RemotingOperate.java | 9 +-
.../service/remoting/RemotingServiceType.java | 5 +-
.../service/remoting/RuntimeRemotingService.java | 11 +-
pom.xml | 99 +++
style/checkStyle.xml | 4 +-
303 files changed, 4072 insertions(+), 6013 deletions(-)
create mode 100644 .mvn/wrapper/maven-wrapper.jar
copy
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/health/callback/HealthCheckCallback.java
=>
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/enums/BusinessType.java
(64%)
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/{model/remoting/runtime/GetRuntimeRequest.java
=> enums/ClusterTrusteeshipType.java} (82%)
create mode 100644
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/enums/ClusterType.java
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/{model/remoting/offset/GetOffsetRequest.java
=> enums/RemotingType.java} (78%)
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/{model/remoting/offset/GetOffsetRequest.java
=> enums/ResetOffsetMode.java} (79%)
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/metadata/{GroupMetadata.java
=> ClusterRelationshipMetadata.java} (76%)
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/remoting/{acl/GetAclsResult.java
=> BaseGlobalResult.java} (86%)
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/remoting/{runtime/GetRuntimeRequest.java
=> GlobalRequest.java} (85%)
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/remoting/{config/GetConfigRequest.java
=> GlobalResult.java} (76%)
copy
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/modle/dto/runtime/GetRuntimeListDTO.java
=>
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/remoting/RemotingAction.java
(73%)
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/remoting/{acl/GetAclsResult.java
=> RemotingOperate.java} (86%)
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/remoting/config/{GetConfigRequest.java
=> AddConfigRequest.java} (76%)
rename
eventmesh-dashboard-observe/src/main/java/org/apache/eventmesh/dashboard/observe/Main.java
=>
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/remoting/config/AddConfigResponse.java
(87%)
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/remoting/{acl/GetAclsResult.java
=> config/AddConfigResult.java} (88%)
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/remoting/{acl/GetAclsResult.java
=> config/ConfigType.java} (87%)
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/remoting/config/{GetConfigResult.java
=> DeleteConfigRequest.java} (76%)
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/remoting/{acl/GetAclsResult.java
=> config/DeleteConfigResponse.java} (88%)
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/remoting/{acl/GetAclsResult.java
=> config/DeleteConfigResult.java} (86%)
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/remoting/config/{GetConfigResult.java
=> UpdateConfigRequest.java} (75%)
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/remoting/{acl/GetAclsResult.java
=> config/UpdateConfigResponse.java} (88%)
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/remoting/{acl/GetAclsResult.java
=> config/UpdateConfigResult.java} (86%)
delete mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/cache/ClusterCache.java
delete mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/cache/RuntimeCache.java
copy
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/controller/{
=> cluster}/AclController.java (89%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/controller/{ClusterController.java
=> cluster/ClientDataController.java} (50%)
create mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/controller/cluster/ClusterController.java
create mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/controller/cluster/ClusterRelationshipController.java
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/controller/{
=> cluster}/InstanceUserController.java (90%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/{service/config/instanceoperation/StoreConfigService.java
=> controller/cluster/NetConnectionController.java} (60%)
create mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/controller/cluster/RuntimeController.java
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/controller/{
=> function}/ConfigController.java (93%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/controller/{
=> function}/HealthController.java (83%)
copy
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/controller/{
=> function}/LogController.java (87%)
copy
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/controller/{RuntimeController.java
=> function/OverviewController.java} (63%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/controller/{RuntimeController.java
=> message/GroupController.java} (52%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/controller/{LogController.java
=> message/GroupRelationshipController.java} (60%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/controller/{AclController.java
=> message/OffsetOperateController.java} (53%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/controller/{
=> message}/TopicController.java (55%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/{base
=> }/BaseEntity.java (81%)
copy
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/{config
=> }/DefaultConfigKey.java (94%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/{storage
=> }/StoreEntity.java (77%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/{acl
=> cluster}/AclEntity.java (82%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/{client
=> cluster}/ClientEntity.java (75%)
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/metadata/GroupMetadata.java
=>
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/cluster/ClusterAndRelationshipEntity.java
(68%)
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/metadata/GroupMetadata.java
=>
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/cluster/ClusterRelationshipEntity.java
(68%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/{connection
=> cluster}/ConnectionEntity.java (75%)
copy
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/{instanceuser
=> cluster}/InstanceUserEntity.java (79%)
copy
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/{instanceuser/InstanceUserEntity.java
=> cluster/NetConnectionEntity.java} (62%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/{instanceuser/InstanceUserEntity.java
=> cluster/RuntimeEntity.java} (67%)
delete mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/config/ConfigEntity.java
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/metadata/ClusterMetadata.java
=>
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/function/ConfigEntity.java
(54%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/{health
=> function}/HealthCheckResultEntity.java (90%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/{log
=> function}/LogEntity.java (89%)
delete mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/group/GroupEntity.java
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/metadata/GroupMetadata.java
=>
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/message/GroupEntity.java
(73%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/{groupmember
=> message}/GroupMemberEntity.java (74%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/{topic
=> message}/TopicEntity.java (64%)
delete mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/meta/MetaEntity.java
delete mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/runtime/RuntimeEntity.java
delete mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/metadata/MetadataManager.java
copy
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/metadata/{syncservice/cluster/InstanceUserFromClusterService.java
=> SyncRelationshipConfig.java} (87%)
delete mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/metadata/handler/db/ConnectionMetadataHandlerToDbImpl.java
delete mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/metadata/handler/db/RegistryMetadataHandlerToDbImpl.java
delete mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/metadata/syncservice/cluster/ConfigSyncFromClusterService.java
delete mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/metadata/syncservice/cluster/GroupSyncFromClusterService.java
delete mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/metadata/syncservice/cluster/RuntimeSyncFromClusterService.java
delete mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/metadata/syncservice/cluster/TopicSyncFromClusterService.java
delete mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/metadata/syncservice/db/TopicSyncFromDbService.java
delete mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/optration/TopicMetadataHandlerToClusterImpl.java
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/mapper/{acl
=> cluster}/AclMapper.java (94%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/mapper/{client
=> cluster}/ClientMapper.java (93%)
create mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/mapper/cluster/ClusterRelationshipMapper.java
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/mapper/{connection
=> cluster}/ConnectionMapper.java (97%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/mapper/{instanceuser
=> cluster}/InstanceUserMapper.java (84%)
copy
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/{service/client/ClientDataService.java
=> mapper/cluster/NetConnectionMapper.java} (58%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/mapper/{runtime
=> cluster}/RuntimeMapper.java (91%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/mapper/{config
=> function}/ConfigMapper.java (97%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/mapper/{health
=> function}/HealthCheckResultMapper.java (97%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/mapper/{log
=> function}/OprLogMapper.java (95%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/mapper/{group
=> message}/OprGroupMapper.java (94%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/mapper/{groupmember
=> message}/OprGroupMemberMapper.java (96%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/mapper/{topic
=> message}/TopicMapper.java (68%)
delete mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/mapper/meta/MetaMapper.java
copy
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/{service/registry/RegistryDataService.java
=> mapstruct/cluster/ClientDataControllerMapper.java} (62%)
copy
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/{service/log/LogService.java
=> mapstruct/cluster/ClusterControllerMapper.java} (62%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/{service/registry/RegistryDataService.java
=> mapstruct/cluster/GroupControllerMapper.java} (60%)
copy
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/{service/store/StoreService.java
=> mapstruct/cluster/RuntimeControllerMapper.java} (52%)
copy
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/{service/store/StoreService.java
=> mapstruct/message/TopicControllerMapper.java} (50%)
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/remoting/offset/GetOffsetRequest.java
=>
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/modle/ClusterIdDTO.java
(83%)
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/remoting/acl/GetAclsResult.java
=>
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/modle/IdDTO.java
(86%)
copy
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/{entity/config/DefaultConfigKey.java
=> modle/cluster/ClusterHomeListVO.java} (74%)
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/metadata/ClientMetadata.java
=>
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/modle/cluster/CreateClusterDTO.java
(60%)
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/remoting/acl/GetAclsResult.java
=>
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/modle/cluster/client/SelectByClusterIdDTO.java
(80%)
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/metadata/GroupMetadata.java
=>
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/modle/cluster/runtime/CrateRuntimeDTO.java
(66%)
copy
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/modle/{dto/runtime/GetRuntimeListDTO.java
=> cluster/runtime/QueryRuntimeListByClusterIdDTO.java} (82%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/modle/{dto/runtime/GetRuntimeListDTO.java
=> function/OverviewDTO.java} (76%)
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/remoting/acl/GetAclsResult.java
=>
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/modle/function/OverviewType.java
(88%)
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/remoting/offset/GetOffsetRequest.java
=>
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/modle/message/offset/QueryOffsetByMessageMetadataDTO.java
(79%)
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/remoting/offset/ResetOffsetRequest.java
=>
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/modle/message/offset/ResetOffsetDTO.java
(72%)
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/remoting/offset/GetOffsetRequest.java
=>
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/OverviewService.java
(78%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/{acl
=> cluster}/AclService.java (89%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/{client
=> cluster}/ClientDataService.java (85%)
copy
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/cluster/{ClusterService.java
=> ClusterRelationshipService.java} (58%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/{connection
=> cluster}/ConnectionDataService.java (89%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/{instanceuser
=> cluster}/InstanceUserService.java (89%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/{runtime
=> cluster}/RuntimeService.java (74%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/{acl/Impl
=> cluster/impl}/AclServiceImpl.java (85%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/{client/Impl
=> cluster/impl}/ClientDataServiceImpl.java (80%)
create mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/cluster/impl/ClusterRelationshipServiceImpl.java
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/{instanceuser/Impl
=> cluster/impl}/InstanceUserServiceImpl.java (83%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/{runtime/Impl
=> cluster/impl}/RuntimeServiceImpl.java (67%)
delete mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/instanceoperation/TopicConfigService.java
delete mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/synchronous/SyncConnectorConfigTask.java
delete mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/synchronous/SyncRuntimeConfigTask.java
delete mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/synchronous/SyncStoreConfigTask.java
delete mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/synchronous/SyncTopicConfigTask.java
delete mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/connection/impl/ConnectionDataServiceDatabaseImpl.java
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/{config
=> function}/ConfigService.java (93%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/{health
=> function}/HealthDataService.java (89%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/{health
=> function}/HealthDataServiceMemoryStorage.java (83%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/{config
=> function}/Impl/ConfigServiceImpl.java (96%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/{health/impl
=> function/Impl}/HealthDataServiceDatabaseImpl.java (90%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/{log
=> function/Impl}/LogServiceImpl.java (86%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/{log
=> function}/LogService.java (89%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/{groupmember
=> message}/GroupMemberService.java (87%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/{group
=> message}/GroupService.java (86%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/{topic
=> message}/TopicService.java (60%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/{groupmember/Impl
=> message/impl}/GroupMemberServiceImp.java (88%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/{group/Impl
=> message/impl}/GroupServiceImpl.java (83%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/{topic
=> message/impl}/TopicServiceImpl.java (64%)
delete mode 100644
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/cache/ClusterCacheBase.java
delete mode 100644
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/cache/ClusterCacheTest.java
delete mode 100644
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/metadata/MetadataManagerTest.java
delete mode 100644
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/metadata/handler/db/ClusterMetadataHandlerToDbImplTest.java
delete mode 100644
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/metadata/handler/db/RegistryMetadataHandlerToDbImplTest.java
delete mode 100644
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/metadata/syncservice/cluster/TopicSyncFromClusterServiceTest.java
delete mode 100644
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/mapper/acl/AclMapperTest.java
delete mode 100644
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/mapper/client/ClientMapperTest.java
delete mode 100644
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/mapper/connection/ConnectionMapperTest.java
delete mode 100644
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/mapper/connector/ConnectorMapperTest.java
delete mode 100644
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/mapper/health/HealthCheckResultMapperTest.java
delete mode 100644
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/mapper/instanceuser/InstanceUserMapperTest.java
delete mode 100644
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/mapper/meta/MetaMapperTest.java
delete mode 100644
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/unit/cluster/TestClusterMapper.java
delete mode 100644
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/unit/config/TestConfigMapper.java
delete mode 100644
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/unit/group/GroupMapperTest.java
delete mode 100644
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/unit/groupmember/GroupMemberMapperTest.java
delete mode 100644
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/unit/runtime/TestRuntimeMapper.java
delete mode 100644
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/unit/store/TestStoreMapper.java
delete mode 100644
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/unit/topic/TopicMapperTest.java
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/remoting/offset/ResetOffsetRequest.java
=>
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/cluster/ClusterDO.java
(66%)
create mode 100644
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/cluster/ClusterDoCache.java
create mode 100644
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/cluster/ColonyDO.java
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/config/DefaultConfigKey.java
=>
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/function/SDK/config/CreateRocketmqAdminSDKConfig.java
(74%)
copy
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/function/SDK/operation/{RocketMQProduceSDKOperation.java
=> rocketmq/RocketMQAdminOperation.java} (77%)
rename
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/function/SDK/operation/{
=> rocketmq}/RocketMQProduceSDKOperation.java (99%)
rename
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/function/SDK/operation/{
=> rocketmq}/RocketMQPushConsumerSDKOperation.java (96%)
rename
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/function/SDK/operation/{
=> rocketmq}/RocketMQRemotingSDKOperation.java (99%)
rename
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/function/SDK/operation/{
=> runtime}/RuntimeGrpcConsumerSDKOperation.java (99%)
rename
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/function/SDK/operation/{
=> runtime}/RuntimeGrpcProducerSDKOperation.java (99%)
rename
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/function/SDK/operation/{
=> runtime}/RuntimeHttpConsumerSDKOperation.java (99%)
rename
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/function/SDK/operation/{
=> runtime}/RuntimeHttpProducerSDKOperation.java (99%)
rename
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/function/SDK/operation/{
=> runtime}/RuntimeSDKOperation.java (99%)
rename
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/function/SDK/operation/{
=> runtime}/RuntimeTcpCloudEventSDKOperation.java (99%)
rename
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/function/SDK/operation/{
=> runtime}/RuntimeTcpEventMeshSDKOperation.java (99%)
rename
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/function/SDK/operation/{
=> runtime}/RuntimeTcpOpenMessageSDKOperation.java (99%)
rename
{eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/metadata/handler
=>
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/metadata}/MetadataHandler.java
(70%)
create mode 100644
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/metadata/MetadataSyncManager.java
create mode 100644
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/metadata/cluster/AbstractMetadataHandler.java
copy
{eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/metadata/syncservice
=>
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/metadata}/cluster/AclSyncFromClusterService.java
(60%)
copy
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/metadata/handler/db/ConfigMetadataHandlerToDbImpl.java
=>
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/metadata/cluster/ConfigSyncFromClusterService.java
(54%)
create mode 100644
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/metadata/cluster/GroupSyncFromClusterService.java
rename
{eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/metadata/syncservice
=>
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/metadata}/cluster/InstanceUserFromClusterService.java
(91%)
create mode 100644
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/metadata/cluster/RuntimeSyncFromClusterService.java
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/registry/impl/RegistryDataServiceImpl.java
=>
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/metadata/cluster/TopicSyncFromClusterService.java
(50%)
create mode 100644
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/remoting/AbstractRemotingService.java
create mode 100644
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/remoting/RemotingManager.java
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/remoting/offset/ResetOffsetRequest.java
=>
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/remoting/RemotingServiceRuntimeConfig.java
(63%)
create mode 100644
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/remoting/rocketmq/AbstractRocketMQRemotingService.java
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/metadata/syncservice/cluster/AclSyncFromClusterService.java
=>
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/remoting/rocketmq/RocketMQAclRemotingService.java
(51%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/instanceoperation/ConnectorConfigService.java
=>
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/remoting/rocketmq/RocketMQClientRemotingService.java
(68%)
copy
eventmesh-dashboard-service/src/main/java/org/apache/eventmesh/dashboard/service/remoting/ConfigRemotingService.java
=>
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/remoting/rocketmq/RocketMQConfigRemotingService.java
(52%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/config/instanceoperation/RuntimeConfigService.java
=>
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/remoting/rocketmq/RocketMQGroupRemotingService.java
(61%)
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/metadata/AclMetadata.java
=>
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/remoting/rocketmq/RocketMQOffsetRemotingService.java
(51%)
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/metadata/AclMetadata.java
=>
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/remoting/rocketmq/RocketMQSubscriptionRemotingService.java
(60%)
create mode 100644
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/remoting/rocketmq/RocketMQTopicRemotingService.java
create mode 100644
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/remoting/rocketmq/RocketMQUserRemotingService.java
create mode 100644
eventmesh-dashboard-core/src/test/java/org/apache/eventmesh/dashboard/core/metadata/MetadataSyncManagerTest.java
create mode 100644
eventmesh-dashboard-core/src/test/java/org/apache/eventmesh/dashboard/core/remoting/RemotingManagerTest.java
copy
eventmesh-dashboard-service/src/main/java/org/apache/eventmesh/dashboard/service/remoting/{ClientRemotingService.java
=> RemotingIntegrationService.java} (74%)
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/remoting/acl/GetAclsResult.java
=>
eventmesh-dashboard-service/src/main/java/org/apache/eventmesh/dashboard/service/remoting/RemotingOperate.java
(86%)
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/remoting/acl/GetAclsResult.java
=>
eventmesh-dashboard-service/src/main/java/org/apache/eventmesh/dashboard/service/remoting/RemotingServiceType.java
(89%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/metadata/syncservice/SyncDataService.java
=>
eventmesh-dashboard-service/src/main/java/org/apache/eventmesh/dashboard/service/remoting/RuntimeRemotingService.java
(70%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
