Trait HummockMetaClient

pub trait HummockMetaClient:
    Send
    + Sync
    + 'static {
    // Required methods
    fn unpin_version_before<'life0, 'async_trait>(
        &'life0 self,
        unpin_version_before: HummockVersionId,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_current_version<'life0, 'async_trait>(
        &'life0 self,
    ) -> Pin<Box<dyn Future<Output = Result<HummockVersion>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_new_sst_ids<'life0, 'async_trait>(
        &'life0 self,
        number: u32,
    ) -> Pin<Box<dyn Future<Output = Result<SstObjectIdRange>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn commit_epoch<'life0, 'async_trait>(
        &'life0 self,
        epoch: HummockEpoch,
        sync_result: SyncResult,
        is_log_store: bool,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn trigger_manual_compaction<'life0, 'async_trait>(
        &'life0 self,
        compaction_group_id: u64,
        table_id: u32,
        level: u32,
        sst_ids: Vec<u64>,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn trigger_full_gc<'life0, 'async_trait>(
        &'life0 self,
        sst_retention_time_sec: u64,
        prefix: Option<String>,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn subscribe_compaction_event<'life0, 'async_trait>(
        &'life0 self,
    ) -> Pin<Box<dyn Future<Output = Result<(UnboundedSender<SubscribeCompactionEventRequest>, BoxStream<'static, CompactionEventItem>)>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_version_by_epoch<'life0, 'async_trait>(
        &'life0 self,
        epoch: HummockEpoch,
        table_id: u32,
    ) -> Pin<Box<dyn Future<Output = Result<PbHummockVersion>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

Required Methods

fn unpin_version_before<'life0, 'async_trait>( &'life0 self, unpin_version_before: HummockVersionId, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_current_version<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<HummockVersion>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_new_sst_ids<'life0, 'async_trait>( &'life0 self, number: u32, ) -> Pin<Box<dyn Future<Output = Result<SstObjectIdRange>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn commit_epoch<'life0, 'async_trait>( &'life0 self, epoch: HummockEpoch, sync_result: SyncResult, is_log_store: bool, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn trigger_manual_compaction<'life0, 'async_trait>( &'life0 self, compaction_group_id: u64, table_id: u32, level: u32, sst_ids: Vec<u64>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn trigger_full_gc<'life0, 'async_trait>( &'life0 self, sst_retention_time_sec: u64, prefix: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn subscribe_compaction_event<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(UnboundedSender<SubscribeCompactionEventRequest>, BoxStream<'static, CompactionEventItem>)>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_version_by_epoch<'life0, 'async_trait>( &'life0 self, epoch: HummockEpoch, table_id: u32, ) -> Pin<Box<dyn Future<Output = Result<PbHummockVersion>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Implementors

impl HummockMetaClient for MetaClient