Struct TraderApi

#[repr(C)]
pub struct TraderApi { /* private fields */ }

Implementations

impl TraderApi

pub fn GetFrontInfo(&self) -> FrontInfoField

impl TraderApi

pub fn GetApiVersion(&self) -> String

impl TraderApi

pub fn Init(&self)

Examples found in repository

examples/td_api.rs (line 25)

fn main() {
    let (tx, rx) = channel();
    let api = Arc::new(TraderApi::CreateTraderApiAndSpi(
        tx,
        FLOW_PATH.to_string(),
        true,
    ));
    api.RegisterFront(FRONT_ADDR.to_string());
    api.SubscribePublicTopic(THOST_TE_RESUME_TYPE::THOST_TERT_QUICK as i32);
    api.SubscribePrivateTopic(THOST_TE_RESUME_TYPE::THOST_TERT_RESTART as i32);
    api.Init();

    loop {
        let msg = rx.recv().unwrap();
        match msg {
            TraderSpiMsg::OnFrontConnected => {
                println!("front connected");
                let req = ReqAuthenticateField {
                    BrokerID: BROKER_ID.to_string(),
                    UserID: USER_ID.to_string(),
                    AuthCode: AUTH_CODE.to_string(),
                    AppID: APP_ID.to_string(),
                    ..Default::default()
                };
                api.ReqAuthenticate(req, 0);
            }
            TraderSpiMsg::OnRspAuthenticate(_, rsp_info, _, _) => {
                if rsp_info.ErrorID != 0 {
                    println!("auth failed: {:?}", rsp_info);
                    std::process::exit(1);
                } else {
                    println!("auth success: {:?}", rsp_info);

                    let req = ReqUserLoginField {
                        BrokerID: BROKER_ID.to_string(),
                        UserID: USER_ID.to_string(),
                        Password: PASSWORD.to_string(),
                        ..Default::default()
                    };
                    api.ReqUserLogin(req, 0);
                }
            }
            TraderSpiMsg::OnRspUserLogin(_, rsp_info, _, _) => {
                if rsp_info.ErrorID != 0 {
                    println!("user login failed: {:?}", rsp_info);
                    std::process::exit(1);
                } else {
                    println!("user login success: {:?}", rsp_info);

                    api.ReqQryInstrument(QryInstrumentField::default(), 0);
                }
            }
            TraderSpiMsg::OnRspQryInstrument(instrument, rsp_info, _, _) => {
                if instrument.is_null {
                    eprintln!("qry instrument: {:?}", rsp_info);
                    std::process::exit(1);
                }

                println!("{:?}", instrument);
            }
            _ => {}
        }
    }
}

impl TraderApi

pub fn Join(&self) -> i32

impl TraderApi

pub fn GetTradingDay(&self) -> String

impl TraderApi

pub fn RegisterFront(&self, pszFrontAddress: String)

Examples found in repository

examples/td_api.rs (line 22)

fn main() {
    let (tx, rx) = channel();
    let api = Arc::new(TraderApi::CreateTraderApiAndSpi(
        tx,
        FLOW_PATH.to_string(),
        true,
    ));
    api.RegisterFront(FRONT_ADDR.to_string());
    api.SubscribePublicTopic(THOST_TE_RESUME_TYPE::THOST_TERT_QUICK as i32);
    api.SubscribePrivateTopic(THOST_TE_RESUME_TYPE::THOST_TERT_RESTART as i32);
    api.Init();

    loop {
        let msg = rx.recv().unwrap();
        match msg {
            TraderSpiMsg::OnFrontConnected => {
                println!("front connected");
                let req = ReqAuthenticateField {
                    BrokerID: BROKER_ID.to_string(),
                    UserID: USER_ID.to_string(),
                    AuthCode: AUTH_CODE.to_string(),
                    AppID: APP_ID.to_string(),
                    ..Default::default()
                };
                api.ReqAuthenticate(req, 0);
            }
            TraderSpiMsg::OnRspAuthenticate(_, rsp_info, _, _) => {
                if rsp_info.ErrorID != 0 {
                    println!("auth failed: {:?}", rsp_info);
                    std::process::exit(1);
                } else {
                    println!("auth success: {:?}", rsp_info);

                    let req = ReqUserLoginField {
                        BrokerID: BROKER_ID.to_string(),
                        UserID: USER_ID.to_string(),
                        Password: PASSWORD.to_string(),
                        ..Default::default()
                    };
                    api.ReqUserLogin(req, 0);
                }
            }
            TraderSpiMsg::OnRspUserLogin(_, rsp_info, _, _) => {
                if rsp_info.ErrorID != 0 {
                    println!("user login failed: {:?}", rsp_info);
                    std::process::exit(1);
                } else {
                    println!("user login success: {:?}", rsp_info);

                    api.ReqQryInstrument(QryInstrumentField::default(), 0);
                }
            }
            TraderSpiMsg::OnRspQryInstrument(instrument, rsp_info, _, _) => {
                if instrument.is_null {
                    eprintln!("qry instrument: {:?}", rsp_info);
                    std::process::exit(1);
                }

                println!("{:?}", instrument);
            }
            _ => {}
        }
    }
}

