Struct StoragePersistSink 

pub struct StoragePersistSink { /* private fields */ }

SpectraSink that queues telemetry for asynchronous storage through a SpectraRouter.

Queue capacity and batching are configured with PersistConfig (via crate::SpectraBuilder::persist), not environment variables.

Default overflow policy is PersistOverflow::Drop (non-blocking; drops counted via persist_queue_drops). Use PersistOverflow::Block for backpressure. Call PersistHandle::flush (or crate::Spectra::flush_persist) to wait for durability.

Implementations

impl StoragePersistSink

pub fn new(router: Arc<SpectraRouter>) -> Self

Persist-only sink with default PersistConfig.

pub fn new_with_config( router: Arc<SpectraRouter>, config: PersistConfig, ) -> Self

Persist-only sink with explicit config.

pub fn with_inner( router: Arc<SpectraRouter>, inner: Option<Arc<dyn SpectraSink>>, ) -> Self

Invoke inner on the hot path, then enqueue the same emit for async storage persist.

pub fn with_config( router: Arc<SpectraRouter>, inner: Option<Arc<dyn SpectraSink>>, config: PersistConfig, ) -> Self

Like Self::with_inner with explicit PersistConfig.

pub fn handle(&self) -> PersistHandle

Handle for PersistHandle::flush.

Trait Implementations

impl SpectraSink for StoragePersistSink

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.