Struct DurationRecorderLayer 

pub struct DurationRecorderLayer<OnRequest = (), OnResponse = (), OnError = ()> { /* private fields */ }

A Layer that records the duration of requests in milliseconds.

Implementations

impl DurationRecorderLayer

pub fn new(name: &'static str) -> Self

Create a new DurationRecorderLayer.

impl<OnRequest, OnResponse, OnError> DurationRecorderLayer<OnRequest, OnResponse, OnError>

pub fn on_request<NewOnRequest>( self, on_request: NewOnRequest, ) -> DurationRecorderLayer<NewOnRequest, OnResponse, OnError>

Set the MetricsAttributes to use on request.

pub fn on_request_fn<F, T>( self, on_request: F, ) -> DurationRecorderLayer<FnWrapper<F>, OnResponse, OnError>

where F: Fn(&T) -> Vec<KeyValue>,

pub fn on_response<NewOnResponse>( self, on_response: NewOnResponse, ) -> DurationRecorderLayer<OnRequest, NewOnResponse, OnError>

Set the MetricsAttributes to use on response.

pub fn on_response_fn<F, T>( self, on_response: F, ) -> DurationRecorderLayer<OnRequest, FnWrapper<F>, OnError>

where F: Fn(&T) -> Vec<KeyValue>,

pub fn on_error<NewOnError>( self, on_error: NewOnError, ) -> DurationRecorderLayer<OnRequest, OnResponse, NewOnError>

Set the MetricsAttributes to use on error.

pub fn on_error_fn<F, T>( self, on_error: F, ) -> DurationRecorderLayer<OnRequest, OnResponse, FnWrapper<F>>

where F: Fn(&T) -> Vec<KeyValue>,

Trait Implementations

impl<OnRequest: Clone, OnResponse: Clone, OnError: Clone> Clone for DurationRecorderLayer<OnRequest, OnResponse, OnError>

fn clone(&self) -> DurationRecorderLayer<OnRequest, OnResponse, OnError>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<OnRequest: Debug, OnResponse: Debug, OnError: Debug> Debug for DurationRecorderLayer<OnRequest, OnResponse, OnError>

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

Formats the value using the given formatter.

impl<S, OnRequest, OnResponse, OnError> Layer<S> for DurationRecorderLayer<OnRequest, OnResponse, OnError>

where OnRequest: Clone, OnResponse: Clone, OnError: Clone,

type Service = DurationRecorderService<S, OnRequest, OnResponse, OnError>

The wrapped service

fn layer(&self, inner: S) -> Self::Service

Wrap the given service with the middleware, returning a new service that has been decorated with the middleware.