matchmaking-system/internal/data/control_virtual.go

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())           // 监控秒合约持仓缓存队列
}