Class ClusterService
java.lang.Object
org.elasticsearch.common.component.AbstractLifecycleComponent
org.elasticsearch.cluster.service.ClusterService
- All Implemented Interfaces:
Closeable
,AutoCloseable
,LifecycleComponent
,org.elasticsearch.core.Releasable
-
Field Summary
Fields inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent
lifecycle
-
Constructor Summary
ConstructorDescriptionClusterService
(Settings settings, ClusterSettings clusterSettings, MasterService masterService, ClusterApplierService clusterApplierService) ClusterService
(Settings settings, ClusterSettings clusterSettings, ThreadPool threadPool) -
Method Summary
Modifier and TypeMethodDescriptionvoid
Adds a high priority applier of updated cluster states.void
addListener
(ClusterStateListener listener) Add a listener for updated cluster statesvoid
Add a listener for on/off local node master eventsvoid
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.static boolean
protected void
doClose()
protected void
doStart()
protected void
doStop()
final String
The name of this node.The node's settings.The local node.void
removeApplier
(ClusterStateApplier applier) Removes an applier of updated cluster states.void
removeListener
(ClusterStateListener listener) Removes a listener for updated cluster states.void
setNodeConnectionsService
(NodeConnectionsService nodeConnectionsService) void
setRerouteService
(RerouteService rerouteService) state()
The currently applied cluster state.<T extends ClusterStateTaskListener>
voidsubmitStateUpdateTask
(String source, T task, ClusterStateTaskConfig config, ClusterStateTaskExecutor<T> executor) Submits a cluster state update task; submitted updates will be batched across the same instance of executor.<T extends ClusterStateTaskConfig & ClusterStateTaskListener>
voidsubmitStateUpdateTask
(String source, T updateTask, ClusterStateTaskExecutor<T> executor) Submits a cluster state update taskMethods inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent
addLifecycleListener, close, lifecycleState, removeLifecycleListener, start, stop
-
Field Details
-
USER_DEFINED_METADATA
-
-
Constructor Details
-
ClusterService
-
ClusterService
public ClusterService(Settings settings, ClusterSettings clusterSettings, MasterService masterService, ClusterApplierService clusterApplierService)
-
-
Method Details
-
setNodeConnectionsService
-
setRerouteService
-
getRerouteService
-
doStart
protected void doStart()- Specified by:
doStart
in classAbstractLifecycleComponent
-
doStop
protected void doStop()- Specified by:
doStop
in classAbstractLifecycleComponent
-
doClose
protected void doClose()- Specified by:
doClose
in classAbstractLifecycleComponent
-
localNode
The local node. -
operationRouting
-
state
The currently applied cluster state. TODO: Should be renamed to appliedState / appliedClusterState -
addHighPriorityApplier
Adds a high priority applier of updated cluster states. -
addLowPriorityApplier
Adds an applier which will be called after all high priority and normal appliers have been called. -
addStateApplier
Adds a applier of updated cluster states. -
removeApplier
Removes an applier of updated cluster states. -
addListener
Add a listener for updated cluster states -
removeListener
Removes a listener for updated cluster states. -
addLocalNodeMasterListener
Add a listener for on/off local node master events -
getMasterService
-
getClusterApplierService
-
assertClusterOrMasterStateThread
public static boolean assertClusterOrMasterStateThread() -
getClusterName
-
getClusterSettings
-
getSettings
The node's settings. -
getNodeName
The name of this node. -
submitStateUpdateTask
public <T extends ClusterStateTaskConfig & ClusterStateTaskListener> void submitStateUpdateTask(String source, T updateTask, ClusterStateTaskExecutor<T> executor) Submits a cluster state update task- Parameters:
source
- the source of the cluster state update taskupdateTask
- the full context for the cluster state updateexecutor
- the executor to use for the submitted task.
-
submitStateUpdateTask
public <T extends ClusterStateTaskListener> void submitStateUpdateTask(String source, T task, ClusterStateTaskConfig config, ClusterStateTaskExecutor<T> executor) 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 tasktask
- the state and the callback needed for the cluster state update taskconfig
- the cluster state update task configurationexecutor
- the cluster state update task executor; tasks that share the same executor will be executed batches on this executor
-