public interface ClusterStateProvider extends Closeable
Modifier and Type | Method and Description |
---|---|
void |
connect() |
Map<String,Object> |
getClusterProperties()
Obtain cluster properties.
|
default <T> T |
getClusterProperty(String propertyName)
Obtain a cluster property, or null if it doesn't exist.
|
default <T> T |
getClusterProperty(String key,
T defaultValue)
Obtain a cluster property, or the default value if it doesn't exist.
|
ClusterState |
getClusterState()
Obtain the current cluster state.
|
Set<String> |
getLiveNodes()
Obtain set of live_nodes for the cluster.
|
String |
getPolicyNameByCollection(String coll)
Get the collection-specific policy
|
ClusterState.CollectionRef |
getState(String collection)
Obtain the state of the collection (cluster status).
|
List<String> |
resolveAlias(String alias)
Given a collection alias, returns a list of collections it points to, or returns a singleton list of the input if
it's not an alias.
|
ClusterState.CollectionRef getState(String collection)
List<String> resolveAlias(String alias)
ClusterState getClusterState() throws IOException
IOException
Map<String,Object> getClusterProperties()
default <T> T getClusterProperty(String key, T defaultValue)
default <T> T getClusterProperty(String propertyName)
String getPolicyNameByCollection(String coll)
void connect()
Copyright © 2000-2018 Apache Software Foundation. All Rights Reserved.