Struct RetryableMultiRegion

pub struct RetryableMultiRegion<P: Plan, PdC: PdClient> {
    pub pd_client: Arc<PdC>,
    pub backoff: Backoff,
    pub preserve_region_results: bool,
    /* private fields */
}

Fields

pd_client: Arc<PdC>

backoff: Backoff

preserve_region_results: bool

Preserve all regions’ results for other downstream plans to handle. If true, return Ok and preserve all regions’ results, even if some of them are Err. Otherwise, return the first Err if there is any.

Trait Implementations

impl<P: Plan, PdC: PdClient> Clone for RetryableMultiRegion<P, PdC>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<P: Plan + Shardable, PdC: PdClient> Plan for RetryableMultiRegion<P, PdC>

where P::Result: HasKeyErrors + HasRegionError,

type Result = Vec<Result<<P as Plan>::Result, Error>>

The ultimate result of executing the plan (should be a high-level type, not a GRPC response).

fn execute<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Self::Result>> + Send + 'async_trait>>

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

Execute the plan.