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

redisConf

Browse Source
This commit is contained in:
zhangkun9038@dingtalk.com 2024-12-17 00:26:02 +08:00
parent 22860fa34b
commit 9a49f28cc4
3 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
go.mod
View File

@ -6,7 +6,7 @@ go 1.21
require (
github.com/go-redis/redis v6.15.9+incompatible
github.com/phyer/core v0.1.20
github.com/phyer/core v0.1.21
github.com/sirupsen/logrus v1.9.3
)

4
go.sum
View File

@ -49,8 +49,8 @@ github.com/onsi/gomega v1.10.1/go.mod h1:iN09h71vgCQne3DLsj+A5owkum+a2tYe+TOCB1y
github.com/onsi/gomega v1.17.0/go.mod h1:HnhC7FXeEQY45zxNK3PPoIUhzk/80Xly9PcubAlGdZY=
github.com/onsi/gomega v1.18.1 h1:M1GfJqGRrBrrGGsbxzV5dqM2U2ApXefZCQpkukxYRLE=
github.com/onsi/gomega v1.18.1/go.mod h1:0q+aL8jAiMXy9hbwj2mr5GziHiwhAIQpFmmtT5hitRs=
github.com/phyer/core v0.1.20 h1:KqDlXB0IFWXpbx8UViRxC5+y2CRZ1K+f8GzQBVhq3Vw=
github.com/phyer/core v0.1.20/go.mod h1:XZdniJiiZPzOU8+QHPFRQWdvJa6m5Ilj5VClWWI0OQg=
github.com/phyer/core v0.1.21 h1:akZDwpqRGxtysvGun9PjyZcrysGIaWcphcWafxxZtig=
github.com/phyer/core v0.1.21/go.mod h1:XZdniJiiZPzOU8+QHPFRQWdvJa6m5Ilj5VClWWI0OQg=
github.com/phyer/texus v0.0.0-20241207132635-0e7fb63f8196 h1:P1sxgCsS0VIL38ufZzgUuZLLyY/B+po6kSY7ziNZT7E=
github.com/phyer/texus v0.0.0-20241207132635-0e7fb63f8196/go.mod h1:iZexs5agdApNlp8HW/FqKgma4Ij1x8/o+ZLcMvY3f80=
github.com/phyer/v5sdkgo v0.1.4 h1:mAxxjPJVTYGuGDarqOcFGkzj5AgqbbzJGsnYmmsbapU=

4
modules/extent.go
View File

@ -52,7 +52,7 @@ func GetRemoteRedisConfigList() ([]*core.RedisConfig, error) {
}
func LoopSubscribe(cr *core.Core, channelName string, redisConf *core.RedisConfig) {
redisRemoteCli := cr.RedisRemoteCli
redisRemoteCli, _ := cr.GetRedisCliFromConf(*redisConf)
suffix := ""
env := os.Getenv("GO_ENV")
if strings.Contains(env, "demoEnv") {
@ -77,7 +77,7 @@ func LoopSubscribe(cr *core.Core, channelName string, redisConf *core.RedisConfi
ctype := ""
if strings.Contains(channelName, "allCandle") {
ctype = "candle"
} else if strings.Contains(channelName, "allMaXs") {
} else if strings.Contains(channelName, "allMaX") {
ctype = "maX"
} else if strings.Contains(channelName, "ticker") {
ctype = "tickerInfo"