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 orders 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 open_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,

Opens a new long position with the specified size, leverage, and optional risk management parameters. Returns the UUID of the created trade.

fn open_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,

Opens a new short position with the specified size, leverage, and optional risk management parameters. Returns the UUID of the created trade.

fn 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 trade, reducing its leverage.

fn 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 trade without closing the position.

fn close_trade<'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 trade by its ID.

fn 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 long positions. Returns the UUIDs of the closed trades.

fn 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 short positions. Returns the UUIDs of the closed trades.

fn 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 open positions (both long and short). Returns the UUIDs of the closed trades.

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.