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) -> Self

Construct a pipeline with the default bounded deduplication store.

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

Construct a pipeline with an explicit idempotency-key bound.

pub fn pending_buckets(&self) -> usize

Number of buffered aggregate buckets.

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

Access the exporter for diagnostics and tests.

impl<E: BatchExporter> BillingPipeline<E>

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

Formats the value using the given formatter.

impl<E: BatchExporter> UsageRecorder for BillingPipeline<E>

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

Add one event without performing I/O.