移除不必要的 Asynq 客户端关闭逻辑
This commit is contained in:
@@ -1,5 +1,7 @@
|
|||||||
## TODO
|
## TODO
|
||||||
|
|
||||||
|
修改边缘节点上线分配策略,已分配的边缘节点优先使用旧的配置,新的边缘节点使用负载均衡算法分配新的网关
|
||||||
|
|
||||||
## 枚举字典
|
## 枚举字典
|
||||||
|
|
||||||
### 产品
|
### 产品
|
||||||
|
|||||||
@@ -2,7 +2,6 @@ package globals
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"github.com/hibiken/asynq"
|
"github.com/hibiken/asynq"
|
||||||
"log/slog"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
var Asynq *asynq.Client
|
var Asynq *asynq.Client
|
||||||
@@ -11,12 +10,3 @@ func InitAsynq() {
|
|||||||
var client = asynq.NewClientFromRedisClient(Redis)
|
var client = asynq.NewClientFromRedisClient(Redis)
|
||||||
Asynq = client
|
Asynq = client
|
||||||
}
|
}
|
||||||
|
|
||||||
func CloseAsynq() {
|
|
||||||
if Asynq != nil {
|
|
||||||
err := Asynq.Close()
|
|
||||||
if err != nil {
|
|
||||||
slog.Error("关闭 Asynq 客户端失败", "error", err)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|||||||
@@ -94,8 +94,6 @@ func (s *Server) Stop() {
|
|||||||
slog.Error("Failed to close database connection", slog.Any("err", err))
|
slog.Error("Failed to close database connection", slog.Any("err", err))
|
||||||
}
|
}
|
||||||
|
|
||||||
g.CloseAsynq()
|
|
||||||
|
|
||||||
err = s.fiber.Shutdown()
|
err = s.fiber.Shutdown()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
slog.Error("Failed to shutdown server", slog.Any("err", err))
|
slog.Error("Failed to shutdown server", slog.Any("err", err))
|
||||||
|
|||||||
Reference in New Issue
Block a user