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

临时关掉，验证问题

Browse Source
This commit is contained in:
zhangkun9038@dingtalk.com 2024-12-17 00:32:19 +08:00
parent 9a49f28cc4
commit 52fa562281
1 changed files with 28 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
main.go
View File

@ -30,34 +30,34 @@ func main() {
md.LoopSubscribe(&cr, core.TICKERINFO_PUBLISH, vv)
}(rdsLs[0])
// 订阅 redis Candles
go func(vv *core.RedisConfig) {
allowed := os.Getenv("SIAGA_ACCEPTCANDLE") == "true"
if !allowed {
return
}
fmt.Println("start subscribe core.TICKERINFO_PUBLISH")
md.LoopSubscribe(&cr, core.ALLCANDLES_PUBLISH, vv)
}(rdsLs[0])
// 订阅 redis Max
go func(vv *core.RedisConfig) {
allowed := os.Getenv("SIAGA_ACCEPTMAX") == "true"
if !allowed {
return
}
md.LoopSubscribe(&cr, core.ALLMAXES_PUBLISH, vv)
}(rdsLs[0])
// 下面这个暂时不运行, 在环境变量里把它关掉
go func(vv *core.RedisConfig) {
allowed := os.Getenv("SIAGA_ACCEPTSERIES") == "true"
if !allowed {
return
}
md.LoopSubscribe(&cr, core.ALLSERIESINFO_PUBLISH, vv)
}(rdsLs[0])
// // 订阅 redis Candles
// go func(vv *core.RedisConfig) {
// allowed := os.Getenv("SIAGA_ACCEPTCANDLE") == "true"
// if !allowed {
// return
// }
// fmt.Println("start subscribe core.TICKERINFO_PUBLISH")
// md.LoopSubscribe(&cr, core.ALLCANDLES_PUBLISH, vv)
// }(rdsLs[0])
//
// // 订阅 redis Max
// go func(vv *core.RedisConfig) {
// allowed := os.Getenv("SIAGA_ACCEPTMAX") == "true"
// if !allowed {
// return
// }
// md.LoopSubscribe(&cr, core.ALLMAXES_PUBLISH, vv)
// }(rdsLs[0])
//
// // 下面这个暂时不运行, 在环境变量里把它关掉
// go func(vv *core.RedisConfig) {
// allowed := os.Getenv("SIAGA_ACCEPTSERIES") == "true"
// if !allowed {
// return
// }
// md.LoopSubscribe(&cr, core.ALLSERIESINFO_PUBLISH, vv)
// }(rdsLs[0])
//
go func() {
md.TickerInfoProcess(&cr)
}()