This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a change to branch feat/runtime-manager-backup
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
from 97f5ff1 feat:support run on k8s integration with framework.
add e6fab4d feat:create worker and env on k8s,according to the DB
declaration.
No new revisions were added by this update.
Summary of changes:
.../cluster/mybatis/mapper/EventClusterMapper.java | 5 +++
.../repository/MybatisClusterRepository.java | 16 +++++++-
.../worker/mybatis/mapper/EventWorkerMapper.java | 3 ++
.../repository/MybatisWorkerRepository.java | 27 ++++++++-----
.../main/resources/mybatis/EventClusterMapper.xml | 24 ++++++++++++
.../main/resources/mybatis/EventWorkerMapper.xml | 14 +++++++
.../runtime/manager/cluster/ClusterService.java | 17 ++++++---
.../manager/repository/ClusterRepository.java | 4 ++
.../adapter/runtime/manager/watch/WatchWorker.java | 24 +++++++++---
.../manager/worker/WorkerSelectorService.java | 2 +-
.../runtime/manager/worker/WorkerService.java | 15 ++++++--
.../runtime/manager/worker/WorkerStatusEnum.java | 2 +-
.../WorkerInstanceRepositoryOnK8STest.java | 7 ++++
.../common/exception/EventBridgeErrorCode.java | 6 ++-
start/pom.xml | 28 ++++++++++++++
.../rocketmq/eventbridge/demo/DefaultDemo.java | 44 +++++++++++++++++++---
16 files changed, 206 insertions(+), 32 deletions(-)
