add witness

TuGraph-family · Dec 15, 2023 · 64fb6e4 · 64fb6e4
1 parent e19f676
commit 64fb6e4
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/rpc-client/src/main/java/com/antgroup/tugraph/TuGraphDbRpcClient.java b/rpc-client/src/main/java/com/antgroup/tugraph/TuGraphDbRpcClient.java
@@ -338,6 +338,8 @@ private void refreshClientPool() {
  ClusterInfo clusterInfo = JSON.parseObject(JSON.parseArray(result).get(0).toString(), new TypeReference<ClusterInfo>(){});
  List<RaftState> raftStates = clusterInfo.getClusterInfo();
  raftStates.forEach(x -> {
+ if (x.getState().equals(RaftState.StateConstant.WITNESS))
+ return;
  TuGraphSingleRpcClient rpcClient = new TuGraphSingleRpcClient("list://" + x.getRpcAddress(), user, password);
  rpcClientPool.add(rpcClient);
  if (x.getState().equals(RaftState.StateConstant.MASTER)) {

diff --git a/rpc-client/src/main/java/com/antgroup/tugraph/model/RaftState.java b/rpc-client/src/main/java/com/antgroup/tugraph/model/RaftState.java
@@ -28,6 +28,8 @@ public static class StateConstant {
  public final static String MASTER = "MASTER";
 
  public final static String FOLLOW = "FOLLOW";
+
+ public final static String WITNESS = "WITNESS";
  }
 
 }