Namespace Akka.Remote.Transport

Classes

AbstractTransportAdapter

An adapter that wraps a transport and provides interception capabilities

AbstractTransportAdapterHandle

TBD

Activity

Base trait for remote activities that are logged by TestTransport

ActorAssociationEventListener

Converts an IActorRef into an IAssociationEventListener, so IAssociationEvent messages can be passed directly to the Actor.

ActorHandleEventListener

Converts an IActorRef into an IHandleEventListener, so IHandleEvent messages can be passed directly to the Actor.

AkkaProtocolException

This exception is thrown when an error occurred during the Akka protocol handshake.

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

Blackhole

Signals that we're going to totally black out a connection

DisassociateAttempt

Disassociated

TBD

DisassociateUnderlying

TBD

FailureInjectorException

This exception is used to indicate a simulated failure in an association.

FailureInjectorProvider

Provider implementation for creating FailureInjectorTransportAdapter instances.

FailureInjectorTransportAdapter

TBD

FailureInjectorTransportAdapter.All

TBD

FailureInjectorTransportAdapter.Drop

TBD

FailureInjectorTransportAdapter.One

TBD

FailureInjectorTransportAdapter.PassThru

TBD

ForceDisassociate

Management command to force disassociation of an address

ForceDisassociateAck

INTERNAL API

ForceDisassociateExplicitly

Management command to force disassociation of an address with an explicit error.

InboundAssociation

Message sent to IAssociationEventListener registered to a transport (via the TaskCompletionSource returned by Listen()) when the inbound association request arrives.

InboundPayload

Message sent to the listener registered to an association (via the TaskCompletionSource returned by ReadHandlerSource)

InvalidAssociationException

This exception is thrown when an association setup request is invalid and it is impossible to recover (malformed IP address, unknown hostname, etc...).

ListenAttempt

ListenerRegistered

TBD

ListenUnderlying

TBD

SchemeAugmenter

Used to augment the protocol scheme of transports when enabled.

SetThrottle

Applies a throttle to the underlying conneciton

SetThrottleAck

ACKs a throttle command

ShutdownAttempt

SwitchableLoggedBehavior<TIn, TOut>

Test utility to make behavior 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 always 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.