Struct LocalReplica 

pub struct LocalReplica<C: Crdt> { /* private fields */ }

Owns the OS lock for its entire lifetime. No Clone or mutable state/log access is exposed. Contention yields a read-only instance whose writes fail.

Implementations

impl<C: Crdt> LocalReplica<C>

where C::Delta: OwnedDelta + Clone + PartialEq,

pub fn state(&self) -> &C

pub fn log(&self) -> &EventLog<C::Delta>

pub fn ticket(&self) -> WriteTicket

pub fn allocation_bytes(&self) -> Vec<u8>

Ordinary allocation metadata, independent of the lock generation.

pub fn renew(&mut self, ticket: WriteTicket) -> Result<WriteTicket, LocalError>

Revoke outstanding tickets while retaining the same exclusive OS lock. I/O uncertainty disables writes. This does not recover a replica.

pub fn receive( &mut self, ticket: WriteTicket, record: Record<C::Delta>, ) -> Result<Admission, LocalError>

Validate ownership and the local lease BEFORE calling M1 admission. Remote redelivery and reordering do not require the receiver to own the author’s coordinate. They require the record to carry its author’s space.

pub fn append( &mut self, ticket: WriteTicket, delta: C::Delta, ) -> Result<Record<C::Delta>, LocalError>

Append an existing delta in the configured writer’s space. No allocation or state mutation occurs on refusal, exhaustion, duplicate or collision.

impl LocalReplica<GCounter>

pub fn counter(root: &Path, config: WriterConfig) -> Result<Self, LocalError>

pub fn bump( &mut self, ticket: WriteTicket, tally: u64, ) -> Result<Record<GCounterDelta>, LocalError>

impl LocalReplica<OrSet<String, u64>>

pub fn utf8_set(root: &Path, config: WriterConfig) -> Result<Self, LocalError>

pub fn add( &mut self, ticket: WriteTicket, element: String, ) -> Result<Record<OrSetDelta<String, u64>>, LocalError>

pub fn remove( &mut self, ticket: WriteTicket, element: &String, ) -> Result<Record<OrSetDelta<String, u64>>, LocalError>

Trait Implementations

impl<C: Crdt> Drop for LocalReplica<C>

fn drop(&mut self)

Executes the destructor for this type. Read more

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned. Read more