Struct CustomEventsSource 

pub struct CustomEventsSource { /* private fields */ }

Flush-thread source that runs a user callback each cycle to record custom events.

Implementations

impl CustomEventsSource

pub fn new<F>(config: CustomEventsConfig, callback: F) -> Self

where F: for<'a> FnMut(&mut CustomEventsContext<'a>) + Send + 'static,

Build a source that invokes callback at the config’s interval.

Trait Implementations

impl Debug for CustomEventsSource

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Source for CustomEventsSource

fn flush(&mut self, ctx: &FlushContext<'_>)

Drain pending data into the trace. Called once per flush cycle.

fn name(&self) -> &'static str

Diagnostic name for this source (e.g. "cpu_profile", "sched").

fn on_thread_start(&mut self) -> Result<()>

Called when a thread joins the recorder: a Tokio worker’s first poll, or an explicit Dial9Handle::track_current_thread.

fn on_thread_stop(&mut self)

Called when a thread stops. Per-thread sources use this to stop tracking the current thread.

fn segment_metadata(&mut self, out: &mut Vec<(String, String)>)

Append this source’s segment-metadata entries to out iff they have changed since the last call.

fn segment_processor(&mut self) -> Option<Box<dyn SegmentProcessor>>

Available on crate feature pipeline only.

A segment-processing stage this source’s data needs, folded into the recorder’s default pipeline at build. Called once, at build.