Struct TradeSession 

pub struct TradeSession { /* private fields */ }

交易会话

Implementations

impl TradeSession

pub fn new( broker: String, user_id: String, password: String, dm: Arc<DataManager>, ws_url: String, ws_config: WebSocketConfig, ) -> Self

创建交易会话

pub async fn on_account<F>(&self, handler: F)

where F: Fn(Account) + Send + Sync + 'static,

注册账户更新回调

pub async fn on_position<F>(&self, handler: F)

where F: Fn(String, Position) + Send + Sync + 'static,

注册持仓更新回调

pub async fn on_order<F>(&self, handler: F)

where F: Fn(Order) + Send + Sync + 'static,

注册委托单更新回调

pub async fn on_trade<F>(&self, handler: F)

where F: Fn(Trade) + Send + Sync + 'static,

注册成交记录回调

pub async fn on_notification<F>(&self, handler: F)

where F: Fn(Notification) + Send + Sync + 'static,

注册通知回调

pub async fn on_error<F>(&self, handler: F)

where F: Fn(String) + Send + Sync + 'static,

注册错误回调

pub fn account_channel(&self) -> Receiver<Account>

获取账户更新 Channel（克隆接收端）

pub fn position_channel(&self) -> Receiver<PositionUpdate>

获取持仓更新 Channel（克隆接收端）

pub fn order_channel(&self) -> Receiver<Order>

获取委托单更新 Channel（克隆接收端）

pub fn trade_channel(&self) -> Receiver<Trade>

获取成交记录 Channel（克隆接收端）

pub fn notification_channel(&self) -> Receiver<Notification>

获取通知 Channel（克隆接收端）

impl TradeSession

pub async fn insert_order(&self, req: &InsertOrderRequest) -> Result<Order>

下单

pub async fn cancel_order(&self, order_id: &str) -> Result<()>

撤单

pub async fn get_account(&self) -> Result<Account>

获取账户信息

pub async fn get_position(&self, symbol: &str) -> Result<Position>

获取指定合约的持仓

pub async fn get_positions(&self) -> Result<HashMap<String, Position>>

获取所有持仓

pub async fn get_orders(&self) -> Result<HashMap<String, Order>>

获取所有委托单

pub async fn get_trades(&self) -> Result<HashMap<String, Trade>>

获取所有成交记录

pub async fn connect(&self) -> Result<()>

连接交易服务器

pub fn is_ready(&self) -> bool

检查交易会话是否已就绪

pub async fn close(&self) -> Result<()>

关闭交易会话