142 lines
4.0 KiB
Go
142 lines
4.0 KiB
Go
package ws
|
|
|
|
import (
|
|
"errors"
|
|
. "gitea.zjmud.xyz/phyer/v5sdkgo/ws/wImpl"
|
|
)
|
|
|
|
/*
|
|
产品频道
|
|
*/
|
|
func (a *WsClient) PubInstruemnts(op string, params []map[string]string, timeOut ...int) (res bool, msg []*Msg, err error) {
|
|
|
|
return a.PubChannel(EVENT_BOOK_INSTRUMENTS, op, params, PERIOD_NONE, timeOut...)
|
|
}
|
|
|
|
// 获取系统维护的状态，当系统维护状态改变时推送
|
|
func (a *WsClient) PubStatus(op string, timeOut ...int) (res bool, msg []*Msg, err error) {
|
|
return a.PubChannel(EVENT_STATUS, op, nil, PERIOD_NONE, timeOut...)
|
|
}
|
|
|
|
/*
|
|
行情频道
|
|
*/
|
|
func (a *WsClient) PubTickers(op string, params []map[string]string, timeOut ...int) (res bool, msg []*Msg, err error) {
|
|
|
|
return a.PubChannel(EVENT_BOOK_TICKERS, op, params, PERIOD_NONE, timeOut...)
|
|
}
|
|
|
|
/*
|
|
持仓总量频道
|
|
*/
|
|
func (a *WsClient) PubOpenInsterest(op string, params []map[string]string, timeOut ...int) (res bool, msg []*Msg, err error) {
|
|
return a.PubChannel(EVENT_BOOK_OPEN_INTEREST, op, params, PERIOD_NONE, timeOut...)
|
|
}
|
|
|
|
/*
|
|
K线频道
|
|
*/
|
|
func (a *WsClient) PubKLine(op string, period Period, params []map[string]string, timeOut ...int) (res bool, msg []*Msg, err error) {
|
|
|
|
return a.PubChannel(EVENT_BOOK_KLINE, op, params, period, timeOut...)
|
|
}
|
|
|
|
/*
|
|
交易频道
|
|
*/
|
|
func (a *WsClient) PubTrade(op string, params []map[string]string, timeOut ...int) (res bool, msg []*Msg, err error) {
|
|
|
|
return a.PubChannel(EVENT_BOOK_TRADE, op, params, PERIOD_NONE, timeOut...)
|
|
}
|
|
|
|
/*
|
|
预估交割/行权价格频道
|
|
*/
|
|
func (a *WsClient) PubEstDePrice(op string, params []map[string]string, timeOut ...int) (res bool, msg []*Msg, err error) {
|
|
|
|
return a.PubChannel(EVENT_BOOK_ESTIMATE_PRICE, op, params, PERIOD_NONE, timeOut...)
|
|
|
|
}
|
|
|
|
/*
|
|
标记价格频道
|
|
*/
|
|
func (a *WsClient) PubMarkPrice(op string, params []map[string]string, timeOut ...int) (res bool, msg []*Msg, err error) {
|
|
|
|
return a.PubChannel(EVENT_BOOK_MARK_PRICE, op, params, PERIOD_NONE, timeOut...)
|
|
}
|
|
|
|
/*
|
|
标记价格K线频道
|
|
*/
|
|
func (a *WsClient) PubMarkPriceCandle(op string, pd Period, params []map[string]string, timeOut ...int) (res bool, msg []*Msg, err error) {
|
|
|
|
return a.PubChannel(EVENT_BOOK_MARK_PRICE_CANDLE_CHART, op, params, pd, timeOut...)
|
|
}
|
|
|
|
/*
|
|
限价频道
|
|
*/
|
|
func (a *WsClient) PubLimitPrice(op string, params []map[string]string, timeOut ...int) (res bool, msg []*Msg, err error) {
|
|
|
|
return a.PubChannel(EVENT_BOOK_LIMIT_PRICE, op, params, PERIOD_NONE, timeOut...)
|
|
}
|
|
|
|
/*
|
|
深度频道
|
|
*/
|
|
func (a *WsClient) PubOrderBooks(op string, channel string, params []map[string]string, timeOut ...int) (res bool, msg []*Msg, err error) {
|
|
|
|
switch channel {
|
|
// 400档快照
|
|
case "books":
|
|
return a.PubChannel(EVENT_BOOK_ORDER_BOOK, op, params, PERIOD_NONE, timeOut...)
|
|
// 5档快照
|
|
case "books5":
|
|
return a.PubChannel(EVENT_BOOK_ORDER_BOOK5, op, params, PERIOD_NONE, timeOut...)
|
|
// 400 tbt
|
|
case "books-l2-tbt":
|
|
return a.PubChannel(EVENT_BOOK_ORDER_BOOK_TBT, op, params, PERIOD_NONE, timeOut...)
|
|
// 50 tbt
|
|
case "books50-l2-tbt":
|
|
return a.PubChannel(EVENT_BOOK_ORDER_BOOK50_TBT, op, params, PERIOD_NONE, timeOut...)
|
|
|
|
default:
|
|
err = errors.New("未知的channel")
|
|
return
|
|
}
|
|
|
|
}
|
|
|
|
/*
|
|
期权定价频道
|
|
*/
|
|
func (a *WsClient) PubOptionSummary(op string, params []map[string]string, timeOut ...int) (res bool, msg []*Msg, err error) {
|
|
|
|
return a.PubChannel(EVENT_BOOK_OPTION_SUMMARY, op, params, PERIOD_NONE, timeOut...)
|
|
}
|
|
|
|
/*
|
|
资金费率频道
|
|
*/
|
|
func (a *WsClient) PubFundRate(op string, params []map[string]string, timeOut ...int) (res bool, msg []*Msg, err error) {
|
|
|
|
return a.PubChannel(EVENT_BOOK_FUND_RATE, op, params, PERIOD_NONE, timeOut...)
|
|
}
|
|
|
|
/*
|
|
指数K线频道
|
|
*/
|
|
func (a *WsClient) PubKLineIndex(op string, pd Period, params []map[string]string, timeOut ...int) (res bool, msg []*Msg, err error) {
|
|
|
|
return a.PubChannel(EVENT_BOOK_KLINE_INDEX, op, params, pd, timeOut...)
|
|
}
|
|
|
|
/*
|
|
指数行情频道
|
|
*/
|
|
func (a *WsClient) PubIndexTickers(op string, params []map[string]string, timeOut ...int) (res bool, msg []*Msg, err error) {
|
|
|
|
return a.PubChannel(EVENT_BOOK_INDEX_TICKERS, op, params, PERIOD_NONE, timeOut...)
|
|
}
|