Struct PersistentStateManager 

pub struct PersistentStateManager<T: Serialize + for<'de> Deserialize<'de> + Clone + PartialEq> { /* private fields */ }

Implementations

impl<T: Serialize + for<'de> Deserialize<'de> + Clone + PartialEq + Send + Sync + 'static> PersistentStateManager<T>

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

Create new persistent state manager

pub async fn upsert(&self, key: String, value: T) -> Result<Option<T>>

Insert or update state entry

pub async fn delete(&self, key: &str) -> Result<Option<T>>

Delete state entry

pub fn get(&self, key: &str) -> Result<Option<T>>

Get state entry

pub fn get_all(&self) -> Result<HashMap<String, T>>

Get all state entries

pub async fn batch_update<F>(&self, update_fn: F) -> Result<()>

where F: FnOnce(&mut HashMap<String, T>) -> Result<()>,

Perform batch update

pub async fn checkpoint(&self) -> Result<()>

Create checkpoint (snapshot)

pub fn add_listener<F>(&self, listener: F) -> Result<()>

where F: Fn(&str, Option<&T>) + Send + Sync + 'static,

Register state change listener

pub fn recovery_stats(&self) -> Result<RecoveryStats>

Get recovery statistics

pub async fn verify_integrity(&self) -> Result<IntegrityReport>

Perform integrity check