Struct WsSession 

pub struct WsSession { /* private fields */ }

A WebSocket session to the coordinator.

Provides synchronous request() for request-reply and subscribe_logs() for streaming log events, both over the same WS connection.

Implementations

impl WsSession

pub fn connect(addr: SocketAddr) -> Result<Self>

Connect to the coordinator via WebSocket.

If called from within an existing tokio runtime, uses that runtime. Otherwise creates a dedicated runtime with one worker thread so the WS receive loop keeps running after synchronous API calls return.

pub fn request(&self, data: &[u8]) -> Result<Vec<u8>>

Send a request and wait synchronously for the reply.

data should be a serialized ControlRequest. Returns the serialized ControlRequestReply.

pub fn subscribe_topics( &self, dataflow_id: Uuid, topics: Vec<(NodeId, DataId)>, ) -> Result<(Uuid, Receiver<Result<Vec<u8>>>)>

Subscribe to topic data via the coordinator’s topic inspection stream.

Sends a TopicSubscribe request, waits for the ack, then returns a (subscription_id, receiver) pair. Binary WS frames with matching subscription UUID prefix are dispatched to the receiver.

pub fn subscribe_logs( &self, request: &[u8], ) -> Result<Receiver<Result<Vec<u8>>>>

Subscribe to log events on this connection.

Sends the subscribe request (LogSubscribe or BuildLogSubscribe), waits for the ack, then returns a receiver for log event payloads.

Each received item is the serialized LogMessage.