pub(super) trait GlobalBarrierWorkerContext:
Send
+ Sync
+ 'static {
// Required methods
fn commit_epoch(
&self,
commit_info: CommitEpochInfo,
) -> impl Future<Output = MetaResult<HummockVersionStats>> + Send + '_;
async fn next_scheduled(&self) -> Scheduled;
fn abort_and_mark_blocked(
&self,
database_id: Option<DatabaseId>,
recovery_reason: RecoveryReason,
);
fn mark_ready(&self, database_id: Option<DatabaseId>);
fn post_collect_command<'a>(
&'a self,
command: &'a CommandContext,
) -> impl Future<Output = MetaResult<()>> + Send + 'a;
async fn notify_creating_job_failed(&self, err: &MetaError);
fn finish_creating_job(
&self,
job: TrackingJob,
) -> impl Future<Output = MetaResult<()>> + Send + '_;
async fn new_control_stream(
&self,
node: &WorkerNode,
init_request: &PbInitRequest,
) -> MetaResult<StreamingControlHandle>;
async fn reload_runtime_info(
&self,
) -> MetaResult<BarrierWorkerRuntimeInfoSnapshot>;
async fn reload_database_runtime_info(
&self,
database_id: DatabaseId,
) -> MetaResult<Option<DatabaseRuntimeInfoSnapshot>>;
}Required Methods§
fn commit_epoch( &self, commit_info: CommitEpochInfo, ) -> impl Future<Output = MetaResult<HummockVersionStats>> + Send + '_
async fn next_scheduled(&self) -> Scheduled
fn abort_and_mark_blocked( &self, database_id: Option<DatabaseId>, recovery_reason: RecoveryReason, )
fn mark_ready(&self, database_id: Option<DatabaseId>)
fn post_collect_command<'a>( &'a self, command: &'a CommandContext, ) -> impl Future<Output = MetaResult<()>> + Send + 'a
async fn notify_creating_job_failed(&self, err: &MetaError)
fn finish_creating_job( &self, job: TrackingJob, ) -> impl Future<Output = MetaResult<()>> + Send + '_
async fn new_control_stream( &self, node: &WorkerNode, init_request: &PbInitRequest, ) -> MetaResult<StreamingControlHandle>
async fn reload_runtime_info( &self, ) -> MetaResult<BarrierWorkerRuntimeInfoSnapshot>
async fn reload_database_runtime_info( &self, database_id: DatabaseId, ) -> MetaResult<Option<DatabaseRuntimeInfoSnapshot>>
Object Safety§
This trait is not object safe.