impl TraderApi

pub fn RegisterNameServer(&self, pszNsAddress: String)

impl TraderApi

pub fn RegisterFensUserInfo(&self, pFensUserInfo: FensUserInfoField)

impl TraderApi

pub fn SubscribePrivateTopic(&self, nResumeType: i32)

Examples found in repository

examples/td_api.rs (line 24)

fn main() {
    let (tx, rx) = channel();
    let api = Arc::new(TraderApi::CreateTraderApiAndSpi(
        tx,
        FLOW_PATH.to_string(),
        true,
    ));
    api.RegisterFront(FRONT_ADDR.to_string());
    api.SubscribePublicTopic(THOST_TE_RESUME_TYPE::THOST_TERT_QUICK as i32);
    api.SubscribePrivateTopic(THOST_TE_RESUME_TYPE::THOST_TERT_RESTART as i32);
    api.Init();

    loop {
        let msg = rx.recv().unwrap();
        match msg {
            TraderSpiMsg::OnFrontConnected => {
                println!("front connected");
                let req = ReqAuthenticateField {
                    BrokerID: BROKER_ID.to_string(),
                    UserID: USER_ID.to_string(),
                    AuthCode: AUTH_CODE.to_string(),
                    AppID: APP_ID.to_string(),
                    ..Default::default()
                };
                api.ReqAuthenticate(req, 0);
            }
            TraderSpiMsg::OnRspAuthenticate(_, rsp_info, _, _) => {
                if rsp_info.ErrorID != 0 {
                    println!("auth failed: {:?}", rsp_info);
                    std::process::exit(1);
                } else {
                    println!("auth success: {:?}", rsp_info);

                    let req = ReqUserLoginField {
                        BrokerID: BROKER_ID.to_string(),
                        UserID: USER_ID.to_string(),
                        Password: PASSWORD.to_string(),
                        ..Default::default()
                    };
                    api.ReqUserLogin(req, 0);
                }
            }
            TraderSpiMsg::OnRspUserLogin(_, rsp_info, _, _) => {
                if rsp_info.ErrorID != 0 {
                    println!("user login failed: {:?}", rsp_info);
                    std::process::exit(1);
                } else {
                    println!("user login success: {:?}", rsp_info);

                    api.ReqQryInstrument(QryInstrumentField::default(), 0);
                }
            }
            TraderSpiMsg::OnRspQryInstrument(instrument, rsp_info, _, _) => {
                if instrument.is_null {
                    eprintln!("qry instrument: {:?}", rsp_info);
                    std::process::exit(1);
                }

                println!("{:?}", instrument);
            }
            _ => {}
        }
    }
}

impl TraderApi

pub fn SubscribePublicTopic(&self, nResumeType: i32)

Examples found in repository

examples/td_api.rs (line 23)

