java.io.Closeable, java.lang.AutoCloseable, ClusterStateApplier, LifecycleComponent, Releasablepublic class IndicesClusterStateService extends AbstractLifecycleComponent implements ClusterStateApplier
| Modifier and Type | Class | Description |
|---|---|---|
static interface |
IndicesClusterStateService.AllocatedIndex<T extends IndicesClusterStateService.Shard> |
|
static interface |
IndicesClusterStateService.AllocatedIndices<T extends IndicesClusterStateService.Shard,U extends IndicesClusterStateService.AllocatedIndex<T>> |
|
static interface |
IndicesClusterStateService.Shard |
deprecationLogger, logger, settingslifecycle| Constructor | Description |
|---|---|
IndicesClusterStateService(Settings settings,
IndicesService indicesService,
ClusterService clusterService,
ThreadPool threadPool,
PeerRecoveryTargetService recoveryTargetService,
ShardStateAction shardStateAction,
NodeMappingRefreshAction nodeMappingRefreshAction,
RepositoriesService repositoriesService,
SearchService searchService,
SyncedFlushService syncedFlushService,
PeerRecoverySourceService peerRecoverySourceService,
SnapshotShardsService snapshotShardsService,
PrimaryReplicaSyncer primaryReplicaSyncer,
GlobalCheckpointSyncAction globalCheckpointSyncAction) |
| Modifier and Type | Method | Description |
|---|---|---|
void |
applyClusterState(ClusterChangedEvent event) |
Called when a new cluster state (
ClusterChangedEvent.state() needs to be applied |
protected void |
doClose() |
|
protected void |
doStart() |
|
protected void |
doStop() |
logDeprecatedSetting, logRemovedSetting, nodeNameaddLifecycleListener, close, lifecycleState, removeLifecycleListener, start, stop@Inject public IndicesClusterStateService(Settings settings, IndicesService indicesService, ClusterService clusterService, ThreadPool threadPool, PeerRecoveryTargetService recoveryTargetService, ShardStateAction shardStateAction, NodeMappingRefreshAction nodeMappingRefreshAction, RepositoriesService repositoriesService, SearchService searchService, SyncedFlushService syncedFlushService, PeerRecoverySourceService peerRecoverySourceService, SnapshotShardsService snapshotShardsService, PrimaryReplicaSyncer primaryReplicaSyncer, GlobalCheckpointSyncAction globalCheckpointSyncAction)
protected void doStart()
doStart in class AbstractLifecycleComponentprotected void doStop()
doStop in class AbstractLifecycleComponentprotected void doClose()
doClose in class AbstractLifecycleComponentpublic void applyClusterState(ClusterChangedEvent event)
ClusterStateApplierClusterChangedEvent.state() needs to be appliedapplyClusterState in interface ClusterStateApplier