lsm/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2025-09-23 03:43:36 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Initial patch for redis version 7 support (#4572)

Browse Source
This commit is contained in:
Aaron Gipson
2023-06-12 15:30:03 -05:00
committed by GitHub
parent 25535e9c36
commit a25bca0692
25 changed files with 43 additions and 35 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
weed/filer/redis2/universal_redis_store.go
View File

@@ -5,7 +5,7 @@ import (
"fmt"
"time"
"github.com/go-redis/redis/v8"
"github.com/redis/go-redis/v9"
"github.com/seaweedfs/seaweedfs/weed/filer"
"github.com/seaweedfs/seaweedfs/weed/glog"
@@ -57,7 +57,7 @@ func (store *UniversalRedis2Store) InsertEntry(ctx context.Context, entry *filer
}
if name != "" {
if err = store.Client.ZAddNX(ctx, genDirectoryListKey(dir), &redis.Z{Score: 0, Member: name}).Err(); err != nil {
if err = store.Client.ZAddNX(ctx, genDirectoryListKey(dir), redis.Z{Score: 0, Member: name}).Err(); err != nil {
return fmt.Errorf("persisting %s in parent dir: %v", entry.FullPath, err)
}
}