Struct BinanceSpotHttpClient 

pub struct BinanceSpotHttpClient { /* private fields */ }

High-level HTTP client for Binance Spot API.

Wraps BinanceRawSpotHttpClient and provides domain-level methods:

• Simple types (ping, server_time): Pass through from raw client.
• Complex types (instruments, orders): Transform to Nautilus domain types.

Implementations

impl BinanceSpotHttpClient

pub fn new( environment: BinanceEnvironment, clock: &'static AtomicTime, api_key: Option<String>, api_secret: Option<String>, base_url_override: Option<String>, recv_window: Option<u64>, timeout_secs: Option<u64>, proxy_url: Option<String>, ) -> BinanceSpotHttpResult<Self>

Creates a new Binance Spot HTTP client.

Errors

Returns an error if the underlying HTTP client cannot be created.

pub fn inner(&self) -> &BinanceRawSpotHttpClient

Returns a reference to the inner raw client.

pub const fn schema_id() -> u16

Returns the SBE schema ID.

pub const fn schema_version() -> u16

Returns the SBE schema version.

pub fn cache_instruments(&self, instruments: Vec<InstrumentAny>)

Caches multiple instruments.

pub fn cache_instrument(&self, instrument: InstrumentAny)

Caches a single instrument.

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

Gets an instrument from the cache by symbol.

pub async fn ping(&self) -> BinanceSpotHttpResult<()>

Tests connectivity to the API.

Errors

Returns an error if the request fails or SBE decoding fails.

pub async fn server_time(&self) -> BinanceSpotHttpResult<i64>

Returns the server time in microseconds since epoch.

Note: SBE provides microsecond precision vs JSON’s milliseconds.

Errors

Returns an error if the request fails or SBE decoding fails.

pub async fn exchange_info( &self, ) -> BinanceSpotHttpResult<BinanceExchangeInfoSbe>

Returns exchange information including trading symbols.

Errors

Returns an error if the request fails or SBE decoding fails.

pub async fn request_instruments( &self, ) -> BinanceSpotHttpResult<Vec<InstrumentAny>>

Requests Nautilus instruments for all trading symbols.

Fetches exchange info via SBE and parses each symbol into a CurrencyPair. Non-trading symbols are skipped with a debug log.

Errors

Returns an error if the request fails or SBE decoding fails.

pub async fn request_trades( &self, instrument_id: InstrumentId, limit: Option<u32>, ) -> Result<Vec<TradeTick>>

Requests recent trades for an instrument.

Errors

Returns an error if the request fails, the instrument is not cached, or trade parsing fails.

pub async fn request_bars( &self, bar_type: BarType, start: Option<DateTime<Utc>>, end: Option<DateTime<Utc>>, limit: Option<u32>, ) -> Result<Vec<Bar>>

Requests bar (kline/candlestick) data.

Errors

Returns an error if the bar type is not supported, instrument is not cached, or the request fails.

pub async fn request_account_state( &self, account_id: AccountId, ) -> Result<AccountState>

Requests the account state with Nautilus types.

Errors

Returns an error if the request fails or SBE decoding fails.

pub async fn request_order_status_report( &self, account_id: AccountId, instrument_id: InstrumentId, venue_order_id: Option<VenueOrderId>, client_order_id: Option<ClientOrderId>, ) -> Result<OrderStatusReport>

Requests the status of a specific order.

Either venue_order_id or client_order_id must be provided.

Errors

Returns an error if neither identifier is provided, the request fails, instrument is not cached, or parsing fails.

pub async fn request_order_status_reports( &self, account_id: AccountId, instrument_id: Option<InstrumentId>, start: Option<DateTime<Utc>>, end: Option<DateTime<Utc>>, open_only: bool, limit: Option<u32>, ) -> Result<Vec<OrderStatusReport>>

Requests order status reports.

When open_only is true, returns only open orders (instrument_id optional). When open_only is false, returns order history (instrument_id required).

Errors

Returns an error if the request fails, any order’s instrument is not cached, or parsing fails.

pub async fn request_fill_reports( &self, account_id: AccountId, instrument_id: InstrumentId, venue_order_id: Option<VenueOrderId>, start: Option<DateTime<Utc>>, end: Option<DateTime<Utc>>, limit: Option<u32>, ) -> Result<Vec<FillReport>>

Requests fill reports (trade history) for an instrument.

Errors

Returns an error if the request fails, any trade’s instrument is not cached, or parsing fails.

pub async fn submit_order( &self, account_id: AccountId, 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, quote_quantity: bool, display_qty: Option<Quantity>, ) -> Result<OrderStatusReport>

Submits a new order to the venue.

Converts Nautilus domain types to Binance-specific parameters and returns an OrderStatusReport.

Errors

Returns an error if:

• The instrument is not cached.
• The order type or time-in-force is unsupported.
• Stop orders are submitted without a trigger price.
• The request fails or SBE decoding fails.

pub async fn submit_order_list( &self, orders: &[BatchOrderItem], ) -> BinanceSpotHttpResult<Vec<BatchOrderResult>>

Submits multiple orders in a single batch request.

Binance limits batch submit to 5 orders maximum.

Errors

Returns an error if the request fails or JSON parsing fails.

pub async fn modify_order( &self, account_id: AccountId, instrument_id: InstrumentId, venue_order_id: VenueOrderId, client_order_id: ClientOrderId, order_side: OrderSide, order_type: OrderType, quantity: Quantity, time_in_force: TimeInForce, price: Option<Price>, ) -> Result<OrderStatusReport>

Modifies an existing order (cancel and replace atomically).

Errors

Returns an error if:

• The instrument is not cached.
• The order type or time-in-force is unsupported.
• The request fails or SBE decoding fails.

pub async fn cancel_order( &self, instrument_id: InstrumentId, venue_order_id: Option<VenueOrderId>, client_order_id: Option<ClientOrderId>, ) -> Result<VenueOrderId>

Cancels an existing order on the venue.

Either venue_order_id or client_order_id must be provided.

Errors

Returns an error if the request fails or SBE decoding fails.

pub async fn batch_cancel_orders( &self, cancels: &[BatchCancelItem], ) -> BinanceSpotHttpResult<Vec<BatchCancelResult>>

Cancels multiple orders in a single batch request.

Binance limits batch cancel to 5 orders maximum.

Errors

Returns an error if the request fails or JSON parsing fails.

pub async fn cancel_all_orders( &self, instrument_id: InstrumentId, ) -> Result<Vec<(VenueOrderId, ClientOrderId)>>

Cancels all open orders for a symbol.

Returns the venue order IDs of all canceled orders.

Errors

Returns an error if the request fails or SBE decoding fails.

Trait Implementations

impl Clone for BinanceSpotHttpClient

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 BinanceSpotHttpClient

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

Formats the value using the given formatter.