Package org.elasticsearch.cluster.routing.allocation

Class DiskThresholdMonitor

java.lang.Object

org.elasticsearch.cluster.routing.allocation.DiskThresholdMonitor

public class DiskThresholdMonitor
extends java.lang.Object

Listens for a node to go over the high watermark and kicks off an empty reroute if it does. Also responsible for logging about nodes that have passed the disk watermarks

Constructor Summary

Constructors

Constructor	Description
DiskThresholdMonitor(Settings settings, java.util.function.Supplier<ClusterState> clusterStateSupplier, ClusterSettings clusterSettings, Client client, java.util.function.LongSupplier currentTimeMillisSupplier, RerouteService rerouteService)

Method Summary

Modifier and Type	Method	Description
void	onNewInfo(ClusterInfo info)
protected void	updateIndicesReadOnly(java.util.Set<java.lang.String> indicesToUpdate, ActionListener<java.lang.Void> listener, boolean readOnly)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DiskThresholdMonitor

public DiskThresholdMonitor(Settings settings,
                            java.util.function.Supplier<ClusterState> clusterStateSupplier,
                            ClusterSettings clusterSettings,
                            Client client,
                            java.util.function.LongSupplier currentTimeMillisSupplier,
                            RerouteService rerouteService)

Method Detail

onNewInfo

public void onNewInfo(ClusterInfo info)

updateIndicesReadOnly

protected void updateIndicesReadOnly(java.util.Set<java.lang.String> indicesToUpdate,
                                     ActionListener<java.lang.Void> listener,
                                     boolean readOnly)