README ¶
Redis client for Golang
Supports:
- Redis 3 commands except QUIT, MONITOR, SLOWLOG and SYNC.
- Pub/Sub.
- Transactions.
- Pipelining.
- Scripting.
- Timeouts.
- Redis Sentinel.
- Redis Cluster.
- Ring.
- Cache friendly.
- Rate limiting.
- Distributed Locks.
API docs: http://godoc.org/gopkg.in/redis.v4. Examples: http://godoc.org/gopkg.in/redis.v4#pkg-examples.
Installation
Install:
go get gopkg.in/redis.v4
Quickstart
func ExampleNewClient() {
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 ExampleClient() {
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
}
Howto
Please go through examples to get an idea how to use this package.
Look and feel
Some corner cases:
SET key value EX 10 NX
set, err := client.SetNX("key", "value", 10*time.Second).Result()
SORT list LIMIT 0 2 ASC
vals, err := client.Sort("list", redis.Sort{Offset: 0, Count: 2, Order: "ASC"}).Result()
ZRANGEBYSCORE zset -inf +inf WITHSCORES LIMIT 0 2
vals, err := client.ZRangeByScoreWithScores("zset", redis.ZRangeByScore{
Min: "-inf",
Max: "+inf",
Offset: 0,
Count: 2,
}).Result()
ZINTERSTORE out 2 zset1 zset2 WEIGHTS 2 3 AGGREGATE SUM
vals, err := client.ZInterStore("out", redis.ZStore{Weights: []int64{2, 3}}, "zset1", "zset2").Result()
EVAL "return {KEYS[1],ARGV[1]}" 1 "key" "hello"
vals, err := client.Eval("return {KEYS[1],ARGV[1]}", []string{"key"}, []string{"hello"}).Result()
Benchmark
go-redis vs redigo:
BenchmarkSetGoRedis10Conns64Bytes-4 200000 7621 ns/op 210 B/op 6 allocs/op
BenchmarkSetGoRedis100Conns64Bytes-4 200000 7554 ns/op 210 B/op 6 allocs/op
BenchmarkSetGoRedis10Conns1KB-4 200000 7697 ns/op 210 B/op 6 allocs/op
BenchmarkSetGoRedis100Conns1KB-4 200000 7688 ns/op 210 B/op 6 allocs/op
BenchmarkSetGoRedis10Conns10KB-4 200000 9214 ns/op 210 B/op 6 allocs/op
BenchmarkSetGoRedis100Conns10KB-4 200000 9181 ns/op 210 B/op 6 allocs/op
BenchmarkSetGoRedis10Conns1MB-4 2000 583242 ns/op 2337 B/op 6 allocs/op
BenchmarkSetGoRedis100Conns1MB-4 2000 583089 ns/op 2338 B/op 6 allocs/op
BenchmarkSetRedigo10Conns64Bytes-4 200000 7576 ns/op 208 B/op 7 allocs/op
BenchmarkSetRedigo100Conns64Bytes-4 200000 7782 ns/op 208 B/op 7 allocs/op
BenchmarkSetRedigo10Conns1KB-4 200000 7958 ns/op 208 B/op 7 allocs/op
BenchmarkSetRedigo100Conns1KB-4 200000 7725 ns/op 208 B/op 7 allocs/op
BenchmarkSetRedigo10Conns10KB-4 100000 18442 ns/op 208 B/op 7 allocs/op
BenchmarkSetRedigo100Conns10KB-4 100000 18818 ns/op 208 B/op 7 allocs/op
BenchmarkSetRedigo10Conns1MB-4 2000 668829 ns/op 226 B/op 7 allocs/op
BenchmarkSetRedigo100Conns1MB-4 2000 679542 ns/op 226 B/op 7 allocs/op
Redis Cluster:
BenchmarkRedisPing-4 200000 6983 ns/op 116 B/op 4 allocs/op
BenchmarkRedisClusterPing-4 100000 11535 ns/op 117 B/op 4 allocs/op
Shameless plug
Check my PostgreSQL client for Go.
Documentation ¶
Overview ¶
Package redis implements a Redis client.
Example (CustomCommand) ¶
Output: "" redis: nil
Index ¶
- Variables
- 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) ClientGetName() *StringCmd
- func (c Client) ClientKill(ipPort string) *StatusCmd
- func (c Client) ClientList() *StringCmd
- func (c Client) ClientPause(dur time.Duration) *BoolCmd
- func (c Client) ClientSetName(name string) *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) 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) 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) 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) Scanner
- func (c Client) HSet(key, field, value string) *BoolCmd
- func (c Client) HSetNX(key, field, value string) *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(keys ...string) *StringCmd
- func (c Client) ObjectIdleTime(keys ...string) *DurationCmd
- func (c Client) ObjectRefCount(keys ...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) PubSub() *PubSub
- 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) Scanner
- 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) Scanner
- 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() *StringSliceCmd
- func (c Client) Type(key string) *StatusCmd
- func (c *Client) Watch(fn func(*Tx) error, keys ...string) 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) 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) Scanner
- 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) ClientSetName(name string) *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) 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) 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) 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) Scanner
- func (c ClusterClient) HSet(key, field, value string) *BoolCmd
- func (c ClusterClient) HSetNX(key, field, value string) *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(keys ...string) *StringCmd
- func (c ClusterClient) ObjectIdleTime(keys ...string) *DurationCmd
- func (c ClusterClient) ObjectRefCount(keys ...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) 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) Scanner
- 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) Scanner
- 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() *StringSliceCmd
- func (c ClusterClient) Type(key string) *StatusCmd
- 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) 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) Scanner
- 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 Cmder
- type CommandInfo
- type CommandsInfoCmd
- type DurationCmd
- type FailoverOptions
- type FloatCmd
- type GeoLocation
- type GeoLocationCmd
- 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) 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 (pipe *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 (pipe *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 (pipe *Pipeline) Exec() ([]Cmder, error)
- func (c Pipeline) Exists(key string) *BoolCmd
- 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) 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) Scanner
- func (c Pipeline) HSet(key, field, value string) *BoolCmd
- func (c Pipeline) HSetNX(key, field, value string) *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(keys ...string) *StringCmd
- func (c Pipeline) ObjectIdleTime(keys ...string) *DurationCmd
- func (c Pipeline) ObjectRefCount(keys ...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 (pipe *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) 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) Scanner
- 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) Scanner
- 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() *StringSliceCmd
- func (c Pipeline) Type(key string) *StatusCmd
- 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) 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) Scanner
- 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) ClientSetName(name string) *BoolCmd
- func (ring *Ring) Close() (retErr 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) 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) 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) 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) Scanner
- func (c Ring) HSet(key, field, value string) *BoolCmd
- func (c Ring) HSetNX(key, field, value string) *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(keys ...string) *StringCmd
- func (c Ring) ObjectIdleTime(keys ...string) *DurationCmd
- func (c Ring) ObjectRefCount(keys ...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 (ring *Ring) Pipeline() *Pipeline
- func (ring *Ring) Pipelined(fn func(*Pipeline) error) ([]Cmder, error)
- func (ring *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) 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) Scanner
- 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) Scanner
- 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() *StringSliceCmd
- func (c Ring) Type(key string) *StatusCmd
- 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) 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) Scanner
- 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 Scanner
- 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 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) 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 (tx *Tx) Discard() error
- 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) 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) 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) Scanner
- func (c Tx) HSet(key, field, value string) *BoolCmd
- func (c Tx) HSetNX(key, field, value string) *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 (tx *Tx) MultiExec(fn func() error) ([]Cmder, error)
- func (c Tx) ObjectEncoding(keys ...string) *StringCmd
- func (c Tx) ObjectIdleTime(keys ...string) *DurationCmd
- func (c Tx) ObjectRefCount(keys ...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 (tx *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) 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) Scanner
- 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) Scanner
- 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() *StringSliceCmd
- func (c Tx) Type(key string) *StatusCmd
- func (tx *Tx) Unwatch(keys ...string) *StatusCmd
- func (tx *Tx) Watch(keys ...string) *StatusCmd
- 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) 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) Scanner
- 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 ¶
This section is empty.
Variables ¶
var Nil = errorf("redis: nil")
Redis nil reply, .e.g. when key does not exist.
var TxFailedErr = errorf("redis: transaction failed")
Redis transaction failed.
Functions ¶
Types ¶
type BoolCmd ¶
type BoolCmd struct {
// contains filtered or unexported fields
}
func NewBoolCmd ¶
func NewBoolCmd(args ...interface{}) *BoolCmd
type BoolSliceCmd ¶
type BoolSliceCmd struct {
// contains filtered or unexported fields
}
func NewBoolSliceCmd ¶
func NewBoolSliceCmd(args ...interface{}) *BoolSliceCmd
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 ¶
Output: key value key2 does not exists
func NewClient ¶
NewClient returns a client to the Redis Server specified by Options.
Example ¶
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 ¶
Output:
func (Client) BLPop ¶
func (c Client) BLPop(timeout time.Duration, keys ...string) *StringSliceCmd
Example ¶
Output: queue message
func (Client) BRPopLPush ¶
func (Client) BgRewriteAOF ¶
func (c Client) BgRewriteAOF() *StatusCmd
func (*Client) ClientGetName ¶
ClientGetName returns the name of the one of many connections in the pool.
func (Client) ClientKill ¶
func (Client) ClientList ¶
func (c Client) ClientList() *StringCmd
func (Client) ClientPause ¶
func (Client) ClientSetName ¶
ClientSetName assigns a name to the one of many connections in the pool.
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) 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) 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(keys ...string) *DurationCmd
func (Client) ObjectRefCount ¶
func (*Client) PSubscribe ¶
Subscribes the client to the given patterns.
func (Client) PTTL ¶
func (c Client) PTTL(key string) *DurationCmd
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) 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.
Zero expiration means the key has no expiration time.
Example ¶
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) Time ¶
func (c Client) Time() *StringSliceCmd
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) 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 ¶
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) ClientSetName ¶
ClientSetName assigns a name to the one of many connections in the pool.
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) 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) 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(keys ...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.
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) Time ¶
func (c ClusterClient) Time() *StringSliceCmd
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) 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 (*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 CommandInfo ¶
type CommandsInfoCmd ¶
type CommandsInfoCmd struct {
// contains filtered or unexported fields
}
func NewCommandsInfoCmd ¶
func NewCommandsInfoCmd(args ...interface{}) *CommandsInfoCmd
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 (*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
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 (*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 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 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) // An optional password. Must match the password specified in the // requirepass server configuration option. Password string // A database to be selected after connecting to server. DB int // The maximum number of retries before giving up. // Default is to not retry failed commands. MaxRetries int // Sets the deadline for establishing new connections. If reached, // dial will fail with a timeout. // Default is 5 seconds. DialTimeout time.Duration // Sets the deadline for socket reads. If reached, commands will // fail with a timeout instead of blocking. ReadTimeout time.Duration // Sets the deadline for socket writes. If reached, commands will // fail with a timeout instead of blocking. WriteTimeout time.Duration // The maximum number of socket connections. // Default is 10 connections. PoolSize int // Specifies amount of time client waits for connection if all // connections are busy before returning an error. // Default is 1 second. PoolTimeout time.Duration // Specifies 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 // The frequency of idle checks. // Default is 1 minute. IdleCheckFrequency time.Duration // Enables read queries for a connection to a Redis Cluster slave node. ReadOnly bool }
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.
Example ¶
Output: 1 <nil>
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) ClientKill ¶
func (Pipeline) ClientList ¶
func (c Pipeline) ClientList() *StringCmd
func (Pipeline) ClientPause ¶
func (Pipeline) ClientSetName ¶
ClientSetName assigns a name to the one of many connections in the pool.
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) 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(keys ...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.
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.
func (Pipeline) SetXX ¶
Redis `SET key value [expiration] XX` command.
Zero expiration means the key has no expiration time.
func (Pipeline) ShutdownNoSave ¶
func (c Pipeline) ShutdownNoSave() *StatusCmd
func (Pipeline) ShutdownSave ¶
func (c Pipeline) ShutdownSave() *StatusCmd
func (Pipeline) Sort ¶
func (c Pipeline) Sort(key string, sort Sort) *StringSliceCmd
func (Pipeline) SortInterfaces ¶
func (Pipeline) TTL ¶
func (c Pipeline) TTL(key string) *DurationCmd
func (Pipeline) Time ¶
func (c Pipeline) Time() *StringSliceCmd
func (Pipeline) ZInterStore ¶
func (Pipeline) ZRange ¶
func (c Pipeline) ZRange(key string, start, stop int64) *StringSliceCmd
func (Pipeline) ZRangeByLex ¶
func (c Pipeline) ZRangeByLex(key string, opt ZRangeBy) *StringSliceCmd
func (Pipeline) ZRangeByScore ¶
func (c Pipeline) ZRangeByScore(key string, opt ZRangeBy) *StringSliceCmd
func (Pipeline) ZRangeByScoreWithScores ¶
func (Pipeline) ZRangeWithScores ¶
func (Pipeline) ZRemRangeByRank ¶
func (Pipeline) ZRemRangeByScore ¶
func (Pipeline) ZRevRange ¶
func (c Pipeline) ZRevRange(key string, start, stop int64) *StringSliceCmd
func (Pipeline) ZRevRangeByLex ¶
func (c Pipeline) ZRevRangeByLex(key string, opt ZRangeBy) *StringSliceCmd
func (Pipeline) ZRevRangeByScore ¶
func (c Pipeline) ZRevRangeByScore(key string, opt ZRangeBy) *StringSliceCmd
func (Pipeline) ZRevRangeByScoreWithScores ¶
func (Pipeline) ZRevRangeWithScores ¶
type Pong ¶
type Pong struct {
Payload string
}
Pong received as result of a PING command issued by another client.
type PoolStats ¶
type PoolStats struct { Requests uint32 // number of times a connection was requested by the pool Hits uint32 // number of times free connection was found in the pool Timeouts uint32 // number of times a wait timeout occurred TotalConns uint32 // the number of total connections in the pool FreeConns uint32 // the number of free connections in the pool }
PoolStats contains pool state information and accumulated stats.
type PubSub ¶
type PubSub struct {
// contains filtered or unexported fields
}
PubSub implements Pub/Sub commands as described in http://redis.io/topics/pubsub. It's NOT safe for concurrent use by multiple goroutines.
Example ¶
Output: mychannel1 hello
func (*PubSub) PSubscribe ¶
Subscribes the client to the given patterns.
func (*PubSub) PUnsubscribe ¶
Unsubscribes the client from the given patterns, or from all of them if none is given.
func (*PubSub) Receive ¶
Receive returns a message as a Subscription, Message, Pong or error. See PubSub example for details. This is low-level API and most clients should use ReceiveMessage.
Example ¶
Output: 1 clients received message subscribed to mychannel2 received hello from mychannel2
func (*PubSub) ReceiveMessage ¶
ReceiveMessage returns a Message or error ignoring Subscription or Pong messages. It automatically reconnects to Redis Server and resubscribes to channels in case of network errors.
func (*PubSub) ReceiveTimeout ¶
ReceiveTimeout acts like Receive but returns an error if message is not received in time. This is low-level API and most clients should use ReceiveMessage.
func (*PubSub) Unsubscribe ¶
Unsubscribes the client from the given channels, or from all of them if none is given.
type Ring ¶
type Ring struct {
// contains filtered or unexported fields
}
Ring is a Redis client that uses constistent hashing to distribute keys across multiple Redis servers (shards). It's safe for concurrent use by multiple goroutines.
Ring monitors the state of each shard and removes dead shards from the ring. When shard comes online it is added back to the ring. This gives you maximum availability and partition tolerance, but no consistency between different shards or even clients. Each client uses shards that are available to the client and does not do any coordination when shard state is changed.
Ring should be used when you use multiple Redis servers for caching and can tolerate losing data when one of the servers dies. Otherwise you should use Redis Cluster.
func (Ring) BRPopLPush ¶
func (Ring) BgRewriteAOF ¶
func (c Ring) BgRewriteAOF() *StatusCmd
func (Ring) ClientKill ¶
func (Ring) ClientList ¶
func (c Ring) ClientList() *StringCmd
func (Ring) ClientPause ¶
func (Ring) ClientSetName ¶
ClientSetName assigns a name to the one of many connections in the pool.
func (*Ring) Close ¶
Close closes the ring client, releasing any open resources.
It is rare to Close a Ring, as the Ring is meant to be long-lived and shared between many goroutines.
func (Ring) ClusterAddSlots ¶
func (Ring) ClusterAddSlotsRange ¶
func (Ring) ClusterCountFailureReports ¶
func (Ring) ClusterCountKeysInSlot ¶
func (Ring) ClusterDelSlots ¶
func (Ring) ClusterDelSlotsRange ¶
func (Ring) ClusterFailover ¶
func (c Ring) ClusterFailover() *StatusCmd
func (Ring) ClusterForget ¶
func (Ring) ClusterInfo ¶
func (c Ring) ClusterInfo() *StringCmd
func (Ring) ClusterKeySlot ¶
func (Ring) ClusterMeet ¶
func (Ring) ClusterNodes ¶
func (c Ring) ClusterNodes() *StringCmd
func (Ring) ClusterReplicate ¶
func (Ring) ClusterResetHard ¶
func (c Ring) ClusterResetHard() *StatusCmd
func (Ring) ClusterResetSoft ¶
func (c Ring) ClusterResetSoft() *StatusCmd
func (Ring) ClusterSaveConfig ¶
func (c Ring) ClusterSaveConfig() *StatusCmd
func (Ring) ClusterSlaves ¶
func (c Ring) ClusterSlaves(nodeID string) *StringSliceCmd
func (Ring) ClusterSlots ¶
func (c Ring) ClusterSlots() *ClusterSlotsCmd
func (Ring) Command ¶
func (c Ring) Command() *CommandsInfoCmd
func (Ring) ConfigResetStat ¶
func (c Ring) ConfigResetStat() *StatusCmd
func (Ring) DebugObject ¶
func (Ring) GeoAdd ¶
func (c Ring) GeoAdd(key string, geoLocation ...*GeoLocation) *IntCmd
func (Ring) GeoHash ¶
func (c Ring) GeoHash(key string, members ...string) *StringSliceCmd
func (Ring) GeoRadius ¶
func (c Ring) GeoRadius(key string, longitude, latitude float64, query *GeoRadiusQuery) *GeoLocationCmd
func (Ring) GeoRadiusByMember ¶
func (c Ring) GeoRadiusByMember(key, member string, query *GeoRadiusQuery) *GeoLocationCmd
func (Ring) HGetAll ¶
func (c Ring) HGetAll(key string) *StringStringMapCmd
func (Ring) HIncrByFloat ¶
func (Ring) HKeys ¶
func (c Ring) HKeys(key string) *StringSliceCmd
func (Ring) HVals ¶
func (c Ring) HVals(key string) *StringSliceCmd
func (Ring) IncrByFloat ¶
func (Ring) Keys ¶
func (c Ring) Keys(pattern string) *StringSliceCmd
func (Ring) LInsertAfter ¶
func (Ring) LInsertBefore ¶
func (Ring) LRange ¶
func (c Ring) LRange(key string, start, stop int64) *StringSliceCmd
func (Ring) ObjectEncoding ¶
func (Ring) ObjectIdleTime ¶
func (c Ring) ObjectIdleTime(keys ...string) *DurationCmd
func (Ring) ObjectRefCount ¶
func (Ring) PTTL ¶
func (c Ring) PTTL(key string) *DurationCmd
func (Ring) PubSubChannels ¶
func (c Ring) PubSubChannels(pattern string) *StringSliceCmd
func (Ring) PubSubNumPat ¶
func (c Ring) PubSubNumPat() *IntCmd
func (Ring) PubSubNumSub ¶
func (c Ring) PubSubNumSub(channels ...string) *StringIntMapCmd
func (Ring) RestoreReplace ¶
func (Ring) SDiff ¶
func (c Ring) SDiff(keys ...string) *StringSliceCmd
func (Ring) SDiffStore ¶
func (Ring) SInter ¶
func (c Ring) SInter(keys ...string) *StringSliceCmd
func (Ring) SInterStore ¶
func (Ring) SMembers ¶
func (c Ring) SMembers(key string) *StringSliceCmd
func (Ring) SPopN ¶
func (c Ring) SPopN(key string, count int64) *StringSliceCmd
Redis `SPOP key count` command.
func (Ring) SRandMember ¶
Redis `SRANDMEMBER key` command.
func (Ring) SRandMemberN ¶
func (c Ring) SRandMemberN(key string, count int64) *StringSliceCmd
Redis `SRANDMEMBER key count` command.
func (Ring) SUnion ¶
func (c Ring) SUnion(keys ...string) *StringSliceCmd
func (Ring) SUnionStore ¶
func (Ring) ScriptExists ¶
func (c Ring) ScriptExists(scripts ...string) *BoolSliceCmd
func (Ring) ScriptFlush ¶
func (c Ring) ScriptFlush() *StatusCmd
func (Ring) ScriptKill ¶
func (c Ring) ScriptKill() *StatusCmd
func (Ring) ScriptLoad ¶
func (Ring) Set ¶
Redis `SET key value [expiration]` command.
Zero expiration means the key has no expiration time.
func (Ring) SetNX ¶
Redis `SET key value [expiration] NX` command.
Zero expiration means the key has no expiration time.
func (Ring) SetXX ¶
Redis `SET key value [expiration] XX` command.
Zero expiration means the key has no expiration time.
func (Ring) ShutdownNoSave ¶
func (c Ring) ShutdownNoSave() *StatusCmd
func (Ring) ShutdownSave ¶
func (c Ring) ShutdownSave() *StatusCmd
func (Ring) Sort ¶
func (c Ring) Sort(key string, sort Sort) *StringSliceCmd
func (Ring) SortInterfaces ¶
func (Ring) TTL ¶
func (c Ring) TTL(key string) *DurationCmd
func (Ring) Time ¶
func (c Ring) Time() *StringSliceCmd
func (Ring) ZInterStore ¶
func (Ring) ZRange ¶
func (c Ring) ZRange(key string, start, stop int64) *StringSliceCmd
func (Ring) ZRangeByLex ¶
func (c Ring) ZRangeByLex(key string, opt ZRangeBy) *StringSliceCmd
func (Ring) ZRangeByScore ¶
func (c Ring) ZRangeByScore(key string, opt ZRangeBy) *StringSliceCmd
func (Ring) ZRangeByScoreWithScores ¶
func (Ring) ZRangeWithScores ¶
func (Ring) ZRemRangeByRank ¶
func (Ring) ZRemRangeByScore ¶
func (Ring) ZRevRange ¶
func (c Ring) ZRevRange(key string, start, stop int64) *StringSliceCmd
func (Ring) ZRevRangeByLex ¶
func (c Ring) ZRevRangeByLex(key string, opt ZRangeBy) *StringSliceCmd
func (Ring) ZRevRangeByScore ¶
func (c Ring) ZRevRangeByScore(key string, opt ZRangeBy) *StringSliceCmd
func (Ring) ZRevRangeByScoreWithScores ¶
func (Ring) ZRevRangeWithScores ¶
type RingOptions ¶
type RingOptions struct { // A map of name => host:port addresses of ring shards. Addrs map[string]string DB int Password string MaxRetries int DialTimeout time.Duration ReadTimeout time.Duration WriteTimeout time.Duration PoolSize int PoolTimeout time.Duration IdleTimeout time.Duration IdleCheckFrequency time.Duration }
RingOptions are used to configure a ring client and should be passed to NewRing.
type ScanCmd ¶
type ScanCmd struct {
// contains filtered or unexported fields
}
func NewScanCmd ¶
func NewScanCmd(args ...interface{}) *ScanCmd
type ScanIterator ¶
type ScanIterator struct { Scanner // contains filtered or unexported fields }
ScanIterator is used to incrementally iterate over a collection of elements. It's safe for concurrent use by multiple goroutines.
Example ¶
Output:
func (*ScanIterator) Err ¶
func (it *ScanIterator) Err() error
Err returns the last iterator error, if any.
func (*ScanIterator) Next ¶
func (it *ScanIterator) Next() bool
Next advances the cursor and returns true if more values can be read.
func (*ScanIterator) Val ¶
func (it *ScanIterator) Val() string
Val returns the key/field at the current cursor position.
type Scanner ¶
type Scanner struct { *ScanCmd // contains filtered or unexported fields }
func (Scanner) Iterator ¶
func (s Scanner) Iterator() *ScanIterator
Iterator creates a new ScanIterator.
type Script ¶
type Script struct {
// contains filtered or unexported fields
}
Example ¶
Output: <nil> redis: nil 42 <nil>
func (*Script) Exists ¶
func (s *Script) Exists(c scripter) *BoolSliceCmd
type SliceCmd ¶
type SliceCmd struct {
// contains filtered or unexported fields
}
func NewSliceCmd ¶
func NewSliceCmd(args ...interface{}) *SliceCmd
type StatusCmd ¶
type StatusCmd struct {
// contains filtered or unexported fields
}
func NewStatusCmd ¶
func NewStatusCmd(args ...interface{}) *StatusCmd
type StringCmd ¶
type StringCmd struct {
// contains filtered or unexported fields
}
func NewStringCmd ¶
func NewStringCmd(args ...interface{}) *StringCmd
type StringIntMapCmd ¶
type StringIntMapCmd struct {
// contains filtered or unexported fields
}
func NewStringIntMapCmd ¶
func NewStringIntMapCmd(args ...interface{}) *StringIntMapCmd
func (*StringIntMapCmd) String ¶
func (cmd *StringIntMapCmd) String() string
func (*StringIntMapCmd) Val ¶
func (cmd *StringIntMapCmd) Val() map[string]int64
type StringSliceCmd ¶
type StringSliceCmd struct {
// contains filtered or unexported fields
}
func NewStringSliceCmd ¶
func NewStringSliceCmd(args ...interface{}) *StringSliceCmd
func (*StringSliceCmd) Result ¶
func (cmd *StringSliceCmd) Result() ([]string, error)
func (*StringSliceCmd) String ¶
func (cmd *StringSliceCmd) String() string
func (*StringSliceCmd) Val ¶
func (cmd *StringSliceCmd) Val() []string
type StringStringMapCmd ¶
type StringStringMapCmd struct {
// contains filtered or unexported fields
}
func NewStringStringMapCmd ¶
func NewStringStringMapCmd(args ...interface{}) *StringStringMapCmd
func (*StringStringMapCmd) Result ¶
func (cmd *StringStringMapCmd) Result() (map[string]string, error)
func (*StringStringMapCmd) String ¶
func (cmd *StringStringMapCmd) String() string
func (*StringStringMapCmd) Val ¶
func (cmd *StringStringMapCmd) Val() map[string]string
type Subscription ¶
type Subscription struct { // Can be "subscribe", "unsubscribe", "psubscribe" or "punsubscribe". Kind string // Channel name we have subscribed to. Channel string // Number of channels we are currently subscribed to. Count int }
Message received after a successful subscription to channel.
func (*Subscription) String ¶
func (m *Subscription) String() string
type Tx ¶
type Tx struct {
// contains filtered or unexported fields
}
Tx implements Redis transactions as described in http://redis.io/topics/transactions. It's NOT safe for concurrent use by multiple goroutines, because Exec resets list of watched keys. If you don't need WATCH it is better to use Pipeline.
func (Tx) BRPopLPush ¶
func (Tx) BgRewriteAOF ¶
func (c Tx) BgRewriteAOF() *StatusCmd
func (Tx) ClientKill ¶
func (Tx) ClientList ¶
func (c Tx) ClientList() *StringCmd
func (Tx) ClientPause ¶
func (Tx) ClientSetName ¶
ClientSetName assigns a name to the one of many connections in the pool.
func (*Tx) Close ¶
func (c *Tx) 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 (Tx) ClusterAddSlots ¶
func (Tx) ClusterAddSlotsRange ¶
func (Tx) ClusterCountFailureReports ¶
func (Tx) ClusterCountKeysInSlot ¶
func (Tx) ClusterDelSlots ¶
func (Tx) ClusterDelSlotsRange ¶
func (Tx) ClusterFailover ¶
func (c Tx) ClusterFailover() *StatusCmd
func (Tx) ClusterForget ¶
func (Tx) ClusterInfo ¶
func (c Tx) ClusterInfo() *StringCmd
func (Tx) ClusterKeySlot ¶
func (Tx) ClusterMeet ¶
func (Tx) ClusterNodes ¶
func (c Tx) ClusterNodes() *StringCmd
func (Tx) ClusterReplicate ¶
func (Tx) ClusterResetHard ¶
func (c Tx) ClusterResetHard() *StatusCmd
func (Tx) ClusterResetSoft ¶
func (c Tx) ClusterResetSoft() *StatusCmd
func (Tx) ClusterSaveConfig ¶
func (c Tx) ClusterSaveConfig() *StatusCmd
func (Tx) ClusterSlaves ¶
func (c Tx) ClusterSlaves(nodeID string) *StringSliceCmd
func (Tx) ClusterSlots ¶
func (c Tx) ClusterSlots() *ClusterSlotsCmd
func (Tx) Command ¶
func (c Tx) Command() *CommandsInfoCmd
func (Tx) ConfigResetStat ¶
func (c Tx) ConfigResetStat() *StatusCmd
func (Tx) DebugObject ¶
func (Tx) GeoAdd ¶
func (c Tx) GeoAdd(key string, geoLocation ...*GeoLocation) *IntCmd
func (Tx) GeoHash ¶
func (c Tx) GeoHash(key string, members ...string) *StringSliceCmd
func (Tx) GeoRadius ¶
func (c Tx) GeoRadius(key string, longitude, latitude float64, query *GeoRadiusQuery) *GeoLocationCmd
func (Tx) GeoRadiusByMember ¶
func (c Tx) GeoRadiusByMember(key, member string, query *GeoRadiusQuery) *GeoLocationCmd
func (Tx) HGetAll ¶
func (c Tx) HGetAll(key string) *StringStringMapCmd
func (Tx) HIncrByFloat ¶
func (Tx) HKeys ¶
func (c Tx) HKeys(key string) *StringSliceCmd
func (Tx) HVals ¶
func (c Tx) HVals(key string) *StringSliceCmd
func (Tx) IncrByFloat ¶
func (Tx) Keys ¶
func (c Tx) Keys(pattern string) *StringSliceCmd
func (Tx) LInsertAfter ¶
func (Tx) LInsertBefore ¶
func (Tx) LRange ¶
func (c Tx) LRange(key string, start, stop int64) *StringSliceCmd
func (*Tx) MultiExec ¶
MultiExec executes all previously queued commands in a transaction and restores the connection state to normal.
When using WATCH, EXEC will execute commands only if the watched keys were not modified, allowing for a check-and-set mechanism.
Exec always returns list of commands. If transaction fails TxFailedErr is returned. Otherwise Exec returns error of the first failed command or nil.
func (Tx) ObjectEncoding ¶
func (Tx) ObjectIdleTime ¶
func (c Tx) ObjectIdleTime(keys ...string) *DurationCmd
func (Tx) ObjectRefCount ¶
func (Tx) PTTL ¶
func (c Tx) PTTL(key string) *DurationCmd
func (Tx) PubSubChannels ¶
func (c Tx) PubSubChannels(pattern string) *StringSliceCmd
func (Tx) PubSubNumPat ¶
func (c Tx) PubSubNumPat() *IntCmd
func (Tx) PubSubNumSub ¶
func (c Tx) PubSubNumSub(channels ...string) *StringIntMapCmd
func (Tx) RestoreReplace ¶
func (Tx) SDiff ¶
func (c Tx) SDiff(keys ...string) *StringSliceCmd
func (Tx) SDiffStore ¶
func (Tx) SInter ¶
func (c Tx) SInter(keys ...string) *StringSliceCmd
func (Tx) SInterStore ¶
func (Tx) SMembers ¶
func (c Tx) SMembers(key string) *StringSliceCmd
func (Tx) SPopN ¶
func (c Tx) SPopN(key string, count int64) *StringSliceCmd
Redis `SPOP key count` command.
func (Tx) SRandMember ¶
Redis `SRANDMEMBER key` command.
func (Tx) SRandMemberN ¶
func (c Tx) SRandMemberN(key string, count int64) *StringSliceCmd
Redis `SRANDMEMBER key count` command.
func (Tx) SUnion ¶
func (c Tx) SUnion(keys ...string) *StringSliceCmd
func (Tx) SUnionStore ¶
func (Tx) ScriptExists ¶
func (c Tx) ScriptExists(scripts ...string) *BoolSliceCmd
func (Tx) ScriptFlush ¶
func (c Tx) ScriptFlush() *StatusCmd
func (Tx) ScriptKill ¶
func (c Tx) ScriptKill() *StatusCmd
func (Tx) ScriptLoad ¶
func (Tx) Set ¶
Redis `SET key value [expiration]` command.
Zero expiration means the key has no expiration time.
func (Tx) SetNX ¶
Redis `SET key value [expiration] NX` command.
Zero expiration means the key has no expiration time.
func (Tx) SetXX ¶
Redis `SET key value [expiration] XX` command.
Zero expiration means the key has no expiration time.
func (Tx) ShutdownNoSave ¶
func (c Tx) ShutdownNoSave() *StatusCmd
func (Tx) ShutdownSave ¶
func (c Tx) ShutdownSave() *StatusCmd
func (Tx) Sort ¶
func (c Tx) Sort(key string, sort Sort) *StringSliceCmd
func (Tx) SortInterfaces ¶
func (Tx) TTL ¶
func (c Tx) TTL(key string) *DurationCmd
func (Tx) Time ¶
func (c Tx) Time() *StringSliceCmd
func (Tx) ZInterStore ¶
func (Tx) ZRange ¶
func (c Tx) ZRange(key string, start, stop int64) *StringSliceCmd
func (Tx) ZRangeByLex ¶
func (c Tx) ZRangeByLex(key string, opt ZRangeBy) *StringSliceCmd
func (Tx) ZRangeByScore ¶
func (c Tx) ZRangeByScore(key string, opt ZRangeBy) *StringSliceCmd
func (Tx) ZRangeByScoreWithScores ¶
func (Tx) ZRangeWithScores ¶
func (Tx) ZRemRangeByRank ¶
func (Tx) ZRemRangeByScore ¶
func (Tx) ZRevRange ¶
func (c Tx) ZRevRange(key string, start, stop int64) *StringSliceCmd
func (Tx) ZRevRangeByLex ¶
func (c Tx) ZRevRangeByLex(key string, opt ZRangeBy) *StringSliceCmd
func (Tx) ZRevRangeByScore ¶
func (c Tx) ZRevRangeByScore(key string, opt ZRangeBy) *StringSliceCmd
func (Tx) ZRevRangeByScoreWithScores ¶
func (Tx) ZRevRangeWithScores ¶
type ZSliceCmd ¶
type ZSliceCmd struct {
// contains filtered or unexported fields
}
func NewZSliceCmd ¶
func NewZSliceCmd(args ...interface{}) *ZSliceCmd