public class SnapshotClusterStateProvider extends Object implements ClusterStateProvider
ClusterStateProvider
.Constructor and Description |
---|
SnapshotClusterStateProvider(ClusterStateProvider other) |
SnapshotClusterStateProvider(Map<String,Object> snapshot) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
connect() |
Map<String,String> |
getAliasProperties(String alias) |
Map<String,Object> |
getClusterProperties() |
ClusterState |
getClusterState() |
Set<String> |
getLiveNodes() |
String |
getPolicyNameByCollection(String coll) |
Map<String,Object> |
getSnapshot() |
ClusterState.CollectionRef |
getState(String collection) |
List<String> |
resolveAlias(String alias) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getClusterProperty, getClusterProperty, getCollection, isRoutedAlias, resolveSimpleAlias
isClosed
public SnapshotClusterStateProvider(ClusterStateProvider other) throws Exception
Exception
public ClusterState.CollectionRef getState(String collection)
getState
in interface ClusterStateProvider
public Set<String> getLiveNodes()
getLiveNodes
in interface ClusterStateProvider
public List<String> resolveAlias(String alias)
resolveAlias
in interface ClusterStateProvider
public Map<String,String> getAliasProperties(String alias)
getAliasProperties
in interface ClusterStateProvider
public ClusterState getClusterState() throws IOException
getClusterState
in interface ClusterStateProvider
IOException
public Map<String,Object> getClusterProperties()
getClusterProperties
in interface ClusterStateProvider
public String getPolicyNameByCollection(String coll)
getPolicyNameByCollection
in interface ClusterStateProvider
public void connect()
connect
in interface ClusterStateProvider
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2000-2020 Apache Software Foundation. All Rights Reserved.