Struct RetryableAllStores

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

Fields

pd_client: Arc<PdC>

backoff: Backoff

Trait Implementations

impl<P: Plan, PdC: PdClient> Clone for RetryableAllStores<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 + StoreRequest, PdC: PdClient> Plan for RetryableAllStores<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.