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 |
---|---|
abstract static boolean |
canEqual(java.lang.Object that) |
abstract static boolean |
equals(java.lang.Object that) |
int |
monitoredByNrOfMembers() |
scala.collection.immutable.Set<UniqueAddress> |
myReceivers() |
scala.collection.immutable.Set<UniqueAddress> |
nodes() |
abstract static int |
productArity() |
abstract static java.lang.Object |
productElement(int n) |
static scala.collection.Iterator<java.lang.Object> |
productIterator() |
static java.lang.String |
productPrefix() |
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 abstract static boolean canEqual(java.lang.Object that)
public abstract static boolean equals(java.lang.Object that)
public abstract static java.lang.Object productElement(int n)
public abstract static int productArity()
public static scala.collection.Iterator<java.lang.Object> productIterator()
public static java.lang.String productPrefix()
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()
public scala.collection.immutable.Set<UniqueAddress> receivers(UniqueAddress sender)
sender
- (undocumented)