Struct MemoryStorage 

pub struct MemoryStorage { /* private fields */ }

In-memory CRDT storage for testing.

This implementation stores all data in memory using HashMap and Vec. It’s thread-safe via RwLock but data is lost when dropped.

Auto-compaction is triggered when the number of updates for a document exceeds [AUTO_COMPACT_THRESHOLD], keeping the most recent [AUTO_COMPACT_KEEP] updates.

Implementations

impl MemoryStorage

pub fn new() -> Self

Create a new empty in-memory storage.

Trait Implementations

impl CrdtStorage for MemoryStorage

fn load_doc(&self, name: &str) -> StorageResult<Option<Vec<u8>>>

Load the full document state as a binary blob.

fn save_doc(&self, name: &str, state: &[u8]) -> StorageResult<()>

Save the full document state.

fn delete_doc(&self, name: &str) -> StorageResult<()>

Delete a document and all its updates.

fn list_docs(&self) -> StorageResult<Vec<String>>

List all document names in storage.

fn append_update_with_device( &self, name: &str, update: &[u8], origin: UpdateOrigin, device_id: Option<&str>, device_name: Option<&str>, ) -> StorageResult<i64>

Append an incremental update with device attribution.

fn get_updates_since( &self, name: &str, since_id: i64, ) -> StorageResult<Vec<CrdtUpdate>>

Get all updates for a document since a given update ID.

fn get_all_updates(&self, name: &str) -> StorageResult<Vec<CrdtUpdate>>

Get all updates for a document.

fn get_state_at( &self, name: &str, update_id: i64, ) -> StorageResult<Option<Vec<u8>>>

Get the state of a document at a specific point in history.

fn compact(&self, name: &str, keep_updates: usize) -> StorageResult<()>

Compact old updates into the document snapshot.

fn get_latest_update_id(&self, name: &str) -> StorageResult<i64>

Get the latest update ID for a document.

fn rename_doc(&self, old_name: &str, new_name: &str) -> StorageResult<()>

Rename a document by copying its state and updates to a new name.

fn clear_updates(&self, name: &str) -> StorageResult<()>

Clear all updates for a document while keeping the snapshot.

fn append_update( &self, name: &str, update: &[u8], origin: UpdateOrigin, ) -> StorageResult<i64>

Append an incremental update to the update log.

fn batch_append_updates( &self, updates: &[(&str, &[u8], UpdateOrigin)], ) -> StorageResult<Vec<i64>>

Append multiple updates atomically.

impl Debug for MemoryStorage

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

Formats the value using the given formatter.

impl Default for MemoryStorage

fn default() -> MemoryStorage

Returns the “default value” for a type.