Trait tikv::storage::Store[−][src]

pub trait Store: Send {
    type Scanner: Scanner;
    fn get(
        &self, 
        key: &Key, 
        statistics: &mut Statistics
    ) -> Result<Option<Value>>;

    fn incremental_get(&mut self, key: &Key) -> Result<Option<Value>>;

    fn incremental_get_take_statistics(&mut self) -> Statistics;

    fn incremental_get_met_newer_ts_data(&self) -> NewerTsCheckState;

    fn batch_get(
        &self, 
        keys: &[Key], 
        statistics: &mut Statistics
    ) -> Result<Vec<Result<Option<Value>>>>;

    fn scanner(
        &self, 
        desc: bool, 
        key_only: bool, 
        check_has_newer_ts_data: bool, 
        lower_bound: Option<Key>, 
        upper_bound: Option<Key>
    ) -> Result<Self::Scanner>;
}

Associated Types

type Scanner: Scanner[src][−]

The scanner type returned by scanner().

Required methods

fn get(&self, key: &Key, statistics: &mut Statistics) -> Result<Option<Value>>[src][−]

Fetch the provided key.

fn incremental_get(&mut self, key: &Key) -> Result<Option<Value>>[src][−]

Re-use last cursor to incrementally (if possible) fetch the provided key.

fn incremental_get_take_statistics(&mut self) -> Statistics[src][−]

Take the statistics. Currently only available for incremental_get.

fn incremental_get_met_newer_ts_data(&self) -> NewerTsCheckState[src][−]

Whether there was data > ts during previous incremental gets.

fn batch_get(
    &self,
    keys: &[Key],
    statistics: &mut Statistics
) -> Result<Vec<Result<Option<Value>>>>[src][−]

Fetch the provided set of keys.

fn scanner(
    &self,
    desc: bool,
    key_only: bool,
    check_has_newer_ts_data: bool,
    lower_bound: Option<Key>,
    upper_bound: Option<Key>
) -> Result<Self::Scanner>[src][−]

Retrieve a scanner over the bounds.

Implementors

impl Store for FixtureStore[src][+]

type Scanner = FixtureStoreScanner

impl<S: Snapshot> Store for SnapshotStore<S>[src][+]

type Scanner = MvccScanner<S>