Struct sozu_lib::network::metrics::Aggregator

pub struct Aggregator { /* fields omitted */ }

Methods

impl Aggregator

pub fn new(prefix: String) -> Aggregator

pub fn set_up_prefix(&mut self, prefix: String)

pub fn set_up_remote(&mut self, socket: UdpSocket, addr: SocketAddr)

pub fn set_up_origin(&mut self, origin: String)

pub fn set_up_tagged_metrics(&mut self, tagged: bool)

pub fn socket(&self) -> Option<&UdpSocket>

pub fn count_add(&mut self, key: &'static str, count_value: i64)

pub fn set_gauge(&mut self, key: &'static str, gauge_value: usize)

pub fn gauge_add(&mut self, key: &'static str, gauge_value: i64)

pub fn writable(&mut self)

pub fn send_data(&mut self)

pub fn dump_metrics_data(&mut self) -> MetricsData

pub fn dump_process_data(&mut self) -> BTreeMap<String, FilteredData>

Trait Implementations

impl Subscriber for Aggregator

fn receive_metric(     &mut self,     label: &'static str,     app_id: Option<&str>,     backend_id: Option<&str>,     metric: MetricData )