Trait raftstore::router::LocalReadRouter[][src]

pub trait LocalReadRouter<EK>: Send + Clone where
    EK: KvEngine
{ fn read(
        &self,
        read_id: Option<ThreadReadId>,
        req: RaftCmdRequest,
        cb: Callback<EK::Snapshot>
    ) -> RaftStoreResult<()>;
fn release_snapshot_cache(&self); }

Required methods

fn read(
    &self,
    read_id: Option<ThreadReadId>,
    req: RaftCmdRequest,
    cb: Callback<EK::Snapshot>
) -> RaftStoreResult<()>
[src]

fn release_snapshot_cache(&self)[src]

Loading content...

Implementors

impl<EK: KvEngine, ER: RaftEngine> LocalReadRouter<EK> for ServerRaftStoreRouter<EK, ER>[src]

Loading content...