Struct tikv_kv::mock_engine::MockEngine

pub struct MockEngine {
    base: RocksEngine,
    expected_modifies: Option<Arc<ExpectedWriteList>>,
    last_modifies: Arc<Mutex<Vec<Vec<Modify>>>>,
}

A mock engine is a simple wrapper around RocksEngine but with the ability to assert the modifies, the callback used, and other aspects during interaction with the engine

Fields

base: RocksEngine

expected_modifies: Option<Arc<ExpectedWriteList>>

last_modifies: Arc<Mutex<Vec<Vec<Modify>>>>

Implementations

impl MockEngine

pub fn take_last_modifies(&self) -> Vec<Vec<Modify>>

Trait Implementations

impl Clone for MockEngine

fn clone(&self) -> MockEngine

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Engine for MockEngine

type Snap = <RocksEngine as Engine>::Snap

type Local = <RocksEngine as Engine>::Local

fn kv_engine(&self) -> Self::Local

Local storage engine.

fn snapshot_on_kv_engine(
    &self,
    start_key: &[u8],
    end_key: &[u8]
) -> Result<Self::Snap>

fn modify_on_kv_engine(&self, modifies: Vec<Modify>) -> Result<()>

Write modifications into internal local engine directly.

fn async_snapshot(
    &self,
    ctx: SnapContext<'_>,
    cb: Callback<Self::Snap>
) -> Result<()>

fn async_write(
    &self,
    ctx: &Context,
    batch: WriteData,
    write_cb: Callback<()>
) -> Result<()>

fn async_write_ext(
    &self,
    ctx: &Context,
    batch: WriteData,
    write_cb: Callback<()>,
    proposed_cb: Option<ExtCallback>,
    committed_cb: Option<ExtCallback>
) -> Result<()>

Writes data to the engine asynchronously with some extensions.

fn write(&self, ctx: &Context, batch: WriteData) -> Result<()>

fn release_snapshot(&self)

fn snapshot(&self, ctx: SnapContext<'_>) -> Result<Self::Snap>

fn put(&self, ctx: &Context, key: Key, value: Value) -> Result<()>

fn put_cf(
    &self,
    ctx: &Context,
    cf: CfName,
    key: Key,
    value: Value
) -> Result<()>

fn delete(&self, ctx: &Context, key: Key) -> Result<()>

fn delete_cf(&self, ctx: &Context, cf: CfName, key: Key) -> Result<()>

fn get_mvcc_properties_cf(
    &self,
    _: CfName,
    _safe_point: TimeStamp,
    _start: &[u8],
    _end: &[u8]
) -> Option<MvccProperties>