Struct raft_engine::internals::MemTableAccessor

pub struct MemTableAccessor<A: AllocatorTrait> { /* private fields */ }

A collection of MemTables.

Internally, they are stored in multiple HashMaps, which are indexed by hashed region IDs.

Implementations

impl MemTableAccessor<DummyAllocator>

pub fn new(global_stats: Arc<GlobalStats>) -> MemTableAccessor<DummyAllocator>

impl MemTableAccessor<DummyAllocator>

pub fn memory_usage(&self) -> usize

impl<A: AllocatorTrait> MemTableAccessor<A>

pub fn new_with_allocator(
    global_stats: Arc<GlobalStats>,
    allocator: A
) -> MemTableAccessor<A>

pub fn get_or_insert(&self, raft_group_id: u64) -> Arc<RwLock<MemTable<A>>>

pub fn get(&self, raft_group_id: u64) -> Option<Arc<RwLock<MemTable<A>>>>

pub fn insert(&self, raft_group_id: u64, memtable: Arc<RwLock<MemTable<A>>>)

pub fn remove(&self, raft_group_id: u64, record_tombstone: bool)

pub fn fold<B, F: Fn(B, &MemTable<A>) -> B>(&self, init: B, fold: F) -> B

pub fn collect<F: FnMut(&MemTable<A>) -> bool>(
    &self,
    condition: F
) -> Vec<Arc<RwLock<MemTable<A>>>>

pub fn take_cleaned_region_logs(&self) -> LogBatch

Returns a LogBatch containing Command::Cleans of all deleted MemTables. The records for these tables will be cleaned up afterwards.

pub fn cleaned_region_ids(&self) -> HashSet<u64>

Returns a HashSet containing region IDs of all deleted MemTables.

This method is only used for recovery.

pub fn merge_newer_neighbor(&self, rhs: Self)

Merges with a newer neighbor MemTableAccessor.

This method is only used for recovery.

pub fn merge_append_table(&self, rhs: Self)

Merges with a MemTableAccessor that contains only append data. Assumes self contains all rewritten data.

This method is only used for recovery.

pub fn apply_append_writes(&self, log_items: Drain<'_, LogItem>)

Applies changes from log items that have been written to append queue.

pub fn apply_rewrite_writes(
    &self,
    log_items: Drain<'_, LogItem>,
    watermark: Option<FileSeq>,
    new_file: FileSeq
)

Applies changes from log items that have been written to rewrite queue.

pub fn apply_replayed_rewrite_writes(&self, log_items: Drain<'_, LogItem>)

Applies changes from log items that are replayed from a rewrite queue. Assumes it haven’t applied any append data.

This method is only used for recovery.

Trait Implementations

impl<A: Clone + AllocatorTrait> Clone for MemTableAccessor<A>

fn clone(&self) -> MemTableAccessor<A>

Returns a copy of the value.

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

Performs copy-assignment from source.