Struct WebSocketServer 

pub struct WebSocketServer {
    metrics: Arc<RwLock<AggregatedMetrics>>,
    port: u16,
    push_interval_ms: u64,
}

WebSocket server for real-time telemetry streaming to zernel watch.

Fields

metrics: Arc<RwLock<AggregatedMetrics>>

port: u16

push_interval_ms: u64

Implementations

impl WebSocketServer

pub fn new( metrics: Arc<RwLock<AggregatedMetrics>>, port: u16, push_interval_ms: u64, ) -> Self

pub async fn serve(&self) -> Result<()>