Struct test_raftstore::RandomLatencyFilter

[+] Show declaration

pub struct RandomLatencyFilter {
    delay_rate: u32,
    delayed_msgs: Mutex<Vec<RaftMessage>>,
}

[−] Expand description

RandomLatencyFilter is a transport filter to simulate randomized network latency. Based on a randomized rate, RandomLatencyFilter will decide whether to delay the sending of any message. It’s could be used to simulate the message sending in a network with random latency, where messages could be delayed, disordered or lost.

Fields

delay_rate: u32

delayed_msgs: Mutex<Vec<RaftMessage>>

Implementations

impl RandomLatencyFilter[−]

pub fn new(rate: u32) -> RandomLatencyFilter

fn will_delay(&self, _: &RaftMessage) -> bool

Trait Implementations

impl Clone for RandomLatencyFilter[+]

[+] Show hidden undocumented items

fn clone(&self) -> RandomLatencyFilter[−]

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Filter for RandomLatencyFilter[+]

[+] Show hidden undocumented items

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

before is run before sending the messages.

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

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