Packages

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
  6. package transport

Type Members

  1. class AddressUidExtension extends Extension
  2. final class ArteryControlFormats extends AnyRef
  3. class BoundAddressesExtension extends Extension
  4. final class ContainerFormats extends AnyRef
  5. 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.

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

    A lock-less thread-safe implementation of org.apache.pekko.remote.FailureDetectorRegistry.

  7. 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.

  8. trait FailureDetectorRegistry[A] extends AnyRef

    Interface for a registry of Pekko failure detectors.

    Interface for a registry of Pekko 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
  9. final class NotAllowedClassRemoteDeploymentAttemptException extends RuntimeException

    INTERNAL API

  10. 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.

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

    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()
  14. class RemoteTransportExceptionNoStackTrace extends RemoteTransportException with NoStackTrace

    RemoteTransportException without stack trace.

    RemoteTransportException without stack trace.

    Annotations
    @SerialVersionUID()
  15. final case class RemotingListenEvent(listenAddresses: Set[Address]) extends RemotingLifecycleEvent with Product with Serializable
    Annotations
    @SerialVersionUID() @nowarn()
  16. final class SystemMessageFormats extends AnyRef
  17. final case class UniqueAddress(address: Address, uid: Long) extends Ordered[UniqueAddress] with Product with Serializable
    Annotations
    @SerialVersionUID()
  18. final class WireFormats extends AnyRef

Deprecated Type Members

  1. final case class Ack(cumulativeAck: SeqNo, nacks: Set[SeqNo] = Set.empty) extends Product with Serializable

    Class representing an acknowledgement with selective negative acknowledgements.

    Class representing an acknowledgement with selective negative acknowledgements.

    cumulativeAck

    Represents the highest sequence number received.

    nacks

    Set of sequence numbers between the last delivered one and cumulativeAck that has been not yet received.

    Annotations
    @deprecated
    Deprecated

    (Since version Akka 2.6.0) Classic remoting is deprecated, use Artery

  2. final case class AckedReceiveBuffer[T <: HasSequenceNumber](lastDelivered: SeqNo = SeqNo(-1), cumulativeAck: SeqNo = SeqNo(-1), buf: SortedSet[T] = TreeSet.empty[T])(implicit seqOrdering: Ordering[T]) extends Product with Serializable

    Implements an immutable receive buffer that buffers incoming messages until they can be safely delivered.

    Implements an immutable receive buffer that buffers incoming messages until they can be safely delivered. This buffer works together with a pekko.remote.AckedSendBuffer on the sender() side.

    lastDelivered

    Sequence number of the last message that has been delivered.

    cumulativeAck

    The highest sequence number received so far.

    buf

    Buffer of messages that are waiting for delivery

    Annotations
    @deprecated
    Deprecated

    (Since version Akka 2.6.0) Classic remoting is deprecated, use Artery

  3. final case class AckedSendBuffer[T <: HasSequenceNumber](capacity: Int, nonAcked: IndexedSeq[T] = Vector.empty[T], nacked: IndexedSeq[T] = Vector.empty[T], maxSeq: SeqNo = SeqNo(-1)) extends Product with Serializable

    Implements an immutable resend buffer that buffers messages until they have been acknowledged.

    Implements an immutable resend buffer that buffers messages until they have been acknowledged. Properly removes messages when an ack is received. This buffer works together with pekko.remote.AckedReceiveBuffer on the receiving end.

    capacity

    Maximum number of messages the buffer is willing to accept. If reached pekko.remote.ResendBufferCapacityReachedException is thrown.

    nonAcked

    Sequence of messages that has not yet been acknowledged.

    nacked

    Sequence of messages that has been explicitly negative acknowledged.

    maxSeq

    The maximum sequence number that has been stored in this buffer. Messages having lower sequence number will be not stored but rejected with java.lang.IllegalArgumentException

    Annotations
    @deprecated
    Deprecated

    (Since version Akka 2.6.0) Classic remoting is deprecated, use Artery

  4. final case class AssociatedEvent(localAddress: Address, remoteAddress: Address, inbound: Boolean) extends AssociationEvent with Product with Serializable
    Annotations
    @SerialVersionUID() @deprecated
    Deprecated

    (Since version Akka 2.6.0) Classic remoting is deprecated, use Artery

  5. final case class AssociationErrorEvent(cause: Throwable, localAddress: Address, remoteAddress: Address, inbound: Boolean, logLevel: LogLevel) extends AssociationEvent with Product with Serializable
    Annotations
    @SerialVersionUID() @deprecated
    Deprecated

    (Since version Akka 2.6.0) Classic remoting is deprecated, use Artery

  6. sealed trait AssociationEvent extends RemotingLifecycleEvent
    Annotations
    @nowarn() @SerialVersionUID() @deprecated
    Deprecated

    (Since version Akka 2.6.0) Classic remoting is deprecated, use Artery

  7. final case class DisassociatedEvent(localAddress: Address, remoteAddress: Address, inbound: Boolean) extends AssociationEvent with Product with Serializable
    Annotations
    @SerialVersionUID() @deprecated
    Deprecated

    (Since version Akka 2.6.0) Classic remoting is deprecated, use Artery

  8. final case class GracefulShutdownQuarantinedEvent(uniqueAddress: UniqueAddress, reason: String) extends RemotingLifecycleEvent with Product with Serializable

    The uniqueAddress was quarantined but it was due to normal shutdown or cluster leaving/exiting.

    The uniqueAddress was quarantined but it was due to normal shutdown or cluster leaving/exiting.

    Annotations
    @SerialVersionUID() @deprecated
    Deprecated

    (Since version Akka 2.6.0) Classic remoting is deprecated, use Artery

  9. trait HasSequenceNumber extends AnyRef

    Messages that are to be buffered in pekko.remote.AckedSendBuffer or pekko.remote.AckedReceiveBuffer has to implement this interface to provide the sequence needed by the buffers.

    Messages that are to be buffered in pekko.remote.AckedSendBuffer or pekko.remote.AckedReceiveBuffer has to implement this interface to provide the sequence needed by the buffers.

    Annotations
    @deprecated
    Deprecated

    (Since version Akka 2.6.0) Classic remoting is deprecated, use Artery

  10. final case class QuarantinedEvent(address: Address, longUid: Long) extends RemotingLifecycleEvent with Product with Serializable
    Annotations
    @SerialVersionUID() @deprecated
    Deprecated

    (Since version Akka 2.6.0) Classic remoting is deprecated, use Artery

  11. final case class RemotingErrorEvent(cause: Throwable) extends RemotingLifecycleEvent with Product with Serializable
    Annotations
    @SerialVersionUID() @deprecated
    Deprecated

    (Since version Akka 2.6.0) Classic remoting is deprecated, use Artery

  12. sealed trait RemotingLifecycleEvent extends Serializable
    Annotations
    @nowarn() @SerialVersionUID() @deprecated
    Deprecated

    (Since version Akka 2.6.0) Classic remoting is deprecated, use Artery

  13. class ResendBufferCapacityReachedException extends PekkoException
    Annotations
    @deprecated
    Deprecated

    (Since version Akka 2.6.0) Classic remoting is deprecated, use Artery

  14. class ResendUnfulfillableException extends PekkoException
    Annotations
    @deprecated
    Deprecated

    (Since version Akka 2.6.0) Classic remoting is deprecated, use Artery

  15. final case class SeqNo(rawValue: Long) extends Ordered[SeqNo] with Product with Serializable

    Implements a 64 bit sequence number with proper wrap-around ordering.

    Implements a 64 bit sequence number with proper wrap-around ordering.

    Annotations
    @deprecated
    Deprecated

    (Since version Akka 2.6.0) Classic remoting is deprecated, use Artery

  16. final case class ThisActorSystemQuarantinedEvent(localAddress: Address, remoteAddress: Address) extends RemotingLifecycleEvent with Product with Serializable
    Annotations
    @SerialVersionUID() @deprecated
    Deprecated

    (Since version Akka 2.6.0) Classic remoting is deprecated, use Artery

