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 Detail
-
NodeRemovalClusterStateTaskExecutor
public NodeRemovalClusterStateTaskExecutor(AllocationService allocationService, org.apache.logging.log4j.Logger logger)
-
-
Method Detail
-
execute
public ClusterStateTaskExecutor.ClusterTasksResult<NodeRemovalClusterStateTaskExecutor.Task> execute(ClusterState currentState, java.util.List<NodeRemovalClusterStateTaskExecutor.Task> tasks) throws java.lang.Exception
Description 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
-
-