fn main() {
    let (tx, rx) = channel();
    let api = Arc::new(TraderApi::CreateTraderApiAndSpi(
        tx,
        FLOW_PATH.to_string(),
        true,
    ));
    api.RegisterFront(FRONT_ADDR.to_string());
    api.SubscribePublicTopic(THOST_TE_RESUME_TYPE::THOST_TERT_QUICK as i32);
    api.SubscribePrivateTopic(THOST_TE_RESUME_TYPE::THOST_TERT_RESTART as i32);
    api.Init();

    loop {
        let msg = rx.recv().unwrap();
        match msg {
            TraderSpiMsg::OnFrontConnected => {
                println!("front connected");
                let req = ReqAuthenticateField {
                    BrokerID: BROKER_ID.to_string(),
                    UserID: USER_ID.to_string(),
                    AuthCode: AUTH_CODE.to_string(),
                    AppID: APP_ID.to_string(),
                    ..Default::default()
                };
                api.ReqAuthenticate(req, 0);
            }
            TraderSpiMsg::OnRspAuthenticate(_, rsp_info, _, _) => {
                if rsp_info.ErrorID != 0 {
                    println!("auth failed: {:?}", rsp_info);
                    std::process::exit(1);
                } else {
                    println!("auth success: {:?}", rsp_info);

                    let req = ReqUserLoginField {
                        BrokerID: BROKER_ID.to_string(),
                        UserID: USER_ID.to_string(),
                        Password: PASSWORD.to_string(),
                        ..Default::default()
                    };
                    api.ReqUserLogin(req, 0);
                }
            }
            TraderSpiMsg::OnRspUserLogin(_, rsp_info, _, _) => {
                if rsp_info.ErrorID != 0 {
                    println!("user login failed: {:?}", rsp_info);
                    std::process::exit(1);
                } else {
                    println!("user login success: {:?}", rsp_info);

                    api.ReqQryInstrument(QryInstrumentField::default(), 0);
                }
            }
            TraderSpiMsg::OnRspQryInstrument(instrument, rsp_info, _, _) => {
                if instrument.is_null {
                    eprintln!("qry instrument: {:?}", rsp_info);
                    std::process::exit(1);
                }

                println!("{:?}", instrument);
            }
            _ => {}
        }
    }
}

impl TraderApi

pub fn ReqAuthenticate( &self, pReqAuthenticateField: ReqAuthenticateField, nRequestID: i32, ) -> i32

Examples found in repository

examples/td_api.rs (line 39)

fn main() {
    let (tx, rx) = channel();
    let api = Arc::new(TraderApi::CreateTraderApiAndSpi(
        tx,
        FLOW_PATH.to_string(),
        true,
    ));
    api.RegisterFront(FRONT_ADDR.to_string());
    api.SubscribePublicTopic(THOST_TE_RESUME_TYPE::THOST_TERT_QUICK as i32);
    api.SubscribePrivateTopic(THOST_TE_RESUME_TYPE::THOST_TERT_RESTART as i32);
    api.Init();

    loop {
        let msg = rx.recv().unwrap();
        match msg {
            TraderSpiMsg::OnFrontConnected => {
                println!("front connected");
                let req = ReqAuthenticateField {
                    BrokerID: BROKER_ID.to_string(),
                    UserID: USER_ID.to_string(),
                    AuthCode: AUTH_CODE.to_string(),
                    AppID: APP_ID.to_string(),
                    ..Default::default()
                };
                api.ReqAuthenticate(req, 0);
            }
            TraderSpiMsg::OnRspAuthenticate(_, rsp_info, _, _) => {
                if rsp_info.ErrorID != 0 {
                    println!("auth failed: {:?}", rsp_info);
                    std::process::exit(1);
                } else {
                    println!("auth success: {:?}", rsp_info);

                    let req = ReqUserLoginField {
                        BrokerID: BROKER_ID.to_string(),
                        UserID: USER_ID.to_string(),
                        Password: PASSWORD.to_string(),
                        ..Default::default()
                    };
                    api.ReqUserLogin(req, 0);
                }
            }
            TraderSpiMsg::OnRspUserLogin(_, rsp_info, _, _) => {
                if rsp_info.ErrorID != 0 {
                    println!("user login failed: {:?}", rsp_info);
                    std::process::exit(1);
                } else {
                    println!("user login success: {:?}", rsp_info);

                    api.ReqQryInstrument(QryInstrumentField::default(), 0);
                }
            }
            TraderSpiMsg::OnRspQryInstrument(instrument, rsp_info, _, _) => {
                if instrument.is_null {
                    eprintln!("qry instrument: {:?}", rsp_info);
                    std::process::exit(1);
                }

                println!("{:?}", instrument);
            }
            _ => {}
        }
    }
}

