Struct TelemetryStream 

pub struct TelemetryStream { /* private fields */ }

Streaming telemetry log that keeps the last capacity entries in memory while also accumulating all entries for bulk export.

Implementations

impl TelemetryStream

pub fn new(capacity: usize) -> Self

Create a stream with the given ring-buffer capacity.

pub fn push(&mut self, entry: SimLogEntry)

Append a new entry to the stream.

pub fn total_count(&self) -> u64

Total number of entries ever pushed.

pub fn ring_iter(&self) -> impl Iterator<Item = &SimLogEntry>

Iterate over the entries currently in the ring buffer (may be < capacity).

pub fn ring_len(&self) -> usize

Number of entries currently in the ring buffer.

pub fn all(&self) -> &[SimLogEntry]

Return all entries ever pushed.

Trait Implementations

impl Clone for TelemetryStream

fn clone(&self) -> TelemetryStream

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TelemetryStream

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

Formats the value using the given formatter.