Struct AtomicMemoryWriter 

pub struct AtomicMemoryWriter<C: ConnectionTrait> { /* private fields */ }

Atomic memory writer that ensures multi-index consistency

Implementations

impl<C: ConnectionTrait> AtomicMemoryWriter<C>

pub fn new(conn: C) -> Self

Create a new atomic memory writer

pub fn write_atomic( &self, memory_id: impl Into<String>, ops: Vec<MemoryOp>, ) -> Result<AtomicWriteResult>

Write an atomic memory item with all its components

This is the main entry point for atomic multi-index writes. Either all operations succeed, or the entire write can be retried.

Arguments

• memory_id - Unique ID for this memory item
• ops - Operations to apply atomically

Returns

The intent ID on success

pub fn recover(&self) -> Result<RecoveryReport>

Recover incomplete intents on startup

This should be called during connection initialization to replay any intents that were interrupted by a crash.

pub fn cleanup(&self, max_age_secs: u64) -> Result<usize>

Clean up old committed/aborted intents

Call this periodically to reclaim storage.