Versions in this module Expand all Collapse all v7 v7.5.0 May 21, 2020 Changes in this version + const Nil + const TxFailedErr + var ErrClosed = pool.ErrClosed + func SetLogger(logger internal.Logging) + type BitCount struct + End int64 + Start int64 + type BoolCmd struct + func NewBoolCmd(args ...interface{}) *BoolCmd + func NewBoolResult(val bool, err error) *BoolCmd + func (cmd *BoolCmd) Args() []interface{} + func (cmd *BoolCmd) Err() error + func (cmd *BoolCmd) Name() string + func (cmd *BoolCmd) Result() (bool, error) + func (cmd *BoolCmd) SetErr(e error) + func (cmd *BoolCmd) String() string + func (cmd *BoolCmd) Val() bool + type BoolSliceCmd struct + func NewBoolSliceCmd(args ...interface{}) *BoolSliceCmd + func NewBoolSliceResult(val []bool, err error) *BoolSliceCmd + func (cmd *BoolSliceCmd) Args() []interface{} + func (cmd *BoolSliceCmd) Err() error + func (cmd *BoolSliceCmd) Name() string + func (cmd *BoolSliceCmd) Result() ([]bool, error) + func (cmd *BoolSliceCmd) SetErr(e error) + func (cmd *BoolSliceCmd) String() string + func (cmd *BoolSliceCmd) Val() []bool + type Client struct + func NewClient(opt *Options) *Client + func NewFailoverClient(failoverOpt *FailoverOptions) *Client + func (c *Client) Conn() *Conn + func (c *Client) Context() context.Context + func (c *Client) Do(args ...interface{}) *Cmd + func (c *Client) DoContext(ctx context.Context, args ...interface{}) *Cmd + func (c *Client) Options() *Options + func (c *Client) PSubscribe(channels ...string) *PubSub + func (c *Client) Pipeline() Pipeliner + func (c *Client) Pipelined(fn func(Pipeliner) error) ([]Cmder, error) + func (c *Client) PoolStats() *PoolStats + func (c *Client) Process(cmd Cmder) error + func (c *Client) ProcessContext(ctx context.Context, cmd Cmder) error + func (c *Client) Subscribe(channels ...string) *PubSub + func (c *Client) TxPipeline() Pipeliner + func (c *Client) TxPipelined(fn func(Pipeliner) error) ([]Cmder, error) + func (c *Client) Watch(fn func(*Tx) error, keys ...string) error + func (c *Client) WatchContext(ctx context.Context, fn func(*Tx) error, keys ...string) error + func (c *Client) WithContext(ctx context.Context) *Client + func (c *Client) WithTimeout(timeout time.Duration) *Client + func (c Client) Append(key, value string) *IntCmd + func (c Client) BLPop(timeout time.Duration, keys ...string) *StringSliceCmd + func (c Client) BRPop(timeout time.Duration, keys ...string) *StringSliceCmd + func (c Client) BRPopLPush(source, destination string, timeout time.Duration) *StringCmd + func (c Client) BZPopMax(timeout time.Duration, keys ...string) *ZWithKeyCmd + func (c Client) BZPopMin(timeout time.Duration, keys ...string) *ZWithKeyCmd + func (c Client) BgRewriteAOF() *StatusCmd + func (c Client) BgSave() *StatusCmd + func (c Client) BitCount(key string, bitCount *BitCount) *IntCmd + func (c Client) BitField(key string, args ...interface{}) *IntSliceCmd + func (c Client) BitOpAnd(destKey string, keys ...string) *IntCmd + func (c Client) BitOpNot(destKey string, key string) *IntCmd + func (c Client) BitOpOr(destKey string, keys ...string) *IntCmd + func (c Client) BitOpXor(destKey string, keys ...string) *IntCmd + func (c Client) BitPos(key string, bit int64, pos ...int64) *IntCmd + func (c Client) ClientGetName() *StringCmd + func (c Client) ClientID() *IntCmd + func (c Client) ClientKill(ipPort string) *StatusCmd + func (c Client) ClientKillByFilter(keys ...string) *IntCmd + func (c Client) ClientList() *StringCmd + func (c Client) ClientPause(dur time.Duration) *BoolCmd + func (c Client) ClientUnblock(id int64) *IntCmd + func (c Client) ClientUnblockWithError(id int64) *IntCmd + func (c Client) Close() error + func (c Client) ClusterAddSlots(slots ...int) *StatusCmd + func (c Client) ClusterAddSlotsRange(min, max int) *StatusCmd + func (c Client) ClusterCountFailureReports(nodeID string) *IntCmd + func (c Client) ClusterCountKeysInSlot(slot int) *IntCmd + func (c Client) ClusterDelSlots(slots ...int) *StatusCmd + func (c Client) ClusterDelSlotsRange(min, max int) *StatusCmd + func (c Client) ClusterFailover() *StatusCmd + func (c Client) ClusterForget(nodeID string) *StatusCmd + func (c Client) ClusterGetKeysInSlot(slot int, count int) *StringSliceCmd + func (c Client) ClusterInfo() *StringCmd + func (c Client) ClusterKeySlot(key string) *IntCmd + func (c Client) ClusterMeet(host, port string) *StatusCmd + func (c Client) ClusterNodes() *StringCmd + func (c Client) ClusterReplicate(nodeID string) *StatusCmd + func (c Client) ClusterResetHard() *StatusCmd + func (c Client) ClusterResetSoft() *StatusCmd + func (c Client) ClusterSaveConfig() *StatusCmd + func (c Client) ClusterSlaves(nodeID string) *StringSliceCmd + func (c Client) ClusterSlots() *ClusterSlotsCmd + func (c Client) Command() *CommandsInfoCmd + func (c Client) ConfigGet(parameter string) *SliceCmd + func (c Client) ConfigResetStat() *StatusCmd + func (c Client) ConfigRewrite() *StatusCmd + func (c Client) ConfigSet(parameter, value string) *StatusCmd + func (c Client) DBSize() *IntCmd + func (c Client) DbSize() *IntCmd + func (c Client) DebugObject(key string) *StringCmd + func (c Client) Decr(key string) *IntCmd + func (c Client) DecrBy(key string, decrement int64) *IntCmd + func (c Client) Del(keys ...string) *IntCmd + func (c Client) Dump(key string) *StringCmd + func (c Client) Echo(message interface{}) *StringCmd + func (c Client) Eval(script string, keys []string, args ...interface{}) *Cmd + func (c Client) EvalSha(sha1 string, keys []string, args ...interface{}) *Cmd + func (c Client) Exists(keys ...string) *IntCmd + func (c Client) Expire(key string, expiration time.Duration) *BoolCmd + func (c Client) ExpireAt(key string, tm time.Time) *BoolCmd + func (c Client) FlushAll() *StatusCmd + func (c Client) FlushAllAsync() *StatusCmd + func (c Client) FlushDB() *StatusCmd + func (c Client) FlushDBAsync() *StatusCmd + func (c Client) GeoAdd(key string, geoLocation ...*GeoLocation) *IntCmd + func (c Client) GeoDist(key string, member1, member2, unit string) *FloatCmd + func (c Client) GeoHash(key string, members ...string) *StringSliceCmd + func (c Client) GeoPos(key string, members ...string) *GeoPosCmd + func (c Client) GeoRadius(key string, longitude, latitude float64, query *GeoRadiusQuery) *GeoLocationCmd + func (c Client) GeoRadiusByMember(key, member string, query *GeoRadiusQuery) *GeoLocationCmd + func (c Client) GeoRadiusByMemberStore(key, member string, query *GeoRadiusQuery) *IntCmd + func (c Client) GeoRadiusStore(key string, longitude, latitude float64, query *GeoRadiusQuery) *IntCmd + func (c Client) Get(key string) *StringCmd + func (c Client) GetBit(key string, offset int64) *IntCmd + func (c Client) GetRange(key string, start, end int64) *StringCmd + func (c Client) GetSet(key string, value interface{}) *StringCmd + func (c Client) HDel(key string, fields ...string) *IntCmd + func (c Client) HExists(key, field string) *BoolCmd + func (c Client) HGet(key, field string) *StringCmd + func (c Client) HGetAll(key string) *StringStringMapCmd + func (c Client) HIncrBy(key, field string, incr int64) *IntCmd + func (c Client) HIncrByFloat(key, field string, incr float64) *FloatCmd + func (c Client) HKeys(key string) *StringSliceCmd + func (c Client) HLen(key string) *IntCmd + func (c Client) HMGet(key string, fields ...string) *SliceCmd + func (c Client) HMSet(key string, values ...interface{}) *BoolCmd + func (c Client) HScan(key string, cursor uint64, match string, count int64) *ScanCmd + func (c Client) HSet(key string, values ...interface{}) *IntCmd + func (c Client) HSetNX(key, field string, value interface{}) *BoolCmd + func (c Client) HVals(key string) *StringSliceCmd + func (c Client) Incr(key string) *IntCmd + func (c Client) IncrBy(key string, value int64) *IntCmd + func (c Client) IncrByFloat(key string, value float64) *FloatCmd + func (c Client) Info(section ...string) *StringCmd + func (c Client) Keys(pattern string) *StringSliceCmd + func (c Client) LIndex(key string, index int64) *StringCmd + func (c Client) LInsert(key, op string, pivot, value interface{}) *IntCmd + func (c Client) LInsertAfter(key string, pivot, value interface{}) *IntCmd + func (c Client) LInsertBefore(key string, pivot, value interface{}) *IntCmd + func (c Client) LLen(key string) *IntCmd + func (c Client) LPop(key string) *StringCmd + func (c Client) LPush(key string, values ...interface{}) *IntCmd + func (c Client) LPushX(key string, values ...interface{}) *IntCmd + func (c Client) LRange(key string, start, stop int64) *StringSliceCmd + func (c Client) LRem(key string, count int64, value interface{}) *IntCmd + func (c Client) LSet(key string, index int64, value interface{}) *StatusCmd + func (c Client) LTrim(key string, start, stop int64) *StatusCmd + func (c Client) LastSave() *IntCmd + func (c Client) MGet(keys ...string) *SliceCmd + func (c Client) MSet(values ...interface{}) *StatusCmd + func (c Client) MSetNX(values ...interface{}) *BoolCmd + func (c Client) MemoryUsage(key string, samples ...int) *IntCmd + func (c Client) Migrate(host, port, key string, db int, timeout time.Duration) *StatusCmd + func (c Client) Move(key string, db int) *BoolCmd + func (c Client) ObjectEncoding(key string) *StringCmd + func (c Client) ObjectIdleTime(key string) *DurationCmd + func (c Client) ObjectRefCount(key string) *IntCmd + func (c Client) PExpire(key string, expiration time.Duration) *BoolCmd + func (c Client) PExpireAt(key string, tm time.Time) *BoolCmd + func (c Client) PFAdd(key string, els ...interface{}) *IntCmd + func (c Client) PFCount(keys ...string) *IntCmd + func (c Client) PFMerge(dest string, keys ...string) *StatusCmd + func (c Client) PTTL(key string) *DurationCmd + func (c Client) Persist(key string) *BoolCmd + func (c Client) Ping() *StatusCmd + func (c Client) PubSubChannels(pattern string) *StringSliceCmd + func (c Client) PubSubNumPat() *IntCmd + func (c Client) PubSubNumSub(channels ...string) *StringIntMapCmd + func (c Client) Publish(channel string, message interface{}) *IntCmd + func (c Client) Quit() *StatusCmd + func (c Client) RPop(key string) *StringCmd + func (c Client) RPopLPush(source, destination string) *StringCmd + func (c Client) RPush(key string, values ...interface{}) *IntCmd + func (c Client) RPushX(key string, values ...interface{}) *IntCmd + func (c Client) RandomKey() *StringCmd + func (c Client) ReadOnly() *StatusCmd + func (c Client) ReadWrite() *StatusCmd + func (c Client) Rename(key, newkey string) *StatusCmd + func (c Client) RenameNX(key, newkey string) *BoolCmd + func (c Client) Restore(key string, ttl time.Duration, value string) *StatusCmd + func (c Client) RestoreReplace(key string, ttl time.Duration, value string) *StatusCmd + func (c Client) SAdd(key string, members ...interface{}) *IntCmd + func (c Client) SCard(key string) *IntCmd + func (c Client) SDiff(keys ...string) *StringSliceCmd + func (c Client) SDiffStore(destination string, keys ...string) *IntCmd + func (c Client) SInter(keys ...string) *StringSliceCmd + func (c Client) SInterStore(destination string, keys ...string) *IntCmd + func (c Client) SIsMember(key string, member interface{}) *BoolCmd + func (c Client) SMembers(key string) *StringSliceCmd + func (c Client) SMembersMap(key string) *StringStructMapCmd + func (c Client) SMove(source, destination string, member interface{}) *BoolCmd + func (c Client) SPop(key string) *StringCmd + func (c Client) SPopN(key string, count int64) *StringSliceCmd + func (c Client) SRandMember(key string) *StringCmd + func (c Client) SRandMemberN(key string, count int64) *StringSliceCmd + func (c Client) SRem(key string, members ...interface{}) *IntCmd + func (c Client) SScan(key string, cursor uint64, match string, count int64) *ScanCmd + func (c Client) SUnion(keys ...string) *StringSliceCmd + func (c Client) SUnionStore(destination string, keys ...string) *IntCmd + func (c Client) Save() *StatusCmd + func (c Client) Scan(cursor uint64, match string, count int64) *ScanCmd + func (c Client) ScriptExists(hashes ...string) *BoolSliceCmd + func (c Client) ScriptFlush() *StatusCmd + func (c Client) ScriptKill() *StatusCmd + func (c Client) ScriptLoad(script string) *StringCmd + func (c Client) Set(key string, value interface{}, expiration time.Duration) *StatusCmd + func (c Client) SetBit(key string, offset int64, value int) *IntCmd + func (c Client) SetNX(key string, value interface{}, expiration time.Duration) *BoolCmd + func (c Client) SetRange(key string, offset int64, value string) *IntCmd + func (c Client) SetXX(key string, value interface{}, expiration time.Duration) *BoolCmd + func (c Client) Shutdown() *StatusCmd + func (c Client) ShutdownNoSave() *StatusCmd + func (c Client) ShutdownSave() *StatusCmd + func (c Client) SlaveOf(host, port string) *StatusCmd + func (c Client) SlowLog() + func (c Client) Sort(key string, sort *Sort) *StringSliceCmd + func (c Client) SortInterfaces(key string, sort *Sort) *SliceCmd + func (c Client) SortStore(key, store string, sort *Sort) *IntCmd + func (c Client) StrLen(key string) *IntCmd + func (c Client) String() string + func (c Client) Sync() + func (c Client) TTL(key string) *DurationCmd + func (c Client) Time() *TimeCmd + func (c Client) Touch(keys ...string) *IntCmd + func (c Client) Type(key string) *StatusCmd + func (c Client) Unlink(keys ...string) *IntCmd + func (c Client) Wait(numSlaves int, timeout time.Duration) *IntCmd + func (c Client) XAck(stream, group string, ids ...string) *IntCmd + func (c Client) XAdd(a *XAddArgs) *StringCmd + func (c Client) XClaim(a *XClaimArgs) *XMessageSliceCmd + func (c Client) XClaimJustID(a *XClaimArgs) *StringSliceCmd + func (c Client) XDel(stream string, ids ...string) *IntCmd + func (c Client) XGroupCreate(stream, group, start string) *StatusCmd + func (c Client) XGroupCreateMkStream(stream, group, start string) *StatusCmd + func (c Client) XGroupDelConsumer(stream, group, consumer string) *IntCmd + func (c Client) XGroupDestroy(stream, group string) *IntCmd + func (c Client) XGroupSetID(stream, group, start string) *StatusCmd + func (c Client) XInfoGroups(key string) *XInfoGroupsCmd + func (c Client) XLen(stream string) *IntCmd + func (c Client) XPending(stream, group string) *XPendingCmd + func (c Client) XPendingExt(a *XPendingExtArgs) *XPendingExtCmd + func (c Client) XRange(stream, start, stop string) *XMessageSliceCmd + func (c Client) XRangeN(stream, start, stop string, count int64) *XMessageSliceCmd + func (c Client) XRead(a *XReadArgs) *XStreamSliceCmd + func (c Client) XReadGroup(a *XReadGroupArgs) *XStreamSliceCmd + func (c Client) XReadStreams(streams ...string) *XStreamSliceCmd + func (c Client) XRevRange(stream, start, stop string) *XMessageSliceCmd + func (c Client) XRevRangeN(stream, start, stop string, count int64) *XMessageSliceCmd + func (c Client) XTrim(key string, maxLen int64) *IntCmd + func (c Client) XTrimApprox(key string, maxLen int64) *IntCmd + func (c Client) ZAdd(key string, members ...*Z) *IntCmd + func (c Client) ZAddCh(key string, members ...*Z) *IntCmd + func (c Client) ZAddNX(key string, members ...*Z) *IntCmd + func (c Client) ZAddNXCh(key string, members ...*Z) *IntCmd + func (c Client) ZAddXX(key string, members ...*Z) *IntCmd + func (c Client) ZAddXXCh(key string, members ...*Z) *IntCmd + func (c Client) ZCard(key string) *IntCmd + func (c Client) ZCount(key, min, max string) *IntCmd + func (c Client) ZIncr(key string, member *Z) *FloatCmd + func (c Client) ZIncrBy(key string, increment float64, member string) *FloatCmd + func (c Client) ZIncrNX(key string, member *Z) *FloatCmd + func (c Client) ZIncrXX(key string, member *Z) *FloatCmd + func (c Client) ZInterStore(destination string, store *ZStore) *IntCmd + func (c Client) ZLexCount(key, min, max string) *IntCmd + func (c Client) ZPopMax(key string, count ...int64) *ZSliceCmd + func (c Client) ZPopMin(key string, count ...int64) *ZSliceCmd + func (c Client) ZRange(key string, start, stop int64) *StringSliceCmd + func (c Client) ZRangeByLex(key string, opt *ZRangeBy) *StringSliceCmd + func (c Client) ZRangeByScore(key string, opt *ZRangeBy) *StringSliceCmd + func (c Client) ZRangeByScoreWithScores(key string, opt *ZRangeBy) *ZSliceCmd + func (c Client) ZRangeWithScores(key string, start, stop int64) *ZSliceCmd + func (c Client) ZRank(key, member string) *IntCmd + func (c Client) ZRem(key string, members ...interface{}) *IntCmd + func (c Client) ZRemRangeByLex(key, min, max string) *IntCmd + func (c Client) ZRemRangeByRank(key string, start, stop int64) *IntCmd + func (c Client) ZRemRangeByScore(key, min, max string) *IntCmd + func (c Client) ZRevRange(key string, start, stop int64) *StringSliceCmd + func (c Client) ZRevRangeByLex(key string, opt *ZRangeBy) *StringSliceCmd + func (c Client) ZRevRangeByScore(key string, opt *ZRangeBy) *StringSliceCmd + func (c Client) ZRevRangeByScoreWithScores(key string, opt *ZRangeBy) *ZSliceCmd + func (c Client) ZRevRangeWithScores(key string, start, stop int64) *ZSliceCmd + func (c Client) ZRevRank(key, member string) *IntCmd + func (c Client) ZScan(key string, cursor uint64, match string, count int64) *ScanCmd + func (c Client) ZScore(key, member string) *FloatCmd + func (c Client) ZUnionStore(dest string, store *ZStore) *IntCmd + func (hs *Client) AddHook(hook Hook) + type ClusterClient struct + func NewClusterClient(opt *ClusterOptions) *ClusterClient + func (c *ClusterClient) Close() error + func (c *ClusterClient) Context() context.Context + func (c *ClusterClient) DBSize() *IntCmd + func (c *ClusterClient) Do(args ...interface{}) *Cmd + func (c *ClusterClient) DoContext(ctx context.Context, args ...interface{}) *Cmd + func (c *ClusterClient) ForEachMaster(fn func(client *Client) error) error + func (c *ClusterClient) ForEachNode(fn func(client *Client) error) error + func (c *ClusterClient) ForEachSlave(fn func(client *Client) error) error + func (c *ClusterClient) Options() *ClusterOptions + func (c *ClusterClient) PSubscribe(channels ...string) *PubSub + func (c *ClusterClient) Pipeline() Pipeliner + func (c *ClusterClient) Pipelined(fn func(Pipeliner) error) ([]Cmder, error) + func (c *ClusterClient) PoolStats() *PoolStats + func (c *ClusterClient) Process(cmd Cmder) error + func (c *ClusterClient) ProcessContext(ctx context.Context, cmd Cmder) error + func (c *ClusterClient) ReloadState() error + func (c *ClusterClient) Subscribe(channels ...string) *PubSub + func (c *ClusterClient) TxPipeline() Pipeliner + func (c *ClusterClient) TxPipelined(fn func(Pipeliner) error) ([]Cmder, error) + func (c *ClusterClient) Watch(fn func(*Tx) error, keys ...string) error + func (c *ClusterClient) WatchContext(ctx context.Context, fn func(*Tx) error, keys ...string) error + func (c *ClusterClient) WithContext(ctx context.Context) *ClusterClient + func (c ClusterClient) Append(key, value string) *IntCmd + func (c ClusterClient) BLPop(timeout time.Duration, keys ...string) *StringSliceCmd + func (c ClusterClient) BRPop(timeout time.Duration, keys ...string) *StringSliceCmd + func (c ClusterClient) BRPopLPush(source, destination string, timeout time.Duration) *StringCmd + func (c ClusterClient) BZPopMax(timeout time.Duration, keys ...string) *ZWithKeyCmd + func (c ClusterClient) BZPopMin(timeout time.Duration, keys ...string) *ZWithKeyCmd + func (c ClusterClient) BgRewriteAOF() *StatusCmd + func (c ClusterClient) BgSave() *StatusCmd + func (c ClusterClient) BitCount(key string, bitCount *BitCount) *IntCmd + func (c ClusterClient) BitField(key string, args ...interface{}) *IntSliceCmd + func (c ClusterClient) BitOpAnd(destKey string, keys ...string) *IntCmd + func (c ClusterClient) BitOpNot(destKey string, key string) *IntCmd + func (c ClusterClient) BitOpOr(destKey string, keys ...string) *IntCmd + func (c ClusterClient) BitOpXor(destKey string, keys ...string) *IntCmd + func (c ClusterClient) BitPos(key string, bit int64, pos ...int64) *IntCmd + func (c ClusterClient) ClientGetName() *StringCmd + func (c ClusterClient) ClientID() *IntCmd + func (c ClusterClient) ClientKill(ipPort string) *StatusCmd + func (c ClusterClient) ClientKillByFilter(keys ...string) *IntCmd + func (c ClusterClient) ClientList() *StringCmd + func (c ClusterClient) ClientPause(dur time.Duration) *BoolCmd + func (c ClusterClient) ClientUnblock(id int64) *IntCmd + func (c ClusterClient) ClientUnblockWithError(id int64) *IntCmd + func (c ClusterClient) ClusterAddSlots(slots ...int) *StatusCmd + func (c ClusterClient) ClusterAddSlotsRange(min, max int) *StatusCmd + func (c ClusterClient) ClusterCountFailureReports(nodeID string) *IntCmd + func (c ClusterClient) ClusterCountKeysInSlot(slot int) *IntCmd + func (c ClusterClient) ClusterDelSlots(slots ...int) *StatusCmd + func (c ClusterClient) ClusterDelSlotsRange(min, max int) *StatusCmd + func (c ClusterClient) ClusterFailover() *StatusCmd + func (c ClusterClient) ClusterForget(nodeID string) *StatusCmd + func (c ClusterClient) ClusterGetKeysInSlot(slot int, count int) *StringSliceCmd + func (c ClusterClient) ClusterInfo() *StringCmd + func (c ClusterClient) ClusterKeySlot(key string) *IntCmd + func (c ClusterClient) ClusterMeet(host, port string) *StatusCmd + func (c ClusterClient) ClusterNodes() *StringCmd + func (c ClusterClient) ClusterReplicate(nodeID string) *StatusCmd + func (c ClusterClient) ClusterResetHard() *StatusCmd + func (c ClusterClient) ClusterResetSoft() *StatusCmd + func (c ClusterClient) ClusterSaveConfig() *StatusCmd + func (c ClusterClient) ClusterSlaves(nodeID string) *StringSliceCmd + func (c ClusterClient) ClusterSlots() *ClusterSlotsCmd + func (c ClusterClient) Command() *CommandsInfoCmd + func (c ClusterClient) ConfigGet(parameter string) *SliceCmd + func (c ClusterClient) ConfigResetStat() *StatusCmd + func (c ClusterClient) ConfigRewrite() *StatusCmd + func (c ClusterClient) ConfigSet(parameter, value string) *StatusCmd + func (c ClusterClient) DbSize() *IntCmd + func (c ClusterClient) DebugObject(key string) *StringCmd + func (c ClusterClient) Decr(key string) *IntCmd + func (c ClusterClient) DecrBy(key string, decrement int64) *IntCmd + func (c ClusterClient) Del(keys ...string) *IntCmd + func (c ClusterClient) Dump(key string) *StringCmd + func (c ClusterClient) Echo(message interface{}) *StringCmd + func (c ClusterClient) Eval(script string, keys []string, args ...interface{}) *Cmd + func (c ClusterClient) EvalSha(sha1 string, keys []string, args ...interface{}) *Cmd + func (c ClusterClient) Exists(keys ...string) *IntCmd + func (c ClusterClient) Expire(key string, expiration time.Duration) *BoolCmd + func (c ClusterClient) ExpireAt(key string, tm time.Time) *BoolCmd + func (c ClusterClient) FlushAll() *StatusCmd + func (c ClusterClient) FlushAllAsync() *StatusCmd + func (c ClusterClient) FlushDB() *StatusCmd + func (c ClusterClient) FlushDBAsync() *StatusCmd + func (c ClusterClient) GeoAdd(key string, geoLocation ...*GeoLocation) *IntCmd + func (c ClusterClient) GeoDist(key string, member1, member2, unit string) *FloatCmd + func (c ClusterClient) GeoHash(key string, members ...string) *StringSliceCmd + func (c ClusterClient) GeoPos(key string, members ...string) *GeoPosCmd + func (c ClusterClient) GeoRadius(key string, longitude, latitude float64, query *GeoRadiusQuery) *GeoLocationCmd + func (c ClusterClient) GeoRadiusByMember(key, member string, query *GeoRadiusQuery) *GeoLocationCmd + func (c ClusterClient) GeoRadiusByMemberStore(key, member string, query *GeoRadiusQuery) *IntCmd + func (c ClusterClient) GeoRadiusStore(key string, longitude, latitude float64, query *GeoRadiusQuery) *IntCmd + func (c ClusterClient) Get(key string) *StringCmd + func (c ClusterClient) GetBit(key string, offset int64) *IntCmd + func (c ClusterClient) GetRange(key string, start, end int64) *StringCmd + func (c ClusterClient) GetSet(key string, value interface{}) *StringCmd + func (c ClusterClient) HDel(key string, fields ...string) *IntCmd + func (c ClusterClient) HExists(key, field string) *BoolCmd + func (c ClusterClient) HGet(key, field string) *StringCmd + func (c ClusterClient) HGetAll(key string) *StringStringMapCmd + func (c ClusterClient) HIncrBy(key, field string, incr int64) *IntCmd + func (c ClusterClient) HIncrByFloat(key, field string, incr float64) *FloatCmd + func (c ClusterClient) HKeys(key string) *StringSliceCmd + func (c ClusterClient) HLen(key string) *IntCmd + func (c ClusterClient) HMGet(key string, fields ...string) *SliceCmd + func (c ClusterClient) HMSet(key string, values ...interface{}) *BoolCmd + func (c ClusterClient) HScan(key string, cursor uint64, match string, count int64) *ScanCmd + func (c ClusterClient) HSet(key string, values ...interface{}) *IntCmd + func (c ClusterClient) HSetNX(key, field string, value interface{}) *BoolCmd + func (c ClusterClient) HVals(key string) *StringSliceCmd + func (c ClusterClient) Incr(key string) *IntCmd + func (c ClusterClient) IncrBy(key string, value int64) *IntCmd + func (c ClusterClient) IncrByFloat(key string, value float64) *FloatCmd + func (c ClusterClient) Info(section ...string) *StringCmd + func (c ClusterClient) Keys(pattern string) *StringSliceCmd + func (c ClusterClient) LIndex(key string, index int64) *StringCmd + func (c ClusterClient) LInsert(key, op string, pivot, value interface{}) *IntCmd + func (c ClusterClient) LInsertAfter(key string, pivot, value interface{}) *IntCmd + func (c ClusterClient) LInsertBefore(key string, pivot, value interface{}) *IntCmd + func (c ClusterClient) LLen(key string) *IntCmd + func (c ClusterClient) LPop(key string) *StringCmd + func (c ClusterClient) LPush(key string, values ...interface{}) *IntCmd + func (c ClusterClient) LPushX(key string, values ...interface{}) *IntCmd + func (c ClusterClient) LRange(key string, start, stop int64) *StringSliceCmd + func (c ClusterClient) LRem(key string, count int64, value interface{}) *IntCmd + func (c ClusterClient) LSet(key string, index int64, value interface{}) *StatusCmd + func (c ClusterClient) LTrim(key string, start, stop int64) *StatusCmd + func (c ClusterClient) LastSave() *IntCmd + func (c ClusterClient) MGet(keys ...string) *SliceCmd + func (c ClusterClient) MSet(values ...interface{}) *StatusCmd + func (c ClusterClient) MSetNX(values ...interface{}) *BoolCmd + func (c ClusterClient) MemoryUsage(key string, samples ...int) *IntCmd + func (c ClusterClient) Migrate(host, port, key string, db int, timeout time.Duration) *StatusCmd + func (c ClusterClient) Move(key string, db int) *BoolCmd + func (c ClusterClient) ObjectEncoding(key string) *StringCmd + func (c ClusterClient) ObjectIdleTime(key string) *DurationCmd + func (c ClusterClient) ObjectRefCount(key string) *IntCmd + func (c ClusterClient) PExpire(key string, expiration time.Duration) *BoolCmd + func (c ClusterClient) PExpireAt(key string, tm time.Time) *BoolCmd + func (c ClusterClient) PFAdd(key string, els ...interface{}) *IntCmd + func (c ClusterClient) PFCount(keys ...string) *IntCmd + func (c ClusterClient) PFMerge(dest string, keys ...string) *StatusCmd + func (c ClusterClient) PTTL(key string) *DurationCmd + func (c ClusterClient) Persist(key string) *BoolCmd + func (c ClusterClient) Ping() *StatusCmd + func (c ClusterClient) PubSubChannels(pattern string) *StringSliceCmd + func (c ClusterClient) PubSubNumPat() *IntCmd + func (c ClusterClient) PubSubNumSub(channels ...string) *StringIntMapCmd + func (c ClusterClient) Publish(channel string, message interface{}) *IntCmd + func (c ClusterClient) Quit() *StatusCmd + func (c ClusterClient) RPop(key string) *StringCmd + func (c ClusterClient) RPopLPush(source, destination string) *StringCmd + func (c ClusterClient) RPush(key string, values ...interface{}) *IntCmd + func (c ClusterClient) RPushX(key string, values ...interface{}) *IntCmd + func (c ClusterClient) RandomKey() *StringCmd + func (c ClusterClient) ReadOnly() *StatusCmd + func (c ClusterClient) ReadWrite() *StatusCmd + func (c ClusterClient) Rename(key, newkey string) *StatusCmd + func (c ClusterClient) RenameNX(key, newkey string) *BoolCmd + func (c ClusterClient) Restore(key string, ttl time.Duration, value string) *StatusCmd + func (c ClusterClient) RestoreReplace(key string, ttl time.Duration, value string) *StatusCmd + func (c ClusterClient) SAdd(key string, members ...interface{}) *IntCmd + func (c ClusterClient) SCard(key string) *IntCmd + func (c ClusterClient) SDiff(keys ...string) *StringSliceCmd + func (c ClusterClient) SDiffStore(destination string, keys ...string) *IntCmd + func (c ClusterClient) SInter(keys ...string) *StringSliceCmd + func (c ClusterClient) SInterStore(destination string, keys ...string) *IntCmd + func (c ClusterClient) SIsMember(key string, member interface{}) *BoolCmd + func (c ClusterClient) SMembers(key string) *StringSliceCmd + func (c ClusterClient) SMembersMap(key string) *StringStructMapCmd + func (c ClusterClient) SMove(source, destination string, member interface{}) *BoolCmd + func (c ClusterClient) SPop(key string) *StringCmd + func (c ClusterClient) SPopN(key string, count int64) *StringSliceCmd + func (c ClusterClient) SRandMember(key string) *StringCmd + func (c ClusterClient) SRandMemberN(key string, count int64) *StringSliceCmd + func (c ClusterClient) SRem(key string, members ...interface{}) *IntCmd + func (c ClusterClient) SScan(key string, cursor uint64, match string, count int64) *ScanCmd + func (c ClusterClient) SUnion(keys ...string) *StringSliceCmd + func (c ClusterClient) SUnionStore(destination string, keys ...string) *IntCmd + func (c ClusterClient) Save() *StatusCmd + func (c ClusterClient) Scan(cursor uint64, match string, count int64) *ScanCmd + func (c ClusterClient) ScriptExists(hashes ...string) *BoolSliceCmd + func (c ClusterClient) ScriptFlush() *StatusCmd + func (c ClusterClient) ScriptKill() *StatusCmd + func (c ClusterClient) ScriptLoad(script string) *StringCmd + func (c ClusterClient) Set(key string, value interface{}, expiration time.Duration) *StatusCmd + func (c ClusterClient) SetBit(key string, offset int64, value int) *IntCmd + func (c ClusterClient) SetNX(key string, value interface{}, expiration time.Duration) *BoolCmd + func (c ClusterClient) SetRange(key string, offset int64, value string) *IntCmd + func (c ClusterClient) SetXX(key string, value interface{}, expiration time.Duration) *BoolCmd + func (c ClusterClient) Shutdown() *StatusCmd + func (c ClusterClient) ShutdownNoSave() *StatusCmd + func (c ClusterClient) ShutdownSave() *StatusCmd + func (c ClusterClient) SlaveOf(host, port string) *StatusCmd + func (c ClusterClient) SlowLog() + func (c ClusterClient) Sort(key string, sort *Sort) *StringSliceCmd + func (c ClusterClient) SortInterfaces(key string, sort *Sort) *SliceCmd + func (c ClusterClient) SortStore(key, store string, sort *Sort) *IntCmd + func (c ClusterClient) StrLen(key string) *IntCmd + func (c ClusterClient) Sync() + func (c ClusterClient) TTL(key string) *DurationCmd + func (c ClusterClient) Time() *TimeCmd + func (c ClusterClient) Touch(keys ...string) *IntCmd + func (c ClusterClient) Type(key string) *StatusCmd + func (c ClusterClient) Unlink(keys ...string) *IntCmd + func (c ClusterClient) Wait(numSlaves int, timeout time.Duration) *IntCmd + func (c ClusterClient) XAck(stream, group string, ids ...string) *IntCmd + func (c ClusterClient) XAdd(a *XAddArgs) *StringCmd + func (c ClusterClient) XClaim(a *XClaimArgs) *XMessageSliceCmd + func (c ClusterClient) XClaimJustID(a *XClaimArgs) *StringSliceCmd + func (c ClusterClient) XDel(stream string, ids ...string) *IntCmd + func (c ClusterClient) XGroupCreate(stream, group, start string) *StatusCmd + func (c ClusterClient) XGroupCreateMkStream(stream, group, start string) *StatusCmd + func (c ClusterClient) XGroupDelConsumer(stream, group, consumer string) *IntCmd + func (c ClusterClient) XGroupDestroy(stream, group string) *IntCmd + func (c ClusterClient) XGroupSetID(stream, group, start string) *StatusCmd + func (c ClusterClient) XInfoGroups(key string) *XInfoGroupsCmd + func (c ClusterClient) XLen(stream string) *IntCmd + func (c ClusterClient) XPending(stream, group string) *XPendingCmd + func (c ClusterClient) XPendingExt(a *XPendingExtArgs) *XPendingExtCmd + func (c ClusterClient) XRange(stream, start, stop string) *XMessageSliceCmd + func (c ClusterClient) XRangeN(stream, start, stop string, count int64) *XMessageSliceCmd + func (c ClusterClient) XRead(a *XReadArgs) *XStreamSliceCmd + func (c ClusterClient) XReadGroup(a *XReadGroupArgs) *XStreamSliceCmd + func (c ClusterClient) XReadStreams(streams ...string) *XStreamSliceCmd + func (c ClusterClient) XRevRange(stream, start, stop string) *XMessageSliceCmd + func (c ClusterClient) XRevRangeN(stream, start, stop string, count int64) *XMessageSliceCmd + func (c ClusterClient) XTrim(key string, maxLen int64) *IntCmd + func (c ClusterClient) XTrimApprox(key string, maxLen int64) *IntCmd + func (c ClusterClient) ZAdd(key string, members ...*Z) *IntCmd + func (c ClusterClient) ZAddCh(key string, members ...*Z) *IntCmd + func (c ClusterClient) ZAddNX(key string, members ...*Z) *IntCmd + func (c ClusterClient) ZAddNXCh(key string, members ...*Z) *IntCmd + func (c ClusterClient) ZAddXX(key string, members ...*Z) *IntCmd + func (c ClusterClient) ZAddXXCh(key string, members ...*Z) *IntCmd + func (c ClusterClient) ZCard(key string) *IntCmd + func (c ClusterClient) ZCount(key, min, max string) *IntCmd + func (c ClusterClient) ZIncr(key string, member *Z) *FloatCmd + func (c ClusterClient) ZIncrBy(key string, increment float64, member string) *FloatCmd + func (c ClusterClient) ZIncrNX(key string, member *Z) *FloatCmd + func (c ClusterClient) ZIncrXX(key string, member *Z) *FloatCmd + func (c ClusterClient) ZInterStore(destination string, store *ZStore) *IntCmd + func (c ClusterClient) ZLexCount(key, min, max string) *IntCmd + func (c ClusterClient) ZPopMax(key string, count ...int64) *ZSliceCmd + func (c ClusterClient) ZPopMin(key string, count ...int64) *ZSliceCmd + func (c ClusterClient) ZRange(key string, start, stop int64) *StringSliceCmd + func (c ClusterClient) ZRangeByLex(key string, opt *ZRangeBy) *StringSliceCmd + func (c ClusterClient) ZRangeByScore(key string, opt *ZRangeBy) *StringSliceCmd + func (c ClusterClient) ZRangeByScoreWithScores(key string, opt *ZRangeBy) *ZSliceCmd + func (c ClusterClient) ZRangeWithScores(key string, start, stop int64) *ZSliceCmd + func (c ClusterClient) ZRank(key, member string) *IntCmd + func (c ClusterClient) ZRem(key string, members ...interface{}) *IntCmd + func (c ClusterClient) ZRemRangeByLex(key, min, max string) *IntCmd + func (c ClusterClient) ZRemRangeByRank(key string, start, stop int64) *IntCmd + func (c ClusterClient) ZRemRangeByScore(key, min, max string) *IntCmd + func (c ClusterClient) ZRevRange(key string, start, stop int64) *StringSliceCmd + func (c ClusterClient) ZRevRangeByLex(key string, opt *ZRangeBy) *StringSliceCmd + func (c ClusterClient) ZRevRangeByScore(key string, opt *ZRangeBy) *StringSliceCmd + func (c ClusterClient) ZRevRangeByScoreWithScores(key string, opt *ZRangeBy) *ZSliceCmd + func (c ClusterClient) ZRevRangeWithScores(key string, start, stop int64) *ZSliceCmd + func (c ClusterClient) ZRevRank(key, member string) *IntCmd + func (c ClusterClient) ZScan(key string, cursor uint64, match string, count int64) *ScanCmd + func (c ClusterClient) ZScore(key, member string) *FloatCmd + func (c ClusterClient) ZUnionStore(dest string, store *ZStore) *IntCmd + func (hs *ClusterClient) AddHook(hook Hook) + type ClusterNode struct + Addr string + ID string + type ClusterOptions struct + Addrs []string + ClusterSlots func() ([]ClusterSlot, error) + DialTimeout time.Duration + Dialer func(ctx context.Context, network, addr string) (net.Conn, error) + IdleCheckFrequency time.Duration + IdleTimeout time.Duration + MaxConnAge time.Duration + MaxRedirects int + MaxRetries int + MaxRetryBackoff time.Duration + MinIdleConns int + MinRetryBackoff time.Duration + NewClient func(opt *Options) *Client + OnConnect func(*Conn) error + OnNewNode func(*Client) + Password string + PoolSize int + PoolTimeout time.Duration + ReadOnly bool + ReadTimeout time.Duration + RouteByLatency bool + RouteRandomly bool + TLSConfig *tls.Config + Username string + WriteTimeout time.Duration + type ClusterSlot struct + End int + Nodes []ClusterNode + Start int + type ClusterSlotsCmd struct + func NewClusterSlotsCmd(args ...interface{}) *ClusterSlotsCmd + func NewClusterSlotsCmdResult(val []ClusterSlot, err error) *ClusterSlotsCmd + func (cmd *ClusterSlotsCmd) Args() []interface{} + func (cmd *ClusterSlotsCmd) Err() error + func (cmd *ClusterSlotsCmd) Name() string + func (cmd *ClusterSlotsCmd) Result() ([]ClusterSlot, error) + func (cmd *ClusterSlotsCmd) SetErr(e error) + func (cmd *ClusterSlotsCmd) String() string + func (cmd *ClusterSlotsCmd) Val() []ClusterSlot + type Cmd struct + func NewCmd(args ...interface{}) *Cmd + func NewCmdResult(val interface{}, err error) *Cmd + func (cmd *Cmd) Args() []interface{} + func (cmd *Cmd) Bool() (bool, error) + func (cmd *Cmd) Err() error + func (cmd *Cmd) Float32() (float32, error) + func (cmd *Cmd) Float64() (float64, error) + func (cmd *Cmd) Int() (int, error) + func (cmd *Cmd) Int64() (int64, error) + func (cmd *Cmd) Name() string + func (cmd *Cmd) Result() (interface{}, error) + func (cmd *Cmd) SetErr(e error) + func (cmd *Cmd) String() string + func (cmd *Cmd) Text() (string, error) + func (cmd *Cmd) Uint64() (uint64, error) + func (cmd *Cmd) Val() interface{} + type Cmdable interface + Append func(key, value string) *IntCmd + BLPop func(timeout time.Duration, keys ...string) *StringSliceCmd + BRPop func(timeout time.Duration, keys ...string) *StringSliceCmd + BRPopLPush func(source, destination string, timeout time.Duration) *StringCmd + BZPopMax func(timeout time.Duration, keys ...string) *ZWithKeyCmd + BZPopMin func(timeout time.Duration, keys ...string) *ZWithKeyCmd + BgRewriteAOF func() *StatusCmd + BgSave func() *StatusCmd + BitCount func(key string, bitCount *BitCount) *IntCmd + BitField func(key string, args ...interface{}) *IntSliceCmd + BitOpAnd func(destKey string, keys ...string) *IntCmd + BitOpNot func(destKey string, key string) *IntCmd + BitOpOr func(destKey string, keys ...string) *IntCmd + BitOpXor func(destKey string, keys ...string) *IntCmd + BitPos func(key string, bit int64, pos ...int64) *IntCmd + ClientGetName func() *StringCmd + ClientID func() *IntCmd + ClientKill func(ipPort string) *StatusCmd + ClientKillByFilter func(keys ...string) *IntCmd + ClientList func() *StringCmd + ClientPause func(dur time.Duration) *BoolCmd + ClusterAddSlots func(slots ...int) *StatusCmd + ClusterAddSlotsRange func(min, max int) *StatusCmd + ClusterCountFailureReports func(nodeID string) *IntCmd + ClusterCountKeysInSlot func(slot int) *IntCmd + ClusterDelSlots func(slots ...int) *StatusCmd + ClusterDelSlotsRange func(min, max int) *StatusCmd + ClusterFailover func() *StatusCmd + ClusterForget func(nodeID string) *StatusCmd + ClusterGetKeysInSlot func(slot int, count int) *StringSliceCmd + ClusterInfo func() *StringCmd + ClusterKeySlot func(key string) *IntCmd + ClusterMeet func(host, port string) *StatusCmd + ClusterNodes func() *StringCmd + ClusterReplicate func(nodeID string) *StatusCmd + ClusterResetHard func() *StatusCmd + ClusterResetSoft func() *StatusCmd + ClusterSaveConfig func() *StatusCmd + ClusterSlaves func(nodeID string) *StringSliceCmd + ClusterSlots func() *ClusterSlotsCmd + Command func() *CommandsInfoCmd + ConfigGet func(parameter string) *SliceCmd + ConfigResetStat func() *StatusCmd + ConfigRewrite func() *StatusCmd + ConfigSet func(parameter, value string) *StatusCmd + DBSize func() *IntCmd + DebugObject func(key string) *StringCmd + Decr func(key string) *IntCmd + DecrBy func(key string, decrement int64) *IntCmd + Del func(keys ...string) *IntCmd + Dump func(key string) *StringCmd + Echo func(message interface{}) *StringCmd + Eval func(script string, keys []string, args ...interface{}) *Cmd + EvalSha func(sha1 string, keys []string, args ...interface{}) *Cmd + Exists func(keys ...string) *IntCmd + Expire func(key string, expiration time.Duration) *BoolCmd + ExpireAt func(key string, tm time.Time) *BoolCmd + FlushAll func() *StatusCmd + FlushAllAsync func() *StatusCmd + FlushDB func() *StatusCmd + FlushDBAsync func() *StatusCmd + GeoAdd func(key string, geoLocation ...*GeoLocation) *IntCmd + GeoDist func(key string, member1, member2, unit string) *FloatCmd + GeoHash func(key string, members ...string) *StringSliceCmd + GeoPos func(key string, members ...string) *GeoPosCmd + GeoRadius func(key string, longitude, latitude float64, query *GeoRadiusQuery) *GeoLocationCmd + GeoRadiusByMember func(key, member string, query *GeoRadiusQuery) *GeoLocationCmd + GeoRadiusByMemberStore func(key, member string, query *GeoRadiusQuery) *IntCmd + GeoRadiusStore func(key string, longitude, latitude float64, query *GeoRadiusQuery) *IntCmd + Get func(key string) *StringCmd + GetBit func(key string, offset int64) *IntCmd + GetRange func(key string, start, end int64) *StringCmd + GetSet func(key string, value interface{}) *StringCmd + HDel func(key string, fields ...string) *IntCmd + HExists func(key, field string) *BoolCmd + HGet func(key, field string) *StringCmd + HGetAll func(key string) *StringStringMapCmd + HIncrBy func(key, field string, incr int64) *IntCmd + HIncrByFloat func(key, field string, incr float64) *FloatCmd + HKeys func(key string) *StringSliceCmd + HLen func(key string) *IntCmd + HMGet func(key string, fields ...string) *SliceCmd + HMSet func(key string, values ...interface{}) *BoolCmd + HScan func(key string, cursor uint64, match string, count int64) *ScanCmd + HSet func(key string, values ...interface{}) *IntCmd + HSetNX func(key, field string, value interface{}) *BoolCmd + HVals func(key string) *StringSliceCmd + Incr func(key string) *IntCmd + IncrBy func(key string, value int64) *IntCmd + IncrByFloat func(key string, value float64) *FloatCmd + Info func(section ...string) *StringCmd + Keys func(pattern string) *StringSliceCmd + LIndex func(key string, index int64) *StringCmd + LInsert func(key, op string, pivot, value interface{}) *IntCmd + LInsertAfter func(key string, pivot, value interface{}) *IntCmd + LInsertBefore func(key string, pivot, value interface{}) *IntCmd + LLen func(key string) *IntCmd + LPop func(key string) *StringCmd + LPush func(key string, values ...interface{}) *IntCmd + LPushX func(key string, values ...interface{}) *IntCmd + LRange func(key string, start, stop int64) *StringSliceCmd + LRem func(key string, count int64, value interface{}) *IntCmd + LSet func(key string, index int64, value interface{}) *StatusCmd + LTrim func(key string, start, stop int64) *StatusCmd + LastSave func() *IntCmd + MGet func(keys ...string) *SliceCmd + MSet func(values ...interface{}) *StatusCmd + MSetNX func(values ...interface{}) *BoolCmd + MemoryUsage func(key string, samples ...int) *IntCmd + Migrate func(host, port, key string, db int, timeout time.Duration) *StatusCmd + Move func(key string, db int) *BoolCmd + ObjectEncoding func(key string) *StringCmd + ObjectIdleTime func(key string) *DurationCmd + ObjectRefCount func(key string) *IntCmd + PExpire func(key string, expiration time.Duration) *BoolCmd + PExpireAt func(key string, tm time.Time) *BoolCmd + PFAdd func(key string, els ...interface{}) *IntCmd + PFCount func(keys ...string) *IntCmd + PFMerge func(dest string, keys ...string) *StatusCmd + PTTL func(key string) *DurationCmd + Persist func(key string) *BoolCmd + Ping func() *StatusCmd + Pipeline func() Pipeliner + Pipelined func(fn func(Pipeliner) error) ([]Cmder, error) + PubSubChannels func(pattern string) *StringSliceCmd + PubSubNumPat func() *IntCmd + PubSubNumSub func(channels ...string) *StringIntMapCmd + Publish func(channel string, message interface{}) *IntCmd + Quit func() *StatusCmd + RPop func(key string) *StringCmd + RPopLPush func(source, destination string) *StringCmd + RPush func(key string, values ...interface{}) *IntCmd + RPushX func(key string, values ...interface{}) *IntCmd + RandomKey func() *StringCmd + ReadOnly func() *StatusCmd + ReadWrite func() *StatusCmd + Rename func(key, newkey string) *StatusCmd + RenameNX func(key, newkey string) *BoolCmd + Restore func(key string, ttl time.Duration, value string) *StatusCmd + RestoreReplace func(key string, ttl time.Duration, value string) *StatusCmd + SAdd func(key string, members ...interface{}) *IntCmd + SCard func(key string) *IntCmd + SDiff func(keys ...string) *StringSliceCmd + SDiffStore func(destination string, keys ...string) *IntCmd + SInter func(keys ...string) *StringSliceCmd + SInterStore func(destination string, keys ...string) *IntCmd + SIsMember func(key string, member interface{}) *BoolCmd + SMembers func(key string) *StringSliceCmd + SMembersMap func(key string) *StringStructMapCmd + SMove func(source, destination string, member interface{}) *BoolCmd + SPop func(key string) *StringCmd + SPopN func(key string, count int64) *StringSliceCmd + SRandMember func(key string) *StringCmd + SRandMemberN func(key string, count int64) *StringSliceCmd + SRem func(key string, members ...interface{}) *IntCmd + SScan func(key string, cursor uint64, match string, count int64) *ScanCmd + SUnion func(keys ...string) *StringSliceCmd + SUnionStore func(destination string, keys ...string) *IntCmd + Save func() *StatusCmd + Scan func(cursor uint64, match string, count int64) *ScanCmd + ScriptExists func(hashes ...string) *BoolSliceCmd + ScriptFlush func() *StatusCmd + ScriptKill func() *StatusCmd + ScriptLoad func(script string) *StringCmd + Set func(key string, value interface{}, expiration time.Duration) *StatusCmd + SetBit func(key string, offset int64, value int) *IntCmd + SetNX func(key string, value interface{}, expiration time.Duration) *BoolCmd + SetRange func(key string, offset int64, value string) *IntCmd + SetXX func(key string, value interface{}, expiration time.Duration) *BoolCmd + Shutdown func() *StatusCmd + ShutdownNoSave func() *StatusCmd + ShutdownSave func() *StatusCmd + SlaveOf func(host, port string) *StatusCmd + Sort func(key string, sort *Sort) *StringSliceCmd + SortInterfaces func(key string, sort *Sort) *SliceCmd + SortStore func(key, store string, sort *Sort) *IntCmd + StrLen func(key string) *IntCmd + TTL func(key string) *DurationCmd + Time func() *TimeCmd + Touch func(keys ...string) *IntCmd + TxPipeline func() Pipeliner + TxPipelined func(fn func(Pipeliner) error) ([]Cmder, error) + Type func(key string) *StatusCmd + Unlink func(keys ...string) *IntCmd + XAck func(stream, group string, ids ...string) *IntCmd + XAdd func(a *XAddArgs) *StringCmd + XClaim func(a *XClaimArgs) *XMessageSliceCmd + XClaimJustID func(a *XClaimArgs) *StringSliceCmd + XDel func(stream string, ids ...string) *IntCmd + XGroupCreate func(stream, group, start string) *StatusCmd + XGroupCreateMkStream func(stream, group, start string) *StatusCmd + XGroupDelConsumer func(stream, group, consumer string) *IntCmd + XGroupDestroy func(stream, group string) *IntCmd + XGroupSetID func(stream, group, start string) *StatusCmd + XInfoGroups func(key string) *XInfoGroupsCmd + XLen func(stream string) *IntCmd + XPending func(stream, group string) *XPendingCmd + XPendingExt func(a *XPendingExtArgs) *XPendingExtCmd + XRange func(stream, start, stop string) *XMessageSliceCmd + XRangeN func(stream, start, stop string, count int64) *XMessageSliceCmd + XRead func(a *XReadArgs) *XStreamSliceCmd + XReadGroup func(a *XReadGroupArgs) *XStreamSliceCmd + XReadStreams func(streams ...string) *XStreamSliceCmd + XRevRange func(stream string, start, stop string) *XMessageSliceCmd + XRevRangeN func(stream string, start, stop string, count int64) *XMessageSliceCmd + XTrim func(key string, maxLen int64) *IntCmd + XTrimApprox func(key string, maxLen int64) *IntCmd + ZAdd func(key string, members ...*Z) *IntCmd + ZAddCh func(key string, members ...*Z) *IntCmd + ZAddNX func(key string, members ...*Z) *IntCmd + ZAddNXCh func(key string, members ...*Z) *IntCmd + ZAddXX func(key string, members ...*Z) *IntCmd + ZAddXXCh func(key string, members ...*Z) *IntCmd + ZCard func(key string) *IntCmd + ZCount func(key, min, max string) *IntCmd + ZIncr func(key string, member *Z) *FloatCmd + ZIncrBy func(key string, increment float64, member string) *FloatCmd + ZIncrNX func(key string, member *Z) *FloatCmd + ZIncrXX func(key string, member *Z) *FloatCmd + ZInterStore func(destination string, store *ZStore) *IntCmd + ZLexCount func(key, min, max string) *IntCmd + ZPopMax func(key string, count ...int64) *ZSliceCmd + ZPopMin func(key string, count ...int64) *ZSliceCmd + ZRange func(key string, start, stop int64) *StringSliceCmd + ZRangeByLex func(key string, opt *ZRangeBy) *StringSliceCmd + ZRangeByScore func(key string, opt *ZRangeBy) *StringSliceCmd + ZRangeByScoreWithScores func(key string, opt *ZRangeBy) *ZSliceCmd + ZRangeWithScores func(key string, start, stop int64) *ZSliceCmd + ZRank func(key, member string) *IntCmd + ZRem func(key string, members ...interface{}) *IntCmd + ZRemRangeByLex func(key, min, max string) *IntCmd + ZRemRangeByRank func(key string, start, stop int64) *IntCmd + ZRemRangeByScore func(key, min, max string) *IntCmd + ZRevRange func(key string, start, stop int64) *StringSliceCmd + ZRevRangeByLex func(key string, opt *ZRangeBy) *StringSliceCmd + ZRevRangeByScore func(key string, opt *ZRangeBy) *StringSliceCmd + ZRevRangeByScoreWithScores func(key string, opt *ZRangeBy) *ZSliceCmd + ZRevRangeWithScores func(key string, start, stop int64) *ZSliceCmd + ZRevRank func(key, member string) *IntCmd + ZScan func(key string, cursor uint64, match string, count int64) *ScanCmd + ZScore func(key, member string) *FloatCmd + ZUnionStore func(dest string, store *ZStore) *IntCmd + type Cmder interface + Args func() []interface{} + Err func() error + Name func() string + SetErr func(error) + String func() string + type CommandInfo struct + Arity int8 + FirstKeyPos int8 + Flags []string + LastKeyPos int8 + Name string + ReadOnly bool + StepCount int8 + type CommandsInfoCmd struct + func NewCommandsInfoCmd(args ...interface{}) *CommandsInfoCmd + func NewCommandsInfoCmdResult(val map[string]*CommandInfo, err error) *CommandsInfoCmd + func (cmd *CommandsInfoCmd) Args() []interface{} + func (cmd *CommandsInfoCmd) Err() error + func (cmd *CommandsInfoCmd) Name() string + func (cmd *CommandsInfoCmd) Result() (map[string]*CommandInfo, error) + func (cmd *CommandsInfoCmd) SetErr(e error) + func (cmd *CommandsInfoCmd) String() string + func (cmd *CommandsInfoCmd) Val() map[string]*CommandInfo + type Conn struct + func (c *Conn) Pipeline() Pipeliner + func (c *Conn) Pipelined(fn func(Pipeliner) error) ([]Cmder, error) + func (c *Conn) Process(cmd Cmder) error + func (c *Conn) ProcessContext(ctx context.Context, cmd Cmder) error + func (c *Conn) TxPipeline() Pipeliner + func (c *Conn) TxPipelined(fn func(Pipeliner) error) ([]Cmder, error) + type DurationCmd struct + func NewDurationCmd(precision time.Duration, args ...interface{}) *DurationCmd + func NewDurationResult(val time.Duration, err error) *DurationCmd + func (cmd *DurationCmd) Args() []interface{} + func (cmd *DurationCmd) Err() error + func (cmd *DurationCmd) Name() string + func (cmd *DurationCmd) Result() (time.Duration, error) + func (cmd *DurationCmd) SetErr(e error) + func (cmd *DurationCmd) String() string + func (cmd *DurationCmd) Val() time.Duration + type Error interface + RedisError func() + type FailoverOptions struct + DB int + DialTimeout time.Duration + Dialer func(ctx context.Context, network, addr string) (net.Conn, error) + IdleCheckFrequency time.Duration + IdleTimeout time.Duration + MasterName string + MaxConnAge time.Duration + MaxRetries int + MaxRetryBackoff time.Duration + MinIdleConns int + MinRetryBackoff time.Duration + OnConnect func(*Conn) error + Password string + PoolSize int + PoolTimeout time.Duration + ReadTimeout time.Duration + SentinelAddrs []string + SentinelPassword string + SentinelUsername string + TLSConfig *tls.Config + Username string + WriteTimeout time.Duration + type FloatCmd struct + func NewFloatCmd(args ...interface{}) *FloatCmd + func NewFloatResult(val float64, err error) *FloatCmd + func (cmd *FloatCmd) Args() []interface{} + func (cmd *FloatCmd) Err() error + func (cmd *FloatCmd) Name() string + func (cmd *FloatCmd) Result() (float64, error) + func (cmd *FloatCmd) SetErr(e error) + func (cmd *FloatCmd) String() string + func (cmd *FloatCmd) Val() float64 + type GeoLocation struct + Dist float64 + GeoHash int64 + Latitude float64 + Longitude float64 + Name string + type GeoLocationCmd struct + func NewGeoLocationCmd(q *GeoRadiusQuery, args ...interface{}) *GeoLocationCmd + func NewGeoLocationCmdResult(val []GeoLocation, err error) *GeoLocationCmd + func (cmd *GeoLocationCmd) Args() []interface{} + func (cmd *GeoLocationCmd) Err() error + func (cmd *GeoLocationCmd) Name() string + func (cmd *GeoLocationCmd) Result() ([]GeoLocation, error) + func (cmd *GeoLocationCmd) SetErr(e error) + func (cmd *GeoLocationCmd) String() string + func (cmd *GeoLocationCmd) Val() []GeoLocation + type GeoPos struct + Latitude float64 + Longitude float64 + type GeoPosCmd struct + func NewGeoPosCmd(args ...interface{}) *GeoPosCmd + func NewGeoPosCmdResult(val []*GeoPos, err error) *GeoPosCmd + func (cmd *GeoPosCmd) Args() []interface{} + func (cmd *GeoPosCmd) Err() error + func (cmd *GeoPosCmd) Name() string + func (cmd *GeoPosCmd) Result() ([]*GeoPos, error) + func (cmd *GeoPosCmd) SetErr(e error) + func (cmd *GeoPosCmd) String() string + func (cmd *GeoPosCmd) Val() []*GeoPos + type GeoRadiusQuery struct + Count int + Radius float64 + Sort string + Store string + StoreDist string + Unit string + WithCoord bool + WithDist bool + WithGeoHash bool + type Hash consistenthash.Hash + type Hook interface + AfterProcess func(ctx context.Context, cmd Cmder) error + AfterProcessPipeline func(ctx context.Context, cmds []Cmder) error + BeforeProcess func(ctx context.Context, cmd Cmder) (context.Context, error) + BeforeProcessPipeline func(ctx context.Context, cmds []Cmder) (context.Context, error) + type IntCmd struct + func NewIntCmd(args ...interface{}) *IntCmd + func NewIntResult(val int64, err error) *IntCmd + func (cmd *IntCmd) Args() []interface{} + func (cmd *IntCmd) Err() error + func (cmd *IntCmd) Name() string + func (cmd *IntCmd) Result() (int64, error) + func (cmd *IntCmd) SetErr(e error) + func (cmd *IntCmd) String() string + func (cmd *IntCmd) Uint64() (uint64, error) + func (cmd *IntCmd) Val() int64 + type IntSliceCmd struct + func NewIntSliceCmd(args ...interface{}) *IntSliceCmd + func (cmd *IntSliceCmd) Args() []interface{} + func (cmd *IntSliceCmd) Err() error + func (cmd *IntSliceCmd) Name() string + func (cmd *IntSliceCmd) Result() ([]int64, error) + func (cmd *IntSliceCmd) SetErr(e error) + func (cmd *IntSliceCmd) String() string + func (cmd *IntSliceCmd) Val() []int64 + type Limiter interface + Allow func() error + ReportResult func(result error) + type Message struct + Channel string + Pattern string + Payload string + func (m *Message) String() string + type Options struct + Addr string + DB int + DialTimeout time.Duration + Dialer func(ctx context.Context, network, addr string) (net.Conn, error) + IdleCheckFrequency time.Duration + IdleTimeout time.Duration + Limiter Limiter + MaxConnAge time.Duration + MaxRetries int + MaxRetryBackoff time.Duration + MinIdleConns int + MinRetryBackoff time.Duration + Network string + OnConnect func(*Conn) error + Password string + PoolSize int + PoolTimeout time.Duration + ReadTimeout time.Duration + TLSConfig *tls.Config + Username string + WriteTimeout time.Duration + func ParseURL(redisURL string) (*Options, error) + type Pipeline struct + func (c *Pipeline) Close() error + func (c *Pipeline) Discard() error + func (c *Pipeline) Do(args ...interface{}) *Cmd + func (c *Pipeline) Exec() ([]Cmder, error) + func (c *Pipeline) ExecContext(ctx context.Context) ([]Cmder, error) + func (c *Pipeline) Pipeline() Pipeliner + func (c *Pipeline) Pipelined(fn func(Pipeliner) error) ([]Cmder, error) + func (c *Pipeline) Process(cmd Cmder) error + func (c *Pipeline) TxPipeline() Pipeliner + func (c *Pipeline) TxPipelined(fn func(Pipeliner) error) ([]Cmder, error) + func (c Pipeline) Append(key, value string) *IntCmd + func (c Pipeline) Auth(password string) *StatusCmd + func (c Pipeline) AuthACL(username, password string) *StatusCmd + func (c Pipeline) BLPop(timeout time.Duration, keys ...string) *StringSliceCmd + func (c Pipeline) BRPop(timeout time.Duration, keys ...string) *StringSliceCmd + func (c Pipeline) BRPopLPush(source, destination string, timeout time.Duration) *StringCmd + func (c Pipeline) BZPopMax(timeout time.Duration, keys ...string) *ZWithKeyCmd + func (c Pipeline) BZPopMin(timeout time.Duration, keys ...string) *ZWithKeyCmd + func (c Pipeline) BgRewriteAOF() *StatusCmd + func (c Pipeline) BgSave() *StatusCmd + func (c Pipeline) BitCount(key string, bitCount *BitCount) *IntCmd + func (c Pipeline) BitField(key string, args ...interface{}) *IntSliceCmd + func (c Pipeline) BitOpAnd(destKey string, keys ...string) *IntCmd + func (c Pipeline) BitOpNot(destKey string, key string) *IntCmd + func (c Pipeline) BitOpOr(destKey string, keys ...string) *IntCmd + func (c Pipeline) BitOpXor(destKey string, keys ...string) *IntCmd + func (c Pipeline) BitPos(key string, bit int64, pos ...int64) *IntCmd + func (c Pipeline) ClientGetName() *StringCmd + func (c Pipeline) ClientID() *IntCmd + func (c Pipeline) ClientKill(ipPort string) *StatusCmd + func (c Pipeline) ClientKillByFilter(keys ...string) *IntCmd + func (c Pipeline) ClientList() *StringCmd + func (c Pipeline) ClientPause(dur time.Duration) *BoolCmd + func (c Pipeline) ClientSetName(name string) *BoolCmd + func (c Pipeline) ClientUnblock(id int64) *IntCmd + func (c Pipeline) ClientUnblockWithError(id int64) *IntCmd + func (c Pipeline) ClusterAddSlots(slots ...int) *StatusCmd + func (c Pipeline) ClusterAddSlotsRange(min, max int) *StatusCmd + func (c Pipeline) ClusterCountFailureReports(nodeID string) *IntCmd + func (c Pipeline) ClusterCountKeysInSlot(slot int) *IntCmd + func (c Pipeline) ClusterDelSlots(slots ...int) *StatusCmd + func (c Pipeline) ClusterDelSlotsRange(min, max int) *StatusCmd + func (c Pipeline) ClusterFailover() *StatusCmd + func (c Pipeline) ClusterForget(nodeID string) *StatusCmd + func (c Pipeline) ClusterGetKeysInSlot(slot int, count int) *StringSliceCmd + func (c Pipeline) ClusterInfo() *StringCmd + func (c Pipeline) ClusterKeySlot(key string) *IntCmd + func (c Pipeline) ClusterMeet(host, port string) *StatusCmd + func (c Pipeline) ClusterNodes() *StringCmd + func (c Pipeline) ClusterReplicate(nodeID string) *StatusCmd + func (c Pipeline) ClusterResetHard() *StatusCmd + func (c Pipeline) ClusterResetSoft() *StatusCmd + func (c Pipeline) ClusterSaveConfig() *StatusCmd + func (c Pipeline) ClusterSlaves(nodeID string) *StringSliceCmd + func (c Pipeline) ClusterSlots() *ClusterSlotsCmd + func (c Pipeline) Command() *CommandsInfoCmd + func (c Pipeline) ConfigGet(parameter string) *SliceCmd + func (c Pipeline) ConfigResetStat() *StatusCmd + func (c Pipeline) ConfigRewrite() *StatusCmd + func (c Pipeline) ConfigSet(parameter, value string) *StatusCmd + func (c Pipeline) DBSize() *IntCmd + func (c Pipeline) DbSize() *IntCmd + func (c Pipeline) DebugObject(key string) *StringCmd + func (c Pipeline) Decr(key string) *IntCmd + func (c Pipeline) DecrBy(key string, decrement int64) *IntCmd + func (c Pipeline) Del(keys ...string) *IntCmd + func (c Pipeline) Dump(key string) *StringCmd + func (c Pipeline) Echo(message interface{}) *StringCmd + func (c Pipeline) Eval(script string, keys []string, args ...interface{}) *Cmd + func (c Pipeline) EvalSha(sha1 string, keys []string, args ...interface{}) *Cmd + func (c Pipeline) Exists(keys ...string) *IntCmd + func (c Pipeline) Expire(key string, expiration time.Duration) *BoolCmd + func (c Pipeline) ExpireAt(key string, tm time.Time) *BoolCmd + func (c Pipeline) FlushAll() *StatusCmd + func (c Pipeline) FlushAllAsync() *StatusCmd + func (c Pipeline) FlushDB() *StatusCmd + func (c Pipeline) FlushDBAsync() *StatusCmd + func (c Pipeline) GeoAdd(key string, geoLocation ...*GeoLocation) *IntCmd + func (c Pipeline) GeoDist(key string, member1, member2, unit string) *FloatCmd + func (c Pipeline) GeoHash(key string, members ...string) *StringSliceCmd + func (c Pipeline) GeoPos(key string, members ...string) *GeoPosCmd + func (c Pipeline) GeoRadius(key string, longitude, latitude float64, query *GeoRadiusQuery) *GeoLocationCmd + func (c Pipeline) GeoRadiusByMember(key, member string, query *GeoRadiusQuery) *GeoLocationCmd + func (c Pipeline) GeoRadiusByMemberStore(key, member string, query *GeoRadiusQuery) *IntCmd + func (c Pipeline) GeoRadiusStore(key string, longitude, latitude float64, query *GeoRadiusQuery) *IntCmd + func (c Pipeline) Get(key string) *StringCmd + func (c Pipeline) GetBit(key string, offset int64) *IntCmd + func (c Pipeline) GetRange(key string, start, end int64) *StringCmd + func (c Pipeline) GetSet(key string, value interface{}) *StringCmd + func (c Pipeline) HDel(key string, fields ...string) *IntCmd + func (c Pipeline) HExists(key, field string) *BoolCmd + func (c Pipeline) HGet(key, field string) *StringCmd + func (c Pipeline) HGetAll(key string) *StringStringMapCmd + func (c Pipeline) HIncrBy(key, field string, incr int64) *IntCmd + func (c Pipeline) HIncrByFloat(key, field string, incr float64) *FloatCmd + func (c Pipeline) HKeys(key string) *StringSliceCmd + func (c Pipeline) HLen(key string) *IntCmd + func (c Pipeline) HMGet(key string, fields ...string) *SliceCmd + func (c Pipeline) HMSet(key string, values ...interface{}) *BoolCmd + func (c Pipeline) HScan(key string, cursor uint64, match string, count int64) *ScanCmd + func (c Pipeline) HSet(key string, values ...interface{}) *IntCmd + func (c Pipeline) HSetNX(key, field string, value interface{}) *BoolCmd + func (c Pipeline) HVals(key string) *StringSliceCmd + func (c Pipeline) Incr(key string) *IntCmd + func (c Pipeline) IncrBy(key string, value int64) *IntCmd + func (c Pipeline) IncrByFloat(key string, value float64) *FloatCmd + func (c Pipeline) Info(section ...string) *StringCmd + func (c Pipeline) Keys(pattern string) *StringSliceCmd + func (c Pipeline) LIndex(key string, index int64) *StringCmd + func (c Pipeline) LInsert(key, op string, pivot, value interface{}) *IntCmd + func (c Pipeline) LInsertAfter(key string, pivot, value interface{}) *IntCmd + func (c Pipeline) LInsertBefore(key string, pivot, value interface{}) *IntCmd + func (c Pipeline) LLen(key string) *IntCmd + func (c Pipeline) LPop(key string) *StringCmd + func (c Pipeline) LPush(key string, values ...interface{}) *IntCmd + func (c Pipeline) LPushX(key string, values ...interface{}) *IntCmd + func (c Pipeline) LRange(key string, start, stop int64) *StringSliceCmd + func (c Pipeline) LRem(key string, count int64, value interface{}) *IntCmd + func (c Pipeline) LSet(key string, index int64, value interface{}) *StatusCmd + func (c Pipeline) LTrim(key string, start, stop int64) *StatusCmd + func (c Pipeline) LastSave() *IntCmd + func (c Pipeline) MGet(keys ...string) *SliceCmd + func (c Pipeline) MSet(values ...interface{}) *StatusCmd + func (c Pipeline) MSetNX(values ...interface{}) *BoolCmd + func (c Pipeline) MemoryUsage(key string, samples ...int) *IntCmd + func (c Pipeline) Migrate(host, port, key string, db int, timeout time.Duration) *StatusCmd + func (c Pipeline) Move(key string, db int) *BoolCmd + func (c Pipeline) ObjectEncoding(key string) *StringCmd + func (c Pipeline) ObjectIdleTime(key string) *DurationCmd + func (c Pipeline) ObjectRefCount(key string) *IntCmd + func (c Pipeline) PExpire(key string, expiration time.Duration) *BoolCmd + func (c Pipeline) PExpireAt(key string, tm time.Time) *BoolCmd + func (c Pipeline) PFAdd(key string, els ...interface{}) *IntCmd + func (c Pipeline) PFCount(keys ...string) *IntCmd + func (c Pipeline) PFMerge(dest string, keys ...string) *StatusCmd + func (c Pipeline) PTTL(key string) *DurationCmd + func (c Pipeline) Persist(key string) *BoolCmd + func (c Pipeline) Ping() *StatusCmd + func (c Pipeline) PubSubChannels(pattern string) *StringSliceCmd + func (c Pipeline) PubSubNumPat() *IntCmd + func (c Pipeline) PubSubNumSub(channels ...string) *StringIntMapCmd + func (c Pipeline) Publish(channel string, message interface{}) *IntCmd + func (c Pipeline) Quit() *StatusCmd + func (c Pipeline) RPop(key string) *StringCmd + func (c Pipeline) RPopLPush(source, destination string) *StringCmd + func (c Pipeline) RPush(key string, values ...interface{}) *IntCmd + func (c Pipeline) RPushX(key string, values ...interface{}) *IntCmd + func (c Pipeline) RandomKey() *StringCmd + func (c Pipeline) ReadOnly() *StatusCmd + func (c Pipeline) ReadWrite() *StatusCmd + func (c Pipeline) Rename(key, newkey string) *StatusCmd + func (c Pipeline) RenameNX(key, newkey string) *BoolCmd + func (c Pipeline) Restore(key string, ttl time.Duration, value string) *StatusCmd + func (c Pipeline) RestoreReplace(key string, ttl time.Duration, value string) *StatusCmd + func (c Pipeline) SAdd(key string, members ...interface{}) *IntCmd + func (c Pipeline) SCard(key string) *IntCmd + func (c Pipeline) SDiff(keys ...string) *StringSliceCmd + func (c Pipeline) SDiffStore(destination string, keys ...string) *IntCmd + func (c Pipeline) SInter(keys ...string) *StringSliceCmd + func (c Pipeline) SInterStore(destination string, keys ...string) *IntCmd + func (c Pipeline) SIsMember(key string, member interface{}) *BoolCmd + func (c Pipeline) SMembers(key string) *StringSliceCmd + func (c Pipeline) SMembersMap(key string) *StringStructMapCmd + func (c Pipeline) SMove(source, destination string, member interface{}) *BoolCmd + func (c Pipeline) SPop(key string) *StringCmd + func (c Pipeline) SPopN(key string, count int64) *StringSliceCmd + func (c Pipeline) SRandMember(key string) *StringCmd + func (c Pipeline) SRandMemberN(key string, count int64) *StringSliceCmd + func (c Pipeline) SRem(key string, members ...interface{}) *IntCmd + func (c Pipeline) SScan(key string, cursor uint64, match string, count int64) *ScanCmd + func (c Pipeline) SUnion(keys ...string) *StringSliceCmd + func (c Pipeline) SUnionStore(destination string, keys ...string) *IntCmd + func (c Pipeline) Save() *StatusCmd + func (c Pipeline) Scan(cursor uint64, match string, count int64) *ScanCmd + func (c Pipeline) ScriptExists(hashes ...string) *BoolSliceCmd + func (c Pipeline) ScriptFlush() *StatusCmd + func (c Pipeline) ScriptKill() *StatusCmd + func (c Pipeline) ScriptLoad(script string) *StringCmd + func (c Pipeline) Select(index int) *StatusCmd + func (c Pipeline) Set(key string, value interface{}, expiration time.Duration) *StatusCmd + func (c Pipeline) SetBit(key string, offset int64, value int) *IntCmd + func (c Pipeline) SetNX(key string, value interface{}, expiration time.Duration) *BoolCmd + func (c Pipeline) SetRange(key string, offset int64, value string) *IntCmd + func (c Pipeline) SetXX(key string, value interface{}, expiration time.Duration) *BoolCmd + func (c Pipeline) Shutdown() *StatusCmd + func (c Pipeline) ShutdownNoSave() *StatusCmd + func (c Pipeline) ShutdownSave() *StatusCmd + func (c Pipeline) SlaveOf(host, port string) *StatusCmd + func (c Pipeline) SlowLog() + func (c Pipeline) Sort(key string, sort *Sort) *StringSliceCmd + func (c Pipeline) SortInterfaces(key string, sort *Sort) *SliceCmd + func (c Pipeline) SortStore(key, store string, sort *Sort) *IntCmd + func (c Pipeline) StrLen(key string) *IntCmd + func (c Pipeline) SwapDB(index1, index2 int) *StatusCmd + func (c Pipeline) Sync() + func (c Pipeline) TTL(key string) *DurationCmd + func (c Pipeline) Time() *TimeCmd + func (c Pipeline) Touch(keys ...string) *IntCmd + func (c Pipeline) Type(key string) *StatusCmd + func (c Pipeline) Unlink(keys ...string) *IntCmd + func (c Pipeline) Wait(numSlaves int, timeout time.Duration) *IntCmd + func (c Pipeline) XAck(stream, group string, ids ...string) *IntCmd + func (c Pipeline) XAdd(a *XAddArgs) *StringCmd + func (c Pipeline) XClaim(a *XClaimArgs) *XMessageSliceCmd + func (c Pipeline) XClaimJustID(a *XClaimArgs) *StringSliceCmd + func (c Pipeline) XDel(stream string, ids ...string) *IntCmd + func (c Pipeline) XGroupCreate(stream, group, start string) *StatusCmd + func (c Pipeline) XGroupCreateMkStream(stream, group, start string) *StatusCmd + func (c Pipeline) XGroupDelConsumer(stream, group, consumer string) *IntCmd + func (c Pipeline) XGroupDestroy(stream, group string) *IntCmd + func (c Pipeline) XGroupSetID(stream, group, start string) *StatusCmd + func (c Pipeline) XInfoGroups(key string) *XInfoGroupsCmd + func (c Pipeline) XLen(stream string) *IntCmd + func (c Pipeline) XPending(stream, group string) *XPendingCmd + func (c Pipeline) XPendingExt(a *XPendingExtArgs) *XPendingExtCmd + func (c Pipeline) XRange(stream, start, stop string) *XMessageSliceCmd + func (c Pipeline) XRangeN(stream, start, stop string, count int64) *XMessageSliceCmd + func (c Pipeline) XRead(a *XReadArgs) *XStreamSliceCmd + func (c Pipeline) XReadGroup(a *XReadGroupArgs) *XStreamSliceCmd + func (c Pipeline) XReadStreams(streams ...string) *XStreamSliceCmd + func (c Pipeline) XRevRange(stream, start, stop string) *XMessageSliceCmd + func (c Pipeline) XRevRangeN(stream, start, stop string, count int64) *XMessageSliceCmd + func (c Pipeline) XTrim(key string, maxLen int64) *IntCmd + func (c Pipeline) XTrimApprox(key string, maxLen int64) *IntCmd + func (c Pipeline) ZAdd(key string, members ...*Z) *IntCmd + func (c Pipeline) ZAddCh(key string, members ...*Z) *IntCmd + func (c Pipeline) ZAddNX(key string, members ...*Z) *IntCmd + func (c Pipeline) ZAddNXCh(key string, members ...*Z) *IntCmd + func (c Pipeline) ZAddXX(key string, members ...*Z) *IntCmd + func (c Pipeline) ZAddXXCh(key string, members ...*Z) *IntCmd + func (c Pipeline) ZCard(key string) *IntCmd + func (c Pipeline) ZCount(key, min, max string) *IntCmd + func (c Pipeline) ZIncr(key string, member *Z) *FloatCmd + func (c Pipeline) ZIncrBy(key string, increment float64, member string) *FloatCmd + func (c Pipeline) ZIncrNX(key string, member *Z) *FloatCmd + func (c Pipeline) ZIncrXX(key string, member *Z) *FloatCmd + func (c Pipeline) ZInterStore(destination string, store *ZStore) *IntCmd + func (c Pipeline) ZLexCount(key, min, max string) *IntCmd + func (c Pipeline) ZPopMax(key string, count ...int64) *ZSliceCmd + func (c Pipeline) ZPopMin(key string, count ...int64) *ZSliceCmd + func (c Pipeline) ZRange(key string, start, stop int64) *StringSliceCmd + func (c Pipeline) ZRangeByLex(key string, opt *ZRangeBy) *StringSliceCmd + func (c Pipeline) ZRangeByScore(key string, opt *ZRangeBy) *StringSliceCmd + func (c Pipeline) ZRangeByScoreWithScores(key string, opt *ZRangeBy) *ZSliceCmd + func (c Pipeline) ZRangeWithScores(key string, start, stop int64) *ZSliceCmd + func (c Pipeline) ZRank(key, member string) *IntCmd + func (c Pipeline) ZRem(key string, members ...interface{}) *IntCmd + func (c Pipeline) ZRemRangeByLex(key, min, max string) *IntCmd + func (c Pipeline) ZRemRangeByRank(key string, start, stop int64) *IntCmd + func (c Pipeline) ZRemRangeByScore(key, min, max string) *IntCmd + func (c Pipeline) ZRevRange(key string, start, stop int64) *StringSliceCmd + func (c Pipeline) ZRevRangeByLex(key string, opt *ZRangeBy) *StringSliceCmd + func (c Pipeline) ZRevRangeByScore(key string, opt *ZRangeBy) *StringSliceCmd + func (c Pipeline) ZRevRangeByScoreWithScores(key string, opt *ZRangeBy) *ZSliceCmd + func (c Pipeline) ZRevRangeWithScores(key string, start, stop int64) *ZSliceCmd + func (c Pipeline) ZRevRank(key, member string) *IntCmd + func (c Pipeline) ZScan(key string, cursor uint64, match string, count int64) *ScanCmd + func (c Pipeline) ZScore(key, member string) *FloatCmd + func (c Pipeline) ZUnionStore(dest string, store *ZStore) *IntCmd + type Pipeliner interface + Close func() error + Discard func() error + Do func(args ...interface{}) *Cmd + Exec func() ([]Cmder, error) + ExecContext func(ctx context.Context) ([]Cmder, error) + Process func(cmd Cmder) error + type Pong struct + Payload string + func (p *Pong) String() string + type PoolStats pool.Stats + type PubSub struct + func (c *PubSub) Channel() <-chan *Message + func (c *PubSub) ChannelSize(size int) <-chan *Message + func (c *PubSub) ChannelWithSubscriptions(size int) <-chan interface{} + func (c *PubSub) Close() error + func (c *PubSub) PSubscribe(patterns ...string) error + func (c *PubSub) PUnsubscribe(patterns ...string) error + func (c *PubSub) Ping(payload ...string) error + func (c *PubSub) Receive() (interface{}, error) + func (c *PubSub) ReceiveMessage() (*Message, error) + func (c *PubSub) ReceiveTimeout(timeout time.Duration) (interface{}, error) + func (c *PubSub) String() string + func (c *PubSub) Subscribe(channels ...string) error + func (c *PubSub) Unsubscribe(channels ...string) error + type Ring struct + func NewRing(opt *RingOptions) *Ring + func (c *Ring) Close() error + func (c *Ring) Context() context.Context + func (c *Ring) Do(args ...interface{}) *Cmd + func (c *Ring) DoContext(ctx context.Context, args ...interface{}) *Cmd + func (c *Ring) ForEachShard(fn func(client *Client) error) error + func (c *Ring) Len() int + func (c *Ring) Options() *RingOptions + func (c *Ring) PSubscribe(channels ...string) *PubSub + func (c *Ring) Pipeline() Pipeliner + func (c *Ring) Pipelined(fn func(Pipeliner) error) ([]Cmder, error) + func (c *Ring) PoolStats() *PoolStats + func (c *Ring) Process(cmd Cmder) error + func (c *Ring) ProcessContext(ctx context.Context, cmd Cmder) error + func (c *Ring) Subscribe(channels ...string) *PubSub + func (c *Ring) TxPipeline() Pipeliner + func (c *Ring) TxPipelined(fn func(Pipeliner) error) ([]Cmder, error) + func (c *Ring) Watch(fn func(*Tx) error, keys ...string) error + func (c *Ring) WithContext(ctx context.Context) *Ring + func (c Ring) Append(key, value string) *IntCmd + func (c Ring) BLPop(timeout time.Duration, keys ...string) *StringSliceCmd + func (c Ring) BRPop(timeout time.Duration, keys ...string) *StringSliceCmd + func (c Ring) BRPopLPush(source, destination string, timeout time.Duration) *StringCmd + func (c Ring) BZPopMax(timeout time.Duration, keys ...string) *ZWithKeyCmd + func (c Ring) BZPopMin(timeout time.Duration, keys ...string) *ZWithKeyCmd + func (c Ring) BgRewriteAOF() *StatusCmd + func (c Ring) BgSave() *StatusCmd + func (c Ring) BitCount(key string, bitCount *BitCount) *IntCmd + func (c Ring) BitField(key string, args ...interface{}) *IntSliceCmd + func (c Ring) BitOpAnd(destKey string, keys ...string) *IntCmd + func (c Ring) BitOpNot(destKey string, key string) *IntCmd + func (c Ring) BitOpOr(destKey string, keys ...string) *IntCmd + func (c Ring) BitOpXor(destKey string, keys ...string) *IntCmd + func (c Ring) BitPos(key string, bit int64, pos ...int64) *IntCmd + func (c Ring) ClientGetName() *StringCmd + func (c Ring) ClientID() *IntCmd + func (c Ring) ClientKill(ipPort string) *StatusCmd + func (c Ring) ClientKillByFilter(keys ...string) *IntCmd + func (c Ring) ClientList() *StringCmd + func (c Ring) ClientPause(dur time.Duration) *BoolCmd + func (c Ring) ClientUnblock(id int64) *IntCmd + func (c Ring) ClientUnblockWithError(id int64) *IntCmd + func (c Ring) ClusterAddSlots(slots ...int) *StatusCmd + func (c Ring) ClusterAddSlotsRange(min, max int) *StatusCmd + func (c Ring) ClusterCountFailureReports(nodeID string) *IntCmd + func (c Ring) ClusterCountKeysInSlot(slot int) *IntCmd + func (c Ring) ClusterDelSlots(slots ...int) *StatusCmd + func (c Ring) ClusterDelSlotsRange(min, max int) *StatusCmd + func (c Ring) ClusterFailover() *StatusCmd + func (c Ring) ClusterForget(nodeID string) *StatusCmd + func (c Ring) ClusterGetKeysInSlot(slot int, count int) *StringSliceCmd + func (c Ring) ClusterInfo() *StringCmd + func (c Ring) ClusterKeySlot(key string) *IntCmd + func (c Ring) ClusterMeet(host, port string) *StatusCmd + func (c Ring) ClusterNodes() *StringCmd + func (c Ring) ClusterReplicate(nodeID string) *StatusCmd + func (c Ring) ClusterResetHard() *StatusCmd + func (c Ring) ClusterResetSoft() *StatusCmd + func (c Ring) ClusterSaveConfig() *StatusCmd + func (c Ring) ClusterSlaves(nodeID string) *StringSliceCmd + func (c Ring) ClusterSlots() *ClusterSlotsCmd + func (c Ring) Command() *CommandsInfoCmd + func (c Ring) ConfigGet(parameter string) *SliceCmd + func (c Ring) ConfigResetStat() *StatusCmd + func (c Ring) ConfigRewrite() *StatusCmd + func (c Ring) ConfigSet(parameter, value string) *StatusCmd + func (c Ring) DBSize() *IntCmd + func (c Ring) DbSize() *IntCmd + func (c Ring) DebugObject(key string) *StringCmd + func (c Ring) Decr(key string) *IntCmd + func (c Ring) DecrBy(key string, decrement int64) *IntCmd + func (c Ring) Del(keys ...string) *IntCmd + func (c Ring) Dump(key string) *StringCmd + func (c Ring) Echo(message interface{}) *StringCmd + func (c Ring) Eval(script string, keys []string, args ...interface{}) *Cmd + func (c Ring) EvalSha(sha1 string, keys []string, args ...interface{}) *Cmd + func (c Ring) Exists(keys ...string) *IntCmd + func (c Ring) Expire(key string, expiration time.Duration) *BoolCmd + func (c Ring) ExpireAt(key string, tm time.Time) *BoolCmd + func (c Ring) FlushAll() *StatusCmd + func (c Ring) FlushAllAsync() *StatusCmd + func (c Ring) FlushDB() *StatusCmd + func (c Ring) FlushDBAsync() *StatusCmd + func (c Ring) GeoAdd(key string, geoLocation ...*GeoLocation) *IntCmd + func (c Ring) GeoDist(key string, member1, member2, unit string) *FloatCmd + func (c Ring) GeoHash(key string, members ...string) *StringSliceCmd + func (c Ring) GeoPos(key string, members ...string) *GeoPosCmd + func (c Ring) GeoRadius(key string, longitude, latitude float64, query *GeoRadiusQuery) *GeoLocationCmd + func (c Ring) GeoRadiusByMember(key, member string, query *GeoRadiusQuery) *GeoLocationCmd + func (c Ring) GeoRadiusByMemberStore(key, member string, query *GeoRadiusQuery) *IntCmd + func (c Ring) GeoRadiusStore(key string, longitude, latitude float64, query *GeoRadiusQuery) *IntCmd + func (c Ring) Get(key string) *StringCmd + func (c Ring) GetBit(key string, offset int64) *IntCmd + func (c Ring) GetRange(key string, start, end int64) *StringCmd + func (c Ring) GetSet(key string, value interface{}) *StringCmd + func (c Ring) HDel(key string, fields ...string) *IntCmd + func (c Ring) HExists(key, field string) *BoolCmd + func (c Ring) HGet(key, field string) *StringCmd + func (c Ring) HGetAll(key string) *StringStringMapCmd + func (c Ring) HIncrBy(key, field string, incr int64) *IntCmd + func (c Ring) HIncrByFloat(key, field string, incr float64) *FloatCmd + func (c Ring) HKeys(key string) *StringSliceCmd + func (c Ring) HLen(key string) *IntCmd + func (c Ring) HMGet(key string, fields ...string) *SliceCmd + func (c Ring) HMSet(key string, values ...interface{}) *BoolCmd + func (c Ring) HScan(key string, cursor uint64, match string, count int64) *ScanCmd + func (c Ring) HSet(key string, values ...interface{}) *IntCmd + func (c Ring) HSetNX(key, field string, value interface{}) *BoolCmd + func (c Ring) HVals(key string) *StringSliceCmd + func (c Ring) Incr(key string) *IntCmd + func (c Ring) IncrBy(key string, value int64) *IntCmd + func (c Ring) IncrByFloat(key string, value float64) *FloatCmd + func (c Ring) Info(section ...string) *StringCmd + func (c Ring) Keys(pattern string) *StringSliceCmd + func (c Ring) LIndex(key string, index int64) *StringCmd + func (c Ring) LInsert(key, op string, pivot, value interface{}) *IntCmd + func (c Ring) LInsertAfter(key string, pivot, value interface{}) *IntCmd + func (c Ring) LInsertBefore(key string, pivot, value interface{}) *IntCmd + func (c Ring) LLen(key string) *IntCmd + func (c Ring) LPop(key string) *StringCmd + func (c Ring) LPush(key string, values ...interface{}) *IntCmd + func (c Ring) LPushX(key string, values ...interface{}) *IntCmd + func (c Ring) LRange(key string, start, stop int64) *StringSliceCmd + func (c Ring) LRem(key string, count int64, value interface{}) *IntCmd + func (c Ring) LSet(key string, index int64, value interface{}) *StatusCmd + func (c Ring) LTrim(key string, start, stop int64) *StatusCmd + func (c Ring) LastSave() *IntCmd + func (c Ring) MGet(keys ...string) *SliceCmd + func (c Ring) MSet(values ...interface{}) *StatusCmd + func (c Ring) MSetNX(values ...interface{}) *BoolCmd + func (c Ring) MemoryUsage(key string, samples ...int) *IntCmd + func (c Ring) Migrate(host, port, key string, db int, timeout time.Duration) *StatusCmd + func (c Ring) Move(key string, db int) *BoolCmd + func (c Ring) ObjectEncoding(key string) *StringCmd + func (c Ring) ObjectIdleTime(key string) *DurationCmd + func (c Ring) ObjectRefCount(key string) *IntCmd + func (c Ring) PExpire(key string, expiration time.Duration) *BoolCmd + func (c Ring) PExpireAt(key string, tm time.Time) *BoolCmd + func (c Ring) PFAdd(key string, els ...interface{}) *IntCmd + func (c Ring) PFCount(keys ...string) *IntCmd + func (c Ring) PFMerge(dest string, keys ...string) *StatusCmd + func (c Ring) PTTL(key string) *DurationCmd + func (c Ring) Persist(key string) *BoolCmd + func (c Ring) Ping() *StatusCmd + func (c Ring) PubSubChannels(pattern string) *StringSliceCmd + func (c Ring) PubSubNumPat() *IntCmd + func (c Ring) PubSubNumSub(channels ...string) *StringIntMapCmd + func (c Ring) Publish(channel string, message interface{}) *IntCmd + func (c Ring) Quit() *StatusCmd + func (c Ring) RPop(key string) *StringCmd + func (c Ring) RPopLPush(source, destination string) *StringCmd + func (c Ring) RPush(key string, values ...interface{}) *IntCmd + func (c Ring) RPushX(key string, values ...interface{}) *IntCmd + func (c Ring) RandomKey() *StringCmd + func (c Ring) ReadOnly() *StatusCmd + func (c Ring) ReadWrite() *StatusCmd + func (c Ring) Rename(key, newkey string) *StatusCmd + func (c Ring) RenameNX(key, newkey string) *BoolCmd + func (c Ring) Restore(key string, ttl time.Duration, value string) *StatusCmd + func (c Ring) RestoreReplace(key string, ttl time.Duration, value string) *StatusCmd + func (c Ring) SAdd(key string, members ...interface{}) *IntCmd + func (c Ring) SCard(key string) *IntCmd + func (c Ring) SDiff(keys ...string) *StringSliceCmd + func (c Ring) SDiffStore(destination string, keys ...string) *IntCmd + func (c Ring) SInter(keys ...string) *StringSliceCmd + func (c Ring) SInterStore(destination string, keys ...string) *IntCmd + func (c Ring) SIsMember(key string, member interface{}) *BoolCmd + func (c Ring) SMembers(key string) *StringSliceCmd + func (c Ring) SMembersMap(key string) *StringStructMapCmd + func (c Ring) SMove(source, destination string, member interface{}) *BoolCmd + func (c Ring) SPop(key string) *StringCmd + func (c Ring) SPopN(key string, count int64) *StringSliceCmd + func (c Ring) SRandMember(key string) *StringCmd + func (c Ring) SRandMemberN(key string, count int64) *StringSliceCmd + func (c Ring) SRem(key string, members ...interface{}) *IntCmd + func (c Ring) SScan(key string, cursor uint64, match string, count int64) *ScanCmd + func (c Ring) SUnion(keys ...string) *StringSliceCmd + func (c Ring) SUnionStore(destination string, keys ...string) *IntCmd + func (c Ring) Save() *StatusCmd + func (c Ring) Scan(cursor uint64, match string, count int64) *ScanCmd + func (c Ring) ScriptExists(hashes ...string) *BoolSliceCmd + func (c Ring) ScriptFlush() *StatusCmd + func (c Ring) ScriptKill() *StatusCmd + func (c Ring) ScriptLoad(script string) *StringCmd + func (c Ring) Set(key string, value interface{}, expiration time.Duration) *StatusCmd + func (c Ring) SetBit(key string, offset int64, value int) *IntCmd + func (c Ring) SetNX(key string, value interface{}, expiration time.Duration) *BoolCmd + func (c Ring) SetRange(key string, offset int64, value string) *IntCmd + func (c Ring) SetXX(key string, value interface{}, expiration time.Duration) *BoolCmd + func (c Ring) Shutdown() *StatusCmd + func (c Ring) ShutdownNoSave() *StatusCmd + func (c Ring) ShutdownSave() *StatusCmd + func (c Ring) SlaveOf(host, port string) *StatusCmd + func (c Ring) SlowLog() + func (c Ring) Sort(key string, sort *Sort) *StringSliceCmd + func (c Ring) SortInterfaces(key string, sort *Sort) *SliceCmd + func (c Ring) SortStore(key, store string, sort *Sort) *IntCmd + func (c Ring) StrLen(key string) *IntCmd + func (c Ring) Sync() + func (c Ring) TTL(key string) *DurationCmd + func (c Ring) Time() *TimeCmd + func (c Ring) Touch(keys ...string) *IntCmd + func (c Ring) Type(key string) *StatusCmd + func (c Ring) Unlink(keys ...string) *IntCmd + func (c Ring) Wait(numSlaves int, timeout time.Duration) *IntCmd + func (c Ring) XAck(stream, group string, ids ...string) *IntCmd + func (c Ring) XAdd(a *XAddArgs) *StringCmd + func (c Ring) XClaim(a *XClaimArgs) *XMessageSliceCmd + func (c Ring) XClaimJustID(a *XClaimArgs) *StringSliceCmd + func (c Ring) XDel(stream string, ids ...string) *IntCmd + func (c Ring) XGroupCreate(stream, group, start string) *StatusCmd + func (c Ring) XGroupCreateMkStream(stream, group, start string) *StatusCmd + func (c Ring) XGroupDelConsumer(stream, group, consumer string) *IntCmd + func (c Ring) XGroupDestroy(stream, group string) *IntCmd + func (c Ring) XGroupSetID(stream, group, start string) *StatusCmd + func (c Ring) XInfoGroups(key string) *XInfoGroupsCmd + func (c Ring) XLen(stream string) *IntCmd + func (c Ring) XPending(stream, group string) *XPendingCmd + func (c Ring) XPendingExt(a *XPendingExtArgs) *XPendingExtCmd + func (c Ring) XRange(stream, start, stop string) *XMessageSliceCmd + func (c Ring) XRangeN(stream, start, stop string, count int64) *XMessageSliceCmd + func (c Ring) XRead(a *XReadArgs) *XStreamSliceCmd + func (c Ring) XReadGroup(a *XReadGroupArgs) *XStreamSliceCmd + func (c Ring) XReadStreams(streams ...string) *XStreamSliceCmd + func (c Ring) XRevRange(stream, start, stop string) *XMessageSliceCmd + func (c Ring) XRevRangeN(stream, start, stop string, count int64) *XMessageSliceCmd + func (c Ring) XTrim(key string, maxLen int64) *IntCmd + func (c Ring) XTrimApprox(key string, maxLen int64) *IntCmd + func (c Ring) ZAdd(key string, members ...*Z) *IntCmd + func (c Ring) ZAddCh(key string, members ...*Z) *IntCmd + func (c Ring) ZAddNX(key string, members ...*Z) *IntCmd + func (c Ring) ZAddNXCh(key string, members ...*Z) *IntCmd + func (c Ring) ZAddXX(key string, members ...*Z) *IntCmd + func (c Ring) ZAddXXCh(key string, members ...*Z) *IntCmd + func (c Ring) ZCard(key string) *IntCmd + func (c Ring) ZCount(key, min, max string) *IntCmd + func (c Ring) ZIncr(key string, member *Z) *FloatCmd + func (c Ring) ZIncrBy(key string, increment float64, member string) *FloatCmd + func (c Ring) ZIncrNX(key string, member *Z) *FloatCmd + func (c Ring) ZIncrXX(key string, member *Z) *FloatCmd + func (c Ring) ZInterStore(destination string, store *ZStore) *IntCmd + func (c Ring) ZLexCount(key, min, max string) *IntCmd + func (c Ring) ZPopMax(key string, count ...int64) *ZSliceCmd + func (c Ring) ZPopMin(key string, count ...int64) *ZSliceCmd + func (c Ring) ZRange(key string, start, stop int64) *StringSliceCmd + func (c Ring) ZRangeByLex(key string, opt *ZRangeBy) *StringSliceCmd + func (c Ring) ZRangeByScore(key string, opt *ZRangeBy) *StringSliceCmd + func (c Ring) ZRangeByScoreWithScores(key string, opt *ZRangeBy) *ZSliceCmd + func (c Ring) ZRangeWithScores(key string, start, stop int64) *ZSliceCmd + func (c Ring) ZRank(key, member string) *IntCmd + func (c Ring) ZRem(key string, members ...interface{}) *IntCmd + func (c Ring) ZRemRangeByLex(key, min, max string) *IntCmd + func (c Ring) ZRemRangeByRank(key string, start, stop int64) *IntCmd + func (c Ring) ZRemRangeByScore(key, min, max string) *IntCmd + func (c Ring) ZRevRange(key string, start, stop int64) *StringSliceCmd + func (c Ring) ZRevRangeByLex(key string, opt *ZRangeBy) *StringSliceCmd + func (c Ring) ZRevRangeByScore(key string, opt *ZRangeBy) *StringSliceCmd + func (c Ring) ZRevRangeByScoreWithScores(key string, opt *ZRangeBy) *ZSliceCmd + func (c Ring) ZRevRangeWithScores(key string, start, stop int64) *ZSliceCmd + func (c Ring) ZRevRank(key, member string) *IntCmd + func (c Ring) ZScan(key string, cursor uint64, match string, count int64) *ScanCmd + func (c Ring) ZScore(key, member string) *FloatCmd + func (c Ring) ZUnionStore(dest string, store *ZStore) *IntCmd + func (hs *Ring) AddHook(hook Hook) + type RingOptions struct + Addrs map[string]string + DB int + DialTimeout time.Duration + Hash Hash + HashReplicas int + HeartbeatFrequency time.Duration + IdleCheckFrequency time.Duration + IdleTimeout time.Duration + MaxConnAge time.Duration + MaxRetries int + MaxRetryBackoff time.Duration + MinIdleConns int + MinRetryBackoff time.Duration + NewClient func(name string, opt *Options) *Client + OnConnect func(*Conn) error + OnNewShard func(*Client) + Password string + Passwords map[string]string + PoolSize int + PoolTimeout time.Duration + ReadTimeout time.Duration + WriteTimeout time.Duration + type ScanCmd struct + func NewScanCmd(process func(cmd Cmder) error, args ...interface{}) *ScanCmd + func NewScanCmdResult(keys []string, cursor uint64, err error) *ScanCmd + func (cmd *ScanCmd) Args() []interface{} + func (cmd *ScanCmd) Err() error + func (cmd *ScanCmd) Iterator() *ScanIterator + func (cmd *ScanCmd) Name() string + func (cmd *ScanCmd) Result() (keys []string, cursor uint64, err error) + func (cmd *ScanCmd) SetErr(e error) + func (cmd *ScanCmd) String() string + func (cmd *ScanCmd) Val() (keys []string, cursor uint64) + type ScanIterator struct + func (it *ScanIterator) Err() error + func (it *ScanIterator) Next() bool + func (it *ScanIterator) Val() string + type Script struct + func NewScript(src string) *Script + func (s *Script) Eval(c scripter, keys []string, args ...interface{}) *Cmd + func (s *Script) EvalSha(c scripter, keys []string, args ...interface{}) *Cmd + func (s *Script) Exists(c scripter) *BoolSliceCmd + func (s *Script) Hash() string + func (s *Script) Load(c scripter) *StringCmd + func (s *Script) Run(c scripter, keys []string, args ...interface{}) *Cmd + type SentinelClient struct + func NewSentinelClient(opt *Options) *SentinelClient + func (c *SentinelClient) CkQuorum(name string) *StringCmd + func (c *SentinelClient) Context() context.Context + func (c *SentinelClient) Failover(name string) *StatusCmd + func (c *SentinelClient) FlushConfig() *StatusCmd + func (c *SentinelClient) GetMasterAddrByName(name string) *StringSliceCmd + func (c *SentinelClient) Master(name string) *StringStringMapCmd + func (c *SentinelClient) Masters() *SliceCmd + func (c *SentinelClient) Monitor(name, ip, port, quorum string) *StringCmd + func (c *SentinelClient) PSubscribe(channels ...string) *PubSub + func (c *SentinelClient) Ping() *StringCmd + func (c *SentinelClient) Process(cmd Cmder) error + func (c *SentinelClient) ProcessContext(ctx context.Context, cmd Cmder) error + func (c *SentinelClient) Remove(name string) *StringCmd + func (c *SentinelClient) Reset(pattern string) *IntCmd + func (c *SentinelClient) Sentinels(name string) *SliceCmd + func (c *SentinelClient) Set(name, option, value string) *StringCmd + func (c *SentinelClient) Slaves(name string) *SliceCmd + func (c *SentinelClient) Subscribe(channels ...string) *PubSub + func (c *SentinelClient) WithContext(ctx context.Context) *SentinelClient + func (c SentinelClient) Close() error + func (c SentinelClient) String() string + type SliceCmd struct + func NewSliceCmd(args ...interface{}) *SliceCmd + func NewSliceResult(val []interface{}, err error) *SliceCmd + func (cmd *SliceCmd) Args() []interface{} + func (cmd *SliceCmd) Err() error + func (cmd *SliceCmd) Name() string + func (cmd *SliceCmd) Result() ([]interface{}, error) + func (cmd *SliceCmd) SetErr(e error) + func (cmd *SliceCmd) String() string + func (cmd *SliceCmd) Val() []interface{} + type Sort struct + Alpha bool + By string + Count int64 + Get []string + Offset int64 + Order string + type StatefulCmdable interface + Auth func(password string) *StatusCmd + AuthACL func(username, password string) *StatusCmd + ClientSetName func(name string) *BoolCmd + Select func(index int) *StatusCmd + SwapDB func(index1, index2 int) *StatusCmd + type StatusCmd struct + func NewStatusCmd(args ...interface{}) *StatusCmd + func NewStatusResult(val string, err error) *StatusCmd + func (cmd *StatusCmd) Args() []interface{} + func (cmd *StatusCmd) Err() error + func (cmd *StatusCmd) Name() string + func (cmd *StatusCmd) Result() (string, error) + func (cmd *StatusCmd) SetErr(e error) + func (cmd *StatusCmd) String() string + func (cmd *StatusCmd) Val() string + type StringCmd struct + func NewStringCmd(args ...interface{}) *StringCmd + func NewStringResult(val string, err error) *StringCmd + func (cmd *StringCmd) Args() []interface{} + func (cmd *StringCmd) Bytes() ([]byte, error) + func (cmd *StringCmd) Err() error + func (cmd *StringCmd) Float32() (float32, error) + func (cmd *StringCmd) Float64() (float64, error) + func (cmd *StringCmd) Int() (int, error) + func (cmd *StringCmd) Int64() (int64, error) + func (cmd *StringCmd) Name() string + func (cmd *StringCmd) Result() (string, error) + func (cmd *StringCmd) Scan(val interface{}) error + func (cmd *StringCmd) SetErr(e error) + func (cmd *StringCmd) String() string + func (cmd *StringCmd) Time() (time.Time, error) + func (cmd *StringCmd) Uint64() (uint64, error) + func (cmd *StringCmd) Val() string + type StringIntMapCmd struct + func NewStringIntMapCmd(args ...interface{}) *StringIntMapCmd + func NewStringIntMapCmdResult(val map[string]int64, err error) *StringIntMapCmd + func (cmd *StringIntMapCmd) Args() []interface{} + func (cmd *StringIntMapCmd) Err() error + func (cmd *StringIntMapCmd) Name() string + func (cmd *StringIntMapCmd) Result() (map[string]int64, error) + func (cmd *StringIntMapCmd) SetErr(e error) + func (cmd *StringIntMapCmd) String() string + func (cmd *StringIntMapCmd) Val() map[string]int64 + type StringSliceCmd struct + func NewStringSliceCmd(args ...interface{}) *StringSliceCmd + func NewStringSliceResult(val []string, err error) *StringSliceCmd + func (cmd *StringSliceCmd) Args() []interface{} + func (cmd *StringSliceCmd) Err() error + func (cmd *StringSliceCmd) Name() string + func (cmd *StringSliceCmd) Result() ([]string, error) + func (cmd *StringSliceCmd) ScanSlice(container interface{}) error + func (cmd *StringSliceCmd) SetErr(e error) + func (cmd *StringSliceCmd) String() string + func (cmd *StringSliceCmd) Val() []string + type StringStringMapCmd struct + func NewStringStringMapCmd(args ...interface{}) *StringStringMapCmd + func NewStringStringMapResult(val map[string]string, err error) *StringStringMapCmd + func (cmd *StringStringMapCmd) Args() []interface{} + func (cmd *StringStringMapCmd) Err() error + func (cmd *StringStringMapCmd) Name() string + func (cmd *StringStringMapCmd) Result() (map[string]string, error) + func (cmd *StringStringMapCmd) SetErr(e error) + func (cmd *StringStringMapCmd) String() string + func (cmd *StringStringMapCmd) Val() map[string]string + type StringStructMapCmd struct + func NewStringStructMapCmd(args ...interface{}) *StringStructMapCmd + func (cmd *StringStructMapCmd) Args() []interface{} + func (cmd *StringStructMapCmd) Err() error + func (cmd *StringStructMapCmd) Name() string + func (cmd *StringStructMapCmd) Result() (map[string]struct{}, error) + func (cmd *StringStructMapCmd) SetErr(e error) + func (cmd *StringStructMapCmd) String() string + func (cmd *StringStructMapCmd) Val() map[string]struct{} + type Subscription struct + Channel string + Count int + Kind string + func (m *Subscription) String() string + type TimeCmd struct + func NewTimeCmd(args ...interface{}) *TimeCmd + func NewTimeCmdResult(val time.Time, err error) *TimeCmd + func (cmd *TimeCmd) Args() []interface{} + func (cmd *TimeCmd) Err() error + func (cmd *TimeCmd) Name() string + func (cmd *TimeCmd) Result() (time.Time, error) + func (cmd *TimeCmd) SetErr(e error) + func (cmd *TimeCmd) String() string + func (cmd *TimeCmd) Val() time.Time + type Tx struct + func (c *Tx) Close() error + func (c *Tx) Context() context.Context + func (c *Tx) Pipeline() Pipeliner + func (c *Tx) Pipelined(fn func(Pipeliner) error) ([]Cmder, error) + func (c *Tx) Process(cmd Cmder) error + func (c *Tx) ProcessContext(ctx context.Context, cmd Cmder) error + func (c *Tx) String() string + func (c *Tx) TxPipeline() Pipeliner + func (c *Tx) TxPipelined(fn func(Pipeliner) error) ([]Cmder, error) + func (c *Tx) Unwatch(keys ...string) *StatusCmd + func (c *Tx) Watch(keys ...string) *StatusCmd + func (c *Tx) WithContext(ctx context.Context) *Tx + func (c Tx) Append(key, value string) *IntCmd + func (c Tx) Auth(password string) *StatusCmd + func (c Tx) AuthACL(username, password string) *StatusCmd + func (c Tx) BLPop(timeout time.Duration, keys ...string) *StringSliceCmd + func (c Tx) BRPop(timeout time.Duration, keys ...string) *StringSliceCmd + func (c Tx) BRPopLPush(source, destination string, timeout time.Duration) *StringCmd + func (c Tx) BZPopMax(timeout time.Duration, keys ...string) *ZWithKeyCmd + func (c Tx) BZPopMin(timeout time.Duration, keys ...string) *ZWithKeyCmd + func (c Tx) BgRewriteAOF() *StatusCmd + func (c Tx) BgSave() *StatusCmd + func (c Tx) BitCount(key string, bitCount *BitCount) *IntCmd + func (c Tx) BitField(key string, args ...interface{}) *IntSliceCmd + func (c Tx) BitOpAnd(destKey string, keys ...string) *IntCmd + func (c Tx) BitOpNot(destKey string, key string) *IntCmd + func (c Tx) BitOpOr(destKey string, keys ...string) *IntCmd + func (c Tx) BitOpXor(destKey string, keys ...string) *IntCmd + func (c Tx) BitPos(key string, bit int64, pos ...int64) *IntCmd + func (c Tx) ClientGetName() *StringCmd + func (c Tx) ClientID() *IntCmd + func (c Tx) ClientKill(ipPort string) *StatusCmd + func (c Tx) ClientKillByFilter(keys ...string) *IntCmd + func (c Tx) ClientList() *StringCmd + func (c Tx) ClientPause(dur time.Duration) *BoolCmd + func (c Tx) ClientSetName(name string) *BoolCmd + func (c Tx) ClientUnblock(id int64) *IntCmd + func (c Tx) ClientUnblockWithError(id int64) *IntCmd + func (c Tx) ClusterAddSlots(slots ...int) *StatusCmd + func (c Tx) ClusterAddSlotsRange(min, max int) *StatusCmd + func (c Tx) ClusterCountFailureReports(nodeID string) *IntCmd + func (c Tx) ClusterCountKeysInSlot(slot int) *IntCmd + func (c Tx) ClusterDelSlots(slots ...int) *StatusCmd + func (c Tx) ClusterDelSlotsRange(min, max int) *StatusCmd + func (c Tx) ClusterFailover() *StatusCmd + func (c Tx) ClusterForget(nodeID string) *StatusCmd + func (c Tx) ClusterGetKeysInSlot(slot int, count int) *StringSliceCmd + func (c Tx) ClusterInfo() *StringCmd + func (c Tx) ClusterKeySlot(key string) *IntCmd + func (c Tx) ClusterMeet(host, port string) *StatusCmd + func (c Tx) ClusterNodes() *StringCmd + func (c Tx) ClusterReplicate(nodeID string) *StatusCmd + func (c Tx) ClusterResetHard() *StatusCmd + func (c Tx) ClusterResetSoft() *StatusCmd + func (c Tx) ClusterSaveConfig() *StatusCmd + func (c Tx) ClusterSlaves(nodeID string) *StringSliceCmd + func (c Tx) ClusterSlots() *ClusterSlotsCmd + func (c Tx) Command() *CommandsInfoCmd + func (c Tx) ConfigGet(parameter string) *SliceCmd + func (c Tx) ConfigResetStat() *StatusCmd + func (c Tx) ConfigRewrite() *StatusCmd + func (c Tx) ConfigSet(parameter, value string) *StatusCmd + func (c Tx) DBSize() *IntCmd + func (c Tx) DbSize() *IntCmd + func (c Tx) DebugObject(key string) *StringCmd + func (c Tx) Decr(key string) *IntCmd + func (c Tx) DecrBy(key string, decrement int64) *IntCmd + func (c Tx) Del(keys ...string) *IntCmd + func (c Tx) Dump(key string) *StringCmd + func (c Tx) Echo(message interface{}) *StringCmd + func (c Tx) Eval(script string, keys []string, args ...interface{}) *Cmd + func (c Tx) EvalSha(sha1 string, keys []string, args ...interface{}) *Cmd + func (c Tx) Exists(keys ...string) *IntCmd + func (c Tx) Expire(key string, expiration time.Duration) *BoolCmd + func (c Tx) ExpireAt(key string, tm time.Time) *BoolCmd + func (c Tx) FlushAll() *StatusCmd + func (c Tx) FlushAllAsync() *StatusCmd + func (c Tx) FlushDB() *StatusCmd + func (c Tx) FlushDBAsync() *StatusCmd + func (c Tx) GeoAdd(key string, geoLocation ...*GeoLocation) *IntCmd + func (c Tx) GeoDist(key string, member1, member2, unit string) *FloatCmd + func (c Tx) GeoHash(key string, members ...string) *StringSliceCmd + func (c Tx) GeoPos(key string, members ...string) *GeoPosCmd + func (c Tx) GeoRadius(key string, longitude, latitude float64, query *GeoRadiusQuery) *GeoLocationCmd + func (c Tx) GeoRadiusByMember(key, member string, query *GeoRadiusQuery) *GeoLocationCmd + func (c Tx) GeoRadiusByMemberStore(key, member string, query *GeoRadiusQuery) *IntCmd + func (c Tx) GeoRadiusStore(key string, longitude, latitude float64, query *GeoRadiusQuery) *IntCmd + func (c Tx) Get(key string) *StringCmd + func (c Tx) GetBit(key string, offset int64) *IntCmd + func (c Tx) GetRange(key string, start, end int64) *StringCmd + func (c Tx) GetSet(key string, value interface{}) *StringCmd + func (c Tx) HDel(key string, fields ...string) *IntCmd + func (c Tx) HExists(key, field string) *BoolCmd + func (c Tx) HGet(key, field string) *StringCmd + func (c Tx) HGetAll(key string) *StringStringMapCmd + func (c Tx) HIncrBy(key, field string, incr int64) *IntCmd + func (c Tx) HIncrByFloat(key, field string, incr float64) *FloatCmd + func (c Tx) HKeys(key string) *StringSliceCmd + func (c Tx) HLen(key string) *IntCmd + func (c Tx) HMGet(key string, fields ...string) *SliceCmd + func (c Tx) HMSet(key string, values ...interface{}) *BoolCmd + func (c Tx) HScan(key string, cursor uint64, match string, count int64) *ScanCmd + func (c Tx) HSet(key string, values ...interface{}) *IntCmd + func (c Tx) HSetNX(key, field string, value interface{}) *BoolCmd + func (c Tx) HVals(key string) *StringSliceCmd + func (c Tx) Incr(key string) *IntCmd + func (c Tx) IncrBy(key string, value int64) *IntCmd + func (c Tx) IncrByFloat(key string, value float64) *FloatCmd + func (c Tx) Info(section ...string) *StringCmd + func (c Tx) Keys(pattern string) *StringSliceCmd + func (c Tx) LIndex(key string, index int64) *StringCmd + func (c Tx) LInsert(key, op string, pivot, value interface{}) *IntCmd + func (c Tx) LInsertAfter(key string, pivot, value interface{}) *IntCmd + func (c Tx) LInsertBefore(key string, pivot, value interface{}) *IntCmd + func (c Tx) LLen(key string) *IntCmd + func (c Tx) LPop(key string) *StringCmd + func (c Tx) LPush(key string, values ...interface{}) *IntCmd + func (c Tx) LPushX(key string, values ...interface{}) *IntCmd + func (c Tx) LRange(key string, start, stop int64) *StringSliceCmd + func (c Tx) LRem(key string, count int64, value interface{}) *IntCmd + func (c Tx) LSet(key string, index int64, value interface{}) *StatusCmd + func (c Tx) LTrim(key string, start, stop int64) *StatusCmd + func (c Tx) LastSave() *IntCmd + func (c Tx) MGet(keys ...string) *SliceCmd + func (c Tx) MSet(values ...interface{}) *StatusCmd + func (c Tx) MSetNX(values ...interface{}) *BoolCmd + func (c Tx) MemoryUsage(key string, samples ...int) *IntCmd + func (c Tx) Migrate(host, port, key string, db int, timeout time.Duration) *StatusCmd + func (c Tx) Move(key string, db int) *BoolCmd + func (c Tx) ObjectEncoding(key string) *StringCmd + func (c Tx) ObjectIdleTime(key string) *DurationCmd + func (c Tx) ObjectRefCount(key string) *IntCmd + func (c Tx) PExpire(key string, expiration time.Duration) *BoolCmd + func (c Tx) PExpireAt(key string, tm time.Time) *BoolCmd + func (c Tx) PFAdd(key string, els ...interface{}) *IntCmd + func (c Tx) PFCount(keys ...string) *IntCmd + func (c Tx) PFMerge(dest string, keys ...string) *StatusCmd + func (c Tx) PTTL(key string) *DurationCmd + func (c Tx) Persist(key string) *BoolCmd + func (c Tx) Ping() *StatusCmd + func (c Tx) PubSubChannels(pattern string) *StringSliceCmd + func (c Tx) PubSubNumPat() *IntCmd + func (c Tx) PubSubNumSub(channels ...string) *StringIntMapCmd + func (c Tx) Publish(channel string, message interface{}) *IntCmd + func (c Tx) Quit() *StatusCmd + func (c Tx) RPop(key string) *StringCmd + func (c Tx) RPopLPush(source, destination string) *StringCmd + func (c Tx) RPush(key string, values ...interface{}) *IntCmd + func (c Tx) RPushX(key string, values ...interface{}) *IntCmd + func (c Tx) RandomKey() *StringCmd + func (c Tx) ReadOnly() *StatusCmd + func (c Tx) ReadWrite() *StatusCmd + func (c Tx) Rename(key, newkey string) *StatusCmd + func (c Tx) RenameNX(key, newkey string) *BoolCmd + func (c Tx) Restore(key string, ttl time.Duration, value string) *StatusCmd + func (c Tx) RestoreReplace(key string, ttl time.Duration, value string) *StatusCmd + func (c Tx) SAdd(key string, members ...interface{}) *IntCmd + func (c Tx) SCard(key string) *IntCmd + func (c Tx) SDiff(keys ...string) *StringSliceCmd + func (c Tx) SDiffStore(destination string, keys ...string) *IntCmd + func (c Tx) SInter(keys ...string) *StringSliceCmd + func (c Tx) SInterStore(destination string, keys ...string) *IntCmd + func (c Tx) SIsMember(key string, member interface{}) *BoolCmd + func (c Tx) SMembers(key string) *StringSliceCmd + func (c Tx) SMembersMap(key string) *StringStructMapCmd + func (c Tx) SMove(source, destination string, member interface{}) *BoolCmd + func (c Tx) SPop(key string) *StringCmd + func (c Tx) SPopN(key string, count int64) *StringSliceCmd + func (c Tx) SRandMember(key string) *StringCmd + func (c Tx) SRandMemberN(key string, count int64) *StringSliceCmd + func (c Tx) SRem(key string, members ...interface{}) *IntCmd + func (c Tx) SScan(key string, cursor uint64, match string, count int64) *ScanCmd + func (c Tx) SUnion(keys ...string) *StringSliceCmd + func (c Tx) SUnionStore(destination string, keys ...string) *IntCmd + func (c Tx) Save() *StatusCmd + func (c Tx) Scan(cursor uint64, match string, count int64) *ScanCmd + func (c Tx) ScriptExists(hashes ...string) *BoolSliceCmd + func (c Tx) ScriptFlush() *StatusCmd + func (c Tx) ScriptKill() *StatusCmd + func (c Tx) ScriptLoad(script string) *StringCmd + func (c Tx) Select(index int) *StatusCmd + func (c Tx) Set(key string, value interface{}, expiration time.Duration) *StatusCmd + func (c Tx) SetBit(key string, offset int64, value int) *IntCmd + func (c Tx) SetNX(key string, value interface{}, expiration time.Duration) *BoolCmd + func (c Tx) SetRange(key string, offset int64, value string) *IntCmd + func (c Tx) SetXX(key string, value interface{}, expiration time.Duration) *BoolCmd + func (c Tx) Shutdown() *StatusCmd + func (c Tx) ShutdownNoSave() *StatusCmd + func (c Tx) ShutdownSave() *StatusCmd + func (c Tx) SlaveOf(host, port string) *StatusCmd + func (c Tx) SlowLog() + func (c Tx) Sort(key string, sort *Sort) *StringSliceCmd + func (c Tx) SortInterfaces(key string, sort *Sort) *SliceCmd + func (c Tx) SortStore(key, store string, sort *Sort) *IntCmd + func (c Tx) StrLen(key string) *IntCmd + func (c Tx) SwapDB(index1, index2 int) *StatusCmd + func (c Tx) Sync() + func (c Tx) TTL(key string) *DurationCmd + func (c Tx) Time() *TimeCmd + func (c Tx) Touch(keys ...string) *IntCmd + func (c Tx) Type(key string) *StatusCmd + func (c Tx) Unlink(keys ...string) *IntCmd + func (c Tx) Wait(numSlaves int, timeout time.Duration) *IntCmd + func (c Tx) XAck(stream, group string, ids ...string) *IntCmd + func (c Tx) XAdd(a *XAddArgs) *StringCmd + func (c Tx) XClaim(a *XClaimArgs) *XMessageSliceCmd + func (c Tx) XClaimJustID(a *XClaimArgs) *StringSliceCmd + func (c Tx) XDel(stream string, ids ...string) *IntCmd + func (c Tx) XGroupCreate(stream, group, start string) *StatusCmd + func (c Tx) XGroupCreateMkStream(stream, group, start string) *StatusCmd + func (c Tx) XGroupDelConsumer(stream, group, consumer string) *IntCmd + func (c Tx) XGroupDestroy(stream, group string) *IntCmd + func (c Tx) XGroupSetID(stream, group, start string) *StatusCmd + func (c Tx) XInfoGroups(key string) *XInfoGroupsCmd + func (c Tx) XLen(stream string) *IntCmd + func (c Tx) XPending(stream, group string) *XPendingCmd + func (c Tx) XPendingExt(a *XPendingExtArgs) *XPendingExtCmd + func (c Tx) XRange(stream, start, stop string) *XMessageSliceCmd + func (c Tx) XRangeN(stream, start, stop string, count int64) *XMessageSliceCmd + func (c Tx) XRead(a *XReadArgs) *XStreamSliceCmd + func (c Tx) XReadGroup(a *XReadGroupArgs) *XStreamSliceCmd + func (c Tx) XReadStreams(streams ...string) *XStreamSliceCmd + func (c Tx) XRevRange(stream, start, stop string) *XMessageSliceCmd + func (c Tx) XRevRangeN(stream, start, stop string, count int64) *XMessageSliceCmd + func (c Tx) XTrim(key string, maxLen int64) *IntCmd + func (c Tx) XTrimApprox(key string, maxLen int64) *IntCmd + func (c Tx) ZAdd(key string, members ...*Z) *IntCmd + func (c Tx) ZAddCh(key string, members ...*Z) *IntCmd + func (c Tx) ZAddNX(key string, members ...*Z) *IntCmd + func (c Tx) ZAddNXCh(key string, members ...*Z) *IntCmd + func (c Tx) ZAddXX(key string, members ...*Z) *IntCmd + func (c Tx) ZAddXXCh(key string, members ...*Z) *IntCmd + func (c Tx) ZCard(key string) *IntCmd + func (c Tx) ZCount(key, min, max string) *IntCmd + func (c Tx) ZIncr(key string, member *Z) *FloatCmd + func (c Tx) ZIncrBy(key string, increment float64, member string) *FloatCmd + func (c Tx) ZIncrNX(key string, member *Z) *FloatCmd + func (c Tx) ZIncrXX(key string, member *Z) *FloatCmd + func (c Tx) ZInterStore(destination string, store *ZStore) *IntCmd + func (c Tx) ZLexCount(key, min, max string) *IntCmd + func (c Tx) ZPopMax(key string, count ...int64) *ZSliceCmd + func (c Tx) ZPopMin(key string, count ...int64) *ZSliceCmd + func (c Tx) ZRange(key string, start, stop int64) *StringSliceCmd + func (c Tx) ZRangeByLex(key string, opt *ZRangeBy) *StringSliceCmd + func (c Tx) ZRangeByScore(key string, opt *ZRangeBy) *StringSliceCmd + func (c Tx) ZRangeByScoreWithScores(key string, opt *ZRangeBy) *ZSliceCmd + func (c Tx) ZRangeWithScores(key string, start, stop int64) *ZSliceCmd + func (c Tx) ZRank(key, member string) *IntCmd + func (c Tx) ZRem(key string, members ...interface{}) *IntCmd + func (c Tx) ZRemRangeByLex(key, min, max string) *IntCmd + func (c Tx) ZRemRangeByRank(key string, start, stop int64) *IntCmd + func (c Tx) ZRemRangeByScore(key, min, max string) *IntCmd + func (c Tx) ZRevRange(key string, start, stop int64) *StringSliceCmd + func (c Tx) ZRevRangeByLex(key string, opt *ZRangeBy) *StringSliceCmd + func (c Tx) ZRevRangeByScore(key string, opt *ZRangeBy) *StringSliceCmd + func (c Tx) ZRevRangeByScoreWithScores(key string, opt *ZRangeBy) *ZSliceCmd + func (c Tx) ZRevRangeWithScores(key string, start, stop int64) *ZSliceCmd + func (c Tx) ZRevRank(key, member string) *IntCmd + func (c Tx) ZScan(key string, cursor uint64, match string, count int64) *ScanCmd + func (c Tx) ZScore(key, member string) *FloatCmd + func (c Tx) ZUnionStore(dest string, store *ZStore) *IntCmd + func (hs *Tx) AddHook(hook Hook) + type UniversalClient interface + AddHook func(Hook) + Close func() error + Context func() context.Context + Do func(args ...interface{}) *Cmd + DoContext func(ctx context.Context, args ...interface{}) *Cmd + PSubscribe func(channels ...string) *PubSub + Process func(cmd Cmder) error + ProcessContext func(ctx context.Context, cmd Cmder) error + Subscribe func(channels ...string) *PubSub + Watch func(fn func(*Tx) error, keys ...string) error + func NewUniversalClient(opts *UniversalOptions) UniversalClient + type UniversalOptions struct + Addrs []string + DB int + DialTimeout time.Duration + Dialer func(ctx context.Context, network, addr string) (net.Conn, error) + IdleCheckFrequency time.Duration + IdleTimeout time.Duration + MasterName string + MaxConnAge time.Duration + MaxRedirects int + MaxRetries int + MaxRetryBackoff time.Duration + MinIdleConns int + MinRetryBackoff time.Duration + OnConnect func(*Conn) error + Password string + PoolSize int + PoolTimeout time.Duration + ReadOnly bool + ReadTimeout time.Duration + RouteByLatency bool + RouteRandomly bool + TLSConfig *tls.Config + Username string + WriteTimeout time.Duration + func (o *UniversalOptions) Cluster() *ClusterOptions + func (o *UniversalOptions) Failover() *FailoverOptions + func (o *UniversalOptions) Simple() *Options + type XAddArgs struct + ID string + MaxLen int64 + MaxLenApprox int64 + Stream string + Values map[string]interface{} + type XClaimArgs struct + Consumer string + Group string + Messages []string + MinIdle time.Duration + Stream string + type XInfoGroups struct + Consumers int64 + LastDeliveredID string + Name string + Pending int64 + type XInfoGroupsCmd struct + func NewXInfoGroupsCmd(stream string) *XInfoGroupsCmd + func (cmd *XInfoGroupsCmd) Args() []interface{} + func (cmd *XInfoGroupsCmd) Err() error + func (cmd *XInfoGroupsCmd) Name() string + func (cmd *XInfoGroupsCmd) Result() ([]XInfoGroups, error) + func (cmd *XInfoGroupsCmd) SetErr(e error) + func (cmd *XInfoGroupsCmd) String() string + func (cmd *XInfoGroupsCmd) Val() []XInfoGroups + type XMessage struct + ID string + Values map[string]interface{} + type XMessageSliceCmd struct + func NewXMessageSliceCmd(args ...interface{}) *XMessageSliceCmd + func NewXMessageSliceCmdResult(val []XMessage, err error) *XMessageSliceCmd + func (cmd *XMessageSliceCmd) Args() []interface{} + func (cmd *XMessageSliceCmd) Err() error + func (cmd *XMessageSliceCmd) Name() string + func (cmd *XMessageSliceCmd) Result() ([]XMessage, error) + func (cmd *XMessageSliceCmd) SetErr(e error) + func (cmd *XMessageSliceCmd) String() string + func (cmd *XMessageSliceCmd) Val() []XMessage + type XPending struct + Consumers map[string]int64 + Count int64 + Higher string + Lower string + type XPendingCmd struct + func NewXPendingCmd(args ...interface{}) *XPendingCmd + func (cmd *XPendingCmd) Args() []interface{} + func (cmd *XPendingCmd) Err() error + func (cmd *XPendingCmd) Name() string + func (cmd *XPendingCmd) Result() (*XPending, error) + func (cmd *XPendingCmd) SetErr(e error) + func (cmd *XPendingCmd) String() string + func (cmd *XPendingCmd) Val() *XPending + type XPendingExt struct + Consumer string + ID string + Idle time.Duration + RetryCount int64 + type XPendingExtArgs struct + Consumer string + Count int64 + End string + Group string + Start string + Stream string + type XPendingExtCmd struct + func NewXPendingExtCmd(args ...interface{}) *XPendingExtCmd + func (cmd *XPendingExtCmd) Args() []interface{} + func (cmd *XPendingExtCmd) Err() error + func (cmd *XPendingExtCmd) Name() string + func (cmd *XPendingExtCmd) Result() ([]XPendingExt, error) + func (cmd *XPendingExtCmd) SetErr(e error) + func (cmd *XPendingExtCmd) String() string + func (cmd *XPendingExtCmd) Val() []XPendingExt + type XReadArgs struct + Block time.Duration + Count int64 + Streams []string + type XReadGroupArgs struct + Block time.Duration + Consumer string + Count int64 + Group string + NoAck bool + Streams []string + type XStream struct + Messages []XMessage + Stream string + type XStreamSliceCmd struct + func NewXStreamSliceCmd(args ...interface{}) *XStreamSliceCmd + func NewXStreamSliceCmdResult(val []XStream, err error) *XStreamSliceCmd + func (cmd *XStreamSliceCmd) Args() []interface{} + func (cmd *XStreamSliceCmd) Err() error + func (cmd *XStreamSliceCmd) Name() string + func (cmd *XStreamSliceCmd) Result() ([]XStream, error) + func (cmd *XStreamSliceCmd) SetErr(e error) + func (cmd *XStreamSliceCmd) String() string + func (cmd *XStreamSliceCmd) Val() []XStream + type Z struct + Member interface{} + Score float64 + type ZRangeBy struct + Count int64 + Max string + Min string + Offset int64 + type ZSliceCmd struct + func NewZSliceCmd(args ...interface{}) *ZSliceCmd + func NewZSliceCmdResult(val []Z, err error) *ZSliceCmd + func (cmd *ZSliceCmd) Args() []interface{} + func (cmd *ZSliceCmd) Err() error + func (cmd *ZSliceCmd) Name() string + func (cmd *ZSliceCmd) Result() ([]Z, error) + func (cmd *ZSliceCmd) SetErr(e error) + func (cmd *ZSliceCmd) String() string + func (cmd *ZSliceCmd) Val() []Z + type ZStore struct + Aggregate string + Keys []string + Weights []float64 + type ZWithKey struct + Key string + type ZWithKeyCmd struct + func NewZWithKeyCmd(args ...interface{}) *ZWithKeyCmd + func NewZWithKeyCmdResult(val *ZWithKey, err error) *ZWithKeyCmd + func (cmd *ZWithKeyCmd) Args() []interface{} + func (cmd *ZWithKeyCmd) Err() error + func (cmd *ZWithKeyCmd) Name() string + func (cmd *ZWithKeyCmd) Result() (*ZWithKey, error) + func (cmd *ZWithKeyCmd) SetErr(e error) + func (cmd *ZWithKeyCmd) String() string + func (cmd *ZWithKeyCmd) Val() *ZWithKey Other modules containing this package github.com/CPTSLLC/redis
Go to main page