Struct OffThreadSpectraSink 

pub struct OffThreadSpectraSink { /* private fields */ }

Sink that enqueues NDJSON + optional console mirror work for a background thread.

Implementations

impl OffThreadSpectraSink

pub fn new(ndjson: NdjsonFileSink) -> Self

Spawn the background writer thread and wire the shared emit queue.

pub fn ndjson(&self) -> &NdjsonFileSink

Underlying NDJSON file sink (used by the worker thread).

Trait Implementations

impl SpectraSink for OffThreadSpectraSink

fn record_counter(&self, name: &str, labels: &[(&str, &str)], delta: i64)

Increment (or decrement) a counter.

fn record_gauge(&self, name: &str, labels: &[(&str, &str)], value: f64)

Set a gauge value.

fn log_event(&self, table: &str, fields: &Value)

Append a structured event row.