Struct TelemetryCollector

Source

pub struct TelemetryCollector { /* private fields */ }

Expand description

Telemetry collector for system metrics

Implementations§

Source §

impl TelemetryCollector

Source

pub fn new() -> Self

Create a new telemetry collector

Source

pub async fn record_lookup(&self, latency: Duration, hops: u8)

Record a lookup operation

Source

pub fn record_timeout(&self)

Record a timeout

Source

pub fn record_dht_put(&self)

Record a DHT put operation

Source

pub fn record_dht_get(&self)

Record a DHT get operation

Source

pub fn record_auth_failure(&self)

Record an auth failure

Source

pub async fn record_stream_bandwidth( &self, class: StreamClass, bytes_per_sec: u64, )

Record stream bandwidth

Source

pub async fn record_stream_rtt(&self, class: StreamClass, rtt: Duration)

Record stream RTT

Source

pub async fn get_metrics(&self) -> Metrics

Get current metrics

Source

pub fn get_counters(&self) -> EventCounters

Get event counters

Source

pub async fn get_stream_metrics( &self, class: StreamClass, ) -> Option<StreamMetrics>

Get stream metrics for a class

Source

pub async fn record_stream_class_usage(&self, class: StreamClass)

Record stream class usage

Source

pub async fn reset(&self)

Reset all metrics

Trait Implementations§

Source §

impl Default for TelemetryCollector

Source §

fn default() -> Self

Returns the “default value” for a type. Read more

Auto Trait Implementations§

§

impl !UnwindSafe for TelemetryCollector

Blanket Implementations§

Source §

impl<T> Any for T
where T: 'static + ?Sized,

Source §

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

Source §

impl<T> Borrow<T> for T
where T: ?Sized,

Source §

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

Source §

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source §

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

Source §

impl<T> From<T> for T

Source §

fn from(t: T) -> T

Returns the argument unchanged.

Source §

impl<T> Instrument for T

Source §

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

Source §

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

Source §

impl<T, U> Into for T
where U: From<T>,

Source §

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source §

impl<T> PolicyExt for T
where T: ?Sized,

Source §

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more

Source §

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more

Source §

impl<T> Same for T

Source §

type Output = T

Should always be Self

Source §

impl<T, U> TryFrom for T
where U: Into<T>,

Source §

type Error = Infallible

The type returned in the event of a conversion error.

Source §

fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>

Performs the conversion.

Source §

impl<T, U> TryInto for T
where U: TryFrom<T>,

Source §

type Error = >::Error

The type returned in the event of a conversion error.

Source §

fn try_into(self) -> Result<U, >::Error>

Performs the conversion.

Source §

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source §

fn vzip(self) -> V

Source §

impl<T> WithSubscriber for T

Source §

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

Source §

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more

Source §

TelemetryCollector

Struct TelemetryCollector Copy item path

Implementations§

impl TelemetryCollector

pub fn new() -> Self

pub async fn record_lookup(&self, latency: Duration, hops: u8)

pub fn record_timeout(&self)

pub fn record_dht_put(&self)

pub fn record_dht_get(&self)

pub fn record_auth_failure(&self)

pub async fn record_stream_bandwidth( &self, class: StreamClass, bytes_per_sec: u64, )

pub async fn record_stream_rtt(&self, class: StreamClass, rtt: Duration)

pub async fn get_metrics(&self) -> Metrics

pub fn get_counters(&self) -> EventCounters

pub async fn get_stream_metrics( &self, class: StreamClass, ) -> Option<StreamMetrics>

pub async fn record_stream_class_usage(&self, class: StreamClass)

pub async fn reset(&self)

Trait Implementations§

impl Default for TelemetryCollector

fn default() -> Self

Auto Trait Implementations§

impl Freeze for TelemetryCollector

impl !RefUnwindSafe for TelemetryCollector

impl Send for TelemetryCollector

impl Sync for TelemetryCollector

impl Unpin for TelemetryCollector

impl !UnwindSafe for TelemetryCollector

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> PolicyExt for Twhere T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>where T: Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>where T: Policy<B, E>, P: Policy<B, E>,

impl<T> Same for T

type Output = T

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

impl<A, B, T> HttpServerConnExec<A, B> for Twhere B: Body,

Struct TelemetryCollector

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

impl<A, B, T> HttpServerConnExec<A, B> for T
where B: Body,