Struct InMemoryTransport 

pub struct InMemoryTransport;

Factory namespace for in-memory replication transports.

InMemoryTransport is a zero-sized type whose associated functions build InMemoryEndpoint / InMemoryGroup instances. See the module-level docs for the full topology table and design rationale.

Implementations

impl InMemoryTransport

pub fn new_pair() -> (InMemoryEndpoint, InMemoryEndpoint)

Create a single bidirectional pair of cross-connected in-memory endpoints.

Sends on a arrive at b’s receive queue and vice versa. Equivalent to LocalChannelPair::new but returned as production-named InMemoryEndpoint handles.

pub fn new_group(n: usize) -> InMemoryGroup

Create an n-node fully-connected in-memory group.

The returned InMemoryGroup owns n · (n - 1) directional channels arranged so that group.channel(i, j).send(msg) is observed by group.channel(j, i).receive(...).

Panics

Panics if n == 0. A 1-node “group” is supported (degenerate) but a zero-node group is meaningless and almost certainly a caller bug.