Trait raftstore::coprocessor::CmdObserver[−][src]

pub trait CmdObserver<E>: Coprocessor {
    fn on_prepare_for_apply(
        &self, 
        cdc_id: &ObserveHandle, 
        rts_id: &ObserveHandle, 
        region_id: u64
    );

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

    fn on_flush_apply(&self, engine: E);
}

Required methods

fn on_prepare_for_apply(
    &self,
    cdc_id: &ObserveHandle,
    rts_id: &ObserveHandle,
    region_id: u64
)[src]

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
)[src]

Hook to call after applying a write request.

fn on_flush_apply(&self, engine: E)[src]

Hook to call after flushing writes to db.

Loading content...

Implementors

Loading content...