Struct raftstore::router::ServerRaftStoreRouter

[+] Show declaration

pub struct ServerRaftStoreRouter<EK: KvEngine, ER: RaftEngine> {
    router: RaftRouter<EK, ER>,
    local_reader: RefCell<LocalReader<RaftRouter<EK, ER>, EK>>,
}

[−] Expand description

A router that routes messages to the raftstore

Fields

router: RaftRouter<EK, ER>

local_reader: RefCell<LocalReader<RaftRouter<EK, ER>, EK>>

Implementations

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

pub fn new(
    router: RaftRouter<EK, ER>,
    reader: LocalReader<RaftRouter<EK, ER>, EK>
) -> ServerRaftStoreRouter<EK, ER>[−]

Creates a new router.

Trait Implementations

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

[+] Show hidden undocumented items

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

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

[+] 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: KvEngine, ER: RaftEngine> LocalReadRouter<EK> for ServerRaftStoreRouter<EK, ER>[+]

[+] Show hidden undocumented items

fn read(
    &self,
    read_id: Option<ThreadReadId>,
    req: RaftCmdRequest,
    cb: Callback<EK::Snapshot>
) -> RaftStoreResult<()>

fn release_snapshot_cache(&self)

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

[+] Show hidden undocumented items

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

impl<EK: KvEngine, ER: RaftEngine> RaftStoreRouter<EK> for ServerRaftStoreRouter<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: KvEngine, ER: RaftEngine> StoreRouter<EK> for ServerRaftStoreRouter<EK, ER>[+]

[+] Show hidden undocumented items

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