Type Definition opendal::raw::FusedAccessor

pub type FusedAccessor = Arc<dyn Accessor<Reader = Reader, BlockingReader = BlockingReader>>;

FusedAccessor is the type erased accessor with Box<dyn Reader>.

Trait Implementations

impl Accessor for FusedAccessor

type Reader = Box<dyn Read + 'static, Global>

Reader is the associated reader the could return in read operation.

type BlockingReader = Box<dyn BlockingRead + 'static, Global>

BlockingReader is the associated reader that could return in blocking_read operation.

fn metadata(&self) -> AccessorMetadata

Invoke the metadata operation to get metadata of accessor.

fn create<'life0, 'life1, 'async_trait>(
    &'life0 self,
    path: &'life1 str,
    args: OpCreate
) -> Pin<Box<dyn Future<Output = Result<RpCreate>> + Send + 'async_trait>>where
    Self: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,

Invoke the create operation on the specified path

fn read<'life0, 'life1, 'async_trait>(
    &'life0 self,
    path: &'life1 str,
    args: OpRead
) -> Pin<Box<dyn Future<Output = Result<(RpRead, Self::Reader)>> + Send + 'async_trait>>where
    Self: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,

Invoke the read operation on the specified path, returns a ObjectReader if operate successful.

fn write<'life0, 'life1, 'async_trait>(
    &'life0 self,
    path: &'life1 str,
    args: OpWrite,
    r: Reader
) -> Pin<Box<dyn Future<Output = Result<RpWrite>> + Send + 'async_trait>>where
    Self: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,

Invoke the write operation on the specified path, returns a written size if operate successful.

fn stat<'life0, 'life1, 'async_trait>(
    &'life0 self,
    path: &'life1 str,
    args: OpStat
) -> Pin<Box<dyn Future<Output = Result<RpStat>> + Send + 'async_trait>>where
    Self: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,

Invoke the stat operation on the specified path.

fn delete<'life0, 'life1, 'async_trait>(
    &'life0 self,
    path: &'life1 str,
    args: OpDelete
) -> Pin<Box<dyn Future<Output = Result<RpDelete>> + Send + 'async_trait>>where
    Self: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,

Invoke the delete operation on the specified path.

fn list<'life0, 'life1, 'async_trait>(
    &'life0 self,
    path: &'life1 str,
    args: OpList
) -> Pin<Box<dyn Future<Output = Result<(RpList, ObjectPager)>> + Send + 'async_trait>>where
    Self: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,

Invoke the list operation on the specified path.

fn presign(&self, path: &str, args: OpPresign) -> Result<RpPresign>

Invoke the presign operation on the specified path.

fn create_multipart<'life0, 'life1, 'async_trait>(
    &'life0 self,
    path: &'life1 str,
    args: OpCreateMultipart
) -> Pin<Box<dyn Future<Output = Result<RpCreateMultipart>> + Send + 'async_trait>>where
    Self: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,

Invoke the create_multipart operation on the specified path.

fn write_multipart<'life0, 'life1, 'async_trait>(
    &'life0 self,
    path: &'life1 str,
    args: OpWriteMultipart,
    r: Reader
) -> Pin<Box<dyn Future<Output = Result<RpWriteMultipart>> + Send + 'async_trait>>where
    Self: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,

Invoke the write_multipart operation on the specified path.

fn complete_multipart<'life0, 'life1, 'async_trait>(
    &'life0 self,
    path: &'life1 str,
    args: OpCompleteMultipart
) -> Pin<Box<dyn Future<Output = Result<RpCompleteMultipart>> + Send + 'async_trait>>where
    Self: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,

Invoke the complete_multipart operation on the specified path.

fn abort_multipart<'life0, 'life1, 'async_trait>(
    &'life0 self,
    path: &'life1 str,
    args: OpAbortMultipart
) -> Pin<Box<dyn Future<Output = Result<RpAbortMultipart>> + Send + 'async_trait>>where
    Self: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,

Invoke the abort_multipart operation on the specified path.

fn blocking_create(&self, path: &str, args: OpCreate) -> Result<RpCreate>

Invoke the blocking_create operation on the specified path.

fn blocking_read(
    &self,
    path: &str,
    args: OpRead
) -> Result<(RpRead, Self::BlockingReader)>

Invoke the blocking_read operation on the specified path.

fn blocking_write(
    &self,
    path: &str,
    args: OpWrite,
    r: BlockingReader
) -> Result<RpWrite>

Invoke the blocking_write operation on the specified path.

fn blocking_stat(&self, path: &str, args: OpStat) -> Result<RpStat>

Invoke the blocking_stat operation on the specified path.

fn blocking_delete(&self, path: &str, args: OpDelete) -> Result<RpDelete>

Invoke the blocking_delete operation on the specified path.

fn blocking_list(
    &self,
    path: &str,
    args: OpList
) -> Result<(RpList, BlockingObjectPager)>

Invoke the blocking_list operation on the specified path.