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>

Trait Implementations

impl Clone for FrontendRetryClient

fn clone(&self) -> FrontendRetryClient

Returns a copy 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,