Struct tikv_client::request::plan::ResolveLock

pub struct ResolveLock<P: Plan, PdC: PdClient> {
    pub inner: P,
    pub pd_client: Arc<PdC>,
    pub backoff: Backoff,
}

Fields

inner: P

pd_client: Arc<PdC>

backoff: Backoff

Trait Implementations

impl<P: Plan, PdC: PdClient> Clone for ResolveLock<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, PdC: PdClient> Plan for ResolveLock<P, PdC>where P::Result: HasLocks,

type Result = <P as Plan>::Result

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.

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

type Shard = <P as Shardable>::Shard

fn shards( &self, pd_client: &Arc<impl PdClient> ) -> BoxStream<'static, Result<(Self::Shard, RegionStore)>>

fn apply_shard(&mut self, shard: Self::Shard, store: &RegionStore) -> Result<()>