Package akka.cluster
Class HeartbeatNodeRing
- java.lang.Object
-
- akka.cluster.HeartbeatNodeRing
-
- All Implemented Interfaces:
java.io.Serializable
,scala.Equals
,scala.Product
public final class HeartbeatNodeRing extends java.lang.Object implements scala.Product, java.io.Serializable
INTERNAL APIData 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
-
-
Constructor Summary
Constructors Constructor Description HeartbeatNodeRing(UniqueAddress selfAddress, scala.collection.immutable.Set<UniqueAddress> nodes, scala.collection.immutable.Set<UniqueAddress> unreachable, int monitoredByNrOfMembers)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description HeartbeatNodeRing
$colon$minus(UniqueAddress node)
Remove a node from the ring.HeartbeatNodeRing
$colon$plus(UniqueAddress node)
Add a node to the ring.static HeartbeatNodeRing
apply(UniqueAddress selfAddress, scala.collection.immutable.Set<UniqueAddress> nodes, scala.collection.immutable.Set<UniqueAddress> unreachable, int monitoredByNrOfMembers)
boolean
canEqual(java.lang.Object x$1)
HeartbeatNodeRing
copy(UniqueAddress selfAddress, scala.collection.immutable.Set<UniqueAddress> nodes, scala.collection.immutable.Set<UniqueAddress> unreachable, int monitoredByNrOfMembers)
UniqueAddress
copy$default$1()
scala.collection.immutable.Set<UniqueAddress>
copy$default$2()
scala.collection.immutable.Set<UniqueAddress>
copy$default$3()
int
copy$default$4()
boolean
equals(java.lang.Object x$1)
int
hashCode()
int
monitoredByNrOfMembers()
scala.collection.immutable.Set<UniqueAddress>
myReceivers()
scala.collection.immutable.Set<UniqueAddress>
nodes()
int
productArity()
java.lang.Object
productElement(int x$1)
java.lang.String
productElementName(int x$1)
scala.collection.Iterator<java.lang.Object>
productIterator()
java.lang.String
productPrefix()
scala.collection.immutable.Set<UniqueAddress>
receivers(UniqueAddress sender)
The receivers to use from a specified sender.UniqueAddress
selfAddress()
java.lang.String
toString()
static scala.Option<scala.Tuple4<UniqueAddress,scala.collection.immutable.Set<UniqueAddress>,scala.collection.immutable.Set<UniqueAddress>,java.lang.Object>>
unapply(HeartbeatNodeRing x$0)
scala.collection.immutable.Set<UniqueAddress>
unreachable()
-
-
-
Constructor Detail
-
HeartbeatNodeRing
public HeartbeatNodeRing(UniqueAddress selfAddress, scala.collection.immutable.Set<UniqueAddress> nodes, scala.collection.immutable.Set<UniqueAddress> unreachable, int monitoredByNrOfMembers)
-
-
Method Detail
-
apply
public static HeartbeatNodeRing apply(UniqueAddress selfAddress, scala.collection.immutable.Set<UniqueAddress> nodes, scala.collection.immutable.Set<UniqueAddress> unreachable, int monitoredByNrOfMembers)
-
unapply
public static scala.Option<scala.Tuple4<UniqueAddress,scala.collection.immutable.Set<UniqueAddress>,scala.collection.immutable.Set<UniqueAddress>,java.lang.Object>> unapply(HeartbeatNodeRing x$0)
-
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
public scala.collection.immutable.Set<UniqueAddress> receivers(UniqueAddress sender)
The receivers to use from a specified sender.
-
$colon$plus
public HeartbeatNodeRing $colon$plus(UniqueAddress node)
Add a node to the ring.
-
$colon$minus
public HeartbeatNodeRing $colon$minus(UniqueAddress node)
Remove a node from the ring.
-
copy
public HeartbeatNodeRing copy(UniqueAddress selfAddress, scala.collection.immutable.Set<UniqueAddress> nodes, scala.collection.immutable.Set<UniqueAddress> unreachable, int monitoredByNrOfMembers)
-
copy$default$1
public UniqueAddress copy$default$1()
-
copy$default$2
public scala.collection.immutable.Set<UniqueAddress> copy$default$2()
-
copy$default$3
public scala.collection.immutable.Set<UniqueAddress> copy$default$3()
-
copy$default$4
public int copy$default$4()
-
productPrefix
public java.lang.String productPrefix()
- Specified by:
productPrefix
in interfacescala.Product
-
productArity
public int productArity()
- Specified by:
productArity
in interfacescala.Product
-
productElement
public java.lang.Object productElement(int x$1)
- Specified by:
productElement
in interfacescala.Product
-
productIterator
public scala.collection.Iterator<java.lang.Object> productIterator()
- Specified by:
productIterator
in interfacescala.Product
-
canEqual
public boolean canEqual(java.lang.Object x$1)
- Specified by:
canEqual
in interfacescala.Equals
-
productElementName
public java.lang.String productElementName(int x$1)
- Specified by:
productElementName
in interfacescala.Product
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
equals
public boolean equals(java.lang.Object x$1)
- Specified by:
equals
in interfacescala.Equals
- Overrides:
equals
in classjava.lang.Object
-
-