Enum raftstore::store::worker::pd::Task[][src]

pub enum Task<E> where
    E: KvEngine
{ AskSplit { region: Region, split_key: Vec<u8>, peer: Peer, right_derive: bool, callback: Callback<E::Snapshot>, }, AskBatchSplit { region: Region, split_keys: Vec<Vec<u8>>, peer: Peer, right_derive: bool, callback: Callback<E::Snapshot>, }, AutoSplit { split_infos: Vec<SplitInfo>, }, Heartbeat(HeartbeatTask), StoreHeartbeat { stats: StoreStats, store_info: StoreInfo<E>, }, ReportBatchSplit { regions: Vec<Region>, }, ValidatePeer { region: Region, peer: Peer, }, ReadStats { read_stats: ReadStats, }, DestroyPeer { region_id: u64, }, StoreInfos { cpu_usages: Vec<RecordPair>, read_io_rates: Vec<RecordPair>, write_io_rates: Vec<RecordPair>, }, UpdateMaxTimestamp { region_id: u64, initial_status: u64, max_ts_sync_status: Arc<AtomicU64>, }, QueryRegionLeader { region_id: u64, }, }

Uses an asynchronous thread to tell PD something.

Variants

AskSplit

Fields of AskSplit

region: Regionsplit_key: Vec<u8>peer: Peerright_derive: boolcallback: Callback<E::Snapshot>
AskBatchSplit

Fields of AskBatchSplit

region: Regionsplit_keys: Vec<Vec<u8>>peer: Peerright_derive: boolcallback: Callback<E::Snapshot>
AutoSplit

Fields of AutoSplit

split_infos: Vec<SplitInfo>
Heartbeat(HeartbeatTask)
StoreHeartbeat

Fields of StoreHeartbeat

stats: StoreStatsstore_info: StoreInfo<E>
ReportBatchSplit

Fields of ReportBatchSplit

regions: Vec<Region>
ValidatePeer

Fields of ValidatePeer

region: Regionpeer: Peer
ReadStats

Fields of ReadStats

read_stats: ReadStats
DestroyPeer

Fields of DestroyPeer

region_id: u64
StoreInfos

Fields of StoreInfos

cpu_usages: Vec<RecordPair>read_io_rates: Vec<RecordPair>write_io_rates: Vec<RecordPair>
UpdateMaxTimestamp

Fields of UpdateMaxTimestamp

region_id: u64initial_status: u64max_ts_sync_status: Arc<AtomicU64>
QueryRegionLeader

Fields of QueryRegionLeader

region_id: u64

Trait Implementations

impl<E> Display for Task<E> where
    E: KvEngine
[src]

impl<EK, ER, T> Runnable<Task<EK>> for Runner<EK, ER, T> where
    EK: KvEngine,
    ER: RaftEngine,
    T: PdClient
[src]

Auto Trait Implementations

impl<E> !RefUnwindSafe for Task<E>

impl<E> Send for Task<E>

impl<E> !Sync for Task<E>

impl<E> Unpin for Task<E>

impl<E> !UnwindSafe for Task<E>

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized
[src]

impl<T> Borrow<T> for T where
    T: ?Sized
[src]

impl<T> BorrowMut<T> for T where
    T: ?Sized
[src]

impl<V, W> ConvertFrom<W> for V where
    W: ConvertTo<V>, 
[src]

impl<T> From<T> for T[src]

impl<T> Instrument for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, 
[src]

impl<T> Pointable for T[src]

type Init = T

The type for initializers.

impl<T> Pointable for T[src]

type Init = T

The type for initializers.

impl<T> Same<T> for T[src]

type Output = T

Should always be Self

impl<T> Sealed<T> for T where
    T: ?Sized
[src]

impl<T> ToString for T where
    T: Display + ?Sized
[src]

impl<T, U> TryFrom<U> for T where
    U: Into<T>, 
[src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, 
[src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

impl<V, T> VZip<V> for T where
    V: MultiLane<T>, 
[src]