Struct mz_persist::s3::S3Blob

pub struct S3Blob {
    metrics: S3BlobMetrics,
    client: Client,
    bucket: String,
    prefix: String,
    max_keys: i32,
    multipart_config: MultipartConfig,
    cfg: Arc<ConfigSet>,
    is_cc_active: bool,
}

Implementation of Blob backed by S3.

Fields

metrics: S3BlobMetrics

client: Client

bucket: String

prefix: String

max_keys: i32

multipart_config: MultipartConfig

cfg: Arc<ConfigSet>

is_cc_active: bool

Implementations

impl S3Blob

pub async fn open(config: S3BlobConfig) -> Result<Self, ExternalError>

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

fn get_path(&self, key: &str) -> String

impl S3Blob

async fn set_single_part( &self, key: &str, value: Bytes, ) -> Result<(), ExternalError>

async fn set_multi_part( &self, key: &str, value: Bytes, ) -> Result<(), ExternalError>

Trait Implementations

impl Blob for S3Blob

fn get<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<SegmentedBytes>, ExternalError>> + Send + 'async_trait>>

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

Returns a reference to the value corresponding to the key.

fn list_keys_and_metadata<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, key_prefix: &'life1 str, f: &'life2 mut (dyn FnMut(BlobMetadata<'_>) + Send + Sync), ) -> Pin<Box<dyn Future<Output = Result<(), ExternalError>> + Send + 'async_trait>>

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

List all of the keys in the map with metadata about the entry.

fn set<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, value: Bytes, ) -> Pin<Box<dyn Future<Output = Result<(), ExternalError>> + Send + 'async_trait>>

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

Inserts a key-value pair into the map.

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<usize>, ExternalError>> + Send + 'async_trait>>

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

Remove a key from the map.

fn restore<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), ExternalError>> + Send + 'async_trait>>

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

Restores a previously-deleted key to the map, if possible.

impl Debug for S3Blob

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

Formats the value using the given formatter.