risingwave_pb::monitor_service::monitor_service_server

Trait MonitorService

source
pub trait MonitorService:
    Send
    + Sync
    + 'static {
    // Required methods
    fn stack_trace<'life0, 'async_trait>(
        &'life0 self,
        request: Request<StackTraceRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<StackTraceResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn profiling<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ProfilingRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<ProfilingResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn heap_profiling<'life0, 'async_trait>(
        &'life0 self,
        request: Request<HeapProfilingRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<HeapProfilingResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn list_heap_profiling<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ListHeapProfilingRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<ListHeapProfilingResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn analyze_heap<'life0, 'async_trait>(
        &'life0 self,
        request: Request<AnalyzeHeapRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<AnalyzeHeapResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_back_pressure<'life0, 'async_trait>(
        &'life0 self,
        request: Request<GetBackPressureRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<GetBackPressureResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn tiered_cache_tracing<'life0, 'async_trait>(
        &'life0 self,
        request: Request<TieredCacheTracingRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<TieredCacheTracingResponse>, 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 MonitorServiceServer.

Required Methods§

source

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

source

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

source

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

source

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

source

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

source

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

source

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

Implementors§