register_sink

Function register_sink 

Source
pub fn register_sink(sink: Box<dyn TraceEventSink>)
Expand description

Register a sink to receive trace events. This can be called at any time - before or after telemetry initialization. The sink will receive all trace events on the background worker thread.

§Example

use hyperactor_telemetry::{register_sink, TraceEventSink, TraceEvent};

struct MySink;
impl TraceEventSink for MySink {
    fn consume(&mut self, event: &TraceEvent) -> Result<(), anyhow::Error> { Ok(()) }
    fn flush(&mut self) -> Result<(), anyhow::Error> { Ok(()) }
}

register_sink(Box::new(MySink));