Struct raftstore::store::worker::read::LocalReader

pub struct LocalReader<C, E> where
    C: ProposalRouter<E::Snapshot>,
    E: KvEngine,  {
    store_id: Cell<Option<u64>>,
    store_meta: Arc<Mutex<StoreMeta>>,
    kv_engine: E,
    metrics: ReadMetrics,
    delegates: LruCache<u64, Arc<ReadDelegate>>,
    snap_cache: Option<Arc<E::Snapshot>>,
    cache_read_id: ThreadReadId,
    router: C,
}

Fields

store_id: Cell<Option<u64>>

store_meta: Arc<Mutex<StoreMeta>>

kv_engine: E

metrics: ReadMetrics

delegates: LruCache<u64, Arc<ReadDelegate>>

snap_cache: Option<Arc<E::Snapshot>>

cache_read_id: ThreadReadId

router: C

Implementations

impl<C, E> LocalReader<C, E> where
    C: ProposalRouter<E::Snapshot>,
    E: KvEngine, 

pub fn new(kv_engine: E, store_meta: Arc<Mutex<StoreMeta>>, router: C) -> Self

fn redirect(&mut self, cmd: RaftCommand<E::Snapshot>)

fn get_delegate(&mut self, region_id: u64) -> Option<Arc<ReadDelegate>>

fn pre_propose_raft_command(
    &mut self,
    req: &RaftCmdRequest
) -> Result<Option<(Arc<ReadDelegate>, RequestPolicy)>>

pub fn propose_raft_command(
    &mut self,
    read_id: Option<ThreadReadId>,
    req: RaftCmdRequest,
    cb: Callback<E::Snapshot>
)

pub fn read(
    &mut self,
    read_id: Option<ThreadReadId>,
    req: RaftCmdRequest,
    cb: Callback<E::Snapshot>
)

If read requests are received at the same RPC request, we can create one snapshot for all of them and check whether the time when the snapshot was created is in lease. We use ThreadReadId to figure out whether this RaftCommand comes from the same RPC request with the last RaftCommand which left a snapshot cached in LocalReader. ThreadReadId is composed by thread_id and a thread_local incremental sequence.

pub fn release_snapshot_cache(&mut self)

Trait Implementations

impl<C, E> Clone for LocalReader<C, E> where
    C: ProposalRouter<E::Snapshot> + Clone,
    E: KvEngine, 

fn clone(&self) -> Self

Returns a copy of the value.

pub fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

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

fn get_engine(&self) -> &E

fn get_snapshot(
    &mut self,
    create_time: 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>