Struct TelemetryBuffer 

pub struct TelemetryBuffer { /* private fields */ }

Thread-safe event buffer.

Implementations

impl TelemetryBuffer

pub fn new(max_size: usize) -> Self

pub async fn push(&self, event: TimestampedEvent) -> bool

pub async fn drain(&self) -> Vec<TimestampedEvent>

pub async fn len(&self) -> usize

pub fn dropped_count(&self) -> u64

pub fn notified(&self) -> impl Future<Output = ()> + '_

Trait Implementations

impl Debug for TelemetryBuffer

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

Formats the value using the given formatter.

impl Default for TelemetryBuffer

fn default() -> Self

Returns the “default value” for a type.