Trait s3handler::tokio_async::traits::DataPool[−][src]

pub trait DataPool: Send + Sync + Debug {
#[must_use]    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;

#[must_use]    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;

#[must_use]    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;

#[must_use]    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;

#[must_use]    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,
    { ... }

    fn check_scheme(&self, _scheme: &str) -> Result<(), Error> { ... }

    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,
    { ... }
}

Required methods

#[must_use]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, [src]

#[must_use]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, [src]

#[must_use]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, [src]

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

#[must_use]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, [src]

Loading content...

Provided methods

#[must_use]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, [src]

TODO: sync feature This method is for the sync feature

fn check_scheme(&self, _scheme: &str) -> Result<(), Error>[src]

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

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

Loading content...

Implementors

impl DataPool for FilePool[src]

impl DataPool for S3Pool[src]

Loading content...