Struct tikv_kv::BTreeEngine

pub struct BTreeEngine {
    cf_names: Vec<CfName>,
    cf_contents: Vec<Arc<RwLock<BTreeMap<Key, Value>>>>,
}

The BTreeEngine(based on BTreeMap) is in memory and only used in tests and benchmarks. Note: The snapshot() and async_snapshot() methods are fake, the returned snapshot is not isolated, they will be affected by the later modifies.

Fields

cf_names: Vec<CfName>

cf_contents: Vec<Arc<RwLock<BTreeMap<Key, Value>>>>

Implementations

impl BTreeEngine

pub fn new(cfs: &[CfName]) -> Self

pub fn get_cf(&self, cf: CfName) -> Arc<RwLock<BTreeMap<Key, Value>>>

Trait Implementations

impl Clone for BTreeEngine

fn clone(&self) -> BTreeEngine

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for BTreeEngine

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for BTreeEngine

fn default() -> Self

Returns the “default value” for a type.

impl Display for BTreeEngine

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Engine for BTreeEngine

type Snap = BTreeEngineSnapshot

type Local = PanicEngine

fn kv_engine(&self) -> PanicEngine

Local storage engine.

fn snapshot_on_kv_engine(&self, _: &[u8], _: &[u8]) -> EngineResult<Self::Snap>

fn modify_on_kv_engine(&self, _: Vec<Modify>) -> EngineResult<()>

Write modifications into internal local engine directly.

fn async_write(
    &self,
    _ctx: &Context,
    batch: WriteData,
    cb: EngineCallback<()>
) -> EngineResult<()>

fn async_snapshot(
    &self,
    _ctx: SnapContext<'_>,
    cb: EngineCallback<Self::Snap>
) -> EngineResult<()>

warning: It returns a fake snapshot whose content will be affected by the later modifies!

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>