Struct InvocationMetricsBus 

pub struct InvocationMetricsBus { /* private fields */ }

Broadcast bus that fans an InvocationMetric out to subscribers.

Construct one per PluginSandbox and clone the Arc to pass it into each SandboxInstance. External code calls subscribe to get a Receiver for live events.

Implementations

impl InvocationMetricsBus

pub fn new() -> Self

Construct a bus with the default channel capacity ([DEFAULT_CHANNEL_CAPACITY]).

pub fn with_capacity(capacity: usize) -> Self

Construct a bus with a custom channel capacity. Larger values tolerate slower subscribers without dropping events; smaller values use less memory per bus.

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

Subscribe to live metrics. Each subscriber sees every event sent after the call to subscribe; events emitted before are not replayed.

pub fn record(&self, metric: InvocationMetric)

Send a metric. Non-blocking. If the channel is full, the oldest undelivered event is dropped (broadcast semantics) — that subscriber gets RecvError::Lagged on the next recv. If nobody is subscribed, the metric is silently dropped.

pub fn subscriber_count(&self) -> usize

Current number of subscribers. Useful for tests and for skipping metric construction when nobody’s listening.

Trait Implementations

impl Clone for InvocationMetricsBus

fn clone(&self) -> InvocationMetricsBus

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InvocationMetricsBus

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

Formats the value using the given formatter.

impl Default for InvocationMetricsBus

fn default() -> Self

Returns the “default value” for a type.