CurrentMeta implements Releasable { public boolean setKeeperMaster(String clusterId, String shardId, Pair<String, Integer> keeperMaster) { checkClusterSupportKeeper(clusterId); CurrentKeeperShardMeta currentShardMeta = (CurrentKeeperShardMeta) getCurrentShardMetaOrThrowException(clusterId, shardId); return currentShardMeta.setKeeperMaster(keeperMaster); }  Set<String> allClusters(); boolean hasCluster(String clusterId); boolean hasShard(String clusterId, String shardId); boolean watchIfNotWatched(String clusterId, String shardId); void setSurviveKeepers(String clusterId, String shardId, List<KeeperMeta> surviveKeepers,
			KeeperMeta activeKeeper); void addResource(String clusterId, String shardId, Releasable releasable); List<KeeperMeta> getSurviveKeepers(String clusterId, String shardId); boolean setKeeperActive(String clusterId, String shardId, KeeperMeta keeperMeta); KeeperMeta getKeeperActive(String clusterId, String shardId); boolean setKeeperMaster(String clusterId, String shardId, Pair<String, Integer> keeperMaster); Pair<String, Integer> getKeeperMaster(String clusterId, String shardId); void setCurrentCRDTMaster(String clusterId, String shardId,  RedisMeta peerMaster); RedisMeta getCurrentCRDTMaster(String clusterId, String shardId); RedisMeta getCurrentMaster(String clusterId, String shardId); void setPeerMaster(String dcId, String clusterId, String shardId, RedisMeta peerMaster); RedisMeta getPeerMaster(String dcId, String clusterId, String shardId); void removePeerMaster(String dcId, String clusterId, String shardId); Set<String> getUpstreamPeerDcs(String clusterId, String shardId); List<RedisMeta> getAllPeerMasters(String clusterId, String shardId); @Override void release(); void addCluster(final ClusterMeta clusterMeta); CurrentClusterMeta removeCluster(String clusterId); void changeCluster(ClusterMetaComparator comparator); @Override String toString(); static CurrentMeta fromJson(String json);  }
@Test(expected = IllegalArgumentException.class) public void testSetKeeperMasterWithErrorType() { currentMeta.setKeeperMaster(biClusterId, biShardId, Pair.of("127.0.0.1", 6379)); }