impl TraderApi

pub fn RegisterUserSystemInfo( &self, pUserSystemInfo: UserSystemInfoField, ) -> i32

impl TraderApi

pub fn SubmitUserSystemInfo(&self, pUserSystemInfo: UserSystemInfoField) -> i32

impl TraderApi

pub fn RegisterWechatUserSystemInfo( &self, pUserSystemInfo: WechatUserSystemInfoField, ) -> i32

impl TraderApi

pub fn SubmitWechatUserSystemInfo( &self, pUserSystemInfo: WechatUserSystemInfoField, ) -> i32

impl TraderApi

pub fn ReqUserLogin( &self, pReqUserLoginField: ReqUserLoginField, nRequestID: i32, ) -> i32

Examples found in repository

examples/td_api.rs (line 54)

fn main() {
    let (tx, rx) = channel();
    let api = Arc::new(TraderApi::CreateTraderApiAndSpi(
        tx,
        FLOW_PATH.to_string(),
        true,
    ));
    api.RegisterFront(FRONT_ADDR.to_string());
    api.SubscribePublicTopic(THOST_TE_RESUME_TYPE::THOST_TERT_QUICK as i32);
    api.SubscribePrivateTopic(THOST_TE_RESUME_TYPE::THOST_TERT_RESTART as i32);
    api.Init();

    loop {
        let msg = rx.recv().unwrap();
        match msg {
            TraderSpiMsg::OnFrontConnected => {
                println!("front connected");
                let req = ReqAuthenticateField {
                    BrokerID: BROKER_ID.to_string(),
                    UserID: USER_ID.to_string(),
                    AuthCode: AUTH_CODE.to_string(),
                    AppID: APP_ID.to_string(),
                    ..Default::default()
                };
                api.ReqAuthenticate(req, 0);
            }
            TraderSpiMsg::OnRspAuthenticate(_, rsp_info, _, _) => {
                if rsp_info.ErrorID != 0 {
                    println!("auth failed: {:?}", rsp_info);
                    std::process::exit(1);
                } else {
                    println!("auth success: {:?}", rsp_info);

                    let req = ReqUserLoginField {
                        BrokerID: BROKER_ID.to_string(),
                        UserID: USER_ID.to_string(),
                        Password: PASSWORD.to_string(),
                        ..Default::default()
                    };
                    api.ReqUserLogin(req, 0);
                }
            }
            TraderSpiMsg::OnRspUserLogin(_, rsp_info, _, _) => {
                if rsp_info.ErrorID != 0 {
                    println!("user login failed: {:?}", rsp_info);
                    std::process::exit(1);
                } else {
                    println!("user login success: {:?}", rsp_info);

                    api.ReqQryInstrument(QryInstrumentField::default(), 0);
                }
            }
            TraderSpiMsg::OnRspQryInstrument(instrument, rsp_info, _, _) => {
                if instrument.is_null {
                    eprintln!("qry instrument: {:?}", rsp_info);
                    std::process::exit(1);
                }

                println!("{:?}", instrument);
            }
            _ => {}
        }
    }
}

impl TraderApi

