Struct opendal::layers::observe::MetricsAccessor

pub struct MetricsAccessor<A: Access, I: MetricsIntercept> { /* private fields */ }

The metrics accessor for opendal.

Trait Implementations

impl<A: Clone + Access, I: Clone + MetricsIntercept> Clone for MetricsAccessor<A, I>

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: Access, I: MetricsIntercept> Debug for MetricsAccessor<A, I>

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

Formats the value using the given formatter.

impl<A: Access, I: MetricsIntercept> LayeredAccess for MetricsAccessor<A, I>

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>

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, path: &str, args: OpDelete) -> Result<RpDelete>

async fn list(&self, path: &str, args: OpList) -> Result<(RpList, Self::Lister)>

async fn batch(&self, args: OpBatch) -> Result<RpBatch>

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

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

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

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

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

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

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

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

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

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