pub struct MetricsCollector { /* private fields */ }Expand description
Metrics collector for MCP operations
Implementations§
Source§impl MetricsCollector
impl MetricsCollector
Sourcepub async fn record_error(&self, error: &McpError, context: &str)
pub async fn record_error(&self, error: &McpError, context: &str)
Record an error occurrence
Sourcepub async fn record_request(&self, method: &str, transport: &str)
pub async fn record_request(&self, method: &str, transport: &str)
Record a request
Sourcepub async fn record_connection_attempt(&self, transport: &str, success: bool)
pub async fn record_connection_attempt(&self, transport: &str, success: bool)
Record a connection attempt
Sourcepub async fn record_retry_attempt(
&self,
operation: &str,
attempt: u32,
error_category: &str,
will_retry: bool,
)
pub async fn record_retry_attempt( &self, operation: &str, attempt: u32, error_category: &str, will_retry: bool, )
Record a retry attempt
Sourcepub async fn get_error_metrics(&self) -> HashMap<String, u64>
pub async fn get_error_metrics(&self) -> HashMap<String, u64>
Get current error metrics
Sourcepub async fn get_request_metrics(&self) -> HashMap<String, u64>
pub async fn get_request_metrics(&self) -> HashMap<String, u64>
Get current request metrics
Sourcepub async fn get_connection_metrics(&self) -> HashMap<String, u64>
pub async fn get_connection_metrics(&self) -> HashMap<String, u64>
Get current connection metrics
Sourcepub async fn get_retry_metrics(&self) -> HashMap<String, u64>
pub async fn get_retry_metrics(&self) -> HashMap<String, u64>
Get current retry metrics
Sourcepub async fn get_all_metrics(&self) -> MetricsSummary
pub async fn get_all_metrics(&self) -> MetricsSummary
Get all metrics
Trait Implementations§
Source§impl Clone for MetricsCollector
impl Clone for MetricsCollector
Source§fn clone(&self) -> MetricsCollector
fn clone(&self) -> MetricsCollector
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for MetricsCollector
impl Debug for MetricsCollector
Auto Trait Implementations§
impl !RefUnwindSafe for MetricsCollector
impl !UnwindSafe for MetricsCollector
impl Freeze for MetricsCollector
impl Send for MetricsCollector
impl Sync for MetricsCollector
impl Unpin for MetricsCollector
impl UnsafeUnpin for MetricsCollector
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
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request§impl<L> LayerExt<L> for L
impl<L> LayerExt<L> for L
§fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
Applies the layer to a service and wraps it in [
Layered].