java.lang.Object
org.elasticsearch.cluster.coordination.LagDetector
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.
-
Nested Class Summary
Nested Classes -
Field Summary
FieldsModifier and TypeFieldDescription -
Constructor Summary
ConstructorsConstructorDescriptionLagDetector(Settings settings, ThreadPool threadPool, LagDetector.LagListener lagListener, Supplier<DiscoveryNode> localNodeSupplier) -
Method Summary
Modifier and TypeMethodDescriptionvoidvoidsetAppliedVersion(DiscoveryNode discoveryNode, long appliedVersion) voidsetTrackedNodes(Iterable<DiscoveryNode> discoveryNodes) voidstartLagDetector(long version) toString()
-
Field Details
-
CLUSTER_FOLLOWER_LAG_TIMEOUT_SETTING
-
-
Constructor Details
-
LagDetector
public LagDetector(Settings settings, ThreadPool threadPool, LagDetector.LagListener lagListener, Supplier<DiscoveryNode> localNodeSupplier)
-
-
Method Details