Struct SimNetworkProvider 

pub struct SimNetworkProvider { /* private fields */ }

Simulated networking implementation

Implementations

impl SimNetworkProvider

pub fn new(sim: WeakSimWorld) -> Self

Create a new simulated network provider

pub fn sleep(&self, duration: Duration) -> SimulationResult<SleepFuture>

Sleep in simulation time.

This allows workloads to introduce delays for coordination purposes. The sleep completes when the simulation processes the corresponding Wake event.

Trait Implementations

impl Clone for SimNetworkProvider

fn clone(&self) -> SimNetworkProvider

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SimNetworkProvider

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl NetworkProvider for SimNetworkProvider

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

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

Connect to a remote address.

When chaos is enabled, connection establishment can fail or hang forever based on the connect_failure_mode setting (FDB ref: sim2.actor.cpp:1243-1250):

• Disabled: Normal operation (no failure injection)
• AlwaysFail: Always fail with ConnectionRefused when buggified
• Probabilistic: 50% fail with error, 50% hang forever (tests timeout handling)

type TcpStream = SimTcpStream

The TCP stream type for this provider.

type TcpListener = SimTcpListener

The TCP listener type for this provider.

fn bind<'life0, 'life1, 'async_trait>( &'life0 self, addr: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Self::TcpListener>> + 'async_trait>>

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

Create a TCP listener bound to the given address.