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 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

Constructor Summary

Constructors

Constructor	Description
HeartbeatNodeRing(UniqueAddress selfAddress, scala.collection.immutable.Set<UniqueAddress> nodes, scala.collection.immutable.Set<UniqueAddress> unreachable, int monitoredByNrOfMembers)

Method Summary

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()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface scala.Product

productElementNames

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 interface scala.Product

productArity

public int productArity()

Specified by:

productArity in interface scala.Product

productElement

public java.lang.Object productElement(int x$1)

Specified by:

productElement in interface scala.Product

productIterator

public scala.collection.Iterator<java.lang.Object> productIterator()

Specified by:

productIterator in interface scala.Product

canEqual

public boolean canEqual(java.lang.Object x$1)

Specified by:

canEqual in interface scala.Equals

productElementName

public java.lang.String productElementName(int x$1)

Specified by:

productElementName in interface scala.Product

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

equals

public boolean equals(java.lang.Object x$1)

Specified by:

equals in interface scala.Equals

Overrides:

equals in class java.lang.Object