Struct CheckpointManager 

pub struct CheckpointManager {
    pub directory: PathBuf,
    pub base_name: String,
    pub format: CheckpointFormat,
    pub keep_n: usize,
    pub interval: usize,
    pub max_bytes: u64,
    /* private fields */
}

Checkpoint manager for automatic saving

Fields

directory: PathBuf

Directory for checkpoint files

base_name: String

Base filename for checkpoints

format: CheckpointFormat

Serialization format

keep_n: usize

How many checkpoints to keep

interval: usize

Save interval (generations)

max_bytes: u64

Maximum checkpoint size accepted when loading (EV-48)

Implementations

impl CheckpointManager

pub fn new(directory: impl Into<PathBuf>, base_name: impl Into<String>) -> Self

Create a new checkpoint manager.

The manager is restart-safe (EV-46): it scans directory for existing checkpoints named after base_name and continues the index after the highest one found, so a fresh manager constructed after a crash never overwrites or shadows pre-crash checkpoints.

pub fn with_format(self, format: CheckpointFormat) -> Self

Set the serialization format

pub fn with_max_bytes(self, max_bytes: u64) -> Self

Set the maximum checkpoint size accepted by load_latest (EV-48).

pub fn current_index(&self) -> usize

The index the next save will write to.

Exposed primarily so restart-resume behavior (EV-46) is observable/testable.

pub fn keep(self, n: usize) -> Self

Set how many checkpoints to keep

pub fn every(self, generations: usize) -> Self

Set the save interval

pub fn should_save(&self, generation: usize) -> bool

Check if a checkpoint should be saved at this generation

pub fn current_path(&self) -> PathBuf

Get the path for the current checkpoint

pub fn save<G>( &mut self, checkpoint: &Checkpoint<G>, ) -> Result<(), CheckpointError>

where G: Clone + Serialize + EvolutionaryGenome,

Save a checkpoint and rotate old ones

pub fn load_latest<G>(&self) -> Result<Option<Checkpoint<G>>, CheckpointError>

where G: Clone + Serialize + DeserializeOwned + EvolutionaryGenome,

Find and load the latest checkpoint