Struct OpendalStorage 

pub struct OpendalStorage { /* private fields */ }

Implementations

impl OpendalStorage

pub fn new(op: Operator) -> Self

Trait Implementations

impl Clone for OpendalStorage

fn clone(&self) -> OpendalStorage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OpendalStorage

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

Formats the value using the given formatter.

impl<User: UserDetail> StorageBackend<User> for OpendalStorage

type Metadata = OpendalMetadata

The concrete type of the metadata used by this storage backend.

fn metadata<'life0, 'life1, 'async_trait, P>( &'life0 self, _: &'life1 User, path: P, ) -> Pin<Box<dyn Future<Output = Result<Self::Metadata>> + Send + 'async_trait>>

where P: 'async_trait + AsRef<Path> + Send + Debug, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Returns the Metadata for the given file.

fn list<'life0, 'life1, 'async_trait, P>( &'life0 self, _: &'life1 User, path: P, ) -> Pin<Box<dyn Future<Output = Result<Vec<Fileinfo<PathBuf, Self::Metadata>>>> + Send + 'async_trait>>

where Self::Metadata: Metadata, P: 'async_trait + AsRef<Path> + Send + Debug, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Returns the list of files in the given directory.

fn get<'life0, 'life1, 'async_trait, P>( &'life0 self, _: &'life1 User, path: P, start_pos: u64, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn AsyncRead + Send + Sync + Unpin>>> + Send + 'async_trait>>

where P: 'async_trait + AsRef<Path> + Send + Debug, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Returns the content of the given file from offset start_pos. The starting position will only be greater than zero if the storage back-end implementation advertises to support partial reads through the supported_features method i.e. the result from supported_features yield 1 if a logical and operation is applied with FEATURE_RESTART.

fn put<'life0, 'life1, 'async_trait, P, R>( &'life0 self, _: &'life1 User, input: R, path: P, __arg4: u64, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

where P: 'async_trait + AsRef<Path> + Send + Debug, R: 'async_trait + AsyncRead + Send + Sync + Unpin + 'static, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Writes bytes from the given reader to the specified path starting at offset start_pos in the file

fn del<'life0, 'life1, 'async_trait, P>( &'life0 self, _: &'life1 User, path: P, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where P: 'async_trait + AsRef<Path> + Send + Debug, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Deletes the file at the given path.

fn mkd<'life0, 'life1, 'async_trait, P>( &'life0 self, _: &'life1 User, path: P, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where P: 'async_trait + AsRef<Path> + Send + Debug, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Creates the given directory.

fn rename<'life0, 'life1, 'async_trait, P>( &'life0 self, _: &'life1 User, from: P, to: P, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where P: 'async_trait + AsRef<Path> + Send + Debug, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Renames the given file to the given new filename.

fn rmd<'life0, 'life1, 'async_trait, P>( &'life0 self, _: &'life1 User, path: P, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where P: 'async_trait + AsRef<Path> + Send + Debug, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Deletes the given directory.

fn cwd<'life0, 'life1, 'async_trait, P>( &'life0 self, _: &'life1 User, path: P, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where P: 'async_trait + AsRef<Path> + Send + Debug, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Changes the working directory to the given path.

fn enter(&mut self, _user_detail: &User) -> Result<(), Error>

Restrict the backend’s capabilities commensurate with the provided UserDetail.

fn name(&self) -> &str

Implement to set the name of the storage back-end. By default it returns the type signature.

fn supported_features(&self) -> u32

Tells which optional features are supported by the storage back-end Return a value with bits set according to the FEATURE_* constants.

fn md5<'life0, 'life1, 'async_trait, P>( &'life0 self, user: &'life1 User, path: P, ) -> Pin<Box<dyn Future<Output = Result<String, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, P: AsRef<Path> + Send + Debug + 'async_trait, Self: 'async_trait,

Returns the MD5 hash for the given file.

fn list_fmt<'life0, 'life1, 'async_trait, P>( &'life0 self, user: &'life1 User, path: P, ) -> Pin<Box<dyn Future<Output = Result<Cursor<Vec<u8>>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, P: AsRef<Path> + Send + Debug + 'async_trait, Self::Metadata: Metadata + 'static, Self: 'async_trait,

Returns some bytes that make up a directory listing that can immediately be sent to the client.

fn list_vec<'life0, 'life1, 'async_trait, P>( &'life0 self, user: &'life1 User, path: P, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, P: AsRef<Path> + Send + Debug + 'async_trait, Self::Metadata: Metadata + 'static, Self: 'async_trait,

Returns directory listing as a vec of strings used for multi line response in the control channel.

fn nlst<'life0, 'life1, 'async_trait, P>( &'life0 self, user: &'life1 User, path: P, ) -> Pin<Box<dyn Future<Output = Result<Cursor<Vec<u8>>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, P: AsRef<Path> + Send + Debug + 'async_trait, Self::Metadata: Metadata + 'static, Self: 'async_trait,

Returns some bytes that make up a NLST directory listing (only the basename) that can immediately be sent to the client.

fn get_into<'a, 'life0, 'life1, 'async_trait, P, W>( &'life0 self, user: &'life1 User, path: P, start_pos: u64, output: &'a mut W, ) -> Pin<Box<dyn Future<Output = Result<u64, Error>> + Send + 'async_trait>>

where 'a: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, W: AsyncWrite + Unpin + Sync + Send + 'async_trait + ?Sized, P: AsRef<Path> + Send + Debug + 'async_trait, Self: 'async_trait,

Gets the content of the given FTP file from offset start_pos file by copying it to the output writer. The starting position will only be greater than zero if the storage back-end implementation advertises to support partial reads through the supported_features method i.e. the result from supported_features yield 1 if a logical and operation is applied with FEATURE_RESTART.