Struct AxOrdersWebSocketClient 

pub struct AxOrdersWebSocketClient { /* private fields */ }

Orders WebSocket client for Ax.

Provides authenticated order management including placing, canceling, and monitoring order status via WebSocket.

Implementations

impl AxOrdersWebSocketClient

pub fn new( url: String, account_id: AccountId, trader_id: TraderId, heartbeat: Option<u64>, ) -> Self

Creates a new Ax orders WebSocket client.

pub fn url(&self) -> &str

Returns the WebSocket URL.

pub fn account_id(&self) -> AccountId

Returns the account ID.

pub fn is_active(&self) -> bool

Returns whether the client is currently connected and active.

pub fn is_closed(&self) -> bool

Returns whether the client is closed.

pub fn cache_instrument(&self, instrument: InstrumentAny)

Caches an instrument for use during message parsing.

pub fn get_cached_instrument(&self, symbol: &Ustr) -> Option<InstrumentAny>

Returns a cached instrument by symbol.

pub fn orders_metadata(&self) -> &Arc<DashMap<ClientOrderId, OrderMetadata>>

Returns the orders metadata cache.

pub fn cid_to_client_order_id(&self) -> &Arc<DashMap<u64, ClientOrderId>>

Returns the cid to client order ID mapping for order correlation.

pub fn resolve_cid(&self, cid: u64) -> Option<ClientOrderId>

Resolves a cid to a ClientOrderId if the mapping exists.

pub fn register_external_order( &self, client_order_id: ClientOrderId, venue_order_id: VenueOrderId, instrument_id: InstrumentId, strategy_id: StrategyId, ) -> bool

Registers an external order with the WebSocket handler for event tracking.

This allows the handler to create proper events (e.g., OrderCanceled, OrderFilled) for orders that were reconciled externally and not submitted through this client.

Returns false if the instrument is not cached (registration skipped).

pub async fn connect(&mut self, bearer_token: &str) -> AxOrdersWsResult<()>

Establishes the WebSocket connection with authentication.

Arguments

• bearer_token - The bearer token for authentication.

Errors

Returns an error if the connection cannot be established.

pub async fn submit_order( &self, trader_id: TraderId, strategy_id: StrategyId, instrument_id: InstrumentId, client_order_id: ClientOrderId, order_side: OrderSide, order_type: OrderType, quantity: Quantity, time_in_force: TimeInForce, price: Option<Price>, trigger_price: Option<Price>, post_only: bool, ) -> AxOrdersWsResult<i64>

Submits an order using Nautilus domain types.

This method handles conversion from Nautilus domain types to AX-specific types and stores order metadata for event correlation.

Errors

Returns an error if:

• The order type is not supported (only MARKET (simulated), LIMIT and STOP_LIMIT).
• The time-in-force is not supported.
• The instrument is not found in the cache.
• A limit order is missing a price.
• A stop-loss order is missing a trigger price.
• The order command cannot be sent.

pub async fn cancel_order( &self, client_order_id: ClientOrderId, venue_order_id: Option<VenueOrderId>, ) -> AxOrdersWsResult<i64>

Cancels an order via WebSocket.

Requires a known venue_order_id.

Errors

Returns an error if the cancel command cannot be sent.

pub async fn get_open_orders(&self) -> AxOrdersWsResult<i64>

Requests open orders via WebSocket.

Errors

Returns an error if the request command cannot be sent.

pub fn stream(&mut self) -> impl Stream<Item = AxOrdersWsMessage> + 'static

Returns a stream of WebSocket messages.

Panics

Panics if called before connect() or if the stream has already been taken.

pub async fn disconnect(&self)

Disconnects the WebSocket connection gracefully.

pub async fn close(&mut self)

Closes the WebSocket connection and cleans up resources.

impl AxOrdersWebSocketClient

pub fn py_url(&self) -> &str

pub fn py_account_id(&self) -> AccountId

pub fn py_is_active(&self) -> bool

pub fn py_is_closed(&self) -> bool

Trait Implementations

impl Clone for AxOrdersWebSocketClient

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for AxOrdersWebSocketClient

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

Formats the value using the given formatter.

impl<'py> IntoPyObject<'py> for AxOrdersWebSocketClient

type Target = AxOrdersWebSocketClient

The Python output type

type Output = Bound<'py, <AxOrdersWebSocketClient as IntoPyObject<'py>>::Target>

The smart pointer type to use.

type Error = PyErr

The type returned in the event of a conversion error.

fn into_pyobject( self, py: Python<'py>, ) -> Result<<Self as IntoPyObject<'_>>::Output, <Self as IntoPyObject<'_>>::Error>

Performs the conversion.

impl PyClass for AxOrdersWebSocketClient

type Frozen = False

Whether the pyclass is frozen.

impl PyClassImpl for AxOrdersWebSocketClient

const IS_BASETYPE: bool = false

#[pyclass(subclass)]

const IS_SUBCLASS: bool = false

#[pyclass(extends=…)]

const IS_MAPPING: bool = false

#[pyclass(mapping)]

const IS_SEQUENCE: bool = false

#[pyclass(sequence)]

const IS_IMMUTABLE_TYPE: bool = false

#[pyclass(immutable_type)]

const RAW_DOC: &'static CStr = /// Orders WebSocket client for Ax. /// /// Provides authenticated order management including placing, canceling, /// and monitoring order status via WebSocket.

Docstring for the class provided on the struct or enum.

const DOC: &'static CStr

Fully rendered class doc, including the text_signature if a constructor is defined.

type BaseType = PyAny

Base class

type ThreadChecker = SendablePyClass<AxOrdersWebSocketClient>

This handles following two situations:

type PyClassMutability = <<PyAny as PyClassBaseType>::PyClassMutability as PyClassMutability>::MutableChild

Immutable or mutable

type Dict = PyClassDummySlot

Specify this class has #[pyclass(dict)] or not.

type WeakRef = PyClassDummySlot

Specify this class has #[pyclass(weakref)] or not.

type BaseNativeType = PyAny

The closest native ancestor. This is PyAny by default, and when you declare #[pyclass(extends=PyDict)], it’s PyDict.

fn items_iter() -> PyClassItemsIter

fn lazy_type_object() -> &'static LazyTypeObject<Self>

fn dict_offset() -> Option<isize>

fn weaklist_offset() -> Option<isize>

impl PyClassNewTextSignature for AxOrdersWebSocketClient

const TEXT_SIGNATURE: &'static str = "(url, account_id, trader_id, heartbeat=None)"

impl PyMethods<AxOrdersWebSocketClient> for PyClassImplCollector<AxOrdersWebSocketClient>

fn py_methods(self) -> &'static PyClassItems

impl PyTypeInfo for AxOrdersWebSocketClient

const NAME: &'static str = "AxOrdersWebSocketClient"

Class name.

const MODULE: Option<&'static str>

Module name, if any.

fn type_object_raw(py: Python<'_>) -> *mut PyTypeObject

Returns the PyTypeObject instance for this type.

fn type_object(py: Python<'_>) -> Bound<'_, PyType>

Returns the safe abstraction over the type object.

fn is_type_of(object: &Bound<'_, PyAny>) -> bool

Checks if object is an instance of this type or a subclass of this type.

fn is_exact_type_of(object: &Bound<'_, PyAny>) -> bool

Checks if object is an instance of this type.

impl DerefToPyAny for AxOrdersWebSocketClient

impl ExtractPyClassWithClone for AxOrdersWebSocketClient