StorageService

remi

Trait StorageService 

Source 
pub trait StorageService: Send + Sync {
    type Error;

    // Required methods
    fn name(&self) -> Cow<'static, str>
       where Self: Sized;
    fn open<'life0, 'async_trait, P>(
        &'life0 self,
        path: P,
    ) -> Pin<Box<dyn Future<Output = Result<Option<Bytes>, Self::Error>> + Send + 'async_trait>>
       where Self: Sized + 'async_trait,
             P: 'async_trait + AsRef<Path> + Send,
             'life0: 'async_trait;
    fn blob<'life0, 'async_trait, P>(
        &'life0 self,
        path: P,
    ) -> Pin<Box<dyn Future<Output = Result<Option<Blob>, Self::Error>> + Send + 'async_trait>>
       where Self: Sized + 'async_trait,
             P: 'async_trait + AsRef<Path> + Send,
             'life0: 'async_trait;
    fn blobs<'life0, 'async_trait, P>(
        &'life0 self,
        path: Option<P>,
        options: Option<ListBlobsRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Vec<Blob>, Self::Error>> + Send + 'async_trait>>
       where Self: Sized + 'async_trait,
             P: 'async_trait + AsRef<Path> + Send,
             'life0: 'async_trait;
    fn delete<'life0, 'async_trait, P>(
        &'life0 self,
        path: P,
    ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>
       where Self: Sized + 'async_trait,
             P: 'async_trait + AsRef<Path> + Send,
             'life0: 'async_trait;
    fn exists<'life0, 'async_trait, P>(
        &'life0 self,
        path: P,
    ) -> Pin<Box<dyn Future<Output = Result<bool, Self::Error>> + Send + 'async_trait>>
       where Self: Sized + 'async_trait,
             P: 'async_trait + AsRef<Path> + Send,
             'life0: 'async_trait;
    fn upload<'life0, 'async_trait, P>(
        &'life0 self,
        path: P,
        options: UploadRequest,
    ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>
       where Self: Sized + 'async_trait,
             P: 'async_trait + AsRef<Path> + Send,
             'life0: 'async_trait;

    // Provided method
    fn init<'life0, 'async_trait>(
        &'life0 self,
    ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>
       where Self: Sized + 'async_trait,
             'life0: 'async_trait { ... }
}
Expand description

A storage service is a base primitive of remi-rs: it is the way to interact with the storage providers in ways that you would commonly use files: open, deleting, listing, etc.

Required Associated Types§

Source

type Error

Represents a generic error to use for errors that could be emitted when calling any function.

Required Methods§

Source

fn name(&self) -> Cow<'static, str>
where Self: Sized,

Returns the name of the storage service.

  • since 0.1.0
Source

fn open<'life0, 'async_trait, P>( &'life0 self, path: P, ) -> Pin<Box<dyn Future<Output = Result<Option<Bytes>, Self::Error>> + Send + 'async_trait>>
where Self: Sized + 'async_trait, P: 'async_trait + AsRef<Path> + Send, 'life0: 'async_trait,

Opens a file in the specified path and returns the contents as Bytes if it existed, otherwise None will be returned to indicate that file doesn’t exist.

  • since 0.1.0
Source

fn blob<'life0, 'async_trait, P>( &'life0 self, path: P, ) -> Pin<Box<dyn Future<Output = Result<Option<Blob>, Self::Error>> + Send + 'async_trait>>
where Self: Sized + 'async_trait, P: 'async_trait + AsRef<Path> + Send, 'life0: 'async_trait,

Open a file in the given path and returns a Blob structure if the path existed, otherwise None will be returned to indiciate that a file doesn’t exist.

  • since 0.1.0
Source

fn blobs<'life0, 'async_trait, P>( &'life0 self, path: Option<P>, options: Option<ListBlobsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Vec<Blob>, Self::Error>> + Send + 'async_trait>>
where Self: Sized + 'async_trait, P: 'async_trait + AsRef<Path> + Send, 'life0: 'async_trait,

Iterate over a list of files from a storage service and returns a Vec of Blobs.

  • since 0.1.0
Source

fn delete<'life0, 'async_trait, P>( &'life0 self, path: P, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>
where Self: Sized + 'async_trait, P: 'async_trait + AsRef<Path> + Send, 'life0: 'async_trait,

Deletes a file in a specified path. At the moment, () is returned but bool might be returned to indicate if it actually deleted itself or not.

  • since 0.1.0
Source

fn exists<'life0, 'async_trait, P>( &'life0 self, path: P, ) -> Pin<Box<dyn Future<Output = Result<bool, Self::Error>> + Send + 'async_trait>>
where Self: Sized + 'async_trait, P: 'async_trait + AsRef<Path> + Send, 'life0: 'async_trait,

Checks the existence of the file by the specified path.

  • since: 0.1.0
Source

fn upload<'life0, 'async_trait, P>( &'life0 self, path: P, options: UploadRequest, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>
where Self: Sized + 'async_trait, P: 'async_trait + AsRef<Path> + Send, 'life0: 'async_trait,

Does a file upload where it writes the byte array as one call and does not do chunking.

  • since: 0.1.0

Provided Methods§

Source

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

Optionally initialize this StorageService if it requires initialization, like creating a directory if it doesn’t exist.

  • since 0.1.0

Implementors§