Struct FrontendRetryClient 

pub struct FrontendRetryClient {
    client: FrontendClient,
}

Fields

client: FrontendClient

Implementations

impl FrontendRetryClient

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

fn get_retry_strategy() -> impl Iterator<Item = Duration>

fn should_retry(status: &Status) -> bool

pub async fn get_table_replace_plan( &self, request: GetTableReplacePlanRequest, ) -> Result<Response<GetTableReplacePlanResponse>, Status>

pub async fn get_running_sqls( &self, request: GetRunningSqlsRequest, ) -> Result<Response<GetRunningSqlsResponse>, Status>

pub async fn get_all_cursors( &self, request: GetAllCursorsRequest, ) -> Result<Response<GetAllCursorsResponse>, Status>

pub async fn get_all_sub_cursors( &self, request: GetAllSubCursorsRequest, ) -> Result<Response<GetAllSubCursorsResponse>, Status>

pub async fn cancel_running_sql( &self, request: CancelRunningSqlRequest, ) -> Result<Response<CancelRunningSqlResponse>, Status>

Trait Implementations

impl Clone for FrontendRetryClient

fn clone(&self) -> FrontendRetryClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl RpcClient for FrontendRetryClient

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,