pub struct ProviderMetrics { /* private fields */ }Expand description
Bounded history of provider requests. Oldest entries are evicted once the buffer exceeds 1000 records.
Prefer the crate::telemetry::PROVIDER_METRICS singleton. Constructing
your own is only useful in tests.
Implementations§
Source§impl ProviderMetrics
impl ProviderMetrics
Sourcepub async fn record(&self, record: ProviderRequestRecord)
pub async fn record(&self, record: ProviderRequestRecord)
Append a request, evicting the oldest if the buffer exceeds 1000.
Sourcepub async fn get_recent(&self, limit: usize) -> Vec<ProviderRequestRecord>
pub async fn get_recent(&self, limit: usize) -> Vec<ProviderRequestRecord>
Return up to limit most-recent records (newest first).
Sourcepub fn all_snapshots(&self) -> Vec<ProviderSnapshot>
pub fn all_snapshots(&self) -> Vec<ProviderSnapshot>
Aggregate the buffer into one ProviderSnapshot per provider.
Returns an empty Vec if the buffer lock is contended.
Trait Implementations§
Source§impl Debug for ProviderMetrics
impl Debug for ProviderMetrics
Source§impl Default for ProviderMetrics
impl Default for ProviderMetrics
Source§fn default() -> ProviderMetrics
fn default() -> ProviderMetrics
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl !Freeze for ProviderMetrics
impl !RefUnwindSafe for ProviderMetrics
impl Send for ProviderMetrics
impl Sync for ProviderMetrics
impl Unpin for ProviderMetrics
impl UnsafeUnpin for ProviderMetrics
impl !UnwindSafe for ProviderMetrics
Blanket Implementations§
Source§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> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::RequestSource§impl<T> Pointable for T
impl<T> Pointable for T
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 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