Struct mz_persist::s3::S3BlobMulti
source · [−]pub struct S3BlobMulti {
client: S3Client,
bucket: String,
prefix: String,
max_keys: i32,
multipart_config: MultipartConfig,
}
Expand description
Implementation of BlobMulti backed by S3.
Fields
client: S3Client
bucket: String
prefix: String
max_keys: i32
multipart_config: MultipartConfig
Implementations
sourceimpl S3BlobMulti
impl S3BlobMulti
sourcepub async fn open(config: S3BlobConfig) -> Result<Self, ExternalError>
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
sourceimpl S3BlobMulti
impl S3BlobMulti
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
sourceimpl BlobMulti for S3BlobMulti
impl BlobMulti for S3BlobMulti
sourcefn get<'life0, 'life1, 'async_trait>(
&'life0 self,
_deadline: Instant,
key: &'life1 str
) -> Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>, ExternalError>> + Send + 'async_trait>> where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
fn get<'life0, 'life1, 'async_trait>(
&'life0 self,
_deadline: Instant,
key: &'life1 str
) -> Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>, ExternalError>> + Send + 'async_trait>> where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
Returns a reference to the value corresponding to the key.
sourcefn list_keys<'life0, 'async_trait>(
&'life0 self,
_deadline: Instant
) -> Pin<Box<dyn Future<Output = Result<Vec<String>, ExternalError>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn list_keys<'life0, 'async_trait>(
&'life0 self,
_deadline: Instant
) -> Pin<Box<dyn Future<Output = Result<Vec<String>, ExternalError>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
List all of the keys in the map.
sourcefn set<'life0, 'life1, 'async_trait>(
&'life0 self,
_deadline: Instant,
key: &'life1 str,
value: Bytes,
_atomic: Atomicity
) -> Pin<Box<dyn Future<Output = Result<(), ExternalError>> + Send + 'async_trait>> where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
fn set<'life0, 'life1, 'async_trait>(
&'life0 self,
_deadline: Instant,
key: &'life1 str,
value: Bytes,
_atomic: Atomicity
) -> Pin<Box<dyn Future<Output = Result<(), ExternalError>> + Send + 'async_trait>> where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
Inserts a key-value pair into the map. Read more
Auto Trait Implementations
impl !RefUnwindSafe for S3BlobMulti
impl Send for S3BlobMulti
impl Sync for S3BlobMulti
impl Unpin for S3BlobMulti
impl !UnwindSafe for S3BlobMulti
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> FutureExt for T
impl<T> FutureExt for T
sourcefn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
sourcefn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
sourcefn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message T
in a tonic::Request
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more