Packages

p

akka

remote

package remote

Content Hierarchy
Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Package Members

  1. package artery
  2. package routing
  3. package serialization
  4. package testconductor
  5. package testkit

Type Members

  1. final class ArteryControlFormats extends AnyRef
  2. class BoundAddressesExtension extends Extension
  3. final class ContainerFormats extends AnyRef
  4. class DeadlineFailureDetector extends FailureDetector

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

    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.

  5. class DefaultFailureDetectorRegistry[A] extends FailureDetectorRegistry[A]

    A lock-less thread-safe implementation of akka.remote.FailureDetectorRegistry.

  6. trait FailureDetector extends AnyRef

    A failure detector must be a thread-safe mutable construct that registers heartbeat events of a resource and is able to decide the availability of that monitored resource.

  7. trait FailureDetectorRegistry[A] extends AnyRef

    Interface for a registry of Akka failure detectors.

    Interface for a registry of Akka failure detectors. New resources are implicitly registered when heartbeat is first called with the resource given as parameter.

    type parameter A:

    • The type of the key that identifies a resource to be monitored by a failure detector
  8. final class NotAllowedClassRemoteDeploymentAttemptException extends RuntimeException

    INTERNAL API

  9. class PhiAccrualFailureDetector extends FailureDetector

    Implementation of 'The Phi Accrual Failure Detector' by Hayashibara et al.

    Implementation of 'The Phi Accrual Failure Detector' by Hayashibara et al. as defined in their paper: [https://oneofus.la/have-emacs-will-hack/files/HDY04.pdf]

    The suspicion level of failure is given by a value called φ (phi). The basic idea of the φ failure detector is to express the value of φ on a scale that is dynamically adjusted to reflect current network conditions. A configurable threshold is used to decide if φ is considered to be a failure.

    The value of φ is calculated as:

    φ = -log10(1 - F(timeSinceLastHeartbeat)

    where F is the cumulative distribution function of a normal distribution with mean and standard deviation estimated from historical heartbeat inter-arrival times.

  10. final case class RemoteScope(node: Address) extends Scope with Product with Serializable
    Annotations
    @SerialVersionUID()
  11. final class RemoteSettings extends AnyRef
  12. class RemoteTransportException extends AkkaException

    RemoteTransportException represents a general failure within a RemoteTransport, such as inability to start, wrong configuration etc.

    RemoteTransportException represents a general failure within a RemoteTransport, such as inability to start, wrong configuration etc.

    Annotations
    @SerialVersionUID()
  13. class RemoteTransportExceptionNoStackTrace extends RemoteTransportException with NoStackTrace

    RemoteTransportException without stack trace.

    RemoteTransportException without stack trace.

    Annotations
    @SerialVersionUID()
  14. final class SystemMessageFormats extends AnyRef
  15. final case class UniqueAddress(address: Address, uid: Long) extends Ordered[UniqueAddress] with Product with Serializable
    Annotations
    @SerialVersionUID()
  16. final class WireFormats extends AnyRef

Deprecated Type Members

  1. class AddressUidExtension extends Extension
    Annotations
    @deprecated
    Deprecated

    (Since version 2.8.0) Use ExtendedActorSystem.uid instead.

Value Members

  1. object BoundAddressesExtension extends ExtensionId[BoundAddressesExtension] with ExtensionIdProvider

    Extension provides access to bound addresses.

  2. object FailureDetector
  3. object RemoteLogMarker

    This is public with the purpose to document the used markers and properties of log events.

    This is public with the purpose to document the used markers and properties of log events. No guarantee that it will remain binary compatible, but the marker names and properties are considered public API and will not be changed without notice.

Deprecated Value Members

  1. object AddressUidExtension extends ExtensionId[AddressUidExtension] with ExtensionIdProvider

    Extension that holds a uid that is assigned as a random Long.

    Extension that holds a uid that is assigned as a random Long.

    The uid is intended to be used together with an akka.actor.Address to be able to distinguish restarted actor system using the same host and port.

    Annotations
    @deprecated
    Deprecated

    (Since version 2.8.0) Use ExtendedActorSystem.uid instead.

Ungrouped