Struct MonitorClient 

pub struct MonitorClient {
    pub monitor_client: MonitorServiceClient<WrappedChannel>,
}

Client for monitoring and profiling.

Can be applied to any type of worker node, though some methods may not be supported. See documentation of each method for availability.

Fields

monitor_client: MonitorServiceClient<WrappedChannel>

Implementations

impl MonitorClient

pub async fn new(host_addr: HostAddr, opts: &RpcClientConfig) -> Result<Self>

pub async fn await_tree( &self, req: StackTraceRequest, ) -> Result<StackTraceResponse>

Available on meta node, compute node, and compactor node.

Note: for meta node, it will gather await tree from all nodes in the cluster besides itself.

pub async fn get_streaming_stats(&self) -> Result<GetStreamingStatsResponse>

Available on compute node.

pub async fn get_profile_stats( &self, request: GetProfileStatsRequest, ) -> Result<GetProfileStatsResponse>

Available on compute node.

pub async fn profile(&self, sleep_s: u64) -> Result<ProfilingResponse>

Available on meta node, compute node, compactor node, and frontend node.

pub async fn heap_profile(&self, dir: String) -> Result<HeapProfilingResponse>

Available on meta node, compute node, compactor node, and frontend node.

pub async fn list_heap_profile(&self) -> Result<ListHeapProfilingResponse>

Available on meta node, compute node, compactor node, and frontend node.

pub async fn analyze_heap(&self, path: String) -> Result<AnalyzeHeapResponse>

Available on meta node, compute node, compactor node, and frontend node.

Trait Implementations

impl Clone for MonitorClient

fn clone(&self) -> MonitorClient

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl RpcClient for MonitorClient

fn new_client<'life0, 'async_trait>( host_addr: HostAddr, opts: &'life0 RpcClientConfig, ) -> Pin<Box<dyn Future<Output = Result<Self>> + Send + 'async_trait>>

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

fn new_clients<'life0, 'async_trait>( host_addr: HostAddr, size: usize, opts: &'life0 RpcClientConfig, ) -> Pin<Box<dyn Future<Output = Result<Arc<Vec<Self>>>> + Send + 'async_trait>>

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