Struct CausalSession 

pub struct CausalSession { /* private fields */ }

A causal-consistency session over one or more replicas of a document.

Implementations

impl CausalSession

pub fn new() -> Self

pub fn token(&self) -> &[u8]

The session’s causal token (the observed state-vector frontier).

pub fn record_write(&mut self, doc: &CrdtDoc) -> Outcome

Record a local write: the session has now observed everything in doc, including the write just made (read-your-writes). Returns Outcome::Local — written and offline-durable, propagation is asynchronous.

pub fn read(&mut self, doc: &CrdtDoc) -> Outcome

Attempt a causal read of doc. If doc has caught up to the session’s frontier, the read is served (Committed(Causal)) and the token advances to doc’s (≥) frontier — so the session never regresses (monotonic reads). If doc is behind, the read is honestly Outcome::Stale and the token is not advanced.

Trait Implementations

impl Clone for CausalSession

fn clone(&self) -> CausalSession

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CausalSession

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

Formats the value using the given formatter.

impl Default for CausalSession

fn default() -> CausalSession

Returns the “default value” for a type.