Struct MemoryKV 

pub struct MemoryKV { /* private fields */ }

An in-memory key-value store.

Implementations

impl MemoryKV

pub fn new() -> Self

Creates a new, purely transient in-memory KV store.

pub fn memory_stats(&self) -> MemoryStats

Returns current in-memory usage statistics.

pub fn new_with_limit(limit: Option<usize>) -> Self

Creates a new in-memory KV store with an optional memory limit.

pub fn open(path: &Path) -> Result<Self>

Opens a persistent in-memory KV store from a file path.

pub fn flush(&self) -> Result<()>

Flushes the in-memory data to an SSTable.

Trait Implementations

impl Clone for MemoryKV

fn clone(&self) -> MemoryKV

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for MemoryKV

fn default() -> Self

Returns the “default value” for a type.

impl KVStore for MemoryKV

type Transaction<'a> = MemoryTransaction<'a>

The transaction type for this store.

type Manager<'a> = &'a MemoryTxnManager

The transaction manager for this store.

fn txn_manager(&self) -> Self::Manager<'_>

Returns the transaction manager for this store.

fn begin(&self, mode: TxnMode) -> Result<Self::Transaction<'_>>

A convenience method to begin a new transaction.

fn runtime_stats(&self) -> Option<RuntimeStats>

Returns a point-in-time runtime statistics snapshot, when supported.

fn set_memory_limit_bytes(&self, limit: Option<usize>) -> Result<()>

Sets the memory limit in bytes, when supported.

fn read_at_capability(&self) -> ReadAtCapability

Reports whether this backend can open a retained snapshot at a caller-provided cluster data epoch.

fn begin_read_at( &self, point: &ReadAtPoint, ) -> ReadAtResult<Self::Transaction<'_>>

Opens a read-only snapshot at a previously fenced cluster read point.

fn set_cache_capacity_bytes(&self, _capacity: usize) -> Result<()>

Sets the cache capacity in bytes, when supported.

fn clear_cache(&self) -> Result<usize>

Clears the cache and returns the number of bytes removed.

impl OwnedKVStore for MemoryKV

fn begin_owned_kv_transaction( self: Arc<Self>, mode: TxnMode, ) -> Result<Box<dyn OwnedKVTransaction>>

Begin a transaction whose lifetime is independent of the Arc<Self> call site.