Struct TelemetryBus 

pub struct TelemetryBus { /* private fields */ }

Cheap-to-clone broadcast bus. Wraps a tokio::sync::broadcast sender plus a slot for attached exporters (synchronous callbacks).

Implementations

impl TelemetryBus

pub fn new(capacity: usize) -> Self

pub fn publish(&self, event: TelemetryEvent)

pub fn subscribe(&self) -> Receiver<TelemetryEvent>

pub fn subscribe_topic( &self, wanted: &'static str, ) -> UnboundedReceiver<TelemetryEvent>

Subscribe to a single topic. The returned receiver yields only events whose topic() matches wanted. Backed by a forwarder task that filters the broadcast stream — drop the receiver to stop the forwarder.

pub fn receiver_count(&self) -> usize

pub fn attach_span_exporter( &self, exporter: Arc<OtelTracerExporter>, probe: SpanProbeConfig, ) -> Arc<TraceContextInterceptor>

Install the FR-11 span exporter and return a TraceContextInterceptor wired to it. Install the interceptor on actor Props via Props::with_interceptor so handled messages open actor.handle spans and outgoing messages carry child trace context. The metrics path is untouched.

pub fn with_span_exporter( self, exporter: Arc<OtelTracerExporter>, probe: SpanProbeConfig, ) -> (Self, Arc<TraceContextInterceptor>)

Builder-style variant of attach_span_exporter. Returns (self, interceptor) so the bus can be threaded fluently.

pub fn span_exporter(&self) -> Option<Arc<OtelTracerExporter>>

The installed span exporter, if any. Lets application code call record_handle_span / record_restart_span directly.

Trait Implementations

impl Clone for TelemetryBus

fn clone(&self) -> TelemetryBus

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.