Struct SimNetwork 

pub struct SimNetwork { /* private fields */ }

In-memory message fabric shared by every SimTransport in a cluster, and the control handle a test uses to inject faults. A drop-in for HttpLoopback via ClusterBuilder::transport that additionally lets a test partition links and heal them.

Clone is a shared handle (an Arc inside): the copy a test keeps and the copies inside each peer’s transport all see the same fabric.

Implementations

impl SimNetwork

pub fn new() -> Self

A fresh, empty fabric.

pub fn partition(&self, a: &Address, b: &Address)

Drop all traffic between a and b in both directions until heal. A send across a blocked link fails as a connection error, so an auto-sync peer’s queued entries stay pending and redeliver after heal — a message-level partition, finer than withholding exchange calls.

pub fn heal(&self, a: &Address, b: &Address)

Restore traffic between a and b (both directions).

pub fn heal_all(&self)

Restore every link in the fabric.

pub fn set_manual_delivery(&self, manual: bool)

Capture SendEntries pushes instead of delivering them inline (true), or return to inline delivery (false). Flip this after setup (bootstrap / auto_sync) so only the entry pushes a test cares about get captured. Turning it back off does not flush the queue — already-captured messages still need an explicit deliver.

The two fault families compose with partition taking precedence: a send across a partitioned link fails as a connection error before capture is considered, so it parks in the retry queue rather than the in-flight queue. Manual delivery only ever captures pushes on links that are up. Tests generally use one family or the other, not both at once.

pub fn pending(&self) -> Vec<usize>

The delivery handles of every captured-but-undelivered message, in the order they were sent. Pass these to deliver, duplicate or drop_message to drive an out-of-order, duplicated, or lossy schedule.

pub async fn deliver(&self, seq: usize) -> bool

Deliver the captured message seq to its receiver and remove it from the queue. Delivering in an order other than pending returned is how a test reorders the wire. Returns false if no such message is queued (or its receiver has stopped).

pub async fn deliver_one(&self) -> bool

Deliver the oldest captured message. Returns false when the queue is empty.

pub async fn deliver_all(&self) -> usize

Deliver every captured message in send order, draining the queue. Returns the number delivered. (Delivery never enqueues more — the receiver’s handler processes entries, it doesn’t push back through this fabric.)

pub fn duplicate(&self, seq: usize) -> Option<usize>

Clone captured message seq so it will be delivered a second time, modelling a duplicate on the wire. The copy gets a fresh handle and lands at the back of the queue; the original stays put. Returns the new handle, or None if seq isn’t queued. Idempotent sync must converge regardless.

pub fn drop_message(&self, seq: usize) -> bool

Drop captured message seq without delivering it — a lost packet. Returns true if a message was removed.

pub fn drop_all(&self) -> usize

Drop every captured message without delivering. Returns the number lost.

Trait Implementations

impl Clone for SimNetwork

fn clone(&self) -> SimNetwork

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for SimNetwork

fn default() -> SimNetwork

Returns the “default value” for a type.