Expand description
WebSocket message dispatch for the OKX execution client.
Routes incoming OKXWsMessage variants to the appropriate parsing and
event emission paths. Orders with a tracked identity, including submitted
orders and registered external limit orders, produce order events. Untracked
orders fall back to execution reports for downstream reconciliation.
Structs§
- Algo
Cancel Context - WsDispatch
State - Shared state for cross-stream event deduplication between the private and business WebSocket dispatch loops.
Functions§
- dispatch_
execution_ reports - Dispatches execution reports with cross-stream deduplication.
- dispatch_
ws_ message - Dispatches a WebSocket message with cross-stream deduplication.
- emit_
algo_ cancel_ rejections - emit_
batch_ cancel_ failure