Struct SimNetwork 

pub struct SimNetwork { /* private fields */ }

Simulated network for DST.

TigerStyle:

• Deterministic message delivery with configurable delays
• Explicit partitions with heal/partition API
• Fault injection at send/receive boundaries
• Full statistics tracking

Implementations

impl SimNetwork

pub fn new( clock: SimClock, rng: DeterministicRng, fault_injector: Arc<FaultInjector>, ) -> Self

Create a new simulated network.

TigerStyle: Takes shared fault injector for consistent fault injection.

pub fn with_latency(self, base_ms: u64, jitter_ms: u64) -> Self

Set network latency parameters.

Panics

Panics if base_ms exceeds NETWORK_LATENCY_MS_MAX.

pub async fn send(&self, from: &str, to: &str, payload: Bytes) -> bool

Send a message from one node to another.

Returns true if message was queued, false if dropped (partition/fault).

pub async fn receive(&self, node_id: &str) -> Vec<NetworkMessage>

Receive messages for a node.

Returns all messages that have arrived (delivery time <= current time).

pub async fn partition(&self, node_a: &str, node_b: &str)

Create a network partition between two nodes.

Messages between these nodes will be dropped.

pub async fn heal(&self, node_a: &str, node_b: &str)

Heal a network partition between two nodes.

pub async fn heal_all(&self)

Heal all network partitions.

pub async fn is_partitioned(&self, node_a: &str, node_b: &str) -> bool

Check if two nodes are partitioned.

pub async fn pending_count(&self, node_id: &str) -> usize

Get count of pending messages for a node.

pub async fn total_pending(&self) -> usize

Get total pending messages across all nodes.

pub async fn clear(&self)

Clear all pending messages.

pub fn clock(&self) -> &SimClock

Get the clock.