Struct TelemetryClient 

pub struct TelemetryClient { /* private fields */ }

Telemetry client for sending events to Signal Horizon.

Implementations

impl TelemetryClient

pub fn new(config: TelemetryConfig) -> Self

pub async fn record(&self, event: TelemetryEvent) -> TelemetryResult<()>

Records a telemetry event.

pub async fn flush(&self) -> TelemetryResult<()>

Flushes buffered events.

pub async fn report(&self, event: TelemetryEvent) -> TelemetryResult<()>

Reports a single event immediately (bypassing batching). Used for critical security alerts like blocks.

pub fn start_background_flush(&self) -> JoinHandle<()>

Starts the background flush task.

pub fn shutdown(&self)

Triggers shutdown of background tasks.

pub fn stats(&self) -> TelemetryStatsSnapshot

Returns telemetry statistics.

pub fn dropped_count(&self) -> u64

Returns the dropped event count.

pub fn is_enabled(&self) -> bool

Returns whether telemetry is enabled.

Trait Implementations

impl Clone for TelemetryClient

fn clone(&self) -> TelemetryClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl SignalEmitter for TelemetryClient

fn emit<'life0, 'life1, 'async_trait>( &'life0 self, signal_type: &'life1 str, payload: Value, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,