Struct PerCoreWalBuffer 

pub struct PerCoreWalBuffer { /* private fields */ }

Implementations

impl PerCoreWalBuffer

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

pub fn append(&mut self, record: WalRecord) -> AppendOutcome

pub fn append_batch(&mut self, records: Vec<WalRecord>) -> AppendOutcome

pub fn seal_active(&mut self, epoch: u64) -> Result<(), &'static str>

pub fn begin_flush(&mut self) -> Result<usize, &'static str>

pub fn complete_flush(&mut self) -> Result<(), &'static str>

pub fn fallback_decision(&self) -> FallbackDecision

pub fn force_serialized_drain(&mut self) -> Vec<WalRecord>

pub fn active_state(&self) -> BufferState

pub fn flush_state(&self) -> BufferState

pub fn active_len(&self) -> usize

pub fn flush_len(&self) -> usize

pub fn overflow_len(&self) -> usize

Trait Implementations

impl Debug for PerCoreWalBuffer

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

Formats the value using the given formatter.