This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a commit to branch feat/runtime-manager
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
The following commit(s) were added to refs/heads/feat/runtime-manager by this
push:
new d7df5cd feat:add WorkerInstanceRepositoryOnK8STest test case.
d7df5cd is described below
commit d7df5cde64e4c3426bf9b51ff97c203627473011
Author: 2011shenlin <2011shen...@gmail.com>
AuthorDate: Wed Jan 17 16:41:14 2024 +0800
feat:add WorkerInstanceRepositoryOnK8STest test case.
---
.../manager/k8s/repository/WorkerInstanceRepositoryOnK8STest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/adapter/runtime-on-k8s/src/test/java/org/apache/rocketmq/eventbridge/adapter/runtime/manager/k8s/repository/WorkerInstanceRepositoryOnK8STest.java
b/adapter/runtime-on-k8s/src/test/java/org/apache/rocketmq/eventbridge/adapter/runtime/manager/k8s/repository/WorkerInstanceRepositoryOnK8STest.java
index d96438b..877799e 100644
---
a/adapter/runtime-on-k8s/src/test/java/org/apache/rocketmq/eventbridge/adapter/runtime/manager/k8s/repository/WorkerInstanceRepositoryOnK8STest.java
+++
b/adapter/runtime-on-k8s/src/test/java/org/apache/rocketmq/eventbridge/adapter/runtime/manager/k8s/repository/WorkerInstanceRepositoryOnK8STest.java
@@ -20,7 +20,7 @@ public class WorkerInstanceRepositoryOnK8STest {
Map<String, Object> environments = Maps.newHashMap();
environments.put("key1", "value1");
environments.put("key2", "value2");
- workerInstanceRepositoryOnK8S.applyWorkerInstance("worker-4",
"registry.cn-beijing.cr.aliyuncs.com/eventbridge:20231115195431f55971", new
Gson().fromJson("{\"cpu\":1,\"memory\":1}", WorkerResource.class), null);
+ workerInstanceRepositoryOnK8S.applyWorkerInstance("worker-4",
"registry.cn-beijing.cr.aliyuncs.com/eventbridge:20231115195431f55971", new
Gson().fromJson("{\"cpu\":1,\"memory\":1}", WorkerResource.class),
environments);
}
@Test
