Class LagDetector

java.lang.Object
org.elasticsearch.cluster.coordination.LagDetector

public class LagDetector extends Object
A publication can succeed and complete before all nodes have applied the published state and acknowledged it; however we need every node eventually either to apply the published state (or a later state) or be removed from the cluster. This component achieves this by removing any lagging nodes from the cluster after a timeout.
  • Field Details

    • CLUSTER_FOLLOWER_LAG_TIMEOUT_SETTING

      public static final Setting<org.elasticsearch.core.TimeValue> CLUSTER_FOLLOWER_LAG_TIMEOUT_SETTING
  • Constructor Details

  • Method Details

    • setTrackedNodes

      public void setTrackedNodes(Iterable<DiscoveryNode> discoveryNodes)
    • clearTrackedNodes

      public void clearTrackedNodes()
    • setAppliedVersion

      public void setAppliedVersion(DiscoveryNode discoveryNode, long appliedVersion)
    • startLagDetector

      public void startLagDetector(long version)
    • toString

      public String toString()
      Overrides:
      toString in class Object