Struct BinanceSpot 

pub struct BinanceSpot { /* private fields */ }

BinanceSpot execution client using the official binance-sdk.

• REST API: account snapshot, balance/order/trade queries (startup/cold paths)
• WebSocket API: order placement, order cancellation, user data stream (hot paths)

Trait Implementations

impl Clone for BinanceSpot

fn clone(&self) -> BinanceSpot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BinanceSpot

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

Formats the value using the given formatter.

impl ExecutionClient for BinanceSpot

fn new(config: Self::Config) -> Self

Panics

Panics if the binance-sdk REST or WebSocket configuration builder fails (e.g. empty or malformed API key/secret).

async fn account_stream( &self, _assets: &[AssetNameExchange], instruments: &[InstrumentNameExchange], ) -> Result<Self::AccountStream, UnindexedClientError>

Returns a live stream of account events (fills, order updates, balance changes).

Startup Race Window

There is a brief window between the initial WS subscribe response and the internal event listener being registered inside the spawned connection manager. TRADE fills arriving in this gap are silently dropped. Callers that require fill completeness at startup MUST call ExecutionClient::fetch_trades with a 1–2 second lookback unconditionally after account_stream returns, before processing any events. Do not use the first event’s arrival as a readiness signal — the first event may be a recovered fill sent before live WS events start. The dedup cache absorbs any duplicates from the overlapping time window. Callers MUST also call ExecutionClient::fetch_open_orders after each reconnect to reconcile open-order state — order lifecycle events (NEW, CANCELED) are not recovered after a WS disconnect, only TRADE fills are.

async fn fetch_open_orders( &self, instruments: &[InstrumentNameExchange], ) -> Result<Vec<Order<ExchangeId, InstrumentNameExchange, Open>>, UnindexedClientError>

An empty instruments slice is the ExecutionClient “return all” sentinel: a single no-symbol GET /api/v3/openOrders call returns open orders across every instrument (each order’s instrument is recovered from its own symbol field). A non-empty slice fetches the listed instruments concurrently, per-symbol.

async fn fetch_trades( &self, time_since: DateTime<Utc>, instruments: &[InstrumentNameExchange], ) -> Result<Vec<Trade<AssetNameExchange, InstrumentNameExchange>>, UnindexedClientError>

Documented deviation from the ExecutionClient::fetch_trades “return all” contract: Binance’s myTrades endpoint requires a symbol — there is no no-symbol “all trades” query (unlike open orders). An empty instruments slice therefore has nothing to query and returns an empty Vec; callers wanting all trades must enumerate instruments explicitly.

const EXCHANGE: ExchangeId = ExchangeId::BinanceSpot

type Config = BinanceSpotConfig

type AccountStream = Pin<Box<dyn Stream<Item = AccountEvent<ExchangeId, AssetNameExchange, InstrumentNameExchange>> + Send>>

async fn account_snapshot( &self, assets: &[AssetNameExchange], instruments: &[InstrumentNameExchange], ) -> Result<UnindexedAccountSnapshot, UnindexedClientError>

async fn cancel_order( &self, request: OrderRequestCancel<ExchangeId, &InstrumentNameExchange>, ) -> Option<UnindexedOrderResponseCancel>

async fn open_order( &self, request: OrderRequestOpen<ExchangeId, &InstrumentNameExchange>, ) -> Option<Order<ExchangeId, InstrumentNameExchange, UnindexedOrderState>>

Place an order on the exchange.

async fn fetch_balances( &self, assets: &[AssetNameExchange], ) -> Result<Vec<AssetBalance<AssetNameExchange>>, UnindexedClientError>

Fetch current balances for the specified assets.

fn cancel_orders<'a>( &self, requests: impl IntoIterator<Item = OrderRequestCancel<ExchangeId, &'a InstrumentNameExchange>>, ) -> impl Stream<Item = Option<UnindexedOrderResponseCancel>> + Send

fn open_orders<'a>( &self, requests: impl IntoIterator<Item = OrderRequestOpen<ExchangeId, &'a InstrumentNameExchange>>, ) -> impl Stream<Item = Option<Order<ExchangeId, InstrumentNameExchange, UnindexedOrderState>>> + Send