Trait raftstore::store::transport::ProposalRouter

pub trait ProposalRouter<S> where
    S: Snapshot, {
    fn send(
        &self, 
        cmd: RaftCommand<S>
    ) -> Result<(), TrySendError<RaftCommand<S>>>;
}

Routes proposal to target region.

Required methods

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

Loading content...

Implementations on Foreign Types

impl<S: Snapshot> ProposalRouter<S> for SyncSender<RaftCommand<S>>

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

Loading content...

Implementors

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

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

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

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

impl<S: Snapshot> ProposalRouter<S> for RaftStoreBlackHole

fn send(&self, _: RaftCommand<S>) -> Result<(), TrySendError<RaftCommand<S>>>

Loading content...