Struct FileSystemCheckpointStore 

pub struct FileSystemCheckpointStore { /* private fields */ }

Filesystem-backed checkpoint store.

Writes checkpoint manifests as JSON files with atomic rename semantics. A latest.txt pointer (not a symlink) tracks the most recent checkpoint for Windows compatibility.

Implementations

impl FileSystemCheckpointStore

pub fn new(base_dir: impl Into<PathBuf>, max_retained: usize) -> Self

Creates a new filesystem checkpoint store.

The base_dir is the parent directory; checkpoints are stored under {base_dir}/checkpoints/. The directory is created lazily on first save.

Trait Implementations

impl CheckpointStore for FileSystemCheckpointStore

fn save( &self, manifest: &CheckpointManifest, ) -> Result<(), CheckpointStoreError>

Persists a checkpoint manifest atomically.

fn load_latest( &self, ) -> Result<Option<CheckpointManifest>, CheckpointStoreError>

Loads the most recent checkpoint manifest.

fn load_by_id( &self, id: u64, ) -> Result<Option<CheckpointManifest>, CheckpointStoreError>

Loads a specific checkpoint manifest by ID.

fn list_ids(&self) -> Result<Vec<u64>, CheckpointStoreError>

Lists all checkpoint IDs without loading manifests.

fn list(&self) -> Result<Vec<(u64, u64)>, CheckpointStoreError>

Lists all available checkpoints as (checkpoint_id, epoch) pairs.

fn prune(&self, keep_count: usize) -> Result<usize, CheckpointStoreError>

Prunes old checkpoints, keeping at most keep_count recent ones.

fn save_state_data( &self, id: u64, data: &[u8], ) -> Result<(), CheckpointStoreError>

Writes large operator state data to a sidecar file for a given checkpoint.

fn save_with_state( &self, manifest: &CheckpointManifest, state_data: Option<&[u8]>, ) -> Result<(), CheckpointStoreError>

Atomically saves a checkpoint manifest with optional sidecar state data.

fn cleanup_orphans(&self) -> Result<usize, CheckpointStoreError>

Delete orphaned state files that have no matching manifest.

fn load_state_data( &self, id: u64, ) -> Result<Option<Vec<u8>>, CheckpointStoreError>

Loads large operator state data from a sidecar file.

fn update_manifest( &self, manifest: &CheckpointManifest, ) -> Result<(), CheckpointStoreError>

Overwrites an existing checkpoint manifest.

fn validate_checkpoint( &self, id: u64, ) -> Result<ValidationResult, CheckpointStoreError>

Validate a specific checkpoint’s integrity.

fn recover_latest_validated( &self, ) -> Result<RecoveryReport, CheckpointStoreError>

Walk backward from latest to find the first valid checkpoint.