Struct InMemoryStorage 

pub struct InMemoryStorage { /* private fields */ }

Implementations

impl InMemoryStorage

pub fn new() -> Self

Trait Implementations

impl Default for InMemoryStorage

fn default() -> Self

Returns the “default value” for a type.

impl Storage for InMemoryStorage

fn health_check(&self) -> Result<()>

Health check

fn write_state(&self, record: StateRecord) -> Result<()>

Write a state record

fn read_state(&self, record_id: &RecordId) -> Result<Option<StateRecord>>

Read a state record

fn read_state_at_version( &self, record_id: &RecordId, version: Version, ) -> Result<Option<StateRecord>>

Read state at specific version

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

List all keys for an agent

fn scan_prefix( &self, namespace: &str, agent_id: &str, prefix: &str, ) -> Result<Vec<StateRecord>>

Scan keys with prefix

fn append_event(&self, event: EventLogEntry) -> Result<()>

Append event to log

fn replay_events( &self, namespace: &str, agent_id: &str, start_ts: Option<CommitTs>, end_ts: Option<CommitTs>, ) -> Result<Vec<EventLogEntry>>

Replay events for an agent

fn next_commit_ts(&self) -> Result<CommitTs>

Get next commit timestamp

fn flush(&self) -> Result<()>

Flush writes to disk

fn create_snapshot(&self) -> Result<Snapshot>

Create a snapshot of current state

fn save_snapshot(&self, _snapshot: &Snapshot) -> Result<()>

Save snapshot to disk

fn load_snapshot(&self) -> Result<Option<Snapshot>>

Load latest snapshot from disk

fn get_all_state(&self) -> Result<Vec<StateRecord>>

Get all state records (for snapshotting)