Struct StateRecovery 

pub struct StateRecovery { /* private fields */ }

Manages checkpoint persistence and recovery.

Implementations

impl StateRecovery

pub fn new(journal: Arc<dyn Journal>) -> Self

Creates a new state recovery manager.

pub async fn persist_checkpoint( &self, checkpoint: &StateCheckpoint, ) -> RecoveryResult<()>

Persists a checkpoint to the journal.

Arguments

• checkpoint - The state checkpoint to persist

Errors

Returns RecoveryError if journal write fails or serialization fails.

pub async fn recover_checkpoint(&self) -> RecoveryResult<StateCheckpoint>

Recovers the most recent checkpoint from the journal.

Errors

Returns RecoveryError::NoCheckpoint if no checkpoint exists. Returns RecoveryError::CorruptedCheckpoint if checkpoint data is invalid.

pub fn create_checkpoint( agent_id: AgentId, agent_state: AgentState, app_state: Value, in_flight_tasks: u32, ) -> StateCheckpoint

Creates a checkpoint from current agent state.

Trait Implementations

impl Debug for StateRecovery

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.