Struct SimNetwork 

pub struct SimNetwork { /* private fields */ }

Simulated network that intercepts all inter-node communication.

Fully deterministic given the same seed. Supports partitions, drops, latency, jitter, reordering, and message duplication.

Implementations

impl SimNetwork

pub fn new(seed: u64) -> Self

Create a new simulated network with the given random seed.

pub fn set_link_config(&mut self, from: NodeId, to: NodeId, config: LinkConfig)

Set the link configuration between two nodes.

pub fn set_all_links(&mut self, nodes: &[NodeId], config: LinkConfig)

Configure all links between the given nodes symmetrically.

pub fn inject_partition(&mut self, a: NodeId, b: NodeId)

Inject a symmetric partition: all messages between a and b are dropped.

pub fn heal_partition(&mut self, a: NodeId, b: NodeId)

Heal a symmetric partition.

pub fn inject_one_way_partition(&mut self, from: NodeId, to: NodeId)

Inject a one-way partition: from→to dropped, to→from delivered.

pub fn heal_one_way_partition(&mut self, from: NodeId, to: NodeId)

Heal a one-way partition.

pub fn heal_all_partitions(&mut self)

Heal all partitions.

pub fn send(&mut self, from: NodeId, to: NodeId, payload: Vec<u8>)

Submit a message into the network.

pub fn tick(&mut self)

Advance by one tick, delivering any due messages.

pub fn drain(&mut self, node_id: NodeId) -> Vec<(NodeId, Vec<u8>)>

Drain delivered messages for a specific node.

pub fn current_tick(&self) -> u64

Current simulation tick.

pub fn in_flight_count(&self) -> usize

Number of messages currently in-flight.

pub fn total_sent(&self) -> u64

Stats: total messages sent.

pub fn total_dropped(&self) -> u64

Stats: total messages dropped.

pub fn total_delivered(&self) -> u64

Stats: total messages delivered.

pub fn total_corrupted(&self) -> u64

Stats: total messages corrupted.

pub fn total_throttled(&self) -> u64

Stats: total messages throttled (delayed due to bandwidth limit).

pub fn partition_pairs(&self) -> Vec<(NodeId, NodeId)>

Get all active partition pairs.