Trait raftstore::store::transport::Transport

[+] Show declaration

pub trait Transport: Send + Clone {
    fn send(&mut self, msg: RaftMessage) -> Result<()>;
    fn need_flush(&self) -> bool;
    fn flush(&mut self);
}

[−] Expand description

Transports messages between different Raft peers.

Required methods

fn send(&mut self, msg: RaftMessage) -> Result<()>

fn need_flush(&self) -> bool

fn flush(&mut self)

Implementors

impl Transport for ChannelTransport

impl<C: Transport> Transport for SimulateTransport<C>

impl<T, S, E> Transport for ServerTransport<T, S, E> where     T: RaftStoreRouter<E> + Unpin + 'static,     S: StoreAddrResolver + Unpin + 'static,     E: KvEngine,