Class LagDetector
org.elasticsearch.cluster.coordination.LagDetector
public class LagDetector
extends
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 Summary
-
Constructor Summary
ConstructorDescriptionLagDetector(Settings settings, ThreadPool threadPool, <DiscoveryNode> onLagDetected, <DiscoveryNode> localNodeSupplier)
-
Method Summary
Modifier and TypeMethodDescriptionvoid
void
setAppliedVersion(DiscoveryNode discoveryNode, long appliedVersion)
void
<DiscoveryNode> discoveryNodes)
void
startLagDetector(long version)
toString()
Methods inherited from class java.lang.
, , , , , , , , ,
-
Field Details
-
CLUSTER_FOLLOWER_LAG_TIMEOUT_SETTING
-
-
Constructor Details
-
LagDetector
public LagDetector(Settings settings, ThreadPool threadPool, <DiscoveryNode> onLagDetected, <DiscoveryNode> localNodeSupplier)
-
-
Method Details
-
setTrackedNodes
-
clearTrackedNodes
public void clearTrackedNodes() -
setAppliedVersion
-
startLagDetector
public void startLagDetector(long version) -
toString
public toString()- Overrides:
in class
-