Akka.Remote.Transport Namespace
Classes
Class | Description | |
---|---|---|
![]() |
Activity |
Base trait for remote activities that are logged by TestTransport
|
![]() |
ActorAssociationEventListener |
Converts an ActorRef instance into an IAssociationEventListener, so IAssociationEvent messages
can be passed directly to the Actor.
|
![]() |
ActorHandleEventListener |
Converts an ActorRef instance into an IHandleEventListener, so IHandleEvent messages
can be passed directly to the Actor.
|
![]() |
AkkaProtocolException | |
![]() |
AssociateAttempt | |
![]() |
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.
|
![]() |
AssociationRegistry |
Shared state among TestTransport instances. Coordinates the transports and the means of
communication between them.
|
![]() |
DisassociateAttempt | |
![]() |
Disassociated | |
![]() |
InboundAssociation |
Message sent to IAssociationEventListener registered to a transport (via the TaskCompletionSource returned by [Transport.Listen])
when the inbound association request arrives.
|
![]() |
InboundPayload |
Message sent to the listener registered to an association (via the TaskCompletionSource returned by [AssociationHandle.ReadHandlerSource])
|
![]() |
InvalidAssociationException |
Indicates that the association setup request is invalid and it is impossible to recover (malformed IP address, unknown hostname, etc...)
|
![]() |
ListenAttempt | |
![]() |
ShutdownAttempt | |
![]() |
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.
|
![]() |
TestAssociationHandle | |
![]() |
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.
|
![]() |
Transport | |
![]() |
UnderlyingTransportError |
The underlying transport reported a non-fatal error
|
![]() |
WriteAttempt |
Interfaces
Interface | Description | |
---|---|---|
![]() |
IAssociationEvent |
Marker type for whenever new actors / endpoints are associated with this ActorSystem via remoting.
|
![]() |
IAssociationEventListener |
Listener interface for any object that can handle IAssociationEvent messages.
|
![]() |
IHandleEvent |
Marker interface for events that the registered listener for a AssociationHandle might receive.
|
![]() |
IHandleEventListener |
An interface that needs to be implemented by a user of an AssociationHandle
in order to listen to association events
|
![]() |
ITransportAdapterProvider |