Trait raftstore::store::peer::RequestInspector

pub trait RequestInspector {
    fn has_applied_to_current_term(&mut self) -> bool;
    fn inspect_lease(&mut self) -> LeaseState;

    fn inspect(&mut self, req: &RaftCmdRequest) -> Result<RequestPolicy> { ... }
}

RequestInspector makes RequestPolicy for requests.

Required methods

fn has_applied_to_current_term(&mut self) -> bool

Has the current term been applied?

fn inspect_lease(&mut self) -> LeaseState

Inspects its lease.

Loading content...

Provided methods

fn inspect(&mut self, req: &RaftCmdRequest) -> Result<RequestPolicy>

Inspect a request, return a policy that tells us how to handle the request.

Loading content...

Implementors

impl<'r, 'm> RequestInspector for Inspector<'r, 'm>

fn has_applied_to_current_term(&mut self) -> bool

fn inspect_lease(&mut self) -> LeaseState

impl<EK, ER> RequestInspector for Peer<EK, ER> where
    EK: KvEngine,
    ER: RaftEngine, 

fn has_applied_to_current_term(&mut self) -> bool

fn inspect_lease(&mut self) -> LeaseState

Loading content...