risingwave_pb::meta::stream_manager_service_server

Trait StreamManagerService

source 
pub trait StreamManagerService:
    Send
    + Sync
    + 'static {

Show 13 methods    // Required methods
    fn flush<'life0, 'async_trait>(
        &'life0 self,
        request: Request<FlushRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<FlushResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn pause<'life0, 'async_trait>(
        &'life0 self,
        request: Request<PauseRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<PauseResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn resume<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ResumeRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<ResumeResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn cancel_creating_jobs<'life0, 'async_trait>(
        &'life0 self,
        request: Request<CancelCreatingJobsRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<CancelCreatingJobsResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn list_table_fragments<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ListTableFragmentsRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<ListTableFragmentsResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn list_table_fragment_states<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ListTableFragmentStatesRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<ListTableFragmentStatesResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn list_fragment_distribution<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ListFragmentDistributionRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<ListFragmentDistributionResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn list_actor_states<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ListActorStatesRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<ListActorStatesResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn list_actor_splits<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ListActorSplitsRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<ListActorSplitsResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn list_object_dependencies<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ListObjectDependenciesRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<ListObjectDependenciesResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn apply_throttle<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ApplyThrottleRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<ApplyThrottleResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn recover<'life0, 'async_trait>(
        &'life0 self,
        request: Request<RecoverRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<RecoverResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn list_rate_limits<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ListRateLimitsRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<ListRateLimitsResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;

}
Expand description

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

Required Methods§

source

fn flush<'life0, 'async_trait>( &'life0 self, request: Request<FlushRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<FlushResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source

fn pause<'life0, 'async_trait>( &'life0 self, request: Request<PauseRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<PauseResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source

fn resume<'life0, 'async_trait>( &'life0 self, request: Request<ResumeRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ResumeResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source

fn cancel_creating_jobs<'life0, 'async_trait>( &'life0 self, request: Request<CancelCreatingJobsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CancelCreatingJobsResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source

fn list_table_fragments<'life0, 'async_trait>( &'life0 self, request: Request<ListTableFragmentsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListTableFragmentsResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source

fn list_table_fragment_states<'life0, 'async_trait>( &'life0 self, request: Request<ListTableFragmentStatesRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListTableFragmentStatesResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source

fn list_fragment_distribution<'life0, 'async_trait>( &'life0 self, request: Request<ListFragmentDistributionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListFragmentDistributionResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source

fn list_actor_states<'life0, 'async_trait>( &'life0 self, request: Request<ListActorStatesRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListActorStatesResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source

fn list_actor_splits<'life0, 'async_trait>( &'life0 self, request: Request<ListActorSplitsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListActorSplitsResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source

fn list_object_dependencies<'life0, 'async_trait>( &'life0 self, request: Request<ListObjectDependenciesRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListObjectDependenciesResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source

fn apply_throttle<'life0, 'async_trait>( &'life0 self, request: Request<ApplyThrottleRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ApplyThrottleResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source

fn recover<'life0, 'async_trait>( &'life0 self, request: Request<RecoverRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RecoverResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source

fn list_rate_limits<'life0, 'async_trait>( &'life0 self, request: Request<ListRateLimitsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListRateLimitsResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Implementors§