Class NodesFaultDetection

  • All Implemented Interfaces:, java.lang.AutoCloseable

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


        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
        close in class FaultDetection
      • handleTransportDisconnect

        protected void handleTransportDisconnect​(DiscoveryNode node)