Struct SpanConcentrator 

pub struct SpanConcentrator { /* private fields */ }

SpanConcentrator compute stats on span aggregated by time and span attributes

Aggregation

Spans are aggregated into time buckets based on their end_time. Within each time bucket there is another level of aggregation based on the spans fields (e.g. resource_name, service_name) and the peer tags if the peer_tags_aggregation is enabled.

Span eligibility

The ingested spans are only aggregated if they are root, top-level, measured or if their span.kind is eligible and the compute_stats_by_span_kind is enabled.

Flushing

When the SpanConcentrator is flushed it keeps the buffer_len most recent buckets and remove all older buckets returning their content. When using force flush all buckets are flushed regardless of their age.

Implementations

impl SpanConcentrator

pub fn new( bucket_size: Duration, now: SystemTime, span_kinds_stats_computed: Vec<String>, peer_tag_keys: Vec<String>, ) -> SpanConcentrator

Return a new concentrator with the given parameters

• bucket_size is the size of the time buckets
• now the current system time, used to define the oldest bucket
• span_kinds_stats_computed list of span kinds eligible for stats computation
• peer_tags_keys list of keys considered as peer tags for aggregation

pub fn set_span_kinds(&mut self, span_kinds: Vec<String>)

Set the list of span kinds eligible for stats computation

pub fn set_peer_tags(&mut self, peer_tags: Vec<String>)

Set the list of keys considered as peer_tags for aggregation

pub fn get_bucket_size(&self) -> Duration

Return the bucket size used for aggregation

pub fn add_span<'a, T>(&'a mut self, span: &'a T)

where T: StatSpan<'a>,

Add a span into the concentrator, by computing stats if the span is eligible for stats computation.

pub fn flush(&mut self, now: SystemTime, force: bool) -> Vec<ClientStatsBucket>

Flush all stats bucket except for the buffer_len most recent. If force is true, flush all buckets.

Trait Implementations

impl Clone for SpanConcentrator

fn clone(&self) -> SpanConcentrator

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SpanConcentrator

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

Formats the value using the given formatter.