Struct TelemetryPipeline 

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

Real-time telemetry pipeline.

Collects metrics from kernels and broadcasts them to subscribers.

Fields

config: TelemetryConfig

running: Arc<AtomicBool>

sender: Sender<TelemetryEvent>

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

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

start_time: Instant

sequence: AtomicU64

Implementations

impl TelemetryPipeline

pub fn new(config: TelemetryConfig) -> TelemetryPipeline

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.