Struct CompactionCatalogManager

pub struct CompactionCatalogManager {
    table_id_to_catalog: RwLock<HashMap<StateTableId, Table>>,
    table_accessor: Box<dyn StateTableAccessor>,
}

CompactionCatalogManager is a manager to manage all Table which used in compaction

Fields

table_id_to_catalog: RwLock<HashMap<StateTableId, Table>>

table_accessor: Box<dyn StateTableAccessor>

Implementations

impl CompactionCatalogManager

pub fn new(table_accessor: Box<dyn StateTableAccessor>) -> Self

impl CompactionCatalogManager

pub fn update(&self, table_id: u32, catalog: Table)

update is used to update Table in table_id_to_catalog from notification

pub fn sync(&self, catalog_map: HashMap<u32, Table>)

sync is used to sync all Table in table_id_to_catalog from notification whole snapshot

pub fn remove(&self, table_id: u32)

remove is used to remove Table in table_id_to_catalog by table_id

pub async fn acquire( &self, table_ids: Vec<StateTableId>, ) -> HummockResult<CompactionCatalogAgentRef>

acquire is used to acquire CompactionCatalogAgent by table_ids if the table not found in table_id_to_catalog, it will fetch from meta

pub fn build_compaction_catalog_agent( table_catalogs: HashMap<StateTableId, Table>, ) -> CompactionCatalogAgentRef

build_compaction_catalog_agent is used to build CompactionCatalogAgent by table_catalogs

Trait Implementations

impl Default for CompactionCatalogManager

fn default() -> Self

Returns the “default value” for a type.