| AsyncShardFetch<T extends BaseNodeResponse> |
Allows to asynchronously fetch shard related data from other nodes for allocation, without blocking
the cluster update thread.
|
| AsyncShardFetch.FetchResult<T extends BaseNodeResponse> |
The result of a fetch operation.
|
| BaseGatewayShardAllocator |
An abstract class that implements basic functionality for allocating
shards to nodes based on shard copies that already exist in the cluster.
|
| ClusterStateUpdaters |
|
| DanglingIndicesState |
The dangling indices state is responsible for finding new dangling indices (indices that have
their state written on disk, but don't exists in the metadata of the cluster), and importing
them into the cluster.
|
| Gateway |
|
| GatewayAllocator |
|
| GatewayMetaState |
Loads (and maybe upgrades) cluster metadata at startup, and persistently stores cluster metadata for future restarts.
|
| GatewayModule |
|
| GatewayService |
|
| IncrementalClusterStateWriter |
Tracks the metadata written to disk, allowing updated metadata to be written incrementally (i.e.
|
| LocalAllocateDangledIndices |
|
| LocalAllocateDangledIndices.AllocateDangledRequest |
|
| LocalAllocateDangledIndices.AllocateDangledResponse |
|
| MetaDataStateFormat<T> |
MetaDataStateFormat is a base class to write checksummed
XContent based files to one or more directories in a standardized directory structure.
|
| MetaStateService |
|
| PersistedClusterStateService |
Stores cluster metadata in a bare Lucene index (per data path) split across a number of documents.
|
| PersistedClusterStateService.OnDiskState |
|
| PersistedClusterStateService.Writer |
|
| PrimaryShardAllocator |
The primary shard allocator allocates unassigned primary shards to nodes that hold
valid copies of the unassigned primaries.
|
| PriorityComparator |
A comparator that compares ShardRouting based on it's indexes priority (index.priority),
it's creation date (index.creation_date), or eventually by it's index name in reverse order.
|
| ReplicaShardAllocator |
|
| TransportNodesListGatewayMetaState |
|
| TransportNodesListGatewayMetaState.NodeGatewayMetaState |
|
| TransportNodesListGatewayMetaState.NodeRequest |
|
| TransportNodesListGatewayMetaState.NodesGatewayMetaState |
|
| TransportNodesListGatewayMetaState.Request |
|
| TransportNodesListGatewayStartedShards |
This transport action is used to fetch the shard version from each node during primary allocation in GatewayAllocator. |
| TransportNodesListGatewayStartedShards.NodeGatewayStartedShards |
|
| TransportNodesListGatewayStartedShards.NodeRequest |
|
| TransportNodesListGatewayStartedShards.NodesGatewayStartedShards |
|
| TransportNodesListGatewayStartedShards.Request |
|