|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object akka.remote.DeadlineFailureDetector
public class DeadlineFailureDetector
Implementation of failure detector using an absolute timeout of missing heartbeats to trigger unavailability.
param: acceptableHeartbeatPause Duration corresponding to number of potentially lost/delayed heartbeats that will be accepted before considering it to be an anomaly.
param: clock The clock, returning current time in milliseconds, but can be faked for testing purposes. It is only used for measuring intervals (duration).
Nested Class Summary |
---|
Nested classes/interfaces inherited from interface akka.remote.FailureDetector |
---|
FailureDetector.Clock |
Constructor Summary | |
---|---|
DeadlineFailureDetector(com.typesafe.config.Config config,
EventStream ev)
Constructor that reads parameters from config. |
|
DeadlineFailureDetector(scala.concurrent.duration.FiniteDuration acceptableHeartbeatPause,
FailureDetector.Clock clock)
|
Method Summary | |
---|---|
scala.concurrent.duration.FiniteDuration |
acceptableHeartbeatPause()
|
void |
heartbeat()
Notifies the FailureDetector that a heartbeat arrived from the monitored resource. |
boolean |
isAvailable()
Returns true if the resource is considered to be up and healthy and returns false otherwise. |
boolean |
isMonitoring()
Returns true if the failure detector has received any heartbeats and started monitoring of the resource. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public DeadlineFailureDetector(scala.concurrent.duration.FiniteDuration acceptableHeartbeatPause, FailureDetector.Clock clock)
public DeadlineFailureDetector(com.typesafe.config.Config config, EventStream ev)
acceptable-heartbeat-pause
.
config
- (undocumented)ev
- (undocumented)Method Detail |
---|
public scala.concurrent.duration.FiniteDuration acceptableHeartbeatPause()
public boolean isAvailable()
FailureDetector
isAvailable
in interface FailureDetector
public boolean isMonitoring()
FailureDetector
isMonitoring
in interface FailureDetector
public final void heartbeat()
FailureDetector
heartbeat
in interface FailureDetector
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |