You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by me...@apache.org on 2021/09/18 09:40:01 UTC
[shardingsphere] branch master updated: Rename executionnode to
execution_nodes for reg center (#12558)
This is an automated email from the ASF dual-hosted git repository.
menghaoran pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new 9041588 Rename executionnode to execution_nodes for reg center (#12558)
9041588 is described below
commit 9041588a722ed44fd9c1507af65773182959fc4c
Author: Liang Zhang <te...@163.com>
AuthorDate: Sat Sep 18 17:39:21 2021 +0800
Rename executionnode to execution_nodes for reg center (#12558)
---
.../cluster/coordinator/registry/process/node/ProcessNode.java | 6 +++---
.../registry/process/subscriber/ProcessRegistrySubscriberTest.java | 2 +-
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/process/node/ProcessNode.java b/shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/process/node/ProcessNode.java
index 45efbee..5b68b01 100644
--- a/shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/process/node/ProcessNode.java
+++ b/shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/process/node/ProcessNode.java
@@ -27,7 +27,7 @@ import lombok.NoArgsConstructor;
@NoArgsConstructor(access = AccessLevel.PRIVATE)
public final class ProcessNode {
- private static final String EXECUTION_NODE_NAME = "executionnodes";
+ private static final String EXECUTION_NODES = "execution_nodes";
/**
* Get execution nodes path.
@@ -35,7 +35,7 @@ public final class ProcessNode {
* @return execution nodes path
*/
public static String getExecutionNodesPath() {
- return Joiner.on("/").join("", EXECUTION_NODE_NAME);
+ return Joiner.on("/").join("", EXECUTION_NODES);
}
/**
@@ -45,6 +45,6 @@ public final class ProcessNode {
* @return execution path
*/
public static String getExecutionPath(final String executionId) {
- return Joiner.on("/").join("", EXECUTION_NODE_NAME, executionId);
+ return Joiner.on("/").join("", EXECUTION_NODES, executionId);
}
}
diff --git a/shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/process/subscriber/ProcessRegistrySubscriberTest.java b/shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/process/subscriber/ProcessRegistrySubscriberTest.java
index cf7057b..d05fb96 100644
--- a/shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/process/subscriber/ProcessRegistrySubscriberTest.java
+++ b/shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/process/subscriber/ProcessRegistrySubscriberTest.java
@@ -83,7 +83,7 @@ public final class ProcessRegistrySubscriberTest {
ExecuteProcessSummaryReportEvent event = new ExecuteProcessSummaryReportEvent(executeProcessContext);
ProcessRegistrySubscriber subscriber = new ProcessRegistrySubscriber(repository);
subscriber.reportExecuteProcessSummary(event);
- verify(repository).persist("/executionnodes/id", YamlEngine.marshal(new YamlExecuteProcessContext(executeProcessContext)));
+ verify(repository).persist("/execution_nodes/id", YamlEngine.marshal(new YamlExecuteProcessContext(executeProcessContext)));
}
@Test