Struct FileCheckpointStore 

pub struct FileCheckpointStore { /* private fields */ }

Durable, file-system-backed checkpoint store.

Each checkpoint is written to root/{stream}/checkpoint-{sequence}.ckpt using CheckpointState::serialize and an atomic temp-file + rename, so a checkpoint that has been acknowledged is guaranteed to survive a process crash or restart. Recovery scans the stream directory for the highest sequence number. Pure Rust, no external services.

Implementations

impl FileCheckpointStore

pub fn new( root: impl Into<PathBuf>, max_per_stream: usize, ) -> Result<Self, StreamingError>

Create a store rooted at root, retaining at most max_per_stream checkpoint files per stream. The root directory is created if missing.

Trait Implementations

impl CheckpointStore for FileCheckpointStore

fn save(&mut self, state: CheckpointState) -> Result<(), StreamingError>

Persist a checkpoint. Later checkpoints for the same stream supersede earlier ones.

fn latest( &self, stream_id: &str, ) -> Result<Option<CheckpointState>, StreamingError>

Return the most recent checkpoint for stream_id, or None if the stream has no checkpoints.