Struct s3handler::tokio_async::primitives::S3Pool

pub struct S3Pool {
    pub host: String,
    pub secure: bool,
    pub url_style: UrlStyle,
    pub part_size: Option<usize>,
    pub authorizer: Box<dyn Authorizer>,
    // some fields omitted
}

Fields

host: String

secure: bool

To use https or not, please note that integrity is secured by S3 protocol. If the confidentiality is not under concerned, the http is good.

url_style: UrlStyle

Default will be Path style, because Virtual hosted URLs may be supported for non-SSL requests only.

part_size: Option<usize>

The part size for multipart, default disabled. If Some the pull/push will check out the object size first and do mulitpart If None download and upload will be in one part

authorizer: Box<dyn Authorizer>

Implementations

impl S3Pool

pub fn bucket(self, bucket_name: &str) -> Canal

pub fn resource(self, s3_object: S3Object) -> Canal

pub fn new(host: String) -> Self

pub fn aws_v2(mut self: Self, access_key: String, secret_key: String) -> Self

pub fn aws_v4(
    mut self: Self,
    access_key: String,
    secret_key: String,
    region: String
) -> Self

pub fn endpoint_and_virturalhost(
    &self,
    desc: S3Object
) -> (String, Option<String>)

pub fn init_headers(
    &self,
    headers: &mut HeaderMap,
    now: &DateTime<Utc>,
    virturalhost: Option<String>
)

pub fn part_size(mut self: Self, s: usize) -> Self

Trait Implementations

impl Clone for S3Pool

fn clone(&self) -> S3Pool

Returns a copy of the value.

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

Performs copy-assignment from source.

impl DataPool for S3Pool

fn push<'life0, 'async_trait>(
    &'life0 self,
    desc: S3Object,
    object: Bytes
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn pull<'life0, 'async_trait>(
    &'life0 self,
    desc: S3Object
) -> Pin<Box<dyn Future<Output = Result<Bytes, Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn list<'life0, 'async_trait>(
    &'life0 self,
    index: Option<S3Object>
) -> Pin<Box<dyn Future<Output = Result<Box<dyn S3Folder>, Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

The index will be treated as a folder object to filter the list results

fn remove<'life0, 'async_trait>(
    &'life0 self,
    desc: S3Object
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn check_scheme(&self, scheme: &str) -> Result<(), Error>

fn fetch_meta<'life0, 'life1, 'async_trait>(
    &'life0 self,
    desc: &'life1 mut S3Object
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

TODO: sync feature This method is for the sync feature

fn as_base_from(self, resource_location: &str) -> Result<Canal, Error> where
    Self: Sized + 'static, 

fn as_target_to(self, resource_location: &str) -> Result<Canal, Error> where
    Self: Sized + 'static, 

impl Debug for S3Pool

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

Formats the value using the given formatter.

impl From<&'_ Handler<'_>> for S3Pool

fn from(handler: &Handler<'_>) -> Self

Performs the conversion.

impl From<Handler<'_>> for S3Pool

fn from(handler: Handler<'_>) -> Self

Performs the conversion.

impl S3Folder for S3Pool

fn next_object<'life0, 'async_trait>(
    &'life0 mut self
) -> Pin<Box<dyn Future<Output = Result<Option<S3Object>, Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait,