Struct Dispatch

pub struct Dispatch<Req: KvRequest> {
    pub request: Req,
    pub kv_client: Option<Arc<dyn KvClient + Send + Sync>>,
}

The simplest plan which just dispatches a request to a specific kv server.

Fields

request: Req

kv_client: Option<Arc<dyn KvClient + Send + Sync>>

Trait Implementations

impl<Req: Clone + KvRequest> Clone for Dispatch<Req>

fn clone(&self) -> Dispatch<Req>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<Req: KvRequest + NextBatch> NextBatch for Dispatch<Req>

fn next_batch(&mut self, range: (Vec<u8>, Vec<u8>))

impl<Req: KvRequest> Plan for Dispatch<Req>

type Result = <Req as KvRequest>::Response

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<Req: KvRequest + Shardable> Shardable for Dispatch<Req>

type Shard = <Req 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<()>

impl<Req: KvRequest + StoreRequest> StoreRequest for Dispatch<Req>

fn apply_store(&mut self, store: &Store)

Apply the request to specified TiKV store.