public class IndicesClusterStateService extends AbstractLifecycleComponent implements ClusterStateApplier
Modifier and Type | Class and 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 |
lifecycle
deprecationLogger, logger, settings
Constructor and 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 and 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() |
addLifecycleListener, close, lifecycleState, removeLifecycleListener, start, stop
logDeprecatedSetting, logRemovedSetting, nodeName
@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 AbstractLifecycleComponent
protected void doStop()
doStop
in class AbstractLifecycleComponent
protected void doClose()
doClose
in class AbstractLifecycleComponent
public void applyClusterState(ClusterChangedEvent event)
ClusterStateApplier
ClusterChangedEvent.state()
needs to be appliedapplyClusterState
in interface ClusterStateApplier