Trait Shardable 

pub trait Shardable {
    type Shard: Debug + Clone + Send + Sync;

    // Required methods
    fn shards(
        &self,
        pd_client: &Arc<impl PdClient>,
    ) -> BoxStream<'static, Result<(Self::Shard, RegionWithLeader)>>;
    fn apply_shard(&mut self, shard: Self::Shard);
    fn apply_store(&mut self, store: &RegionStore) -> Result<()>;

    // Provided method
    fn clone_then_apply_shard(&self, shard: Self::Shard) -> Self
       where Self: Sized + Clone { ... }
}

Required Associated Types

type Shard: Debug + Clone + Send + Sync

Required Methods

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

fn apply_shard(&mut self, shard: Self::Shard)

fn apply_store(&mut self, store: &RegionStore) -> Result<()>

Provided Methods

fn clone_then_apply_shard(&self, shard: Self::Shard) -> Self

where Self: Sized + Clone,

Implementation can skip unnecessary fields clone if fields will be overwritten by apply_shard.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

impl<P: Plan + Shardable> Shardable for PreserveShard<P>

type Shard = <P as Shardable>::Shard

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

type Shard = <P as Shardable>::Shard

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

type Shard = <P as Shardable>::Shard

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

type Shard = <Req as Shardable>::Shard