Trait CompactorManagerTrait

pub trait CompactorManagerTrait {
    // Required methods
    fn add_compactor(
        &self,
        context_id: HummockContextId,
    ) -> UnboundedReceiver<MetaResult<SubscribeCompactionEventResponse>>;
    fn remove_compactor(&self, context_id: HummockContextId);
    fn get_compactor(
        &self,
        context_id: HummockContextId,
    ) -> Option<Arc<Compactor>>;
    fn next_compactor(&self) -> Option<Arc<Compactor>>;
    fn compactor_num(&self) -> usize;
}

Required Methods

fn add_compactor( &self, context_id: HummockContextId, ) -> UnboundedReceiver<MetaResult<SubscribeCompactionEventResponse>>

fn remove_compactor(&self, context_id: HummockContextId)

fn get_compactor(&self, context_id: HummockContextId) -> Option<Arc<Compactor>>

fn next_compactor(&self) -> Option<Arc<Compactor>>

fn compactor_num(&self) -> usize

Implementors