File tree 1 file changed +12
-0
lines changed
server/src/main/java/org/elasticsearch/discovery
1 file changed +12
-0
lines changed Original file line number Diff line number Diff line change @@ -49,7 +49,19 @@ public interface Discovery extends LifecycleComponent {
49
49
void publish (ClusterChangedEvent clusterChangedEvent , AckListener ackListener );
50
50
51
51
interface AckListener {
52
+ /**
53
+ * Should be called when the discovery layer has committed the clusters state (i.e. even if this publication fails,
54
+ * it is guaranteed to appear in future publications).
55
+ * @param commitTime the time it took to commit the cluster state
56
+ */
52
57
void onCommit (TimeValue commitTime );
58
+
59
+ /**
60
+ * Should be called whenever the discovery layer receives confirmation from a node that it has successfully applied
61
+ * the cluster state. In case of failures, an exception should be provided as parameter.
62
+ * @param node the node
63
+ * @param e the optional exception
64
+ */
53
65
void onNodeAck (DiscoveryNode node , @ Nullable Exception e );
54
66
}
55
67
You can’t perform that action at this time.
0 commit comments