Package org.elasticsearch.cluster.coordination

Interface ClusterStatePublisher.AckListener

Enclosing interface:
ClusterStatePublisher
public static interface ClusterStatePublisher.AckListener

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    onCommit(org.elasticsearch.core.TimeValue commitTime)
    Should be called when the cluster coordination layer has committed the cluster state (i.e.
    void
    onNodeAck(DiscoveryNode node, 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(org.elasticsearch.core.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 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