Struct Aggregator

pub struct Aggregator { /* private fields */ }

Implementations

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 socket_mut(&mut self) -> Option<&mut 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_local_proxy_metrics(&mut self) -> BTreeMap<String, FilteredMetrics>

pub fn query( &mut self, q: &QueryMetricsOptions, ) -> Result<ResponseContent, MetricError>

pub fn clear_local(&mut self)

pub fn configure(&mut self, config: &MetricsConfiguration)

Trait Implementations

impl Subscriber for Aggregator

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