Struct SimTransport 

pub struct SimTransport { /* private fields */ }

In-memory SyncTransport. Routes a SyncRequest straight to the target peer’s SyncHandler through the shared SimNetwork — no sockets, no serialization — and honors the network’s partition state.

Trait Implementations

impl SyncTransport for SimTransport

fn transport_type(&self) -> &'static str

Get the transport type identifier.

fn can_handle_address(&self, address: &Address) -> bool

Check if this transport can handle the given address

fn start_server<'life0, 'async_trait>( &'life0 mut self, handler: Arc<dyn SyncHandler>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Start a server with the pre-configured bind address.

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

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

Stop the running server gracefully.

fn send_request<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, address: &'life1 Address, request: &'life2 SyncRequest, ) -> Pin<Box<dyn Future<Output = Result<SyncResponse>> + Send + 'async_trait>>

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

Send a sync request to a peer and receive a response.

fn is_server_running(&self) -> bool

Check if the server is currently running.

fn get_server_address(&self) -> Result<String>

Get the address the server is currently bound to.

fn send_entries<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, address: &'life1 Address, entries: &'life2 [Entry], ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Send entries to a sync peer and ensure they are acknowledged.