Struct CrdtStore 

pub struct CrdtStore { /* private fields */ }

Persists CrdtDocs into an encrypted spacedb-store collection. Engine- agnostic like the underlying Collection: the methods take the engine and open their own transactions.

Implementations

impl CrdtStore

pub fn open<E: KvEngine>( engine: &E, key_provider: Arc<dyn KeyProvider>, ) -> CrdtResult<Self>

Open (or first-time provision) the CRDT document collection on engine.

pub fn save<E: KvEngine>( &self, engine: &E, doc_id: &str, doc: &CrdtDoc, ) -> CrdtResult<()>

Persist doc’s full CRDT state under doc_id, encrypted, in a single write transaction.

pub fn load<E: KvEngine>( &self, engine: &E, doc_id: &str, actor_id: u64, ) -> CrdtResult<CrdtDoc>

Load the document stored under doc_id for replica actor_id. Returns a fresh empty document if nothing has been persisted there yet (local-first: you can always start writing).

pub fn apply_remote<E: KvEngine>( &self, engine: &E, doc_id: &str, actor_id: u64, update: &[u8], ) -> CrdtResult<CrdtDoc>

Receive side of anti-entropy: merge a remote update into the persisted document and re-persist it (load → merge → save). Returns the merged doc.

pub fn contains<E: KvEngine>( &self, engine: &E, doc_id: &str, ) -> CrdtResult<bool>

Whether a document has been persisted under doc_id.