Struct LoopbackTransport 

pub struct LoopbackTransport { /* private fields */ }

An in-process SyncTransport: each scope is a real FsRelay + InMemoryLeaseCoordinator over a temp dir, so it reproduces the canonical relay/lease semantics exactly. Clone shares one server across devices.

Implementations

impl LoopbackTransport

pub fn new() -> Result<Self>

A fresh reference server (system wall clock, no eviction horizon).

pub fn with_config(config: RelayConfig, wall: WallClock) -> Result<Self>

Trait Implementations

impl Clone for LoopbackTransport

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl OrgKeyTransport for LoopbackTransport

fn publish_wrapped( &self, scope: &str, wrapped: &WrappedOrgKey, ) -> Result<(), TransportError>

fn fetch_wrapped( &self, scope: &str, epoch: u64, recipient_user_id: &str, ) -> Result<Option<WrappedOrgKey>, TransportError>

fn fetch_wrapped_for( &self, scope: &str, recipient_user_id: &str, ) -> Result<Vec<WrappedOrgKey>, TransportError>

fn publish_pubkey( &self, scope: &str, account_id: &str, public_hex: &str, ) -> Result<(), TransportError>

fn fetch_pubkeys( &self, scope: &str, ) -> Result<Vec<MemberPublicKey>, TransportError>

impl SyncTransport for LoopbackTransport

fn enroll( &self, scope: &str, device_id: &str, ) -> Result<RosterEntry, TransportError>

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

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

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

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

fn checkpoint_get( &self, scope: &str, ) -> Result<Option<Checkpoint>, TransportError>

fn roster(&self, scope: &str) -> Result<Vec<RosterEntry>, TransportError>

fn stable_frontier(&self, scope: &str) -> Result<Option<Hlc>, TransportError>

fn gc(&self, scope: &str) -> Result<GcReport, TransportError>

fn lease_acquire( &self, scope: &str, agent_id: &str, device_id: &str, ttl_ms: u64, ) -> Result<LeaseWire, TransportError>

fn lease_renew( &self, scope: &str, agent_id: &str, device_id: &str, epoch: u64, ttl_ms: u64, ) -> Result<LeaseWire, TransportError>

fn lease_release( &self, scope: &str, agent_id: &str, device_id: &str, epoch: u64, ) -> Result<LeaseWire, TransportError>

fn lease_current( &self, scope: &str, agent_id: &str, ) -> Result<LeaseWire, TransportError>