fix: use redis config

2025-03-06 13:30:24 +08:00
parent cf410bdf05
commit a2a6fe6374
3 changed files with 22 additions and 5 deletions
@@ -1,6 +1,7 @@
 package redisaccessor

 import (
+	"fmt"
 	"legalgo-BE-go/config"

 	"github.com/redis/go-redis/v9"
@@ -12,12 +13,13 @@ func Get() *redis.Client {
 	return redisClient
 }

-func New() *redis.Client {
+func New(cfg *config.Config) *redis.Client {
+	addr := fmt.Sprintf("%s:%s", cfg.Redis.Host, cfg.Redis.Port)
+
 	redisClient = redis.NewClient(&redis.Options{
-		Username: config.REDIS_USERNAME,
-		Addr:     config.REDIS_ADDR,
-		Password: config.REDIS_PASSWORD,
-		DB:       config.REDIS_DB,
+		Addr:     addr,
+		Password: cfg.Redis.Password,
+		DB:       cfg.Redis.DB,
 	})

 	return redisClient