zeromicro/go-zero
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix #820 (#934)

Browse Source
This commit is contained in:
Kevin Wan
2021-08-19 22:48:21 +08:00
committed by GitHub
parent 189721da16
commit bf3ce16823
4 changed files with 33 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
core/stores/cache/cachenode.go vendored
View File

@@ -65,9 +65,18 @@ func (c cacheNode) Del(keys ...string) error {
return nil
}
if _, err := c.rds.Del(keys...); err != nil {
logx.Errorf("failed to clear cache with keys: %q, error: %v", formatKeys(keys), err)
c.asyncRetryDelCache(keys...)
if len(keys) > 1 && c.rds.Type == redis.ClusterType {
for _, key := range keys {
if _, err := c.rds.Del(key); err != nil {
logx.Errorf("failed to clear cache with key: %q, error: %v", key, err)
c.asyncRetryDelCache(key)
}
}
} else {
if _, err := c.rds.Del(keys...); err != nil {
logx.Errorf("failed to clear cache with keys: %q, error: %v", formatKeys(keys), err)
c.asyncRetryDelCache(keys...)
}
}
return nil