Documentation ¶
Overview ¶
Package redis implements a Redis client.
Example (CustomCommand) ¶
Get := func(client *redis.Client, key string) *redis.StringCmd { cmd := redis.NewStringCmd("GET", key) client.Process(cmd) return cmd } v, err := Get(client, "key_does_not_exist").Result() fmt.Printf("%q %s", v, err)
Output: "" redis: nil
Example (Instrumentation) ¶
package main import ( "fmt" "sync/atomic" "time" redis "gopkg.in/redis.v5" ) func main() { ring := redis.NewRing(&redis.RingOptions{ Addrs: map[string]string{ "shard1": ":6379", }, }) ring.ForEachShard(func(client *redis.Client) error { wrapRedisProcess(client) return nil }) for { ring.Ping() } } func wrapRedisProcess(client *redis.Client) { const precision = time.Microsecond var count, avgDur uint32 go func() { for _ = range time.Tick(3 * time.Second) { n := atomic.LoadUint32(&count) dur := time.Duration(atomic.LoadUint32(&avgDur)) * precision fmt.Printf("%s: processed=%d avg_dur=%s\n", client, n, dur) } }() client.WrapProcess(func(oldProcess func(redis.Cmder) error) func(redis.Cmder) error { return func(cmd redis.Cmder) error { start := time.Now() err := oldProcess(cmd) dur := time.Since(start) const decay = float64(1) / 100 ms := float64(dur / precision) for { avg := atomic.LoadUint32(&avgDur) newAvg := uint32((1-decay)*float64(avg) + decay*ms) if atomic.CompareAndSwapUint32(&avgDur, avg, newAvg) { break } } atomic.AddUint32(&count, 1) return err } }) }
Output:
Index ¶
- Constants
- func SetLogger(logger *log.Logger)
- type BitCount
- type BoolCmd
- type BoolSliceCmd
- type 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) 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) ConfigSet(parameter, value string) *StatusCmd
- func (c *Client) Context() context.Context
- 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(key string) *BoolCmd
- func (c *Client) ExistsMulti(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) 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) 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]string) *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) 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, error)
- func (c *Client) PTTL(key string) *DurationCmd
- func (c *Client) Persist(key string) *BoolCmd
- func (c *Client) Ping() *StatusCmd
- func (c *Client) Pipeline() *Pipeline
- func (c *Client) Pipelined(fn func(*Pipeline) 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, message string) *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) 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) 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(scripts ...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) StrLen(key string) *IntCmd
- func (c *Client) String() string
- func (c *Client) Subscribe(channels ...string) (*PubSub, error)
- func (c *Client) Sync()
- func (c *Client) TTL(key string) *DurationCmd
- func (c *Client) Time() *TimeCmd
- func (c *Client) TxPipeline() *Pipeline
- func (c *Client) TxPipelined(fn func(*Pipeline) 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) 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) 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
- 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) 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) 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(key string) *BoolCmd
- func (c *ClusterClient) ExistsMulti(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) 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) 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) 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]string) *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) 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) Pipeline() *Pipeline
- func (c *ClusterClient) Pipelined(fn func(*Pipeline) 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, message string) *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) 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) 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(scripts ...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) StrLen(key string) *IntCmd
- func (c *ClusterClient) Sync()
- func (c *ClusterClient) TTL(key string) *DurationCmd
- func (c *ClusterClient) Time() *TimeCmd
- func (c *ClusterClient) TxPipeline() *Pipeline
- func (c *ClusterClient) TxPipelined(fn func(*Pipeline) 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) 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) 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
- type ClusterOptions
- type ClusterSlot
- type ClusterSlotsCmd
- type Cmd
- type Cmdable
- type Cmder
- type CommandInfo
- type CommandsInfoCmd
- type DurationCmd
- type FailoverOptions
- type FloatCmd
- type GeoLocation
- type GeoLocationCmd
- type GeoPos
- type GeoPosCmd
- type GeoRadiusQuery
- type IntCmd
- type Message
- type Options
- type Pipeline
- func (c *Pipeline) Append(key, value string) *IntCmd
- func (c *Pipeline) Auth(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) BgRewriteAOF() *StatusCmd
- func (c *Pipeline) BgSave() *StatusCmd
- func (c *Pipeline) BitCount(key string, bitCount *BitCount) *IntCmd
- 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) ClientKill(ipPort string) *StatusCmd
- func (c *Pipeline) ClientList() *StringCmd
- func (c *Pipeline) ClientPause(dur time.Duration) *BoolCmd
- func (c *Pipeline) ClientSetName(name string) *BoolCmd
- func (c *Pipeline) Close() error
- 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) 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) ConfigSet(parameter, value string) *StatusCmd
- 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) Discard() error
- 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) Exec() ([]Cmder, error)
- func (c *Pipeline) Exists(key string) *BoolCmd
- func (c *Pipeline) ExistsMulti(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) FlushDb() *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) 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, fields map[string]string) *StatusCmd
- func (c *Pipeline) HScan(key string, cursor uint64, match string, count int64) *ScanCmd
- func (c *Pipeline) HSet(key, field string, value interface{}) *BoolCmd
- 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, value 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(pairs ...interface{}) *StatusCmd
- func (c *Pipeline) MSetNX(pairs ...interface{}) *BoolCmd
- func (c *Pipeline) Migrate(host, port, key string, db int64, timeout time.Duration) *StatusCmd
- func (c *Pipeline) Move(key string, db int64) *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) Process(cmd Cmder) error
- func (c *Pipeline) PubSubChannels(pattern string) *StringSliceCmd
- func (c *Pipeline) PubSubNumPat() *IntCmd
- func (c *Pipeline) PubSubNumSub(channels ...string) *StringIntMapCmd
- func (c *Pipeline) Publish(channel, message string) *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, value 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) 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(scripts ...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) StrLen(key string) *IntCmd
- func (c *Pipeline) Sync()
- func (c *Pipeline) TTL(key string) *DurationCmd
- func (c *Pipeline) Time() *TimeCmd
- 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) 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, keys ...string) *IntCmd
- 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, keys ...string) *IntCmd
- type Pong
- type PoolStats
- type PubSub
- 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
- 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) 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) ConfigSet(parameter, value string) *StatusCmd
- 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(key string) *BoolCmd
- func (c *Ring) ExistsMulti(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) 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) 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]string) *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) 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) Pipeline() *Pipeline
- func (c *Ring) Pipelined(fn func(*Pipeline) 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, message string) *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) 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) 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(scripts ...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) StrLen(key string) *IntCmd
- func (c *Ring) Sync()
- func (c *Ring) TTL(key string) *DurationCmd
- func (c *Ring) Time() *TimeCmd
- 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) 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) 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
- type ScanCmd
- type ScanIterator
- type 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) Load(c scripter) *StringCmd
- func (s *Script) Run(c scripter, keys []string, args ...interface{}) *Cmd
- type SliceCmd
- type Sort
- type StatusCmd
- type StringCmd
- 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) 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
- type StringSliceCmd
- type StringStringMapCmd
- type Subscription
- type TimeCmd
- type Tx
- func (c *Tx) Append(key, value string) *IntCmd
- func (c *Tx) Auth(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) BgRewriteAOF() *StatusCmd
- func (c *Tx) BgSave() *StatusCmd
- func (c *Tx) BitCount(key string, bitCount *BitCount) *IntCmd
- 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) ClientKill(ipPort string) *StatusCmd
- func (c *Tx) ClientList() *StringCmd
- func (c *Tx) ClientPause(dur time.Duration) *BoolCmd
- func (c *Tx) ClientSetName(name string) *BoolCmd
- func (c *Tx) Close() error
- 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) 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) ConfigSet(parameter, value string) *StatusCmd
- 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(key string) *BoolCmd
- func (c *Tx) ExistsMulti(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) FlushDb() *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) 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, fields map[string]string) *StatusCmd
- func (c *Tx) HScan(key string, cursor uint64, match string, count int64) *ScanCmd
- func (c *Tx) HSet(key, field string, value interface{}) *BoolCmd
- 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, value 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(pairs ...interface{}) *StatusCmd
- func (c *Tx) MSetNX(pairs ...interface{}) *BoolCmd
- func (c *Tx) Migrate(host, port, key string, db int64, timeout time.Duration) *StatusCmd
- func (c *Tx) Move(key string, db int64) *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) Pipeline() *Pipeline
- func (c *Tx) Pipelined(fn func(*Pipeline) error) ([]Cmder, error)
- func (c *Tx) Process(cmd Cmder) error
- func (c *Tx) PubSubChannels(pattern string) *StringSliceCmd
- func (c *Tx) PubSubNumPat() *IntCmd
- func (c *Tx) PubSubNumSub(channels ...string) *StringIntMapCmd
- func (c *Tx) Publish(channel, message string) *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, value 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) 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(scripts ...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) StrLen(key string) *IntCmd
- func (c *Tx) String() string
- func (c *Tx) Sync()
- func (c *Tx) TTL(key string) *DurationCmd
- func (c *Tx) Time() *TimeCmd
- func (c *Tx) Type(key string) *StatusCmd
- func (c *Tx) Unlink(keys ...string) *IntCmd
- func (c *Tx) Unwatch(keys ...string) *StatusCmd
- func (c *Tx) Wait(numSlaves int, timeout time.Duration) *IntCmd
- 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) 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, keys ...string) *IntCmd
- 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, keys ...string) *IntCmd
- type Z
- type ZRangeBy
- type ZSliceCmd
- type ZStore
Examples ¶
Constants ¶
const Nil = internal.Nil
Redis nil reply, .e.g. when key does not exist.
const TxFailedErr = internal.RedisError("redis: transaction failed")
Redis transaction failed.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type BoolCmd ¶
type BoolCmd struct {
// contains filtered or unexported fields
}
func NewBoolCmd ¶
func NewBoolCmd(args ...interface{}) *BoolCmd
func NewBoolResult ¶
NewBoolResult returns a BoolCmd initalised with val and err for testing
type BoolSliceCmd ¶
type BoolSliceCmd struct {
// contains filtered or unexported fields
}
func NewBoolSliceCmd ¶
func NewBoolSliceCmd(args ...interface{}) *BoolSliceCmd
func NewBoolSliceResult ¶
func NewBoolSliceResult(val []bool, err error) *BoolSliceCmd
NewBoolSliceResult returns a BoolSliceCmd initalised with val and err for testing
func (*BoolSliceCmd) Result ¶
func (cmd *BoolSliceCmd) Result() ([]bool, error)
func (*BoolSliceCmd) String ¶
func (cmd *BoolSliceCmd) String() string
func (*BoolSliceCmd) Val ¶
func (cmd *BoolSliceCmd) Val() []bool
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client is a Redis client representing a pool of zero or more underlying connections. It's safe for concurrent use by multiple goroutines.
Example ¶
err := client.Set("key", "value", 0).Err() if err != nil { panic(err) } val, err := client.Get("key").Result() if err != nil { panic(err) } fmt.Println("key", val) val2, err := client.Get("key2").Result() if err == redis.Nil { fmt.Println("key2 does not exists") } else if err != nil { panic(err) } else { fmt.Println("key2", val2) }
Output: key value key2 does not exists
func NewClient ¶
NewClient returns a client to the Redis Server specified by Options.
Example ¶
client := redis.NewClient(&redis.Options{ Addr: "localhost:6379", Password: "", // no password set DB: 0, // use default DB }) pong, err := client.Ping().Result() fmt.Println(pong, err)
Output: PONG <nil>
func NewFailoverClient ¶
func NewFailoverClient(failoverOpt *FailoverOptions) *Client
NewFailoverClient returns a Redis client that uses Redis Sentinel for automatic failover. It's safe for concurrent use by multiple goroutines.
Example ¶
// See http://redis.io/topics/sentinel for instructions how to // setup Redis Sentinel. client := redis.NewFailoverClient(&redis.FailoverOptions{ MasterName: "master", SentinelAddrs: []string{":26379"}, }) client.Ping()
Output:
func (*Client) BLPop ¶
func (c *Client) BLPop(timeout time.Duration, keys ...string) *StringSliceCmd
Example ¶
if err := client.RPush("queue", "message").Err(); err != nil { panic(err) } // use `client.BLPop(0, "queue")` for infinite waiting time result, err := client.BLPop(1*time.Second, "queue").Result() if err != nil { panic(err) } fmt.Println(result[0], result[1])
Output: queue message
func (*Client) BRPop ¶
func (c *Client) BRPop(timeout time.Duration, keys ...string) *StringSliceCmd
func (*Client) BRPopLPush ¶
func (*Client) BgRewriteAOF ¶
func (c *Client) BgRewriteAOF() *StatusCmd
func (*Client) ClientKill ¶
func (*Client) ClientList ¶
func (c *Client) ClientList() *StringCmd
func (*Client) ClientPause ¶
func (*Client) Close ¶
func (c *Client) Close() error
Close closes the client, releasing any open resources.
It is rare to Close a Client, as the Client is meant to be long-lived and shared between many goroutines.
func (*Client) ClusterAddSlots ¶
func (*Client) ClusterAddSlotsRange ¶
func (*Client) ClusterCountFailureReports ¶
func (*Client) ClusterCountKeysInSlot ¶
func (*Client) ClusterDelSlots ¶
func (*Client) ClusterDelSlotsRange ¶
func (*Client) ClusterFailover ¶
func (c *Client) ClusterFailover() *StatusCmd
func (*Client) ClusterForget ¶
func (*Client) ClusterInfo ¶
func (c *Client) ClusterInfo() *StringCmd
func (*Client) ClusterKeySlot ¶
func (*Client) ClusterMeet ¶
func (*Client) ClusterNodes ¶
func (c *Client) ClusterNodes() *StringCmd
func (*Client) ClusterReplicate ¶
func (*Client) ClusterResetHard ¶
func (c *Client) ClusterResetHard() *StatusCmd
func (*Client) ClusterResetSoft ¶
func (c *Client) ClusterResetSoft() *StatusCmd
func (*Client) ClusterSaveConfig ¶
func (c *Client) ClusterSaveConfig() *StatusCmd
func (*Client) ClusterSlaves ¶
func (c *Client) ClusterSlaves(nodeID string) *StringSliceCmd
func (*Client) ClusterSlots ¶
func (c *Client) ClusterSlots() *ClusterSlotsCmd
func (*Client) Command ¶
func (c *Client) Command() *CommandsInfoCmd
func (*Client) ConfigResetStat ¶
func (c *Client) ConfigResetStat() *StatusCmd
func (*Client) DebugObject ¶
func (*Client) ExistsMulti ¶ added in v5.2.5
func (*Client) GeoAdd ¶
func (c *Client) GeoAdd(key string, geoLocation ...*GeoLocation) *IntCmd
func (*Client) GeoHash ¶
func (c *Client) GeoHash(key string, members ...string) *StringSliceCmd
func (*Client) GeoRadius ¶
func (c *Client) GeoRadius(key string, longitude, latitude float64, query *GeoRadiusQuery) *GeoLocationCmd
func (*Client) GeoRadiusByMember ¶
func (c *Client) GeoRadiusByMember(key, member string, query *GeoRadiusQuery) *GeoLocationCmd
func (*Client) HGetAll ¶
func (c *Client) HGetAll(key string) *StringStringMapCmd
func (*Client) HIncrByFloat ¶
func (*Client) HKeys ¶
func (c *Client) HKeys(key string) *StringSliceCmd
func (*Client) HVals ¶
func (c *Client) HVals(key string) *StringSliceCmd
func (*Client) Incr ¶
Example ¶
if err := client.Incr("counter").Err(); err != nil { panic(err) } n, err := client.Get("counter").Int64() fmt.Println(n, err)
Output: 1 <nil>
func (*Client) IncrByFloat ¶
func (*Client) Keys ¶
func (c *Client) Keys(pattern string) *StringSliceCmd
func (*Client) LInsertAfter ¶
func (*Client) LInsertBefore ¶
func (*Client) LRange ¶
func (c *Client) LRange(key string, start, stop int64) *StringSliceCmd
func (*Client) ObjectEncoding ¶
func (*Client) ObjectIdleTime ¶
func (c *Client) ObjectIdleTime(key string) *DurationCmd
func (*Client) ObjectRefCount ¶
func (*Client) PSubscribe ¶
PSubscribe subscribes the client to the given patterns.
func (*Client) PTTL ¶
func (c *Client) PTTL(key string) *DurationCmd
func (*Client) Pipeline ¶
Example ¶
pipe := client.Pipeline() incr := pipe.Incr("pipeline_counter") pipe.Expire("pipeline_counter", time.Hour) // Execute // // INCR pipeline_counter // EXPIRE pipeline_counts 3600 // // using one client-server roundtrip. _, err := pipe.Exec() fmt.Println(incr.Val(), err)
Output: 1 <nil>
func (*Client) Pipelined ¶
Example ¶
var incr *redis.IntCmd _, err := client.Pipelined(func(pipe *redis.Pipeline) error { incr = pipe.Incr("pipelined_counter") pipe.Expire("pipelined_counter", time.Hour) return nil }) fmt.Println(incr.Val(), err)
Output: 1 <nil>
func (*Client) PubSubChannels ¶
func (c *Client) PubSubChannels(pattern string) *StringSliceCmd
func (*Client) PubSubNumPat ¶
func (c *Client) PubSubNumPat() *IntCmd
func (*Client) PubSubNumSub ¶
func (c *Client) PubSubNumSub(channels ...string) *StringIntMapCmd
func (*Client) RestoreReplace ¶
func (*Client) SDiff ¶
func (c *Client) SDiff(keys ...string) *StringSliceCmd
func (*Client) SDiffStore ¶
func (*Client) SInter ¶
func (c *Client) SInter(keys ...string) *StringSliceCmd
func (*Client) SInterStore ¶
func (*Client) SMembers ¶
func (c *Client) SMembers(key string) *StringSliceCmd
func (*Client) SPopN ¶
func (c *Client) SPopN(key string, count int64) *StringSliceCmd
Redis `SPOP key count` command.
func (*Client) SRandMember ¶
Redis `SRANDMEMBER key` command.
func (*Client) SRandMemberN ¶
func (c *Client) SRandMemberN(key string, count int64) *StringSliceCmd
Redis `SRANDMEMBER key count` command.
func (*Client) SUnion ¶
func (c *Client) SUnion(keys ...string) *StringSliceCmd
func (*Client) SUnionStore ¶
func (*Client) Scan ¶
Example ¶
client.FlushDb() for i := 0; i < 33; i++ { err := client.Set(fmt.Sprintf("key%d", i), "value", 0).Err() if err != nil { panic(err) } } var cursor uint64 var n int for { var keys []string var err error keys, cursor, err = client.Scan(cursor, "", 10).Result() if err != nil { panic(err) } n += len(keys) if cursor == 0 { break } } fmt.Printf("found %d keys\n", n)
Output: found 33 keys
func (*Client) ScriptExists ¶
func (c *Client) ScriptExists(scripts ...string) *BoolSliceCmd
func (*Client) ScriptFlush ¶
func (c *Client) ScriptFlush() *StatusCmd
func (*Client) ScriptKill ¶
func (c *Client) ScriptKill() *StatusCmd
func (*Client) ScriptLoad ¶
func (*Client) Set ¶
Redis `SET key value [expiration]` command.
Use expiration for `SETEX`-like behavior. Zero expiration means the key has no expiration time.
Example ¶
// Last argument is expiration. Zero means the key has no // expiration time. err := client.Set("key", "value", 0).Err() if err != nil { panic(err) } // key2 will expire in an hour. err = client.Set("key2", "value", time.Hour).Err() if err != nil { panic(err) }
Output:
func (*Client) SetNX ¶
Redis `SET key value [expiration] NX` command.
Zero expiration means the key has no expiration time.
func (*Client) SetXX ¶
Redis `SET key value [expiration] XX` command.
Zero expiration means the key has no expiration time.
func (*Client) ShutdownNoSave ¶
func (c *Client) ShutdownNoSave() *StatusCmd
func (*Client) ShutdownSave ¶
func (c *Client) ShutdownSave() *StatusCmd
func (*Client) Sort ¶
func (c *Client) Sort(key string, sort Sort) *StringSliceCmd
func (*Client) SortInterfaces ¶
func (*Client) TTL ¶
func (c *Client) TTL(key string) *DurationCmd
func (*Client) TxPipeline ¶ added in v5.1.4
TxPipeline acts like Pipeline, but wraps queued commands with MULTI/EXEC.
Example ¶
pipe := client.TxPipeline() incr := pipe.Incr("tx_pipeline_counter") pipe.Expire("tx_pipeline_counter", time.Hour) // Execute // // MULTI // INCR pipeline_counter // EXPIRE pipeline_counts 3600 // EXEC // // using one client-server roundtrip. _, err := pipe.Exec() fmt.Println(incr.Val(), err)
Output: 1 <nil>
func (*Client) TxPipelined ¶ added in v5.1.4
Example ¶
var incr *redis.IntCmd _, err := client.TxPipelined(func(pipe *redis.Pipeline) error { incr = pipe.Incr("tx_pipelined_counter") pipe.Expire("tx_pipelined_counter", time.Hour) return nil }) fmt.Println(incr.Val(), err)
Output: 1 <nil>
func (*Client) Watch ¶
Example ¶
var incr func(string) error // Transactionally increments key using GET and SET commands. incr = func(key string) error { err := client.Watch(func(tx *redis.Tx) error { n, err := tx.Get(key).Int64() if err != nil && err != redis.Nil { return err } _, err = tx.Pipelined(func(pipe *redis.Pipeline) error { pipe.Set(key, strconv.FormatInt(n+1, 10), 0) return nil }) return err }, key) if err == redis.TxFailedErr { return incr(key) } return err } var wg sync.WaitGroup for i := 0; i < 100; i++ { wg.Add(1) go func() { defer wg.Done() err := incr("counter3") if err != nil { panic(err) } }() } wg.Wait() n, err := client.Get("counter3").Int64() fmt.Println(n, err)
Output: 100 <nil>
func (*Client) WithContext ¶ added in v5.2.2
func (*Client) WrapProcess ¶
WrapProcess replaces the process func. It takes a function createWrapper which is supplied by the user. createWrapper takes the old process func as an input and returns the new wrapper process func. createWrapper should use call the old process func within the new process func.
func (*Client) ZInterStore ¶
func (*Client) ZRange ¶
func (c *Client) ZRange(key string, start, stop int64) *StringSliceCmd
func (*Client) ZRangeByLex ¶
func (c *Client) ZRangeByLex(key string, opt ZRangeBy) *StringSliceCmd
func (*Client) ZRangeByScore ¶
func (c *Client) ZRangeByScore(key string, opt ZRangeBy) *StringSliceCmd
func (*Client) ZRangeByScoreWithScores ¶
func (*Client) ZRangeWithScores ¶
func (*Client) ZRemRangeByLex ¶ added in v5.2.3
func (*Client) ZRemRangeByRank ¶
func (*Client) ZRemRangeByScore ¶
func (*Client) ZRevRange ¶
func (c *Client) ZRevRange(key string, start, stop int64) *StringSliceCmd
func (*Client) ZRevRangeByLex ¶
func (c *Client) ZRevRangeByLex(key string, opt ZRangeBy) *StringSliceCmd
func (*Client) ZRevRangeByScore ¶
func (c *Client) ZRevRangeByScore(key string, opt ZRangeBy) *StringSliceCmd
func (*Client) ZRevRangeByScoreWithScores ¶
func (*Client) ZRevRangeWithScores ¶
type ClusterClient ¶
type ClusterClient struct {
// contains filtered or unexported fields
}
ClusterClient is a Redis Cluster client representing a pool of zero or more underlying connections. It's safe for concurrent use by multiple goroutines.
func NewClusterClient ¶
func NewClusterClient(opt *ClusterOptions) *ClusterClient
NewClusterClient returns a Redis Cluster client as described in http://redis.io/topics/cluster-spec.
Example ¶
// See http://redis.io/topics/cluster-tutorial for instructions // how to setup Redis Cluster. client := redis.NewClusterClient(&redis.ClusterOptions{ Addrs: []string{":7000", ":7001", ":7002", ":7003", ":7004", ":7005"}, }) client.Ping()
Output:
func (*ClusterClient) BLPop ¶
func (c *ClusterClient) BLPop(timeout time.Duration, keys ...string) *StringSliceCmd
func (*ClusterClient) BRPop ¶
func (c *ClusterClient) BRPop(timeout time.Duration, keys ...string) *StringSliceCmd
func (*ClusterClient) BRPopLPush ¶
func (*ClusterClient) BgRewriteAOF ¶
func (c *ClusterClient) BgRewriteAOF() *StatusCmd
func (*ClusterClient) ClientKill ¶
func (*ClusterClient) ClientList ¶
func (c *ClusterClient) ClientList() *StringCmd
func (*ClusterClient) ClientPause ¶
func (*ClusterClient) Close ¶
func (c *ClusterClient) Close() error
Close closes the cluster client, releasing any open resources.
It is rare to Close a ClusterClient, as the ClusterClient is meant to be long-lived and shared between many goroutines.
func (*ClusterClient) ClusterAddSlots ¶
func (*ClusterClient) ClusterAddSlotsRange ¶
func (*ClusterClient) ClusterCountFailureReports ¶
func (*ClusterClient) ClusterCountKeysInSlot ¶
func (*ClusterClient) ClusterDelSlots ¶
func (*ClusterClient) ClusterDelSlotsRange ¶
func (*ClusterClient) ClusterFailover ¶
func (c *ClusterClient) ClusterFailover() *StatusCmd
func (*ClusterClient) ClusterForget ¶
func (*ClusterClient) ClusterInfo ¶
func (c *ClusterClient) ClusterInfo() *StringCmd
func (*ClusterClient) ClusterKeySlot ¶
func (*ClusterClient) ClusterMeet ¶
func (*ClusterClient) ClusterNodes ¶
func (c *ClusterClient) ClusterNodes() *StringCmd
func (*ClusterClient) ClusterReplicate ¶
func (*ClusterClient) ClusterResetHard ¶
func (c *ClusterClient) ClusterResetHard() *StatusCmd
func (*ClusterClient) ClusterResetSoft ¶
func (c *ClusterClient) ClusterResetSoft() *StatusCmd
func (*ClusterClient) ClusterSaveConfig ¶
func (c *ClusterClient) ClusterSaveConfig() *StatusCmd
func (*ClusterClient) ClusterSlaves ¶
func (c *ClusterClient) ClusterSlaves(nodeID string) *StringSliceCmd
func (*ClusterClient) ClusterSlots ¶
func (c *ClusterClient) ClusterSlots() *ClusterSlotsCmd
func (*ClusterClient) Command ¶
func (c *ClusterClient) Command() *CommandsInfoCmd
func (*ClusterClient) ConfigResetStat ¶
func (c *ClusterClient) ConfigResetStat() *StatusCmd
func (*ClusterClient) DebugObject ¶
func (*ClusterClient) ExistsMulti ¶ added in v5.2.5
func (*ClusterClient) ForEachMaster ¶
func (c *ClusterClient) ForEachMaster(fn func(client *Client) error) error
ForEachMaster concurrently calls the fn on each master node in the cluster. It returns the first error if any.
func (*ClusterClient) ForEachNode ¶ added in v5.1.3
func (c *ClusterClient) ForEachNode(fn func(client *Client) error) error
ForEachNode concurrently calls the fn on each ever known node in the cluster. It returns the first error if any.
func (*ClusterClient) GeoAdd ¶
func (c *ClusterClient) GeoAdd(key string, geoLocation ...*GeoLocation) *IntCmd
func (*ClusterClient) GeoHash ¶
func (c *ClusterClient) GeoHash(key string, members ...string) *StringSliceCmd
func (*ClusterClient) GeoRadius ¶
func (c *ClusterClient) GeoRadius(key string, longitude, latitude float64, query *GeoRadiusQuery) *GeoLocationCmd
func (*ClusterClient) GeoRadiusByMember ¶
func (c *ClusterClient) GeoRadiusByMember(key, member string, query *GeoRadiusQuery) *GeoLocationCmd
func (*ClusterClient) HGetAll ¶
func (c *ClusterClient) HGetAll(key string) *StringStringMapCmd
func (*ClusterClient) HIncrByFloat ¶
func (*ClusterClient) HKeys ¶
func (c *ClusterClient) HKeys(key string) *StringSliceCmd
func (*ClusterClient) HVals ¶
func (c *ClusterClient) HVals(key string) *StringSliceCmd
func (*ClusterClient) IncrByFloat ¶
func (*ClusterClient) Keys ¶
func (c *ClusterClient) Keys(pattern string) *StringSliceCmd
func (*ClusterClient) LInsertAfter ¶
func (*ClusterClient) LInsertBefore ¶
func (*ClusterClient) LRange ¶
func (c *ClusterClient) LRange(key string, start, stop int64) *StringSliceCmd
func (*ClusterClient) ObjectEncoding ¶
func (*ClusterClient) ObjectIdleTime ¶
func (c *ClusterClient) ObjectIdleTime(key string) *DurationCmd
func (*ClusterClient) ObjectRefCount ¶
func (*ClusterClient) PTTL ¶
func (c *ClusterClient) PTTL(key string) *DurationCmd
func (*ClusterClient) Pipeline ¶
func (c *ClusterClient) Pipeline() *Pipeline
func (*ClusterClient) Pipelined ¶
func (c *ClusterClient) Pipelined(fn func(*Pipeline) error) ([]Cmder, error)
func (*ClusterClient) PoolStats ¶
func (c *ClusterClient) PoolStats() *PoolStats
PoolStats returns accumulated connection pool stats.
func (*ClusterClient) Process ¶
func (c *ClusterClient) Process(cmd Cmder) error
func (*ClusterClient) PubSubChannels ¶
func (c *ClusterClient) PubSubChannels(pattern string) *StringSliceCmd
func (*ClusterClient) PubSubNumPat ¶
func (c *ClusterClient) PubSubNumPat() *IntCmd
func (*ClusterClient) PubSubNumSub ¶
func (c *ClusterClient) PubSubNumSub(channels ...string) *StringIntMapCmd
func (*ClusterClient) RestoreReplace ¶
func (*ClusterClient) SDiff ¶
func (c *ClusterClient) SDiff(keys ...string) *StringSliceCmd
func (*ClusterClient) SDiffStore ¶
func (*ClusterClient) SInter ¶
func (c *ClusterClient) SInter(keys ...string) *StringSliceCmd
func (*ClusterClient) SInterStore ¶
func (*ClusterClient) SMembers ¶
func (c *ClusterClient) SMembers(key string) *StringSliceCmd
func (*ClusterClient) SPopN ¶
func (c *ClusterClient) SPopN(key string, count int64) *StringSliceCmd
Redis `SPOP key count` command.
func (*ClusterClient) SRandMember ¶
Redis `SRANDMEMBER key` command.
func (*ClusterClient) SRandMemberN ¶
func (c *ClusterClient) SRandMemberN(key string, count int64) *StringSliceCmd
Redis `SRANDMEMBER key count` command.
func (*ClusterClient) SUnion ¶
func (c *ClusterClient) SUnion(keys ...string) *StringSliceCmd
func (*ClusterClient) SUnionStore ¶
func (*ClusterClient) ScriptExists ¶
func (c *ClusterClient) ScriptExists(scripts ...string) *BoolSliceCmd
func (*ClusterClient) ScriptFlush ¶
func (c *ClusterClient) ScriptFlush() *StatusCmd
func (*ClusterClient) ScriptKill ¶
func (c *ClusterClient) ScriptKill() *StatusCmd
func (*ClusterClient) ScriptLoad ¶
func (*ClusterClient) Set ¶
Redis `SET key value [expiration]` command.
Use expiration for `SETEX`-like behavior. Zero expiration means the key has no expiration time.
func (*ClusterClient) SetNX ¶
Redis `SET key value [expiration] NX` command.
Zero expiration means the key has no expiration time.
func (*ClusterClient) SetXX ¶
Redis `SET key value [expiration] XX` command.
Zero expiration means the key has no expiration time.
func (*ClusterClient) ShutdownNoSave ¶
func (c *ClusterClient) ShutdownNoSave() *StatusCmd
func (*ClusterClient) ShutdownSave ¶
func (c *ClusterClient) ShutdownSave() *StatusCmd
func (*ClusterClient) Sort ¶
func (c *ClusterClient) Sort(key string, sort Sort) *StringSliceCmd
func (*ClusterClient) SortInterfaces ¶
func (*ClusterClient) TTL ¶
func (c *ClusterClient) TTL(key string) *DurationCmd
func (*ClusterClient) TxPipeline ¶ added in v5.1.4
func (c *ClusterClient) TxPipeline() *Pipeline
TxPipeline acts like Pipeline, but wraps queued commands with MULTI/EXEC.
func (*ClusterClient) TxPipelined ¶ added in v5.1.4
func (c *ClusterClient) TxPipelined(fn func(*Pipeline) error) ([]Cmder, error)
func (*ClusterClient) Watch ¶
func (c *ClusterClient) Watch(fn func(*Tx) error, keys ...string) error
func (*ClusterClient) ZInterStore ¶
func (*ClusterClient) ZRange ¶
func (c *ClusterClient) ZRange(key string, start, stop int64) *StringSliceCmd
func (*ClusterClient) ZRangeByLex ¶
func (c *ClusterClient) ZRangeByLex(key string, opt ZRangeBy) *StringSliceCmd
func (*ClusterClient) ZRangeByScore ¶
func (c *ClusterClient) ZRangeByScore(key string, opt ZRangeBy) *StringSliceCmd
func (*ClusterClient) ZRangeByScoreWithScores ¶
func (*ClusterClient) ZRangeWithScores ¶
func (*ClusterClient) ZRemRangeByLex ¶ added in v5.2.3
func (*ClusterClient) ZRemRangeByRank ¶
func (*ClusterClient) ZRemRangeByScore ¶
func (*ClusterClient) ZRevRange ¶
func (c *ClusterClient) ZRevRange(key string, start, stop int64) *StringSliceCmd
func (*ClusterClient) ZRevRangeByLex ¶
func (c *ClusterClient) ZRevRangeByLex(key string, opt ZRangeBy) *StringSliceCmd
func (*ClusterClient) ZRevRangeByScore ¶
func (c *ClusterClient) ZRevRangeByScore(key string, opt ZRangeBy) *StringSliceCmd
func (*ClusterClient) ZRevRangeByScoreWithScores ¶
func (*ClusterClient) ZRevRangeWithScores ¶
type ClusterNode ¶
type ClusterOptions ¶
type ClusterOptions struct { // A seed list of host:port addresses of cluster nodes. Addrs []string // The maximum number of retries before giving up. Command is retried // on network errors and MOVED/ASK redirects. // Default is 16. MaxRedirects int // Enables read queries for a connection to a Redis Cluster slave node. ReadOnly bool // Enables routing read-only queries to the closest master or slave node. RouteByLatency bool Password string DialTimeout time.Duration ReadTimeout time.Duration WriteTimeout time.Duration // PoolSize applies per cluster node and not for the whole cluster. PoolSize int PoolTimeout time.Duration IdleTimeout time.Duration IdleCheckFrequency time.Duration }
ClusterOptions are used to configure a cluster client and should be passed to NewClusterClient.
type ClusterSlot ¶
type ClusterSlot struct { Start int End int Nodes []ClusterNode }
type ClusterSlotsCmd ¶
type ClusterSlotsCmd struct {
// contains filtered or unexported fields
}
func NewClusterSlotsCmd ¶
func NewClusterSlotsCmd(args ...interface{}) *ClusterSlotsCmd
func NewClusterSlotsCmdResult ¶
func NewClusterSlotsCmdResult(val []ClusterSlot, err error) *ClusterSlotsCmd
NewClusterSlotsCmdResult returns a ClusterSlotsCmd initalised with val and err for testing
func (*ClusterSlotsCmd) Result ¶
func (cmd *ClusterSlotsCmd) Result() ([]ClusterSlot, error)
func (*ClusterSlotsCmd) String ¶
func (cmd *ClusterSlotsCmd) String() string
func (*ClusterSlotsCmd) Val ¶
func (cmd *ClusterSlotsCmd) Val() []ClusterSlot
type Cmd ¶
type Cmd struct {
// contains filtered or unexported fields
}
func NewCmdResult ¶
NewCmdResult returns a Cmd initalised with val and err for testing
type Cmdable ¶
type Cmdable interface { Pipeline() *Pipeline Pipelined(fn func(*Pipeline) error) ([]Cmder, error) Echo(message interface{}) *StringCmd Ping() *StatusCmd Quit() *StatusCmd Del(keys ...string) *IntCmd Unlink(keys ...string) *IntCmd Dump(key string) *StringCmd Exists(key string) *BoolCmd // TODO: merge with Exists in v6 ExistsMulti(keys ...string) *IntCmd Expire(key string, expiration time.Duration) *BoolCmd ExpireAt(key string, tm time.Time) *BoolCmd Keys(pattern string) *StringSliceCmd Migrate(host, port, key string, db int64, timeout time.Duration) *StatusCmd Move(key string, db int64) *BoolCmd ObjectRefCount(key string) *IntCmd ObjectEncoding(key string) *StringCmd ObjectIdleTime(key string) *DurationCmd Persist(key string) *BoolCmd PExpire(key string, expiration time.Duration) *BoolCmd PExpireAt(key string, tm time.Time) *BoolCmd PTTL(key string) *DurationCmd RandomKey() *StringCmd Rename(key, newkey string) *StatusCmd RenameNX(key, newkey string) *BoolCmd Restore(key string, ttl time.Duration, value string) *StatusCmd RestoreReplace(key string, ttl time.Duration, value string) *StatusCmd Sort(key string, sort Sort) *StringSliceCmd SortInterfaces(key string, sort Sort) *SliceCmd TTL(key string) *DurationCmd Type(key string) *StatusCmd Scan(cursor uint64, match string, count int64) *ScanCmd SScan(key string, cursor uint64, match string, count int64) *ScanCmd HScan(key string, cursor uint64, match string, count int64) *ScanCmd ZScan(key string, cursor uint64, match string, count int64) *ScanCmd Append(key, value string) *IntCmd BitCount(key string, bitCount *BitCount) *IntCmd BitOpAnd(destKey string, keys ...string) *IntCmd BitOpOr(destKey string, keys ...string) *IntCmd BitOpXor(destKey string, keys ...string) *IntCmd BitOpNot(destKey string, key string) *IntCmd BitPos(key string, bit int64, pos ...int64) *IntCmd Decr(key string) *IntCmd DecrBy(key string, decrement int64) *IntCmd Get(key string) *StringCmd GetBit(key string, offset int64) *IntCmd GetRange(key string, start, end int64) *StringCmd GetSet(key string, value interface{}) *StringCmd Incr(key string) *IntCmd IncrBy(key string, value int64) *IntCmd IncrByFloat(key string, value float64) *FloatCmd MGet(keys ...string) *SliceCmd MSet(pairs ...interface{}) *StatusCmd MSetNX(pairs ...interface{}) *BoolCmd Set(key string, value interface{}, expiration time.Duration) *StatusCmd SetBit(key string, offset int64, value int) *IntCmd SetNX(key string, value interface{}, expiration time.Duration) *BoolCmd SetXX(key string, value interface{}, expiration time.Duration) *BoolCmd SetRange(key string, offset int64, value string) *IntCmd StrLen(key string) *IntCmd HDel(key string, fields ...string) *IntCmd HExists(key, field string) *BoolCmd HGet(key, field string) *StringCmd HGetAll(key string) *StringStringMapCmd HIncrBy(key, field string, incr int64) *IntCmd HIncrByFloat(key, field string, incr float64) *FloatCmd HKeys(key string) *StringSliceCmd HLen(key string) *IntCmd HMGet(key string, fields ...string) *SliceCmd HMSet(key string, fields map[string]string) *StatusCmd HSet(key, field string, value interface{}) *BoolCmd HSetNX(key, field string, value interface{}) *BoolCmd HVals(key string) *StringSliceCmd BLPop(timeout time.Duration, keys ...string) *StringSliceCmd BRPop(timeout time.Duration, keys ...string) *StringSliceCmd BRPopLPush(source, destination string, timeout time.Duration) *StringCmd LIndex(key string, index int64) *StringCmd LInsert(key, op string, pivot, value interface{}) *IntCmd LInsertBefore(key string, pivot, value interface{}) *IntCmd LInsertAfter(key string, pivot, value interface{}) *IntCmd LLen(key string) *IntCmd LPop(key string) *StringCmd LPush(key string, values ...interface{}) *IntCmd LPushX(key string, value interface{}) *IntCmd LRange(key string, start, stop int64) *StringSliceCmd LRem(key string, count int64, value interface{}) *IntCmd LSet(key string, index int64, value interface{}) *StatusCmd LTrim(key string, start, stop int64) *StatusCmd RPop(key string) *StringCmd RPopLPush(source, destination string) *StringCmd RPush(key string, values ...interface{}) *IntCmd RPushX(key string, value interface{}) *IntCmd SAdd(key string, members ...interface{}) *IntCmd SCard(key string) *IntCmd SDiff(keys ...string) *StringSliceCmd SDiffStore(destination string, keys ...string) *IntCmd SInter(keys ...string) *StringSliceCmd SInterStore(destination string, keys ...string) *IntCmd SIsMember(key string, member interface{}) *BoolCmd SMembers(key string) *StringSliceCmd SMove(source, destination string, member interface{}) *BoolCmd SPop(key string) *StringCmd SPopN(key string, count int64) *StringSliceCmd SRandMember(key string) *StringCmd SRandMemberN(key string, count int64) *StringSliceCmd SRem(key string, members ...interface{}) *IntCmd SUnion(keys ...string) *StringSliceCmd SUnionStore(destination string, keys ...string) *IntCmd ZAdd(key string, members ...Z) *IntCmd ZAddNX(key string, members ...Z) *IntCmd ZAddXX(key string, members ...Z) *IntCmd ZAddCh(key string, members ...Z) *IntCmd ZAddNXCh(key string, members ...Z) *IntCmd ZAddXXCh(key string, members ...Z) *IntCmd ZIncr(key string, member Z) *FloatCmd ZIncrNX(key string, member Z) *FloatCmd ZIncrXX(key string, member Z) *FloatCmd ZCard(key string) *IntCmd ZCount(key, min, max string) *IntCmd ZIncrBy(key string, increment float64, member string) *FloatCmd ZInterStore(destination string, store ZStore, keys ...string) *IntCmd ZRange(key string, start, stop int64) *StringSliceCmd ZRangeWithScores(key string, start, stop int64) *ZSliceCmd ZRangeByScore(key string, opt ZRangeBy) *StringSliceCmd ZRangeByLex(key string, opt ZRangeBy) *StringSliceCmd ZRangeByScoreWithScores(key string, opt ZRangeBy) *ZSliceCmd ZRank(key, member string) *IntCmd ZRem(key string, members ...interface{}) *IntCmd ZRemRangeByRank(key string, start, stop int64) *IntCmd ZRemRangeByScore(key, min, max string) *IntCmd ZRemRangeByLex(key, min, max string) *IntCmd ZRevRange(key string, start, stop int64) *StringSliceCmd ZRevRangeWithScores(key string, start, stop int64) *ZSliceCmd ZRevRangeByScore(key string, opt ZRangeBy) *StringSliceCmd ZRevRangeByLex(key string, opt ZRangeBy) *StringSliceCmd ZRevRangeByScoreWithScores(key string, opt ZRangeBy) *ZSliceCmd ZRevRank(key, member string) *IntCmd ZScore(key, member string) *FloatCmd ZUnionStore(dest string, store ZStore, keys ...string) *IntCmd PFAdd(key string, els ...interface{}) *IntCmd PFCount(keys ...string) *IntCmd PFMerge(dest string, keys ...string) *StatusCmd BgRewriteAOF() *StatusCmd BgSave() *StatusCmd ClientKill(ipPort string) *StatusCmd ClientList() *StringCmd ClientPause(dur time.Duration) *BoolCmd ConfigGet(parameter string) *SliceCmd ConfigResetStat() *StatusCmd ConfigSet(parameter, value string) *StatusCmd DbSize() *IntCmd FlushAll() *StatusCmd FlushDb() *StatusCmd Info(section ...string) *StringCmd LastSave() *IntCmd Save() *StatusCmd Shutdown() *StatusCmd ShutdownSave() *StatusCmd ShutdownNoSave() *StatusCmd SlaveOf(host, port string) *StatusCmd Time() *TimeCmd Eval(script string, keys []string, args ...interface{}) *Cmd EvalSha(sha1 string, keys []string, args ...interface{}) *Cmd ScriptExists(scripts ...string) *BoolSliceCmd ScriptFlush() *StatusCmd ScriptKill() *StatusCmd ScriptLoad(script string) *StringCmd DebugObject(key string) *StringCmd PubSubChannels(pattern string) *StringSliceCmd PubSubNumSub(channels ...string) *StringIntMapCmd PubSubNumPat() *IntCmd ClusterSlots() *ClusterSlotsCmd ClusterNodes() *StringCmd ClusterMeet(host, port string) *StatusCmd ClusterForget(nodeID string) *StatusCmd ClusterReplicate(nodeID string) *StatusCmd ClusterResetSoft() *StatusCmd ClusterResetHard() *StatusCmd ClusterInfo() *StringCmd ClusterKeySlot(key string) *IntCmd ClusterCountFailureReports(nodeID string) *IntCmd ClusterCountKeysInSlot(slot int) *IntCmd ClusterDelSlots(slots ...int) *StatusCmd ClusterDelSlotsRange(min, max int) *StatusCmd ClusterSaveConfig() *StatusCmd ClusterSlaves(nodeID string) *StringSliceCmd ClusterFailover() *StatusCmd ClusterAddSlots(slots ...int) *StatusCmd ClusterAddSlotsRange(min, max int) *StatusCmd GeoAdd(key string, geoLocation ...*GeoLocation) *IntCmd GeoPos(key string, members ...string) *GeoPosCmd GeoRadius(key string, longitude, latitude float64, query *GeoRadiusQuery) *GeoLocationCmd GeoRadiusByMember(key, member string, query *GeoRadiusQuery) *GeoLocationCmd GeoDist(key string, member1, member2, unit string) *FloatCmd GeoHash(key string, members ...string) *StringSliceCmd Command() *CommandsInfoCmd }
type CommandInfo ¶
type CommandsInfoCmd ¶
type CommandsInfoCmd struct {
// contains filtered or unexported fields
}
func NewCommandsInfoCmd ¶
func NewCommandsInfoCmd(args ...interface{}) *CommandsInfoCmd
func NewCommandsInfoCmdResult ¶
func NewCommandsInfoCmdResult(val map[string]*CommandInfo, err error) *CommandsInfoCmd
NewCommandsInfoCmdResult returns a CommandsInfoCmd initalised with val and err for testing
func (*CommandsInfoCmd) Result ¶
func (cmd *CommandsInfoCmd) Result() (map[string]*CommandInfo, error)
func (*CommandsInfoCmd) String ¶
func (cmd *CommandsInfoCmd) String() string
func (*CommandsInfoCmd) Val ¶
func (cmd *CommandsInfoCmd) Val() map[string]*CommandInfo
type DurationCmd ¶
type DurationCmd struct {
// contains filtered or unexported fields
}
func NewDurationCmd ¶
func NewDurationCmd(precision time.Duration, args ...interface{}) *DurationCmd
func NewDurationResult ¶
func NewDurationResult(val time.Duration, err error) *DurationCmd
NewDurationResult returns a DurationCmd initalised with val and err for testing
func (*DurationCmd) String ¶
func (cmd *DurationCmd) String() string
func (*DurationCmd) Val ¶
func (cmd *DurationCmd) Val() time.Duration
type FailoverOptions ¶
type FailoverOptions struct { // The master name. MasterName string // A seed list of host:port addresses of sentinel nodes. SentinelAddrs []string Password string DB int MaxRetries int DialTimeout time.Duration ReadTimeout time.Duration WriteTimeout time.Duration PoolSize int PoolTimeout time.Duration IdleTimeout time.Duration IdleCheckFrequency time.Duration }
FailoverOptions are used to configure a failover client and should be passed to NewFailoverClient.
type FloatCmd ¶
type FloatCmd struct {
// contains filtered or unexported fields
}
func NewFloatCmd ¶
func NewFloatCmd(args ...interface{}) *FloatCmd
func NewFloatResult ¶
NewFloatResult returns a FloatCmd initalised with val and err for testing
type GeoLocation ¶
GeoLocation is used with GeoAdd to add geospatial location.
type GeoLocationCmd ¶
type GeoLocationCmd struct {
// contains filtered or unexported fields
}
func NewGeoLocationCmd ¶
func NewGeoLocationCmd(q *GeoRadiusQuery, args ...interface{}) *GeoLocationCmd
func NewGeoLocationCmdResult ¶
func NewGeoLocationCmdResult(val []GeoLocation, err error) *GeoLocationCmd
NewGeoLocationCmdResult returns a GeoLocationCmd initalised with val and err for testing
func (*GeoLocationCmd) Result ¶
func (cmd *GeoLocationCmd) Result() ([]GeoLocation, error)
func (*GeoLocationCmd) String ¶
func (cmd *GeoLocationCmd) String() string
func (*GeoLocationCmd) Val ¶
func (cmd *GeoLocationCmd) Val() []GeoLocation
type GeoPosCmd ¶
type GeoPosCmd struct {
// contains filtered or unexported fields
}
func NewGeoPosCmd ¶
func NewGeoPosCmd(args ...interface{}) *GeoPosCmd
type GeoRadiusQuery ¶
type GeoRadiusQuery struct { Radius float64 // Can be m, km, ft, or mi. Default is km. Unit string WithCoord bool WithDist bool WithGeoHash bool Count int // Can be ASC or DESC. Default is no sort order. Sort string }
GeoRadiusQuery is used with GeoRadius to query geospatial index.
type IntCmd ¶
type IntCmd struct {
// contains filtered or unexported fields
}
func NewIntResult ¶
NewIntResult returns an IntCmd initalised with val and err for testing
type Options ¶
type Options struct { // The network type, either tcp or unix. // Default is tcp. Network string // host:port address. Addr string // Dialer creates new network connection and has priority over // Network and Addr options. Dialer func() (net.Conn, error) // Optional password. Must match the password specified in the // requirepass server configuration option. Password string // Database to be selected after connecting to the server. DB int // Maximum number of retries before giving up. // Default is to not retry failed commands. MaxRetries int // Dial timeout for establishing new connections. // Default is 5 seconds. DialTimeout time.Duration // Timeout for socket reads. If reached, commands will fail // with a timeout instead of blocking. // Default is 3 seconds. ReadTimeout time.Duration // Timeout for socket writes. If reached, commands will fail // with a timeout instead of blocking. // Default is 3 seconds. WriteTimeout time.Duration // Maximum number of socket connections. // Default is 10 connections. PoolSize int // Amount of time client waits for connection if all connections // are busy before returning an error. // Default is ReadTimeout + 1 second. PoolTimeout time.Duration // Amount of time after which client closes idle connections. // Should be less than server's timeout. // Default is to not close idle connections. IdleTimeout time.Duration // Frequency of idle checks. // Default is 1 minute. // When minus value is set, then idle check is disabled. IdleCheckFrequency time.Duration // Enables read only queries on slave nodes. ReadOnly bool // TLS Config to use. When set TLS will be negotiated. TLSConfig *tls.Config }
type Pipeline ¶
type Pipeline struct {
// contains filtered or unexported fields
}
Pipeline implements pipelining as described in http://redis.io/topics/pipelining. It's safe for concurrent use by multiple goroutines.
func (*Pipeline) BLPop ¶
func (c *Pipeline) BLPop(timeout time.Duration, keys ...string) *StringSliceCmd
func (*Pipeline) BRPop ¶
func (c *Pipeline) BRPop(timeout time.Duration, keys ...string) *StringSliceCmd
func (*Pipeline) BRPopLPush ¶
func (*Pipeline) BgRewriteAOF ¶
func (c *Pipeline) BgRewriteAOF() *StatusCmd
func (*Pipeline) ClientGetName ¶ added in v5.1.1
func (c *Pipeline) ClientGetName() *StringCmd
ClientGetName returns the name of the connection.
func (*Pipeline) ClientKill ¶
func (*Pipeline) ClientList ¶
func (c *Pipeline) ClientList() *StringCmd
func (*Pipeline) ClientPause ¶
func (*Pipeline) ClientSetName ¶
ClientSetName assigns a name to the connection.
func (*Pipeline) ClusterAddSlots ¶
func (*Pipeline) ClusterAddSlotsRange ¶
func (*Pipeline) ClusterCountFailureReports ¶
func (*Pipeline) ClusterCountKeysInSlot ¶
func (*Pipeline) ClusterDelSlots ¶
func (*Pipeline) ClusterDelSlotsRange ¶
func (*Pipeline) ClusterFailover ¶
func (c *Pipeline) ClusterFailover() *StatusCmd
func (*Pipeline) ClusterForget ¶
func (*Pipeline) ClusterInfo ¶
func (c *Pipeline) ClusterInfo() *StringCmd
func (*Pipeline) ClusterKeySlot ¶
func (*Pipeline) ClusterMeet ¶
func (*Pipeline) ClusterNodes ¶
func (c *Pipeline) ClusterNodes() *StringCmd
func (*Pipeline) ClusterReplicate ¶
func (*Pipeline) ClusterResetHard ¶
func (c *Pipeline) ClusterResetHard() *StatusCmd
func (*Pipeline) ClusterResetSoft ¶
func (c *Pipeline) ClusterResetSoft() *StatusCmd
func (*Pipeline) ClusterSaveConfig ¶
func (c *Pipeline) ClusterSaveConfig() *StatusCmd
func (*Pipeline) ClusterSlaves ¶
func (c *Pipeline) ClusterSlaves(nodeID string) *StringSliceCmd
func (*Pipeline) ClusterSlots ¶
func (c *Pipeline) ClusterSlots() *ClusterSlotsCmd
func (*Pipeline) Command ¶
func (c *Pipeline) Command() *CommandsInfoCmd
func (*Pipeline) ConfigResetStat ¶
func (c *Pipeline) ConfigResetStat() *StatusCmd
func (*Pipeline) DebugObject ¶
func (*Pipeline) Exec ¶
Exec executes all previously queued commands using one client-server roundtrip.
Exec always returns list of commands and error of the first failed command if any.
func (*Pipeline) ExistsMulti ¶ added in v5.2.5
func (*Pipeline) GeoAdd ¶
func (c *Pipeline) GeoAdd(key string, geoLocation ...*GeoLocation) *IntCmd
func (*Pipeline) GeoHash ¶
func (c *Pipeline) GeoHash(key string, members ...string) *StringSliceCmd
func (*Pipeline) GeoRadius ¶
func (c *Pipeline) GeoRadius(key string, longitude, latitude float64, query *GeoRadiusQuery) *GeoLocationCmd
func (*Pipeline) GeoRadiusByMember ¶
func (c *Pipeline) GeoRadiusByMember(key, member string, query *GeoRadiusQuery) *GeoLocationCmd
func (*Pipeline) HGetAll ¶
func (c *Pipeline) HGetAll(key string) *StringStringMapCmd
func (*Pipeline) HIncrByFloat ¶
func (*Pipeline) HKeys ¶
func (c *Pipeline) HKeys(key string) *StringSliceCmd
func (*Pipeline) HVals ¶
func (c *Pipeline) HVals(key string) *StringSliceCmd
func (*Pipeline) IncrByFloat ¶
func (*Pipeline) Keys ¶
func (c *Pipeline) Keys(pattern string) *StringSliceCmd
func (*Pipeline) LInsertAfter ¶
func (*Pipeline) LInsertBefore ¶
func (*Pipeline) LRange ¶
func (c *Pipeline) LRange(key string, start, stop int64) *StringSliceCmd
func (*Pipeline) ObjectEncoding ¶
func (*Pipeline) ObjectIdleTime ¶
func (c *Pipeline) ObjectIdleTime(key string) *DurationCmd
func (*Pipeline) ObjectRefCount ¶
func (*Pipeline) PTTL ¶
func (c *Pipeline) PTTL(key string) *DurationCmd
func (*Pipeline) PubSubChannels ¶
func (c *Pipeline) PubSubChannels(pattern string) *StringSliceCmd
func (*Pipeline) PubSubNumPat ¶
func (c *Pipeline) PubSubNumPat() *IntCmd
func (*Pipeline) PubSubNumSub ¶
func (c *Pipeline) PubSubNumSub(channels ...string) *StringIntMapCmd
func (*Pipeline) RestoreReplace ¶
func (*Pipeline) SDiff ¶
func (c *Pipeline) SDiff(keys ...string) *StringSliceCmd
func (*Pipeline) SDiffStore ¶
func (*Pipeline) SInter ¶
func (c *Pipeline) SInter(keys ...string) *StringSliceCmd
func (*Pipeline) SInterStore ¶
func (*Pipeline) SMembers ¶
func (c *Pipeline) SMembers(key string) *StringSliceCmd
func (*Pipeline) SPopN ¶
func (c *Pipeline) SPopN(key string, count int64) *StringSliceCmd
Redis `SPOP key count` command.
func (*Pipeline) SRandMember ¶
Redis `SRANDMEMBER key` command.
func (*Pipeline) SRandMemberN ¶
func (c *Pipeline) SRandMemberN(key string, count int64) *StringSliceCmd
Redis `SRANDMEMBER key count` command.
func (*Pipeline) SUnion ¶
func (c *Pipeline) SUnion(keys ...string) *StringSliceCmd
func (*Pipeline) SUnionStore ¶
func (*Pipeline) ScriptExists ¶
func (c *Pipeline) ScriptExists(scripts ...string) *BoolSliceCmd
func (*Pipeline) ScriptFlush ¶
func (c *Pipeline) ScriptFlush() *StatusCmd
func (*Pipeline) ScriptKill ¶
func (c *Pipeline) ScriptKill() *StatusCmd
func (*Pipeline) ScriptLoad ¶
func (*Pipeline) Set ¶
Redis `SET key value [expiration]` command.
Use expiration for `SETEX`-like behavior. Zero expiration means the key has no expiration time.
func (*Pipeline) SetNX ¶
Redis `SET key value [expiration] NX` command.
Zero expiration means the key has no expiration time.