Struct tikv::server::gc_worker::applied_lock_collector::LockObserver

struct LockObserver {
    state: Arc<LockObserverState>,
    sender: Scheduler<LockCollectorTask>,
}

LockObserver observes apply events and apply snapshot events. If it happens in CF_LOCK, it checks the start_tss of the locks being written. If a lock’s start_ts <= specified max_ts in the state, it will send the lock to through the sender, so the receiver can collect it.

Fields

state: Arc<LockObserverState>

sender: Scheduler<LockCollectorTask>

Implementations

impl LockObserver

pub fn new(
    state: Arc<LockObserverState>,
    sender: Scheduler<LockCollectorTask>
) -> Self

pub fn register(self, coprocessor_host: &mut CoprocessorHost<RocksEngine>)

fn send(&self, locks: Vec<(Key, Lock)>)

Trait Implementations

impl ApplySnapshotObserver for LockObserver

fn apply_plain_kvs(
    &self,
    _: &mut ObserverContext<'_>,
    cf: CfName,
    kv_pairs: &[(Vec<u8>, Vec<u8>)]
)

Hook to call after applying key from plain file. This may be invoked multiple times for each plain file, and each time a batch of key-value pairs will be passed to the function.

fn apply_sst(&self, _: &mut ObserverContext<'_>, cf: CfName, _path: &str)

Hook to call after applying sst file. Currently the content of the snapshot can’t be passed to the observer.

impl Clone for LockObserver

fn clone(&self) -> LockObserver

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Coprocessor for LockObserver

pub fn start(&self)

pub fn stop(&self)

impl QueryObserver for LockObserver

fn post_apply_query(&self, _: &mut ObserverContext<'_>, cmd: &mut Cmd)

Hook to call after applying write request.

pub fn pre_propose_query(
    &self,
    &mut ObserverContext<'_>,
    &mut Vec<Request, Global>
) -> Result<(), Error>

Hook to call before proposing write request.

pub fn pre_apply_query(&self, &mut ObserverContext<'_>, &[Request])

Hook to call before applying write request.