Class NodeRemovalClusterStateTaskExecutor
java.lang.Object
org.elasticsearch.cluster.coordination.NodeRemovalClusterStateTaskExecutor
- All Implemented Interfaces:
ClusterStateTaskExecutor<NodeRemovalClusterStateTaskExecutor.Task>
,ClusterStateTaskListener
public class NodeRemovalClusterStateTaskExecutor extends java.lang.Object implements ClusterStateTaskExecutor<NodeRemovalClusterStateTaskExecutor.Task>, ClusterStateTaskListener
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
NodeRemovalClusterStateTaskExecutor.Task
Nested classes/interfaces inherited from interface org.elasticsearch.cluster.ClusterStateTaskExecutor
ClusterStateTaskExecutor.ClusterTasksResult<T>, ClusterStateTaskExecutor.TaskResult
-
Constructor Summary
Constructors Constructor Description NodeRemovalClusterStateTaskExecutor(AllocationService allocationService, org.apache.logging.log4j.Logger logger)
-
Method Summary
Modifier and Type Method Description ClusterStateTaskExecutor.ClusterTasksResult<NodeRemovalClusterStateTaskExecutor.Task>
execute(ClusterState currentState, java.util.List<NodeRemovalClusterStateTaskExecutor.Task> tasks)
Update the cluster state based on the current state and the given tasks.protected ClusterStateTaskExecutor.ClusterTasksResult<NodeRemovalClusterStateTaskExecutor.Task>
getTaskClusterTasksResult(ClusterState currentState, java.util.List<NodeRemovalClusterStateTaskExecutor.Task> tasks, ClusterState remainingNodesClusterState)
void
onFailure(java.lang.String source, java.lang.Exception e)
A callback called when execute fails.void
onNoLongerMaster(java.lang.String source)
called when the task was rejected because the local node is no longer master.protected ClusterState
remainingNodesClusterState(ClusterState currentState, DiscoveryNodes.Builder remainingNodesBuilder)
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.elasticsearch.cluster.ClusterStateTaskExecutor
clusterStatePublished, describeTasks, runOnlyOnMaster
Methods inherited from interface org.elasticsearch.cluster.ClusterStateTaskListener
clusterStateProcessed
-
Constructor Details
-
NodeRemovalClusterStateTaskExecutor
public NodeRemovalClusterStateTaskExecutor(AllocationService allocationService, org.apache.logging.log4j.Logger logger)
-
-
Method Details
-
execute
public ClusterStateTaskExecutor.ClusterTasksResult<NodeRemovalClusterStateTaskExecutor.Task> execute(ClusterState currentState, java.util.List<NodeRemovalClusterStateTaskExecutor.Task> tasks) throws java.lang.ExceptionDescription copied from interface:ClusterStateTaskExecutor
Update the cluster state based on the current state and the given tasks. Return the *same instance* if no state should be changed.- Specified by:
execute
in interfaceClusterStateTaskExecutor<NodeRemovalClusterStateTaskExecutor.Task>
- Throws:
java.lang.Exception
-
getTaskClusterTasksResult
protected ClusterStateTaskExecutor.ClusterTasksResult<NodeRemovalClusterStateTaskExecutor.Task> getTaskClusterTasksResult(ClusterState currentState, java.util.List<NodeRemovalClusterStateTaskExecutor.Task> tasks, ClusterState remainingNodesClusterState) -
remainingNodesClusterState
protected ClusterState remainingNodesClusterState(ClusterState currentState, DiscoveryNodes.Builder remainingNodesBuilder) -
onFailure
public void onFailure(java.lang.String source, java.lang.Exception e)Description copied from interface:ClusterStateTaskListener
A callback called when execute fails.- Specified by:
onFailure
in interfaceClusterStateTaskListener
-
onNoLongerMaster
public void onNoLongerMaster(java.lang.String source)Description copied from interface:ClusterStateTaskListener
called when the task was rejected because the local node is no longer master. Used only for tasks submitted toMasterService
.- Specified by:
onNoLongerMaster
in interfaceClusterStateTaskListener
-