Struct raftstore::store::fsm::store::RaftPoller

pub struct RaftPoller<EK: KvEngine + 'static, ER: RaftEngine + 'static, T: 'static> {
    tag: String,
    store_msg_buf: Vec<StoreMsg<EK>>,
    peer_msg_buf: Vec<PeerMsg<EK>>,
    previous_metrics: RaftMetrics,
    timer: TiInstant,
    poll_ctx: PollContext<EK, ER, T>,
    messages_per_tick: usize,
    cfg_tracker: Tracker<Config>,
}

Fields

tag: String

store_msg_buf: Vec<StoreMsg<EK>>

peer_msg_buf: Vec<PeerMsg<EK>>

previous_metrics: RaftMetrics

timer: TiInstant

poll_ctx: PollContext<EK, ER, T>

messages_per_tick: usize

cfg_tracker: Tracker<Config>

Implementations

impl<EK: KvEngine, ER: RaftEngine, T: Transport> RaftPoller<EK, ER, T>

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

fn flush_ticks(&mut self)

Trait Implementations

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.