Struct OrderRequestState 

pub struct OrderRequestState { /* private fields */ }

Implementations

impl OrderRequestState

pub fn new( cmd_tx_handle: Arc<RwLock<UnboundedSender<SpotHandlerCommand>>>, event_tx: UnboundedSender<OrderEventAny>, dispatch_state: Arc<WsDispatchState>, req_id_counter: Arc<AtomicU64>, timeout: Duration, trader_id: TraderId, account_id: AccountId, auth_token: Arc<RwLock<Option<String>>>, task_spawner: TaskSpawner, clock: &'static AtomicTime, ) -> Self

Creates a new OrderRequestState.

pub fn next_req_id(&self) -> u64

Returns the next request ID and advances the counter.

pub fn submit( self: &Arc<Self>, params: KrakenWsAddOrderParams, identity: PendingRequest, ts_now_ns: u64, ) -> Result<u64>

Sends an add_order request over the WebSocket transport.

Errors

Returns an error if the JSON envelope fails to serialise or if the handler command channel is closed.

pub fn amend( self: &Arc<Self>, params: KrakenWsAmendOrderParams, identity: PendingRequest, ts_now_ns: u64, ) -> Result<u64>

Sends an amend_order request over the WebSocket transport.

Errors

Returns an error if serialisation fails or the handler command channel is closed.

pub fn cancel( self: &Arc<Self>, params: KrakenWsCancelOrderParams, identity: PendingRequest, ts_now_ns: u64, ) -> Result<u64>

Sends a cancel_order request over the WebSocket transport.

Errors

Returns an error if serialisation fails or the handler command channel is closed.

pub fn batch_add( self: &Arc<Self>, params: KrakenWsBatchAddParams, identity: PendingRequest, ts_now_ns: u64, ) -> Result<u64>

Sends a batch_add request over the WebSocket transport.

Errors

Returns an error if serialisation fails or the handler command channel is closed.

pub fn handle_response( &self, response: &KrakenWsOrderResponse, ts_event_ns: u64, )

Routes an order-method WebSocket response to the correct event emitter.

ts_event_ns is the local receipt time. Kraken’s time_in/time_out are ignored to keep event ordering monotonic against the local clock. Timed-out requests remain correlated until a definitive response arrives.

Trait Implementations

impl Debug for OrderRequestState

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.