dataservice

package module

v1.0.2 Latest Latest Go to latest Published: Aug 15, 2020 License: BSD-3-Clause Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

gitee.com/iamyl/dataservice

README ¶

dataservice

介绍

使用说明

    
ds := dataservice.DataService{}

// 设置日志界别,如果不设置,默认级别为 LOG_LEVEL_INFO
ds.LogLevel = global.LOG_LEVEL_DEBUG

// 设置为当前程序执行目录,如果不设置,默认为程序执行目录
ds.DataStoragePath = "/Users/iamyl/goPro/guex"

// 设置Trade数据存储级别,单文件最小存储单位,分为年,月,日,小时,分钟,秒,如果不设置默认为小时
ds.DataStorageLevelTrade = global.DATA_STORAGE_LEVEL_HOUR

// 设置Kline数据存储级别,单文件最小存储单位,分为年,月,日,小时,分钟,秒,如果不设置默认为日
// ds.DataStorageLevelKline = dataservice.DATA_STORAGE_LEVEL_DAY

// 初始化数据服务
if err := ds.Init(); err != nil {
    logs.Fatalf("[数据服务] 创建错误===>>> %+v", err)
}

Documentation ¶

Overview ¶

对外提供的服务

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 ¶

func AddBeforeHook ¶

func AddBeforeHook(hf ...hookFunc)

AddBeforeHook 添加钩子函数

Types ¶

type DataService ¶

type DataService struct {
	global.Config
}

基础数据服务类型

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 返回数据的接收管道,当有数据返回时会给该管道输出数据

func (*DataService) Init ¶

func (this *DataService) Init() (err error)

Build 启动数据服务

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
datasource
aofex
binance
exservice
huobipro
master 连续更新的数据	连续更新的数据
master/bak 历史数据更新	历史数据更新
okex
global
logs
utils

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL