Struct DhtTelemetry 

pub struct DhtTelemetry { /* private fields */ }

DHT telemetry collector

Implementations

impl DhtTelemetry

pub fn new(max_points: usize) -> Self

Create new telemetry collector

pub async fn record(&self, point: TelemetryPoint)

Record a telemetry point

pub async fn record_put( &self, duration: Duration, hops: usize, success: bool, error: Option<String>, )

Record a PUT operation

pub async fn record_get( &self, duration: Duration, hops: usize, success: bool, error: Option<String>, )

Record a GET operation

pub async fn record_find_node( &self, duration: Duration, hops: usize, success: bool, error: Option<String>, )

Record a FIND_NODE operation

pub async fn get_stats(&self) -> TelemetryStats

Get current statistics

pub async fn get_error_summary(&self) -> HashMap<String, usize>

Get recent error summary