Class LagDetector

  • public class LagDetector
    extends java.lang.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 Detail


        public static final Setting<TimeValue> CLUSTER_FOLLOWER_LAG_TIMEOUT_SETTING
    • Method Detail

      • setTrackedNodes

        public void setTrackedNodes​(java.lang.Iterable<DiscoveryNode> discoveryNodes)
      • clearTrackedNodes

        public void clearTrackedNodes()
      • setAppliedVersion

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

        public void startLagDetector​(long version)
      • toString

        public java.lang.String toString()
        toString in class java.lang.Object