Versions in this module Expand all Collapse all v0 v0.4.1 Sep 28, 2022 v0.4.0 Sep 25, 2022 Changes in this version + type CmdableWrapper struct + func (c *CmdableWrapper) Append(ctx context.Context, key, value string) *redis.IntCmd + func (c *CmdableWrapper) BLMove(ctx context.Context, srcKey, destKey, srcPos, destPos string, ...) *redis.StringCmd + func (c *CmdableWrapper) BLPop(ctx context.Context, timeout time.Duration, keys ...string) *redis.StringSliceCmd + func (c *CmdableWrapper) BRPop(ctx context.Context, timeout time.Duration, keys ...string) *redis.StringSliceCmd + func (c *CmdableWrapper) BZPopMax(ctx context.Context, timeout time.Duration, keys ...string) *redis.ZWithKeyCmd + func (c *CmdableWrapper) BZPopMin(ctx context.Context, timeout time.Duration, keys ...string) *redis.ZWithKeyCmd + func (c *CmdableWrapper) BitCount(ctx context.Context, key string, bitCount *redis.BitCount) *redis.IntCmd + func (c *CmdableWrapper) BitField(ctx context.Context, key string, args ...interface{}) *redis.IntSliceCmd + func (c *CmdableWrapper) BitOpAnd(ctx context.Context, destKey string, keys ...string) *redis.IntCmd + func (c *CmdableWrapper) BitOpNot(ctx context.Context, destKey, key string) *redis.IntCmd + func (c *CmdableWrapper) BitOpOr(ctx context.Context, destKey string, keys ...string) *redis.IntCmd + func (c *CmdableWrapper) BitOpXor(ctx context.Context, destKey string, keys ...string) *redis.IntCmd + func (c *CmdableWrapper) BitPos(ctx context.Context, key string, bit int64, pos ...int64) *redis.IntCmd + func (c *CmdableWrapper) Copy(ctx context.Context, srcKey, destKey string, destDb int, replace bool) *redis.IntCmd + func (c *CmdableWrapper) DBSize(ctx context.Context) *redis.IntCmd + func (c *CmdableWrapper) Decr(ctx context.Context, key string) *redis.IntCmd + func (c *CmdableWrapper) DecrBy(ctx context.Context, key string, value int64) *redis.IntCmd + func (c *CmdableWrapper) Del(ctx context.Context, keys ...string) *redis.IntCmd + func (c *CmdableWrapper) Dump(ctx context.Context, key string) *redis.StringCmd + func (c *CmdableWrapper) Eval(ctx context.Context, script string, keys []string, args ...interface{}) *redis.Cmd + func (c *CmdableWrapper) EvalSha(ctx context.Context, scriptSha string, keys []string, args ...interface{}) *redis.Cmd + func (c *CmdableWrapper) Exists(ctx context.Context, keys ...string) *redis.IntCmd + func (c *CmdableWrapper) Expire(ctx context.Context, key string, value time.Duration) *redis.BoolCmd + func (c *CmdableWrapper) ExpireAt(ctx context.Context, key string, value time.Time) *redis.BoolCmd + func (c *CmdableWrapper) FlushAll(ctx context.Context) *redis.StatusCmd + func (c *CmdableWrapper) FlushAllAsync(ctx context.Context) *redis.StatusCmd + func (c *CmdableWrapper) FlushDB(ctx context.Context) *redis.StatusCmd + func (c *CmdableWrapper) FlushDBAsync(ctx context.Context) *redis.StatusCmd + func (c *CmdableWrapper) GeoAdd(ctx context.Context, key string, geoLocations ...*redis.GeoLocation) *redis.IntCmd + func (c *CmdableWrapper) GeoDist(ctx context.Context, key, member1, member2, unit string) *redis.FloatCmd + func (c *CmdableWrapper) GeoHash(ctx context.Context, key string, members ...string) *redis.StringSliceCmd + func (c *CmdableWrapper) GeoPos(ctx context.Context, key string, members ...string) *redis.GeoPosCmd + func (c *CmdableWrapper) GeoSearch(ctx context.Context, key string, query *redis.GeoSearchQuery) *redis.StringSliceCmd + func (c *CmdableWrapper) GeoSearchLocation(ctx context.Context, key string, query *redis.GeoSearchLocationQuery) *redis.GeoSearchLocationCmd + func (c *CmdableWrapper) GeoSearchStore(ctx context.Context, key, store string, query *redis.GeoSearchStoreQuery) *redis.IntCmd + func (c *CmdableWrapper) Get(ctx context.Context, key string) *redis.StringCmd + func (c *CmdableWrapper) GetBit(ctx context.Context, key string, offset int64) *redis.IntCmd + func (c *CmdableWrapper) GetDel(ctx context.Context, key string) *redis.StringCmd + func (c *CmdableWrapper) GetEx(ctx context.Context, key string, expiration time.Duration) *redis.StringCmd + func (c *CmdableWrapper) GetRange(ctx context.Context, key string, start, end int64) *redis.StringCmd + func (c *CmdableWrapper) GetSet(ctx context.Context, key string, value interface{}) *redis.StringCmd + func (c *CmdableWrapper) HDel(ctx context.Context, key string, fields ...string) *redis.IntCmd + func (c *CmdableWrapper) HExists(ctx context.Context, key, field string) *redis.BoolCmd + func (c *CmdableWrapper) HGet(ctx context.Context, key, field string) *redis.StringCmd + func (c *CmdableWrapper) HGetAll(ctx context.Context, key string) *redis.StringStringMapCmd + func (c *CmdableWrapper) HIncrBy(ctx context.Context, key, field string, value int64) *redis.IntCmd + func (c *CmdableWrapper) HIncrByFloat(ctx context.Context, key, field string, value float64) *redis.FloatCmd + func (c *CmdableWrapper) HKeys(ctx context.Context, key string) *redis.StringSliceCmd + func (c *CmdableWrapper) HLen(ctx context.Context, key string) *redis.IntCmd + func (c *CmdableWrapper) HMGet(ctx context.Context, key string, fields ...string) *redis.SliceCmd + func (c *CmdableWrapper) HRandField(ctx context.Context, key string, count int, withValues bool) *redis.StringSliceCmd + func (c *CmdableWrapper) HScan(ctx context.Context, key string, cursor uint64, match string, count int64) *redis.ScanCmd + func (c *CmdableWrapper) HSet(ctx context.Context, key string, values ...interface{}) *redis.IntCmd + func (c *CmdableWrapper) HSetNX(ctx context.Context, key, field string, value interface{}) *redis.BoolCmd + func (c *CmdableWrapper) HVals(ctx context.Context, key string) *redis.StringSliceCmd + func (c *CmdableWrapper) Incr(ctx context.Context, key string) *redis.IntCmd + func (c *CmdableWrapper) IncrBy(ctx context.Context, key string, value int64) *redis.IntCmd + func (c *CmdableWrapper) IncrByFloat(ctx context.Context, key string, value float64) *redis.FloatCmd + func (c *CmdableWrapper) Keys(ctx context.Context, pattern string) *redis.StringSliceCmd + func (c *CmdableWrapper) LIndex(ctx context.Context, key string, index int64) *redis.StringCmd + func (c *CmdableWrapper) LInsert(ctx context.Context, key, op string, pivot, value interface{}) *redis.IntCmd + func (c *CmdableWrapper) LLen(ctx context.Context, key string) *redis.IntCmd + func (c *CmdableWrapper) LMove(ctx context.Context, srcKey, destKey, srcPos, destPos string) *redis.StringCmd + func (c *CmdableWrapper) LPop(ctx context.Context, key string) *redis.StringCmd + func (c *CmdableWrapper) LPos(ctx context.Context, key, value string, args redis.LPosArgs) *redis.IntCmd + func (c *CmdableWrapper) LPush(ctx context.Context, key string, values ...interface{}) *redis.IntCmd + func (c *CmdableWrapper) LPushX(ctx context.Context, key string, values ...interface{}) *redis.IntCmd + func (c *CmdableWrapper) LRange(ctx context.Context, key string, start, stop int64) *redis.StringSliceCmd + func (c *CmdableWrapper) LRem(ctx context.Context, key string, count int64, value interface{}) *redis.IntCmd + func (c *CmdableWrapper) LSet(ctx context.Context, key string, index int64, value interface{}) *redis.StatusCmd + func (c *CmdableWrapper) LTrim(ctx context.Context, key string, start, stop int64) *redis.StatusCmd + func (c *CmdableWrapper) MGet(ctx context.Context, keys ...string) *redis.SliceCmd + func (c *CmdableWrapper) MSet(ctx context.Context, values ...interface{}) *redis.StatusCmd + func (c *CmdableWrapper) MSetNX(ctx context.Context, values ...interface{}) *redis.BoolCmd + func (c *CmdableWrapper) Migrate(ctx context.Context, host, port, key string, db int, timeout time.Duration) *redis.StatusCmd + func (c *CmdableWrapper) Move(ctx context.Context, key string, db int) *redis.BoolCmd + func (c *CmdableWrapper) ObjectEncoding(ctx context.Context, key string) *redis.StringCmd + func (c *CmdableWrapper) ObjectIdleTime(ctx context.Context, key string) *redis.DurationCmd + func (c *CmdableWrapper) ObjectRefCount(ctx context.Context, key string) *redis.IntCmd + func (c *CmdableWrapper) PExpire(ctx context.Context, key string, value time.Duration) *redis.BoolCmd + func (c *CmdableWrapper) PExpireAt(ctx context.Context, key string, value time.Time) *redis.BoolCmd + func (c *CmdableWrapper) PFAdd(ctx context.Context, key string, elements ...interface{}) *redis.IntCmd + func (c *CmdableWrapper) PFCount(ctx context.Context, keys ...string) *redis.IntCmd + func (c *CmdableWrapper) PFMerge(ctx context.Context, destKey string, keys ...string) *redis.StatusCmd + func (c *CmdableWrapper) PTTL(ctx context.Context, key string) *redis.DurationCmd + func (c *CmdableWrapper) Persist(ctx context.Context, key string) *redis.BoolCmd + func (c *CmdableWrapper) Ping(ctx context.Context) *redis.StatusCmd + func (c *CmdableWrapper) PubSubChannels(ctx context.Context, pattern string) *redis.StringSliceCmd + func (c *CmdableWrapper) PubSubNumPat(ctx context.Context) *redis.IntCmd + func (c *CmdableWrapper) PubSubNumSub(ctx context.Context, channels ...string) *redis.StringIntMapCmd + func (c *CmdableWrapper) Publish(ctx context.Context, channel string, message interface{}) *redis.IntCmd + func (c *CmdableWrapper) RPop(ctx context.Context, key string) *redis.StringCmd + func (c *CmdableWrapper) RPush(ctx context.Context, key string, values ...interface{}) *redis.IntCmd + func (c *CmdableWrapper) RPushX(ctx context.Context, key string, values ...interface{}) *redis.IntCmd + func (c *CmdableWrapper) RandomKey(ctx context.Context) *redis.StringCmd + func (c *CmdableWrapper) ReadOnly(ctx context.Context) *redis.StatusCmd + func (c *CmdableWrapper) ReadWrite(ctx context.Context) *redis.StatusCmd + func (c *CmdableWrapper) Rename(ctx context.Context, key, newKey string) *redis.StatusCmd + func (c *CmdableWrapper) RenameNX(ctx context.Context, key, newKey string) *redis.BoolCmd + func (c *CmdableWrapper) Restore(ctx context.Context, key string, ttl time.Duration, value string) *redis.StatusCmd + func (c *CmdableWrapper) SAdd(ctx context.Context, key string, values ...interface{}) *redis.IntCmd + func (c *CmdableWrapper) SCard(ctx context.Context, key string) *redis.IntCmd + func (c *CmdableWrapper) SDiff(ctx context.Context, keys ...string) *redis.StringSliceCmd + func (c *CmdableWrapper) SDiffStore(ctx context.Context, destKey string, keys ...string) *redis.IntCmd + func (c *CmdableWrapper) SInter(ctx context.Context, keys ...string) *redis.StringSliceCmd + func (c *CmdableWrapper) SInterStore(ctx context.Context, destKey string, keys ...string) *redis.IntCmd + func (c *CmdableWrapper) SIsMember(ctx context.Context, key string, value interface{}) *redis.BoolCmd + func (c *CmdableWrapper) SMIsMember(ctx context.Context, key string, values ...interface{}) *redis.BoolSliceCmd + func (c *CmdableWrapper) SMembers(ctx context.Context, key string) *redis.StringSliceCmd + func (c *CmdableWrapper) SMove(ctx context.Context, srcKey, destKey string, value interface{}) *redis.BoolCmd + func (c *CmdableWrapper) SPop(ctx context.Context, key string) *redis.StringCmd + func (c *CmdableWrapper) SPopN(ctx context.Context, key string, count int64) *redis.StringSliceCmd + func (c *CmdableWrapper) SRandMember(ctx context.Context, key string) *redis.StringCmd + func (c *CmdableWrapper) SRandMemberN(ctx context.Context, key string, count int64) *redis.StringSliceCmd + func (c *CmdableWrapper) SRem(ctx context.Context, key string, values ...interface{}) *redis.IntCmd + func (c *CmdableWrapper) SScan(ctx context.Context, key string, cursor uint64, pattern string, count int64) *redis.ScanCmd + func (c *CmdableWrapper) SUnion(ctx context.Context, keys ...string) *redis.StringSliceCmd + func (c *CmdableWrapper) SUnionStore(ctx context.Context, destKey string, keys ...string) *redis.IntCmd + func (c *CmdableWrapper) Scan(ctx context.Context, cursor uint64, match string, count int64) *redis.ScanCmd + func (c *CmdableWrapper) ScriptExists(ctx context.Context, hashes ...string) *redis.BoolSliceCmd + func (c *CmdableWrapper) ScriptFlush(ctx context.Context) *redis.StatusCmd + func (c *CmdableWrapper) ScriptKill(ctx context.Context) *redis.StatusCmd + func (c *CmdableWrapper) ScriptLoad(ctx context.Context, script string) *redis.StringCmd + func (c *CmdableWrapper) Set(ctx context.Context, key string, value interface{}, expiration time.Duration) *redis.StatusCmd + func (c *CmdableWrapper) SetBit(ctx context.Context, key string, offset int64, value int) *redis.IntCmd + func (c *CmdableWrapper) SetEX(ctx context.Context, key string, value interface{}, expiration time.Duration) *redis.StatusCmd + func (c *CmdableWrapper) SetNX(ctx context.Context, key string, value interface{}, expiration time.Duration) *redis.BoolCmd + func (c *CmdableWrapper) SetRange(ctx context.Context, key string, offset int64, value string) *redis.IntCmd + func (c *CmdableWrapper) Sort(ctx context.Context, key string, sort *redis.Sort) *redis.StringSliceCmd + func (c *CmdableWrapper) StrLen(ctx context.Context, key string) *redis.IntCmd + func (c *CmdableWrapper) TTL(ctx context.Context, key string) *redis.DurationCmd + func (c *CmdableWrapper) Touch(ctx context.Context, keys ...string) *redis.IntCmd + func (c *CmdableWrapper) Type(ctx context.Context, key string) *redis.StatusCmd + func (c *CmdableWrapper) Unlink(ctx context.Context, keys ...string) *redis.IntCmd + func (c *CmdableWrapper) XAck(ctx context.Context, stream, group string, ids ...string) *redis.IntCmd + func (c *CmdableWrapper) XAdd(ctx context.Context, args *redis.XAddArgs) *redis.StringCmd + func (c *CmdableWrapper) XAutoClaim(ctx context.Context, args *redis.XAutoClaimArgs) *redis.XAutoClaimCmd + func (c *CmdableWrapper) XAutoClaimJustID(ctx context.Context, args *redis.XAutoClaimArgs) *redis.XAutoClaimJustIDCmd + func (c *CmdableWrapper) XDel(ctx context.Context, stream string, ids ...string) *redis.IntCmd + func (c *CmdableWrapper) XGroupCreate(ctx context.Context, stream, group, start string) *redis.StatusCmd + func (c *CmdableWrapper) XGroupCreateConsumer(ctx context.Context, stream, group, consumer string) *redis.IntCmd + func (c *CmdableWrapper) XGroupCreateMkStream(ctx context.Context, stream, group, start string) *redis.StatusCmd + func (c *CmdableWrapper) XGroupDelConsumer(ctx context.Context, stream, group, consumer string) *redis.IntCmd + func (c *CmdableWrapper) XGroupDestroy(ctx context.Context, stream, group string) *redis.IntCmd + func (c *CmdableWrapper) XGroupSetID(ctx context.Context, stream, group, start string) *redis.StatusCmd + func (c *CmdableWrapper) XInfoConsumers(ctx context.Context, key, group string) *redis.XInfoConsumersCmd + func (c *CmdableWrapper) XInfoGroups(ctx context.Context, key string) *redis.XInfoGroupsCmd + func (c *CmdableWrapper) XInfoStream(ctx context.Context, key string) *redis.XInfoStreamCmd + func (c *CmdableWrapper) XInfoStreamFull(ctx context.Context, key string, count int) *redis.XInfoStreamFullCmd + func (c *CmdableWrapper) XLen(ctx context.Context, stream string) *redis.IntCmd + func (c *CmdableWrapper) XPending(ctx context.Context, stream, group string) *redis.XPendingCmd + func (c *CmdableWrapper) XPendingExt(ctx context.Context, args *redis.XPendingExtArgs) *redis.XPendingExtCmd + func (c *CmdableWrapper) XRange(ctx context.Context, stream, start, stop string) *redis.XMessageSliceCmd + func (c *CmdableWrapper) XRangeN(ctx context.Context, stream, start, stop string, count int64) *redis.XMessageSliceCmd + func (c *CmdableWrapper) XRead(ctx context.Context, args *redis.XReadArgs) *redis.XStreamSliceCmd + func (c *CmdableWrapper) XReadGroup(ctx context.Context, args *redis.XReadGroupArgs) *redis.XStreamSliceCmd + func (c *CmdableWrapper) XRevRange(ctx context.Context, stream, start, stop string) *redis.XMessageSliceCmd + func (c *CmdableWrapper) XRevRangeN(ctx context.Context, stream, start, stop string, count int64) *redis.XMessageSliceCmd + func (c *CmdableWrapper) XTrimMaxLen(ctx context.Context, key string, maxLen int64) *redis.IntCmd + func (c *CmdableWrapper) XTrimMaxLenApprox(ctx context.Context, key string, maxLen, limit int64) *redis.IntCmd + func (c *CmdableWrapper) XTrimMinID(ctx context.Context, key, minId string) *redis.IntCmd + func (c *CmdableWrapper) XTrimMinIDApprox(ctx context.Context, key, minId string, limit int64) *redis.IntCmd + func (c *CmdableWrapper) ZAdd(ctx context.Context, key string, values ...*redis.Z) *redis.IntCmd + func (c *CmdableWrapper) ZCard(ctx context.Context, key string) *redis.IntCmd + func (c *CmdableWrapper) ZCount(ctx context.Context, key, min, max string) *redis.IntCmd + func (c *CmdableWrapper) ZDiff(ctx context.Context, keys ...string) *redis.StringSliceCmd + func (c *CmdableWrapper) ZDiffStore(ctx context.Context, destKey string, keys ...string) *redis.IntCmd + func (c *CmdableWrapper) ZDiffWithScores(ctx context.Context, keys ...string) *redis.ZSliceCmd + func (c *CmdableWrapper) ZIncrBy(ctx context.Context, key string, increment float64, value string) *redis.FloatCmd + func (c *CmdableWrapper) ZInter(ctx context.Context, store *redis.ZStore) *redis.StringSliceCmd + func (c *CmdableWrapper) ZInterStore(ctx context.Context, destKey string, store *redis.ZStore) *redis.IntCmd + func (c *CmdableWrapper) ZInterWithScores(ctx context.Context, store *redis.ZStore) *redis.ZSliceCmd + func (c *CmdableWrapper) ZLexCount(ctx context.Context, key, min, max string) *redis.IntCmd + func (c *CmdableWrapper) ZMScore(ctx context.Context, key string, values ...string) *redis.FloatSliceCmd + func (c *CmdableWrapper) ZPopMax(ctx context.Context, key string, count ...int64) *redis.ZSliceCmd + func (c *CmdableWrapper) ZPopMin(ctx context.Context, key string, count ...int64) *redis.ZSliceCmd + func (c *CmdableWrapper) ZRandMember(ctx context.Context, key string, count int, withScores bool) *redis.StringSliceCmd + func (c *CmdableWrapper) ZRange(ctx context.Context, key string, start, stop int64) *redis.StringSliceCmd + func (c *CmdableWrapper) ZRangeArgs(ctx context.Context, args redis.ZRangeArgs) *redis.StringSliceCmd + func (c *CmdableWrapper) ZRangeArgsWithScores(ctx context.Context, args redis.ZRangeArgs) *redis.ZSliceCmd + func (c *CmdableWrapper) ZRangeByLex(ctx context.Context, key string, opts *redis.ZRangeBy) *redis.StringSliceCmd + func (c *CmdableWrapper) ZRangeByScore(ctx context.Context, key string, opts *redis.ZRangeBy) *redis.StringSliceCmd + func (c *CmdableWrapper) ZRangeByScoreWithScores(ctx context.Context, key string, opts *redis.ZRangeBy) *redis.ZSliceCmd + func (c *CmdableWrapper) ZRangeStore(ctx context.Context, destKey string, args redis.ZRangeArgs) *redis.IntCmd + func (c *CmdableWrapper) ZRangeWithScores(ctx context.Context, key string, start, stop int64) *redis.ZSliceCmd + func (c *CmdableWrapper) ZRank(ctx context.Context, key, member string) *redis.IntCmd + func (c *CmdableWrapper) ZRem(ctx context.Context, key string, members ...interface{}) *redis.IntCmd + func (c *CmdableWrapper) ZRemRangeByLex(ctx context.Context, key, min, max string) *redis.IntCmd + func (c *CmdableWrapper) ZRemRangeByRank(ctx context.Context, key string, start, stop int64) *redis.IntCmd + func (c *CmdableWrapper) ZRemRangeByScore(ctx context.Context, key, min, max string) *redis.IntCmd + func (c *CmdableWrapper) ZRevRange(ctx context.Context, key string, start, stop int64) *redis.StringSliceCmd + func (c *CmdableWrapper) ZRevRangeByLex(ctx context.Context, key string, opts *redis.ZRangeBy) *redis.StringSliceCmd + func (c *CmdableWrapper) ZRevRangeByScore(ctx context.Context, key string, opts *redis.ZRangeBy) *redis.StringSliceCmd + func (c *CmdableWrapper) ZRevRangeByScoreWithScores(ctx context.Context, key string, opts *redis.ZRangeBy) *redis.ZSliceCmd + func (c *CmdableWrapper) ZRevRangeWithScores(ctx context.Context, key string, start, stop int64) *redis.ZSliceCmd + func (c *CmdableWrapper) ZRevRank(ctx context.Context, key string, member string) *redis.IntCmd + func (c *CmdableWrapper) ZScan(ctx context.Context, key string, cursor uint64, match string, count int64) *redis.ScanCmd + func (c *CmdableWrapper) ZScore(ctx context.Context, key, member string) *redis.FloatCmd + func (c *CmdableWrapper) ZUnion(ctx context.Context, store redis.ZStore) *redis.StringSliceCmd + func (c *CmdableWrapper) ZUnionStore(ctx context.Context, destKey string, store *redis.ZStore) *redis.IntCmd + func (c *CmdableWrapper) ZUnionWithScores(ctx context.Context, store redis.ZStore) *redis.ZSliceCmd + type GoRedisConnect struct + func NewGoRedisConnect(hostsAndPorts, password string, maxRetries int) (*GoRedisConnect, error) + func NewGoRedisConnectWithPoolOptions(hostsAndPorts, password string, maxRetries int, poolOpts *RedisPoolOpts) (*GoRedisConnect, error) + func (r *GoRedisConnect) Close() error + func (r *GoRedisConnect) GetClient(db int) *redis.Client + func (r *GoRedisConnect) GetClientProxy(db int) *RedisClientProxy + func (r *GoRedisConnect) GetClusterClient() *redis.ClusterClient + func (r *GoRedisConnect) GetClusterClientProxy() *RedisClusterClientProxy + func (r *GoRedisConnect) GetFailoverClient(db int) *redis.Client + func (r *GoRedisConnect) GetFailoverClientProxy(db int) *RedisFailoverClientProxy + func (r *GoRedisConnect) GetRedisPoolOpts() *RedisPoolOpts + func (r *GoRedisConnect) GetSentinelMasterName() string + func (r *GoRedisConnect) GetSlaveReadOnly() bool + func (r *GoRedisConnect) Init() error + func (r *GoRedisConnect) LogMetrics(category string, cmd *prom.CmdExecInfo) error + func (r *GoRedisConnect) Metrics(category string, opts ...prom.MetricsOpts) (*prom.Metrics, error) + func (r *GoRedisConnect) MetricsLogger() prom.IMetricsLogger + func (r *GoRedisConnect) NewCmdExecInfo() *prom.CmdExecInfo + func (r *GoRedisConnect) RegisterMetricsLogger(metricsLogger prom.IMetricsLogger) *GoRedisConnect + func (r *GoRedisConnect) SetRedisPoolOpts(opts *RedisPoolOpts) *GoRedisConnect + func (r *GoRedisConnect) SetSentinelMasterName(masterName string) *GoRedisConnect + func (r *GoRedisConnect) SetSlaveReadOnly(readOnly bool) *GoRedisConnect + type RedisClientProxy struct + func (cp *RedisClientProxy) PSubscribe(ctx context.Context, channels ...string) *redis.PubSub + func (cp *RedisClientProxy) Subscribe(ctx context.Context, channels ...string) *redis.PubSub + func (cp *RedisClientProxy) Wait(ctx context.Context, numSlaves int, timeout time.Duration) *redis.IntCmd + type RedisClusterClientProxy struct + func (cp *RedisClusterClientProxy) PSubscribe(ctx context.Context, channels ...string) *redis.PubSub + func (cp *RedisClusterClientProxy) Subscribe(ctx context.Context, channels ...string) *redis.PubSub + func (cp *RedisClusterClientProxy) Wait(ctx context.Context, numSlaves int, timeout time.Duration) *redis.IntCmd + type RedisFailoverClientProxy struct + type RedisPoolOpts struct + DialTimeout time.Duration + MinIdleConns int + PoolSize int + ReadTimeout time.Duration + WriteTimeout time.Duration