master

Aug 15, 2020

Changes in this version

+ const MSG_ACTION_ASSETS

+ const MSG_ACTION_DEPTH

+ const MSG_ACTION_KLINE

+ const MSG_ACTION_ORDER

+ const MSG_ACTION_TRADE

+ const MSG_OP_ERROR

+ const MSG_OP_PING

+ const MSG_OP_PONG

+ const MSG_OP_PUSH

+ const MSG_OP_REQ

+ const MSG_OP_REQ_BUYCLOSE

+ const MSG_OP_REQ_BUYOPEN

+ const MSG_OP_REQ_CHECKLOGIN

+ const MSG_OP_REQ_GETSYMBOLS

+ const MSG_OP_REQ_LOGIN

+ const MSG_OP_REQ_SELLCLOSE

+ const MSG_OP_REQ_SELLOPEN

+ const MSG_OP_SUB

+ const MSG_OP_UNSUB

+ var PkgName = "[Master数据源]"

+ type BaseAction struct

+ ThisDataSource global.DataSource

+ func (this *BaseAction) DepthRealTimeLink(kp global.RealTimeDataParam, rsData chan global.DepthRealTimeData)

+ func (this *BaseAction) GetKlineBarSlice(di global.DataIndex, sTime, eTime global.Timestamp) (kbs global.KlineBarSlice, err error)

+ func (this *BaseAction) GetSymbolList(dsID global.DataSourceID) (ss []global.Symbol, err error)

+ func (this *BaseAction) GetTradeSlice(di global.DataIndex, sTime, eTime global.Timestamp) (kbs global.KlineBarSlice, err error)

+ func (this *BaseAction) KlineRealTimeLine(kp global.RealTimeDataParam, rsData chan global.KlineRealTimeData)

+ func (this *BaseAction) SetConfig(conf global.Config)

+ func (this *BaseAction) TradeRealTimeLink(kp global.RealTimeDataParam, rsData chan global.TradeRealTimeData)

+ func (this *BaseAction) UpdataKlineFileCache(uParam global.UpdataFileCacheParam, sTime, eTime global.Timestamp, ...)

+ func (this *BaseAction) UpdataTradeFileCache(uParam global.UpdataFileCacheParam, sTime, eTime global.Timestamp) (err error)

+ type LoadPastData struct

+ func NewLoadPastData(ba *BaseAction, di global.DataIndex, sTime, eTime global.Timestamp, ...) (lpd *LoadPastData, err error)

+ func (this *LoadPastData) CloseWs()

+ func (this *LoadPastData) ReConnect()

+ func (this *LoadPastData) SendMsg(msg *Msg)

+ type Msg struct

+ Action string

+ Data interface{}

+ Op string

+ Param url.Values

+ Platform string

+ Symbol string

+ func (this *Msg) ToAssets() (aData *global.AssetsData)

+ func (this *Msg) ToDepth() (dData *global.DepthData)

+ func (this *Msg) ToKlineBarSlice() (kbs []global.KlineBar, err error)

+ func (this *Msg) ToOrder() (oData *global.OrderData)

+ func (this *Msg) ToTradeInfoSlice() (tdList []global.TradeInfo, err error)