Struct tikv_client::request::plan::CleanupLocks

pub struct CleanupLocks<P: Plan, PdC: PdClient> {
    pub inner: P,
    pub ctx: ResolveLocksContext,
    pub options: ResolveLocksOptions,
    pub store: Option<RegionStore>,
    pub pd_client: Arc<PdC>,
    pub backoff: Backoff,
}

Fields

inner: P

ctx: ResolveLocksContext

options: ResolveLocksOptions

store: Option<RegionStore>

pd_client: Arc<PdC>

backoff: Backoff

Trait Implementations

impl<P: Plan, PdC: PdClient> Clone for CleanupLocks<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 + NextBatch, PdC: PdClient> Plan for CleanupLocks<P, PdC>where P::Result: HasLocks + HasNextBatch + HasKeyErrors + HasRegionError,

type Result = CleanupLocksResult

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 CleanupLocks<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<()>