Trait s3_ext::S3Ext[−][src]

pub trait S3Ext {
#[must_use]    fn download_to_file<'life0, 'async_trait, F>(
        &'life0 self, 
        source: GetObjectRequest, 
        target: F
    ) -> Pin<Box<dyn Future<Output = S3ExtResult<GetObjectOutput>> + Send + 'async_trait>>
    where
        F: AsRef<Path> + Send,
        F: 'async_trait,
        'life0: 'async_trait,
        Self: 'async_trait;

#[must_use]    fn upload_from_file<'life0, 'async_trait, F>(
        &'life0 self, 
        source: F, 
        target: PutObjectRequest
    ) -> Pin<Box<dyn Future<Output = S3ExtResult<PutObjectOutput>> + Send + 'async_trait>>
    where
        F: AsRef<Path> + Send,
        F: 'async_trait,
        'life0: 'async_trait,
        Self: 'async_trait;

#[must_use]    fn upload_from_file_multipart<'life0, 'life1, 'async_trait, F>(
        &'life0 self, 
        source: F, 
        target: &'life1 PutObjectRequest, 
        part_size: usize
    ) -> Pin<Box<dyn Future<Output = S3ExtResult<CompleteMultipartUploadOutput>> + Send + 'async_trait>>
    where
        F: AsRef<Path> + Send,
        F: 'async_trait,
        'life0: 'async_trait,
        'life1: 'async_trait,
        Self: 'async_trait;

#[must_use]    fn download<'life0, 'life1, 'async_trait, W>(
        &'life0 self, 
        source: GetObjectRequest, 
        target: &'life1 mut W
    ) -> Pin<Box<dyn Future<Output = S3ExtResult<GetObjectOutput>> + Send + 'async_trait>>
    where
        W: AsyncWrite + Unpin + Send,
        W: 'async_trait,
        'life0: 'async_trait,
        'life1: 'async_trait,
        Self: 'async_trait;

#[must_use]    fn upload<'life0, 'life1, 'async_trait, R>(
        &'life0 self, 
        source: &'life1 mut R, 
        target: PutObjectRequest
    ) -> Pin<Box<dyn Future<Output = S3ExtResult<PutObjectOutput>> + Send + 'async_trait>>
    where
        R: AsyncRead + Unpin + Send,
        R: 'async_trait,
        'life0: 'async_trait,
        'life1: 'async_trait,
        Self: 'async_trait;

#[must_use]    fn upload_multipart<'life0, 'life1, 'life2, 'async_trait, R>(
        &'life0 self, 
        source: &'life1 mut R, 
        target: &'life2 PutObjectRequest, 
        part_size: usize
    ) -> Pin<Box<dyn Future<Output = S3ExtResult<CompleteMultipartUploadOutput>> + Send + 'async_trait>>
    where
        R: AsyncRead + Unpin + Send,
        R: 'async_trait,
        'life0: 'async_trait,
        'life1: 'async_trait,
        'life2: 'async_trait,
        Self: 'async_trait;

    fn stream_objects(&self, bucket: &str) -> ObjectStream;

    fn stream_objects_with_prefix(
        &self, 
        bucket: &str, 
        prefix: &str
    ) -> ObjectStream;

    fn stream_get_objects(&self, bucket: &str) -> GetObjectStream;

    fn stream_get_objects_with_prefix(
        &self, 
        bucket: &str, 
        prefix: &str
    ) -> GetObjectStream;
}

Required methods

#[must_use]fn download_to_file<'life0, 'async_trait, F>(
    &'life0 self,
    source: GetObjectRequest,
    target: F
) -> Pin<Box<dyn Future<Output = S3ExtResult<GetObjectOutput>> + Send + 'async_trait>> where
    F: AsRef<Path> + Send,
    F: 'async_trait,
    'life0: 'async_trait,
    Self: 'async_trait, [src]

Get object and write it to file target

#[must_use]fn upload_from_file<'life0, 'async_trait, F>(
    &'life0 self,
    source: F,
    target: PutObjectRequest
) -> Pin<Box<dyn Future<Output = S3ExtResult<PutObjectOutput>> + Send + 'async_trait>> where
    F: AsRef<Path> + Send,
    F: 'async_trait,
    'life0: 'async_trait,
    Self: 'async_trait, [src]

Upload content of file to S3

Caveats

The current implementation is incomplete. For now, the following limitation applies:

  • The full content of source is copied into memory.

#[must_use]fn upload_from_file_multipart<'life0, 'life1, 'async_trait, F>(
    &'life0 self,
    source: F,
    target: &'life1 PutObjectRequest,
    part_size: usize
) -> Pin<Box<dyn Future<Output = S3ExtResult<CompleteMultipartUploadOutput>> + Send + 'async_trait>> where
    F: AsRef<Path> + Send,
    F: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, [src]

Upload content of file to S3 using multi-part upload

Caveats

The current implementation is incomplete. For now, the following limitation applies:

  • The full content of a part is copied into memory.

#[must_use]fn download<'life0, 'life1, 'async_trait, W>(
    &'life0 self,
    source: GetObjectRequest,
    target: &'life1 mut W
) -> Pin<Box<dyn Future<Output = S3ExtResult<GetObjectOutput>> + Send + 'async_trait>> where
    W: AsyncWrite + Unpin + Send,
    W: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, [src]

Get object and write it to target

#[must_use]fn upload<'life0, 'life1, 'async_trait, R>(
    &'life0 self,
    source: &'life1 mut R,
    target: PutObjectRequest
) -> Pin<Box<dyn Future<Output = S3ExtResult<PutObjectOutput>> + Send + 'async_trait>> where
    R: AsyncRead + Unpin + Send,
    R: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, [src]

Read source and upload it to S3

Caveats

The current implementation is incomplete. For now, the following limitation applies:

  • The full content of source is copied into memory.

#[must_use]fn upload_multipart<'life0, 'life1, 'life2, 'async_trait, R>(
    &'life0 self,
    source: &'life1 mut R,
    target: &'life2 PutObjectRequest,
    part_size: usize
) -> Pin<Box<dyn Future<Output = S3ExtResult<CompleteMultipartUploadOutput>> + Send + 'async_trait>> where
    R: AsyncRead + Unpin + Send,
    R: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,
    'life2: 'async_trait,
    Self: 'async_trait, [src]

Read source and upload it to S3 using multi-part upload

Caveats

The current implementation is incomplete. For now, the following limitation applies:

  • The full content of a part is copied into memory.

fn stream_objects(&self, bucket: &str) -> ObjectStream[src]

Stream over all objects Access to an iterator-like object ObjectIter can be obtained by calling into_iter()

Objects are lexicographically sorted by their key.

fn stream_objects_with_prefix(&self, bucket: &str, prefix: &str) -> ObjectStream[src]

Stream over objects with given prefix

Objects are lexicographically sorted by their key.

fn stream_get_objects(&self, bucket: &str) -> GetObjectStream[src]

Stream over all objects; fetching objects as needed

Objects are lexicographically sorted by their key.

fn stream_get_objects_with_prefix(
    &self,
    bucket: &str,
    prefix: &str
) -> GetObjectStream[src]

Stream over objects with given prefix; fetching objects as needed

Objects are lexicographically sorted by their key.

Loading content...

Implementations on Foreign Types

impl S3Ext for S3Client[src]

Loading content...

Implementors

Loading content...