Package org.elasticsearch.cluster.coordination

Interface LagDetector.LagListener

Enclosing class:
LagDetector
public static interface LagDetector.LagListener

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    onLagDetected(DiscoveryNode discoveryNode, long appliedVersion, long expectedVersion)
    Called when a node is detected as lagging and should be removed from the cluster.

  • Method Details

    • onLagDetected

      void onLagDetected(DiscoveryNode discoveryNode, long appliedVersion, long expectedVersion)
      Called when a node is detected as lagging and should be removed from the cluster.
      Parameters:
      discoveryNode - the node that is lagging.
      appliedVersion - the cluster state version that the node has definitely applied
      expectedVersion - the cluster state version that we were waiting for the node to apply