Struct Network 

pub struct Network { /* private fields */ }

The virtual network: links, cuts, the flight queue, and per-node inboxes.

Implementations

impl Network

pub fn new(default_link: LinkConfig) -> Self

A fully connected network using default_link for pairs without an explicit configuration.

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

Overrides the configuration of one directed link.

pub fn partition( &mut self, group_a: impl IntoIterator<Item = NodeId>, group_b: impl IntoIterator<Item = NodeId>, )

Cuts connectivity between two node sets, in both directions. Messages already in flight are unaffected.

pub fn heal(&mut self)

Restores full connectivity.

pub fn connected(&self, a: NodeId, b: NodeId) -> bool

Whether a send between the two nodes would go through.

pub fn send( &mut self, from: NodeId, to: NodeId, payload: Vec<u8>, now: Micros, rng: &mut SimRng, ) -> SendOutcome

Queues a message for delivery, applying the link’s latency, drop, and duplication behavior. All randomness comes from rng.

pub fn deliver_due( &mut self, now: Micros, crashed: &BTreeSet<NodeId>, ) -> Vec<Delivery>

Moves every message due at or before now into destination inboxes. Messages addressed to crashed nodes are discarded.

pub fn next_delivery(&self) -> Option<Micros>

The earliest pending delivery time, if any.

pub fn try_recv(&mut self, node: NodeId) -> Option<Message>

Pops the oldest message from a node’s inbox.

pub fn inbox_len(&self, node: NodeId) -> usize

Number of messages waiting in a node’s inbox.

pub fn clear_inbox(&mut self, node: NodeId)

Drops every buffered message of a node (its volatile state).

pub fn stats(&self) -> NetworkStats

Cumulative delivery counters.

Trait Implementations

impl Debug for Network

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

Formats the value using the given formatter.