Class NodesFaultDetection

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable

    public class NodesFaultDetection
    extends FaultDetection
    A fault detection of multiple nodes.
    • Field Detail

      • PING_ACTION_NAME

        public static final java.lang.String PING_ACTION_NAME
        See Also:
        Constant Field Values
    • Method Detail

      • setLocalNode

        public void setLocalNode​(DiscoveryNode localNode)
      • 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
      • close

        public void close()
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface java.io.Closeable
        Overrides:
        close in class FaultDetection
      • handleTransportDisconnect

        protected void handleTransportDisconnect​(DiscoveryNode node)