Struct FailureInjectorTransport 

pub struct FailureInjectorTransport { /* private fields */ }

Implementations

impl FailureInjectorTransport

pub fn new(inner: Arc<dyn Transport>, mode: InjectionMode) -> Arc<Self>

pub fn set_mode(&self, mode: InjectionMode)

Trait Implementations

impl Transport for FailureInjectorTransport

fn listen<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Address, TransportError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Bind a listener and return the local Address.

fn associate<'life0, 'life1, 'async_trait>( &'life0 self, target: &'life1 Address, ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Open (or reuse) an outbound association to target.

fn send<'life0, 'life1, 'async_trait>( &'life0 self, target: &'life1 Address, pdu: AkkaPdu, ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Send a single PDU to the peer at target. Implementations are expected to associate lazily if needed.

fn inbound(&self) -> UnboundedReceiver<InboundFrame>

Take ownership of the inbound stream. Calling more than once returns an empty channel.

fn disassociate<'life0, 'life1, 'async_trait>( &'life0 self, target: &'life1 Address, ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Drop a specific association (used by quarantine).

fn shutdown<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Stop listening and close all associations.