Struct CheckpointManager 

pub struct CheckpointManager<S: CheckpointStorage> { /* private fields */ }

Checkpoint manager for creating and restoring checkpoints

Implementations

impl<S: CheckpointStorage> CheckpointManager<S>

pub fn new(db: Arc<AzothDb>, storage: S, config: CheckpointConfig) -> Self

Create a new checkpoint manager

pub async fn create_checkpoint(&self) -> Result<CheckpointMetadata>

Create a checkpoint and upload to storage

Returns the checkpoint metadata including the storage identifier

pub async fn restore_checkpoint( &self, checkpoint_id: &str, target_path: &Path, ) -> Result<()>

Restore from a checkpoint

Downloads the checkpoint from storage and restores the database

pub async fn list_checkpoints(&self) -> Result<Vec<CheckpointMetadata>>

List all available checkpoints

pub async fn delete_checkpoint(&self, checkpoint_id: &str) -> Result<()>

Delete a checkpoint

pub async fn shutdown_checkpoint(&self) -> Result<CheckpointMetadata>

Create a final checkpoint on shutdown

This creates a checkpoint with a “shutdown” marker in the metadata. Call this before closing the database to ensure a recovery point exists.