Trait tikv_util::worker::pool::Runnable[−][src]

pub trait Runnable: Send {
    type Task: Display + Send + 'static;
    fn run(&mut self, _: Self::Task) { ... }

    fn on_tick(&mut self) { ... }

    fn shutdown(&mut self) { ... }
}

Associated Types

type Task: Display + Send + 'static[src]

Provided methods

fn run(&mut self, _: Self::Task)[src][−]

Runs a task.

fn on_tick(&mut self)[src]

fn shutdown(&mut self)[src]

Implementors

impl<E: Engine, R: RegionInfoProvider + Clone + 'static> Runnable for Endpoint<E, R>

impl<T: 'static + RaftStoreRouter<RocksEngine>> Runnable for Endpoint<T>

impl Runnable for RegionCollector

impl<E, C, S> Runnable for Runner<E, C, S> where
    E: KvEngine,
    C: PdClient,
    S: StoreRouter<E>, 

impl<EK, C, S> Runnable for Runner<EK, C, S> where
    EK: KvEngine,
    C: PdClient,
    S: StoreRouter<EK>, 

impl<E> Runnable for Runner<E> where
    E: KvEngine, 

impl<EK, C> Runnable for Runner<EK, C> where
    EK: KvEngine,
    C: CasualRouter<EK>, 

impl<EK, ER, R> Runnable for Runner<EK, ER, R> where
    EK: KvEngine,
    ER: RaftEngine,
    R: CasualRouter<EK>, 

impl<EK, R> Runnable for Runner<EK, R> where
    EK: KvEngine,
    R: CasualRouter<EK> + Send + Clone + 'static, 

impl<E, S> Runnable for Runner<E, S> where
    E: KvEngine,
    S: CasualRouter<E>, 

impl<T, E, C> Runnable for Endpoint<T, E, C> where
    T: 'static + RaftStoreRouter<E>,
    E: KvEngine,
    C: CmdSinker<E::Snapshot>, 

impl Runnable for LockCollectorRunner

impl<T, RR, E> Runnable for Runner<T, RR, E> where
    T: PdClient,
    RR: RaftStoreRouter<E>,
    E: KvEngine, 

impl<E, R> Runnable for Runner<E, R> where
    E: KvEngine,
    R: RaftStoreRouter<E> + 'static, 

impl<E: KvEngine, R: RegionInfoProvider> Runnable for TTLChecker<E, R> where
    E: KvEngine, 

impl Runnable for Runner