Enum Storage 

pub enum Storage {
    Memory(MemoryStorage),
    Lsm(LsmTreeStorage),
}

Storage engine wrapper enum to support multiple storage types

Variants

Memory(MemoryStorage)

Lsm(LsmTreeStorage)

Trait Implementations

impl Clone for Storage

fn clone(&self) -> Storage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl StorageEngine for Storage

fn put<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, key: &'life1 Key, value: &'life2 CipherBlob, ) -> Pin<Box<dyn Future<Output = CoreResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Write data with fsync guarantee

fn get<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 Key, ) -> Pin<Box<dyn Future<Output = CoreResult<Option<CipherBlob>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Read data, returns None if key doesn’t exist

fn atomic_update<'life0, 'life1, 'async_trait, F>( &'life0 self, key: &'life1 Key, f: F, ) -> Pin<Box<dyn Future<Output = CoreResult<()>> + Send + 'async_trait>>

where F: Fn(&CipherBlob) -> CoreResult<CipherBlob> + Send + Sync + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Atomic update operation (Read-Modify-Write)

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 Key, ) -> Pin<Box<dyn Future<Output = CoreResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Delete a key

fn range<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, start: &'life1 Key, end: &'life2 Key, ) -> Pin<Box<dyn Future<Output = CoreResult<Vec<(Key, CipherBlob)>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Range scan from start (inclusive) to end (exclusive)

fn keys<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = CoreResult<Vec<Key>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get all keys in the storage (for debugging/admin)

fn flush<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = CoreResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Flush all pending writes to disk

fn close<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = CoreResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Close the storage engine gracefully

fn contains<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 Key, ) -> Pin<Box<dyn Future<Output = Result<bool, AmateRSError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Check if a key exists