Struct SyncOpRelay 

pub struct SyncOpRelay { /* private fields */ }

A reference op relay/store — append-only, dedup by frame content, cursor = position. The responder side of the protocol. A dumb pipe: it stores and serves opaque frames and trusts nothing. Cloning yields another handle onto the same store (so a node can both serve and be queried).

Implementations

impl SyncOpRelay

pub fn new() -> Self

pub fn publish(&self, op_frames: &[Vec<u8>]) -> u64

Add frames, skipping any already present (dedup by content). Returns the number newly added.

pub fn pull_since(&self, cursor: u64) -> (Vec<Vec<u8>>, u64)

The frames after cursor (in store order) plus the next cursor. Re-pulling is safe.

pub fn len(&self) -> usize

Number of distinct frames held.

pub fn is_empty(&self) -> bool

pub fn handle(&self, req: SyncOpRequest) -> SyncOpResponse

Serve one request against the store — the responder’s request→response handler.

Trait Implementations

impl Clone for SyncOpRelay

fn clone(&self) -> SyncOpRelay

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for SyncOpRelay

fn default() -> SyncOpRelay

Returns the “default value” for a type.