akka.cluster
Class HeartbeatNodeRing
java.lang.Object
akka.cluster.HeartbeatNodeRing
- All Implemented Interfaces:
- java.io.Serializable, scala.Equals, scala.Product
public class HeartbeatNodeRing
- extends java.lang.Object
- implements scala.Product, scala.Serializable
INTERNAL API
Data structure for picking heartbeat receivers. The node ring is
shuffled by deterministic hashing to avoid picking physically co-located
neighbors.
It is immutable, i.e. the methods return new instances.
- See Also:
- Serialized Form
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface scala.Product |
productArity, productElement, productIterator, productPrefix |
Methods inherited from interface scala.Equals |
canEqual, equals |
HeartbeatNodeRing
public HeartbeatNodeRing(UniqueAddress selfAddress,
scala.collection.immutable.Set<UniqueAddress> nodes,
scala.collection.immutable.Set<UniqueAddress> unreachable,
int monitoredByNrOfMembers)
selfAddress
public UniqueAddress selfAddress()
nodes
public scala.collection.immutable.Set<UniqueAddress> nodes()
unreachable
public scala.collection.immutable.Set<UniqueAddress> unreachable()
monitoredByNrOfMembers
public int monitoredByNrOfMembers()
myReceivers
public scala.collection.immutable.Set<UniqueAddress> myReceivers()
- Receivers for
selfAddress
. Cached for subsequent access.
- Returns:
- (undocumented)
receivers
public scala.collection.immutable.Set<UniqueAddress> receivers(UniqueAddress sender)
- The receivers to use from a specified sender.
- Parameters:
sender
- (undocumented)
- Returns:
- (undocumented)