Struct raftstore::store::fsm::store::RaftRouter

[+] Show declaration

pub struct RaftRouter<EK, ER> where
    EK: KvEngine,
    ER: RaftEngine,  {
    pub router: BatchRouter<PeerFsm<EK, ER>, StoreFsm<EK>>,
}

Fields

router: BatchRouter<PeerFsm<EK, ER>, StoreFsm<EK>>

Implementations

impl<EK, ER> RaftRouter<EK, ER> where
    EK: KvEngine,
    ER: RaftEngine, [−]

pub fn send_raft_message(
    &self,
    msg: RaftMessage
) -> Result<(), TrySendError<RaftMessage>>

pub fn send_raft_command(
    &self,
    cmd: RaftCommand<EK::Snapshot>
) -> Result<(), TrySendError<RaftCommand<EK::Snapshot>>>

fn report_unreachable(&self, store_id: u64)

fn report_status_update(&self)

pub fn report_resolved(&self, store_id: u64, group_id: u64)[−]

Broadcasts resolved result to all regions.

pub fn register(&self, region_id: u64, mailbox: BasicMailbox<PeerFsm<EK, ER>>)

pub fn register_all(&self, mailboxes: Vec<(u64, BasicMailbox<PeerFsm<EK, ER>>)>)

pub fn close(&self, region_id: u64)

pub fn clear_cache(&self)

fn update_trace(&self)

Trait Implementations

impl<EK, ER> CasualRouter<EK> for RaftRouter<EK, ER> where
    EK: KvEngine,
    ER: RaftEngine, [+]

[+] Show hidden undocumented items

fn send(&self, region_id: u64, msg: CasualMessage<EK>) -> Result<()>

impl<EK, ER> Clone for RaftRouter<EK, ER> where
    EK: KvEngine,
    ER: RaftEngine, [+]

[+] Show hidden undocumented items

fn clone(&self) -> Self[−]

Returns a copy of the value.

pub fn clone_from(&mut self, source: &Self)[−]

Performs copy-assignment from source.

impl<EK, ER> Deref for RaftRouter<EK, ER> where
    EK: KvEngine,
    ER: RaftEngine, [+]

[+] Show hidden undocumented items

type Target = BatchRouter<PeerFsm<EK, ER>, StoreFsm<EK>>

The resulting type after dereferencing.

fn deref(&self) -> &BatchRouter<PeerFsm<EK, ER>, StoreFsm<EK>>[−]

Dereferences the value.

impl<EK, ER> Drop for RaftRouter<EK, ER> where
    EK: KvEngine,
    ER: RaftEngine, [+]

[+] Show hidden undocumented items

fn drop(&mut self)[−]

Executes the destructor for this type.

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

[+] Show hidden undocumented items

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 ApplyNotifier<EK>>

impl<EK, ER> ProposalRouter<<EK as KvEngine>::Snapshot> for RaftRouter<EK, ER> where
    EK: KvEngine,
    ER: RaftEngine, [+]

[+] Show hidden undocumented items

fn send(
    &self,
    cmd: RaftCommand<EK::Snapshot>
) -> Result<(), TrySendError<RaftCommand<EK::Snapshot>>>

impl<EK: KvEngine, ER: RaftEngine> RaftStoreRouter<EK> for RaftRouter<EK, ER>[+]

[+] Show hidden undocumented items

fn send_raft_msg(&self, msg: RaftMessage) -> RaftStoreResult<()>[−]

Sends RaftMessage to local store.

fn significant_send(
    &self,
    region_id: u64,
    msg: SignificantMsg<EK::Snapshot>
) -> RaftStoreResult<()>[−]

Sends a significant message. We should guarantee that the message can’t be dropped.

fn broadcast_normal(&self, msg_gen: impl FnMut() -> PeerMsg<EK>)[−]

Broadcast a message generated by msg_gen to all Raft groups.

fn send_casual_msg(
    &self,
    region_id: u64,
    msg: CasualMessage<EK>
) -> RaftStoreResult<()>[−]

Send a casual message to the given region.

fn send_store_msg(&self, msg: StoreMsg<EK>) -> RaftStoreResult<()>[−]

Send a store message to the backend raft batch system.

fn send_command(
    &self,
    req: RaftCmdRequest,
    cb: Callback<EK::Snapshot>
) -> RaftStoreResult<()>[−]

Sends RaftCmdRequest to local store.

fn send_command_with_deadline(
    &self,
    req: RaftCmdRequest,
    cb: Callback<EK::Snapshot>,
    deadline: Deadline
) -> RaftStoreResult<()>

fn report_unreachable(
    &self,
    region_id: u64,
    to_peer_id: u64
) -> RaftStoreResult<()>[−]

Reports the peer being unreachable to the Region.

fn report_snapshot_status(
    &self,
    region_id: u64,
    to_peer_id: u64,
    status: SnapshotStatus
) -> RaftStoreResult<()>[−]

Reports the sending snapshot status to the peer of the Region.

fn broadcast_unreachable(&self, store_id: u64)[−]

Broadcast an StoreUnreachable event to all Raft groups.

fn report_resolved(&self, store_id: u64, group_id: u64)[−]

Report a StoreResolved event to all Raft groups.

impl<EK, ER> StoreRouter<EK> for RaftRouter<EK, ER> where
    EK: KvEngine,
    ER: RaftEngine, [+]

[+] Show hidden undocumented items

fn send(&self, msg: StoreMsg<EK>) -> Result<()>