Struct TableSnapshotCommitter 

pub struct TableSnapshotCommitter { /* private fields */ }

Collects shard snapshots and materializes each complete table checkpoint.

Implementations

impl TableSnapshotCommitter

pub fn new( coordinator: Arc<DbCoordinator>, total_buckets: u32, max_pending_commits: usize, ) -> Result<Self>

pub fn submit( &self, commit_id: u64, snapshot: ShardSnapshotMetadata, ) -> Result<Option<GlobalSnapshotManifest>>

Submit one full shard report for a process-local commit ID.

Returns Some only when this shard completes and materializes the commit. Pending, completed, and superseded submissions return None. Captured table metadata is validated in memory; this does not read shard manifests.

pub fn commit_batch( &self, commit_id: u64, shard_snapshots: Vec<ShardSnapshotMetadata>, ) -> Result<Option<GlobalSnapshotManifest>>

Commit an already collected, complete checkpoint batch.

Full reports may be unordered. Equivalent duplicate shard inputs are ignored, while gaps, overlaps, conflicting duplicates, and incompatible captured table metadata are rejected without reading manifests. Returns None when this commit or a higher commit has already completed.