pub struct MetricsAccessor<A: Access, I: MetricsIntercept> { /* private fields */ }
Expand description
The metrics accessor for opendal.
Trait Implementations§
Source§impl<A: Access, I: MetricsIntercept> Debug for MetricsAccessor<A, I>
impl<A: Access, I: MetricsIntercept> Debug for MetricsAccessor<A, I>
Source§impl<A: Access, I: MetricsIntercept> LayeredAccess for MetricsAccessor<A, I>
impl<A: Access, I: MetricsIntercept> LayeredAccess for MetricsAccessor<A, I>
type Inner = A
type Reader = MetricsWrapper<<A as Access>::Reader, I>
type Writer = MetricsWrapper<<A as Access>::Writer, I>
type Lister = MetricsWrapper<<A as Access>::Lister, I>
type Deleter = MetricsWrapper<<A as Access>::Deleter, I>
fn inner(&self) -> &Self::Inner
async fn create_dir(&self, path: &str, args: OpCreateDir) -> Result<RpCreateDir>
async fn read(&self, path: &str, args: OpRead) -> Result<(RpRead, Self::Reader)>
async fn write( &self, path: &str, args: OpWrite, ) -> Result<(RpWrite, Self::Writer)>
async fn copy(&self, from: &str, to: &str, args: OpCopy) -> Result<RpCopy>
async fn rename(&self, from: &str, to: &str, args: OpRename) -> Result<RpRename>
async fn stat(&self, path: &str, args: OpStat) -> Result<RpStat>
async fn delete(&self) -> Result<(RpDelete, Self::Deleter)>
async fn list(&self, path: &str, args: OpList) -> Result<(RpList, Self::Lister)>
async fn presign(&self, path: &str, args: OpPresign) -> Result<RpPresign>
fn info(&self) -> Arc<AccessorInfo>
Auto Trait Implementations§
impl<A, I> Freeze for MetricsAccessor<A, I>
impl<A, I> RefUnwindSafe for MetricsAccessor<A, I>where
A: RefUnwindSafe,
I: RefUnwindSafe,
impl<A, I> Send for MetricsAccessor<A, I>
impl<A, I> Sync for MetricsAccessor<A, I>
impl<A, I> Unpin for MetricsAccessor<A, I>
impl<A, I> UnwindSafe for MetricsAccessor<A, I>where
A: UnwindSafe,
I: UnwindSafe,
Blanket Implementations§
Source§impl<L> Access for Lwhere
L: LayeredAccess,
impl<L> Access for Lwhere
L: LayeredAccess,
Source§type Reader = <L as LayeredAccess>::Reader
type Reader = <L as LayeredAccess>::Reader
Reader is the associated reader returned in
read
operation.Source§type Writer = <L as LayeredAccess>::Writer
type Writer = <L as LayeredAccess>::Writer
Writer is the associated writer returned in
write
operation.Source§type Lister = <L as LayeredAccess>::Lister
type Lister = <L as LayeredAccess>::Lister
Lister is the associated lister returned in
list
operation.Source§type Deleter = <L as LayeredAccess>::Deleter
type Deleter = <L as LayeredAccess>::Deleter
Deleter is the associated deleter returned in
delete
operation.Source§fn info(&self) -> Arc<AccessorInfo>
fn info(&self) -> Arc<AccessorInfo>
Invoke the
info
operation to get metadata of accessor. Read moreSource§async fn create_dir(
&self,
path: &str,
args: OpCreateDir,
) -> Result<RpCreateDir, Error>
async fn create_dir( &self, path: &str, args: OpCreateDir, ) -> Result<RpCreateDir, Error>
Invoke the
create
operation on the specified path Read moreSource§async fn read(
&self,
path: &str,
args: OpRead,
) -> Result<(RpRead, <L as Access>::Reader), Error>
async fn read( &self, path: &str, args: OpRead, ) -> Result<(RpRead, <L as Access>::Reader), Error>
Source§async fn write(
&self,
path: &str,
args: OpWrite,
) -> Result<(RpWrite, <L as Access>::Writer), Error>
async fn write( &self, path: &str, args: OpWrite, ) -> Result<(RpWrite, <L as Access>::Writer), Error>
Invoke the
write
operation on the specified path, returns a
written size if operate successful. Read moreSource§async fn stat(&self, path: &str, args: OpStat) -> Result<RpStat, Error>
async fn stat(&self, path: &str, args: OpStat) -> Result<RpStat, Error>
Invoke the
stat
operation on the specified path. Read moreSource§async fn delete(&self) -> Result<(RpDelete, <L as Access>::Deleter), Error>
async fn delete(&self) -> Result<(RpDelete, <L as Access>::Deleter), Error>
Invoke the
delete
operation on the specified path. Read moreSource§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
Source§impl<T> ServiceExt for T
impl<T> ServiceExt for T
Source§fn map_response_body<F>(self, f: F) -> MapResponseBody<Self, F>where
Self: Sized,
fn map_response_body<F>(self, f: F) -> MapResponseBody<Self, F>where
Self: Sized,
Apply a transformation to the response body. Read more
Source§fn decompression(self) -> Decompression<Self>where
Self: Sized,
fn decompression(self) -> Decompression<Self>where
Self: Sized,
Decompress response bodies. Read more
Source§fn trace_for_http(self) -> Trace<Self, SharedClassifier<ServerErrorsAsFailures>>where
Self: Sized,
fn trace_for_http(self) -> Trace<Self, SharedClassifier<ServerErrorsAsFailures>>where
Self: Sized,
High level tracing that classifies responses using HTTP status codes. Read more
Source§fn trace_for_grpc(self) -> Trace<Self, SharedClassifier<GrpcErrorsAsFailures>>where
Self: Sized,
fn trace_for_grpc(self) -> Trace<Self, SharedClassifier<GrpcErrorsAsFailures>>where
Self: Sized,
High level tracing that classifies responses using gRPC headers. Read more