Versions in this module Expand all Collapse all v1 v1.0.0 Nov 29, 2023 Changes in this version + const Nil + const TxFailedErr + func SetLogger(logger *log.Logger) + 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) 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) String() string + func (cmd *BoolSliceCmd) Val() []bool + type Client struct + func NewClient(opt *Options) *Client + func NewFailoverClient(failoverOpt *FailoverOptions) *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) BgRewriteAOF() *StatusCmd + func (c *Client) BgSave() *StatusCmd + func (c *Client) BitCount(key string, bitCount *BitCount) *IntCmd + 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) ClientKill(ipPort string) *StatusCmd + func (c *Client) ClientList() *StringCmd + func (c *Client) ClientPause(dur time.Duration) *BoolCmd + 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) 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) Context() context.Context + 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) FlushDb() *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) GeoRadiusByMemberRO(key, member string, query *GeoRadiusQuery) *GeoLocationCmd + func (c *Client) GeoRadiusRO(key string, longitude, latitude float64, query *GeoRadiusQuery) *GeoLocationCmd + 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, fields map[string]interface{}) *StatusCmd + func (c *Client) HScan(key string, cursor uint64, match string, count int64) *ScanCmd + func (c *Client) HSet(key, field string, value interface{}) *BoolCmd + 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, value 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(pairs ...interface{}) *StatusCmd + func (c *Client) MSetNX(pairs ...interface{}) *BoolCmd + func (c *Client) Migrate(host, port, key string, db int64, timeout time.Duration) *StatusCmd + func (c *Client) Move(key string, db int64) *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) Options() *Options + 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) PSubscribe(channels ...string) *PubSub + func (c *Client) PTTL(key string) *DurationCmd + func (c *Client) Persist(key string) *BoolCmd + func (c *Client) Ping() *StatusCmd + 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) 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, value 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) Subscribe(channels ...string) *PubSub + 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) TxPipeline() Pipeliner + func (c *Client) TxPipelined(fn func(Pipeliner) error) ([]Cmder, error) + 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) Watch(fn func(*Tx) error, keys ...string) error + func (c *Client) WithContext(ctx context.Context) *Client + func (c *Client) WrapProcess(fn func(oldProcess func(cmd Cmder) error) func(cmd Cmder) error) + func (c *Client) WrapProcessPipeline(fn func(oldProcess func([]Cmder) error) func([]Cmder) error) + 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, keys ...string) *IntCmd + func (c *Client) ZLexCount(key, min, max string) *IntCmd + 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, keys ...string) *IntCmd + type ClusterClient struct + func NewClusterClient(opt *ClusterOptions) *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) BgRewriteAOF() *StatusCmd + func (c *ClusterClient) BgSave() *StatusCmd + func (c *ClusterClient) BitCount(key string, bitCount *BitCount) *IntCmd + 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) ClientKill(ipPort string) *StatusCmd + func (c *ClusterClient) ClientList() *StringCmd + func (c *ClusterClient) ClientPause(dur time.Duration) *BoolCmd + func (c *ClusterClient) Close() error + 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) 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) Context() context.Context + func (c *ClusterClient) DBSize() *IntCmd + 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) FlushDb() *StatusCmd + 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) 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) GeoRadiusByMemberRO(key, member string, query *GeoRadiusQuery) *GeoLocationCmd + func (c *ClusterClient) GeoRadiusRO(key string, longitude, latitude float64, query *GeoRadiusQuery) *GeoLocationCmd + 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, fields map[string]interface{}) *StatusCmd + func (c *ClusterClient) HScan(key string, cursor uint64, match string, count int64) *ScanCmd + func (c *ClusterClient) HSet(key, field string, value interface{}) *BoolCmd + 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, value 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(pairs ...interface{}) *StatusCmd + func (c *ClusterClient) MSetNX(pairs ...interface{}) *BoolCmd + func (c *ClusterClient) Migrate(host, port, key string, db int64, timeout time.Duration) *StatusCmd + func (c *ClusterClient) Move(key string, db int64) *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) Options() *ClusterOptions + 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) PSubscribe(channels ...string) *PubSub + func (c *ClusterClient) PTTL(key string) *DurationCmd + func (c *ClusterClient) Persist(key string) *BoolCmd + func (c *ClusterClient) Ping() *StatusCmd + 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) 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, value 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) Subscribe(channels ...string) *PubSub + 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) TxPipeline() Pipeliner + func (c *ClusterClient) TxPipelined(fn func(Pipeliner) error) ([]Cmder, error) + 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) Watch(fn func(*Tx) error, keys ...string) error + func (c *ClusterClient) WithContext(ctx context.Context) *ClusterClient + func (c *ClusterClient) WrapProcess(fn func(oldProcess func(Cmder) error) func(Cmder) error) + func (c *ClusterClient) WrapProcessPipeline(fn func(oldProcess func([]Cmder) error) func([]Cmder) error) + 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, keys ...string) *IntCmd + func (c *ClusterClient) ZLexCount(key, min, max string) *IntCmd + 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, keys ...string) *IntCmd + type ClusterNode struct + Addr string + Id string + type ClusterOptions struct + Addrs []string + Context context.Context + DialTimeout time.Duration + IdleCheckFrequency time.Duration + IdleTimeout time.Duration + MaxRedirects int + MaxRetries int + MaxRetryBackoff time.Duration + 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 + 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) 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) Err() error + func (cmd *Cmd) Name() string + func (cmd *Cmd) Result() (interface{}, error) + func (cmd *Cmd) String() string + 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 + BgRewriteAOF func() *StatusCmd + BgSave func() *StatusCmd + BitCount func(key string, bitCount *BitCount) *IntCmd + 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 + ClientKill func(ipPort string) *StatusCmd + 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 + 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 + GeoRadiusByMemberRO func(key, member string, query *GeoRadiusQuery) *GeoLocationCmd + GeoRadiusRO func(key string, longitude, latitude float64, query *GeoRadiusQuery) *GeoLocationCmd + 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, fields map[string]interface{}) *StatusCmd + HScan func(key string, cursor uint64, match string, count int64) *ScanCmd + HSet func(key, field string, value interface{}) *BoolCmd + 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, value 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(pairs ...interface{}) *StatusCmd + MSetNX func(pairs ...interface{}) *BoolCmd + Migrate func(host, port, key string, db int64, timeout time.Duration) *StatusCmd + Move func(key string, db int64) *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, value 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 + 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, keys ...string) *IntCmd + ZLexCount func(key, min, max string) *IntCmd + 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, keys ...string) *IntCmd + type Cmder interface + Args func() []interface{} + Err func() error + Name 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) String() string + func (cmd *CommandsInfoCmd) Val() map[string]*CommandInfo + type Conn struct + func (c *Conn) Auth(password string) *StatusCmd + func (c *Conn) ClientSetName(name string) *BoolCmd + func (c *Conn) Close() error + 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) Select(index int) *StatusCmd + func (c *Conn) String() string + func (c *Conn) SwapDB(index1, index2 int) *StatusCmd + func (c *Conn) TxPipeline() Pipeliner + func (c *Conn) TxPipelined(fn func(Pipeliner) error) ([]Cmder, error) + func (c *Conn) WrapProcess(fn func(oldProcess func(cmd Cmder) error) func(cmd Cmder) error) + func (c *Conn) WrapProcessPipeline(fn func(oldProcess func([]Cmder) error) func([]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) String() string + func (cmd *DurationCmd) Val() time.Duration + type FailoverOptions struct + DB int + DialTimeout time.Duration + IdleCheckFrequency time.Duration + IdleTimeout time.Duration + MasterName string + MaxRetries int + OnConnect func(*Conn) error + Password string + PoolSize int + PoolTimeout time.Duration + ReadTimeout time.Duration + SentinelAddrs []string + TLSConfig *tls.Config + 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) 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) String() string + func (cmd *GeoLocationCmd) Val() []GeoLocation + type GeoPos struct + Latitude float64 + Longitude float64 + type GeoPosCmd struct + func NewGeoPosCmd(args ...interface{}) *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) 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 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) String() string + func (cmd *IntCmd) Val() int64 + type Message struct + Channel string + Pattern string + Payload string + func (m *Message) String() string + type Options struct + Addr string + Context context.Context + DB int + DialTimeout time.Duration + Dialer func() (net.Conn, error) + IdleCheckFrequency time.Duration + IdleTimeout time.Duration + MaxRetries int + MaxRetryBackoff time.Duration + MinRetryBackoff time.Duration + Network string + OnConnect func(*Conn) error + Password string + PoolSize int + PoolTimeout time.Duration + ReadTimeout time.Duration + TLSConfig *tls.Config + WriteTimeout time.Duration + func ParseURL(redisURL string) (*Options, error) + type Pipeline struct + func (c *Pipeline) Auth(password string) *StatusCmd + func (c *Pipeline) ClientSetName(name string) *BoolCmd + func (c *Pipeline) Close() error + func (c *Pipeline) Discard() error + func (c *Pipeline) Exec() ([]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) Select(index int) *StatusCmd + func (c *Pipeline) SwapDB(index1, index2 int) *StatusCmd + func (c *Pipeline) TxPipeline() Pipeliner + func (c *Pipeline) TxPipelined(fn func(Pipeliner) error) ([]Cmder, error) + type Pipeliner interface + Close func() error + Discard func() error + Exec func() ([]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) 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) Subscribe(channels ...string) error + func (c *PubSub) Unsubscribe(channels ...string) error + type Ring struct + func NewRing(opt *RingOptions) *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) BgRewriteAOF() *StatusCmd + func (c *Ring) BgSave() *StatusCmd + func (c *Ring) BitCount(key string, bitCount *BitCount) *IntCmd + 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) ClientKill(ipPort string) *StatusCmd + func (c *Ring) ClientList() *StringCmd + func (c *Ring) ClientPause(dur time.Duration) *BoolCmd + func (c *Ring) Close() error + 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) 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) Context() context.Context + 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) FlushDb() *StatusCmd + func (c *Ring) ForEachShard(fn func(client *Client) error) error + 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) GeoRadiusByMemberRO(key, member string, query *GeoRadiusQuery) *GeoLocationCmd + func (c *Ring) GeoRadiusRO(key string, longitude, latitude float64, query *GeoRadiusQuery) *GeoLocationCmd + 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, fields map[string]interface{}) *StatusCmd + func (c *Ring) HScan(key string, cursor uint64, match string, count int64) *ScanCmd + func (c *Ring) HSet(key, field string, value interface{}) *BoolCmd + 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, value 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(pairs ...interface{}) *StatusCmd + func (c *Ring) MSetNX(pairs ...interface{}) *BoolCmd + func (c *Ring) Migrate(host, port, key string, db int64, timeout time.Duration) *StatusCmd + func (c *Ring) Move(key string, db int64) *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) Options() *RingOptions + 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) PSubscribe(channels ...string) *PubSub + func (c *Ring) PTTL(key string) *DurationCmd + func (c *Ring) Persist(key string) *BoolCmd + func (c *Ring) Ping() *StatusCmd + 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) 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, value 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) Subscribe(channels ...string) *PubSub + 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) TxPipeline() Pipeliner + func (c *Ring) TxPipelined(fn func(Pipeliner) error) ([]Cmder, error) + 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) WithContext(ctx context.Context) *Ring + func (c *Ring) WrapProcess(fn func(oldProcess func(cmd Cmder) error) func(cmd Cmder) error) + func (c *Ring) WrapProcessPipeline(fn func(oldProcess func([]Cmder) error) func([]Cmder) error) + 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, keys ...string) *IntCmd + func (c *Ring) ZLexCount(key, min, max string) *IntCmd + 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, keys ...string) *IntCmd + type RingOptions struct + Addrs map[string]string + DB int + DialTimeout time.Duration + HeartbeatFrequency time.Duration + IdleCheckFrequency time.Duration + IdleTimeout time.Duration + MaxRetries int + MaxRetryBackoff time.Duration + MinRetryBackoff time.Duration + OnConnect func(*Conn) error + Password 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) 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 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) 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 + 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) 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) Float64() (float64, 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) String() string + 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) 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) 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) 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) 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 (cmd *TimeCmd) Args() []interface{} + func (cmd *TimeCmd) Err() error + func (cmd *TimeCmd) Name() string + func (cmd *TimeCmd) Result() (time.Time, error) + func (cmd *TimeCmd) String() string + func (cmd *TimeCmd) Val() time.Time + type Tx struct + func (c *Tx) Auth(password string) *StatusCmd + func (c *Tx) ClientSetName(name string) *BoolCmd + func (c *Tx) Close() error + 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) Select(index int) *StatusCmd + func (c *Tx) String() string + func (c *Tx) SwapDB(index1, index2 int) *StatusCmd + 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) WrapProcess(fn func(oldProcess func(cmd Cmder) error) func(cmd Cmder) error) + func (c *Tx) WrapProcessPipeline(fn func(oldProcess func([]Cmder) error) func([]Cmder) error) + type UniversalClient interface + Close func() error + PSubscribe func(channels ...string) *PubSub + Process func(cmd Cmder) error + Subscribe func(channels ...string) *PubSub + Watch func(fn func(*Tx) error, keys ...string) error + WrapProcess func(fn func(oldProcess func(cmd Cmder) error) func(cmd Cmder) error) + func NewUniversalClient(opts *UniversalOptions) UniversalClient + type UniversalOptions struct + Addrs []string + DB int + DialTimeout time.Duration + IdleCheckFrequency time.Duration + IdleTimeout time.Duration + MasterName string + MaxRedirects int + MaxRetries int + OnConnect func(*Conn) error + Password string + PoolSize int + PoolTimeout time.Duration + ReadOnly bool + ReadTimeout time.Duration + RouteByLatency bool + TLSConfig *tls.Config + WriteTimeout time.Duration + 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) String() string + func (cmd *ZSliceCmd) Val() []Z + type ZStore struct + Aggregate string + Weights []float64