Struct cfix::TradeClient

pub struct TradeClient { /* private fields */ }

Implementations

impl TradeClient

pub fn new( host: String, login: String, password: String, sender_comp_id: String, heartbeat_interval: Option<u32> ) -> Self

pub fn register_connection_handler<T: ConnectionHandler + Send + Sync + 'static>( &mut self, handler: T )

pub fn register_connection_handler_arc<T: ConnectionHandler + Send + Sync + 'static>( &mut self, handler: Arc<T> )

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

pub async fn disconnect(&mut self) -> Result<(), Error>

pub fn is_connected(&self) -> bool

pub async fn fetch_security_list(&self) -> Result<Vec<SymbolInformation>, Error>

Fetch the security list from the server.

This is asn asynchronous method that sends a request to the server and waits for the response. It returns a result containing the data if the request succesful, or an error if it fails.

pub async fn fetch_positions(&self) -> Result<Vec<PositionReport>, Error>

pub async fn fetch_all_order_status( &self, issue_data: Option<NaiveDateTime> ) -> Result<Vec<OrderStatusReport>, Error>

pub async fn new_market_order( &self, symbol: u32, side: Side, order_qty: f64, cl_ord_id: Option<String>, pos_id: Option<String>, transact_time: Option<NaiveDateTime>, custom_ord_label: Option<String> ) -> Result<NewOrderReport, Error>

pub async fn new_limit_order( &self, symbol: u32, side: Side, price: f64, order_qty: f64, cl_ord_id: Option<String>, pos_id: Option<String>, expire_time: Option<NaiveDateTime>, transact_time: Option<NaiveDateTime>, custom_ord_label: Option<String> ) -> Result<NewOrderReport, Error>

pub async fn new_stop_order( &self, symbol: u32, side: Side, stop_px: f64, order_qty: f64, cl_ord_id: Option<String>, pos_id: Option<String>, expire_time: Option<NaiveDateTime>, transact_time: Option<NaiveDateTime>, custom_ord_label: Option<String> ) -> Result<NewOrderReport, Error>

pub async fn replace_order(&self) -> Result<(), Error>

pub async fn close_position(&self) -> Result<(), Error>

pub async fn close_all_position(&self) -> Result<(), Error>

pub async fn cancel_order(&self) -> Result<(), Error>

pub async fn cancel_all_position(&self) -> Result<(), Error>