Trait LockedProcessor

Source
pub trait LockedProcessor {
    // Required method
    fn process(&mut self, accumulation: Accumulation<'_>) -> Result<()>;
}
Available on crate feature metrics only.
Expand description

A locked processor.

The Process method is called during collection in a single-threaded context from the SDK, after the aggregator is checkpointed, allowing the processor to build the set of metrics currently being exported.

Required Methods§

Source

fn process(&mut self, accumulation: Accumulation<'_>) -> Result<()>

Process is called by the SDK once per internal record, passing the export Accumulation (a Descriptor, the corresponding Attributes, and the checkpointed Aggregator).

The Context argument originates from the controller that orchestrates collection.

Implementors§