Expand description
WebSocket message dispatch for the OKX execution client.
Routes incoming OKXWsMessage variants to the appropriate parsing and
event emission paths. Tracked orders (submitted through this client) produce
proper order events; untracked orders fall back to execution reports for
downstream reconciliation.
Structs§
- Algo
Cancel Context - Order
Identity - Order identity context stored at submission time, used by the WS dispatch task to produce proper order events without Cache access.
- 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