Struct TelemetryBuffer 

pub struct TelemetryBuffer { /* private fields */ }

Shared event buffer. record() is cheap and lock-bound; clones are light (Arc).

Internally carries a Notify that the buffer signals when the queue length crosses the flush_threshold — the uploader waits on this alongside its periodic ticker so that “batch_size reached” triggers an immediate flush without waiting for the next interval tick.

Implementations

impl TelemetryBuffer

pub fn new(capacity: usize) -> Self

pub fn set_flush_threshold(&self, threshold: usize)

Set the queue length at which record() wakes the flusher. Called by the pipeline once batch_size is known.

pub fn size_trigger(&self) -> Arc<Notify>

Notifier the background flusher waits on for size-triggered flushes.

pub async fn record(&self, event: TelemetryEvent)

Push an event. When the queue is full, drops the oldest event to make room. Wakes the background flusher as soon as the queue length crosses Self::set_flush_threshold.

pub async fn drain(&self, max: usize) -> Vec<TelemetryEvent>

Drain up to max events without releasing the lock between pops.

pub async fn requeue_front(&self, events: Vec<TelemetryEvent>)

Return events to the front of the queue (after a failed upload).

pub async fn len(&self) -> usize

pub async fn is_empty(&self) -> bool

Trait Implementations

impl Clone for TelemetryBuffer

fn clone(&self) -> TelemetryBuffer

Returns a duplicate of the value.

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

Performs copy-assignment from source.