Package org.elasticsearch.cluster.service

Class ClusterService

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.common.component.AbstractLifecycleComponent

org.elasticsearch.cluster.service.ClusterService

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, LifecycleComponent, Releasable

public class ClusterService
extends AbstractLifecycleComponent

Field Summary

Fields

Modifier and Type	Field	Description
static Setting<TimeValue>	CLUSTER_SERVICE_SLOW_TASK_LOGGING_THRESHOLD_SETTING

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

deprecationLogger, logger, settings

Fields inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent

lifecycle

Constructor Summary

Constructors

Constructor	Description
ClusterService(Settings settings, ClusterSettings clusterSettings, ThreadPool threadPool, java.util.Map<java.lang.String,java.util.function.Supplier<ClusterState.Custom>> initialClusterStateCustoms)

Method Summary

Modifier and Type	Method	Description
void	addHighPriorityApplier(ClusterStateApplier applier)	Adds a high priority applier of updated cluster states.
void	addListener(ClusterStateListener listener)	Add a listener for updated cluster states
void	addLocalNodeMasterListener(LocalNodeMasterListener listener)	Add a listener for on/off local node master events
void	addLowPriorityApplier(ClusterStateApplier applier)	Adds an applier which will be called after all high priority and normal appliers have been called.
void	addStateApplier(ClusterStateApplier applier)	Adds a applier of updated cluster states.
void	addTimeoutListener(TimeValue timeout, TimeoutClusterStateListener listener)	Adds a cluster state listener that is expected to be removed during a short period of time.
static boolean	assertClusterOrMasterStateThread()
protected void	doClose()
protected void	doStart()
protected void	doStop()
ClusterApplierService	getClusterApplierService()
ClusterName	getClusterName()
ClusterSettings	getClusterSettings()
MasterService	getMasterService()
Settings	getSettings()
DiscoveryNode	localNode()	The local node.
ClusterState.Builder	newClusterStateBuilder()	Creates a new cluster state builder that is initialized with the cluster name and all initial cluster state customs.
OperationRouting	operationRouting()
void	removeApplier(ClusterStateApplier applier)	Removes an applier of updated cluster states.
void	removeListener(ClusterStateListener listener)	Removes a listener for updated cluster states.
void	removeLocalNodeMasterListener(LocalNodeMasterListener listener)	Remove the given listener for on/off local master events
void	removeTimeoutListener(TimeoutClusterStateListener listener)	Removes a timeout listener for updated cluster states.
void	setNodeConnectionsService(NodeConnectionsService nodeConnectionsService)
ClusterState	state()	The currently applied cluster state.
<T extends ClusterStateTaskConfig & ClusterStateTaskExecutor<T> & ClusterStateTaskListener> void	submitStateUpdateTask(java.lang.String source, T updateTask)	Submits a cluster state update task; unlike submitStateUpdateTask(String, Object, ClusterStateTaskConfig, ClusterStateTaskExecutor, ClusterStateTaskListener), submitted updates will not be batched.
<T> void	submitStateUpdateTask(java.lang.String source, T task, ClusterStateTaskConfig config, ClusterStateTaskExecutor<T> executor, ClusterStateTaskListener listener)	Submits a cluster state update task; submitted updates will be batched across the same instance of executor.
<T> void	submitStateUpdateTasks(java.lang.String source, java.util.Map<T,ClusterStateTaskListener> tasks, ClusterStateTaskConfig config, ClusterStateTaskExecutor<T> executor)	Submits a batch of cluster state update tasks; submitted updates are guaranteed to be processed together, potentially with more tasks of the same executor.

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

logDeprecatedSetting, logRemovedSetting, nodeName

Methods inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent

addLifecycleListener, close, lifecycleState, removeLifecycleListener, start, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

CLUSTER_SERVICE_SLOW_TASK_LOGGING_THRESHOLD_SETTING

public static final Setting<TimeValue> CLUSTER_SERVICE_SLOW_TASK_LOGGING_THRESHOLD_SETTING

Constructor Detail

ClusterService

public ClusterService(Settings settings,
                      ClusterSettings clusterSettings,
                      ThreadPool threadPool,
                      java.util.Map<java.lang.String,java.util.function.Supplier<ClusterState.Custom>> initialClusterStateCustoms)

Method Detail

newClusterStateBuilder

public ClusterState.Builder newClusterStateBuilder()

Creates a new cluster state builder that is initialized with the cluster name and all initial cluster state customs.

