From dc61d47b665e2dadbf45f7fe049e9eaaaaf8f0d4 Mon Sep 17 00:00:00 2001 From: AnthonyAxenov Date: Thu, 2 Oct 2025 01:12:46 +0800 Subject: [PATCH] =?UTF-8?q?=D0=92=D1=8B=D0=B2=D0=BE=D0=B4=20=D1=81=D1=82?= =?UTF-8?q?=D1=80=D0=BE=D0=BA=D0=B8=20=D0=BF=D0=BE=D0=B4=D0=BA=D0=BB=D1=8E?= =?UTF-8?q?=D1=87=D0=B5=D0=BD=D0=B8=D1=8F=20redis?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/cache/cache.go | 14 ++++++++------ 1 file changed, 8 insertions(+), 6 deletions(-) diff --git a/app/cache/cache.go b/app/cache/cache.go index 9e9a623..4b38f48 100644 --- a/app/cache/cache.go +++ b/app/cache/cache.go @@ -10,28 +10,30 @@ import ( "axenov/iptv-checker/app/config" "context" "fmt" - "github.com/redis/go-redis/v9" "log" "strconv" + + "github.com/redis/go-redis/v9" ) func Init(cfg *config.CacheConfig) *redis.Client { - redis := redis.NewClient(&redis.Options{ - Addr: fmt.Sprintf("%s:%s", cfg.Host, strconv.Itoa(int(cfg.Port))), + redisUrl := fmt.Sprintf("%s:%s", cfg.Host, strconv.Itoa(int(cfg.Port))) + redisClient := redis.NewClient(&redis.Options{ + Addr: redisUrl, DB: int(cfg.Db), PoolSize: 1000, ReadTimeout: -1, WriteTimeout: -1, }) - client := redis.Conn() + client := redisClient.Conn() ctx := context.Background() err := client.Ping(ctx).Err() if err == nil { - log.Println("Connected to cache DB") + log.Println("Connected to cache DB:", redisUrl) cfg.IsActive = true } else { log.Println("Error while connecting to cache DB, program may work not as expected:", err) } - return redis + return redisClient }