|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object akka.cluster.AccrualFailureDetector
public class AccrualFailureDetector
Constructor Summary | |
---|---|
AccrualFailureDetector(ActorSystem system,
ClusterSettings settings)
Constructor that picks configuration from the settings. |
|
AccrualFailureDetector(ActorSystem system,
double threshold,
int maxSampleSize,
scala.concurrent.duration.Duration minStdDeviation,
scala.concurrent.duration.Duration acceptableHeartbeatPause,
scala.concurrent.duration.Duration firstHeartbeatEstimate,
scala.Function0<java.lang.Object> clock)
|
Method Summary | |
---|---|
scala.concurrent.duration.Duration |
acceptableHeartbeatPause()
|
scala.Function0<java.lang.Object> |
clock()
|
scala.concurrent.duration.Duration |
firstHeartbeatEstimate()
|
void |
heartbeat(Address connection)
Records a heartbeat for a connection. |
boolean |
isAvailable(Address connection)
Returns true if the connection is considered to be up and healthy and returns false otherwise. |
boolean |
isMonitoring(Address connection)
Returns true if the failure detector has received any heartbeats and started monitoring of the resource. |
int |
maxSampleSize()
|
scala.concurrent.duration.Duration |
minStdDeviation()
|
double |
phi(Address connection)
The suspicion level of the accrual failure detector. |
void |
remove(Address connection)
Removes the heartbeat management for a connection. |
void |
reset()
Removes all connections and starts over. |
ActorSystem |
system()
|
double |
threshold()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public AccrualFailureDetector(ActorSystem system, double threshold, int maxSampleSize, scala.concurrent.duration.Duration minStdDeviation, scala.concurrent.duration.Duration acceptableHeartbeatPause, scala.concurrent.duration.Duration firstHeartbeatEstimate, scala.Function0<java.lang.Object> clock)
public AccrualFailureDetector(ActorSystem system, ClusterSettings settings)
Method Detail |
---|
public ActorSystem system()
public double threshold()
public int maxSampleSize()
public scala.concurrent.duration.Duration minStdDeviation()
public scala.concurrent.duration.Duration acceptableHeartbeatPause()
public scala.concurrent.duration.Duration firstHeartbeatEstimate()
public scala.Function0<java.lang.Object> clock()
public boolean isAvailable(Address connection)
FailureDetector
isAvailable
in interface FailureDetector
public boolean isMonitoring(Address connection)
FailureDetector
isMonitoring
in interface FailureDetector
public final void heartbeat(Address connection)
heartbeat
in interface FailureDetector
public double phi(Address connection)
If a connection does not have any records in failure detector then it is considered healthy.
public final void remove(Address connection)
remove
in interface FailureDetector
public void reset()
FailureDetector
reset
in interface FailureDetector
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |