- All Implemented Interfaces:
public abstract class AckedClusterStateUpdateTask extends ClusterStateUpdateTask implements AckedClusterStateTaskListener
An extension interface to
ClusterStateUpdateTaskthat allows to be notified when all the nodes have acknowledged a cluster state update request
Nested Class Summary
Nested classes/interfaces inherited from interface org.elasticsearch.cluster.ClusterStateTaskConfig
Method SummaryModifier and TypeMethodDescription
final TimeValueAcknowledgement timeout, maximum time interval to wait for acknowledgements
booleanCalled to determine which nodes the acknowledgement is expected from
voidCalled once all the nodes have acknowledged the cluster state update request.
voidA callback for when task execution fails.
Methods inherited from class org.elasticsearch.cluster.ClusterStateUpdateTask
clusterStatePublished, describeTasks, execute, execute, priority, runOnlyOnMaster, timeout
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
mustAckpublic boolean mustAck
(DiscoveryNode discoveryNode)Called to determine which nodes the acknowledgement is expected from
onAllNodesAckedCalled once all the nodes have acknowledged the cluster state update request. Must be very lightweight execution, since it gets executed on the cluster service thread.
newResponseprotected AcknowledgedResponse newResponse
onAckTimeoutpublic void onAckTimeout()
onFailureDescription copied from class:
ClusterStateUpdateTaskA callback for when task execution fails. Implementations of this callback should not throw exceptions: an exception thrown here is logged by the master service at
ERRORlevel and otherwise ignored. If log-and-ignore is the right behaviour then implementations should do so themselves, typically using a more specific logger and at a less dramatic log level.
ackTimeoutpublic final TimeValue ackTimeout()Acknowledgement timeout, maximum time interval to wait for acknowledgements