Value Members

  1. object AddressUidExtension extends ExtensionId[AddressUidExtension] with ExtensionIdProvider

    Extension that holds a uid that is assigned as a random Long or Int depending on which version of remoting that is used.

    Extension that holds a uid that is assigned as a random Long or Int depending on which version of remoting that is used.

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

  2. object BoundAddressesExtension extends ExtensionId[BoundAddressesExtension] with ExtensionIdProvider

    Extension provides access to bound addresses.

  3. object FailureDetector
  4. 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.

    Annotations
    @ApiMayChange()

Deprecated Value Members

  1. object HasSequenceNumber
    Annotations
    @deprecated
    Deprecated

    (Since version Akka 2.6.0) Classic remoting is deprecated, use Artery

  2. object QuarantinedEvent extends AbstractFunction2[Address, Int, QuarantinedEvent] with Serializable
    Annotations
    @deprecated
    Deprecated

    (Since version Akka 2.6.0) Classic remoting is deprecated, use Artery

  3. case object RemotingShutdownEvent extends RemotingLifecycleEvent with Product with Serializable
    Annotations
    @SerialVersionUID() @deprecated
    Deprecated

    (Since version Akka 2.6.0) Classic remoting is deprecated, use Artery

  4. object SeqNo extends Serializable
    Annotations
    @deprecated
    Deprecated

    (Since version Akka 2.6.0) Classic remoting is deprecated, use Artery

Ungrouped