setNodeConnectionsService

public void setNodeConnectionsService(NodeConnectionsService nodeConnectionsService)

doStart

protected void doStart()

Specified by:

doStart in class AbstractLifecycleComponent

doStop

protected void doStop()

Specified by:

doStop in class AbstractLifecycleComponent

doClose

protected void doClose()

Specified by:

doClose in class AbstractLifecycleComponent

localNode

public DiscoveryNode localNode()

The local node.

operationRouting

public OperationRouting operationRouting()

state

public ClusterState state()

The currently applied cluster state. TODO: Should be renamed to appliedState / appliedClusterState

addHighPriorityApplier

public void addHighPriorityApplier(ClusterStateApplier applier)

Adds a high priority applier of updated cluster states.

addLowPriorityApplier

public void addLowPriorityApplier(ClusterStateApplier applier)

Adds an applier which will be called after all high priority and normal appliers have been called.

addStateApplier

public void addStateApplier(ClusterStateApplier applier)

Adds a applier of updated cluster states.

removeApplier

public void removeApplier(ClusterStateApplier applier)

Removes an applier of updated cluster states.

addListener

public void addListener(ClusterStateListener listener)

Add a listener for updated cluster states

removeListener

public void removeListener(ClusterStateListener listener)

Removes a listener for updated cluster states.

removeTimeoutListener

public void removeTimeoutListener(TimeoutClusterStateListener listener)

Removes a timeout listener for updated cluster states.

addLocalNodeMasterListener

public void addLocalNodeMasterListener(LocalNodeMasterListener listener)

Add a listener for on/off local node master events

removeLocalNodeMasterListener

public void removeLocalNodeMasterListener(LocalNodeMasterListener listener)

Remove the given listener for on/off local master events

addTimeoutListener

public void addTimeoutListener(@Nullable
                               TimeValue timeout,
                               TimeoutClusterStateListener listener)

Adds a cluster state listener that is expected to be removed during a short period of time. If provided, the listener will be notified once a specific time has elapsed. NOTE: the listener is not removed on timeout. This is the responsibility of the caller.

getMasterService

public MasterService getMasterService()

getClusterApplierService

public ClusterApplierService getClusterApplierService()

assertClusterOrMasterStateThread

public static boolean assertClusterOrMasterStateThread()

getClusterName

public ClusterName getClusterName()

getClusterSettings

public ClusterSettings getClusterSettings()

getSettings

public Settings getSettings()

submitStateUpdateTask

public <T extends ClusterStateTaskConfig & ClusterStateTaskExecutor<T> & ClusterStateTaskListener> void submitStateUpdateTask(java.lang.String source,
                                                                                                                              T updateTask)

Submits a cluster state update task; unlike submitStateUpdateTask(String, Object, ClusterStateTaskConfig, ClusterStateTaskExecutor, ClusterStateTaskListener), submitted updates will not be batched.

Parameters:

source - the source of the cluster state update task

updateTask - the full context for the cluster state update task

submitStateUpdateTask

public <T> void submitStateUpdateTask(java.lang.String source,
                                      T task,
                                      ClusterStateTaskConfig config,
                                      ClusterStateTaskExecutor<T> executor,
                                      ClusterStateTaskListener listener)

Submits a cluster state update task; submitted updates will be batched across the same instance of executor. The exact batching semantics depend on the underlying implementation but a rough guideline is that if the update task is submitted while there are pending update tasks for the same executor, these update tasks will all be executed on the executor in a single batch

Type Parameters:

T - the type of the cluster state update task state

Parameters:

source - the source of the cluster state update task

task - the state needed for the cluster state update task

config - the cluster state update task configuration

executor - the cluster state update task executor; tasks that share the same executor will be executed batches on this executor

listener - callback after the cluster state update task completes

submitStateUpdateTasks

public <T> void submitStateUpdateTasks(java.lang.String source,
                                       java.util.Map<T,ClusterStateTaskListener> tasks,
                                       ClusterStateTaskConfig config,
                                       ClusterStateTaskExecutor<T> executor)

Submits a batch of cluster state update tasks; submitted updates are guaranteed to be processed together, potentially with more tasks of the same executor.

Type Parameters:

T - the type of the cluster state update task state

Parameters:

source - the source of the cluster state update task

tasks - a map of update tasks and their corresponding listeners

config - the cluster state update task configuration

executor - the cluster state update task executor; tasks that share the same executor will be executed batches on this executor