diff --git a/configs/basicConfig.json b/configs/basicConfig.json index 01d3c08..829cb95 100644 --- a/configs/basicConfig.json +++ b/configs/basicConfig.json @@ -153,7 +153,7 @@ }, "redisRemotes": { "master": { - "url": "this Set is abandend, use env insted", + "url": "this Set is abandend, use env instead", "password": "", "index": 5, "description": "" diff --git a/modules/extent.go b/modules/extent.go index c828ac5..f6a3707 100644 --- a/modules/extent.go +++ b/modules/extent.go @@ -120,6 +120,7 @@ func LoopSubscribe(cr *core.Core, channelName string, redisConf *core.RedisConfi dt = append(dt, mx.AvgVal) mx.Data = dt cr.MaXProcessChan <- &mx + } // 接收到的tinckerInfo扔到 tickerInfo 二次加工流水线 @@ -448,7 +449,6 @@ func CandlesProcess(cr *core.Core) { for { cd := <-cr.CandlesProcessChan cd.LastUpdate = time.Now() - // logrus.Debug("cd: ", cd) logrus.Debug("candle in process: ", cd) go func(cad *core.Candle) { mcd := MyCandle{