Struct persist::mem::MemBlob

pub struct MemBlob {
    core: Option<Arc<Mutex<MemBlobCore>>>,
}

An in-memory implementation of Blob.

Fields

core: Option<Arc<Mutex<MemBlobCore>>>

Implementations

impl MemBlob

pub fn new(lock_info: LockInfo) -> Self

Constructs a new, empty MemBlob.

fn core_lock<'c>(&'c self) -> Result<MutexGuard<'c, MemBlobCore>, Error>

Trait Implementations

impl Blob for MemBlob

type Config = MemBlobConfig

The configuration necessary to open this type of storage.

type Read = MemBlobRead

The corresponding BlobRead implementation.

fn open_exclusive(
    config: MemBlobConfig,
    lock_info: LockInfo
) -> Result<Self, Error>

Opens the given location for exclusive read-write access.

fn open_read(config: MemBlobConfig) -> Result<MemBlobRead, Error>

Opens the given location for non-exclusive read-only access.

fn set<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    key: &'life1 str,
    value: Vec<u8>,
    _atomic: Atomicity
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Inserts a key-value pair into the map.

fn delete<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    key: &'life1 str
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Remove a key from the map.

impl BlobRead for MemBlob

fn get<'life0, 'life1, 'async_trait>(
    &'life0 self,
    key: &'life1 str
) -> Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>, Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Returns a reference to the value corresponding to the key.

fn list_keys<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = Result<Vec<String>, Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

List all of the keys in the map.

fn close<'life0, 'async_trait>(
    &'life0 mut self
) -> Pin<Box<dyn Future<Output = Result<bool, Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Synchronously closes the blob, causing all future commands to error.

impl Debug for MemBlob

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

Formats the value using the given formatter.

impl Drop for MemBlob

fn drop(&mut self)

Executes the destructor for this type.