Trait test_raftstore::transport_simulate::Filter

pub trait Filter: Send + Sync {
    fn before(&self, msgs: &mut Vec<RaftMessage>) -> Result<()>;

    fn after(&self, res: Result<()>) -> Result<()> { ... }
}

Required methods

fn before(&self, msgs: &mut Vec<RaftMessage>) -> Result<()>

before is run before sending the messages.

Loading content...

Provided methods

fn after(&self, res: Result<()>) -> Result<()>

after is run after sending the messages, so that the returned value could be changed if necessary.

Loading content...

Implementors

impl Filter for CollectSnapshotFilter

fn before(&self, msgs: &mut Vec<RaftMessage>) -> Result<()>

fn after(&self, res: Result<()>) -> Result<()>

impl Filter for DelayFilter

fn before(&self, _: &mut Vec<RaftMessage>) -> Result<()>

impl Filter for DropMessageFilter

fn before(&self, msgs: &mut Vec<RaftMessage>) -> Result<()>

impl Filter for DropPacketFilter

fn before(&self, msgs: &mut Vec<RaftMessage>) -> Result<()>

impl Filter for DropSnapshotFilter

fn before(&self, msgs: &mut Vec<RaftMessage>) -> Result<()>

impl Filter for LeadingDuplicatedSnapshotFilter

fn before(&self, msgs: &mut Vec<RaftMessage>) -> Result<()>

fn after(&self, res: Result<()>) -> Result<()>

impl Filter for LeadingFilter

fn before(&self, msgs: &mut Vec<RaftMessage>) -> Result<()>

fn after(&self, _: Result<()>) -> Result<()>

impl Filter for LeaseReadFilter

fn before(&self, msgs: &mut Vec<RaftMessage>) -> Result<()>

impl Filter for MessageTypeNotifier

fn before(&self, msgs: &mut Vec<RaftMessage>) -> Result<()>

fn after(&self, _: Result<()>) -> Result<()>

impl Filter for PartitionFilter

fn before(&self, msgs: &mut Vec<RaftMessage>) -> Result<()>

impl Filter for RandomLatencyFilter

fn before(&self, msgs: &mut Vec<RaftMessage>) -> Result<()>

impl Filter for RecvSnapshotFilter

fn before(&self, msgs: &mut Vec<RaftMessage>) -> Result<()>

impl Filter for RegionPacketFilter

fn before(&self, msgs: &mut Vec<RaftMessage>) -> Result<()>

impl Filter for SnapshotFilter

fn before(&self, msgs: &mut Vec<RaftMessage>) -> Result<()>

fn after(&self, x: Result<()>) -> Result<()>

Loading content...