akka

remote

package remote

Content Hierarchy Learn more about scaladoc diagrams
Visibility
  1. Public
  2. All

Type Members

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

    Class representing an acknowledgement with selective negative acknowledgements.

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

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

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

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

  4. class AddressUidExtension extends Extension

  5. final case class AssociatedEvent(localAddress: Address, remoteAddress: Address, inbound: Boolean) extends AssociationEvent with Product with Serializable

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

    Annotations
    @SerialVersionUID( 1L )
  7. sealed trait AssociationEvent extends RemotingLifecycleEvent

    Annotations
    @SerialVersionUID( 1L )
  8. final class ContainerFormats extends AnyRef

  9. class DeadlineFailureDetector extends FailureDetector

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

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

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

  11. final case class DisassociatedEvent(localAddress: Address, remoteAddress: Address, inbound: Boolean) extends AssociationEvent with Product with Serializable

    Annotations
    @SerialVersionUID( 1L )
  12. 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.

  13. trait FailureDetectorRegistry[A] extends AnyRef

    Interface for a registry of Akka failure detectors.

  14. trait HasSequenceNumber extends AnyRef

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

  15. class PhiAccrualFailureDetector extends FailureDetector

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

  16. case class QuarantinedEvent(address: Address, uid: Int) extends RemotingLifecycleEvent with Product with Serializable

    Annotations
    @SerialVersionUID( 1L )
  17. case class RemoteScope(node: Address) extends Scope with Product with Serializable

    Annotations
    @SerialVersionUID( 1L )
  18. final class RemoteSettings extends AnyRef

  19. class RemoteTransportException extends AkkaException

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

  20. class RemoteTransportExceptionNoStackTrace extends RemoteTransportException with NoStackTrace

    RemoteTransportException without stack trace.

  21. final case class RemotingErrorEvent(cause: Throwable) extends RemotingLifecycleEvent with Product with Serializable

    Annotations
    @SerialVersionUID( 1L )
  22. sealed trait RemotingLifecycleEvent extends Serializable

    Annotations
    @SerialVersionUID( 1L )
  23. final case class RemotingListenEvent(listenAddresses: Set[Address]) extends RemotingLifecycleEvent with Product with Serializable

    Annotations
    @SerialVersionUID( 1L )
  24. class ResendBufferCapacityReachedException extends AkkaException

  25. class ResendUnfulfillableException extends AkkaException

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

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

  27. final class WireFormats extends AnyRef

Value Members

  1. object AddressUidExtension extends ExtensionId[AddressUidExtension] with ExtensionIdProvider

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

  2. object FailureDetector

  3. object HasSequenceNumber

  4. object RemotingShutdownEvent extends RemotingLifecycleEvent with Product with Serializable

    Annotations
    @SerialVersionUID( 1L )
  5. object SeqNo extends Serializable

  6. package routing

  7. package security

  8. package serialization

  9. package testconductor

  10. package testkit

  11. package transport

Ungrouped