Rename GovernanceRepositoryAPI.watchPipeLineRootPath()

apache · Nov 21, 2023 · e9ebe05 · e9ebe05
1 parent ff98084
commit e9ebe05
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 12 deletions.
diff --git a/...hardingsphere/data/pipeline/common/registrycenter/repository/GovernanceRepositoryAPI.java b/...hardingsphere/data/pipeline/common/registrycenter/repository/GovernanceRepositoryAPI.java
@@ -31,6 +31,13 @@
  */
 public interface GovernanceRepositoryAPI {
 
+    /**
+     * Watch pipeLine root path.
+     *
+     * @param listener data changed event listener
+     */
+    void watchPipeLineRootPath(DataChangedEventListener listener);
+
     /**
      * Whether job configuration existed.
      *
@@ -146,13 +153,6 @@ public interface GovernanceRepositoryAPI {
      */
     void deleteJob(String jobId);
 
-    /**
-     * Watch pipeLine root path.
-     *
-     * @param listener data changed event listener
-     */
-    void watchPipeLineRootPath(DataChangedEventListener listener);
-
     /**
      * Persist data.
      *

diff --git a/...ingsphere/data/pipeline/common/registrycenter/repository/GovernanceRepositoryAPIImpl.java b/...ingsphere/data/pipeline/common/registrycenter/repository/GovernanceRepositoryAPIImpl.java
@@ -51,6 +51,11 @@ public final class GovernanceRepositoryAPIImpl implements GovernanceRepositoryAP
 
     private final ClusterPersistRepository repository;
 
+    @Override
+    public void watchPipeLineRootPath(final DataChangedEventListener listener) {
+        repository.watch(PipelineNodePath.DATA_PIPELINE_ROOT, listener);
+    }
+
     @Override
     public boolean isJobConfigurationExisted(final String jobId) {
         return null != repository.getDirectly(PipelineMetaDataNode.getJobConfigurationPath(jobId));
@@ -142,11 +147,6 @@ public void deleteJob(final String jobId) {
         repository.delete(PipelineMetaDataNode.getJobRootPath(jobId));
     }
 
-    @Override
-    public void watchPipeLineRootPath(final DataChangedEventListener listener) {
-        repository.watch(PipelineNodePath.DATA_PIPELINE_ROOT, listener);
-    }
-
     @Override
     public void persist(final String key, final String value) {
         repository.persist(key, value);