c

akka.remote

DeadlineFailureDetector

class DeadlineFailureDetector extends FailureDetector

Implementation of failure detector using an absolute timeout of missing heartbeats to trigger unavailability.

#isAvailable will return false if there is no #heartbeat within the duration heartbeatInterval + acceptableHeartbeatPause.

Source
DeadlineFailureDetector.scala
Linear Supertypes
FailureDetector, AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. DeadlineFailureDetector
  2. FailureDetector
  3. AnyRef
  4. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new DeadlineFailureDetector(config: Config, ev: EventStream)

    Constructor that reads parameters from config.

    Constructor that reads parameters from config. Expecting config properties named acceptable-heartbeat-pause.

  2. new DeadlineFailureDetector(acceptableHeartbeatPause: FiniteDuration, heartbeatInterval: FiniteDuration)(implicit clock: Clock)

    acceptableHeartbeatPause

    Duration corresponding to number of potentially lost/delayed heartbeats that will be accepted before considering it to be an anomaly.

    heartbeatInterval

    Expected heartbeat interval

    clock

    The clock, returning current time in milliseconds, but can be faked for testing purposes. It is only used for measuring intervals (duration).

Value Members

  1. val acceptableHeartbeatPause: FiniteDuration
  2. final def heartbeat(): Unit

    Notifies the FailureDetector that a heartbeat arrived from the monitored resource.

    Notifies the FailureDetector that a heartbeat arrived from the monitored resource. This causes the FailureDetector to update its state.

    Definition Classes
    → FailureDetector
  3. val heartbeatInterval: FiniteDuration
  4. def isAvailable: Boolean

    Returns true if the resource is considered to be up and healthy and returns false otherwise.

    Returns true if the resource is considered to be up and healthy and returns false otherwise.

    Definition Classes
    → FailureDetector
  5. def isMonitoring: Boolean

    Returns true if the failure detector has received any heartbeats and started monitoring of the resource.

    Returns true if the failure detector has received any heartbeats and started monitoring of the resource.

    Definition Classes
    → FailureDetector