java.io.Closeable
, java.lang.AutoCloseable
public class MasterFaultDetection extends FaultDetection
Modifier and Type | Class | Description |
---|---|---|
static interface |
MasterFaultDetection.Listener |
|
static class |
MasterFaultDetection.MasterPingRequest |
Modifier and Type | Field | Description |
---|---|---|
static java.lang.String |
MASTER_PING_ACTION_NAME |
deprecationLogger, logger, settings
clusterName, CONNECT_ON_NETWORK_DISCONNECT_SETTING, connectionListener, connectOnNetworkDisconnect, PING_INTERVAL_SETTING, PING_RETRIES_SETTING, PING_TIMEOUT_SETTING, pingInterval, pingRetryCount, pingRetryTimeout, REGISTER_CONNECTION_LISTENER_SETTING, registerConnectionListener, threadPool, transportService
Constructor | Description |
---|---|
MasterFaultDetection(Settings settings,
ThreadPool threadPool,
TransportService transportService,
java.util.function.Supplier<ClusterState> clusterStateSupplier,
MasterService masterService,
ClusterName clusterName) |
Modifier and Type | Method | Description |
---|---|---|
void |
addListener(MasterFaultDetection.Listener listener) |
|
void |
close() |
|
protected void |
handleTransportDisconnect(DiscoveryNode node) |
|
DiscoveryNode |
masterNode() |
|
void |
removeListener(MasterFaultDetection.Listener listener) |
|
void |
restart(DiscoveryNode masterNode,
java.lang.String reason) |
|
void |
stop(java.lang.String reason) |
logDeprecatedSetting, logRemovedSetting, nodeName
public static final java.lang.String MASTER_PING_ACTION_NAME
public MasterFaultDetection(Settings settings, ThreadPool threadPool, TransportService transportService, java.util.function.Supplier<ClusterState> clusterStateSupplier, MasterService masterService, ClusterName clusterName)
public DiscoveryNode masterNode()
public void addListener(MasterFaultDetection.Listener listener)
public void removeListener(MasterFaultDetection.Listener listener)
public void restart(DiscoveryNode masterNode, java.lang.String reason)
public void stop(java.lang.String reason)
public void close()
close
in interface java.lang.AutoCloseable
close
in interface java.io.Closeable
close
in class FaultDetection
protected void handleTransportDisconnect(DiscoveryNode node)