Struct GroupCommitBatch 

pub struct GroupCommitBatch { /* private fields */ }

A batch of pending commits that will share a single fsync.

Group commit amortizes the cost of fsync across multiple writers. The coordinator accumulates submissions until either the batch is full or a timeout expires, then issues a single fsync covering all of them.

Implementations

impl GroupCommitBatch

pub fn new(max_batch_size: usize) -> Self

Create a new batch with the given maximum size.

pub fn len(&self) -> usize

Number of pending commits in the batch.

pub fn is_empty(&self) -> bool

Whether the batch is empty.

pub fn is_full(&self) -> bool

Whether the batch is full and should be flushed.

Trait Implementations

impl Debug for GroupCommitBatch

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

Formats the value using the given formatter.