Module checkpoint_store 

Checkpoint persistence trait and filesystem store Checkpoint persistence via the CheckpointStore trait.

Provides a filesystem-backed implementation (FileSystemCheckpointStore) that writes manifests as atomic JSON files with a latest.txt pointer for crash-safe recovery.

Disk Layout

{base_dir}/checkpoints/
  checkpoint_000001/
    manifest.json     # CheckpointManifest as pretty-printed JSON
    state.bin         # Optional: large operator state sidecar
  checkpoint_000002/
    manifest.json
  latest.txt          # "checkpoint_000002" — pointer to latest good checkpoint

Structs

FileSystemCheckpointStore

Filesystem-backed checkpoint store.

ObjectStoreCheckpointStore

Object-store-backed checkpoint store with hierarchical layout.

RecoveryReport

Report from a crash-safe recovery walk.

ValidationResult

Result of validating a single checkpoint.

Enums

CheckpointStoreError

Errors from checkpoint store operations.

Traits

CheckpointStore

Trait for checkpoint persistence backends.