Struct StatsExporter 

pub struct StatsExporter { /* private fields */ }

An exporter that concentrates and sends stats to the agent

Implementations

impl StatsExporter

pub fn new( flush_interval: Duration, concentrator: Arc<Mutex<SpanConcentrator>>, meta: TracerMetadata, endpoint: Endpoint, cancellation_token: CancellationToken, client: HttpClient, ) -> Self

Return a new StatsExporter

• flush_interval the interval on which the concentrator is flushed
• concentrator SpanConcentrator storing the stats to be sent to the agent
• meta metadata used in ClientStatsPayload and as headers to send stats to the agent
• endpoint the Endpoint used to send stats to the agent
• cancellation_token Token used to safely shutdown the exporter by force flushing the concentrator

pub async fn send(&self, force_flush: bool) -> Result<()>

Flush the stats stored in the concentrator and send them

If the stats flushed from the concentrator contain at least one time bucket the stats are sent to self.endpoint. The stats are serialized as msgpack.

Errors

The function will return an error in the following case:

• The endpoint failed to build
• The stats payload cannot be serialized as a valid http body
• The http client failed while sending the request
• The http status of the response is not 2xx

Panic

Will panic if another thread panicked while holding the concentrator lock in which case stats cannot be flushed since the concentrator might be corrupted.

Trait Implementations

impl Debug for StatsExporter

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

Formats the value using the given formatter.

impl Worker for StatsExporter

async fn run(&mut self)

Run loop of the stats exporter

Once started, the stats exporter will flush and send stats on every self.flush_interval. If the self.cancellation_token is cancelled, the exporter will force flush all stats and return.