Struct CheckpointStore 

pub struct CheckpointStore { /* private fields */ }

Persistent checkpoint store with bounded history per (stream, partition) key.

The store always keeps the latest checkpoint as the authoritative offset and additionally retains up to max_history older entries for auditing or replay purposes.

Implementations

impl CheckpointStore

pub fn new(max_history: usize) -> Self

Create a new store.

Parameters

• max_history: maximum number of historical checkpoints retained.

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

Commit a checkpoint.

Updates the latest offset for the (stream, partition) key and appends the entry to the rolling history buffer.

pub fn get(&self, stream_id: &str, partition: u32) -> Option<&Checkpoint>

Return a reference to the latest checkpoint for a (stream, partition) pair.

pub fn latest_offset(&self, stream_id: &str, partition: u32) -> Option<i64>

Return the latest committed offset, if any.

pub fn reset(&mut self, stream_id: &str, partition: u32)

Remove the checkpoint for the given (stream, partition) key.

Historical entries for this key are not removed so that auditing still works.

pub fn reset_to(&mut self, stream_id: &str, partition: u32, offset: i64) -> bool

Roll back the checkpoint to a specific offset.

Returns true if a checkpoint existed and was updated, false otherwise. Historical entries are preserved unchanged.

pub fn all_streams(&self) -> Vec<&str>

Return all stream IDs that have at least one active checkpoint.

pub fn partitions(&self, stream_id: &str) -> Vec<u32>

Return all active partitions for a given stream.

pub fn history(&self, stream_id: &str, partition: u32) -> Vec<&Checkpoint>

Return historical checkpoints for a (stream, partition) pair, oldest first.

pub fn total_committed(&self) -> usize

Return the total number of commits across all partitions and streams.

Trait Implementations

impl Debug for CheckpointStore

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

Formats the value using the given formatter.