Trait raftstore::store::fsm::apply::Notifier[−][src]

pub trait Notifier<EK: KvEngine>: Send {
    fn notify(&self, apply_res: Vec<ApplyRes<EK::Snapshot>>);

    fn notify_one(&self, region_id: u64, msg: PeerMsg<EK>);

    fn clone_box(&self) -> Box<dyn Notifier<EK>>ⓘ
Notable traits for Box<R, Global>
impl<R> Read for Box<R, Global> where
    R: Read + ?Sized, impl<W> Write for Box<W, Global> where
    W: Write + ?Sized, impl<F, A> Future for Box<F, A> where
    F: Future + Unpin + ?Sized,
    A: Allocator + 'static,     type Output = <F as Future>::Output;impl<I, A> Iterator for Box<I, A> where
    I: Iterator + ?Sized,
    A: Allocator,     type Item = <I as Iterator>::Item;
;
}

Required methods

fn notify(&self, apply_res: Vec<ApplyRes<EK::Snapshot>>)[src]

fn notify_one(&self, region_id: u64, msg: PeerMsg<EK>)[src]

fn clone_box(&self) -> Box<dyn Notifier<EK>>ⓘ

Notable traits for Box<R, Global>

impl<R> Read for Box<R, Global> where
    R: Read + ?Sized, impl<W> Write for Box<W, Global> where
    W: Write + ?Sized, impl<F, A> Future for Box<F, A> where
    F: Future + Unpin + ?Sized,
    A: Allocator + 'static,  type Output = <F as Future>::Output;impl<I, A> Iterator for Box<I, A> where
    I: Iterator + ?Sized,
    A: Allocator,  type Item = <I as Iterator>::Item;
[src]

Loading content...

Implementors

impl<EK, ER> Notifier<EK> for RaftRouter<EK, ER> where
    EK: KvEngine,
    ER: RaftEngine, [src]

Loading content...