Package akka.cluster

Class Reachability

  • All Implemented Interfaces:
    java.io.Serializable, scala.Serializable

    public class Reachability
    extends java.lang.Object
    implements scala.Serializable
    See Also:
    Serialized Form
    • Constructor Detail

      • Reachability

        public Reachability()
    • Method Detail

      • versions

        public scala.collection.immutable.Map<UniqueAddress,​java.lang.Object> versions()
      • isReachable

        public boolean isReachable​(UniqueAddress node)
        Parameters:
        node - (undocumented)
        Returns:
        true if the given node is seen as Reachable, i.e. there's no negative (Unreachable, Terminated) observation record known for that the node.
      • isReachable

        public boolean isReachable​(UniqueAddress observer,
                                   UniqueAddress subject)
        Parameters:
        observer - (undocumented)
        subject - (undocumented)
        Returns:
        true if the given observer node can reach the subject node.
      • isAllReachable

        public boolean isAllReachable()
        Returns:
        true if there's no negative (Unreachable, Terminated) observation record at all for any node
      • allUnreachable

        public scala.collection.immutable.Set<UniqueAddress> allUnreachable()
        Returns:
        all nodes that are Unreachable (i.e. they have been reported as Unreachable by at least one other node). This does not include nodes observed to be Terminated.
      • allUnreachableOrTerminated

        public scala.collection.immutable.Set<UniqueAddress> allUnreachableOrTerminated()
        Returns:
        all nodes that are Unreachable or Terminated (i.e. they have been reported as Unreachable or Terminated by at least one other node).
      • allUnreachableFrom

        public scala.collection.immutable.Set<UniqueAddress> allUnreachableFrom​(UniqueAddress observer)
        Parameters:
        observer - (undocumented)
        Returns:
        all nodes that have been observed as Unreachable by the given observer. This doesn't include nodes observed as Terminated.
      • observersGroupedByUnreachable

        public scala.collection.immutable.Map<UniqueAddress,​scala.collection.immutable.Set<UniqueAddress>> observersGroupedByUnreachable()
      • allObservers

        public scala.collection.immutable.Set<UniqueAddress> allObservers()
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object
      • equals

        public boolean equals​(java.lang.Object obj)
        Overrides:
        equals in class java.lang.Object
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object