Struct RocksStorage 

pub struct RocksStorage { /* private fields */ }

Implementations

impl RocksStorage

pub fn new(config: StorageConfig) -> Result<Self>

pub fn restore_from_snapshot(&self, snapshot: &Snapshot) -> Result<()>

Restore state from snapshot

Trait Implementations

impl Storage for RocksStorage

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)