Struct persist::s3::S3Blob

pub struct S3Blob {
    core: S3BlobCore,
}

Implementation of Blob backed by S3.

Fields

core: S3BlobCore

Implementations

impl S3Blob

const LOCKFILE_KEY: &'static str

async fn lock(&mut self, new_lock: LockInfo) -> Result<(), Error>

async fn set_single_part(&self, key: &str, value: Vec<u8>) -> Result<(), Error>

async fn set_multi_part(&self, key: &str, value: Vec<u8>) -> Result<(), Error>

Trait Implementations

impl Blob for S3Blob

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

Returns a new S3Blob which stores objects under the given bucket and prefix.

All calls to methods on S3Blob must be from a thread with a tokio runtime guard.

type Config = S3BlobConfig

The configuration necessary to open this type of storage.

type Read = S3BlobRead

The corresponding BlobRead implementation.

fn open_read(config: S3BlobConfig) -> Result<S3BlobRead, 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 S3Blob

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 S3Blob

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

Formats the value using the given formatter.