Expand description
WebSocket handler and watch subscription manager.
This module provides two major components:
-
WatchManager— a thread-safe subscription registry that manages watch lifecycles (subscribe, poll, unsubscribe, add/remove IDs). -
ws_handler— an Axum WebSocket upgrade endpoint (GET /api/ws) that handles Haystack watch operations over JSON messages.
Structs§
- Watch
Manager - Manages watch subscriptions for change polling.
Functions§
- ws_
handler - WebSocket upgrade handler for
/api/ws.