Trait raftstore::coprocessor::QueryObserver[][src]

pub trait QueryObserver: Coprocessor {
    fn pre_propose_query(
        &self,
        _: &mut ObserverContext<'_>,
        _: &mut Vec<Request>
    ) -> Result<()> { ... }
fn pre_apply_query(&self, _: &mut ObserverContext<'_>, _: &[Request]) { ... }
fn post_apply_query(&self, _: &mut ObserverContext<'_>, _: &mut Cmd) { ... } }

Provided methods

fn pre_propose_query(
    &self,
    _: &mut ObserverContext<'_>,
    _: &mut Vec<Request>
) -> Result<()>
[src]

Hook to call before proposing write request.

We don’t propose read request, hence there is no hook for it yet.

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

Hook to call before applying write request.

fn post_apply_query(&self, _: &mut ObserverContext<'_>, _: &mut Cmd)[src]

Hook to call after applying write request.

Loading content...

Implementors

Loading content...