Package akka.cluster
Class CrossDcHeartbeatingState
- java.lang.Object
-
- akka.cluster.CrossDcHeartbeatingState
-
- All Implemented Interfaces:
java.io.Serializable
,scala.Equals
,scala.Product
public final class CrossDcHeartbeatingState extends java.lang.Object implements scala.Product, java.io.Serializable
INTERNAL API- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description CrossDcHeartbeatingState(java.lang.String selfDataCenter, FailureDetectorRegistry<Address> failureDetector, int nrOfMonitoredNodesPerDc, scala.collection.immutable.Map<java.lang.String,scala.collection.immutable.SortedSet<Member>> state)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description scala.collection.immutable.Set<UniqueAddress>
activeReceivers()
Lists addresses that this node should send heartbeats toCrossDcHeartbeatingState
addMember(Member m)
scala.collection.Iterable<Member>
allMembers()
static CrossDcHeartbeatingState
apply(java.lang.String selfDataCenter, FailureDetectorRegistry<Address> failureDetector, int nrOfMonitoredNodesPerDc, scala.collection.immutable.Map<java.lang.String,scala.collection.immutable.SortedSet<Member>> state)
static boolean
atLeastInUpState(Member m)
boolean
canEqual(java.lang.Object x$1)
CrossDcHeartbeatingState
copy(java.lang.String selfDataCenter, FailureDetectorRegistry<Address> failureDetector, int nrOfMonitoredNodesPerDc, scala.collection.immutable.Map<java.lang.String,scala.collection.immutable.SortedSet<Member>> state)
java.lang.String
copy$default$1()
FailureDetectorRegistry<Address>
copy$default$2()
int
copy$default$3()
scala.collection.immutable.Map<java.lang.String,scala.collection.immutable.SortedSet<Member>>
copy$default$4()
scala.collection.immutable.Set<java.lang.String>
dataCenters()
boolean
equals(java.lang.Object x$1)
FailureDetectorRegistry<Address>
failureDetector()
int
hashCode()
CrossDcHeartbeatingState
heartbeatRsp(UniqueAddress from)
static CrossDcHeartbeatingState
init(java.lang.String selfDataCenter, FailureDetectorRegistry<Address> crossDcFailureDetector, int nrOfMonitoredNodesPerDc, scala.collection.immutable.SortedSet<Member> members)
int
nrOfMonitoredNodesPerDc()
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()
CrossDcHeartbeatingState
removeMember(Member m)
java.lang.String
selfDataCenter()
boolean
shouldActivelyMonitorNodes(java.lang.String selfDc, UniqueAddress selfAddress)
Decides ifself
node should become active and monitor other nodes with heartbeats.scala.collection.immutable.Map<java.lang.String,scala.collection.immutable.SortedSet<Member>>
state()
java.lang.String
toString()
static scala.Option<scala.Tuple4<java.lang.String,FailureDetectorRegistry<Address>,java.lang.Object,scala.collection.immutable.Map<java.lang.String,scala.collection.immutable.SortedSet<Member>>>>
unapply(CrossDcHeartbeatingState x$0)
-
-
-
Constructor Detail
-
CrossDcHeartbeatingState
public CrossDcHeartbeatingState(java.lang.String selfDataCenter, FailureDetectorRegistry<Address> failureDetector, int nrOfMonitoredNodesPerDc, scala.collection.immutable.Map<java.lang.String,scala.collection.immutable.SortedSet<Member>> state)
-
-
Method Detail
-
atLeastInUpState
public static boolean atLeastInUpState(Member m)
-
init
public static CrossDcHeartbeatingState init(java.lang.String selfDataCenter, FailureDetectorRegistry<Address> crossDcFailureDetector, int nrOfMonitoredNodesPerDc, scala.collection.immutable.SortedSet<Member> members)
-
apply
public static CrossDcHeartbeatingState apply(java.lang.String selfDataCenter, FailureDetectorRegistry<Address> failureDetector, int nrOfMonitoredNodesPerDc, scala.collection.immutable.Map<java.lang.String,scala.collection.immutable.SortedSet<Member>> state)
-
unapply
public static scala.Option<scala.Tuple4<java.lang.String,FailureDetectorRegistry<Address>,java.lang.Object,scala.collection.immutable.Map<java.lang.String,scala.collection.immutable.SortedSet<Member>>>> unapply(CrossDcHeartbeatingState x$0)
-
selfDataCenter
public java.lang.String selfDataCenter()
-
failureDetector
public FailureDetectorRegistry<Address> failureDetector()
-
nrOfMonitoredNodesPerDc
public int nrOfMonitoredNodesPerDc()
-
state
public scala.collection.immutable.Map<java.lang.String,scala.collection.immutable.SortedSet<Member>> state()
-
shouldActivelyMonitorNodes
public boolean shouldActivelyMonitorNodes(java.lang.String selfDc, UniqueAddress selfAddress)
Decides ifself
node should become active and monitor other nodes with heartbeats. Only thenrOfMonitoredNodesPerDc
-oldest nodes in each DC fulfil this role.
-
addMember
public CrossDcHeartbeatingState addMember(Member m)
-
removeMember
public CrossDcHeartbeatingState removeMember(Member m)
-
activeReceivers
public scala.collection.immutable.Set<UniqueAddress> activeReceivers()
Lists addresses that this node should send heartbeats to
-
allMembers
public scala.collection.Iterable<Member> allMembers()
-
heartbeatRsp
public CrossDcHeartbeatingState heartbeatRsp(UniqueAddress from)
-
dataCenters
public scala.collection.immutable.Set<java.lang.String> dataCenters()
-
copy
public CrossDcHeartbeatingState copy(java.lang.String selfDataCenter, FailureDetectorRegistry<Address> failureDetector, int nrOfMonitoredNodesPerDc, scala.collection.immutable.Map<java.lang.String,scala.collection.immutable.SortedSet<Member>> state)
-
copy$default$1
public java.lang.String copy$default$1()
-
copy$default$2
public FailureDetectorRegistry<Address> copy$default$2()
-
copy$default$3
public int copy$default$3()
-
copy$default$4
public scala.collection.immutable.Map<java.lang.String,scala.collection.immutable.SortedSet<Member>> 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
-
-