Struct BillingPipeline 

pub struct BillingPipeline<E> { /* private fields */ }

Coordinates a UsageBuffer with an off-path exporter.

Implementations

impl<E> BillingPipeline<E>

pub fn new(exporter: E) -> BillingPipeline<E>

Construct a pipeline with the default bounded deduplication store.

pub fn with_idempotency_capacity( exporter: E, capacity: usize, ) -> BillingPipeline<E>

Construct a pipeline with an explicit idempotency-key bound.

pub fn pending_buckets(&self) -> usize

Number of buffered aggregate buckets.

pub fn retry_buckets(&self) -> usize

Number of aggregates waiting to be retried.

Worth alerting on: a count that never falls is usage the provider keeps refusing, and the buffer is in memory, so it is lost at the next deploy.

pub const fn exporter(&self) -> &E

Access the exporter for diagnostics and tests.

impl<E> BillingPipeline<E>

where E: BatchExporter,

pub async fn flush(&self) -> Result<usize, ExportError>

Drain and export one batch. Failed batches retain their exact identifiers for an idempotent retry.

Errors

Returns ExportError::FlushInProgress for overlapping flushes, or the provider error after restoring the batch for retry.

Trait Implementations

impl<E> Debug for BillingPipeline<E>

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

Formats the value using the given formatter.

impl<E> UsageRecorder for BillingPipeline<E>

where E: BatchExporter,

fn record(&self, event: UsageEvent) -> Result<RecordOutcome, RecordError>

Add one event without performing I/O.