Module org.elasticsearch.server
Class WriteLoadConstraintMonitor
java.lang.Object
org.elasticsearch.cluster.routing.allocation.WriteLoadConstraintMonitor
Monitors the node-level write thread pool usage across the cluster and initiates (coming soon) a rebalancing round (via
RerouteService.reroute(java.lang.String, org.elasticsearch.common.Priority, org.elasticsearch.action.ActionListener<java.lang.Void>)) whenever a node crosses the node-level write load thresholds.
TODO (ES-11992): implement-
Constructor Summary
ConstructorsConstructorDescriptionWriteLoadConstraintMonitor(ClusterSettings clusterSettings, LongSupplier currentTimeMillisSupplier, Supplier<ClusterState> clusterStateSupplier, RerouteService rerouteService) -
Method Summary
Modifier and TypeMethodDescriptionvoidonNewInfo(ClusterInfo clusterInfo) Receives a copy of the latestClusterInfowhenever theClusterInfoServicecollects it.
-
Constructor Details
-
WriteLoadConstraintMonitor
public WriteLoadConstraintMonitor(ClusterSettings clusterSettings, LongSupplier currentTimeMillisSupplier, Supplier<ClusterState> clusterStateSupplier, RerouteService rerouteService)
-
-
Method Details
-
onNewInfo
Receives a copy of the latestClusterInfowhenever theClusterInfoServicecollects it. Processes the newNodeUsageStatsForThreadPoolsand initiates rebalancing, via reroute, if a node in the cluster exceeds thread pool usage thresholds.
-