Struct TokioMpscSink 

pub struct TokioMpscSink { /* private fields */ }

Non-blocking telemetry sink backed by a Tokio MPSC channel.

emit() is non-blocking — events are queued to the channel. flush() is synchronous and blocks until the background worker acknowledges all prior events. Call flush().await before the process exits.

Implementations

impl TokioMpscSink

pub fn new(capacity: usize) -> Self

Spawn the background writer and return the sink.

Args:

• capacity: MPSC channel buffer depth in events.

Usage:

let sink = TokioMpscSink::new(256);

pub async fn flush(self)

Flush all buffered events and wait for the worker to drain.

Call this before the process exits to prevent losing events.

Trait Implementations

impl Clone for TokioMpscSink

fn clone(&self) -> TokioMpscSink

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl EventSink for TokioMpscSink

fn emit(&self, payload: &str)

Emit a JSON-serialized event payload. Must not block.

fn flush(&self)

Block until all previously-emitted payloads have been written.