Akka.Remote.Transport Namespace

Classes


  Class Description
Public class Activity
Base trait for remote activities that are logged by TestTransport
Public class ActorAssociationEventListener
Converts an ActorRef instance into an IAssociationEventListener, so IAssociationEvent messages can be passed directly to the Actor.
Public class ActorHandleEventListener
Converts an ActorRef instance into an IHandleEventListener, so IHandleEvent messages can be passed directly to the Actor.
Public class AkkaProtocolException
Public class AssociateAttempt
Public class AssociationHandle
A Service Provider Interface (SPI) layer for abstracting over logical links (associations) created by a Transport. Handles are responsible for providing an API for sending and receiving from the underlying channel. To register a listener for processing incoming payload data, the listener must be registered by completing the Task returned by [AssociationHandle.ReadHandlerSource]. Incoming data is not processed until this registration takes place.
Public class AssociationRegistry
Shared state among TestTransport instances. Coordinates the transports and the means of communication between them.
Public class DisassociateAttempt
Public class Disassociated
Public class InboundAssociation
Message sent to IAssociationEventListener registered to a transport (via the TaskCompletionSource returned by [Transport.Listen]) when the inbound association request arrives.
Public class InboundPayload
Message sent to the listener registered to an association (via the TaskCompletionSource returned by [AssociationHandle.ReadHandlerSource])
Public class InvalidAssociationException
Indicates that the association setup request is invalid and it is impossible to recover (malformed IP address, unknown hostname, etc...)
Public class ListenAttempt
Public class ShutdownAttempt
Public class SwitchableLoggedBehavior<(Of <(<'TIn, TOut>)>)>
Test utility to make bhavior of functions that return some Task controllable form tests. This tool is able to override default behavior with any generic behavior, including failure, and exposes control to the timing of completion of the associated Task. The utility is implemented as a stack of behaviors, where the behavior on the top of the stack represents the currently active behavior. The bottom of the stack alway contains the [DefaultBehavior] which can not be popped out.
Public class TestAssociationHandle
Public class TestTransport
Transport implementation used for testing. The TestTransport is basically shared memory between actor systems. It can be programmed to emulate different failure modes of a Transport implementation. TestTransport keeps a log of the activities it was requested to do. This class is not optimized for performance and MUST not be used in production systems.
Public class Transport
Public class UnderlyingTransportError
The underlying transport reported a non-fatal error
Public class WriteAttempt

Interfaces


  Interface Description
Public interface IAssociationEvent
Marker type for whenever new actors / endpoints are associated with this ActorSystem via remoting.
Public interface IAssociationEventListener
Listener interface for any object that can handle IAssociationEvent messages.
Public interface IHandleEvent
Marker interface for events that the registered listener for a AssociationHandle might receive.
Public interface IHandleEventListener
An interface that needs to be implemented by a user of an AssociationHandle in order to listen to association events
Public interface ITransportAdapterProvider

Enumerations


  Enumeration Description
Public enumeration DisassociateInfo
Supertype of possible disassociation reasons