Struct MeterEventExporter 

pub struct MeterEventExporter<P> { /* private fields */ }

Exports pre-aggregated usage through an application-supplied provider.

Confirmed accepted and permanently rejected events are skipped on a later retry. Retryable and ambiguous events retain their original identifiers. While partial progress exists, only the identical original batch is accepted.

Implementations

impl<P> MeterEventExporter<P>

pub fn new(provider: P) -> MeterEventExporter<P>

Construct an exporter with a dead letter capacity of 1,024.

pub const fn provider(&self) -> &P

Access the provider for diagnostics and tests.

pub fn with_dead_letter_capacity(self, capacity: usize) -> MeterEventExporter<P>

Bound how many rejected aggregates are retained for reconciliation.

Reducing the capacity evicts the oldest entries and increments MeterEventExporter::dropped_dead_letters. Zero disables retention while continuing to count discarded entries.

pub fn dead_letter_count(&self) -> usize

Number of aggregates retained for reconciliation.

pub fn dropped_dead_letters(&self) -> u64

Number of reconciliation aggregates discarded because retention was full.

pub fn take_dead_letters(&self) -> Vec<MeterEventDeadLetter>

Drain retained aggregates for application-owned reconciliation.

pub fn quarantine_async_rejection( &self, aggregate: &AggregatedUsage, code: &'static str, ) -> bool

Retain an aggregate that a provider rejected after initial acceptance.

Returns true when the aggregate was newly retained. A duplicate identifier or zero-capacity queue returns false. The code must be a static, sanitized, low-cardinality category.

pub fn retry_in_progress(&self) -> bool

Whether an incomplete batch is still owed a retry.

While this is true, BatchExporter::export accepts only the identical original batch and refuses any other.

pub fn abandon_retry_progress(&self) -> Vec<String>

Give up on an incomplete batch so a different one can be exported.

Returns the identifiers that were not confirmed complete. If an export is currently running, no progress is abandoned and an empty vector is returned. Callers can distinguish that case with Self::retry_in_progress.

Trait Implementations

impl<P> BatchExporter for MeterEventExporter<P>

where P: MeterEventProvider,

fn retry_policy(&self) -> RetryPolicy

Ordering required after a failed or cancelled export.

fn export<'a>( &'a self, batch: &'a [AggregatedUsage], ) -> Pin<Box<dyn Future<Output = Result<(), ExportError>> + Send + 'a>>

Export every aggregate in batch.

impl<P> Debug for MeterEventExporter<P>

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

Formats the value using the given formatter.