Struct WsTransport 

pub struct WsTransport { /* private fields */ }

WebSocket transport for communicating with a Haystack server.

Uses a JSON envelope with Zinc-encoded grid bodies:

• Request: {"id": "<counter>", "op": "<op_name>", "body": "<zinc_grid>"}
• Response: {"id": "<counter>", "body": "<zinc_grid>"}

Supports concurrent in-flight requests by matching response IDs to pending oneshot channels via a background reader task.

Implementations

impl WsTransport

pub async fn connect(url: &str, auth_token: &str) -> Result<Self, ClientError>

Connect to a Haystack server via WebSocket.

url should be a ws:// or wss:// URL to the server’s WebSocket endpoint. auth_token is the bearer token obtained from SCRAM authentication.

pub async fn connect_with_timeout( url: &str, auth_token: &str, timeout: Duration, ) -> Result<Self, ClientError>

Connect with a custom request timeout.

Trait Implementations

impl Drop for WsTransport

fn drop(&mut self)

Executes the destructor for this type.

impl Transport for WsTransport

async fn call(&self, op: &str, req: &HGrid) -> Result<HGrid, ClientError>

Call a Haystack op with the given request grid and return the response grid.

async fn close(&self) -> Result<(), ClientError>

Close the transport, releasing any resources.