Struct TelemetryEmitter 

pub struct TelemetryEmitter { /* private fields */ }

Fire-and-forget telemetry publisher.

Zero-await on the hot path: the NATS client’s internal buffer absorbs transient spikes. Serialization or publish failure is silently dropped — telemetry must never gate critical-path work. All failures are counted via atomics so tests + dashboards can still observe drop rates.

Cloning is cheap: the inner async_nats::Client is already Clone and the counter is an Arc.

Debug skips the NATS client (its impl is verbose and not useful for our purposes); only the source identity and drop counter are printed so an AgentContext Debug-format is concise.

Implementations

impl TelemetryEmitter

pub fn new(client: Client, source: TelemetrySource) -> Self

pub fn with_prefix(self, prefix: impl Into<String>) -> Self

Override the subject prefix (forwarder tenanted deployments).

pub fn dropped_count(&self) -> u64

Number of events dropped due to serialization or publish failure since this emitter was constructed. Exposed for tests and operator visibility.

pub fn emit(&self, event: &TelemetryEvent)

Publish an event. Returns immediately; publish happens inside the async_nats client’s outbound queue. The event is silently dropped (counter increments) on any of:

• Subject derivation failure (invalid agent_id or custom_prefix).
• Serialization failure (programmer error — should not happen for well-typed TelemetryEvent variants).
• No active Tokio runtime — calling emit() from a thread that has no current runtime increments dropped instead of panicking. Telemetry must never crash the caller.
• The async-nats client’s publish() future returning Err.

Trait Implementations

impl Clone for TelemetryEmitter

fn clone(&self) -> TelemetryEmitter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TelemetryEmitter

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

Formats the value using the given formatter.