Struct CheckpointStore 

pub struct CheckpointStore { /* private fields */ }

In-memory store of checkpoints, keyed by CheckpointId.

Implementations

impl CheckpointStore

pub fn new() -> Self

Create a new empty checkpoint store.

pub fn save(&mut self, checkpoint: Checkpoint)

Save a checkpoint.

pub fn load(&self, id: &CheckpointId) -> Option<&Checkpoint>

Load a checkpoint by ID, returning a reference if found.

pub fn latest_for_job(&self, job_id: &str) -> Option<&Checkpoint>

Return the most recently created checkpoint for a job (by created_at_ms).

pub fn purge_old(&mut self, keep_last_n: usize)

Purge old checkpoints for each job, keeping only the keep_last_n most recent.

pub fn len(&self) -> usize

Return the total number of stored checkpoints.

pub fn is_empty(&self) -> bool

Return true if the store is empty.

Trait Implementations

impl Debug for CheckpointStore

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

Formats the value using the given formatter.

impl Default for CheckpointStore

fn default() -> CheckpointStore

Returns the “default value” for a type.