pub struct Backend { /* private fields */ }
Expand description
Backend for hdfs services.
Trait Implementations
sourceimpl Accessor for Backend
impl Accessor for Backend
sourcefn metadata(&self) -> AccessorMetadata
fn metadata(&self) -> AccessorMetadata
Invoke the metadata
operation to get metadata of accessor.
sourcefn create<'life0, 'life1, 'async_trait>(
&'life0 self,
path: &'life1 str,
args: OpCreate
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
fn create<'life0, 'life1, 'async_trait>(
&'life0 self,
path: &'life1 str,
args: OpCreate
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
Invoke the create
operation on the specified path Read more
sourcefn read<'life0, 'life1, 'async_trait>(
&'life0 self,
path: &'life1 str,
args: OpRead
) -> Pin<Box<dyn Future<Output = Result<BytesReader>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
fn read<'life0, 'life1, 'async_trait>(
&'life0 self,
path: &'life1 str,
args: OpRead
) -> Pin<Box<dyn Future<Output = Result<BytesReader>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
Invoke the read
operation on the specified path, returns a
BytesReader
if operate successful. Read more
sourcefn write<'life0, 'life1, 'async_trait>(
&'life0 self,
path: &'life1 str,
__arg2: OpWrite,
r: BytesReader
) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
fn write<'life0, 'life1, 'async_trait>(
&'life0 self,
path: &'life1 str,
__arg2: OpWrite,
r: BytesReader
) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
Invoke the write
operation on the specified path, returns a
written size if operate successful. Read more
sourcefn stat<'life0, 'life1, 'async_trait>(
&'life0 self,
path: &'life1 str,
__arg2: OpStat
) -> Pin<Box<dyn Future<Output = Result<ObjectMetadata>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
fn stat<'life0, 'life1, 'async_trait>(
&'life0 self,
path: &'life1 str,
__arg2: OpStat
) -> Pin<Box<dyn Future<Output = Result<ObjectMetadata>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
Invoke the stat
operation on the specified path. Read more
sourcefn delete<'life0, 'life1, 'async_trait>(
&'life0 self,
path: &'life1 str,
__arg2: OpDelete
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
fn delete<'life0, 'life1, 'async_trait>(
&'life0 self,
path: &'life1 str,
__arg2: OpDelete
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
Invoke the delete
operation on the specified path. Read more
sourcefn list<'life0, 'life1, 'async_trait>(
&'life0 self,
path: &'life1 str,
__arg2: OpList
) -> Pin<Box<dyn Future<Output = Result<DirStreamer>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
fn list<'life0, 'life1, 'async_trait>(
&'life0 self,
path: &'life1 str,
__arg2: OpList
) -> Pin<Box<dyn Future<Output = Result<DirStreamer>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
Invoke the list
operation on the specified path. Read more
sourcefn presign(&self, path: &str, args: OpPresign) -> Result<PresignedRequest>
fn presign(&self, path: &str, args: OpPresign) -> Result<PresignedRequest>
Invoke the presign
operation on the specified path. Read more
sourcefn create_multipart<'life0, 'life1, 'async_trait>(
&'life0 self,
path: &'life1 str,
args: OpCreateMultipart
) -> Pin<Box<dyn Future<Output = Result<String>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
fn create_multipart<'life0, 'life1, 'async_trait>(
&'life0 self,
path: &'life1 str,
args: OpCreateMultipart
) -> Pin<Box<dyn Future<Output = Result<String>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
Invoke the create_multipart
operation on the specified path. Read more
sourcefn write_multipart<'life0, 'life1, 'async_trait>(
&'life0 self,
path: &'life1 str,
args: OpWriteMultipart,
r: BytesReader
) -> Pin<Box<dyn Future<Output = Result<ObjectPart>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
fn write_multipart<'life0, 'life1, 'async_trait>(
&'life0 self,
path: &'life1 str,
args: OpWriteMultipart,
r: BytesReader
) -> Pin<Box<dyn Future<Output = Result<ObjectPart>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
Invoke the write_multipart
operation on the specified path. Read more
sourcefn complete_multipart<'life0, 'life1, 'async_trait>(
&'life0 self,
path: &'life1 str,
args: OpCompleteMultipart
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
fn complete_multipart<'life0, 'life1, 'async_trait>(
&'life0 self,
path: &'life1 str,
args: OpCompleteMultipart
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
Invoke the complete_multipart
operation on the specified path. Read more
sourcefn abort_multipart<'life0, 'life1, 'async_trait>(
&'life0 self,
path: &'life1 str,
args: OpAbortMultipart
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
fn abort_multipart<'life0, 'life1, 'async_trait>(
&'life0 self,
path: &'life1 str,
args: OpAbortMultipart
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
Invoke the abort_multipart
operation on the specified path. Read more
sourcefn blocking_create(&self, path: &str, args: OpCreate) -> Result<()>
fn blocking_create(&self, path: &str, args: OpCreate) -> Result<()>
Invoke the blocking_create
operation on the specified path. Read more
sourcefn blocking_read(&self, path: &str, args: OpRead) -> Result<BlockingBytesReader>
fn blocking_read(&self, path: &str, args: OpRead) -> Result<BlockingBytesReader>
Invoke the blocking_read
operation on the specified path. Read more
sourcefn blocking_write(
&self,
path: &str,
args: OpWrite,
r: BlockingBytesReader
) -> Result<u64>
fn blocking_write(
&self,
path: &str,
args: OpWrite,
r: BlockingBytesReader
) -> Result<u64>
Invoke the blocking_write
operation on the specified path. Read more
sourcefn blocking_stat(&self, path: &str, args: OpStat) -> Result<ObjectMetadata>
fn blocking_stat(&self, path: &str, args: OpStat) -> Result<ObjectMetadata>
Invoke the blocking_stat
operation on the specified path. Read more
sourcefn blocking_delete(&self, path: &str, args: OpDelete) -> Result<()>
fn blocking_delete(&self, path: &str, args: OpDelete) -> Result<()>
Invoke the blocking_delete
operation on the specified path. Read more
sourcefn blocking_list(&self, path: &str, args: OpList) -> Result<DirIterator>
fn blocking_list(&self, path: &str, args: OpList) -> Result<DirIterator>
Invoke the blocking_list
operation on the specified path. Read more
impl Send for Backend
hdrs::Client is thread-safe.
impl Sync for Backend
Auto Trait Implementations
Blanket Implementations
sourceimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
impl<V, T> VZip<V> for Twhere
V: MultiLane<T>,
impl<V, T> VZip<V> for Twhere
V: MultiLane<T>,
fn vzip(self) -> V
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where
S: Into<Dispatch>,
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more