Struct resolved_ts::Observer

pub struct Observer<E: KvEngine> {
    cmd_batches: RefCell<Vec<CmdBatch>>,
    scheduler: Scheduler<Task<E::Snapshot>>,
    need_old_value: bool,
    last_batch_observing: RefCell<bool>,
}

Fields

cmd_batches: RefCell<Vec<CmdBatch>>

scheduler: Scheduler<Task<E::Snapshot>>

need_old_value: bool

last_batch_observing: RefCell<bool>

Implementations

impl<E: KvEngine> Observer<E>

pub fn new(scheduler: Scheduler<Task<E::Snapshot>>) -> Self

pub fn disable_old_value(&mut self)

pub fn register_to(&self, coprocessor_host: &mut CoprocessorHost<E>)

Trait Implementations

impl<E: KvEngine> Clone for Observer<E>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<E: KvEngine> CmdObserver<E> for Observer<E>

fn on_prepare_for_apply(
    &self,
    cdc: &ObserveHandle,
    rts: &ObserveHandle,
    region_id: u64
)

Hook to call after preparing for applying write requests.

fn on_apply_cmd(
    &self,
    cdc_id: ObserveID,
    rts_id: ObserveID,
    region_id: u64,
    cmd: &Cmd
)

Hook to call after applying a write request.

fn on_flush_apply(&self, engine: E)

Hook to call after flushing writes to db.

impl<E: KvEngine> Coprocessor for Observer<E>

pub fn start(&self)

pub fn stop(&self)

impl<E: KvEngine> RegionChangeObserver for Observer<E>

fn on_region_changed(
    &self,
    ctx: &mut ObserverContext<'_>,
    event: RegionChangeEvent,
    _: StateRole
)

Hook to call when a region changed on this TiKV

impl<E: KvEngine> RoleObserver for Observer<E>

fn on_role_change(&self, ctx: &mut ObserverContext<'_>, role: StateRole)

Hook to call when role of a peer changes.