Struct DurableReplica 

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

Additive durable API for Linux local filesystems. The root must already exist durably and remain in place; all writers use the same fixed root and configuration. Each Accepted/Ok(record) follows full transaction replacement and file + directory sync. Any persistence error permanently disables this instance’s writes, retaining its fence until drop. Use the explicit restart constructors for existing stores; fresh constructors never reset a store.

Implementations

impl<C: Crdt> DurableReplica<C>

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

pub fn state(&self) -> &C

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

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

pub fn ticket(&self) -> WriteTicket

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

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

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

impl DurableReplica<GCounter>

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

Reacquire ownership, validate the committed history and replay fresh state. Any error returns no replica and grants no write ticket.

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

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

impl DurableReplica<OrSet<String, u64>>

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

Checked ordinary restart, including tombstones and token allocation.

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>