Struct test_raftstore::transport_simulate::SimulateTransport

pub struct SimulateTransport<C> {
    filters: Arc<RwLock<Vec<Box<dyn Filter>>>>,
    ch: C,
}

Fields

filters: Arc<RwLock<Vec<Box<dyn Filter>>>>

ch: C

Implementations

impl<C> SimulateTransport<C>

pub fn new(ch: C) -> SimulateTransport<C>

pub fn clear_filters(&mut self)

pub fn add_filter(&mut self, filter: Box<dyn Filter>)

Trait Implementations

impl<C: RaftStoreRouter<RocksEngine>> CasualRouter<RocksEngine> for SimulateTransport<C>

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

impl<C: Clone> Clone for SimulateTransport<C>

fn clone(&self) -> SimulateTransport<C>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<C: LocalReadRouter<RocksEngine>> LocalReadRouter<RocksEngine> for SimulateTransport<C>

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

fn release_snapshot_cache(&self)

impl<C: RaftStoreRouter<RocksEngine>> ProposalRouter<RocksSnapshot> for SimulateTransport<C>

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

impl<C: RaftStoreRouter<RocksEngine>> RaftStoreRouter<RocksEngine> for SimulateTransport<C>

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

Sends RaftMessage to local store.

fn significant_send(
    &self,
    region_id: u64,
    msg: SignificantMsg<RocksSnapshot>
) -> Result<()>

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

fn broadcast_normal(&self, _: impl FnMut() -> PeerMsg<RocksEngine>)

Broadcast a message generated by msg_gen to all Raft groups.

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

Send a casual message to the given region.

pub fn send_store_msg(&self, msg: StoreMsg<EK>) -> Result<(), Error>

Send a store message to the backend raft batch system.

pub fn send_command(
    &self,
    req: RaftCmdRequest,
    cb: Callback<<EK as KvEngine>::Snapshot>
) -> Result<(), Error>

Sends RaftCmdRequest to local store.

pub fn send_command_with_deadline(
    &self,
    req: RaftCmdRequest,
    cb: Callback<<EK as KvEngine>::Snapshot>,
    deadline: Deadline
) -> Result<(), Error>

pub fn report_unreachable(
    &self,
    region_id: u64,
    to_peer_id: u64
) -> Result<(), Error>

Reports the peer being unreachable to the Region.

pub fn report_snapshot_status(
    &self,
    region_id: u64,
    to_peer_id: u64,
    status: SnapshotStatus
) -> Result<(), Error>

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

pub fn broadcast_unreachable(&self, store_id: u64)

Broadcast an StoreUnreachable event to all Raft groups.

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

Report a StoreResolved event to all Raft groups.

impl<C: RaftStoreRouter<RocksEngine>> StoreRouter<RocksEngine> for SimulateTransport<C>

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

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

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

fn need_flush(&self) -> bool

fn flush(&mut self)