diff --git a/README.md b/README.md index 3d567a3..7e59b10 100644 --- a/README.md +++ b/README.md @@ -1,5 +1,7 @@ ## TODO +修改边缘节点上线分配策略,已分配的边缘节点优先使用旧的配置,新的边缘节点使用负载均衡算法分配新的网关 + ## 枚举字典 ### 产品 diff --git a/web/globals/asynq.go b/web/globals/asynq.go index 19fe59c..b494482 100644 --- a/web/globals/asynq.go +++ b/web/globals/asynq.go @@ -2,7 +2,6 @@ package globals import ( "github.com/hibiken/asynq" - "log/slog" ) var Asynq *asynq.Client @@ -11,12 +10,3 @@ func InitAsynq() { var client = asynq.NewClientFromRedisClient(Redis) Asynq = client } - -func CloseAsynq() { - if Asynq != nil { - err := Asynq.Close() - if err != nil { - slog.Error("关闭 Asynq 客户端失败", "error", err) - } - } -} diff --git a/web/web.go b/web/web.go index 7db773b..2b3016f 100644 --- a/web/web.go +++ b/web/web.go @@ -94,8 +94,6 @@ func (s *Server) Stop() { slog.Error("Failed to close database connection", slog.Any("err", err)) } - g.CloseAsynq() - err = s.fiber.Shutdown() if err != nil { slog.Error("Failed to shutdown server", slog.Any("err", err))