org.elasticsearch.discovery.zen

Class NodesFaultDetection

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.discovery.zen.FaultDetection

org.elasticsearch.discovery.zen.NodesFaultDetection

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class NodesFaultDetection
extends FaultDetection

A fault detection of multiple nodes.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	NodesFaultDetection.Listener
static class	NodesFaultDetection.PingRequest

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	PING_ACTION_NAME

Fields inherited from class org.elasticsearch.discovery.zen.FaultDetection

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

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

deprecationLogger, logger, settings

Constructor Summary

Constructors

Constructor and Description
NodesFaultDetection(Settings settings, ThreadPool threadPool, TransportService transportService, java.util.function.Supplier<ClusterState> clusterStateSupplier, ClusterName clusterName)

Method Summary

Modifier and Type	Method and Description
void	addListener(NodesFaultDetection.Listener listener)
void	close()
java.util.Set<DiscoveryNode>	getNodes() Gets the current set of nodes involved in node fault detection.
protected void	handleTransportDisconnect(DiscoveryNode node) This method will be called when the TransportService raised a node disconnected event
void	removeListener(NodesFaultDetection.Listener listener)
void	setLocalNode(DiscoveryNode localNode)
NodesFaultDetection	stop() stops all pinging
void	updateNodesAndPing(ClusterState clusterState) make sure that nodes in clusterState are pinged.

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

logDeprecatedSetting, logRemovedSetting, nodeName

Methods inherited from class java.lang.Object

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

Field Detail

PING_ACTION_NAME

public static final java.lang.String PING_ACTION_NAME

See Also:

Constant Field Values

Constructor Detail

NodesFaultDetection

public NodesFaultDetection(Settings settings,
                           ThreadPool threadPool,
                           TransportService transportService,
                           java.util.function.Supplier<ClusterState> clusterStateSupplier,
                           ClusterName clusterName)

Method Detail

setLocalNode

public void setLocalNode(DiscoveryNode localNode)

addListener

public void addListener(NodesFaultDetection.Listener listener)

removeListener

public void removeListener(NodesFaultDetection.Listener listener)

getNodes

public java.util.Set<DiscoveryNode> getNodes()

Gets the current set of nodes involved in node fault detection. NB: For testing purposes.

updateNodesAndPing

public void updateNodesAndPing(ClusterState clusterState)

make sure that nodes in clusterState are pinged. Any pinging to nodes which are not part of the cluster will be stopped

stop

public NodesFaultDetection stop()

stops all pinging

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Overrides:

close in class FaultDetection

handleTransportDisconnect

protected void handleTransportDisconnect(DiscoveryNode node)

Description copied from class: FaultDetection

This method will be called when the TransportService raised a node disconnected event