This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a change to branch feat/runtime-manager
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
from d7df5cd feat:add WorkerInstanceRepositoryOnK8STest test case.
new 52f82fa [runtime-on-k8s] runtime-on-k8s
new 8d72ad2 [runtime-on-k8s] runtime-on-k8s
new 85b3ea9 [runtime-on-k8s] runtime-on-k8s
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
adapter/pom.xml | 1 +
.../repository/WorkerInstanceRepository.java | 10 +-
.../runtime/manager/worker/WorkerResource.java | 4 +-
.../runtime/manager/worker/WorkerStatusEnum.java | 2 +
adapter/runtime-on-k8s/pom.xml | 24 +-
.../manager/k8s/api/BaseK8SApiService.java} | 26 +-
.../manager/k8s/api/K8SConfigMapService.java | 76 +++--
.../manager/k8s/api/K8SCustomResourceService.java | 78 ++++-
.../manager/k8s/api/K8SDeploymentService.java | 144 ++++----
.../manager/k8s/api/K8SNameSpaceService.java | 17 +
.../runtime/manager/k8s/api/KubectlService.java | 114 ++++++-
.../runtime/manager/k8s/common/K8SConstants.java | 20 ++
.../manager/k8s/common/WorkerStatusEnum.java | 47 ---
.../k8s/config/DeploySpecTemplateSpec.java} | 50 +--
.../runtime/manager/k8s/config/SpecContainer.java | 54 +++
.../k8s/model/K8SCRDConnectTaskSetModel.java | 17 +
.../repository/WorkerInstanceRepositoryOnK8S.java | 361 ++++++++++++++++++++-
.../WorkerInstanceRepositoryOnK8STest.java | 134 +++++---
.../src/test/resources/application.properties | 5 +-
.../rocketmq/eventbridge/tools/JsonUtil.java | 34 +-
pom.xml | 2 +-
rocketmq_eventbridge.mv.db | Bin 77824 -> 0 bytes
rocketmq_eventbridge.trace.db | 94 ------
23 files changed, 963 insertions(+), 351 deletions(-)
copy
adapter/{runtime-manager/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/manager/dispatch/WorkerRebalance.java
=>
runtime-on-k8s/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/manager/k8s/api/BaseK8SApiService.java}
(59%)
delete mode 100644
adapter/runtime-on-k8s/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/manager/k8s/common/WorkerStatusEnum.java
copy
adapter/{persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/FlywayConfig.java
=>
runtime-on-k8s/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/manager/k8s/config/DeploySpecTemplateSpec.java}
(57%)
create mode 100644
adapter/runtime-on-k8s/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/manager/k8s/config/SpecContainer.java
copy
infrastructure/src/main/resources/META-INF/services/org.apache.rocketmq.eventbridge.infrastructure.validate.AuthValidation
=> adapter/runtime-on-k8s/src/test/resources/application.properties (90%)
delete mode 100644 rocketmq_eventbridge.mv.db
delete mode 100644 rocketmq_eventbridge.trace.db
