Struct ComputeClient

pub struct ComputeClient {
    pub exchange_client: ExchangeServiceClient<Channel>,
    pub task_client: TaskServiceClient<Channel>,
    pub monitor_client: MonitorServiceClient<Channel>,
    pub config_client: ConfigServiceClient<Channel>,
    pub addr: HostAddr,
}

Fields

exchange_client: ExchangeServiceClient<Channel>

task_client: TaskServiceClient<Channel>

monitor_client: MonitorServiceClient<Channel>

config_client: ConfigServiceClient<Channel>

addr: HostAddr

Implementations

impl ComputeClient

pub async fn new(addr: HostAddr) -> Result<Self>

pub fn with_channel(addr: HostAddr, channel: Channel) -> Self

pub async fn get_data( &self, output_id: TaskOutputId, ) -> Result<Streaming<GetDataResponse>>

pub async fn get_stream( &self, up_actor_id: u32, down_actor_id: u32, up_fragment_id: u32, down_fragment_id: u32, ) -> Result<(Streaming<GetStreamResponse>, UnboundedSender<Value>)>

pub async fn create_task( &self, task_id: TaskId, plan: PlanFragment, epoch: BatchQueryEpoch, expr_context: ExprContext, ) -> Result<Streaming<TaskInfoResponse>>

pub async fn execute( &self, req: ExecuteRequest, ) -> Result<Streaming<GetDataResponse>>

pub async fn cancel(&self, req: CancelTaskRequest) -> Result<CancelTaskResponse>

pub async fn stack_trace(&self) -> Result<StackTraceResponse>

pub async fn get_back_pressure(&self) -> Result<GetBackPressureResponse>

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

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

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

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

pub async fn show_config(&self) -> Result<ShowConfigResponse>

Trait Implementations

impl Clone for ComputeClient

fn clone(&self) -> ComputeClient

Returns a copy of the value.

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

Performs copy-assignment from source.

impl RpcClient for ComputeClient

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

where Self: 'async_trait,

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

where Self: 'async_trait,