Struct LiveTradeExecutor 

pub struct LiveTradeExecutor { /* private fields */ }

Live trade executor implementing the TradeExecutor trait for real-time trade execution on an exchange. Manages trading sessions, validates operations, and maintains trade state.

Implementations

impl LiveTradeExecutor

pub fn update_receiver(&self) -> LiveTradeExecutorReceiver

Creates a new LiveTradeExecutorReceiver for subscribing to trade executor updates including executor actions, status changes, trading state, and closed trades.

pub async fn shutdown(&self) -> Result<(), LiveTradeExecutorError>

Shuts down the trade executor and optionally closes all running trades. This method can only be called once per executor instance.

Trait Implementations

impl TradeExecutor for LiveTradeExecutor

fn isolated_order<'life0, 'async_trait>( &'life0 self, request: IsolatedOrderRequest, ) -> Pin<Box<dyn Future<Output = Result<Uuid, TradeExecutorError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Places a validated isolated-margin market order.

fn isolated_trade_add_margin<'life0, 'async_trait>( &'life0 self, trade_id: Uuid, amount: NonZeroU64, ) -> Pin<Box<dyn Future<Output = Result<(), TradeExecutorError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Adds margin to an existing isolated trade, reducing its leverage.

fn isolated_trade_cash_in<'life0, 'async_trait>( &'life0 self, trade_id: Uuid, amount: NonZeroU64, ) -> Pin<Box<dyn Future<Output = Result<(), TradeExecutorError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Withdraws profit and/or margin from a running isolated trade without closing the position.

fn isolated_order_close<'life0, 'async_trait>( &'life0 self, trade_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<(), TradeExecutorError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Closes a specific isolated trade by its ID.

fn isolated_order_close_longs<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<Uuid>, TradeExecutorError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Closes all isolated long positions. Returns the UUIDs of the closed trades.

fn isolated_order_close_shorts<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<Uuid>, TradeExecutorError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Closes all isolated short positions. Returns the UUIDs of the closed trades.

fn isolated_order_close_all<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<Uuid>, TradeExecutorError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Closes all isolated positions. Returns the UUIDs of the closed trades.

fn cross_deposit<'life0, 'async_trait>( &'life0 self, amount: NonZeroU64, ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn CrossPositionCore>, TradeExecutorError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Transfers satoshis from isolated/free balance into the cross-margin account and returns the updated cross position.

fn cross_withdraw<'life0, 'async_trait>( &'life0 self, amount: NonZeroU64, ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn CrossPositionCore>, TradeExecutorError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Transfers satoshis from the cross-margin account back to isolated/free balance and returns the updated cross position.

fn cross_set_leverage<'life0, 'async_trait>( &'life0 self, leverage: CrossLeverage, ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn CrossPositionCore>, TradeExecutorError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Sets the account-level cross-margin leverage and returns the updated cross position.

fn cross_order<'life0, 'async_trait>( &'life0 self, request: CrossOrderRequest, ) -> Pin<Box<dyn Future<Output = Result<Uuid, TradeExecutorError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Places a validated cross-margin market order and returns the cross-order UUID.

fn cross_order_close_position<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Option<Uuid>, TradeExecutorError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Closes the full cross-margin position, returning the closing cross-order UUID when a position was open.

fn trading_state<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<TradingState, TradeExecutorError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns the current trading state including balance, positions, and metrics.

fn isolated_order_market_long<'life0, 'async_trait>( &'life0 self, size: TradeSize, leverage: Leverage, stoploss: Option<Stoploss>, takeprofit: Option<Price>, client_id: Option<ClientId>, ) -> Pin<Box<dyn Future<Output = Result<Uuid, TradeExecutorError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Places an isolated-margin market long order.

fn isolated_order_market_short<'life0, 'async_trait>( &'life0 self, size: TradeSize, leverage: Leverage, stoploss: Option<Stoploss>, takeprofit: Option<Price>, client_id: Option<ClientId>, ) -> Pin<Box<dyn Future<Output = Result<Uuid, TradeExecutorError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Places an isolated-margin market short order.

fn cross_order_market_long<'life0, 'async_trait>( &'life0 self, quantity: OrderQuantity, ) -> Pin<Box<dyn Future<Output = Result<Uuid, TradeExecutorError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Places a cross-margin market long order and returns the cross-order UUID.

fn cross_order_market_short<'life0, 'async_trait>( &'life0 self, quantity: OrderQuantity, ) -> Pin<Box<dyn Future<Output = Result<Uuid, TradeExecutorError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Places a cross-margin market short order and returns the cross-order UUID.