Struct GroupCommitReplica 

pub struct GroupCommitReplica { /* private fields */ }

Group-commit implementation for the Replica role.

Batches acknowledgements during log replay, sending an ACK to the feeder once a batch of committed transactions has been applied and durably written.

Implementations

impl GroupCommitReplica

pub fn new(interval_ms: u64) -> Self

Creates a new GroupCommitReplica.

Trait Implementations

impl Default for GroupCommitReplica

fn default() -> Self

Returns the “default value” for a type.

impl GroupCommit for GroupCommitReplica

fn is_enabled(&self) -> bool

Returns true if group commit is currently enabled.

fn buffer_commit(&self, _commit_vlsn: i64) -> bool

Called by each committing transaction to buffer itself and potentially trigger an fsync.

fn shutdown(&self)

Shuts down the group-commit background machinery.