Struct Persistent 

pub struct Persistent<T>
where
    T: Merge + Serialize + DeserializeOwned + Clone + Default + Send + 'static,
{ /* private fields */ }

A persistent CRDT wrapper with journaling (native platform).

Wraps any type implementing Merge + Serialize + DeserializeOwned and provides durable storage with crash recovery.

This is the native version with Send bounds required for thread-safe access. The WASM version relaxes these bounds since JavaScript is single-threaded.

Implementations

impl<T> Persistent<T>

where T: Merge + Serialize + DeserializeOwned + Clone + Default + Send + 'static,

Native implementation with Send bounds.

pub async fn mount( vfs: Arc<dyn Vfs + Send + Sync>, path: &str, ) -> VfsResult<Self>

Mount a persistent value from a journal file.

If the journal exists, replays all entries to reconstruct state. If not, creates a new journal with default state.

pub async fn get(&self) -> T

Get immutable access to the current state.

pub async fn mutate<F, R>(&self, f: F) -> VfsResult<R>

where F: FnOnce(&mut T) -> R + Send,

Mutate the state and persist the delta.

pub async fn compact(&self) -> VfsResult<()>

Compact the journal by writing a snapshot.

pub async fn entry_count(&self) -> u64

Get the number of journal entries.

pub async fn maybe_compact(&self, threshold: u64) -> VfsResult<bool>

Automatically compact when entry count exceeds threshold.