Struct StateMachine 

pub struct StateMachine { /* private fields */ }

State machine for Statehouse Single-writer design: all mutations go through one logical thread

Implementations

impl StateMachine

pub fn new(storage: Arc<dyn Storage>) -> Self

pub fn begin_transaction(&self, timeout_ms: Option<u64>) -> Result<TxnId>

Begin a new transaction

pub fn write( &self, txn_id: &str, namespace: String, agent_id: String, key: String, value: Value, ) -> Result<()>

Stage a write operation

pub fn delete( &self, txn_id: &str, namespace: String, agent_id: String, key: String, ) -> Result<()>

Stage a delete operation

pub fn commit(&self, txn_id: &str) -> Result<CommitTs>

Commit a transaction atomically

pub fn abort(&self, txn_id: &str) -> Result<()>

Abort a transaction

pub fn get_state( &self, namespace: &str, agent_id: &str, key: &str, ) -> Result<Option<StateRecord>>

Read latest state

pub fn get_state_at_version( &self, namespace: &str, agent_id: &str, key: &str, version: Version, ) -> Result<Option<StateRecord>>

Read state at specific version

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

List keys for an agent

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

Scan keys with prefix

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

Replay events for an agent

pub fn cleanup_expired_transactions(&self)

Cleanup expired transactions (should be called periodically)

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

Create a snapshot of current state

pub fn maybe_snapshot(&self, snapshot_interval: u64) -> Result<()>

Check if snapshot should be created and do it if needed

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

Load snapshot and replay events after snapshot timestamp