Versions in this module Expand all Collapse all v1 v1.0.0 Mar 24, 2023 Changes in this version + const BIG_M + const BIG_R + const RedisTypeClient + const RedisTypeCluster + const RedisTypeSentinel + const RedisTypeShardedSentinel + const SEED + func Find(slice []string, val string) (int, bool) + func MurmurHash64A(data []byte, seed int64) (h int64) + func MurmurHashBytes(data []byte) (h int64) + func MurmurHashString(data string) (h int64) + func NewShardedPipeline(ctx context.Context, fn func(context.Context, []redis.Cmder) error) redis.Pipeliner + func SetClient(name string, client Redis) + type Hashing interface + type MurmurHash struct + type Option struct + Addr []string + AutoGenShardName bool + ConnType string + DB int + DialTimeout time.Duration + EnableTracer bool + IdleCheckFrequency time.Duration + IdleTimeout time.Duration + MasterNames []string + MaxConnAge time.Duration + MaxRetries int + MaxRetryBackoff time.Duration + MinIdleConns int + MinRetryBackoff time.Duration + Name string + Password string + PoolSize int + PoolTimeout time.Duration + ReadTimeout time.Duration + TLSConfig *tls.Config + Username string + WriteTimeout time.Duration + func NewDefaultOptions() *Option + type Redis interface + func GetClient(name string) Redis + func NewShardedClient(sis []*ShardInfo) Redis + type RedisContainer struct + Opt Option + func New(opt *Option, logger xlog.Logger, metrics metrics.Provider, ...) (*RedisContainer, error) + func NewClient(opt *Option, logger xlog.Logger, metrics metrics.Provider, ...) *RedisContainer + func NewClusterClient(opt *Option, logger xlog.Logger, metrics metrics.Provider, ...) *RedisContainer + func NewSentinelClient(opt *Option, logger xlog.Logger, metrics metrics.Provider, ...) *RedisContainer + func NewShardedSentinelClient(opt *Option, logger xlog.Logger, metrics metrics.Provider, ...) *RedisContainer + type ShardInfo struct + type ShardedClient struct + func (c *ShardedClient) Append(ctx context.Context, key, value string) *redis.IntCmd + func (c *ShardedClient) BLPop(ctx context.Context, timeout time.Duration, keys ...string) *redis.StringSliceCmd + func (c *ShardedClient) BRPop(ctx context.Context, timeout time.Duration, keys ...string) *redis.StringSliceCmd + func (c *ShardedClient) BRPopLPush(ctx context.Context, source, destination string, timeout time.Duration) *redis.StringCmd + func (c *ShardedClient) BZPopMax(ctx context.Context, timeout time.Duration, keys ...string) *redis.ZWithKeyCmd + func (c *ShardedClient) BZPopMin(ctx context.Context, timeout time.Duration, keys ...string) *redis.ZWithKeyCmd + func (c *ShardedClient) BgRewriteAOF(ctx context.Context) *redis.StatusCmd + func (c *ShardedClient) BgSave(ctx context.Context) *redis.StatusCmd + func (c *ShardedClient) BitCount(ctx context.Context, key string, bitCount *redis.BitCount) *redis.IntCmd + func (c *ShardedClient) BitField(ctx context.Context, key string, args ...interface{}) *redis.IntSliceCmd + func (c *ShardedClient) BitOpAnd(ctx context.Context, destKey string, keys ...string) *redis.IntCmd + func (c *ShardedClient) BitOpNot(ctx context.Context, destKey string, key string) *redis.IntCmd + func (c *ShardedClient) BitOpOr(ctx context.Context, destKey string, keys ...string) *redis.IntCmd + func (c *ShardedClient) BitOpXor(ctx context.Context, destKey string, keys ...string) *redis.IntCmd + func (c *ShardedClient) BitPos(ctx context.Context, key string, bit int64, pos ...int64) *redis.IntCmd + func (c *ShardedClient) ChangeShardInfo(id string, si *ShardInfo) + func (c *ShardedClient) ClientGetName(ctx context.Context) *redis.StringCmd + func (c *ShardedClient) ClientID(ctx context.Context) *redis.IntCmd + func (c *ShardedClient) ClientKill(ctx context.Context, ipPort string) *redis.StatusCmd + func (c *ShardedClient) ClientKillByFilter(ctx context.Context, keys ...string) *redis.IntCmd + func (c *ShardedClient) ClientList(ctx context.Context) *redis.StringCmd + func (c *ShardedClient) ClientPause(ctx context.Context, dur time.Duration) *redis.BoolCmd + func (c *ShardedClient) Close() error + func (c *ShardedClient) ClusterAddSlots(ctx context.Context, slots ...int) *redis.StatusCmd + func (c *ShardedClient) ClusterAddSlotsRange(ctx context.Context, min, max int) *redis.StatusCmd + func (c *ShardedClient) ClusterCountFailureReports(ctx context.Context, nodeID string) *redis.IntCmd + func (c *ShardedClient) ClusterCountKeysInSlot(ctx context.Context, slot int) *redis.IntCmd + func (c *ShardedClient) ClusterDelSlots(ctx context.Context, slots ...int) *redis.StatusCmd + func (c *ShardedClient) ClusterDelSlotsRange(ctx context.Context, min, max int) *redis.StatusCmd + func (c *ShardedClient) ClusterFailover(ctx context.Context) *redis.StatusCmd + func (c *ShardedClient) ClusterForget(ctx context.Context, nodeID string) *redis.StatusCmd + func (c *ShardedClient) ClusterGetKeysInSlot(ctx context.Context, slot int, count int) *redis.StringSliceCmd + func (c *ShardedClient) ClusterInfo(ctx context.Context) *redis.StringCmd + func (c *ShardedClient) ClusterKeySlot(ctx context.Context, key string) *redis.IntCmd + func (c *ShardedClient) ClusterMeet(ctx context.Context, host, port string) *redis.StatusCmd + func (c *ShardedClient) ClusterNodes(ctx context.Context) *redis.StringCmd + func (c *ShardedClient) ClusterReplicate(ctx context.Context, nodeID string) *redis.StatusCmd + func (c *ShardedClient) ClusterResetHard(ctx context.Context) *redis.StatusCmd + func (c *ShardedClient) ClusterResetSoft(ctx context.Context) *redis.StatusCmd + func (c *ShardedClient) ClusterSaveConfig(ctx context.Context) *redis.StatusCmd + func (c *ShardedClient) ClusterSlaves(ctx context.Context, nodeID string) *redis.StringSliceCmd + func (c *ShardedClient) ClusterSlots(ctx context.Context) *redis.ClusterSlotsCmd + func (c *ShardedClient) Command(ctx context.Context) *redis.CommandsInfoCmd + func (c *ShardedClient) ConfigGet(ctx context.Context, parameter string) *redis.SliceCmd + func (c *ShardedClient) ConfigResetStat(ctx context.Context) *redis.StatusCmd + func (c *ShardedClient) ConfigRewrite(ctx context.Context) *redis.StatusCmd + func (c *ShardedClient) ConfigSet(ctx context.Context, parameter, value string) *redis.StatusCmd + func (c *ShardedClient) DBSize(ctx context.Context) *redis.IntCmd + func (c *ShardedClient) DebugObject(ctx context.Context, key string) *redis.StringCmd + func (c *ShardedClient) Decr(ctx context.Context, key string) *redis.IntCmd + func (c *ShardedClient) DecrBy(ctx context.Context, key string, decrement int64) *redis.IntCmd + func (c *ShardedClient) Del(ctx context.Context, keys ...string) *redis.IntCmd + func (c *ShardedClient) Dump(ctx context.Context, key string) *redis.StringCmd + func (c *ShardedClient) Echo(ctx context.Context, message interface{}) *redis.StringCmd + func (c *ShardedClient) Eval(ctx context.Context, script string, keys []string, args ...interface{}) *redis.Cmd + func (c *ShardedClient) EvalSha(ctx context.Context, sha1 string, keys []string, args ...interface{}) *redis.Cmd + func (c *ShardedClient) Exists(ctx context.Context, keys ...string) *redis.IntCmd + func (c *ShardedClient) Expire(ctx context.Context, key string, expiration time.Duration) *redis.BoolCmd + func (c *ShardedClient) ExpireAt(ctx context.Context, key string, tm time.Time) *redis.BoolCmd + func (c *ShardedClient) FlushAll(ctx context.Context) *redis.StatusCmd + func (c *ShardedClient) FlushAllAsync(ctx context.Context) *redis.StatusCmd + func (c *ShardedClient) FlushDB(ctx context.Context) *redis.StatusCmd + func (c *ShardedClient) FlushDBAsync(ctx context.Context) *redis.StatusCmd + func (c *ShardedClient) GeoAdd(ctx context.Context, key string, geoLocation ...*redis.GeoLocation) *redis.IntCmd + func (c *ShardedClient) GeoDist(ctx context.Context, key string, member1, member2, unit string) *redis.FloatCmd + func (c *ShardedClient) GeoHash(ctx context.Context, key string, members ...string) *redis.StringSliceCmd + func (c *ShardedClient) GeoPos(ctx context.Context, key string, members ...string) *redis.GeoPosCmd + func (c *ShardedClient) GeoRadius(ctx context.Context, key string, longitude, latitude float64, ...) *redis.GeoLocationCmd + func (c *ShardedClient) GeoRadiusByMember(ctx context.Context, key, member string, query *redis.GeoRadiusQuery) *redis.GeoLocationCmd + func (c *ShardedClient) GeoRadiusByMemberStore(ctx context.Context, key, member string, query *redis.GeoRadiusQuery) *redis.IntCmd + func (c *ShardedClient) GeoRadiusStore(ctx context.Context, key string, longitude, latitude float64, ...) *redis.IntCmd + func (c *ShardedClient) Get(ctx context.Context, key string) *redis.StringCmd + func (c *ShardedClient) GetBit(ctx context.Context, key string, offset int64) *redis.IntCmd + func (c *ShardedClient) GetRange(ctx context.Context, key string, start, end int64) *redis.StringCmd + func (c *ShardedClient) GetSet(ctx context.Context, key string, value interface{}) *redis.StringCmd + func (c *ShardedClient) HDel(ctx context.Context, key string, fields ...string) *redis.IntCmd + func (c *ShardedClient) HExists(ctx context.Context, key, field string) *redis.BoolCmd + func (c *ShardedClient) HGet(ctx context.Context, key, field string) *redis.StringCmd + func (c *ShardedClient) HGetAll(ctx context.Context, key string) *redis.StringStringMapCmd + func (c *ShardedClient) HIncrBy(ctx context.Context, key, field string, incr int64) *redis.IntCmd + func (c *ShardedClient) HIncrByFloat(ctx context.Context, key, field string, incr float64) *redis.FloatCmd + func (c *ShardedClient) HKeys(ctx context.Context, key string) *redis.StringSliceCmd + func (c *ShardedClient) HLen(ctx context.Context, key string) *redis.IntCmd + func (c *ShardedClient) HMGet(ctx context.Context, key string, fields ...string) *redis.SliceCmd + func (c *ShardedClient) HMSet(ctx context.Context, key string, values ...interface{}) *redis.BoolCmd + func (c *ShardedClient) HScan(ctx context.Context, key string, cursor uint64, match string, count int64) *redis.ScanCmd + func (c *ShardedClient) HSet(ctx context.Context, key string, values ...interface{}) *redis.IntCmd + func (c *ShardedClient) HSetNX(ctx context.Context, key, field string, value interface{}) *redis.BoolCmd + func (c *ShardedClient) HVals(ctx context.Context, key string) *redis.StringSliceCmd + func (c *ShardedClient) Incr(ctx context.Context, key string) *redis.IntCmd + func (c *ShardedClient) IncrBy(ctx context.Context, key string, value int64) *redis.IntCmd + func (c *ShardedClient) IncrByFloat(ctx context.Context, key string, value float64) *redis.FloatCmd + func (c *ShardedClient) Info(ctx context.Context, section ...string) *redis.StringCmd + func (c *ShardedClient) Keys(ctx context.Context, pattern string) *redis.StringSliceCmd + func (c *ShardedClient) LIndex(ctx context.Context, key string, index int64) *redis.StringCmd + func (c *ShardedClient) LInsert(ctx context.Context, key, op string, pivot, value interface{}) *redis.IntCmd + func (c *ShardedClient) LInsertAfter(ctx context.Context, key string, pivot, value interface{}) *redis.IntCmd + func (c *ShardedClient) LInsertBefore(ctx context.Context, key string, pivot, value interface{}) *redis.IntCmd + func (c *ShardedClient) LLen(ctx context.Context, key string) *redis.IntCmd + func (c *ShardedClient) LPop(ctx context.Context, key string) *redis.StringCmd + func (c *ShardedClient) LPush(ctx context.Context, key string, values ...interface{}) *redis.IntCmd + func (c *ShardedClient) LPushX(ctx context.Context, key string, values ...interface{}) *redis.IntCmd + func (c *ShardedClient) LRange(ctx context.Context, key string, start, stop int64) *redis.StringSliceCmd + func (c *ShardedClient) LRem(ctx context.Context, key string, count int64, value interface{}) *redis.IntCmd + func (c *ShardedClient) LSet(ctx context.Context, key string, index int64, value interface{}) *redis.StatusCmd + func (c *ShardedClient) LTrim(ctx context.Context, key string, start, stop int64) *redis.StatusCmd + func (c *ShardedClient) LastSave(ctx context.Context) *redis.IntCmd + func (c *ShardedClient) MGet(ctx context.Context, keys ...string) *redis.SliceCmd + func (c *ShardedClient) MSet(ctx context.Context, values ...interface{}) *redis.StatusCmd + func (c *ShardedClient) MSetNX(ctx context.Context, values ...interface{}) *redis.BoolCmd + func (c *ShardedClient) MemoryUsage(ctx context.Context, key string, samples ...int) *redis.IntCmd + func (c *ShardedClient) Migrate(ctx context.Context, host, port, key string, db int, timeout time.Duration) *redis.StatusCmd + func (c *ShardedClient) Move(ctx context.Context, key string, db int) *redis.BoolCmd + func (c *ShardedClient) ObjectEncoding(ctx context.Context, key string) *redis.StringCmd + func (c *ShardedClient) ObjectIdleTime(ctx context.Context, key string) *redis.DurationCmd + func (c *ShardedClient) ObjectRefCount(ctx context.Context, key string) *redis.IntCmd + func (c *ShardedClient) PExpire(ctx context.Context, key string, expiration time.Duration) *redis.BoolCmd + func (c *ShardedClient) PExpireAt(ctx context.Context, key string, tm time.Time) *redis.BoolCmd + func (c *ShardedClient) PFAdd(ctx context.Context, key string, els ...interface{}) *redis.IntCmd + func (c *ShardedClient) PFCount(ctx context.Context, keys ...string) *redis.IntCmd + func (c *ShardedClient) PFMerge(ctx context.Context, dest string, keys ...string) *redis.StatusCmd + func (c *ShardedClient) PTTL(ctx context.Context, key string) *redis.DurationCmd + func (c *ShardedClient) Persist(ctx context.Context, key string) *redis.BoolCmd + func (c *ShardedClient) Ping(ctx context.Context) *redis.StatusCmd + func (c *ShardedClient) Pipeline() redis.Pipeliner + func (c *ShardedClient) Pipelined(ctx context.Context, fn func(redis.Pipeliner) error) ([]redis.Cmder, error) + func (c *ShardedClient) PubSubChannels(ctx context.Context, pattern string) *redis.StringSliceCmd + func (c *ShardedClient) PubSubNumPat(ctx context.Context) *redis.IntCmd + func (c *ShardedClient) PubSubNumSub(ctx context.Context, channels ...string) *redis.StringIntMapCmd + func (c *ShardedClient) Publish(ctx context.Context, channel string, message interface{}) *redis.IntCmd + func (c *ShardedClient) Quit(ctx context.Context) *redis.StatusCmd + func (c *ShardedClient) RPop(ctx context.Context, key string) *redis.StringCmd + func (c *ShardedClient) RPopLPush(ctx context.Context, source, destination string) *redis.StringCmd + func (c *ShardedClient) RPush(ctx context.Context, key string, values ...interface{}) *redis.IntCmd + func (c *ShardedClient) RPushX(ctx context.Context, key string, values ...interface{}) *redis.IntCmd + func (c *ShardedClient) RandomKey(ctx context.Context) *redis.StringCmd + func (c *ShardedClient) ReadOnly(ctx context.Context) *redis.StatusCmd + func (c *ShardedClient) ReadWrite(ctx context.Context) *redis.StatusCmd + func (c *ShardedClient) Rename(ctx context.Context, key, newkey string) *redis.StatusCmd + func (c *ShardedClient) RenameNX(ctx context.Context, key, newkey string) *redis.BoolCmd + func (c *ShardedClient) Restore(ctx context.Context, key string, ttl time.Duration, value string) *redis.StatusCmd + func (c *ShardedClient) RestoreReplace(ctx context.Context, key string, ttl time.Duration, value string) *redis.StatusCmd + func (c *ShardedClient) SAdd(ctx context.Context, key string, members ...interface{}) *redis.IntCmd + func (c *ShardedClient) SCard(ctx context.Context, key string) *redis.IntCmd + func (c *ShardedClient) SDiff(ctx context.Context, keys ...string) *redis.StringSliceCmd + func (c *ShardedClient) SDiffStore(ctx context.Context, destination string, keys ...string) *redis.IntCmd + func (c *ShardedClient) SInter(ctx context.Context, keys ...string) *redis.StringSliceCmd + func (c *ShardedClient) SInterStore(ctx context.Context, destination string, keys ...string) *redis.IntCmd + func (c *ShardedClient) SIsMember(ctx context.Context, key string, member interface{}) *redis.BoolCmd + func (c *ShardedClient) SMembers(ctx context.Context, key string) *redis.StringSliceCmd + func (c *ShardedClient) SMembersMap(ctx context.Context, key string) *redis.StringStructMapCmd + func (c *ShardedClient) SMove(ctx context.Context, source, destination string, member interface{}) *redis.BoolCmd + func (c *ShardedClient) SPop(ctx context.Context, key string) *redis.StringCmd + func (c *ShardedClient) SPopN(ctx context.Context, key string, count int64) *redis.StringSliceCmd + func (c *ShardedClient) SRandMember(ctx context.Context, key string) *redis.StringCmd + func (c *ShardedClient) SRandMemberN(ctx context.Context, key string, count int64) *redis.StringSliceCmd + func (c *ShardedClient) SRem(ctx context.Context, key string, members ...interface{}) *redis.IntCmd + func (c *ShardedClient) SScan(ctx context.Context, key string, cursor uint64, match string, count int64) *redis.ScanCmd + func (c *ShardedClient) SUnion(ctx context.Context, keys ...string) *redis.StringSliceCmd + func (c *ShardedClient) SUnionStore(ctx context.Context, destination string, keys ...string) *redis.IntCmd + func (c *ShardedClient) Save(ctx context.Context) *redis.StatusCmd + func (c *ShardedClient) Scan(ctx context.Context, cursor uint64, match string, count int64) *redis.ScanCmd + func (c *ShardedClient) ScriptExists(ctx context.Context, hashes ...string) *redis.BoolSliceCmd + func (c *ShardedClient) ScriptFlush(ctx context.Context) *redis.StatusCmd + func (c *ShardedClient) ScriptKill(ctx context.Context) *redis.StatusCmd + func (c *ShardedClient) ScriptLoad(ctx context.Context, script string) *redis.StringCmd + func (c *ShardedClient) Set(ctx context.Context, key string, value interface{}, expiration time.Duration) *redis.StatusCmd + func (c *ShardedClient) SetBit(ctx context.Context, key string, offset int64, value int) *redis.IntCmd + func (c *ShardedClient) SetEX(ctx context.Context, key string, value interface{}, expiration time.Duration) *redis.StatusCmd + func (c *ShardedClient) SetNX(ctx context.Context, key string, value interface{}, expiration time.Duration) *redis.BoolCmd + func (c *ShardedClient) SetRange(ctx context.Context, key string, offset int64, value string) *redis.IntCmd + func (c *ShardedClient) SetXX(ctx context.Context, key string, value interface{}, expiration time.Duration) *redis.BoolCmd + func (c *ShardedClient) Shutdown(ctx context.Context) *redis.StatusCmd + func (c *ShardedClient) ShutdownNoSave(ctx context.Context) *redis.StatusCmd + func (c *ShardedClient) ShutdownSave(ctx context.Context) *redis.StatusCmd + func (c *ShardedClient) SlaveOf(ctx context.Context, host, port string) *redis.StatusCmd + func (c *ShardedClient) Sort(ctx context.Context, key string, sort *redis.Sort) *redis.StringSliceCmd + func (c *ShardedClient) SortInterfaces(ctx context.Context, key string, sort *redis.Sort) *redis.SliceCmd + func (c *ShardedClient) SortStore(ctx context.Context, key, store string, sort *redis.Sort) *redis.IntCmd + func (c *ShardedClient) StrLen(ctx context.Context, key string) *redis.IntCmd + func (c *ShardedClient) TTL(ctx context.Context, key string) *redis.DurationCmd + func (c *ShardedClient) Time(ctx context.Context) *redis.TimeCmd + func (c *ShardedClient) Touch(ctx context.Context, keys ...string) *redis.IntCmd + func (c *ShardedClient) TxPipeline() redis.Pipeliner + func (c *ShardedClient) TxPipelined(ctx context.Context, fn func(redis.Pipeliner) error) ([]redis.Cmder, error) + func (c *ShardedClient) Type(ctx context.Context, key string) *redis.StatusCmd + func (c *ShardedClient) Unlink(ctx context.Context, keys ...string) *redis.IntCmd + func (c *ShardedClient) XAck(ctx context.Context, stream, group string, ids ...string) *redis.IntCmd + func (c *ShardedClient) XAdd(ctx context.Context, a *redis.XAddArgs) *redis.StringCmd + func (c *ShardedClient) XClaim(ctx context.Context, a *redis.XClaimArgs) *redis.XMessageSliceCmd + func (c *ShardedClient) XClaimJustID(ctx context.Context, a *redis.XClaimArgs) *redis.StringSliceCmd + func (c *ShardedClient) XDel(ctx context.Context, stream string, ids ...string) *redis.IntCmd + func (c *ShardedClient) XGroupCreate(ctx context.Context, stream, group, start string) *redis.StatusCmd + func (c *ShardedClient) XGroupCreateMkStream(ctx context.Context, stream, group, start string) *redis.StatusCmd + func (c *ShardedClient) XGroupDelConsumer(ctx context.Context, stream, group, consumer string) *redis.IntCmd + func (c *ShardedClient) XGroupDestroy(ctx context.Context, stream, group string) *redis.IntCmd + func (c *ShardedClient) XGroupSetID(ctx context.Context, stream, group, start string) *redis.StatusCmd + func (c *ShardedClient) XInfoGroups(ctx context.Context, key string) *redis.XInfoGroupsCmd + func (c *ShardedClient) XInfoStream(ctx context.Context, key string) *redis.XInfoStreamCmd + func (c *ShardedClient) XLen(ctx context.Context, stream string) *redis.IntCmd + func (c *ShardedClient) XPending(ctx context.Context, stream, group string) *redis.XPendingCmd + func (c *ShardedClient) XPendingExt(ctx context.Context, a *redis.XPendingExtArgs) *redis.XPendingExtCmd + func (c *ShardedClient) XRange(ctx context.Context, stream, start, stop string) *redis.XMessageSliceCmd + func (c *ShardedClient) XRangeN(ctx context.Context, stream, start, stop string, count int64) *redis.XMessageSliceCmd + func (c *ShardedClient) XRead(ctx context.Context, a *redis.XReadArgs) *redis.XStreamSliceCmd + func (c *ShardedClient) XReadGroup(ctx context.Context, a *redis.XReadGroupArgs) *redis.XStreamSliceCmd + func (c *ShardedClient) XReadStreams(ctx context.Context, streams ...string) *redis.XStreamSliceCmd + func (c *ShardedClient) XRevRange(ctx context.Context, stream string, start, stop string) *redis.XMessageSliceCmd + func (c *ShardedClient) XRevRangeN(ctx context.Context, stream string, start, stop string, count int64) *redis.XMessageSliceCmd + func (c *ShardedClient) XTrim(ctx context.Context, key string, maxLen int64) *redis.IntCmd + func (c *ShardedClient) XTrimApprox(ctx context.Context, key string, maxLen int64) *redis.IntCmd + func (c *ShardedClient) ZAdd(ctx context.Context, key string, members ...*redis.Z) *redis.IntCmd + func (c *ShardedClient) ZAddCh(ctx context.Context, key string, members ...*redis.Z) *redis.IntCmd + func (c *ShardedClient) ZAddNX(ctx context.Context, key string, members ...*redis.Z) *redis.IntCmd + func (c *ShardedClient) ZAddNXCh(ctx context.Context, key string, members ...*redis.Z) *redis.IntCmd + func (c *ShardedClient) ZAddXX(ctx context.Context, key string, members ...*redis.Z) *redis.IntCmd + func (c *ShardedClient) ZAddXXCh(ctx context.Context, key string, members ...*redis.Z) *redis.IntCmd + func (c *ShardedClient) ZCard(ctx context.Context, key string) *redis.IntCmd + func (c *ShardedClient) ZCount(ctx context.Context, key, min, max string) *redis.IntCmd + func (c *ShardedClient) ZIncr(ctx context.Context, key string, member *redis.Z) *redis.FloatCmd + func (c *ShardedClient) ZIncrBy(ctx context.Context, key string, increment float64, member string) *redis.FloatCmd + func (c *ShardedClient) ZIncrNX(ctx context.Context, key string, member *redis.Z) *redis.FloatCmd + func (c *ShardedClient) ZIncrXX(ctx context.Context, key string, member *redis.Z) *redis.FloatCmd + func (c *ShardedClient) ZInterStore(ctx context.Context, destination string, store *redis.ZStore) *redis.IntCmd + func (c *ShardedClient) ZLexCount(ctx context.Context, key, min, max string) *redis.IntCmd + func (c *ShardedClient) ZPopMax(ctx context.Context, key string, count ...int64) *redis.ZSliceCmd + func (c *ShardedClient) ZPopMin(ctx context.Context, key string, count ...int64) *redis.ZSliceCmd + func (c *ShardedClient) ZRange(ctx context.Context, key string, start, stop int64) *redis.StringSliceCmd + func (c *ShardedClient) ZRangeByLex(ctx context.Context, key string, opt *redis.ZRangeBy) *redis.StringSliceCmd + func (c *ShardedClient) ZRangeByScore(ctx context.Context, key string, opt *redis.ZRangeBy) *redis.StringSliceCmd + func (c *ShardedClient) ZRangeByScoreWithScores(ctx context.Context, key string, opt *redis.ZRangeBy) *redis.ZSliceCmd + func (c *ShardedClient) ZRangeWithScores(ctx context.Context, key string, start, stop int64) *redis.ZSliceCmd + func (c *ShardedClient) ZRank(ctx context.Context, key, member string) *redis.IntCmd + func (c *ShardedClient) ZRem(ctx context.Context, key string, members ...interface{}) *redis.IntCmd + func (c *ShardedClient) ZRemRangeByLex(ctx context.Context, key, min, max string) *redis.IntCmd + func (c *ShardedClient) ZRemRangeByRank(ctx context.Context, key string, start, stop int64) *redis.IntCmd + func (c *ShardedClient) ZRemRangeByScore(ctx context.Context, key, min, max string) *redis.IntCmd + func (c *ShardedClient) ZRevRange(ctx context.Context, key string, start, stop int64) *redis.StringSliceCmd + func (c *ShardedClient) ZRevRangeByLex(ctx context.Context, key string, opt *redis.ZRangeBy) *redis.StringSliceCmd + func (c *ShardedClient) ZRevRangeByScore(ctx context.Context, key string, opt *redis.ZRangeBy) *redis.StringSliceCmd + func (c *ShardedClient) ZRevRangeByScoreWithScores(ctx context.Context, key string, opt *redis.ZRangeBy) *redis.ZSliceCmd + func (c *ShardedClient) ZRevRangeWithScores(ctx context.Context, key string, start, stop int64) *redis.ZSliceCmd + func (c *ShardedClient) ZRevRank(ctx context.Context, key, member string) *redis.IntCmd + func (c *ShardedClient) ZScan(ctx context.Context, key string, cursor uint64, match string, count int64) *redis.ScanCmd + func (c *ShardedClient) ZScore(ctx context.Context, key, member string) *redis.FloatCmd + func (c *ShardedClient) ZUnionStore(ctx context.Context, dest string, store *redis.ZStore) *redis.IntCmd + type ShardedSentinelClient struct Other modules containing this package github.com/NetEase-Media/easy-ngo