Struct TelemetryWriter 

pub struct TelemetryWriter { /* private fields */ }

Cloneable handle to the bounded background writer.

Implementations

impl TelemetryWriter

pub fn new(options: WriterOptions) -> Self

Spawn the dedicated worker thread and return a cloneable handle. None paths resolve to the installation defaults at spawn time.

pub fn enqueue_telemetry(&self, record: TelemetryRecord)

Enqueue a legacy telemetry record. Non-blocking; overflow drops.

pub fn enqueue_trace(&self, record: RequestTrace)

Enqueue a metadata-only request trace. Non-blocking; overflow drops.

pub fn enrich_trace( &self, request_id: &TraceId, events: Vec<ToolExecutionEvent>, )

pub fn trace_snapshot(&self, request_id: &TraceId) -> Option<RequestTrace>

pub fn stats(&self) -> WriterStats

Snapshot the counters.

pub fn shutdown(&self, timeout: Duration) -> ShutdownOutcome

Stop accepting new records, drain the queue until timeout, and return typed stats. On timeout the worker stays detached and keeps draining in the background — the caller never waits past the deadline. Safe from sync contexts; async callers should use Self::shutdown_async. Idempotent.

“Flushed” means every queued record was appended into the OS file buffers (write(2) returned) — there is deliberately no fsync: these are best-effort diagnostic logs, and surviving a kernel crash is not part of their contract.

pub async fn shutdown_async(&self, timeout: Duration) -> ShutdownOutcome

Async-safe wrapper around Self::shutdown (runs on the blocking pool so an executor thread is never parked).

Trait Implementations

impl Clone for TelemetryWriter

fn clone(&self) -> TelemetryWriter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TelemetryWriter

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

Formats the value using the given formatter.