Struct InMemoryRelay 

pub struct InMemoryRelay { /* private fields */ }

The in-process reference relay: [RelayState] + an injected wall clock.

Implementations

impl InMemoryRelay

pub fn new(config: RelayConfig, wall: WallClock) -> Self

Trait Implementations

impl Debug for InMemoryRelay

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

Formats the value using the given formatter.

impl Relay for InMemoryRelay

fn register(&mut self, device_id: &str) -> Result<RosterEntry, RelayError>

Enroll (or touch) a device on the roster. Idempotent; push/pull/ack auto-register on first contact.

fn push( &mut self, device_id: &str, ops: &[OpRecord], ) -> Result<PushOutcome, RelayError>

Admit device_id’s own journal-durable ops (in seq order) onto its relay-held chain. Contract (B1, binding): the caller transmits only ops that are already journal-durable on the device.

fn pull( &mut self, device_id: &str, since: &Frontier, ) -> Result<PullResult, RelayError>

Every retained op above since (per-device seq cursor) + the latest checkpoint pointer.

fn ack( &mut self, device_id: &str, frontier: Hlc, ) -> Result<AckOutcome, RelayError>

Record a device’s fold frontier. Contract (B4, binding): the device acks only what it has DURABLY folded (journaled), never merely received.

fn checkpoint_put( &mut self, device_id: &str, checkpoint: &Checkpoint, ) -> Result<bool, RelayError>

Store a device-computed checkpoint. Verified, deduped on checkpoint_hash (whole-record content address — contract from B4). Returns false when the identical checkpoint was already stored.

fn checkpoint_get(&mut self) -> Result<Option<Checkpoint>, RelayError>

The latest stored checkpoint (dominance-monotone pointer), if any.

fn roster(&mut self) -> Result<Vec<RosterEntry>, RelayError>

The device registry.

fn stable_frontier(&mut self) -> Result<Option<Hlc>, RelayError>

min(acked) over active roster devices; None while any active device has never acked (nothing is droppable then).

fn gc(&mut self) -> Result<GcReport, RelayError>

Drop every op that is BOTH at/below the stable frontier AND covered by a stored checkpoint. Never drops anything else.