Struct CheckpointManager 

pub struct CheckpointManager { /* private fields */ }

Manages serialised state blobs on the local filesystem.

Implementations

impl CheckpointManager

pub fn new(config: CheckpointConfig) -> Self

Create a new manager with the given configuration.

pub fn with_defaults() -> Self

Create a new manager with the default configuration.

pub fn save(&self, state_id: &str, data: &[u8]) -> Result<String>

Save data as a checkpoint for state_id.

The file is named {state_id}_{timestamp_ms}.ckpt and written to the configured storage_path. Returns the absolute path of the file written.

After saving, old checkpoints beyond max_checkpoints are removed.

pub fn load_latest(&self, state_id: &str) -> Result<Vec<u8>>

Load the most recently saved checkpoint for state_id.

Errors

Returns an error if no checkpoint is found or if reading fails.

pub fn cleanup_old(&self, state_id: &str)

Delete all but the newest max_checkpoints checkpoint files for state_id.

pub fn list_checkpoints(&self, state_id: &str) -> Vec<String>

Return a sorted list of checkpoint file paths for state_id (oldest first).

Trait Implementations

impl Clone for CheckpointManager

fn clone(&self) -> CheckpointManager

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CheckpointManager

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

Formats the value using the given formatter.