Struct CheckpointCoalescer 

pub struct CheckpointCoalescer { /* private fields */ }

Tracks high-water seq per subscription partition; flushes periodically.

Implementations

impl CheckpointCoalescer

pub fn new(port: Arc<dyn StoragePort>) -> Self

Start a background flush loop bound to port.

pub fn attach_reclaimer(&self, reclaimer: Arc<dyn PartitionReclaim>)

Wire opportunistic reclaim after checkpoint commits.

pub async fn record( &self, subscription_name: &str, topic_name: &str, topic_key: Option<&str>, seq: i64, ) -> Result<()>

Record delivered seq; may trigger immediate flush when batch threshold hit.

Errors

Returns an error if the operation fails.

pub async fn flush(&self) -> Result<()>

Flush all pending checkpoints now.

Errors

Returns an error if the operation fails.

pub async fn pending_min_seq( &self, topic: &str, topic_key: Option<&str>, ) -> Option<i64>

Minimum unflushed seq for a storage partition.

pub async fn pending_partitions(&self) -> Vec<TopicPartition>

Storage partitions with unflushed checkpoint state.