Struct TraceServer 

pub struct TraceServer { /* private fields */ }

The shared trace server. Clone the Arc, not the server.

Implementations

impl TraceServer

pub fn new(vars: VariableMap) -> Arc<TraceServer>

Build a server that decodes variables according to vars.

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

Subscribe to the JSON event stream (one JSON object per message).

pub fn ingest(&self, bytes: &[u8]) -> Vec<TraceEvent>

Decode bytes, broadcast the resulting events, and return them (handy for tests and for callers that want to log locally).

pub fn flush(&self) -> Vec<TraceEvent>

Emit any buffered partial log line. Call when the source ends.

pub async fn serve_ws( self: &Arc<Self>, addr: &str, ) -> Result<(SocketAddr, JoinHandle<()>)>

Bind a WebSocket listener on addr and accept clients in the background. Returns the bound address (useful when addr uses port 0).

pub async fn run_source<R: AsyncRead + Unpin>( self: &Arc<Self>, reader: R, ) -> Result<()>

Read SWO bytes from reader until EOF, feeding the pipeline.