Struct BufferManager 

pub struct BufferManager { /* private fields */ }

Buffer manager with split read/write pools.

Pages are loaded from a PageStore into frames. The read pool holds pages for analytical queries (70% default), the write pool holds pages for ingestion/WAL staging (30% default).

Eviction uses the clock (second-chance) algorithm per pool.

Implementations

impl BufferManager

pub fn new( total_frames: u32, read_ratio: f64, store: Box<dyn PageStore>, ) -> Self

Create a new buffer manager with the given total frame count and read ratio.

pub fn pin_read(&self, page_id: PageId) -> KyuResult<PinnedPage<'_>>

Pin a page for reading. Loads from disk if not already in memory.

pub fn pin_write(&self, page_id: PageId) -> KyuResult<PinnedPage<'_>>

Pin a page for writing. Loads from disk if not already in memory.

pub fn allocate_new_page( &self, file_id: FileId, ) -> KyuResult<(PageId, PinnedPage<'_>)>

Allocate a new page in the given file and pin it for writing.

pub fn flush_all(&self) -> KyuResult<()>

Flush all dirty pages to disk.

pub fn total_frames(&self) -> u32

Get the total number of frames across both pools.

pub fn stats(&self) -> BufferManagerStats

Get statistics about the buffer manager.