Struct MetricsCallBuffer 

pub struct MetricsCallBuffer<I>
where
    I: BufferInstrumentRef,
{ /* private fields */ }

Buffers MetricEvents for periodic consumption by lang

Implementations

impl<I> MetricsCallBuffer<I>

where I: Clone + BufferInstrumentRef,

pub fn new(buffer_size: usize) -> Self

Create a new buffer with the given capacity

Trait Implementations

impl<I> CoreMeter for MetricsCallBuffer<I>

where I: BufferInstrumentRef + Debug + Send + Sync + Clone + 'static,

fn new_attributes(&self, opts: NewAttributes) -> MetricAttributes

Given some k/v pairs, create a return a new instantiated instance of metric attributes. Only MetricAttributes created by this meter can be used when calling record on instruments created by this meter.

fn extend_attributes( &self, existing: MetricAttributes, attribs: NewAttributes, ) -> MetricAttributes

Extend some existing attributes with new values. Implementations should create new instances when doing so, rather than mutating whatever is backing the passed in existing attributes. Ideally that new instance retains a ref to the extended old attribute, promoting re-use.

fn counter(&self, params: MetricParameters) -> Counter

Create a new counter instrument.

fn histogram(&self, params: MetricParameters) -> Histogram

Create a new histogram instrument recording u64 values.

fn histogram_f64(&self, params: MetricParameters) -> HistogramF64

Create a new histogram instrument recording f64 values.

fn histogram_duration(&self, params: MetricParameters) -> HistogramDuration

Create a histogram which records Durations. Implementations should choose to emit in either milliseconds or seconds depending on how they have been configured. MetricParameters::unit should be overwritten by implementations to be ms or s accordingly.

fn gauge(&self, params: MetricParameters) -> Gauge

Create a new gauge instrument recording u64 values.

fn gauge_f64(&self, params: MetricParameters) -> GaugeF64

Create a new gauge instrument recording f64 values.

fn up_down_counter(&self, params: MetricParameters) -> UpDownCounter

Create a new up-down counter instrument recording i64 values.

fn counter_with_in_memory( &self, params: MetricParameters, in_memory_counter: HeartbeatMetricType, ) -> Counter

Create a counter with in-memory tracking for worker heartbeating reporting

fn histogram_duration_with_in_memory( &self, params: MetricParameters, in_memory_hist: HeartbeatMetricType, ) -> HistogramDuration

Create a histogram duration with in-memory tracking for worker heartbeating reporting

fn gauge_with_in_memory( &self, params: MetricParameters, in_memory_metrics: HeartbeatMetricType, ) -> Gauge

Create a gauge with in-memory tracking for worker heartbeating reporting

impl<I> Debug for MetricsCallBuffer<I>

where I: BufferInstrumentRef + Debug,

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

Formats the value using the given formatter.

impl<I> MetricCallBufferer<I> for MetricsCallBuffer<I>

where I: Send + Sync + BufferInstrumentRef,

fn retrieve(&self) -> Vec<MetricEvent<I>>

Drain and return all buffered metric events.