Struct test_raftstore::RegionPacketFilter

[+] Show declaration

pub struct RegionPacketFilter {
    region_id: u64,
    store_id: u64,
    direction: Direction,
    block: Either<Arc<AtomicUsize>, Arc<AtomicBool>>,
    drop_type: Vec<MessageType>,
    skip_type: Vec<MessageType>,
    dropped_messages: Option<Arc<Mutex<Vec<RaftMessage>>>>,
    msg_callback: Option<Arc<dyn Fn(&RaftMessage) + Send + Sync>>,
}

[−] Expand description

Drop specified messages for the store with special region.

If drop_type is empty, all message will be dropped.

Fields

region_id: u64

store_id: u64

direction: Direction

block: Either<Arc<AtomicUsize>, Arc<AtomicBool>>

drop_type: Vec<MessageType>

skip_type: Vec<MessageType>

dropped_messages: Option<Arc<Mutex<Vec<RaftMessage>>>>

msg_callback: Option<Arc<dyn Fn(&RaftMessage) + Send + Sync>>

Implementations

impl RegionPacketFilter[−]

pub fn new(region_id: u64, store_id: u64) -> RegionPacketFilter

pub fn direction(self, direction: Direction) -> RegionPacketFilter

pub fn msg_type(self, m_type: MessageType) -> RegionPacketFilter

pub fn skip(self, m_type: MessageType) -> RegionPacketFilter

pub fn allow(self, number: usize) -> RegionPacketFilter

pub fn when(self, condition: Arc<AtomicBool>) -> RegionPacketFilter

pub fn reserve_dropped(
    self,
    dropped: Arc<Mutex<Vec<RaftMessage>>>
) -> RegionPacketFilter

pub fn set_msg_callback(
    self,
    cb: Arc<dyn Fn(&RaftMessage) + Send + Sync>
) -> RegionPacketFilter

Trait Implementations

impl Clone for RegionPacketFilter[+]

[+] Show hidden undocumented items

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Filter for RegionPacketFilter[+]

[+] 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.