Struct PerCoreWalBufferPool 

pub struct PerCoreWalBufferPool { /* private fields */ }

Implementations

impl PerCoreWalBufferPool

pub fn new(core_count: usize, config: BufferConfig) -> Self

pub fn append_to_core( &self, core_id: usize, record: WalRecord, ) -> Result<AppendOutcome, String>

pub fn append_batch_to_core( &self, core_id: usize, records: Vec<WalRecord>, ) -> Result<AppendOutcome, String>

pub fn contention_events_total(&self) -> u64

pub fn core_count(&self) -> usize

pub fn seal_active_for_epoch(&self, epoch: u64) -> Result<usize, String>

pub fn flush_epoch_batches( &self, epoch: u64, ) -> Result<(Vec<WalRecord>, Vec<usize>), String>

Trait Implementations

impl Debug for PerCoreWalBufferPool

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

Formats the value using the given formatter.