Struct DiagnosticsBus 

pub struct DiagnosticsBus { /* private fields */ }

Fan-out bus connecting one diagnostics source to many sinks.

Implementations

impl DiagnosticsBus

pub fn new() -> Self

New bus with no sinks attached.

pub fn attach(&self, sink: Arc<dyn DiagnosticsSink>) -> usize

Attach a sink. Returns the new sink count.

pub async fn publish(&self, batch: DiagnosticsBatch)

Publish a batch to every attached sink concurrently.

Trait Implementations

impl Clone for DiagnosticsBus

fn clone(&self) -> DiagnosticsBus

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DiagnosticsBus

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

Formats the value using the given formatter.

impl Default for DiagnosticsBus

fn default() -> DiagnosticsBus

Returns the “default value” for a type.