Struct MemoryLsmEngine 

pub struct MemoryLsmEngine { /* private fields */ }

In-memory LSM Engine

Implementations

impl MemoryLsmEngine

pub fn create() -> Result<Self>

Create a new in-memory database

pub fn create_with_schema(schema: TableSchema) -> Result<Self>

Create a new in-memory database with a table schema

pub fn put(&self, key: Key, item: Item) -> Result<()>

Put an item

pub fn get(&self, key: &Key) -> Result<Option<Item>>

Get an item

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

Delete an item

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

Flush all stripes

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

Clear all data (for testing)

pub fn len(&self) -> usize

Get the number of items in memory (approximate)

pub fn is_empty(&self) -> bool

Check if empty

pub fn query(&self, params: QueryParams) -> Result<QueryResult>

Query items within a partition

pub fn scan(&self, params: ScanParams) -> Result<ScanResult>

Scan all items across all stripes

pub fn update( &self, key: &Key, actions: &[UpdateAction], context: &ExpressionContext, ) -> Result<Item>

Update an item using update expression

pub fn update_conditional( &self, key: &Key, actions: &[UpdateAction], condition: &Expr, context: &ExpressionContext, ) -> Result<Item>

Update an item with a condition expression

pub fn put_conditional( &self, key: Key, item: Item, condition: &Expr, context: &ExpressionContext, ) -> Result<()>

Put an item with a condition expression

pub fn delete_conditional( &self, key: Key, condition: &Expr, context: &ExpressionContext, ) -> Result<()>

Delete an item with a condition expression

pub fn batch_get(&self, keys: &[Key]) -> Result<HashMap<Key, Option<Item>>>

Batch get multiple items

pub fn batch_write(&self, operations: &[(Key, Option<Item>)]) -> Result<usize>

Batch write multiple items

pub fn transact_get(&self, keys: &[Key]) -> Result<Vec<Option<Item>>>

Transaction get - read multiple items atomically

pub fn transact_write( &self, operations: &[(Key, TransactWriteOperation)], context: &ExpressionContext, ) -> Result<usize>

Transaction write - write multiple items atomically with conditions

Trait Implementations

impl Clone for MemoryLsmEngine

fn clone(&self) -> MemoryLsmEngine

Returns a duplicate of the value.

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

Performs copy-assignment from source.