public final class ClusterHeartbeatSenderState
extends java.lang.Object
implements scala.Product, scala.Serializable
ClusterHeartbeatSender
. Encapsulated to facilitate unit testing.
It is immutable, but it updates the failureDetector.Constructor and Description |
---|
ClusterHeartbeatSenderState(HeartbeatNodeRing ring,
scala.collection.immutable.Set<UniqueAddress> oldReceiversNowUnreachable,
akka.remote.FailureDetectorRegistry<akka.actor.Address> failureDetector) |
Modifier and Type | Method and Description |
---|---|
scala.collection.immutable.Set<UniqueAddress> |
activeReceivers() |
ClusterHeartbeatSenderState |
addMember(UniqueAddress node) |
akka.remote.FailureDetectorRegistry<akka.actor.Address> |
failureDetector() |
ClusterHeartbeatSenderState |
heartbeatRsp(UniqueAddress from) |
ClusterHeartbeatSenderState |
init(scala.collection.immutable.Set<UniqueAddress> nodes,
scala.collection.immutable.Set<UniqueAddress> unreachable) |
scala.collection.immutable.Set<UniqueAddress> |
oldReceiversNowUnreachable() |
ClusterHeartbeatSenderState |
reachableMember(UniqueAddress node) |
ClusterHeartbeatSenderState |
removeMember(UniqueAddress node) |
HeartbeatNodeRing |
ring() |
UniqueAddress |
selfAddress() |
ClusterHeartbeatSenderState |
unreachableMember(UniqueAddress node) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public ClusterHeartbeatSenderState(HeartbeatNodeRing ring, scala.collection.immutable.Set<UniqueAddress> oldReceiversNowUnreachable, akka.remote.FailureDetectorRegistry<akka.actor.Address> failureDetector)
public HeartbeatNodeRing ring()
public scala.collection.immutable.Set<UniqueAddress> oldReceiversNowUnreachable()
public akka.remote.FailureDetectorRegistry<akka.actor.Address> failureDetector()
public scala.collection.immutable.Set<UniqueAddress> activeReceivers()
public UniqueAddress selfAddress()
public ClusterHeartbeatSenderState init(scala.collection.immutable.Set<UniqueAddress> nodes, scala.collection.immutable.Set<UniqueAddress> unreachable)
public ClusterHeartbeatSenderState addMember(UniqueAddress node)
public ClusterHeartbeatSenderState removeMember(UniqueAddress node)
public ClusterHeartbeatSenderState unreachableMember(UniqueAddress node)
public ClusterHeartbeatSenderState reachableMember(UniqueAddress node)
public ClusterHeartbeatSenderState heartbeatRsp(UniqueAddress from)