Struct persist::unreliable::UnreliableBlob

pub struct UnreliableBlob<B> {
    handle: UnreliableHandle,
    blob: B,
}

An unreliable delegate to Blob.

Fields

handle: UnreliableHandle

blob: B

Implementations

impl<B: BlobRead> UnreliableBlob<B>

pub fn new(blob: B) -> (Self, UnreliableHandle)

Returns a new UnreliableBlob and a handle for controlling it.

pub fn from_handle(blob: B, handle: UnreliableHandle) -> Self

Returns a new UnreliableLog sharing the given handle.

Trait Implementations

impl<B> Blob for UnreliableBlob<B> where
    B: Blob + Sync,
    B::Read: Sync, 

type Config = UnreliableBlobConfig<B>

The configuration necessary to open this type of storage.

type Read = UnreliableBlob<B::Read>

The corresponding BlobRead implementation.

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

Opens the given location for exclusive read-write access.

fn open_read(
    config: UnreliableBlobConfig<B>
) -> Result<UnreliableBlob<B::Read>, 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<B: BlobRead + Sync> BlobRead for UnreliableBlob<B>

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<B: Debug> Debug for UnreliableBlob<B>

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

Formats the value using the given formatter.