Struct MemoryStore 

pub struct MemoryStore { /* private fields */ }

In-memory storage backend.

All data is stored in BTreeMaps — nothing touches disk. Ideal for testing and prototyping.

Example

use crdt_store::{MemoryStore, StateStore};

let mut store = MemoryStore::new();
store.put("sensors", "s1", b"temp=22.5").unwrap();

let data = store.get("sensors", "s1").unwrap().unwrap();
assert_eq!(data, b"temp=22.5");

Implementations

impl MemoryStore

pub fn new() -> Self

Create a new empty in-memory store.

pub fn state_count(&self) -> usize

Returns the total number of state entries across all namespaces.

pub fn total_event_count(&self) -> usize

Returns the total number of events across all entities.

Trait Implementations

impl Default for MemoryStore

fn default() -> Self

Returns the “default value” for a type.

impl EventStore for MemoryStore

fn append_event( &mut self, namespace: &str, entity_id: &str, data: &[u8], timestamp: u64, node_id: &str, ) -> Result<u64, Self::Error>

Append an event to the log for a given entity. Returns the assigned sequence number.

fn events_since( &self, namespace: &str, entity_id: &str, since_sequence: u64, ) -> Result<Vec<StoredEvent>, Self::Error>

Read events for an entity since a given sequence number (exclusive).

fn event_count( &self, namespace: &str, entity_id: &str, ) -> Result<u64, Self::Error>

Count total events for an entity (useful for compaction decisions).

fn save_snapshot( &mut self, namespace: &str, entity_id: &str, state: &[u8], at_sequence: u64, version: u8, ) -> Result<(), Self::Error>

Save a snapshot of an entity’s state at a given event sequence.

fn load_snapshot( &self, namespace: &str, entity_id: &str, ) -> Result<Option<Snapshot>, Self::Error>

Load the latest snapshot for an entity.

fn truncate_events_before( &mut self, namespace: &str, entity_id: &str, before_sequence: u64, ) -> Result<u64, Self::Error>

Delete events before a given sequence (for compaction). The snapshot at before_sequence must exist first.

impl StateStore for MemoryStore

type Error = MemoryError

Error type for this backend.

fn put( &mut self, namespace: &str, key: &str, value: &[u8], ) -> Result<(), Self::Error>

Store a value under (namespace, key).

fn get( &self, namespace: &str, key: &str, ) -> Result<Option<Vec<u8>>, Self::Error>

Retrieve a value by (namespace, key). Returns None if the key does not exist.

fn delete(&mut self, namespace: &str, key: &str) -> Result<(), Self::Error>

Delete a value by (namespace, key).

fn list_keys(&self, namespace: &str) -> Result<Vec<String>, Self::Error>

List all keys in a namespace.

fn exists(&self, namespace: &str, key: &str) -> Result<bool, Self::Error>

Check if a key exists in a namespace.