Class FailureInjectorTransportAdapter

TBD

Inheritance

Object

Transport

AbstractTransportAdapter

FailureInjectorTransportAdapter

Implements

IAssociationEventListener

Inherited Members

AbstractTransportAdapter.WrappedTransport

AbstractTransportAdapter.SchemeIdentifier

AbstractTransportAdapter.MaximumPayloadBytes

AbstractTransportAdapter.IsResponsibleFor(Address)

AbstractTransportAdapter.Listen()

AbstractTransportAdapter.Associate(Address)

AbstractTransportAdapter.Shutdown()

Transport.Config

Transport.System

Object.Equals(Object)

Object.Equals(Object, Object)

Object.GetHashCode()

Object.GetType()

Object.MemberwiseClone()

Object.ReferenceEquals(Object, Object)

Object.ToString()

Namespace: Akka.Remote.Transport

Assembly: Akka.Remote.dll

Syntax

public class FailureInjectorTransportAdapter : AbstractTransportAdapter, IAssociationEventListener

Constructors

FailureInjectorTransportAdapter(Transport, ExtendedActorSystem)

TBD

Declaration

public FailureInjectorTransportAdapter(Transport wrappedTransport, ExtendedActorSystem extendedActorSystem)

Parameters

Type	Name	Description
Transport	wrappedTransport	TBD
ExtendedActorSystem	extendedActorSystem	TBD

Fields

ExtendedActorSystem

TBD

Declaration

public readonly ExtendedActorSystem ExtendedActorSystem

Field Value

Type	Description
ExtendedActorSystem

FailureInjectorSchemeIdentifier

TBD

Declaration

public const string FailureInjectorSchemeIdentifier = "gremlin"

Field Value

Type	Description
String

MaximumOverhead

TBD

Declaration

protected int MaximumOverhead

Field Value

Type	Description
Int32

Properties

SchemeAugmenter

TBD

Declaration

protected override SchemeAugmenter SchemeAugmenter { get; }

Property Value

Type	Description
SchemeAugmenter

Overrides

AbstractTransportAdapter.SchemeAugmenter

Methods

InterceptAssociate(Address, TaskCompletionSource<AssociationHandle>)

TBD

Declaration

protected override void InterceptAssociate(Address remoteAddress, TaskCompletionSource<AssociationHandle> statusPromise)

Parameters

Type	Name	Description
Address	remoteAddress	TBD
TaskCompletionSource<AssociationHandle>	statusPromise	TBD

Overrides

AbstractTransportAdapter.InterceptAssociate(Address, TaskCompletionSource<AssociationHandle>)

Exceptions

Type	Condition
FailureInjectorException	TBD

InterceptListen(Address, Task<IAssociationEventListener>)

TBD

Declaration

protected override Task<IAssociationEventListener> InterceptListen(Address listenAddress, Task<IAssociationEventListener> listenerTask)

Parameters

Type	Name	Description
Address	listenAddress	TBD
Task<IAssociationEventListener>	listenerTask	TBD

Returns

Type	Description
Task<IAssociationEventListener>	TBD

Overrides

AbstractTransportAdapter.InterceptListen(Address, Task<IAssociationEventListener>)

ManagementCommand(Object)

TBD

Declaration

public override Task<bool> ManagementCommand(object message)

Parameters

Type	Name	Description
Object	message	TBD

Returns

Type	Description
Task<Boolean>	TBD

Overrides

Transport.ManagementCommand(Object)

Notify(IAssociationEvent)

TBD

Declaration

public void Notify(IAssociationEvent ev)

Parameters

Type	Name	Description
IAssociationEvent	ev	TBD

ShouldDropInbound(Address, Object, String)

TBD

Declaration

public bool ShouldDropInbound(Address remoteAddress, object instance, string debugMessage)

Parameters

Type	Name	Description
Address	remoteAddress	TBD
Object	instance	TBD
String	debugMessage	TBD

Returns

Type	Description
Boolean	TBD

ShouldDropOutbound(Address, Object, String)

TBD

Declaration

public bool ShouldDropOutbound(Address remoteAddress, object instance, string debugMessage)

Parameters

Type	Name	Description
Address	remoteAddress	TBD
Object	instance	TBD
String	debugMessage	TBD

Returns

Type	Description
Boolean	TBD

Implements

IAssociationEventListener

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(Object)