Struct TelemetryPipeline 

pub struct TelemetryPipeline { /* private fields */ }

Real-time telemetry pipeline.

Collects metrics from kernels and broadcasts them to subscribers.

Implementations

impl TelemetryPipeline

pub fn new(config: TelemetryConfig) -> Self

Create a new telemetry pipeline.

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

Subscribe to telemetry events.

pub fn register_source(&self, source: Arc<dyn MetricsSource>)

Register a metrics source.

pub fn unregister_source(&self, kernel_id: &KernelId)

Unregister a metrics source.

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

Start the telemetry collection loop.

pub fn stop(&self)

Stop the telemetry collection loop.

pub fn latest_snapshot(&self) -> Option<MetricsSnapshot>

Get the latest snapshot.

pub fn history(&self) -> Vec<MetricsSnapshot>

Get historical snapshots.

pub fn aggregate_over(&self, duration: Duration) -> Option<AggregateMetrics>

Get aggregate metrics over a time range.