Struct StatsExporter 

pub struct StatsExporter<Cap: HttpClientCapability + SleepCapability + MaybeSend + Sync + 'static, Con: FlushableConcentrator = SpanConcentrator> { /* private fields */ }

An exporter that concentrates and sends stats to the agent.

Cap is the capabilities bundle (HTTP + sleep). Leaf crates pin it to a concrete type (NativeCapabilities or WasmCapabilities).

Implementations

impl<Cap: HttpClientCapability + SleepCapability + MaybeSend + Sync + 'static, Con: FlushableConcentrator> StatsExporter<Cap, Con>

pub fn new( flush_interval: Duration, concentrator: Arc<Mutex<Con>>, meta: StatsMetadata, endpoint: Endpoint, capabilities: Cap, ) -> Self

Return a new StatsExporter targeting the Datadog Agent’s /v0.6/stats.

• flush_interval the interval on which the concentrator is flushed
• concentrator an impl of FlushableConcentrator 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

pub fn new_agentless( flush_interval: Duration, concentrator: Arc<Mutex<Con>>, meta: StatsMetadata, target: AgentlessStatsTarget, capabilities: Cap, ) -> Self

Return a new StatsExporter that sends the top-level StatsPayload directly to the Datadog intake (agentless).

This path is fully decoupled from the Agent transport: it wraps the flushed buckets in a StatsPayload, msgpack-encodes it, and posts it to target.endpoint with dd-api-key auth and zstd compression.

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

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. Returns Ok(true) if stats were sent, Ok(false) if the concentrator had nothing to send.

Trait Implementations

impl<Cap: Debug + HttpClientCapability + SleepCapability + MaybeSend + Sync + 'static, Con: Debug + FlushableConcentrator> Debug for StatsExporter<Cap, Con>

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

Formats the value using the given formatter.

impl<Cap: HttpClientCapability + SleepCapability + MaybeSend + Sync + 'static, Con: FlushableConcentrator + Send + Debug> Worker for StatsExporter<Cap, Con>

fn run<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Flush and send stats on every trigger.

fn trigger<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Function called between each run to wait for the next run. This function should be cancellation safe as it can be cancelled at any yield point.

fn reset(&mut self)

Reset the worker state. Called in the child after a fork to cleanup parent state.

fn shutdown<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Hook called when the app is shutting down. Can be used to flush remaining data.

fn initial_trigger<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: Send + 'async_trait,

Alternative trigger called on start to provide custom behavior. Defaults to trigger behavior.