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 4494f0a chore(deps): bump org.apache.commons:commons-lang3 from
3.13.0 to 3.14.0 (#124)
add 53785bf [ISSUE #63] Function Manager and Health Service update (#98)
No new revisions were added by this update.
Summary of changes:
.../common/model/metadata/AclMetadata.java | 5 +
.../common/model/metadata/ClientMetadata.java | 5 +
.../common/model/metadata/ClusterMetadata.java | 5 +
.../common/model/metadata/ConfigMetadata.java | 5 +
.../common/model/metadata/ConnectionMetadata.java | 5 +
.../common/model/metadata/ConnectorMetadata.java | 5 +
.../common/model/metadata/GroupMetadata.java | 5 +
.../common/model/metadata/MetadataConfig.java | 13 +-
.../common/model/metadata/RegistryMetadata.java | 9 +
.../common/model/metadata/RuntimeMetadata.java | 13 +-
.../common/model/metadata/TopicMetadata.java | 9 +
.../model/remoting/runtime/GetRuntimeResponse.java | 4 +
eventmesh-dashboard-console/pom.xml | 1 +
.../dashboard/console/cache/ClusterCache.java | 99 ++++++++
.../dashboard/console/cache/RuntimeCache.java | 60 +++++
.../console/config/FunctionManagerConfigs.java | 69 +++++
.../console/config/HealthCheckConfig.java | 31 ---
.../dashboard/console/entity/acl/AclEntity.java | 2 +
.../dashboard/console/entity/base/BaseEntity.java | 8 +
.../console/entity/client/ClientEntity.java | 25 +-
.../console/entity/cluster/ClusterEntity.java | 37 ++-
.../console/entity/config/ConfigEntity.java | 28 +-
.../entity/connection/ConnectionEntity.java | 40 ++-
.../console/entity/connector/ConnectorEntity.java | 12 +-
.../console/entity/group/GroupEntity.java | 15 ++
.../entity/groupmember/GroupMemberEntity.java | 4 +
.../entity/health/HealthCheckResultEntity.java | 6 +-
.../entity/instanceuser/InstanceUserEntity.java | 2 +
.../dashboard/console/entity/log/LogEntity.java | 2 +
.../dashboard/console/entity/meta/MetaEntity.java | 22 +-
.../console/entity/runtime/RuntimeEntity.java | 21 +-
.../console/entity/storage/StoreEntity.java | 13 +-
.../console/entity/topic/TopicEntity.java | 25 +-
.../console/function/health/CheckResultCache.java | 9 +-
.../console/function/health/HealthExecutor.java | 5 +-
.../console/function/health/HealthService.java | 163 ++++++++++--
.../health/callback/HealthCheckCallback.java | 2 +-
.../function/health/check/HealthCheckService.java | 4 +-
.../check/config/HealthCheckObjectConfig.java | 19 +-
.../health/check/config/RocketmqConfig.java} | 14 +-
.../health/check/impl/meta/NacosConfigCheck.java | 3 +
...sterCheck.java => NacosNamingServiceCheck.java} | 13 +-
.../health/check/impl/storage/RedisCheck.java | 24 +-
.../storage/rocketmq4/Rocketmq4BrokerCheck.java | 44 ++--
.../rocketmq4/Rocketmq4NameServerCheck.java | 37 ++-
.../storage/rocketmq4/Rocketmq4TopicCheck.java | 1 +
.../console/function/metadata/MetadataManager.java | 222 ++++++++++++++++
.../function/metadata/MetadataServiceWrapper.java | 61 +++++
.../function/metadata/handler/MetadataHandler.java | 104 ++++++++
.../metadata/handler/MetadataHandlerWrapper.java | 57 +++++
.../db/ClusterMetadataHandlerToDbImpl.java} | 31 +--
.../handler/db/ConfigMetadataHandlerToDbImpl.java | 59 +++++
.../db/ConnectionMetadataHandlerToDbImpl.java | 154 +++++++++++
.../handler/db/GroupMetadataHandlerToDbImpl.java} | 33 +--
.../db/RegistryMetadataHandlerToDbImpl.java} | 32 ++-
.../handler/db/RuntimeMetadataHandlerToDbImpl.java | 82 ++++++
.../handler/db/TopicMetadataHandlerToDbImpl.java | 64 +++++
.../metadata/syncservice/SyncDataService.java | 14 +-
.../syncservice/SyncDataServiceWrapper.java | 54 ++++
.../cluster/AclSyncFromClusterService.java} | 23 +-
.../cluster/ConfigSyncFromClusterService.java | 97 +++++++
.../cluster/GroupSyncFromClusterService.java | 25 +-
.../cluster/InstanceUserFromClusterService.java | 9 +-
.../cluster/RuntimeSyncFromClusterService.java | 93 +++++++
.../cluster/TopicSyncFromClusterService.java | 87 +++++++
.../syncservice/db/TopicSyncFromDbService.java} | 25 +-
.../TopicMetadataHandlerToClusterImpl.java | 57 +++++
.../console/mapper/client/ClientMapper.java | 8 +-
.../console/mapper/cluster/ClusterMapper.java | 13 +-
.../console/mapper/config/ConfigMapper.java | 12 +-
.../mapper/connection/ConnectionMapper.java | 12 +-
.../console/mapper/connector/ConnectorMapper.java | 9 +-
.../mapper/health/HealthCheckResultMapper.java | 40 ++-
.../dashboard/console/mapper/meta/MetaMapper.java | 8 +-
.../console/mapper/runtime/RuntimeMapper.java | 5 +-
.../console/mapper/storage/StoreMapper.java | 3 +
.../console/modle/dto/meta/NewMetaDTO.java | 10 +-
.../console/service/DataServiceWrapper.java | 81 ++++++
.../console/service/client/ClientDataService.java | 8 +-
.../service/client/Impl/ClientDataServiceImpl.java | 22 +-
.../console/service/cluster/ClusterService.java | 1 -
.../service/cluster/impl/ClusterServiceImpl.java | 8 +
.../service/connection/ConnectionDataService.java | 5 +-
.../service/connection/ConnectionService.java | 50 ----
.../impl/ConnectionDataServiceDatabaseImpl.java | 42 +--
.../service/connector/ConnectorDataService.java | 4 +
.../connector/Impl/ConnectorDataServiceImpl.java | 12 +-
.../console/service/group/GroupService.java | 2 +-
.../service/group/Impl/GroupServiceImpl.java | 3 +-
.../console/service/health/HealthDataService.java | 8 +-
.../health/impl/HealthDataServiceDatabaseImpl.java | 36 ++-
.../service/runtime/Impl/RuntimeServiceImpl.java | 2 +-
.../service/store/Impl/StoreServiceImpl.java | 8 +
.../console/service/store/StoreService.java | 2 +
.../console/service/topic/TopicServiceImpl.java | 5 +-
.../console/spring/support/FunctionManager.java | 27 +-
.../spring/support/FunctionManagerLoader.java | 27 +-
.../spring/support/FunctionManagerProperties.java | 16 ++
.../src/main/resources/application-dev.yml | 18 +-
.../src/main/resources/eventmesh-dashboard.sql | 282 ++++++++++-----------
.../console/EventMeshDashboardApplicationTest.java | 89 +++++++
.../dashboard/console/cache/ClusterCacheBase.java | 46 ++++
.../dashboard/console/cache/ClusterCacheTest.java | 53 ++++
.../function/health/HealthExecutorTest.java | 44 ++--
.../console/function/health/HealthServiceTest.java | 65 +++--
.../check/impl/meta/NacosConfigCheckTest.java | 58 +++--
.../impl/meta/NacosNamingServiceCheckTest.java | 84 ++++++
.../check/impl/meta/NacosRegisterCheckTest.java | 70 -----
.../health/check/impl/storage/RedisCheckTest.java | 60 +++--
...heckTest.java => Rocketmq4BrokerCheckTest.java} | 52 ++--
...Test.java => Rocketmq4NameserverCheckTest.java} | 52 ++--
.../storage/rocketmq4/Rocketmq4TopicCheckTest.java | 85 +++++++
.../storage/rocketmq4/RocketmqTopicCheckTest.java | 75 ------
.../function/metadata/MetadataManagerTest.java | 159 ++++++++++++
.../db/ClusterMetadataHandlerToDbImplTest.java} | 44 +++-
.../db/ConfigMetadataHandlerToDbImplTest.java} | 29 ++-
.../db/ConnectionMetadataHandlerToDbImplTest.java | 121 +++++++++
.../db/GroupMetadataHandlerToDbImplTest.java} | 37 ++-
.../db/RegistryMetadataHandlerToDbImplTest.java} | 49 +++-
.../db/RuntimeMetadataHandlerToDbImplTest.java | 122 +++++++++
.../db/TopicMetadataHandlerToDbImplTest.java} | 44 +++-
.../cluster/TopicSyncFromClusterServiceTest.java | 82 ++++++
.../health/HealthServiceIntegrateTest.java | 17 +-
.../dashboard/console/linkage/log/TestOprLog.java | 8 +-
.../mapper/connector/ConnectorMapperTest.java | 17 +-
.../ConnectionDataServiceDatabaseImplTest.java | 9 -
.../spring/support/FunctionManagerTest.java | 81 ++++++
.../console/unit/cluster/TestClusterMapper.java | 22 +-
.../console/unit/runtime/TestRuntimeMapper.java | 6 +-
.../console/unit/store/TestStoreMapper.java | 16 +-
.../console/unit/topic/TopicMapperTest.java | 2 +-
.../src/test/resources/application-test.yml | 4 +-
.../src/test/resources/connector-test.sql | 20 +-
.../src/test/resources/meta-test.sql | 4 +-
.../src/test/resources/runtime-test.sql | 12 +-
.../resources/{client-test.sql => store-test.sql} | 16 +-
.../src/test/resources/topic-test.sql | 17 +-
.../function/SDK/operation/RedisSDKOperation.java | 2 +-
.../core/meta/runtime/NacosRuntimeCore.java | 87 +++++++
.../core/function/SDK/SDKManagerTest.java | 22 ++
.../SDK/operation/EtcdSDKCreateOperationTest.java | 2 +
.../SDK/operation/NacosNamingSDKOperationTest.java | 53 ++++
...erationTest.java => RedisSDKOperationTest.java} | 4 +-
.../RuntimeGrpcConsumerSDKOperationTest.java | 2 +
.../RuntimeGrpcProducerSDKOperationTest.java | 2 +
.../RuntimeHttpConsumerSDKOperationTest.java | 2 +
.../RuntimeHttpProducerSDKOperationTest.java | 2 +
.../SDK/operation/RuntimeSDKOperationTest.java | 2 +
.../RuntimeTcpCloudEventSDKOperationTest.java | 2 +
.../RuntimeTcpEventMeshSDKOperationTest.java | 2 +
.../RuntimeTcpOpenMessageSDKOperationTest.java | 2 +
.../core/meta/runtime/NacosRuntimeCoreTest.java | 50 ++++
.../service/remoting/ClientRemotingService.java | 1 +
.../service/remoting/ConfigRemotingService.java | 2 +-
...motingService.java => MetaRemotingService.java} | 13 +-
.../service/remoting/OffsetRemotingService.java | 4 +-
156 files changed, 4150 insertions(+), 992 deletions(-)
create mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/cache/ClusterCache.java
create mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/cache/RuntimeCache.java
create mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/config/FunctionManagerConfigs.java
delete mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/config/HealthCheckConfig.java
copy
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/{modle/dto/config/ChangeConfigDTO.java
=> function/health/check/config/RocketmqConfig.java} (82%)
rename
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/meta/{NacosRegisterCheck.java
=> NacosNamingServiceCheck.java} (89%)
create mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/metadata/MetadataManager.java
create mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/metadata/MetadataServiceWrapper.java
create mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/metadata/handler/MetadataHandler.java
create mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/metadata/handler/MetadataHandlerWrapper.java
copy
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/{service/client/Impl/ClientDataServiceImpl.java
=> function/metadata/handler/db/ClusterMetadataHandlerToDbImpl.java} (51%)
create mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/metadata/handler/db/ConfigMetadataHandlerToDbImpl.java
create mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/metadata/handler/db/ConnectionMetadataHandlerToDbImpl.java
copy
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/{service/registry/impl/RegistryDataServiceImpl.java
=> function/metadata/handler/db/GroupMetadataHandlerToDbImpl.java} (50%)
copy
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/{service/registry/impl/RegistryDataServiceImpl.java
=> function/metadata/handler/db/RegistryMetadataHandlerToDbImpl.java} (55%)
create mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/metadata/handler/db/RuntimeMetadataHandlerToDbImpl.java
create mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/metadata/handler/db/TopicMetadataHandlerToDbImpl.java
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/remoting/client/GetClientResponse.java
=>
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/metadata/syncservice/SyncDataService.java
(74%)
create mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/metadata/syncservice/SyncDataServiceWrapper.java
copy
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/{service/config/instanceoperation/StoreConfigService.java
=> function/metadata/syncservice/cluster/AclSyncFromClusterService.java} (54%)
create mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/metadata/syncservice/cluster/ConfigSyncFromClusterService.java
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/remoting/group/GetGroupsResponse.java
=>
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/metadata/syncservice/cluster/GroupSyncFromClusterService.java
(52%)
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/remoting/offset/ResetOffsetResponse.java
=>
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/metadata/syncservice/cluster/InstanceUserFromClusterService.java
(81%)
create mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/metadata/syncservice/cluster/RuntimeSyncFromClusterService.java
create mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/metadata/syncservice/cluster/TopicSyncFromClusterService.java
copy
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/{service/config/instanceoperation/StoreConfigService.java
=> function/metadata/syncservice/db/TopicSyncFromDbService.java} (57%)
create mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/function/optration/TopicMetadataHandlerToClusterImpl.java
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/remoting/topic/DeleteTopicResponse.java
=>
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/modle/dto/meta/NewMetaDTO.java
(87%)
create mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/DataServiceWrapper.java
delete mode 100644
eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/connection/ConnectionService.java
create mode 100644
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/EventMeshDashboardApplicationTest.java
create mode 100644
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/cache/ClusterCacheBase.java
create mode 100644
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/cache/ClusterCacheTest.java
create mode 100644
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/meta/NacosNamingServiceCheckTest.java
delete mode 100644
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/meta/NacosRegisterCheckTest.java
rename
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/storage/rocketmq4/{RocketmqBrokerCheckTest.java
=> Rocketmq4BrokerCheckTest.java} (54%)
rename
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/storage/rocketmq4/{RocketmqNameserverCheckTest.java
=> Rocketmq4NameserverCheckTest.java} (54%)
create mode 100644
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/storage/rocketmq4/Rocketmq4TopicCheckTest.java
delete mode 100644
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/storage/rocketmq4/RocketmqTopicCheckTest.java
create mode 100644
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/metadata/MetadataManagerTest.java
copy
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/{mapper/meta/MetaMapperTest.java
=> function/metadata/handler/db/ClusterMetadataHandlerToDbImplTest.java} (51%)
copy
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/{mapper/meta/MetaMapperTest.java
=> function/metadata/handler/db/ConfigMetadataHandlerToDbImplTest.java} (66%)
create mode 100644
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/metadata/handler/db/ConnectionMetadataHandlerToDbImplTest.java
copy
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/{mapper/meta/MetaMapperTest.java
=> function/metadata/handler/db/GroupMetadataHandlerToDbImplTest.java} (58%)
copy
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/{mapper/meta/MetaMapperTest.java
=> function/metadata/handler/db/RegistryMetadataHandlerToDbImplTest.java} (50%)
create mode 100644
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/metadata/handler/db/RuntimeMetadataHandlerToDbImplTest.java
copy
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/{mapper/meta/MetaMapperTest.java
=> function/metadata/handler/db/TopicMetadataHandlerToDbImplTest.java} (51%)
create mode 100644
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/metadata/syncservice/cluster/TopicSyncFromClusterServiceTest.java
create mode 100644
eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/spring/support/FunctionManagerTest.java
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/constant/ApiPrefix.java
=> eventmesh-dashboard-console/src/test/resources/runtime-test.sql (56%)
copy eventmesh-dashboard-console/src/test/resources/{client-test.sql =>
store-test.sql} (50%)
copy
eventmesh-dashboard-common/src/main/java/org/apache/eventmesh/dashboard/common/constant/ApiPrefix.java
=> eventmesh-dashboard-console/src/test/resources/topic-test.sql (52%)
create mode 100644
eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/meta/runtime/NacosRuntimeCore.java
create mode 100644
eventmesh-dashboard-core/src/test/java/org/apache/eventmesh/dashboard/core/function/SDK/operation/NacosNamingSDKOperationTest.java
rename
eventmesh-dashboard-core/src/test/java/org/apache/eventmesh/dashboard/core/function/SDK/operation/{RedisSDKCreateOperationTest.java
=> RedisSDKOperationTest.java} (95%)
create mode 100644
eventmesh-dashboard-core/src/test/java/org/apache/eventmesh/dashboard/core/meta/runtime/NacosRuntimeCoreTest.java
copy
eventmesh-dashboard-service/src/main/java/org/apache/eventmesh/dashboard/service/remoting/{ClientRemotingService.java
=> MetaRemotingService.java} (73%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
