Struct DiagnosticObserver 

pub struct DiagnosticObserver { /* private fields */ }

The receiving side of one independently bounded diagnostics queue.

Implementations

impl DiagnosticObserver

pub async fn recv(&mut self) -> Option<DiagnosticRecord>

Waits asynchronously for the oldest pending record.

The observer side may await; Kernel producers always use non-blocking enqueue and never execute observer-owned code.

pub fn try_recv(&self) -> Option<DiagnosticRecord>

Removes and returns the oldest pending record without waiting.

pub fn try_next(&self) -> Option<DiagnosticRecord>

Alias for Self::try_recv.

pub fn dropped_count(&self) -> u64

Returns the number of records dropped because this queue was full.

pub fn pending_count(&self) -> usize

Returns the number of records currently buffered.

pub fn capacity(&self) -> usize

Returns the fixed queue capacity.

pub fn filter(&self) -> DiagnosticFilter

Returns this observer’s source filter.

Trait Implementations

impl Debug for DiagnosticObserver

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

Formats the value using the given formatter.