Interface ClusterStatePublisher.AckListener

Enclosing interface:
ClusterStatePublisher

public static interface ClusterStatePublisher.AckListener
  • Method Summary

    Modifier and Type Method Description
    void onCommit​(TimeValue commitTime)
    Should be called when the cluster coordination layer has committed the cluster state (i.e.
    void onNodeAck​(DiscoveryNode node, java.lang.Exception e)
    Should be called whenever the cluster coordination layer receives confirmation from a node that it has successfully applied the cluster state.
  • Method Details

    • onCommit

      void onCommit​(TimeValue commitTime)
      Should be called when the cluster coordination layer has committed the cluster state (i.e. even if this publication fails, it is guaranteed to appear in future publications).
      Parameters:
      commitTime - the time it took to commit the cluster state
    • onNodeAck

      void onNodeAck​(DiscoveryNode node, @Nullable java.lang.Exception e)
      Should be called whenever the cluster coordination layer receives confirmation from a node that it has successfully applied the cluster state. In case of failures, an exception should be provided as parameter.
      Parameters:
      node - the node
      e - the optional exception