risingwave_pb::serverless_backfill_controller::node_group_controller_service_server

Trait NodeGroupControllerService

Source 
pub trait NodeGroupControllerService:
    Send
    + Sync
    + 'static {
    // Required method
    fn provision<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ProvisionRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<ProvisionResponse>, 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 NodeGroupControllerServiceServer.

Required Methods§

Source

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

Provision interacts with Kubernetes to provide a group of compute nodes. To avoid collision and simplify GC, it will generate the a name for node group identification. The RPC call will hold until all nodes haven been observed in the RisingWave’s system catalog. Timeout may be applied over the call to cancel the request, and GC shall be taken care of by the service provider.

Implementors§