phyer/siaga
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

debug

Browse Source
This commit is contained in:
zhangkun9038@dingtalk.com 2024-12-26 10:19:35 +08:00
parent b56318d385
commit 66072fc47f
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
configs/basicConfig.json
View File

@ -153,7 +153,7 @@
}, },
"redisRemotes": { "redisRemotes": {
"master": { "master": {
"url": "this Set is abandend, use env insted", "url": "this Set is abandend, use env instead",
"password": "", "password": "",
"index": 5, "index": 5,
"description": "" "description": ""

2
modules/extent.go
View File

@ -120,6 +120,7 @@ func LoopSubscribe(cr *core.Core, channelName string, redisConf *core.RedisConfi
dt = append(dt, mx.AvgVal) dt = append(dt, mx.AvgVal)
mx.Data = dt mx.Data = dt
cr.MaXProcessChan <- &mx cr.MaXProcessChan <- &mx
} }
// 接收到的tinckerInfo扔到 tickerInfo 二次加工流水线 // 接收到的tinckerInfo扔到 tickerInfo 二次加工流水线
@ -448,7 +449,6 @@ func CandlesProcess(cr *core.Core) {
for { for {
cd := <-cr.CandlesProcessChan cd := <-cr.CandlesProcessChan
cd.LastUpdate = time.Now() cd.LastUpdate = time.Now()
// logrus.Debug("cd: ", cd)
logrus.Debug("candle in process: ", cd) logrus.Debug("candle in process: ", cd)
go func(cad *core.Candle) { go func(cad *core.Candle) {
mcd := MyCandle{ mcd := MyCandle{