git/wechat
1
0
Fork 0
mirror of https://github.com/silenceper/wechat.git synced 2026-02-11 16:22:26 +08:00
Code Issues Projects Releases Wiki Activity

feat: redis deprecated

Browse Source
This commit is contained in:
houseme
2023-08-25 19:57:35 +08:00
parent c81d0b1215
commit 5467bc6245
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
cache/redis.go vendored
View File

@@ -8,6 +8,8 @@ import (
) )
// Redis .redis cache // Redis .redis cache
// Deprecated: user defined implementation cache、ContextCache interface
// The implementation was officially removed in v2.1.6
type Redis struct { type Redis struct {
ctx context.Context ctx context.Context
conn redis.UniversalClient conn redis.UniversalClient
@@ -35,12 +37,12 @@ func NewRedis(ctx context.Context, opts *RedisOpts) *Redis {
return &Redis{ctx: ctx, conn: conn} return &Redis{ctx: ctx, conn: conn}
} }
// SetConn 设置conn // SetConn 设置 conn
func (r *Redis) SetConn(conn redis.UniversalClient) { func (r *Redis) SetConn(conn redis.UniversalClient) {
r.conn = conn r.conn = conn
} }
// SetRedisCtx 设置redis ctx 参数 // SetRedisCtx 设置 redis ctx 参数
func (r *Redis) SetRedisCtx(ctx context.Context) { func (r *Redis) SetRedisCtx(ctx context.Context) {
r.ctx = ctx r.ctx = ctx
} }
@@ -69,12 +71,12 @@ func (r *Redis) SetContext(ctx context.Context, key string, val interface{}, tim
return r.conn.SetEX(ctx, key, val, timeout).Err() return r.conn.SetEX(ctx, key, val, timeout).Err()
} }
// IsExist 判断key是否存在 // IsExist 判断 key 是否存在
func (r *Redis) IsExist(key string) bool { func (r *Redis) IsExist(key string) bool {
return r.IsExistContext(r.ctx, key) return r.IsExistContext(r.ctx, key)
} }
// IsExistContext 判断key是否存在 // IsExistContext 判断 key 是否存在
func (r *Redis) IsExistContext(ctx context.Context, key string) bool { func (r *Redis) IsExistContext(ctx context.Context, key string) bool {
result, _ := r.conn.Exists(ctx, key).Result() result, _ := r.conn.Exists(ctx, key).Result()