Struct test_coprocessor::store::Store

pub struct Store<E: Engine> {
    store: SyncTestStorage<E>,
    current_ts: TimeStamp,
    last_committed_ts: TimeStamp,
    handles: Vec<Vec<u8>>,
}

A store that operates over MVCC and support transactions.

Fields

store: SyncTestStorage<E>

current_ts: TimeStamp

last_committed_ts: TimeStamp

handles: Vec<Vec<u8>>

Implementations

impl Store<RocksEngine>

pub fn new() -> Self

impl<E: Engine> Store<E>

pub fn from_engine(engine: E) -> Self

pub fn begin(&mut self)

pub fn put(&mut self, ctx: Context, kv: Vec<(Vec<u8>, Vec<u8>)>)

pub fn insert_into<'a>(&'a mut self, table: &'a Table) -> Insert<'a, E>

pub fn delete(&mut self, ctx: Context, keys: Vec<Vec<u8>>)

pub fn delete_from<'a>(&'a mut self, table: &'a Table) -> Delete<'a, E>

pub fn commit_with_ctx(&mut self, ctx: Context)

pub fn commit(&mut self)

pub fn get_engine(&self) -> E

pub fn export(&self) -> Vec<(Vec<u8>, Vec<u8>)>

Strip off committed MVCC information to get a final data view.

Notice: Only first 100000 records can be retrieved.

pub fn to_snapshot_store(&self) -> SnapshotStore<E::Snap>

Directly creates a SnapshotStore over current committed data.

pub fn to_fixture_store(&self) -> FixtureStore

Strip off committed MVCC information to create a FixtureStore.

Trait Implementations

impl<E: Engine> ToTxnStore<FixtureStore> for Store<E>

fn to_store(&self) -> FixtureStore

Converts to a specific Txn Store.

impl<E: Engine, S: Store> ToTxnStore<S> for Store<E>

default fn to_store(&self) -> S

Converts to a specific Txn Store.

impl<E: Engine> ToTxnStore<SnapshotStore<<E as Engine>::Snap>> for Store<E>

fn to_store(&self) -> SnapshotStore<<E as Engine>::Snap>

Converts to a specific Txn Store.