Struct GroupCommitter 

pub struct GroupCommitter { /* private fields */ }

Thread-safe group commit coordinator.

Multiple threads call submit() which blocks until the record is durable. Internally, one thread becomes the commit leader and batches all pending writes into a single WAL flush.

Safety invariants

• A non-leader thread only returns durable: true if it confirms its write was drained from the pending queue and the leader’s fsync succeeded (checked via last_commit_failed).
• If the leader’s fsync fails, all non-leader threads whose writes were in the failed batch receive an error.
• durable_lsn is updated only after a successful fsync.

Implementations

impl GroupCommitter

pub fn new() -> Self

Create a new group committer.

pub fn submit( &self, writer: &Mutex<WalWriter>, write: PendingWrite, ) -> Result<CommitResult>

Submit a write and block until it’s durable.

Returns the assigned LSN once the batch containing this write has been fsynced to disk. If fsync fails, the error is propagated to all threads whose writes were in the failed batch.

pub fn durable_lsn(&self) -> u64

Current durable LSN (all records <= this are on disk).

Trait Implementations

impl Default for GroupCommitter

fn default() -> Self

Returns the “default value” for a type.