Struct CheckpointManager 

pub struct CheckpointManager {
    pub snapshots: Vec<Snapshot>,
    pub full_interval: u64,
    pub last_full_idx: Option<usize>,
    pub step: u64,
}

Manages incremental checkpoint/restart for a streaming simulation.

Full snapshots are stored periodically; incremental deltas reduce I/O cost.

Fields

snapshots: Vec<Snapshot>

Stored snapshots (base + incremental).

full_interval: u64

Interval (in steps) between full snapshots.

last_full_idx: Option<usize>

Last full snapshot index in snapshots.

step: u64

Current step counter.

Implementations

impl CheckpointManager

pub fn full_interval(full_interval: u64) -> Self

Create a new checkpoint manager.

pub fn record(&mut self, sim_time: f64, state: &[u8], prev_state: &[u8])

Record a new snapshot. Decides automatically whether to store a full or incremental (delta) snapshot.

state is the raw state bytes; prev_state is the previous state for delta encoding (ignored for full snapshots).

pub fn restore_latest(&self) -> Option<Vec<u8>>

Restore the state at the latest checkpoint by replaying deltas.

Returns None if no snapshots exist.

pub fn snapshot_count(&self) -> usize

Number of stored snapshots.

Trait Implementations

impl Debug for CheckpointManager

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

Formats the value using the given formatter.