public interface AckedClusterStateTaskListener extends ClusterStateTaskListener
Modifier and Type | Method and Description |
---|---|
TimeValue |
ackTimeout()
Acknowledgement timeout, maximum time interval to wait for acknowledgements
|
boolean |
mustAck(DiscoveryNode discoveryNode)
Called to determine which nodes the acknowledgement is expected from
|
void |
onAckTimeout()
Called once the acknowledgement timeout defined by
AckedClusterStateUpdateTask.ackTimeout() has expired |
void |
onAllNodesAcked(java.lang.Exception e)
Called once all the nodes have acknowledged the cluster state update request.
|
clusterStateProcessed, onFailure, onNoLongerMaster
boolean mustAck(DiscoveryNode discoveryNode)
discoveryNode
- a nodevoid onAllNodesAcked(@Nullable java.lang.Exception e)
e
- optional error that might have been thrownvoid onAckTimeout()
AckedClusterStateUpdateTask.ackTimeout()
has expiredTimeValue ackTimeout()