Interface | Description |
---|---|
ClusterInfoService |
Interface for a class used to gather information about a cluster at
regular intervals
|
ClusterInfoService.Listener |
Interface for listeners to implement in order to perform actions when
new information about the cluster has been gathered
|
ClusterService |
The cluster service allowing to both register for cluster state events (
ClusterStateListener )
and submit state update tasks (ClusterStateUpdateTask . |
ClusterState.Custom | |
ClusterState.Custom.Factory<T extends ClusterState.Custom> | |
ClusterStateListener |
A listener to be notified when a cluster state changes.
|
ClusterStateObserver.ChangePredicate | |
ClusterStateObserver.Listener | |
LocalNodeMasterListener |
Enables listening to master changes events of the local node (when the local node becomes the master, and when the local
node cease being a master).
|
TimeoutClusterStateListener |
An exception to cluster state listener that allows for timeouts and for post added notifications.
|
Class | Description |
---|---|
AckedClusterStateUpdateTask<Response> |
An extension interface to
ClusterStateUpdateTask that allows to be notified when
all the nodes have acknowledged a cluster state update request |
ClusterChangedEvent | |
ClusterInfo |
ClusterInfo is an object representing a map of nodes to
DiskUsage
and a map of shard ids to shard sizes, see
InternalClusterInfoService.shardIdentifierFromRouting(String)
for the key used in the shardSizes map |
ClusterModule | |
ClusterName | |
ClusterNameModule | |
ClusterState | |
ClusterState.Builder | |
ClusterStateNonMasterUpdateTask |
This is a marker interface to indicate that the task should be executed
even if the current node is not a master.
|
ClusterStateObserver |
A utility class which simplifies interacting with the cluster state in cases where
one tries to take action based on the current state but may want to wait for a new state
and retry upon failure.
|
ClusterStateObserver.EventPredicate | |
ClusterStateObserver.ValidationPredicate | |
ClusterStateUpdateTask |
A task that can update the cluster state.
|
DiskUsage |
Encapsulation class used to represent the amount of disk used on a node.
|
EmptyClusterInfoService |
ClusterInfoService that provides empty maps for disk usage and shard sizes
|
InternalClusterInfoService |
InternalClusterInfoService provides the ClusterInfoService interface,
routinely updated on a timer.
|
ProcessedClusterStateNonMasterUpdateTask |
A combination between
ProcessedClusterStateUpdateTask and
ClusterStateNonMasterUpdateTask to allow easy creation of anonymous classes |
ProcessedClusterStateUpdateTask |
An extension interface to
ClusterStateUpdateTask that allows to be notified when
the cluster state update has been processed. |
TimeoutClusterStateUpdateTask |
An extension interface to
ClusterStateUpdateTask that allows to associate
a timeout. |
Enum | Description |
---|---|
ClusterState.ClusterStateStatus | |
ClusterState.Metric |
Copyright © 2009–2015. All rights reserved.