fix: not support redis cluster. CROSSSLOT Keys in request don't hash …

…to the same slot
FGadvancer · Oct 24, 2023 · e9a6973 · e9a6973
1 parent c08b95f
commit e9a6973
Show file tree

Hide file tree

Showing 7 changed files with 721 additions and 782 deletions.
diff --git a/pkg/common/db/cache/black.go b/pkg/common/db/cache/black.go
@@ -52,6 +52,7 @@ func NewBlackCacheRedis(
 	options rockscache.Options,
 ) BlackCache {
 	rcClient := rockscache.NewClient(rdb, options)
+
 	return &BlackCacheRedis{
 		expireTime: blackExpireTime,
 		rcClient:   rcClient,
@@ -61,32 +62,22 @@ func NewBlackCacheRedis(
 }
 
 func (b *BlackCacheRedis) NewCache() BlackCache {
-	return &BlackCacheRedis{
-		expireTime: b.expireTime,
-		rcClient:   b.rcClient,
-		blackDB:    b.blackDB,
-		metaCache:  NewMetaCacheRedis(b.rcClient, b.metaCache.GetPreDelKeys()...),
-	}
+	return &BlackCacheRedis{expireTime: b.expireTime, rcClient: b.rcClient, blackDB: b.blackDB, metaCache: NewMetaCacheRedis(b.rcClient, b.metaCache.GetPreDelKeys()...)}
 }
 
 func (b *BlackCacheRedis) getBlackIDsKey(ownerUserID string) string {
 	return blackIDsKey + ownerUserID
 }
 
 func (b *BlackCacheRedis) GetBlackIDs(ctx context.Context, userID string) (blackIDs []string, err error) {
-	return getCache(
-		ctx,
-		b.rcClient,
-		b.getBlackIDsKey(userID),
-		b.expireTime,
-		func(ctx context.Context) ([]string, error) {
-			return b.blackDB.FindBlackUserIDs(ctx, userID)
-		},
-	)
+	return getCache(ctx, b.rcClient, b.getBlackIDsKey(userID), b.expireTime, func(ctx context.Context) ([]string, error) {
+		return b.blackDB.FindBlackUserIDs(ctx, userID)
+	})
 }
 
 func (b *BlackCacheRedis) DelBlackIDs(ctx context.Context, userID string) BlackCache {
 	cache := b.NewCache()
 	cache.AddKeys(b.getBlackIDsKey(userID))
+
 	return cache
 }