pub fn ReqUserLogout( &self, pUserLogout: UserLogoutField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqUserPasswordUpdate( &self, pUserPasswordUpdate: UserPasswordUpdateField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqTradingAccountPasswordUpdate( &self, pTradingAccountPasswordUpdate: TradingAccountPasswordUpdateField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqUserAuthMethod( &self, pReqUserAuthMethod: ReqUserAuthMethodField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqGenUserCaptcha( &self, pReqGenUserCaptcha: ReqGenUserCaptchaField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqGenUserText( &self, pReqGenUserText: ReqGenUserTextField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqUserLoginWithCaptcha( &self, pReqUserLoginWithCaptcha: ReqUserLoginWithCaptchaField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqUserLoginWithText( &self, pReqUserLoginWithText: ReqUserLoginWithTextField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqUserLoginWithOTP( &self, pReqUserLoginWithOTP: ReqUserLoginWithOTPField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqOrderInsert( &self, pInputOrder: InputOrderField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqParkedOrderInsert( &self, pParkedOrder: ParkedOrderField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqParkedOrderAction( &self, pParkedOrderAction: ParkedOrderActionField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqOrderAction( &self, pInputOrderAction: InputOrderActionField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryMaxOrderVolume( &self, pQryMaxOrderVolume: QryMaxOrderVolumeField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqSettlementInfoConfirm( &self, pSettlementInfoConfirm: SettlementInfoConfirmField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqRemoveParkedOrder( &self, pRemoveParkedOrder: RemoveParkedOrderField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqRemoveParkedOrderAction( &self, pRemoveParkedOrderAction: RemoveParkedOrderActionField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqExecOrderInsert( &self, pInputExecOrder: InputExecOrderField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqExecOrderAction( &self, pInputExecOrderAction: InputExecOrderActionField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqForQuoteInsert( &self, pInputForQuote: InputForQuoteField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQuoteInsert( &self, pInputQuote: InputQuoteField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQuoteAction( &self, pInputQuoteAction: InputQuoteActionField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqBatchOrderAction( &self, pInputBatchOrderAction: InputBatchOrderActionField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqOptionSelfCloseInsert( &self, pInputOptionSelfClose: InputOptionSelfCloseField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqOptionSelfCloseAction( &self, pInputOptionSelfCloseAction: InputOptionSelfCloseActionField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqCombActionInsert( &self, pInputCombAction: InputCombActionField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryOrder(&self, pQryOrder: QryOrderField, nRequestID: i32) -> i32

impl TraderApi

pub fn ReqQryTrade(&self, pQryTrade: QryTradeField, nRequestID: i32) -> i32

impl TraderApi

pub fn ReqQryInvestorPosition( &self, pQryInvestorPosition: QryInvestorPositionField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryTradingAccount( &self, pQryTradingAccount: QryTradingAccountField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryInvestor( &self, pQryInvestor: QryInvestorField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryTradingCode( &self, pQryTradingCode: QryTradingCodeField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryInstrumentMarginRate( &self, pQryInstrumentMarginRate: QryInstrumentMarginRateField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryInstrumentCommissionRate( &self, pQryInstrumentCommissionRate: QryInstrumentCommissionRateField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryUserSession( &self, pQryUserSession: QryUserSessionField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryExchange( &self, pQryExchange: QryExchangeField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryProduct( &self, pQryProduct: QryProductField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryInstrument( &self, pQryInstrument: QryInstrumentField, nRequestID: i32, ) -> i32

Examples found in repository

examples/td_api.rs (line 64)

fn main() {
    let (tx, rx) = channel();
    let api = Arc::new(TraderApi::CreateTraderApiAndSpi(
        tx,
        FLOW_PATH.to_string(),
        true,
    ));
    api.RegisterFront(FRONT_ADDR.to_string());
    api.SubscribePublicTopic(THOST_TE_RESUME_TYPE::THOST_TERT_QUICK as i32);
    api.SubscribePrivateTopic(THOST_TE_RESUME_TYPE::THOST_TERT_RESTART as i32);
    api.Init();

    loop {
        let msg = rx.recv().unwrap();
        match msg {
            TraderSpiMsg::OnFrontConnected => {
                println!("front connected");
                let req = ReqAuthenticateField {
                    BrokerID: BROKER_ID.to_string(),
                    UserID: USER_ID.to_string(),
                    AuthCode: AUTH_CODE.to_string(),
                    AppID: APP_ID.to_string(),
                    ..Default::default()
                };
                api.ReqAuthenticate(req, 0);
            }
            TraderSpiMsg::OnRspAuthenticate(_, rsp_info, _, _) => {
                if rsp_info.ErrorID != 0 {
                    println!("auth failed: {:?}", rsp_info);
                    std::process::exit(1);
                } else {
                    println!("auth success: {:?}", rsp_info);

                    let req = ReqUserLoginField {
                        BrokerID: BROKER_ID.to_string(),
                        UserID: USER_ID.to_string(),
                        Password: PASSWORD.to_string(),
                        ..Default::default()
                    };
                    api.ReqUserLogin(req, 0);
                }
            }
            TraderSpiMsg::OnRspUserLogin(_, rsp_info, _, _) => {
                if rsp_info.ErrorID != 0 {
                    println!("user login failed: {:?}", rsp_info);
                    std::process::exit(1);
                } else {
                    println!("user login success: {:?}", rsp_info);

                    api.ReqQryInstrument(QryInstrumentField::default(), 0);
                }
            }
            TraderSpiMsg::OnRspQryInstrument(instrument, rsp_info, _, _) => {
                if instrument.is_null {
                    eprintln!("qry instrument: {:?}", rsp_info);
                    std::process::exit(1);
                }

                println!("{:?}", instrument);
            }
            _ => {}
        }
    }
}

impl TraderApi

pub fn ReqQryDepthMarketData( &self, pQryDepthMarketData: QryDepthMarketDataField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryTraderOffer( &self, pQryTraderOffer: QryTraderOfferField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQrySettlementInfo( &self, pQrySettlementInfo: QrySettlementInfoField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryTransferBank( &self, pQryTransferBank: QryTransferBankField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryInvestorPositionDetail( &self, pQryInvestorPositionDetail: QryInvestorPositionDetailField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryNotice(&self, pQryNotice: QryNoticeField, nRequestID: i32) -> i32

impl TraderApi

pub fn ReqQrySettlementInfoConfirm( &self, pQrySettlementInfoConfirm: QrySettlementInfoConfirmField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryInvestorPositionCombineDetail( &self, pQryInvestorPositionCombineDetail: QryInvestorPositionCombineDetailField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryCFMMCTradingAccountKey( &self, pQryCFMMCTradingAccountKey: QryCFMMCTradingAccountKeyField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryEWarrantOffset( &self, pQryEWarrantOffset: QryEWarrantOffsetField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryInvestorProductGroupMargin( &self, pQryInvestorProductGroupMargin: QryInvestorProductGroupMarginField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryExchangeMarginRate( &self, pQryExchangeMarginRate: QryExchangeMarginRateField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryExchangeMarginRateAdjust( &self, pQryExchangeMarginRateAdjust: QryExchangeMarginRateAdjustField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryExchangeRate( &self, pQryExchangeRate: QryExchangeRateField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQrySecAgentACIDMap( &self, pQrySecAgentACIDMap: QrySecAgentACIDMapField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryProductExchRate( &self, pQryProductExchRate: QryProductExchRateField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryProductGroup( &self, pQryProductGroup: QryProductGroupField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryMMInstrumentCommissionRate( &self, pQryMMInstrumentCommissionRate: QryMMInstrumentCommissionRateField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryMMOptionInstrCommRate( &self, pQryMMOptionInstrCommRate: QryMMOptionInstrCommRateField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryInstrumentOrderCommRate( &self, pQryInstrumentOrderCommRate: QryInstrumentOrderCommRateField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQrySecAgentTradingAccount( &self, pQryTradingAccount: QryTradingAccountField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQrySecAgentCheckMode( &self, pQrySecAgentCheckMode: QrySecAgentCheckModeField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQrySecAgentTradeInfo( &self, pQrySecAgentTradeInfo: QrySecAgentTradeInfoField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryOptionInstrTradeCost( &self, pQryOptionInstrTradeCost: QryOptionInstrTradeCostField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryOptionInstrCommRate( &self, pQryOptionInstrCommRate: QryOptionInstrCommRateField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryExecOrder( &self, pQryExecOrder: QryExecOrderField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryForQuote( &self, pQryForQuote: QryForQuoteField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryQuote(&self, pQryQuote: QryQuoteField, nRequestID: i32) -> i32

impl TraderApi

pub fn ReqQryOptionSelfClose( &self, pQryOptionSelfClose: QryOptionSelfCloseField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryInvestUnit( &self, pQryInvestUnit: QryInvestUnitField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryCombInstrumentGuard( &self, pQryCombInstrumentGuard: QryCombInstrumentGuardField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryCombAction( &self, pQryCombAction: QryCombActionField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryTransferSerial( &self, pQryTransferSerial: QryTransferSerialField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryAccountregister( &self, pQryAccountregister: QryAccountregisterField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryContractBank( &self, pQryContractBank: QryContractBankField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryParkedOrder( &self, pQryParkedOrder: QryParkedOrderField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryParkedOrderAction( &self, pQryParkedOrderAction: QryParkedOrderActionField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryTradingNotice( &self, pQryTradingNotice: QryTradingNoticeField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryBrokerTradingParams( &self, pQryBrokerTradingParams: QryBrokerTradingParamsField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryBrokerTradingAlgos( &self, pQryBrokerTradingAlgos: QryBrokerTradingAlgosField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQueryCFMMCTradingAccountToken( &self, pQueryCFMMCTradingAccountToken: QueryCFMMCTradingAccountTokenField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqFromBankToFutureByFuture( &self, pReqTransfer: ReqTransferField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqFromFutureToBankByFuture( &self, pReqTransfer: ReqTransferField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQueryBankAccountMoneyByFuture( &self, pReqQueryAccount: ReqQueryAccountField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryClassifiedInstrument( &self, pQryClassifiedInstrument: QryClassifiedInstrumentField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryCombPromotionParam( &self, pQryCombPromotionParam: QryCombPromotionParamField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryRiskSettleInvstPosition( &self, pQryRiskSettleInvstPosition: QryRiskSettleInvstPositionField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryRiskSettleProductStatus( &self, pQryRiskSettleProductStatus: QryRiskSettleProductStatusField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQrySPBMFutureParameter( &self, pQrySPBMFutureParameter: QrySPBMFutureParameterField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQrySPBMOptionParameter( &self, pQrySPBMOptionParameter: QrySPBMOptionParameterField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQrySPBMIntraParameter( &self, pQrySPBMIntraParameter: QrySPBMIntraParameterField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQrySPBMInterParameter( &self, pQrySPBMInterParameter: QrySPBMInterParameterField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQrySPBMPortfDefinition( &self, pQrySPBMPortfDefinition: QrySPBMPortfDefinitionField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQrySPBMInvestorPortfDef( &self, pQrySPBMInvestorPortfDef: QrySPBMInvestorPortfDefField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryInvestorPortfMarginRatio( &self, pQryInvestorPortfMarginRatio: QryInvestorPortfMarginRatioField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryInvestorProdSPBMDetail( &self, pQryInvestorProdSPBMDetail: QryInvestorProdSPBMDetailField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryInvestorCommoditySPMMMargin( &self, pQryInvestorCommoditySPMMMargin: QryInvestorCommoditySPMMMarginField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryInvestorCommodityGroupSPMMMargin( &self, pQryInvestorCommodityGroupSPMMMargin: QryInvestorCommodityGroupSPMMMarginField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQrySPMMInstParam( &self, pQrySPMMInstParam: QrySPMMInstParamField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQrySPMMProductParam( &self, pQrySPMMProductParam: QrySPMMProductParamField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQrySPBMAddOnInterParameter( &self, pQrySPBMAddOnInterParameter: QrySPBMAddOnInterParameterField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryRCAMSCombProductInfo( &self, pQryRCAMSCombProductInfo: QryRCAMSCombProductInfoField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryRCAMSInstrParameter( &self, pQryRCAMSInstrParameter: QryRCAMSInstrParameterField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryRCAMSIntraParameter( &self, pQryRCAMSIntraParameter: QryRCAMSIntraParameterField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryRCAMSInterParameter( &self, pQryRCAMSInterParameter: QryRCAMSInterParameterField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryRCAMSShortOptAdjustParam( &self, pQryRCAMSShortOptAdjustParam: QryRCAMSShortOptAdjustParamField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryRCAMSInvestorCombPosition( &self, pQryRCAMSInvestorCombPosition: QryRCAMSInvestorCombPositionField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryInvestorProdRCAMSMargin( &self, pQryInvestorProdRCAMSMargin: QryInvestorProdRCAMSMarginField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryRULEInstrParameter( &self, pQryRULEInstrParameter: QryRULEInstrParameterField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryRULEIntraParameter( &self, pQryRULEIntraParameter: QryRULEIntraParameterField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryRULEInterParameter( &self, pQryRULEInterParameter: QryRULEInterParameterField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryInvestorProdRULEMargin( &self, pQryInvestorProdRULEMargin: QryInvestorProdRULEMarginField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryInvestorPortfSetting( &self, pQryInvestorPortfSetting: QryInvestorPortfSettingField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryInvestorInfoCommRec( &self, pQryInvestorInfoCommRec: QryInvestorInfoCommRecField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryCombLeg( &self, pQryCombLeg: QryCombLegField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqOffsetSetting( &self, pInputOffsetSetting: InputOffsetSettingField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqCancelOffsetSetting( &self, pInputOffsetSetting: InputOffsetSettingField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn ReqQryOffsetSetting( &self, pQryOffsetSetting: QryOffsetSettingField, nRequestID: i32, ) -> i32

impl TraderApi

pub fn CreateTraderApiAndSpi( tx: Sender<TraderSpiMsg>, flow_path: String, is_production_mode: bool, ) -> UniquePtr<TraderApi>

Examples found in repository

examples/td_api.rs (lines 17-21)

fn main() {
    let (tx, rx) = channel();
    let api = Arc::new(TraderApi::CreateTraderApiAndSpi(
        tx,
        FLOW_PATH.to_string(),
        true,
    ));
    api.RegisterFront(FRONT_ADDR.to_string());
    api.SubscribePublicTopic(THOST_TE_RESUME_TYPE::THOST_TERT_QUICK as i32);
    api.SubscribePrivateTopic(THOST_TE_RESUME_TYPE::THOST_TERT_RESTART as i32);
    api.Init();

    loop {
        let msg = rx.recv().unwrap();
        match msg {
            TraderSpiMsg::OnFrontConnected => {
                println!("front connected");
                let req = ReqAuthenticateField {
                    BrokerID: BROKER_ID.to_string(),
                    UserID: USER_ID.to_string(),
                    AuthCode: AUTH_CODE.to_string(),
                    AppID: APP_ID.to_string(),
                    ..Default::default()
                };
                api.ReqAuthenticate(req, 0);
            }
            TraderSpiMsg::OnRspAuthenticate(_, rsp_info, _, _) => {
                if rsp_info.ErrorID != 0 {
                    println!("auth failed: {:?}", rsp_info);
                    std::process::exit(1);
                } else {
                    println!("auth success: {:?}", rsp_info);

                    let req = ReqUserLoginField {
                        BrokerID: BROKER_ID.to_string(),
                        UserID: USER_ID.to_string(),
                        Password: PASSWORD.to_string(),
                        ..Default::default()
                    };
                    api.ReqUserLogin(req, 0);
                }
            }
            TraderSpiMsg::OnRspUserLogin(_, rsp_info, _, _) => {
                if rsp_info.ErrorID != 0 {
                    println!("user login failed: {:?}", rsp_info);
                    std::process::exit(1);
                } else {
                    println!("user login success: {:?}", rsp_info);

                    api.ReqQryInstrument(QryInstrumentField::default(), 0);
                }
            }
            TraderSpiMsg::OnRspQryInstrument(instrument, rsp_info, _, _) => {
                if instrument.is_null {
                    eprintln!("qry instrument: {:?}", rsp_info);
                    std::process::exit(1);
                }

                println!("{:?}", instrument);
            }
            _ => {}
        }
    }
}

Trait Implementations

impl ExternType for TraderApi

type Kind = Opaque

Either cxx::kind::Opaque or cxx::kind::Trivial.

type Id

A type-level representation of the type’s C++ namespace and type name.

impl Send for TraderApi

impl Sync for TraderApi

impl UniquePtrTarget for TraderApi