diff --git a/modules/extent.go b/modules/extent.go index e0c7ba0..2183a6a 100644 --- a/modules/extent.go +++ b/modules/extent.go @@ -19,15 +19,15 @@ import ( func GetRemoteRedisConfigList() ([]*core.RedisConfig, error) { list := []*core.RedisConfig{} - envListStr := os.Getenv("SARDINE_REMOTE_REDIS_LIST") + envListStr := os.Getenv("SIAGA_UPSTREAM_REDIS_LIST") envList := strings.Split(envListStr, "|") for _, v := range envList { if len(v) == 0 { continue } - urlstr := core.REMOTE_REDIS_PRE_NAME + v + "_URL" - indexstr := core.REMOTE_REDIS_PRE_NAME + v + "_INDEX" - password := os.Getenv(core.REMOTE_REDIS_PRE_NAME + v + "_PASSWORD") + urlstr := "SIAGA_UPSTREAM_REDIS_" + v + "_URL" + indexstr := "SIAGA_UPSTREAM_REDIS_" + v + "_INDEX" + password := os.Getenv("SIAGA_UPSTREAM_REDIS_" + v + "_PASSWORD") // channelstr := core.REMOTE_REDIS_PRE_NAME + v + "_CHANNEL_PRENAME" // channelPreName := os.Getenv(channelstr) url := os.Getenv(urlstr) diff --git a/modules/maX.go b/modules/maX.go index 160cb7f..522eb25 100644 --- a/modules/maX.go +++ b/modules/maX.go @@ -30,7 +30,7 @@ func (mmx *MyMaX) Process(cr *core.Core) { } // TODO go func() { - torqueSorted := os.Getenv("SARDINE_MAKESERIES") == "true" + torqueSorted := os.Getenv("SIAGA_MAKESERIES") == "true" if !torqueSorted { return } diff --git a/siaga.env b/siaga.env new file mode 100644 index 0000000..800dee5 --- /dev/null +++ b/siaga.env @@ -0,0 +1,20 @@ +GO_ENV=stage + +SIAGA_ACCEPTTICKER=true +SIAGA_ACCEPTCANDLE=true +SIAGA_ACCEPTMAX=true +SIAGA_ACCEPTSERIES=false + +SIAGA_SAVECANDLE=true +SIAGA_MAKESERIES=false +SIAGA_MAKEMAX=true +SIAGA_MAKESOFTCANDLE=true + +SIAGA_TORQUESORTED=true +SIAGA_TICKERTOCANDLE=true + +TEXUS_FluentBitUrl=fluentd.k8s.xunlang.home + +SIAGA_UPSTREAM_REDIS_LIST=SILVER +SIAGA_UPSTREAM_REDIS_SILVER_URL=10.66.66.20:6379 +SIAGA_UPSTREAM_REDIS_SILVER_INDEX=4