Struct CompactionCatalogAgent

pub struct CompactionCatalogAgent {
    filter_key_extractor_manager: FilterKeyExtractorImpl,
    table_id_to_vnode: HashMap<StateTableId, usize>,
}

CompactionCatalogAgent is a wrapper of filter_key_extractor_manager and table_id_to_vnode The CompactionCatalogAgent belongs to a compaction task call, which we will build from the table_ids contained in a compact task and use it during the compaction. The CompactionCatalogAgent can act as a agent for the CompactionCatalogManager, providing extract and vnode_count capabilities.

Fields

filter_key_extractor_manager: FilterKeyExtractorImpl

table_id_to_vnode: HashMap<StateTableId, usize>

Implementations

impl CompactionCatalogAgent

pub fn new( filter_key_extractor_manager: FilterKeyExtractorImpl, table_id_to_vnode: HashMap<StateTableId, usize>, ) -> Self

pub fn dummy() -> Self

pub fn for_test(table_ids: Vec<StateTableId>) -> Arc<Self>

impl CompactionCatalogAgent

pub fn extract<'a>(&self, full_key: &'a [u8]) -> &'a [u8]

pub fn vnode_count(&self, table_id: StateTableId) -> usize

pub fn table_id_to_vnode_ref(&self) -> &HashMap<StateTableId, usize>

pub fn table_ids(&self) -> impl Iterator<Item = StateTableId> + '_