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, waitgetClusterProperty, getClusterProperty, getCollection, isRoutedAlias, resolveSimpleAliasisClosedpublic SnapshotClusterStateProvider(ClusterStateProvider other) throws Exception
Exceptionpublic ClusterState.CollectionRef getState(String collection)
getState in interface ClusterStateProviderpublic Set<String> getLiveNodes()
getLiveNodes in interface ClusterStateProviderpublic List<String> resolveAlias(String alias)
resolveAlias in interface ClusterStateProviderpublic Map<String,String> getAliasProperties(String alias)
getAliasProperties in interface ClusterStateProviderpublic ClusterState getClusterState() throws IOException
getClusterState in interface ClusterStateProviderIOExceptionpublic Map<String,Object> getClusterProperties()
getClusterProperties in interface ClusterStateProviderpublic String getPolicyNameByCollection(String coll)
getPolicyNameByCollection in interface ClusterStateProviderpublic void connect()
connect in interface ClusterStateProviderpublic void close()
throws IOException
close in interface Closeableclose in interface AutoCloseableIOExceptionCopyright © 2000-2020 Apache Software Foundation. All Rights Reserved.