pub struct TelemetryManager { /* private fields */ }Expand description
Telemetry manager
Implementations§
Source§impl TelemetryManager
impl TelemetryManager
Sourcepub async fn increment_counter(
&self,
name: &str,
value: f64,
tags: HashMap<String, String>,
)
pub async fn increment_counter( &self, name: &str, value: f64, tags: HashMap<String, String>, )
Record a counter metric
Sourcepub async fn set_gauge(
&self,
name: &str,
value: f64,
tags: HashMap<String, String>,
)
pub async fn set_gauge( &self, name: &str, value: f64, tags: HashMap<String, String>, )
Record a gauge metric
Sourcepub async fn record_histogram(
&self,
name: &str,
value: f64,
tags: HashMap<String, String>,
)
pub async fn record_histogram( &self, name: &str, value: f64, tags: HashMap<String, String>, )
Record a histogram value
Sourcepub async fn record_timer(
&self,
name: &str,
duration: Duration,
tags: HashMap<String, String>,
)
pub async fn record_timer( &self, name: &str, duration: Duration, tags: HashMap<String, String>, )
Record a timer metric
Sourcepub async fn update_system_health(&self, health: SystemHealth)
pub async fn update_system_health(&self, health: SystemHealth)
Update system health metrics
Sourcepub async fn set_active_agents(&self, count: usize)
pub async fn set_active_agents(&self, count: usize)
Update active agent count without overwriting the rest of the health snapshot.
Sourcepub async fn set_active_connections(&self, count: usize)
pub async fn set_active_connections(&self, count: usize)
Update active connection count without overwriting the rest of the health snapshot.
Sourcepub async fn get_system_health(&self) -> SystemHealth
pub async fn get_system_health(&self) -> SystemHealth
Get current system health
Sourcepub async fn get_recent_metrics(&self, limit: usize) -> Vec<Metric>
pub async fn get_recent_metrics(&self, limit: usize) -> Vec<Metric>
Get recent metrics
Sourcepub async fn get_metrics_summary(&self) -> MetricsSummary
pub async fn get_metrics_summary(&self) -> MetricsSummary
Get an aggregate snapshot of counters, gauges, histograms, and system health.
Sourcepub async fn clear_metrics(&self)
pub async fn clear_metrics(&self)
Clear all metrics
Auto Trait Implementations§
impl Freeze for TelemetryManager
impl !RefUnwindSafe for TelemetryManager
impl Send for TelemetryManager
impl Sync for TelemetryManager
impl Unpin for TelemetryManager
impl !UnwindSafe for TelemetryManager
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<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].