GitHub/015
1
0
Fork 0
mirror of https://github.com/keven1024/015.git synced 2026-05-26 07:08:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor(backend): improve Redis connection handling in async queue utilities by introducing RedisURI2AsynqOpt function

Browse Source
This commit is contained in:
keven1024
2025-05-23 20:29:01 +08:00
parent 622f04a1e0
commit 9d8de69f9f
1 changed files with 12 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
backend/internal/utils/asyncq.go
View File

@@ -3,9 +3,19 @@ package utils
import "github.com/hibiken/asynq"
func GetQueueClient() *asynq.Client {
return asynq.NewClient(asynq.RedisClientOpt{Addr: GetEnv("REDIS_URL")})
opt := RedisURI2AsynqOpt(GetEnv("REDIS_URL"))
return asynq.NewClient(opt)
}
func GetQueueInspector() *asynq.Inspector {
return asynq.NewInspector(asynq.RedisClientOpt{Addr: GetEnv("REDIS_URL")})
opt := RedisURI2AsynqOpt(GetEnv("REDIS_URL"))
return asynq.NewInspector(opt)
}
func RedisURI2AsynqOpt(uri string) asynq.RedisConnOpt {
opt, err := asynq.ParseRedisURI(GetEnv("REDIS_URL"))
if err != nil {
panic(err)
}
return opt
}