Struct raftstore::store::fsm::store::StoreFsm

pub struct StoreFsm<EK> where
    EK: KvEngine,  {
    store: Store,
    receiver: Receiver<StoreMsg<EK>>,
}

Fields

store: Store

receiver: Receiver<StoreMsg<EK>>

Implementations

impl<EK> StoreFsm<EK> where
    EK: KvEngine, 

pub fn new(
    cfg: &Config
) -> (LooseBoundedSender<StoreMsg<EK>>, Box<StoreFsm<EK>>)

Trait Implementations

impl<EK> Fsm for StoreFsm<EK> where
    EK: KvEngine, 

type Message = StoreMsg<EK>

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, ER, T> HandlerBuilder<PeerFsm<EK, ER>, StoreFsm<EK>> for RaftPollerBuilder<EK, ER, T> where
    EK: KvEngine + 'static,
    ER: RaftEngine + 'static,
    T: Transport + 'static, 

type Handler = RaftPoller<EK, ER, T>

fn build(&mut self, _: Priority) -> RaftPoller<EK, ER, T>

impl<EK: KvEngine, ER: RaftEngine, T: Transport> PollHandler<PeerFsm<EK, ER>, StoreFsm<EK>> for RaftPoller<EK, ER, T>

fn begin(&mut self, _batch_size: usize)

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

fn handle_control(&mut self, store: &mut StoreFsm<EK>) -> Option<usize>

This function is called when handling readiness for control FSM.

fn handle_normal(&mut self, peer: &mut PeerFsm<EK, ER>) -> Option<usize>

This function is called when handling readiness for normal FSM.

fn end(&mut self, peers: &mut [Box<PeerFsm<EK, ER>>])

This function is called at the end of every round.

fn pause(&mut self)

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

pub fn get_priority(&self) -> Priority

This function returns the priority of this handler.