Struct ComputeClient 

pub struct ComputeClient {
    pub batch_exchange_client: BatchExchangeServiceClient<Channel>,
    pub stream_exchange_client: StreamExchangeServiceClient<Channel>,
    pub task_client: TaskServiceClient<Channel>,
    pub config_client: ConfigServiceClient<Channel>,
    pub addr: HostAddr,
}

Fields

batch_exchange_client: BatchExchangeServiceClient<Channel>

stream_exchange_client: StreamExchangeServiceClient<Channel>

task_client: TaskServiceClient<Channel>

config_client: ConfigServiceClient<Channel>

addr: HostAddr

Implementations

impl ComputeClient

pub async fn new(addr: HostAddr, opts: &RpcClientConfig) -> 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: ActorId, down_actor_id: ActorId, up_fragment_id: FragmentId, down_fragment_id: FragmentId, up_partial_graph_id: PartialGraphId, term_id: String, ) -> Result<(Streaming<GetStreamResponse>, UnboundedSender<Value>)>

pub async fn create_task( &self, task_id: TaskId, plan: PlanFragment, 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 fast_insert( &self, req: FastInsertRequest, ) -> Result<FastInsertResponse>

pub async fn ingest_dml( &self, req: impl IntoStreamingRequest<Message = IngestDmlRequest>, ) -> Result<Streaming<IngestDmlResponse>>

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

pub async fn resize_cache( &self, request: ResizeCacheRequest, ) -> Result<ResizeCacheResponse>

Trait Implementations

impl Clone for ComputeClient

fn clone(&self) -> ComputeClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl RpcClient for ComputeClient

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,