Struct opentelemetry::sdk::metrics::Accumulator

pub struct Accumulator(_);

Available on crate feature metrics only.

Accumulator implements the OpenTelemetry Meter API. The Accumulator is bound to a single Processor.

The Accumulator supports a collect API to gather and export current data. Collect should be arranged according to the processor model. Push-based processors will setup a timer to call collect periodically. Pull-based processors will call collect when a pull request arrives.

Implementations

impl Accumulator

pub fn collect(
    &self,
    cx: &Context,
    locked_processor: &mut dyn LockedProcessor
) -> usize

Traverses the list of active records and observers and exports data for each active instrument.

During the collection pass, the LockedProcessor will receive one export call per current aggregation.

Returns the number of records that were checkpointed.

Trait Implementations

impl Clone for Accumulator

fn clone(&self) -> Accumulator

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Accumulator

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

Formats the value using the given formatter.

impl MeterCore for Accumulator

fn new_sync_instrument(
    &self,
    descriptor: Descriptor
) -> Result<Arc<dyn SyncInstrumentCore + Send + Sync + 'static>, MetricsError>

Create a new synchronous instrument implementation.

fn new_async_instrument(
    &self,
    descriptor: Descriptor
) -> Result<Arc<dyn AsyncInstrumentCore + Send + Sync + 'static>, MetricsError>

Create a new asynchronous instrument implementation.

fn register_callback(
    &self,
    f: Box<dyn Fn(&Context) + Send + Sync + 'static, Global>
) -> Result<(), MetricsError>

Register a batch observer