Struct S3Endpoint 

pub struct S3Endpoint { /* private fields */ }

Implementations

impl S3Endpoint

pub fn connect(secret: &S3Secret) -> Result<Client, Error>

pub fn connection(&self) -> Arc<Client>

pub fn bucket(&self) -> &str

impl S3Endpoint

pub async fn start_multi_part_s3_upload( &self, path: &str, ) -> Result<String, Error>

pub async fn upload_s3_part( &self, path: &str, upload_id: &str, part_number: i32, data: Vec<u8>, ) -> Result<CompletedPart, Error>

pub async fn complete_s3_upload( &self, path: &str, upload_id: &str, parts: Vec<CompletedPart>, ) -> Result<(), Error>

Trait Implementations

impl Clone for S3Endpoint

fn clone(&self) -> S3Endpoint

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl StreamReader for S3Endpoint

fn read_stream<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, path: &'life1 str, sender: Sender<StreamData>, channel: &'life2 dyn ReaderNotification, ) -> Pin<Box<dyn Future<Output = Result<u64, Error>> + Send + 'async_trait>>

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

impl StreamWriter for S3Endpoint

fn write_stream<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, path: &'life1 str, receiver: Receiver<StreamData>, job_and_notification: &'life2 dyn WriteJob, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

impl TreeList for S3Endpoint

fn list<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, root_path: &'life1 str, prefix: Option<&'life2 str>, ) -> Pin<Box<dyn Future<Output = Result<TreeItems, Error>> + Send + 'async_trait>>

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

List items in a directory

fn list_tree<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, root_path: &'life1 str, prefix: Option<&'life2 str>, ) -> Pin<Box<dyn Future<Output = Result<TreeItems, Error>> + Send + 'async_trait>>

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

List items recursively from a directory

fn get_absolute_prefix( root_path: &str, prefix: Option<&str>, separator: char, ) -> String

fn get_absolute_path( root_path: &str, prefix: Option<&str>, separator: char, ) -> String

fn get_delimiter(separator: char) -> String

fn get_root_path(root_path: &str, separator: char) -> String

impl TryFrom<&S3Secret> for S3Endpoint

type Error = Error

The type returned in the event of a conversion error.

fn try_from(secret: &S3Secret) -> Result<Self, Self::Error>

Performs the conversion.