public class MasterFaultDetection extends FaultDetection
Modifier and Type | Class and Description |
---|---|
static interface |
MasterFaultDetection.Listener |
static class |
MasterFaultDetection.MasterPingRequest |
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
MASTER_PING_ACTION_NAME |
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
deprecationLogger, logger, settings
Constructor and Description |
---|
MasterFaultDetection(Settings settings,
ThreadPool threadPool,
TransportService transportService,
java.util.function.Supplier<ClusterState> clusterStateSupplier,
MasterService masterService,
ClusterName clusterName) |
Modifier and Type | Method and Description |
---|---|
void |
addListener(MasterFaultDetection.Listener listener) |
void |
close() |
protected void |
handleTransportDisconnect(DiscoveryNode node)
This method will be called when the
TransportService raised a node disconnected event |
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.io.Closeable
close
in interface java.lang.AutoCloseable
close
in class FaultDetection
protected void handleTransportDisconnect(DiscoveryNode node)
FaultDetection
TransportService
raised a node disconnected event