Trait HummockManagerService

pub trait HummockManagerService:
    Send
    + Sync
    + 'static {
    type SubscribeCompactionEventStream: Stream<Item = Result<SubscribeCompactionEventResponse, Status>> + Send + 'static;

    // Required methods
    fn unpin_version_before<'life0, 'async_trait>(
        &'life0 self,
        request: Request<UnpinVersionBeforeRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<UnpinVersionBeforeResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_current_version<'life0, 'async_trait>(
        &'life0 self,
        request: Request<GetCurrentVersionRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<GetCurrentVersionResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn list_version_deltas<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ListVersionDeltasRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<ListVersionDeltasResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn replay_version_delta<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ReplayVersionDeltaRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<ReplayVersionDeltaResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_assigned_compact_task_num<'life0, 'async_trait>(
        &'life0 self,
        request: Request<GetAssignedCompactTaskNumRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<GetAssignedCompactTaskNumResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn trigger_compaction_deterministic<'life0, 'async_trait>(
        &'life0 self,
        request: Request<TriggerCompactionDeterministicRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<TriggerCompactionDeterministicResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn disable_commit_epoch<'life0, 'async_trait>(
        &'life0 self,
        request: Request<DisableCommitEpochRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<DisableCommitEpochResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_new_sst_ids<'life0, 'async_trait>(
        &'life0 self,
        request: Request<GetNewSstIdsRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<GetNewSstIdsResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn trigger_manual_compaction<'life0, 'async_trait>(
        &'life0 self,
        request: Request<TriggerManualCompactionRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<TriggerManualCompactionResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn trigger_full_gc<'life0, 'async_trait>(
        &'life0 self,
        request: Request<TriggerFullGcRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<TriggerFullGcResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn rise_ctl_get_pinned_versions_summary<'life0, 'async_trait>(
        &'life0 self,
        request: Request<RiseCtlGetPinnedVersionsSummaryRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<RiseCtlGetPinnedVersionsSummaryResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn rise_ctl_list_compaction_group<'life0, 'async_trait>(
        &'life0 self,
        request: Request<RiseCtlListCompactionGroupRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<RiseCtlListCompactionGroupResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn rise_ctl_update_compaction_config<'life0, 'async_trait>(
        &'life0 self,
        request: Request<RiseCtlUpdateCompactionConfigRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<RiseCtlUpdateCompactionConfigResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn rise_ctl_pause_version_checkpoint<'life0, 'async_trait>(
        &'life0 self,
        request: Request<RiseCtlPauseVersionCheckpointRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<RiseCtlPauseVersionCheckpointResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn rise_ctl_resume_version_checkpoint<'life0, 'async_trait>(
        &'life0 self,
        request: Request<RiseCtlResumeVersionCheckpointRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<RiseCtlResumeVersionCheckpointResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn rise_ctl_get_checkpoint_version<'life0, 'async_trait>(
        &'life0 self,
        request: Request<RiseCtlGetCheckpointVersionRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<RiseCtlGetCheckpointVersionResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn rise_ctl_rebuild_table_stats<'life0, 'async_trait>(
        &'life0 self,
        request: Request<RiseCtlRebuildTableStatsRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<RiseCtlRebuildTableStatsResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn init_metadata_for_replay<'life0, 'async_trait>(
        &'life0 self,
        request: Request<InitMetadataForReplayRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<InitMetadataForReplayResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn pin_version<'life0, 'async_trait>(
        &'life0 self,
        request: Request<PinVersionRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<PinVersionResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn split_compaction_group<'life0, 'async_trait>(
        &'life0 self,
        request: Request<SplitCompactionGroupRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<SplitCompactionGroupResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn rise_ctl_list_compaction_status<'life0, 'async_trait>(
        &'life0 self,
        request: Request<RiseCtlListCompactionStatusRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<RiseCtlListCompactionStatusResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn subscribe_compaction_event<'life0, 'async_trait>(
        &'life0 self,
        request: Request<Streaming<SubscribeCompactionEventRequest>>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<Self::SubscribeCompactionEventStream>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn report_compaction_task<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ReportCompactionTaskRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<ReportCompactionTaskResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn list_branched_object<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ListBranchedObjectRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<ListBranchedObjectResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn list_active_write_limit<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ListActiveWriteLimitRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<ListActiveWriteLimitResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn list_hummock_meta_config<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ListHummockMetaConfigRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<ListHummockMetaConfigResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_compaction_score<'life0, 'async_trait>(
        &'life0 self,
        request: Request<GetCompactionScoreRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<GetCompactionScoreResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn list_compact_task_assignment<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ListCompactTaskAssignmentRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<ListCompactTaskAssignmentResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn list_compact_task_progress<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ListCompactTaskProgressRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<ListCompactTaskProgressResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn cancel_compact_task<'life0, 'async_trait>(
        &'life0 self,
        request: Request<CancelCompactTaskRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<CancelCompactTaskResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_version_by_epoch<'life0, 'async_trait>(
        &'life0 self,
        request: Request<GetVersionByEpochRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<GetVersionByEpochResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn merge_compaction_group<'life0, 'async_trait>(
        &'life0 self,
        request: Request<MergeCompactionGroupRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<MergeCompactionGroupResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

Generated trait containing gRPC methods that should be implemented for use with HummockManagerServiceServer.

Required Associated Types

type SubscribeCompactionEventStream: Stream<Item = Result<SubscribeCompactionEventResponse, Status>> + Send + 'static

Server streaming response type for the SubscribeCompactionEvent method.

Required Methods

fn unpin_version_before<'life0, 'async_trait>( &'life0 self, request: Request<UnpinVersionBeforeRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UnpinVersionBeforeResponse>, Status>> + Send + 'async_trait>>

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

fn get_current_version<'life0, 'async_trait>( &'life0 self, request: Request<GetCurrentVersionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetCurrentVersionResponse>, Status>> + Send + 'async_trait>>

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

fn list_version_deltas<'life0, 'async_trait>( &'life0 self, request: Request<ListVersionDeltasRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListVersionDeltasResponse>, Status>> + Send + 'async_trait>>

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

fn replay_version_delta<'life0, 'async_trait>( &'life0 self, request: Request<ReplayVersionDeltaRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ReplayVersionDeltaResponse>, Status>> + Send + 'async_trait>>

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

fn get_assigned_compact_task_num<'life0, 'async_trait>( &'life0 self, request: Request<GetAssignedCompactTaskNumRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetAssignedCompactTaskNumResponse>, Status>> + Send + 'async_trait>>

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

fn trigger_compaction_deterministic<'life0, 'async_trait>( &'life0 self, request: Request<TriggerCompactionDeterministicRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<TriggerCompactionDeterministicResponse>, Status>> + Send + 'async_trait>>

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

fn disable_commit_epoch<'life0, 'async_trait>( &'life0 self, request: Request<DisableCommitEpochRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DisableCommitEpochResponse>, Status>> + Send + 'async_trait>>

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

fn get_new_sst_ids<'life0, 'async_trait>( &'life0 self, request: Request<GetNewSstIdsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetNewSstIdsResponse>, Status>> + Send + 'async_trait>>

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

fn trigger_manual_compaction<'life0, 'async_trait>( &'life0 self, request: Request<TriggerManualCompactionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<TriggerManualCompactionResponse>, Status>> + Send + 'async_trait>>

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

fn trigger_full_gc<'life0, 'async_trait>( &'life0 self, request: Request<TriggerFullGcRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<TriggerFullGcResponse>, Status>> + Send + 'async_trait>>

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

fn rise_ctl_get_pinned_versions_summary<'life0, 'async_trait>( &'life0 self, request: Request<RiseCtlGetPinnedVersionsSummaryRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RiseCtlGetPinnedVersionsSummaryResponse>, Status>> + Send + 'async_trait>>

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

fn rise_ctl_list_compaction_group<'life0, 'async_trait>( &'life0 self, request: Request<RiseCtlListCompactionGroupRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RiseCtlListCompactionGroupResponse>, Status>> + Send + 'async_trait>>

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

fn rise_ctl_update_compaction_config<'life0, 'async_trait>( &'life0 self, request: Request<RiseCtlUpdateCompactionConfigRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RiseCtlUpdateCompactionConfigResponse>, Status>> + Send + 'async_trait>>

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

fn rise_ctl_pause_version_checkpoint<'life0, 'async_trait>( &'life0 self, request: Request<RiseCtlPauseVersionCheckpointRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RiseCtlPauseVersionCheckpointResponse>, Status>> + Send + 'async_trait>>

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

fn rise_ctl_resume_version_checkpoint<'life0, 'async_trait>( &'life0 self, request: Request<RiseCtlResumeVersionCheckpointRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RiseCtlResumeVersionCheckpointResponse>, Status>> + Send + 'async_trait>>

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

fn rise_ctl_get_checkpoint_version<'life0, 'async_trait>( &'life0 self, request: Request<RiseCtlGetCheckpointVersionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RiseCtlGetCheckpointVersionResponse>, Status>> + Send + 'async_trait>>

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

fn rise_ctl_rebuild_table_stats<'life0, 'async_trait>( &'life0 self, request: Request<RiseCtlRebuildTableStatsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RiseCtlRebuildTableStatsResponse>, Status>> + Send + 'async_trait>>

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

fn init_metadata_for_replay<'life0, 'async_trait>( &'life0 self, request: Request<InitMetadataForReplayRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<InitMetadataForReplayResponse>, Status>> + Send + 'async_trait>>

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

fn pin_version<'life0, 'async_trait>( &'life0 self, request: Request<PinVersionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<PinVersionResponse>, Status>> + Send + 'async_trait>>

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

fn split_compaction_group<'life0, 'async_trait>( &'life0 self, request: Request<SplitCompactionGroupRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SplitCompactionGroupResponse>, Status>> + Send + 'async_trait>>

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

fn rise_ctl_list_compaction_status<'life0, 'async_trait>( &'life0 self, request: Request<RiseCtlListCompactionStatusRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RiseCtlListCompactionStatusResponse>, Status>> + Send + 'async_trait>>

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

fn subscribe_compaction_event<'life0, 'async_trait>( &'life0 self, request: Request<Streaming<SubscribeCompactionEventRequest>>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::SubscribeCompactionEventStream>, Status>> + Send + 'async_trait>>

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

fn report_compaction_task<'life0, 'async_trait>( &'life0 self, request: Request<ReportCompactionTaskRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ReportCompactionTaskResponse>, Status>> + Send + 'async_trait>>

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

fn list_branched_object<'life0, 'async_trait>( &'life0 self, request: Request<ListBranchedObjectRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListBranchedObjectResponse>, Status>> + Send + 'async_trait>>

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

fn list_active_write_limit<'life0, 'async_trait>( &'life0 self, request: Request<ListActiveWriteLimitRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListActiveWriteLimitResponse>, Status>> + Send + 'async_trait>>

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

fn list_hummock_meta_config<'life0, 'async_trait>( &'life0 self, request: Request<ListHummockMetaConfigRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListHummockMetaConfigResponse>, Status>> + Send + 'async_trait>>

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

fn get_compaction_score<'life0, 'async_trait>( &'life0 self, request: Request<GetCompactionScoreRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetCompactionScoreResponse>, Status>> + Send + 'async_trait>>

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

fn list_compact_task_assignment<'life0, 'async_trait>( &'life0 self, request: Request<ListCompactTaskAssignmentRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListCompactTaskAssignmentResponse>, Status>> + Send + 'async_trait>>

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

fn list_compact_task_progress<'life0, 'async_trait>( &'life0 self, request: Request<ListCompactTaskProgressRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListCompactTaskProgressResponse>, Status>> + Send + 'async_trait>>

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

fn cancel_compact_task<'life0, 'async_trait>( &'life0 self, request: Request<CancelCompactTaskRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CancelCompactTaskResponse>, Status>> + Send + 'async_trait>>

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

fn get_version_by_epoch<'life0, 'async_trait>( &'life0 self, request: Request<GetVersionByEpochRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetVersionByEpochResponse>, Status>> + Send + 'async_trait>>

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

fn merge_compaction_group<'life0, 'async_trait>( &'life0 self, request: Request<MergeCompactionGroupRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<MergeCompactionGroupResponse>, Status>> + Send + 'async_trait>>

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

Implementors