Struct FaultyTransport 

pub struct FaultyTransport { /* private fields */ }

Fault-injection wrapper around InMemoryTransport.

Useful for SWIM / circuit-breaker / reconnect tests.

Implementations

impl FaultyTransport

pub fn new(inner: InMemoryTransport) -> Self

Wrap an in-memory transport with default (healthy) fault settings.

pub fn set_drop_every_n(&self, n: u32)

Drop every Nth sent message (0 disables).

pub fn set_fail_next_connects(&self, n: u32)

Fail the next n connect attempts with a transport error.

pub fn set_latency_ms(&self, ms: u64)

Artificial connect latency in milliseconds.

pub fn inner(&self) -> &InMemoryTransport

Access the underlying fabric (e.g. to share listeners).

Trait Implementations

impl MeshTransport for FaultyTransport

fn name(&self) -> &str

Human-readable transport name (e.g., “quic”, “websocket”, “tcp”).

fn listen<'life0, 'life1, 'async_trait>( &'life0 self, addr: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn TransportListener>, MeshError>> + Send + 'async_trait>>

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

Start listening for incoming connections on the given address.

fn connect<'life0, 'life1, 'async_trait>( &'life0 self, addr: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn MeshStream>, MeshError>> + Send + 'async_trait>>

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

Connect to a remote peer at the given address.

fn supports(&self, addr: &str) -> bool

Check if this transport supports the given address scheme.