Struct SharedMemory 

pub struct SharedMemory { /* private fields */ }

In-memory shared KV store with optimistic locking.

Thread-safe via parking_lot::RwLock. Supports atomic increment for counters and version-based conflict detection.

Implementations

impl SharedMemory

pub fn new() -> Self

Create a new shared memory store.

pub fn read(&self, key: &MemoryKey) -> Option<Value>

Read a value by key.

pub fn read_entry(&self, key: &MemoryKey) -> Option<MemoryEntry>

Read a full entry (including version and metadata).

pub fn write( &self, key: &MemoryKey, value: Value, author: &str, expected_version: Option<u64>, ) -> Result<u64, SdkError>

Write a value with optional optimistic locking.

If expected_version is Some(v), the write fails if the current version does not match. Returns the new version on success.

pub fn increment(&self, key: &MemoryKey, delta: i64, author: &str) -> i64

Atomic increment for counter values. Returns the new value.

pub fn delete(&self, key: &MemoryKey) -> bool

Delete a key. Returns true if the key existed.

pub fn list_namespace(&self, namespace: &str) -> Vec<MemoryKey>

List all keys in a namespace.

pub fn subscribe(&self) -> Receiver<MemoryEvent>

Subscribe to memory events.

Trait Implementations

impl Default for SharedMemory

fn default() -> Self

Returns the “default value” for a type.