Struct tikv::storage::kv::BTreeEngine

pub struct BTreeEngine {
    cf_names: Vec<&'static str, Global>,
    cf_contents: Vec<Arc<RwLock<BTreeMap<Key, Vec<u8, Global>>>>, Global>,
}

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<&'static str, Global>

cf_contents: Vec<Arc<RwLock<BTreeMap<Key, Vec<u8, Global>>>>, Global>

Implementations

impl BTreeEngine

pub fn new(cfs: &[&'static str]) -> BTreeEngine

pub fn get_cf(
    &self,
    cf: &'static str
) -> Arc<RwLock<BTreeMap<Key, Vec<u8, Global>>>>

Trait Implementations

impl Clone for BTreeEngine

pub 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

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

Formats the value using the given formatter.

impl Default for BTreeEngine

pub fn default() -> BTreeEngine

Returns the “default value” for a type.

impl Display for BTreeEngine

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

Formats the value using the given formatter.

impl Engine for BTreeEngine

type Snap = BTreeEngineSnapshot

type Local = PanicEngine

pub fn kv_engine(&self) -> PanicEngine

Local storage engine.

pub fn snapshot_on_kv_engine(
    &self,
    &[u8],
    &[u8]
) -> Result<<BTreeEngine as Engine>::Snap, Error>

pub fn modify_on_kv_engine(&self, Vec<Modify, Global>) -> Result<(), Error>

Write modifications into internal local engine directly.

pub fn async_write(
    &self,
    _ctx: &Context,
    batch: WriteData,
    cb: Box<dyn FnOnce((CbContext, Result<(), Error>)) + 'static + Send, Global>
) -> Result<(), Error>

pub fn async_snapshot(
    &self,
    _ctx: SnapContext<'_>,
    cb: Box<dyn FnOnce((CbContext, Result<<BTreeEngine as Engine>::Snap, Error>)) + 'static + Send, Global>
) -> Result<(), Error>

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

pub fn async_write_ext(
    &self,
    ctx: &Context,
    batch: WriteData,
    write_cb: Box<dyn FnOnce((CbContext, Result<(), Error>)) + 'static + Send, Global>,
    _proposed_cb: Option<Box<dyn FnOnce() + 'static + Send, Global>>,
    _committed_cb: Option<Box<dyn FnOnce() + 'static + Send, Global>>
) -> Result<(), Error>

Writes data to the engine asynchronously with some extensions.

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

pub fn release_snapshot(&self)

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

pub fn put(
    &self,
    ctx: &Context,
    key: Key,
    value: Vec<u8, Global>
) -> Result<(), Error>

pub fn put_cf(
    &self,
    ctx: &Context,
    cf: &'static str,
    key: Key,
    value: Vec<u8, Global>
) -> Result<(), Error>

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

pub fn delete_cf(
    &self,
    ctx: &Context,
    cf: &'static str,
    key: Key
) -> Result<(), Error>

pub fn get_mvcc_properties_cf(
    &self,
    &'static str,
    _safe_point: TimeStamp,
    _start: &[u8],
    _end: &[u8]
) -> Option<MvccProperties>