ClusterStateTaskListener
AckedClusterStateUpdateTask
public interface AckedClusterStateTaskListener extends ClusterStateTaskListener
Modifier and Type | Method | 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()