Struct MetricsAccessor

pub struct MetricsAccessor<A, I>
where
    A: Access,
    I: MetricsIntercept,
{
    inner: Arc<A>,
    interceptor: I,
    scheme: Scheme,
    namespace: Arc<String>,
    root: Arc<String>,
}

The metrics accessor for opendal.

Fields

inner: Arc<A>

interceptor: I

scheme: Scheme

namespace: Arc<String>

root: Arc<String>

Trait Implementations

impl<A, I> Clone for MetricsAccessor<A, I>

where A: Clone + Access, I: Clone + MetricsIntercept,

fn clone(&self) -> MetricsAccessor<A, I>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<A, I> Debug for MetricsAccessor<A, I>

where A: Access, I: MetricsIntercept,

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

Formats the value using the given formatter.

impl<A, I> LayeredAccess for MetricsAccessor<A, I>

where A: Access, I: MetricsIntercept,

type Inner = A

type Reader = MetricsWrapper<<A as Access>::Reader, I>

type BlockingReader = MetricsWrapper<<A as Access>::BlockingReader, I>

type Writer = MetricsWrapper<<A as Access>::Writer, I>

type BlockingWriter = MetricsWrapper<<A as Access>::BlockingWriter, I>

type Lister = MetricsWrapper<<A as Access>::Lister, I>

type BlockingLister = MetricsWrapper<<A as Access>::BlockingLister, I>

type Deleter = MetricsWrapper<<A as Access>::Deleter, I>

type BlockingDeleter = MetricsWrapper<<A as Access>::BlockingDeleter, I>

fn inner(&self) -> &<MetricsAccessor<A, I> as LayeredAccess>::Inner

async fn create_dir( &self, path: &str, args: OpCreateDir, ) -> Result<RpCreateDir, Error>

async fn read( &self, path: &str, args: OpRead, ) -> Result<(RpRead, <MetricsAccessor<A, I> as LayeredAccess>::Reader), Error>

async fn write( &self, path: &str, args: OpWrite, ) -> Result<(RpWrite, <MetricsAccessor<A, I> as LayeredAccess>::Writer), Error>

async fn copy( &self, from: &str, to: &str, args: OpCopy, ) -> Result<RpCopy, Error>

async fn rename( &self, from: &str, to: &str, args: OpRename, ) -> Result<RpRename, Error>

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

async fn delete( &self, ) -> Result<(RpDelete, <MetricsAccessor<A, I> as LayeredAccess>::Deleter), Error>

async fn list( &self, path: &str, args: OpList, ) -> Result<(RpList, <MetricsAccessor<A, I> as LayeredAccess>::Lister), Error>

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

fn blocking_create_dir( &self, path: &str, args: OpCreateDir, ) -> Result<RpCreateDir, Error>

fn blocking_read( &self, path: &str, args: OpRead, ) -> Result<(RpRead, <MetricsAccessor<A, I> as LayeredAccess>::BlockingReader), Error>

fn blocking_write( &self, path: &str, args: OpWrite, ) -> Result<(RpWrite, <MetricsAccessor<A, I> as LayeredAccess>::BlockingWriter), Error>

fn blocking_copy( &self, from: &str, to: &str, args: OpCopy, ) -> Result<RpCopy, Error>

fn blocking_rename( &self, from: &str, to: &str, args: OpRename, ) -> Result<RpRename, Error>

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

fn blocking_delete( &self, ) -> Result<(RpDelete, <MetricsAccessor<A, I> as LayeredAccess>::BlockingDeleter), Error>

fn blocking_list( &self, path: &str, args: OpList, ) -> Result<(RpList, <MetricsAccessor<A, I> as LayeredAccess>::BlockingLister), Error>

fn info(&self) -> Arc<AccessorInfo>