Trait raftstore::store::worker::read::ReadExecutor[−][src]

pub trait ReadExecutor<E: KvEngine> {
    fn get_engine(&self) -> &E;

    fn get_snapshot(&mut self, ts: Option<ThreadReadId>) -> Arc<E::Snapshot>;

    fn get_value(&self, req: &Request, region: &Region) -> Result<Response> { ... }

    fn execute(
        &mut self, 
        msg: &RaftCmdRequest, 
        region: &Arc<Region>, 
        read_index: Option<u64>, 
        ts: Option<ThreadReadId>
    ) -> ReadResponse<E::Snapshot> { ... }
}

Required methods

fn get_engine(&self) -> &E[src]

fn get_snapshot(&mut self, ts: Option<ThreadReadId>) -> Arc<E::Snapshot>[src]

Loading content...

Provided methods

fn get_value(&self, req: &Request, region: &Region) -> Result<Response>[src]

fn execute(
    &mut self,
    msg: &RaftCmdRequest,
    region: &Arc<Region>,
    read_index: Option<u64>,
    ts: Option<ThreadReadId>
) -> ReadResponse<E::Snapshot>[src]

Loading content...

Implementors

impl<C, E> ReadExecutor<E> for LocalReader<C, E> where
    C: ProposalRouter<E::Snapshot>,
    E: KvEngine, [src]

impl<EK, ER, T> ReadExecutor<EK> for PollContext<EK, ER, T> where
    EK: KvEngine,
    ER: RaftEngine, [src]

Loading content...