Struct ChainedSink 

pub struct ChainedSink { /* private fields */ }

Forwards each emit to every sink in the chain, synchronously and in registration order.

Use a chain when one emit must reach multiple transports or telemetry destinations. A slow child sink delays later children and the caller.

Examples

use std::sync::Arc;
use spectra_core::{ChainedSink, RecordingSink, SpectraSink};

let first = Arc::new(RecordingSink::new());
let second = Arc::new(RecordingSink::new());
let chain = ChainedSink::new()
    .push(Arc::clone(&first) as Arc<dyn SpectraSink>)
    .push(Arc::clone(&second) as Arc<dyn SpectraSink>);

chain.record_counter("cache_hits", &[("region", "us")], 1);
assert_eq!(first.counters().len(), 1);
assert_eq!(second.counters().len(), 1);

Implementations

impl ChainedSink

pub fn new() -> ChainedSink

Creates an empty sink chain.

pub fn push(self, sink: Arc<dyn SpectraSink>) -> ChainedSink

Appends a sink to the end of the chain.

pub fn len(&self) -> usize

Returns the number of sinks in the chain.

pub fn is_empty(&self) -> bool

Returns whether the chain has no sinks.

Trait Implementations

impl Default for ChainedSink

fn default() -> ChainedSink

Returns the “default value” for a type.

impl SpectraSink for ChainedSink

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.