Search Results for

    Show / Hide Table of Contents

    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.

    ActorTransportAdapter

    Actor-based transport adapter

    ActorTransportAdapterManager

    TBD

    AkkaProtocolException

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

    AssociateAttempt

    TBD

    AssociateUnderlying

    TBD

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

    DisassociateUnderlying

    TBD

    Disassociated

    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

    ListenUnderlying

    TBD

    ListenerRegistered

    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.

    ThrottleMode

    The type of throttle being applied to a connection.

    ThrottleTransportAdapter

    INTERNAL API

    The throttler transport adapter

    ThrottlerProvider

    Used to provide throttling controls for remote Transport instances.

    TokenBucket

    Applies token-bucket throttling to introduce latency to a connection

    Transport

    TBD

    TransportOperation

    Marker interface for all transport operations

    UnderlyingTransportError

    The underlying transport reported a non-fatal error

    Unthrottled

    Unthrottles a previously throttled connection

    WriteAttempt

    Interfaces

    FailureInjectorTransportAdapter.IFailureInjectorCommand

    TBD

    FailureInjectorTransportAdapter.IGremlinMode

    TBD

    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

    Interface for producing adapters that can wrap an underlying transport and augment it with additional behavior.

    Enums

    DisassociateInfo

    Supertype of possible disassociation reasons

    ThrottleTransportAdapter.Direction

    TBD

    In this article
    Back to top
    Contribute
    • Project Chat
    • Discussion Forum
    • Source Code
    Support
    • Akka.NET Support Plans
    • Akka.NET Observability Tools
    • Akka.NET Training & Consulting
    Maintained By
    • Petabridge - The Akka.NET Company
    • Learn Akka.NET