Struct TelemetryPipeline 

pub struct TelemetryPipeline {
    config: TelemetryConfig,
    running: Arc<AtomicBool>,
    sender: Sender<TelemetryEvent>,
    sources: Arc<RwLock<HashMap<KernelId, Arc<dyn MetricsSource>>>>,
    history: Arc<RwLock<Vec<MetricsSnapshot>>>,
    start_time: Instant,
    sequence: AtomicU64,
}

Real-time telemetry pipeline.

Collects metrics from kernels and broadcasts them to subscribers.

Fields

config: TelemetryConfig

Configuration.

running: Arc<AtomicBool>

Running state.

sender: Sender<TelemetryEvent>

Broadcast sender for events.

sources: Arc<RwLock<HashMap<KernelId, Arc<dyn MetricsSource>>>>

Registered metrics sources.

history: Arc<RwLock<Vec<MetricsSnapshot>>>

Historical snapshots.

start_time: Instant

Pipeline start time.

sequence: AtomicU64

Sequence number for events.

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.

fn collect_snapshot( sources: &RwLock<HashMap<KernelId, Arc<dyn MetricsSource>>>, start_time: Instant, _config: &TelemetryConfig, ) -> MetricsSnapshot

Collect a metrics snapshot.

fn check_alerts( snapshot: &MetricsSnapshot, config: &TelemetryConfig, ) -> Vec<TelemetryAlert>

Check for alert conditions.