You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
36 lines
1.3 KiB
36 lines
1.3 KiB
package data
|
|
|
|
import (
|
|
"context"
|
|
)
|
|
|
|
// InitSpots
|
|
//
|
|
// @Description: 现货交易
|
|
// @param data
|
|
func InitSpots(data *Data) {
|
|
go SubscribeQuotesSpots(context.Background(), data, spots) // 现货下单交易对行情订阅
|
|
go InitSubscribeQuotesSpots(spots) // 检查交易订单订阅标识状态机
|
|
go SpotsTransaction() // 监控现货挂单缓存队列
|
|
}
|
|
|
|
// InitContract
|
|
//
|
|
// @Description: 合约交易
|
|
// @param data
|
|
func InitContract(data *Data) {
|
|
go SubscribeQuotesContract(context.Background(), data, contract) // 合约下单交易对行情订阅
|
|
go InitSubscribeQuotesContract(contract) // 检查交易订单订阅标识状态机
|
|
go ContractTransactionEntrust(context.Background()) // 监控合约挂单缓存队列
|
|
go ContractTransactionPosition(context.Background()) // 监控合约持仓缓存队列
|
|
}
|
|
|
|
// InitSecond
|
|
//
|
|
// @Description: 秒合约交易
|
|
// @param data
|
|
func InitSecond(data *Data) {
|
|
go SubscribeQuotesSecond(context.Background(), data, second) // 秒合约下单交易对行情订阅
|
|
go InitSubscribeQuotesSecond() // 检查交易订单订阅标识状态机
|
|
go SecondTransactionPosition(context.Background()) // 监控秒合约持仓缓存队列
|
|
}
|
|
|