Struct InMemoryRelay 

pub struct InMemoryRelay { /* private fields */ }

A shared in-memory relay — a dumb op store (append-only, dedup by operation id). Cloning yields another handle onto the same underlying store, so two nodes can rendezvous through one relay.

Implementations

impl InMemoryRelay

pub fn new() -> Self

pub fn len(&self) -> usize

Number of distinct operations the relay holds.

pub fn is_empty(&self) -> bool

Trait Implementations

impl Clone for InMemoryRelay

fn clone(&self) -> InMemoryRelay

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for InMemoryRelay

fn default() -> InMemoryRelay

Returns the “default value” for a type.

impl SyncTransport for InMemoryRelay

fn publish(&self, ops: &[SyncOperation]) -> Result<(), String>

Publish local operations to the relay/peer. Must be idempotent at the relay (dedup by operation id), so re-publishing a queued op is harmless.

fn pull(&self, since: u64) -> Result<Vec<SyncOperation>, String>

Pull operations the relay holds after cursor since (0 = from the start). Returns them in relay order. Re-pulling is safe: the inbox dedups by operation id on admission.