You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by zh...@apache.org on 2020/07/30 03:12:34 UTC

[shardingsphere] branch master updated: Add unit test (#6516)

This is an automated email from the ASF dual-hosted git repository.

zhangyonglun 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 96ae9a2  Add unit test (#6516)
96ae9a2 is described below

commit 96ae9a2206b5ceee183673cd829c68293f9902ba
Author: Haoran Meng <me...@gmail.com>
AuthorDate: Thu Jul 30 11:12:16 2020 +0800

    Add unit test (#6516)
---
 .../core/facade/OrchestrationFacadeTest.java              | 15 +++++++++++++++
 1 file changed, 15 insertions(+)

diff --git a/shardingsphere-control-panel/shardingsphere-orchestration/shardingsphere-orchestration-core/shardingsphere-orchestration-core-facade/src/test/java/org/apache/shardingsphere/orchestration/core/facade/OrchestrationFacadeTest.java b/shardingsphere-control-panel/shardingsphere-orchestration/shardingsphere-orchestration-core/shardingsphere-orchestration-core-facade/src/test/java/org/apache/shardingsphere/orchestration/core/facade/OrchestrationFacadeTest.java
index dc2e49e..0e82186 100644
--- a/shardingsphere-control-panel/shardingsphere-orchestration/shardingsphere-orchestration-core/shardingsphere-orchestration-core-facade/src/test/java/org/apache/shardingsphere/orchestration/core/facade/OrchestrationFacadeTest.java
+++ b/shardingsphere-control-panel/shardingsphere-orchestration/shardingsphere-orchestration-core/shardingsphere-orchestration-core-facade/src/test/java/org/apache/shardingsphere/orchestration/core/facade/OrchestrationFacadeTest.java
@@ -17,6 +17,8 @@
 
 package org.apache.shardingsphere.orchestration.core.facade;
 
+import org.apache.shardingsphere.cluster.configuration.config.ClusterConfiguration;
+import org.apache.shardingsphere.cluster.configuration.config.HeartbeatConfiguration;
 import org.apache.shardingsphere.infra.auth.Authentication;
 import org.apache.shardingsphere.infra.auth.ProxyUser;
 import org.apache.shardingsphere.infra.config.DataSourceConfiguration;
@@ -108,6 +110,19 @@ public final class OrchestrationFacadeTest {
     }
     
     @Test
+    public void assertInitClusterConfiguration() {
+        HeartbeatConfiguration heartBeatConfiguration = new HeartbeatConfiguration();
+        heartBeatConfiguration.setSql("select 1");
+        heartBeatConfiguration.setInterval(60);
+        heartBeatConfiguration.setRetryEnable(true);
+        heartBeatConfiguration.setRetryMaximum(3);
+        ClusterConfiguration clusterConfiguration = new ClusterConfiguration();
+        clusterConfiguration.setHeartbeat(heartBeatConfiguration);
+        orchestrationFacade.initClusterConfiguration(clusterConfiguration);
+        verify(configCenter).persistClusterConfiguration(clusterConfiguration, false);
+    }
+    
+    @Test
     public void assertClose() {
         orchestrationFacade.close();
         verify(repositoryFacade).close();