Struct raftstore::store::fsm::store::RaftPollerBuilder

pub struct RaftPollerBuilder<EK: KvEngine, ER: RaftEngine, T> {
    pub cfg: Arc<VersionTrack<Config>>,
    pub store: Store,
    pd_scheduler: FutureScheduler<PdTask<EK>>,
    consistency_check_scheduler: Scheduler<ConsistencyCheckTask<EK::Snapshot>>,
    split_check_scheduler: Scheduler<SplitCheckTask>,
    cleanup_scheduler: Scheduler<CleanupTask>,
    raftlog_gc_scheduler: Scheduler<RaftlogGcTask>,
    pub region_scheduler: Scheduler<RegionTask<EK::Snapshot>>,
    apply_router: ApplyRouter<EK>,
    pub router: RaftRouter<EK, ER>,
    pub importer: Arc<SSTImporter>,
    pub store_meta: Arc<Mutex<StoreMeta>>,
    pub pending_create_peers: Arc<Mutex<HashMap<u64, (u64, bool)>>>,
    snap_mgr: SnapManager,
    pub coprocessor_host: CoprocessorHost<EK>,
    trans: T,
    global_stat: GlobalStoreStat,
    pub engines: Engines<EK, ER>,
    global_replication_state: Arc<Mutex<GlobalReplicationState>>,
    feature_gate: FeatureGate,
}

Fields

cfg: Arc<VersionTrack<Config>>

store: Store

pd_scheduler: FutureScheduler<PdTask<EK>>

consistency_check_scheduler: Scheduler<ConsistencyCheckTask<EK::Snapshot>>

split_check_scheduler: Scheduler<SplitCheckTask>

cleanup_scheduler: Scheduler<CleanupTask>

raftlog_gc_scheduler: Scheduler<RaftlogGcTask>

region_scheduler: Scheduler<RegionTask<EK::Snapshot>>

apply_router: ApplyRouter<EK>

router: RaftRouter<EK, ER>

importer: Arc<SSTImporter>

store_meta: Arc<Mutex<StoreMeta>>

pending_create_peers: Arc<Mutex<HashMap<u64, (u64, bool)>>>

snap_mgr: SnapManager

coprocessor_host: CoprocessorHost<EK>

trans: T

global_stat: GlobalStoreStat

engines: Engines<EK, ER>

global_replication_state: Arc<Mutex<GlobalReplicationState>>

feature_gate: FeatureGate

Implementations

impl<EK: KvEngine, ER: RaftEngine, T> RaftPollerBuilder<EK, ER, T>

fn init(
    &mut self
) -> Result<Vec<(LooseBoundedSender<PeerMsg<EK>>, Box<PeerFsm<EK, ER>>)>>

Initialize this store. It scans the db engine, loads all regions and their peers from it, and schedules snapshot worker if necessary. WARN: This store should not be used before initialized.

fn clear_stale_meta(
    &self,
    kv_wb: &mut EK::WriteBatch,
    raft_wb: &mut ER::LogBatch,
    origin_state: &RegionLocalState
)

fn clear_stale_data(&self, meta: &StoreMeta) -> Result<()>

clear_stale_data clean up all possible garbage data.

Trait Implementations

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>