Modifier and Type | Interface and Description |
---|---|
interface |
TimeoutClusterStateListener
An exception to cluster state listener that allows for timeouts and for post added notifications.
|
Modifier and Type | Class and Description |
---|---|
class |
InternalClusterInfoService
InternalClusterInfoService provides the ClusterInfoService interface,
routinely updated on a timer.
|
Modifier and Type | Method and Description |
---|---|
void |
ClusterService.add(ClusterStateListener listener)
Adds a listener for updated cluster states.
|
void |
ClusterService.addFirst(ClusterStateListener listener)
Adds a priority listener for updated cluster states.
|
void |
ClusterService.addLast(ClusterStateListener listener)
Adds last listener.
|
void |
ClusterService.remove(ClusterStateListener listener)
Removes a listener for updated cluster states.
|
Modifier and Type | Class and Description |
---|---|
class |
MetaDataUpdateSettingsService
Service responsible for submitting update index settings requests
|
Modifier and Type | Class and Description |
---|---|
class |
RoutingService
A
RoutingService listens to clusters state. |
Modifier and Type | Method and Description |
---|---|
void |
InternalClusterService.add(ClusterStateListener listener) |
void |
InternalClusterService.addFirst(ClusterStateListener listener) |
void |
InternalClusterService.addLast(ClusterStateListener listener) |
void |
InternalClusterService.remove(ClusterStateListener listener) |
Modifier and Type | Class and Description |
---|---|
class |
GatewayService |
Modifier and Type | Class and Description |
---|---|
class |
LocalGateway |
Modifier and Type | Class and Description |
---|---|
class |
LocalGatewayMetaState |
Modifier and Type | Class and Description |
---|---|
class |
LocalGatewayShardsState |
Modifier and Type | Class and Description |
---|---|
class |
IndexCache |
Modifier and Type | Class and Description |
---|---|
class |
IndicesClusterStateService |
Modifier and Type | Class and Description |
---|---|
class |
IndicesStore |
Modifier and Type | Class and Description |
---|---|
class |
NodeSettingsService
A service that allows to register for node settings change that can come from cluster
events holding new settings.
|
Modifier and Type | Class and Description |
---|---|
class |
RepositoriesService
Service responsible for maintaining and providing access to snapshot repositories on nodes.
|
Modifier and Type | Class and Description |
---|---|
class |
RiversRouter |
Modifier and Type | Class and Description |
---|---|
class |
RestoreService
Service responsible for restoring snapshots
Restore operation is performed in several stages.
|
class |
SnapshotsService
Service responsible for creating snapshots
A typical snapshot creating process looks like this:
On the master node the
SnapshotsService.createSnapshot(SnapshotRequest, CreateSnapshotListener) is called and makes sure that no snapshots is currently running
and registers the new snapshot in cluster state
When cluster state is updated the SnapshotsService.beginSnapshot(ClusterState, SnapshotMetaData.Entry, boolean, CreateSnapshotListener) method
kicks in and initializes the snapshot in the repository and then populates list of shards that needs to be snapshotted in cluster state
Each data node is watching for these shards and when new shards scheduled for snapshotting appear in the cluster state, data nodes
start processing them through SnapshotsService.processIndexShardSnapshots(SnapshotMetaData) method
Once shard snapshot is created data node updates state of the shard in the cluster state using the SnapshotsService.updateIndexShardSnapshotStatus(UpdateIndexShardSnapshotStatusRequest) method
When last shard is completed master node in SnapshotsService.innerUpdateSnapshotState(org.elasticsearch.snapshots.SnapshotsService.UpdateIndexShardSnapshotStatusRequest) method marks the snapshot as completed
After cluster state is updated, the SnapshotsService.endSnapshot(SnapshotMetaData.Entry) finalizes snapshot in the repository,
notifies all SnapshotsService.snapshotCompletionListeners that snapshot is completed, and finally calls SnapshotsService.removeSnapshotFromClusterState(SnapshotId, SnapshotInfo, Throwable) to remove snapshot from cluster state
|
Copyright © 2009–2015. All rights reserved.