Documentation ¶
Overview ¶
对外提供的服务
Index ¶
- Variables
- func AddBeforeHook(hf ...hookFunc)
- type DataService
- func (this *DataService) BuildDepthRealTimeLink(kps []global.RealTimeDataParam, rsDataChan chan global.KlineRealTimeData)
- func (this *DataService) BuildKlineRealTimeLink(kps []global.RealTimeDataParam, rsDataChan chan global.KlineRealTimeData)
- func (this *DataService) BuildTradeRealTimeLink(kps []global.RealTimeDataParam, rsDataChan chan global.KlineRealTimeData)
- func (this *DataService) Init() (err error)
Constants ¶
This section is empty.
Variables ¶
View Source
var DefultConf = global.Config{ DataServiceName: "DataServiceSignal", LogLevel: global.LOG_LEVEL_INFO, DataStoragePath: "/__DSCache__/", DataSource: map[global.DataSourceID]global.DataSource{ global.PLATFORM_ID_MASTER: { Tag: "market", Name: "Market(主服务器)", EnableSource: true, Urls: global.Urls{ "https://api.iamyl.vip", "ws://172.16.136.80:21002/sws", }, Password: "0O0@Q0O0", DSAction: &master.BaseAction{}, }, }, AssignUpdate: map[global.DataIndex]global.AssignUpdateInfo{ global.DataIndex{ Action: global.ACTION_KLINE, Platform: global.PLATFORM_NAME_HUOBIPRO, Symbol: "btc-usdt", }: { StartTime: utils.StringToTimestamp("2018-01-01 00:00:00"), EndTime: utils.StringToTimestamp("2018-01-31 23:59:00"), DataSourceID: 1001, }, global.DataIndex{ Action: global.ACTION_KLINE, Platform: global.PLATFORM_NAME_HUOBIPRO, Symbol: "etc-usdt", }: { StartTime: utils.StringToTimestamp("2018-01-01 00:00:00"), EndTime: utils.StringToTimestamp("2018-01-31 23:59:00"), DataSourceID: 1001, }, global.DataIndex{ Action: global.ACTION_TRADE, Platform: global.PLATFORM_NAME_HUOBIPRO, Symbol: "bch-usdt", }: { StartTime: utils.StringToTimestamp("2019-05-01 00:00:00"), EndTime: utils.StringToTimestamp("2019-05-31 23:59:00"), DataSourceID: 1001, }, }, UserSecret: global.UserSecret{ "huobipro": { "aaaabbbbbccccdddd": { Name: "张三的火币账号", ApiKey: "aaaabbbbbccccdddd", SecretKey: "aaaabbbbbccccdddd123123123123123", Enable: true, }, "aaaabbbbbccccddd2": { Name: "李四的火币账号", ApiKey: "aaaabbbbbccccdddd", SecretKey: "aaaabbbbbccccdddd123123123123123", Enable: false, }, }, "binance": { "aaaabbbbbccccddd2": { Name: "张三的币安账号", ApiKey: "aaaabbbbbccccdddd", SecretKey: "aaaabbbbbccccdddd123123123123123", Enable: true, }, }, }, }
默认配置
View Source
var PkgName = "[数据服务]" // 包名称
Functions ¶
Types ¶
type DataService ¶
基础数据服务类型
func (*DataService) BuildDepthRealTimeLink ¶
func (this *DataService) BuildDepthRealTimeLink(kps []global.RealTimeDataParam, rsDataChan chan global.KlineRealTimeData)
BuildKlineRealTimeLink 创建长链接持续提供Depth数据,合并处理数据
参数: kp 传入多个数据源,多个币种信息 参数: rsDataChan 返回数据的接收管道,当有数据返回时会给该管道输出数据
func (*DataService) BuildKlineRealTimeLink ¶
func (this *DataService) BuildKlineRealTimeLink(kps []global.RealTimeDataParam, rsDataChan chan global.KlineRealTimeData)
BuildKlineRealTimeLink 创建长链接持续提供Kline数据,合并处理数据
参数: kp 传入多个数据源,多个币种信息 参数: rsDataChan 返回数据的接收管道,当有数据返回时会给该管道输出数据
func (*DataService) BuildTradeRealTimeLink ¶
func (this *DataService) BuildTradeRealTimeLink(kps []global.RealTimeDataParam, rsDataChan chan global.KlineRealTimeData)
BuildTradeRealTimeLink 创建长链接持续提供Trade数据,合并处理数据
参数: kp 传入多个数据源,多个币种信息 参数: rsDataChan 返回数据的接收管道,当有数据返回时会给该管道输出数据
Click to show internal directories.
Click to hide internal directories.