Struct cadence::ext::SocketStats

pub struct SocketStats { /* private fields */ }

Thread-safe collection of stats updated by network sinks.

This struct is meant to be updated internally by MetricSink implementations and converted to an instance of SinkStats for consumption by external callers.

Example

use std::net::{SocketAddr, UdpSocket};
use cadence::ext::SocketStats;
use cadence::{MetricSink, SinkStats};

pub struct MyCustomSink {
    addr: SocketAddr,
    socket: UdpSocket,
    stats: SocketStats,
}

impl MetricSink for MyCustomSink {
    fn emit(&self, metric: &str) -> std::io::Result<usize> {
        let res = self.socket.send_to(metric.as_bytes(), &self.addr);
        self.stats.update(res, metric.len())
    }

    fn stats(&self) -> SinkStats {
       (&self.stats).into()
    }
}

Implementations

impl SocketStats

pub fn incr_bytes_sent(&self, n: u64)

pub fn incr_packets_sent(&self)

pub fn incr_bytes_dropped(&self, n: u64)

pub fn incr_packets_dropped(&self)

pub fn update(&self, res: Result<usize>, len: usize) -> Result<usize>

Trait Implementations

impl Clone for SocketStats

fn clone(&self) -> SocketStats

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SocketStats

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for SocketStats

fn default() -> SocketStats

Returns the “default value” for a type.

impl From<&SocketStats> for SinkStats

fn from(stats: &SocketStats) -> Self

Converts to this type from the input type.