gitlab-com-seaweedfs/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2024-01-19 02:48:24 +00:00
Code Issues Projects Releases Wiki Activity

Set redis key ttl with entry.TTLSec

Browse source
This commit is contained in:
byungjo.yoon 2019-01-09 11:48:19 +09:00
parent badd8fdf8f
commit 58fd2e5a19
1 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
weed/filer2/redis/universal_redis_store.go
View file

@ -7,6 +7,7 @@ import (
"github.com/go-redis/redis" "github.com/go-redis/redis"
"sort" "sort"
"strings" "strings"
"time"
) )
const ( const (
@ -24,7 +25,7 @@ func (store *UniversalRedisStore) InsertEntry(entry *filer2.Entry) (err error) {
return fmt.Errorf("encoding %s %+v: %v", entry.FullPath, entry.Attr, err) return fmt.Errorf("encoding %s %+v: %v", entry.FullPath, entry.Attr, err)
} }
_, err = store.Client.Set(string(entry.FullPath), value, 0).Result() _, err = store.Client.Set(string(entry.FullPath), value, time.Duration(entry.TtlSec) * time.Second).Result()
if err != nil { if err != nil {
return fmt.Errorf("persisting %s : %v", entry.FullPath, err) return fmt.Errorf("persisting %s : %v", entry.FullPath, err)