Struct raftstore::store::fsm::apply::ControlFsm

pub struct ControlFsm;

Trait Implementations

impl Fsm for ControlFsm

type Message = ControlMsg

fn is_stopped(&self) -> bool

pub fn set_mailbox(&mut self, _mailbox: Cow<'_, BasicMailbox<Self>>)

Set a mailbox to Fsm, which should be used to send message to itself.

pub fn take_mailbox(&mut self) -> Option<BasicMailbox<Self>>

Take the mailbox from Fsm. Implementation should ensure there will be no reference to mailbox after calling this method.

pub fn get_priority(&self) -> Priority

impl<EK, W> HandlerBuilder<ApplyFsm<EK>, ControlFsm> for Builder<EK, W> where
    EK: KvEngine,
    W: WriteBatch<EK>, 

type Handler = ApplyPoller<EK, W>

fn build(&mut self, priority: Priority) -> ApplyPoller<EK, W>

impl<EK, W> PollHandler<ApplyFsm<EK>, ControlFsm> for ApplyPoller<EK, W> where
    EK: KvEngine,
    W: WriteBatch<EK>, 

fn begin(&mut self, _batch_size: usize)

This function is called at the very beginning of every round.

fn handle_control(&mut self, _: &mut ControlFsm) -> Option<usize>

There is no control fsm in apply poller.

fn handle_normal(&mut self, normal: &mut ApplyFsm<EK>) -> Option<usize>

This function is called when handling readiness for normal FSM.

fn end(&mut self, fsms: &mut [Box<ApplyFsm<EK>>])

This function is called at the end of every round.

fn get_priority(&self) -> Priority

This function returns the priority of this handler.

pub fn pause(&mut self)

This function is called when batch system is going to sleep.