public final class HeartbeatNodeRing
extends java.lang.Object
implements scala.Product, scala.Serializable
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.
Constructor and Description |
---|
HeartbeatNodeRing(UniqueAddress selfAddress,
scala.collection.immutable.Set<UniqueAddress> nodes,
scala.collection.immutable.Set<UniqueAddress> unreachable,
int monitoredByNrOfMembers) |
Modifier and Type | Method and Description |
---|---|
int |
monitoredByNrOfMembers() |
scala.collection.immutable.Set<UniqueAddress> |
myReceivers()
Receivers for
selfAddress . |
scala.collection.immutable.Set<UniqueAddress> |
nodes() |
scala.collection.immutable.Set<UniqueAddress> |
receivers(UniqueAddress sender)
The receivers to use from a specified sender.
|
UniqueAddress |
selfAddress() |
scala.collection.immutable.Set<UniqueAddress> |
unreachable() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public HeartbeatNodeRing(UniqueAddress selfAddress, scala.collection.immutable.Set<UniqueAddress> nodes, scala.collection.immutable.Set<UniqueAddress> unreachable, int monitoredByNrOfMembers)
public UniqueAddress selfAddress()
public scala.collection.immutable.Set<UniqueAddress> nodes()
public scala.collection.immutable.Set<UniqueAddress> unreachable()
public int monitoredByNrOfMembers()
public scala.collection.immutable.Set<UniqueAddress> myReceivers()
selfAddress
. Cached for subsequent access.public scala.collection.immutable.Set<UniqueAddress> receivers(UniqueAddress sender)
sender
- (undocumented)