Struct MultiReadBufferTier 

pub struct MultiReadBufferTier { /* private fields */ }

Implementations

impl MultiReadBufferTier

pub fn get( &self, key: &EncodedKey, version: CommitVersion, ) -> VersionedGetResult

pub fn insert( &self, key: EncodedKey, version: CommitVersion, value: Option<CowVec<u8>>, )

pub fn invalidate(&self, key: &EncodedKey)

pub fn remove_dropped(&self, key: &EncodedKey)

pub fn remove_dropped_through(&self, key: &EncodedKey, through: CommitVersion)

pub fn page_is_warm_candidate(&self, page: PageId) -> bool

pub fn set_warm_blocked(&self, page: PageId)

pub fn begin_warm(&self, page: PageId) -> bool

pub fn abort_warm(&self, page: PageId)

pub fn clear(&self)

pub fn set_capacity(&self, resident_pages: usize)

pub fn reconfigure(&self, resident_pages: usize, page_size_rows: u64)

impl MultiReadBufferTier

pub fn new(config: ReadBufferConfig) -> Self

impl MultiReadBufferTier

pub fn page_of_key(&self, key: &EncodedKey) -> PageId

pub fn page_key_range(&self, page: PageId) -> Option<EncodedKeyRange>

pub fn invalidate_page(&self, page: PageId)

pub fn populate_page( &self, page: PageId, entries: Vec<RawEntry>, complete: bool, )

pub fn finish_warm(&self, page: PageId, entries: Vec<RawEntry>) -> bool

pub fn serve_persistent_chunk( &self, table: EntryKind, cursor: &mut RangeCursor, start: &[u8], end: &[u8], scope: MultiVersionScope, batch_size: usize, descending: bool, ) -> ServedChunk

pub fn page_is_complete(&self, page: PageId) -> bool

Trait Implementations

impl Clone for MultiReadBufferTier

fn clone(&self) -> MultiReadBufferTier

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.