Struct raftstore::coprocessor::split_check::keys::KeysCheckObserver

pub struct KeysCheckObserver<C, E> {
    router: Arc<Mutex<C>>,
    _phantom: PhantomData<E>,
}

Fields

router: Arc<Mutex<C>>

_phantom: PhantomData<E>

Implementations

impl<C: CasualRouter<E>, E> KeysCheckObserver<C, E> where
    E: KvEngine, 

pub fn new(router: C) -> KeysCheckObserver<C, E>

Trait Implementations

impl<C: Clone, E: Clone> Clone for KeysCheckObserver<C, E>

fn clone(&self) -> KeysCheckObserver<C, E>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<C: Send, E: Send> Coprocessor for KeysCheckObserver<C, E>

fn start(&self)

fn stop(&self)

impl<C: CasualRouter<E> + Send, E> SplitCheckObserver<E> for KeysCheckObserver<C, E> where
    E: KvEngine, 

fn add_checker(
    &self,
    ctx: &mut ObserverContext<'_>,
    host: &mut Host<'_, E>,
    engine: &E,
    policy: CheckPolicy
)

Add a checker for a split scan.