Struct CompositeSink 

pub struct CompositeSink { /* private fields */ }

An EventSink that dispatches events to multiple other EventSinks.

This allows for fanning out telemetry events to different sinks, each with its own filtering and processing logic.

Implementations

impl CompositeSink

pub fn new( sinks: Vec<(LevelFilter, Box<dyn EventSink>)>, target_max_level: Vec<(String, LevelFilter)>, max_level_override: Option<LevelFilter>, ) -> CompositeSink

Creates a new CompositeSink.

Trait Implementations

impl EventSink for CompositeSink

fn on_startup(&self, process_info: Arc<ProcessInfo>)

fn on_shutdown(&self)

fn on_log_enabled(&self, metadata: &LogMetadata<'_>) -> bool

fn on_log( &self, metadata: &LogMetadata<'_>, properties: &[Property], time: i64, args: Arguments<'_>, )

fn on_init_log_stream(&self, log_stream: &EventStream<EventBlock<LogMsgQueue>>)

fn on_process_log_block(&self, old_event_block: Arc<EventBlock<LogMsgQueue>>)

fn on_init_metrics_stream( &self, metrics_stream: &EventStream<EventBlock<MetricsMsgQueue>>, )

fn on_process_metrics_block( &self, old_event_block: Arc<EventBlock<MetricsMsgQueue>>, )

fn on_init_thread_stream( &self, thread_stream: &EventStream<EventBlock<ThreadEventQueue>>, )

fn on_process_thread_block( &self, old_event_block: Arc<EventBlock<ThreadEventQueue>>, )

fn is_busy(&self) -> bool