Struct L0Manager 

pub struct L0Manager { /* private fields */ }

Implementations

impl L0Manager

pub fn new(start_version: u64, wal: Option<Arc<WriteAheadLog>>) -> Self

pub fn get_current(&self) -> Arc<RwLock<L0Buffer>>

Get the current L0 buffer.

pub fn get_all_readable(&self) -> Vec<Arc<RwLock<L0Buffer>>>

Get all L0 buffers that should be visible to reads. This includes the current L0 plus any L0s being flushed.

pub fn get_pending_flush(&self) -> Vec<Arc<RwLock<L0Buffer>>>

Get L0 buffers currently being flushed (for QueryContext).

pub fn rotate( &self, next_version: u64, new_wal: Option<Arc<WriteAheadLog>>, ) -> Arc<RwLock<L0Buffer>>

Rotate L0. Returns the OLD L0 buffer. The new L0 is initialized with next_version and new_wal.

pub fn begin_flush( &self, next_version: u64, new_wal: Option<Arc<WriteAheadLog>>, ) -> Arc<RwLock<L0Buffer>>

Begin flush: rotate L0 and add old L0 to pending flush list. The old L0 remains visible to reads until complete_flush is called. Returns the old L0 buffer to be flushed.

pub fn complete_flush(&self, l0: &Arc<RwLock<L0Buffer>>)

Complete flush: remove the flushed L0 from pending list. Call this only after L1 writes have succeeded.

pub fn min_pending_wal_lsn(&self) -> Option<u64>

Get the minimum WAL LSN across all pending flush L0s. WAL truncation should not go past this LSN to preserve data for pending flushes. Returns None if no pending flushes exist.