Struct TelemetryQueue 

pub struct TelemetryQueue { /* private fields */ }

Cloneable producer for one bounded exporter queue.

Implementations

impl TelemetryQueue

pub fn new(bound: ExportQueueBound, report_window: DropReportWindow) -> Self

Constructs an empty bounded queue.

pub fn enqueue(&self, record: TelemetryRecord, now: Duration) -> EnqueueResult

Enqueues without waiting; a full queue drops this newest record.

pub fn len(&self) -> usize

Returns the current queued count.

pub fn is_empty(&self) -> bool

Returns whether the queue is empty.

pub fn dropped(&self) -> u64

Returns the cumulative dropped-newest count.

Trait Implementations

impl Clone for TelemetryQueue

fn clone(&self) -> TelemetryQueue

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for TelemetryQueue

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

Formats the value using the given formatter.