Struct CheckpointManager 

pub struct CheckpointManager {
    pub base_dir: String,
    pub max_checkpoints: usize,
    /* private fields */
}

Manages a rolling set of checkpoint files in a directory.

Fields

base_dir: String

Base directory where checkpoint files are stored.

max_checkpoints: usize

Maximum number of checkpoints to retain.

Implementations

impl CheckpointManager

pub fn new(base_dir: &str, max_checkpoints: usize) -> Self

Create a new manager rooted at base_dir, keeping at most max_checkpoints files.

pub fn save_checkpoint(&mut self, data: &RestartData, step: u64) -> String

Serialize data and write it as checkpoint_step.bin under base_dir.

Returns the full path of the newly written file.

pub fn load_latest(&self) -> Option<RestartData>

Load and return the most recent checkpoint, or None if none exist.

pub fn list_checkpoints(&self) -> Vec<(u64, String)>

Return all known checkpoints as (step, path) pairs, oldest first.

pub fn prune_old_checkpoints(&mut self)

Remove the oldest checkpoints so that at most max_checkpoints remain.

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.