redis

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.

API docs: http://godoc.org/gopkg.in/redis.v3. Examples: http://godoc.org/gopkg.in/redis.v3#pkg-examples.

Installation

Install:

go get gopkg.in/redis.v3

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()

Documentation

Overview

Package redis implements a Redis client.

Example (CustomCommand)

Get := func(client *redis.Client, key string) *redis.StringCmd {
	cmd := redis.NewStringCmd("GET", key)
	client.Process(cmd)
	return cmd
}

v, err := Get(client, "key_does_not_exist").Result()
fmt.Printf("%q %s", v, err)

Output:

"" redis: nil

Index

• Variables
• type BitCount
• type BoolCmd
  • func NewBoolCmd(args ...interface{}) *BoolCmd
  • func (cmd *BoolCmd) Err() error
  • func (cmd *BoolCmd) Result() (bool, error)
  • func (cmd *BoolCmd) String() string
  • func (cmd *BoolCmd) Val() bool
• type BoolSliceCmd
  • func NewBoolSliceCmd(args ...interface{}) *BoolSliceCmd
  • func (cmd *BoolSliceCmd) Err() error
  • func (cmd *BoolSliceCmd) Result() ([]bool, error)
  • func (cmd *BoolSliceCmd) String() string
  • func (cmd *BoolSliceCmd) Val() []bool
• type Client
  • func NewClient(opt *Options) *Client
  • func NewFailoverClient(failoverOpt *FailoverOptions) *Client
  • func (c *Client) Append(key, value string) *IntCmd
  • func (c *Client) Auth(password string) *StatusCmd
  • func (c *Client) BLPop(timeout time.Duration, keys ...string) *StringSliceCmd
  • func (c *Client) BRPop(timeout time.Duration, keys ...string) *StringSliceCmd
  • func (c *Client) BRPopLPush(source, destination string, timeout time.Duration) *StringCmd
  • func (c *Client) BgRewriteAOF() *StatusCmd
  • func (c *Client) BgSave() *StatusCmd
  • func (c *Client) BitCount(key string, bitCount *BitCount) *IntCmd
  • func (c *Client) BitOpAnd(destKey string, keys ...string) *IntCmd
  • func (c *Client) BitOpNot(destKey string, key string) *IntCmd
  • func (c *Client) BitOpOr(destKey string, keys ...string) *IntCmd
  • func (c *Client) BitOpXor(destKey string, keys ...string) *IntCmd
  • func (c *Client) BitPos(key string, bit int64, pos ...int64) *IntCmd
  • func (c *Client) ClientKill(ipPort string) *StatusCmd
  • func (c *Client) ClientList() *StringCmd
  • func (c *Client) ClientPause(dur time.Duration) *BoolCmd
  • func (c Client) Close() error
  • func (c *Client) ClusterAddSlots(slots ...int) *StatusCmd
  • func (c *Client) ClusterAddSlotsRange(min, max int) *StatusCmd
  • func (c *Client) ClusterFailover() *StatusCmd
  • func (c *Client) ClusterInfo() *StringCmd
  • func (c *Client) ClusterMeet(host, port string) *StatusCmd
  • func (c *Client) ClusterNodes() *StringCmd
  • func (c *Client) ClusterReplicate(nodeID string) *StatusCmd
  • func (c *Client) ClusterSlots() *ClusterSlotCmd
  • 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 string) *StringCmd
  • func (c *Client) Eval(script string, keys []string, args []string) *Cmd
  • func (c *Client) EvalSha(sha1 string, keys []string, args []string) *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) 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) *StringSliceCmd
  • func (c *Client) HGetAllMap(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, field, value string, pairs ...string) *StatusCmd
  • func (c *Client) HScan(key string, cursor int64, match string, count int64) *ScanCmd
  • 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() *StringCmd
  • func (c *Client) Keys(pattern string) *StringSliceCmd
  • func (c *Client) LIndex(key string, index int64) *StringCmd
  • func (c *Client) LInsert(key, op, pivot, value string) *IntCmd
  • func (c *Client) LLen(key string) *IntCmd
  • func (c *Client) LPop(key string) *StringCmd
  • func (c *Client) LPush(key string, values ...string) *IntCmd
  • func (c *Client) LPushX(key, value string) *IntCmd
  • func (c *Client) LRange(key string, start, stop int64) *StringSliceCmd
  • func (c *Client) LRem(key string, count int64, value string) *IntCmd
  • func (c *Client) LSet(key string, index int64, value string) *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 ...string) *StatusCmd
  • func (c *Client) MSetNX(pairs ...string) *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) Multi() *Multi
  • 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) 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) Process(cmd Cmder)
  • 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 ...string) *IntCmd
  • func (c *Client) RPushX(key string, value string) *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 ...string) *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, member string) *BoolCmd
  • func (c *Client) SMembers(key string) *StringSliceCmd
  • func (c *Client) SMove(source, destination, member string) *BoolCmd
  • func (c *Client) SPop(key string) *StringCmd
  • func (c *Client) SRandMember(key string) *StringCmd
  • func (c *Client) SRandMemberN(key string, count int64) *StringSliceCmd
  • func (c *Client) SRem(key string, members ...string) *IntCmd
  • func (c *Client) SScan(key string, cursor int64, match string, count int64) *ScanCmd
  • func (c *Client) SUnion(keys ...string) *StringSliceCmd
  • func (c *Client) SUnionStore(destination string, keys ...string) *IntCmd
  • func (c *Client) Save() *StatusCmd
  • func (c *Client) Scan(cursor int64, match string, count int64) *ScanCmd
  • func (c *Client) ScriptExists(scripts ...string) *BoolSliceCmd
  • func (c *Client) ScriptFlush() *StatusCmd
  • func (c *Client) ScriptKill() *StatusCmd
  • func (c *Client) ScriptLoad(script string) *StringCmd
  • func (c *Client) Select(index int64) *StatusCmd
  • 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) 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) 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 ZRangeByScore) *StringSliceCmd
  • func (c *Client) ZRangeByScore(key string, opt ZRangeByScore) *StringSliceCmd
  • func (c *Client) ZRangeByScoreWithScores(key string, opt ZRangeByScore) *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 ...string) *IntCmd
  • func (c *Client) ZRemRangeByRank(key string, start, stop int64) *IntCmd
  • func (c *Client) ZRemRangeByScore(key, min, max string) *IntCmd
  • func (c *Client) ZRevRange(key string, start, stop int64) *StringSliceCmd
  • func (c Client) ZRevRangeByLex(key string, opt ZRangeByScore) *StringSliceCmd
  • func (c *Client) ZRevRangeByScore(key string, opt ZRangeByScore) *StringSliceCmd
  • func (c *Client) ZRevRangeByScoreWithScores(key string, opt ZRangeByScore) *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 int64, match string, count int64) *ScanCmd
  • func (c *Client) ZScore(key, member string) *FloatCmd
  • func (c *Client) ZUnionStore(dest string, store ZStore, keys ...string) *IntCmd
• type ClusterClient
  • func NewClusterClient(opt *ClusterOptions) *ClusterClient
  • func (c *ClusterClient) Append(key, value string) *IntCmd
  • func (c *ClusterClient) Auth(password string) *StatusCmd
  • func (c *ClusterClient) BLPop(timeout time.Duration, keys ...string) *StringSliceCmd
  • func (c *ClusterClient) BRPop(timeout time.Duration, keys ...string) *StringSliceCmd
  • func (c *ClusterClient) BRPopLPush(source, destination string, timeout time.Duration) *StringCmd
  • func (c *ClusterClient) BgRewriteAOF() *StatusCmd
  • func (c *ClusterClient) BgSave() *StatusCmd
  • func (c *ClusterClient) BitCount(key string, bitCount *BitCount) *IntCmd
  • func (c *ClusterClient) BitOpAnd(destKey string, keys ...string) *IntCmd
  • func (c *ClusterClient) BitOpNot(destKey string, key string) *IntCmd
  • func (c *ClusterClient) BitOpOr(destKey string, keys ...string) *IntCmd
  • func (c *ClusterClient) BitOpXor(destKey string, keys ...string) *IntCmd
  • func (c *ClusterClient) BitPos(key string, bit int64, pos ...int64) *IntCmd
  • func (c *ClusterClient) ClientKill(ipPort string) *StatusCmd
  • func (c *ClusterClient) ClientList() *StringCmd
  • func (c *ClusterClient) ClientPause(dur time.Duration) *BoolCmd
  • func (c *ClusterClient) Close() error
  • func (c *ClusterClient) ClusterAddSlots(slots ...int) *StatusCmd
  • func (c *ClusterClient) ClusterAddSlotsRange(min, max int) *StatusCmd
  • func (c *ClusterClient) ClusterFailover() *StatusCmd
  • func (c *ClusterClient) ClusterInfo() *StringCmd
  • func (c *ClusterClient) ClusterMeet(host, port string) *StatusCmd
  • func (c *ClusterClient) ClusterNodes() *StringCmd
  • func (c *ClusterClient) ClusterReplicate(nodeID string) *StatusCmd
  • func (c *ClusterClient) ClusterSlots() *ClusterSlotCmd
  • 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 string) *StringCmd
  • func (c *ClusterClient) Eval(script string, keys []string, args []string) *Cmd
  • func (c *ClusterClient) EvalSha(sha1 string, keys []string, args []string) *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) 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) *StringSliceCmd
  • func (c *ClusterClient) HGetAllMap(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, field, value string, pairs ...string) *StatusCmd
  • func (c *ClusterClient) HScan(key string, cursor int64, match string, count int64) *ScanCmd
  • 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() *StringCmd
  • func (c *ClusterClient) Keys(pattern string) *StringSliceCmd
  • func (c *ClusterClient) LIndex(key string, index int64) *StringCmd
  • func (c *ClusterClient) LInsert(key, op, pivot, value string) *IntCmd
  • func (c *ClusterClient) LLen(key string) *IntCmd
  • func (c *ClusterClient) LPop(key string) *StringCmd
  • func (c *ClusterClient) LPush(key string, values ...string) *IntCmd
  • func (c *ClusterClient) LPushX(key, value string) *IntCmd
  • func (c *ClusterClient) LRange(key string, start, stop int64) *StringSliceCmd
  • func (c *ClusterClient) LRem(key string, count int64, value string) *IntCmd
  • func (c *ClusterClient) LSet(key string, index int64, value string) *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 ...string) *StatusCmd
  • func (c *ClusterClient) MSetNX(pairs ...string) *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) PTTL(key string) *DurationCmd
  • func (c *ClusterClient) Persist(key string) *BoolCmd
  • func (c *ClusterClient) Ping() *StatusCmd
  • func (c *ClusterClient) Pipeline() *ClusterPipeline
  • func (c *ClusterClient) Process(cmd Cmder)
  • 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 ...string) *IntCmd
  • func (c *ClusterClient) RPushX(key string, value string) *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 ...string) *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, member string) *BoolCmd
  • func (c *ClusterClient) SMembers(key string) *StringSliceCmd
  • func (c *ClusterClient) SMove(source, destination, member string) *BoolCmd
  • func (c *ClusterClient) SPop(key string) *StringCmd
  • func (c *ClusterClient) SRandMember(key string) *StringCmd
  • func (c *ClusterClient) SRandMemberN(key string, count int64) *StringSliceCmd
  • func (c *ClusterClient) SRem(key string, members ...string) *IntCmd
  • func (c *ClusterClient) SScan(key string, cursor int64, match string, count int64) *ScanCmd
  • func (c *ClusterClient) SUnion(keys ...string) *StringSliceCmd
  • func (c *ClusterClient) SUnionStore(destination string, keys ...string) *IntCmd
  • func (c *ClusterClient) Save() *StatusCmd
  • func (c *ClusterClient) Scan(cursor int64, match string, count int64) *ScanCmd
  • func (c *ClusterClient) ScriptExists(scripts ...string) *BoolSliceCmd
  • func (c *ClusterClient) ScriptFlush() *StatusCmd
  • func (c *ClusterClient) ScriptKill() *StatusCmd
  • func (c *ClusterClient) ScriptLoad(script string) *StringCmd
  • func (c *ClusterClient) Select(index int64) *StatusCmd
  • 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) 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) 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) 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 ZRangeByScore) *StringSliceCmd
  • func (c *ClusterClient) ZRangeByScore(key string, opt ZRangeByScore) *StringSliceCmd
  • func (c *ClusterClient) ZRangeByScoreWithScores(key string, opt ZRangeByScore) *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 ...string) *IntCmd
  • func (c *ClusterClient) ZRemRangeByRank(key string, start, stop int64) *IntCmd
  • func (c *ClusterClient) ZRemRangeByScore(key, min, max string) *IntCmd
  • func (c *ClusterClient) ZRevRange(key string, start, stop int64) *StringSliceCmd
  • func (c ClusterClient) ZRevRangeByLex(key string, opt ZRangeByScore) *StringSliceCmd
  • func (c *ClusterClient) ZRevRangeByScore(key string, opt ZRangeByScore) *StringSliceCmd
  • func (c *ClusterClient) ZRevRangeByScoreWithScores(key string, opt ZRangeByScore) *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 int64, match string, count int64) *ScanCmd
  • func (c *ClusterClient) ZScore(key, member string) *FloatCmd
  • func (c *ClusterClient) ZUnionStore(dest string, store ZStore, keys ...string) *IntCmd
• type ClusterOptions
• type ClusterPipeline
  • func (c *ClusterPipeline) Append(key, value string) *IntCmd
  • func (c *ClusterPipeline) Auth(password string) *StatusCmd
  • func (c *ClusterPipeline) BLPop(timeout time.Duration, keys ...string) *StringSliceCmd
  • func (c *ClusterPipeline) BRPop(timeout time.Duration, keys ...string) *StringSliceCmd
  • func (c *ClusterPipeline) BRPopLPush(source, destination string, timeout time.Duration) *StringCmd
  • func (c *ClusterPipeline) BgRewriteAOF() *StatusCmd
  • func (c *ClusterPipeline) BgSave() *StatusCmd
  • func (c *ClusterPipeline) BitCount(key string, bitCount *BitCount) *IntCmd
  • func (c *ClusterPipeline) BitOpAnd(destKey string, keys ...string) *IntCmd
  • func (c *ClusterPipeline) BitOpNot(destKey string, key string) *IntCmd
  • func (c *ClusterPipeline) BitOpOr(destKey string, keys ...string) *IntCmd
  • func (c *ClusterPipeline) BitOpXor(destKey string, keys ...string) *IntCmd
  • func (c *ClusterPipeline) BitPos(key string, bit int64, pos ...int64) *IntCmd
  • func (c *ClusterPipeline) ClientKill(ipPort string) *StatusCmd
  • func (c *ClusterPipeline) ClientList() *StringCmd
  • func (c *ClusterPipeline) ClientPause(dur time.Duration) *BoolCmd
  • func (pipe *ClusterPipeline) Close() error
  • func (c *ClusterPipeline) ClusterAddSlots(slots ...int) *StatusCmd
  • func (c *ClusterPipeline) ClusterAddSlotsRange(min, max int) *StatusCmd
  • func (c *ClusterPipeline) ClusterFailover() *StatusCmd
  • func (c *ClusterPipeline) ClusterInfo() *StringCmd
  • func (c *ClusterPipeline) ClusterMeet(host, port string) *StatusCmd
  • func (c *ClusterPipeline) ClusterNodes() *StringCmd
  • func (c *ClusterPipeline) ClusterReplicate(nodeID string) *StatusCmd
  • func (c *ClusterPipeline) ClusterSlots() *ClusterSlotCmd
  • func (c *ClusterPipeline) ConfigGet(parameter string) *SliceCmd
  • func (c *ClusterPipeline) ConfigResetStat() *StatusCmd
  • func (c *ClusterPipeline) ConfigSet(parameter, value string) *StatusCmd
  • func (c *ClusterPipeline) DbSize() *IntCmd
  • func (c *ClusterPipeline) DebugObject(key string) *StringCmd
  • func (c *ClusterPipeline) Decr(key string) *IntCmd
  • func (c *ClusterPipeline) DecrBy(key string, decrement int64) *IntCmd
  • func (c *ClusterPipeline) Del(keys ...string) *IntCmd
  • func (pipe *ClusterPipeline) Discard() error
  • func (c *ClusterPipeline) Dump(key string) *StringCmd
  • func (c *ClusterPipeline) Echo(message string) *StringCmd
  • func (c *ClusterPipeline) Eval(script string, keys []string, args []string) *Cmd
  • func (c *ClusterPipeline) EvalSha(sha1 string, keys []string, args []string) *Cmd
  • func (pipe *ClusterPipeline) Exec() (cmds []Cmder, retErr error)
  • func (c *ClusterPipeline) Exists(key string) *BoolCmd
  • func (c *ClusterPipeline) Expire(key string, expiration time.Duration) *BoolCmd
  • func (c *ClusterPipeline) ExpireAt(key string, tm time.Time) *BoolCmd
  • func (c *ClusterPipeline) FlushAll() *StatusCmd
  • func (c *ClusterPipeline) FlushDb() *StatusCmd
  • func (c *ClusterPipeline) Get(key string) *StringCmd
  • func (c *ClusterPipeline) GetBit(key string, offset int64) *IntCmd
  • func (c *ClusterPipeline) GetRange(key string, start, end int64) *StringCmd
  • func (c *ClusterPipeline) GetSet(key string, value interface{}) *StringCmd
  • func (c *ClusterPipeline) HDel(key string, fields ...string) *IntCmd
  • func (c *ClusterPipeline) HExists(key, field string) *BoolCmd
  • func (c *ClusterPipeline) HGet(key, field string) *StringCmd
  • func (c *ClusterPipeline) HGetAll(key string) *StringSliceCmd
  • func (c *ClusterPipeline) HGetAllMap(key string) *StringStringMapCmd
  • func (c *ClusterPipeline) HIncrBy(key, field string, incr int64) *IntCmd
  • func (c *ClusterPipeline) HIncrByFloat(key, field string, incr float64) *FloatCmd
  • func (c *ClusterPipeline) HKeys(key string) *StringSliceCmd
  • func (c *ClusterPipeline) HLen(key string) *IntCmd
  • func (c *ClusterPipeline) HMGet(key string, fields ...string) *SliceCmd
  • func (c *ClusterPipeline) HMSet(key, field, value string, pairs ...string) *StatusCmd
  • func (c *ClusterPipeline) HScan(key string, cursor int64, match string, count int64) *ScanCmd
  • func (c *ClusterPipeline) HSet(key, field, value string) *BoolCmd
  • func (c *ClusterPipeline) HSetNX(key, field, value string) *BoolCmd
  • func (c *ClusterPipeline) HVals(key string) *StringSliceCmd
  • func (c *ClusterPipeline) Incr(key string) *IntCmd
  • func (c *ClusterPipeline) IncrBy(key string, value int64) *IntCmd
  • func (c *ClusterPipeline) IncrByFloat(key string, value float64) *FloatCmd
  • func (c *ClusterPipeline) Info() *StringCmd
  • func (c *ClusterPipeline) Keys(pattern string) *StringSliceCmd
  • func (c *ClusterPipeline) LIndex(key string, index int64) *StringCmd
  • func (c *ClusterPipeline) LInsert(key, op, pivot, value string) *IntCmd
  • func (c *ClusterPipeline) LLen(key string) *IntCmd
  • func (c *ClusterPipeline) LPop(key string) *StringCmd
  • func (c *ClusterPipeline) LPush(key string, values ...string) *IntCmd
  • func (c *ClusterPipeline) LPushX(key, value string) *IntCmd
  • func (c *ClusterPipeline) LRange(key string, start, stop int64) *StringSliceCmd
  • func (c *ClusterPipeline) LRem(key string, count int64, value string) *IntCmd
  • func (c *ClusterPipeline) LSet(key string, index int64, value string) *StatusCmd
  • func (c *ClusterPipeline) LTrim(key string, start, stop int64) *StatusCmd
  • func (c *ClusterPipeline) LastSave() *IntCmd
  • func (c *ClusterPipeline) MGet(keys ...string) *SliceCmd
  • func (c *ClusterPipeline) MSet(pairs ...string) *StatusCmd
  • func (c *ClusterPipeline) MSetNX(pairs ...string) *BoolCmd
  • func (c *ClusterPipeline) Migrate(host, port, key string, db int64, timeout time.Duration) *StatusCmd
  • func (c *ClusterPipeline) Move(key string, db int64) *BoolCmd
  • func (c *ClusterPipeline) ObjectEncoding(keys ...string) *StringCmd
  • func (c *ClusterPipeline) ObjectIdleTime(keys ...string) *DurationCmd
  • func (c *ClusterPipeline) ObjectRefCount(keys ...string) *IntCmd
  • func (c *ClusterPipeline) PExpire(key string, expiration time.Duration) *BoolCmd
  • func (c *ClusterPipeline) PExpireAt(key string, tm time.Time) *BoolCmd
  • func (c *ClusterPipeline) PTTL(key string) *DurationCmd
  • func (c *ClusterPipeline) Persist(key string) *BoolCmd
  • func (c *ClusterPipeline) Ping() *StatusCmd
  • func (c *ClusterPipeline) Process(cmd Cmder)
  • func (c *ClusterPipeline) PubSubChannels(pattern string) *StringSliceCmd
  • func (c *ClusterPipeline) PubSubNumPat() *IntCmd
  • func (c *ClusterPipeline) PubSubNumSub(channels ...string) *StringIntMapCmd
  • func (c *ClusterPipeline) Quit() *StatusCmd
  • func (c *ClusterPipeline) RPop(key string) *StringCmd
  • func (c *ClusterPipeline) RPopLPush(source, destination string) *StringCmd
  • func (c *ClusterPipeline) RPush(key string, values ...string) *IntCmd
  • func (c *ClusterPipeline) RPushX(key string, value string) *IntCmd
  • func (c *ClusterPipeline) RandomKey() *StringCmd
  • func (c *ClusterPipeline) Rename(key, newkey string) *StatusCmd
  • func (c *ClusterPipeline) RenameNX(key, newkey string) *BoolCmd
  • func (c *ClusterPipeline) Restore(key string, ttl time.Duration, value string) *StatusCmd
  • func (c *ClusterPipeline) RestoreReplace(key string, ttl time.Duration, value string) *StatusCmd
  • func (c *ClusterPipeline) SAdd(key string, members ...string) *IntCmd
  • func (c *ClusterPipeline) SCard(key string) *IntCmd
  • func (c *ClusterPipeline) SDiff(keys ...string) *StringSliceCmd
  • func (c *ClusterPipeline) SDiffStore(destination string, keys ...string) *IntCmd
  • func (c *ClusterPipeline) SInter(keys ...string) *StringSliceCmd
  • func (c *ClusterPipeline) SInterStore(destination string, keys ...string) *IntCmd
  • func (c *ClusterPipeline) SIsMember(key, member string) *BoolCmd
  • func (c *ClusterPipeline) SMembers(key string) *StringSliceCmd
  • func (c *ClusterPipeline) SMove(source, destination, member string) *BoolCmd
  • func (c *ClusterPipeline) SPop(key string) *StringCmd
  • func (c *ClusterPipeline) SRandMember(key string) *StringCmd
  • func (c *ClusterPipeline) SRandMemberN(key string, count int64) *StringSliceCmd
  • func (c *ClusterPipeline) SRem(key string, members ...string) *IntCmd
  • func (c *ClusterPipeline) SScan(key string, cursor int64, match string, count int64) *ScanCmd
  • func (c *ClusterPipeline) SUnion(keys ...string) *StringSliceCmd
  • func (c *ClusterPipeline) SUnionStore(destination string, keys ...string) *IntCmd
  • func (c *ClusterPipeline) Save() *StatusCmd
  • func (c *ClusterPipeline) Scan(cursor int64, match string, count int64) *ScanCmd
  • func (c *ClusterPipeline) ScriptExists(scripts ...string) *BoolSliceCmd
  • func (c *ClusterPipeline) ScriptFlush() *StatusCmd
  • func (c *ClusterPipeline) ScriptKill() *StatusCmd
  • func (c *ClusterPipeline) ScriptLoad(script string) *StringCmd
  • func (c *ClusterPipeline) Select(index int64) *StatusCmd
  • func (c *ClusterPipeline) Set(key string, value interface{}, expiration time.Duration) *StatusCmd
  • func (c *ClusterPipeline) SetBit(key string, offset int64, value int) *IntCmd
  • func (c *ClusterPipeline) SetNX(key string, value interface{}, expiration time.Duration) *BoolCmd
  • func (c *ClusterPipeline) SetRange(key string, offset int64, value string) *IntCmd
  • func (c *ClusterPipeline) Shutdown() *StatusCmd
  • func (c *ClusterPipeline) ShutdownNoSave() *StatusCmd
  • func (c *ClusterPipeline) ShutdownSave() *StatusCmd
  • func (c *ClusterPipeline) SlaveOf(host, port string) *StatusCmd
  • func (c *ClusterPipeline) SlowLog()
  • func (c *ClusterPipeline) Sort(key string, sort Sort) *StringSliceCmd
  • func (c *ClusterPipeline) StrLen(key string) *IntCmd
  • func (c *ClusterPipeline) Sync()
  • func (c *ClusterPipeline) TTL(key string) *DurationCmd
  • func (c *ClusterPipeline) Time() *StringSliceCmd
  • func (c *ClusterPipeline) Type(key string) *StatusCmd
  • func (c *ClusterPipeline) ZAdd(key string, members ...Z) *IntCmd
  • func (c *ClusterPipeline) ZAddCh(key string, members ...Z) *IntCmd
  • func (c *ClusterPipeline) ZAddNX(key string, members ...Z) *IntCmd
  • func (c *ClusterPipeline) ZAddNXCh(key string, members ...Z) *IntCmd
  • func (c *ClusterPipeline) ZAddXX(key string, members ...Z) *IntCmd
  • func (c *ClusterPipeline) ZAddXXCh(key string, members ...Z) *IntCmd
  • func (c *ClusterPipeline) ZCard(key string) *IntCmd
  • func (c *ClusterPipeline) ZCount(key, min, max string) *IntCmd
  • func (c *ClusterPipeline) ZIncr(key string, member Z) *FloatCmd
  • func (c *ClusterPipeline) ZIncrBy(key string, increment float64, member string) *FloatCmd
  • func (c *ClusterPipeline) ZIncrNX(key string, member Z) *FloatCmd
  • func (c *ClusterPipeline) ZIncrXX(key string, member Z) *FloatCmd
  • func (c *ClusterPipeline) ZInterStore(destination string, store ZStore, keys ...string) *IntCmd
  • func (c *ClusterPipeline) ZRange(key string, start, stop int64) *StringSliceCmd
  • func (c *ClusterPipeline) ZRangeByLex(key string, opt ZRangeByScore) *StringSliceCmd
  • func (c *ClusterPipeline) ZRangeByScore(key string, opt ZRangeByScore) *StringSliceCmd
  • func (c *ClusterPipeline) ZRangeByScoreWithScores(key string, opt ZRangeByScore) *ZSliceCmd
  • func (c *ClusterPipeline) ZRangeWithScores(key string, start, stop int64) *ZSliceCmd
  • func (c *ClusterPipeline) ZRank(key, member string) *IntCmd
  • func (c *ClusterPipeline) ZRem(key string, members ...string) *IntCmd
  • func (c *ClusterPipeline) ZRemRangeByRank(key string, start, stop int64) *IntCmd
  • func (c *ClusterPipeline) ZRemRangeByScore(key, min, max string) *IntCmd
  • func (c *ClusterPipeline) ZRevRange(key string, start, stop int64) *StringSliceCmd
  • func (c ClusterPipeline) ZRevRangeByLex(key string, opt ZRangeByScore) *StringSliceCmd
  • func (c *ClusterPipeline) ZRevRangeByScore(key string, opt ZRangeByScore) *StringSliceCmd
  • func (c *ClusterPipeline) ZRevRangeByScoreWithScores(key string, opt ZRangeByScore) *ZSliceCmd
  • func (c *ClusterPipeline) ZRevRangeWithScores(key string, start, stop int64) *ZSliceCmd
  • func (c *ClusterPipeline) ZRevRank(key, member string) *IntCmd
  • func (c *ClusterPipeline) ZScan(key string, cursor int64, match string, count int64) *ScanCmd
  • func (c *ClusterPipeline) ZScore(key, member string) *FloatCmd
  • func (c *ClusterPipeline) ZUnionStore(dest string, store ZStore, keys ...string) *IntCmd
• type ClusterSlotCmd
  • func NewClusterSlotCmd(args ...interface{}) *ClusterSlotCmd
  • func (cmd *ClusterSlotCmd) Err() error
  • func (cmd *ClusterSlotCmd) Result() ([]ClusterSlotInfo, error)
  • func (cmd *ClusterSlotCmd) String() string
  • func (cmd *ClusterSlotCmd) Val() []ClusterSlotInfo
• type ClusterSlotInfo
• type Cmd
  • func NewCmd(args ...interface{}) *Cmd
  • func (cmd *Cmd) Err() error
  • func (cmd *Cmd) Result() (interface{}, error)
  • func (cmd *Cmd) String() string
  • func (cmd *Cmd) Val() interface{}
• type Cmder
• type DurationCmd
  • func NewDurationCmd(precision time.Duration, args ...interface{}) *DurationCmd
  • func (cmd *DurationCmd) Err() error
  • func (cmd *DurationCmd) Result() (time.Duration, error)
  • func (cmd *DurationCmd) String() string
  • func (cmd *DurationCmd) Val() time.Duration
• type FailoverOptions
• type FloatCmd
  • func NewFloatCmd(args ...interface{}) *FloatCmd
  • func (cmd *FloatCmd) Err() error
  • func (cmd *FloatCmd) Result() (float64, error)
  • func (cmd *FloatCmd) String() string
  • func (cmd *FloatCmd) Val() float64
• type IntCmd
  • func NewIntCmd(args ...interface{}) *IntCmd
  • func (cmd *IntCmd) Err() error
  • func (cmd *IntCmd) Result() (int64, error)
  • func (cmd *IntCmd) String() string
  • func (cmd *IntCmd) Val() int64
• type Message
  • func (m *Message) String() string
• type Multi
  • func (c *Multi) Append(key, value string) *IntCmd
  • func (c *Multi) Auth(password string) *StatusCmd
  • func (c *Multi) BLPop(timeout time.Duration, keys ...string) *StringSliceCmd
  • func (c *Multi) BRPop(timeout time.Duration, keys ...string) *StringSliceCmd
  • func (c *Multi) BRPopLPush(source, destination string, timeout time.Duration) *StringCmd
  • func (c *Multi) BgRewriteAOF() *StatusCmd
  • func (c *Multi) BgSave() *StatusCmd
  • func (c *Multi) BitCount(key string, bitCount *BitCount) *IntCmd
  • func (c *Multi) BitOpAnd(destKey string, keys ...string) *IntCmd
  • func (c *Multi) BitOpNot(destKey string, key string) *IntCmd
  • func (c *Multi) BitOpOr(destKey string, keys ...string) *IntCmd
  • func (c *Multi) BitOpXor(destKey string, keys ...string) *IntCmd
  • func (c *Multi) BitPos(key string, bit int64, pos ...int64) *IntCmd
  • func (c *Multi) ClientKill(ipPort string) *StatusCmd
  • func (c *Multi) ClientList() *StringCmd
  • func (c *Multi) ClientPause(dur time.Duration) *BoolCmd
  • func (c *Multi) Close() error
  • func (c *Multi) ClusterAddSlots(slots ...int) *StatusCmd
  • func (c *Multi) ClusterAddSlotsRange(min, max int) *StatusCmd
  • func (c *Multi) ClusterFailover() *StatusCmd
  • func (c *Multi) ClusterInfo() *StringCmd
  • func (c *Multi) ClusterMeet(host, port string) *StatusCmd
  • func (c *Multi) ClusterNodes() *StringCmd
  • func (c *Multi) ClusterReplicate(nodeID string) *StatusCmd
  • func (c *Multi) ClusterSlots() *ClusterSlotCmd
  • func (c *Multi) ConfigGet(parameter string) *SliceCmd
  • func (c *Multi) ConfigResetStat() *StatusCmd
  • func (c *Multi) ConfigSet(parameter, value string) *StatusCmd
  • func (c *Multi) DbSize() *IntCmd
  • func (c *Multi) DebugObject(key string) *StringCmd
  • func (c *Multi) Decr(key string) *IntCmd
  • func (c *Multi) DecrBy(key string, decrement int64) *IntCmd
  • func (c *Multi) Del(keys ...string) *IntCmd
  • func (c *Multi) Discard() error
  • func (c *Multi) Dump(key string) *StringCmd
  • func (c *Multi) Echo(message string) *StringCmd
  • func (c *Multi) Eval(script string, keys []string, args []string) *Cmd
  • func (c *Multi) EvalSha(sha1 string, keys []string, args []string) *Cmd
  • func (c *Multi) Exec(f func() error) ([]Cmder, error)
  • func (c *Multi) Exists(key string) *BoolCmd
  • func (c *Multi) Expire(key string, expiration time.Duration) *BoolCmd
  • func (c *Multi) ExpireAt(key string, tm time.Time) *BoolCmd
  • func (c *Multi) FlushAll() *StatusCmd
  • func (c *Multi) FlushDb() *StatusCmd
  • func (c *Multi) Get(key string) *StringCmd
  • func (c *Multi) GetBit(key string, offset int64) *IntCmd
  • func (c *Multi) GetRange(key string, start, end int64) *StringCmd
  • func (c *Multi) GetSet(key string, value interface{}) *StringCmd
  • func (c *Multi) HDel(key string, fields ...string) *IntCmd
  • func (c *Multi) HExists(key, field string) *BoolCmd
  • func (c *Multi) HGet(key, field string) *StringCmd
  • func (c *Multi) HGetAll(key string) *StringSliceCmd
  • func (c *Multi) HGetAllMap(key string) *StringStringMapCmd
  • func (c *Multi) HIncrBy(key, field string, incr int64) *IntCmd
  • func (c *Multi) HIncrByFloat(key, field string, incr float64) *FloatCmd
  • func (c *Multi) HKeys(key string) *StringSliceCmd
  • func (c *Multi) HLen(key string) *IntCmd
  • func (c *Multi) HMGet(key string, fields ...string) *SliceCmd
  • func (c *Multi) HMSet(key, field, value string, pairs ...string) *StatusCmd
  • func (c *Multi) HScan(key string, cursor int64, match string, count int64) *ScanCmd
  • func (c *Multi) HSet(key, field, value string) *BoolCmd
  • func (c *Multi) HSetNX(key, field, value string) *BoolCmd
  • func (c *Multi) HVals(key string) *StringSliceCmd
  • func (c *Multi) Incr(key string) *IntCmd
  • func (c *Multi) IncrBy(key string, value int64) *IntCmd
  • func (c *Multi) IncrByFloat(key string, value float64) *FloatCmd
  • func (c *Multi) Info() *StringCmd
  • func (c *Multi) Keys(pattern string) *StringSliceCmd
  • func (c *Multi) LIndex(key string, index int64) *StringCmd
  • func (c *Multi) LInsert(key, op, pivot, value string) *IntCmd
  • func (c *Multi) LLen(key string) *IntCmd
  • func (c *Multi) LPop(key string) *StringCmd
  • func (c *Multi) LPush(key string, values ...string) *IntCmd
  • func (c *Multi) LPushX(key, value string) *IntCmd
  • func (c *Multi) LRange(key string, start, stop int64) *StringSliceCmd
  • func (c *Multi) LRem(key string, count int64, value string) *IntCmd
  • func (c *Multi) LSet(key string, index int64, value string) *StatusCmd
  • func (c *Multi) LTrim(key string, start, stop int64) *StatusCmd
  • func (c *Multi) LastSave() *IntCmd
  • func (c *Multi) MGet(keys ...string) *SliceCmd
  • func (c *Multi) MSet(pairs ...string) *StatusCmd
  • func (c *Multi) MSetNX(pairs ...string) *BoolCmd
  • func (c *Multi) Migrate(host, port, key string, db int64, timeout time.Duration) *StatusCmd
  • func (c *Multi) Move(key string, db int64) *BoolCmd
  • func (c *Multi) ObjectEncoding(keys ...string) *StringCmd
  • func (c *Multi) ObjectIdleTime(keys ...string) *DurationCmd
  • func (c *Multi) ObjectRefCount(keys ...string) *IntCmd
  • func (c *Multi) PExpire(key string, expiration time.Duration) *BoolCmd
  • func (c *Multi) PExpireAt(key string, tm time.Time) *BoolCmd
  • func (c *Multi) PTTL(key string) *DurationCmd
  • func (c *Multi) Persist(key string) *BoolCmd
  • func (c *Multi) Ping() *StatusCmd
  • func (c *Multi) Process(cmd Cmder)
  • func (c *Multi) PubSubChannels(pattern string) *StringSliceCmd
  • func (c *Multi) PubSubNumPat() *IntCmd
  • func (c *Multi) PubSubNumSub(channels ...string) *StringIntMapCmd
  • func (c *Multi) Quit() *StatusCmd
  • func (c *Multi) RPop(key string) *StringCmd
  • func (c *Multi) RPopLPush(source, destination string) *StringCmd
  • func (c *Multi) RPush(key string, values ...string) *IntCmd
  • func (c *Multi) RPushX(key string, value string) *IntCmd
  • func (c *Multi) RandomKey() *StringCmd
  • func (c *Multi) Rename(key, newkey string) *StatusCmd
  • func (c *Multi) RenameNX(key, newkey string) *BoolCmd
  • func (c *Multi) Restore(key string, ttl time.Duration, value string) *StatusCmd
  • func (c *Multi) RestoreReplace(key string, ttl time.Duration, value string) *StatusCmd
  • func (c *Multi) SAdd(key string, members ...string) *IntCmd
  • func (c *Multi) SCard(key string) *IntCmd
  • func (c *Multi) SDiff(keys ...string) *StringSliceCmd
  • func (c *Multi) SDiffStore(destination string, keys ...string) *IntCmd
  • func (c *Multi) SInter(keys ...string) *StringSliceCmd
  • func (c *Multi) SInterStore(destination string, keys ...string) *IntCmd
  • func (c *Multi) SIsMember(key, member string) *BoolCmd
  • func (c *Multi) SMembers(key string) *StringSliceCmd
  • func (c *Multi) SMove(source, destination, member string) *BoolCmd
  • func (c *Multi) SPop(key string) *StringCmd
  • func (c *Multi) SRandMember(key string) *StringCmd
  • func (c *Multi) SRandMemberN(key string, count int64) *StringSliceCmd
  • func (c *Multi) SRem(key string, members ...string) *IntCmd
  • func (c *Multi) SScan(key string, cursor int64, match string, count int64) *ScanCmd
  • func (c *Multi) SUnion(keys ...string) *StringSliceCmd
  • func (c *Multi) SUnionStore(destination string, keys ...string) *IntCmd
  • func (c *Multi) Save() *StatusCmd
  • func (c *Multi) Scan(cursor int64, match string, count int64) *ScanCmd
  • func (c *Multi) ScriptExists(scripts ...string) *BoolSliceCmd
  • func (c *Multi) ScriptFlush() *StatusCmd
  • func (c *Multi) ScriptKill() *StatusCmd
  • func (c *Multi) ScriptLoad(script string) *StringCmd
  • func (c *Multi) Select(index int64) *StatusCmd
  • func (c *Multi) Set(key string, value interface{}, expiration time.Duration) *StatusCmd
  • func (c *Multi) SetBit(key string, offset int64, value int) *IntCmd
  • func (c *Multi) SetNX(key string, value interface{}, expiration time.Duration) *BoolCmd
  • func (c *Multi) SetRange(key string, offset int64, value string) *IntCmd
  • func (c *Multi) Shutdown() *StatusCmd
  • func (c *Multi) ShutdownNoSave() *StatusCmd
  • func (c *Multi) ShutdownSave() *StatusCmd
  • func (c *Multi) SlaveOf(host, port string) *StatusCmd
  • func (c *Multi) SlowLog()
  • func (c *Multi) Sort(key string, sort Sort) *StringSliceCmd
  • func (c *Multi) StrLen(key string) *IntCmd
  • func (c *Multi) Sync()
  • func (c *Multi) TTL(key string) *DurationCmd
  • func (c *Multi) Time() *StringSliceCmd
  • func (c *Multi) Type(key string) *StatusCmd
  • func (c *Multi) Unwatch(keys ...string) *StatusCmd
  • func (c *Multi) Watch(keys ...string) *StatusCmd
  • func (c *Multi) ZAdd(key string, members ...Z) *IntCmd
  • func (c *Multi) ZAddCh(key string, members ...Z) *IntCmd
  • func (c *Multi) ZAddNX(key string, members ...Z) *IntCmd
  • func (c *Multi) ZAddNXCh(key string, members ...Z) *IntCmd
  • func (c *Multi) ZAddXX(key string, members ...Z) *IntCmd
  • func (c *Multi) ZAddXXCh(key string, members ...Z) *IntCmd
  • func (c *Multi) ZCard(key string) *IntCmd
  • func (c *Multi) ZCount(key, min, max string) *IntCmd
  • func (c *Multi) ZIncr(key string, member Z) *FloatCmd
  • func (c *Multi) ZIncrBy(key string, increment float64, member string) *FloatCmd
  • func (c *Multi) ZIncrNX(key string, member Z) *FloatCmd
  • func (c *Multi) ZIncrXX(key string, member Z) *FloatCmd
  • func (c *Multi) ZInterStore(destination string, store ZStore, keys ...string) *IntCmd
  • func (c *Multi) ZRange(key string, start, stop int64) *StringSliceCmd
  • func (c *Multi) ZRangeByLex(key string, opt ZRangeByScore) *StringSliceCmd
  • func (c *Multi) ZRangeByScore(key string, opt ZRangeByScore) *StringSliceCmd
  • func (c *Multi) ZRangeByScoreWithScores(key string, opt ZRangeByScore) *ZSliceCmd
  • func (c *Multi) ZRangeWithScores(key string, start, stop int64) *ZSliceCmd
  • func (c *Multi) ZRank(key, member string) *IntCmd
  • func (c *Multi) ZRem(key string, members ...string) *IntCmd
  • func (c *Multi) ZRemRangeByRank(key string, start, stop int64) *IntCmd
  • func (c *Multi) ZRemRangeByScore(key, min, max string) *IntCmd
  • func (c *Multi) ZRevRange(key string, start, stop int64) *StringSliceCmd
  • func (c Multi) ZRevRangeByLex(key string, opt ZRangeByScore) *StringSliceCmd
  • func (c *Multi) ZRevRangeByScore(key string, opt ZRangeByScore) *StringSliceCmd
  • func (c *Multi) ZRevRangeByScoreWithScores(key string, opt ZRangeByScore) *ZSliceCmd
  • func (c *Multi) ZRevRangeWithScores(key string, start, stop int64) *ZSliceCmd
  • func (c *Multi) ZRevRank(key, member string) *IntCmd
  • func (c *Multi) ZScan(key string, cursor int64, match string, count int64) *ScanCmd
  • func (c *Multi) ZScore(key, member string) *FloatCmd
  • func (c *Multi) ZUnionStore(dest string, store ZStore, keys ...string) *IntCmd
• type Options
• type PMessage
  • func (m *PMessage) String() string
• 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 (pipe *Pipeline) Close() error
  • func (c *Pipeline) ClusterAddSlots(slots ...int) *StatusCmd
  • func (c *Pipeline) ClusterAddSlotsRange(min, max int) *StatusCmd
  • func (c *Pipeline) ClusterFailover() *StatusCmd
  • func (c *Pipeline) ClusterInfo() *StringCmd
  • func (c *Pipeline) ClusterMeet(host, port string) *StatusCmd
  • func (c *Pipeline) ClusterNodes() *StringCmd
  • func (c *Pipeline) ClusterReplicate(nodeID string) *StatusCmd
  • func (c *Pipeline) ClusterSlots() *ClusterSlotCmd
  • 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 string) *StringCmd
  • func (c *Pipeline) Eval(script string, keys []string, args []string) *Cmd
  • func (c *Pipeline) EvalSha(sha1 string, keys []string, args []string) *Cmd
  • func (pipe *Pipeline) Exec() (cmds []Cmder, retErr 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) 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) *StringSliceCmd
  • func (c *Pipeline) HGetAllMap(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, field, value string, pairs ...string) *StatusCmd
  • func (c *Pipeline) HScan(key string, cursor int64, match string, count int64) *ScanCmd
  • 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() *StringCmd
  • func (c *Pipeline) Keys(pattern string) *StringSliceCmd
  • func (c *Pipeline) LIndex(key string, index int64) *StringCmd
  • func (c *Pipeline) LInsert(key, op, pivot, value string) *IntCmd
  • func (c *Pipeline) LLen(key string) *IntCmd
  • func (c *Pipeline) LPop(key string) *StringCmd
  • func (c *Pipeline) LPush(key string, values ...string) *IntCmd
  • func (c *Pipeline) LPushX(key, value string) *IntCmd
  • func (c *Pipeline) LRange(key string, start, stop int64) *StringSliceCmd
  • func (c *Pipeline) LRem(key string, count int64, value string) *IntCmd
  • func (c *Pipeline) LSet(key string, index int64, value string) *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 ...string) *StatusCmd
  • func (c *Pipeline) MSetNX(pairs ...string) *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) PTTL(key string) *DurationCmd
  • func (c *Pipeline) Persist(key string) *BoolCmd
  • func (c *Pipeline) Ping() *StatusCmd
  • func (c *Pipeline) Process(cmd Cmder)
  • 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 ...string) *IntCmd
  • func (c *Pipeline) RPushX(key string, value string) *IntCmd
  • func (c *Pipeline) RandomKey() *StringCmd
  • 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 ...string) *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, member string) *BoolCmd
  • func (c *Pipeline) SMembers(key string) *StringSliceCmd
  • func (c *Pipeline) SMove(source, destination, member string) *BoolCmd
  • func (c *Pipeline) SPop(key string) *StringCmd
  • func (c *Pipeline) SRandMember(key string) *StringCmd
  • func (c *Pipeline) SRandMemberN(key string, count int64) *StringSliceCmd
  • func (c *Pipeline) SRem(key string, members ...string) *IntCmd
  • func (c *Pipeline) SScan(key string, cursor int64, match string, count int64) *ScanCmd
  • func (c *Pipeline) SUnion(keys ...string) *StringSliceCmd
  • func (c *Pipeline) SUnionStore(destination string, keys ...string) *IntCmd
  • func (c *Pipeline) Save() *StatusCmd
  • func (c *Pipeline) Scan(cursor int64, match string, count int64) *ScanCmd
  • func (c *Pipeline) ScriptExists(scripts ...string) *BoolSliceCmd
  • func (c *Pipeline) ScriptFlush() *StatusCmd
  • func (c *Pipeline) ScriptKill() *StatusCmd
  • func (c *Pipeline) ScriptLoad(script string) *StringCmd
  • func (c *Pipeline) Select(index int64) *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) 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) 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 ZRangeByScore) *StringSliceCmd
  • func (c *Pipeline) ZRangeByScore(key string, opt ZRangeByScore) *StringSliceCmd
  • func (c *Pipeline) ZRangeByScoreWithScores(key string, opt ZRangeByScore) *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 ...string) *IntCmd
  • func (c *Pipeline) ZRemRangeByRank(key string, start, stop int64) *IntCmd
  • func (c *Pipeline) ZRemRangeByScore(key, min, max string) *IntCmd
  • func (c *Pipeline) ZRevRange(key string, start, stop int64) *StringSliceCmd
  • func (c Pipeline) ZRevRangeByLex(key string, opt ZRangeByScore) *StringSliceCmd
  • func (c *Pipeline) ZRevRangeByScore(key string, opt ZRangeByScore) *StringSliceCmd
  • func (c *Pipeline) ZRevRangeByScoreWithScores(key string, opt ZRangeByScore) *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 int64, match string, count int64) *ScanCmd
  • func (c *Pipeline) ZScore(key, member string) *FloatCmd
  • func (c *Pipeline) ZUnionStore(dest string, store ZStore, keys ...string) *IntCmd
• type Pong
  • func (p *Pong) String() string
• 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) String() string
  • func (c *PubSub) Subscribe(channels ...string) error
  • func (c *PubSub) Unsubscribe(channels ...string) error
• type Ring
  • func NewRing(opt *RingOptions) *Ring
  • func (c *Ring) Append(key, value string) *IntCmd
  • func (c *Ring) Auth(password string) *StatusCmd
  • 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 (ring *Ring) Close() (retErr error)
  • func (c *Ring) ClusterAddSlots(slots ...int) *StatusCmd
  • func (c *Ring) ClusterAddSlotsRange(min, max int) *StatusCmd
  • func (c *Ring) ClusterFailover() *StatusCmd
  • func (c *Ring) ClusterInfo() *StringCmd
  • func (c *Ring) ClusterMeet(host, port string) *StatusCmd
  • func (c *Ring) ClusterNodes() *StringCmd
  • func (c *Ring) ClusterReplicate(nodeID string) *StatusCmd
  • func (c *Ring) ClusterSlots() *ClusterSlotCmd
  • 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 string) *StringCmd
  • func (c *Ring) Eval(script string, keys []string, args []string) *Cmd
  • func (c *Ring) EvalSha(sha1 string, keys []string, args []string) *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) 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) *StringSliceCmd
  • func (c *Ring) HGetAllMap(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, field, value string, pairs ...string) *StatusCmd
  • func (c *Ring) HScan(key string, cursor int64, match string, count int64) *ScanCmd
  • 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() *StringCmd
  • func (c *Ring) Keys(pattern string) *StringSliceCmd
  • func (c *Ring) LIndex(key string, index int64) *StringCmd
  • func (c *Ring) LInsert(key, op, pivot, value string) *IntCmd
  • func (c *Ring) LLen(key string) *IntCmd
  • func (c *Ring) LPop(key string) *StringCmd
  • func (c *Ring) LPush(key string, values ...string) *IntCmd
  • func (c *Ring) LPushX(key, value string) *IntCmd
  • func (c *Ring) LRange(key string, start, stop int64) *StringSliceCmd
  • func (c *Ring) LRem(key string, count int64, value string) *IntCmd
  • func (c *Ring) LSet(key string, index int64, value string) *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 ...string) *StatusCmd
  • func (c *Ring) MSetNX(pairs ...string) *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) PTTL(key string) *DurationCmd
  • func (c *Ring) Persist(key string) *BoolCmd
  • func (c *Ring) Ping() *StatusCmd
  • func (ring *Ring) Pipeline() *RingPipeline
  • func (ring *Ring) Pipelined(fn func(*RingPipeline) error) ([]Cmder, error)
  • func (c *Ring) Process(cmd Cmder)
  • 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 ...string) *IntCmd
  • func (c *Ring) RPushX(key string, value string) *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 ...string) *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, member string) *BoolCmd
  • func (c *Ring) SMembers(key string) *StringSliceCmd
  • func (c *Ring) SMove(source, destination, member string) *BoolCmd
  • func (c *Ring) SPop(key string) *StringCmd
  • func (c *Ring) SRandMember(key string) *StringCmd
  • func (c *Ring) SRandMemberN(key string, count int64) *StringSliceCmd
  • func (c *Ring) SRem(key string, members ...string) *IntCmd
  • func (c *Ring) SScan(key string, cursor int64, match string, count int64) *ScanCmd
  • func (c *Ring) SUnion(keys ...string) *StringSliceCmd
  • func (c *Ring) SUnionStore(destination string, keys ...string) *IntCmd
  • func (c *Ring) Save() *StatusCmd
  • func (c *Ring) Scan(cursor int64, match string, count int64) *ScanCmd
  • func (c *Ring) ScriptExists(scripts ...string) *BoolSliceCmd
  • func (c *Ring) ScriptFlush() *StatusCmd
  • func (c *Ring) ScriptKill() *StatusCmd
  • func (c *Ring) ScriptLoad(script string) *StringCmd
  • func (c *Ring) Select(index int64) *StatusCmd
  • 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) 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) 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 ZRangeByScore) *StringSliceCmd
  • func (c *Ring) ZRangeByScore(key string, opt ZRangeByScore) *StringSliceCmd
  • func (c *Ring) ZRangeByScoreWithScores(key string, opt ZRangeByScore) *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 ...string) *IntCmd
  • func (c *Ring) ZRemRangeByRank(key string, start, stop int64) *IntCmd
  • func (c *Ring) ZRemRangeByScore(key, min, max string) *IntCmd
  • func (c *Ring) ZRevRange(key string, start, stop int64) *StringSliceCmd
  • func (c Ring) ZRevRangeByLex(key string, opt ZRangeByScore) *StringSliceCmd
  • func (c *Ring) ZRevRangeByScore(key string, opt ZRangeByScore) *StringSliceCmd
  • func (c *Ring) ZRevRangeByScoreWithScores(key string, opt ZRangeByScore) *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 int64, match string, count int64) *ScanCmd
  • func (c *Ring) ZScore(key, member string) *FloatCmd
  • func (c *Ring) ZUnionStore(dest string, store ZStore, keys ...string) *IntCmd
• type RingOptions
• type RingPipeline
  • func (c *RingPipeline) Append(key, value string) *IntCmd
  • func (c *RingPipeline) Auth(password string) *StatusCmd
  • func (c *RingPipeline) BLPop(timeout time.Duration, keys ...string) *StringSliceCmd
  • func (c *RingPipeline) BRPop(timeout time.Duration, keys ...string) *StringSliceCmd
  • func (c *RingPipeline) BRPopLPush(source, destination string, timeout time.Duration) *StringCmd
  • func (c *RingPipeline) BgRewriteAOF() *StatusCmd
  • func (c *RingPipeline) BgSave() *StatusCmd
  • func (c *RingPipeline) BitCount(key string, bitCount *BitCount) *IntCmd
  • func (c *RingPipeline) BitOpAnd(destKey string, keys ...string) *IntCmd
  • func (c *RingPipeline) BitOpNot(destKey string, key string) *IntCmd
  • func (c *RingPipeline) BitOpOr(destKey string, keys ...string) *IntCmd
  • func (c *RingPipeline) BitOpXor(destKey string, keys ...string) *IntCmd
  • func (c *RingPipeline) BitPos(key string, bit int64, pos ...int64) *IntCmd
  • func (c *RingPipeline) ClientKill(ipPort string) *StatusCmd
  • func (c *RingPipeline) ClientList() *StringCmd
  • func (c *RingPipeline) ClientPause(dur time.Duration) *BoolCmd
  • func (pipe *RingPipeline) Close() error
  • func (c *RingPipeline) ClusterAddSlots(slots ...int) *StatusCmd
  • func (c *RingPipeline) ClusterAddSlotsRange(min, max int) *StatusCmd
  • func (c *RingPipeline) ClusterFailover() *StatusCmd
  • func (c *RingPipeline) ClusterInfo() *StringCmd
  • func (c *RingPipeline) ClusterMeet(host, port string) *StatusCmd
  • func (c *RingPipeline) ClusterNodes() *StringCmd
  • func (c *RingPipeline) ClusterReplicate(nodeID string) *StatusCmd
  • func (c *RingPipeline) ClusterSlots() *ClusterSlotCmd
  • func (c *RingPipeline) ConfigGet(parameter string) *SliceCmd
  • func (c *RingPipeline) ConfigResetStat() *StatusCmd
  • func (c *RingPipeline) ConfigSet(parameter, value string) *StatusCmd
  • func (c *RingPipeline) DbSize() *IntCmd
  • func (c *RingPipeline) DebugObject(key string) *StringCmd
  • func (c *RingPipeline) Decr(key string) *IntCmd
  • func (c *RingPipeline) DecrBy(key string, decrement int64) *IntCmd
  • func (c *RingPipeline) Del(keys ...string) *IntCmd
  • func (pipe *RingPipeline) Discard() error
  • func (c *RingPipeline) Dump(key string) *StringCmd
  • func (c *RingPipeline) Echo(message string) *StringCmd
  • func (c *RingPipeline) Eval(script string, keys []string, args []string) *Cmd
  • func (c *RingPipeline) EvalSha(sha1 string, keys []string, args []string) *Cmd
  • func (pipe *RingPipeline) Exec() (cmds []Cmder, retErr error)
  • func (c *RingPipeline) Exists(key string) *BoolCmd
  • func (c *RingPipeline) Expire(key string, expiration time.Duration) *BoolCmd
  • func (c *RingPipeline) ExpireAt(key string, tm time.Time) *BoolCmd
  • func (c *RingPipeline) FlushAll() *StatusCmd
  • func (c *RingPipeline) FlushDb() *StatusCmd
  • func (c *RingPipeline) Get(key string) *StringCmd
  • func (c *RingPipeline) GetBit(key string, offset int64) *IntCmd
  • func (c *RingPipeline) GetRange(key string, start, end int64) *StringCmd
  • func (c *RingPipeline) GetSet(key string, value interface{}) *StringCmd
  • func (c *RingPipeline) HDel(key string, fields ...string) *IntCmd
  • func (c *RingPipeline) HExists(key, field string) *BoolCmd
  • func (c *RingPipeline) HGet(key, field string) *StringCmd
  • func (c *RingPipeline) HGetAll(key string) *StringSliceCmd
  • func (c *RingPipeline) HGetAllMap(key string) *StringStringMapCmd
  • func (c *RingPipeline) HIncrBy(key, field string, incr int64) *IntCmd
  • func (c *RingPipeline) HIncrByFloat(key, field string, incr float64) *FloatCmd
  • func (c *RingPipeline) HKeys(key string) *StringSliceCmd
  • func (c *RingPipeline) HLen(key string) *IntCmd
  • func (c *RingPipeline) HMGet(key string, fields ...string) *SliceCmd
  • func (c *RingPipeline) HMSet(key, field, value string, pairs ...string) *StatusCmd
  • func (c *RingPipeline) HScan(key string, cursor int64, match string, count int64) *ScanCmd
  • func (c *RingPipeline) HSet(key, field, value string) *BoolCmd
  • func (c *RingPipeline) HSetNX(key, field, value string) *BoolCmd
  • func (c *RingPipeline) HVals(key string) *StringSliceCmd
  • func (c *RingPipeline) Incr(key string) *IntCmd
  • func (c *RingPipeline) IncrBy(key string, value int64) *IntCmd
  • func (c *RingPipeline) IncrByFloat(key string, value float64) *FloatCmd
  • func (c *RingPipeline) Info() *StringCmd
  • func (c *RingPipeline) Keys(pattern string) *StringSliceCmd
  • func (c *RingPipeline) LIndex(key string, index int64) *StringCmd
  • func (c *RingPipeline) LInsert(key, op, pivot, value string) *IntCmd
  • func (c *RingPipeline) LLen(key string) *IntCmd
  • func (c *RingPipeline) LPop(key string) *StringCmd
  • func (c *RingPipeline) LPush(key string, values ...string) *IntCmd
  • func (c *RingPipeline) LPushX(key, value string) *IntCmd
  • func (c *RingPipeline) LRange(key string, start, stop int64) *StringSliceCmd
  • func (c *RingPipeline) LRem(key string, count int64, value string) *IntCmd
  • func (c *RingPipeline) LSet(key string, index int64, value string) *StatusCmd
  • func (c *RingPipeline) LTrim(key string, start, stop int64) *StatusCmd
  • func (c *RingPipeline) LastSave() *IntCmd
  • func (c *RingPipeline) MGet(keys ...string) *SliceCmd
  • func (c *RingPipeline) MSet(pairs ...string) *StatusCmd
  • func (c *RingPipeline) MSetNX(pairs ...string) *BoolCmd
  • func (c *RingPipeline) Migrate(host, port, key string, db int64, timeout time.Duration) *StatusCmd
  • func (c *RingPipeline) Move(key string, db int64) *BoolCmd
  • func (c *RingPipeline) ObjectEncoding(keys ...string) *StringCmd
  • func (c *RingPipeline) ObjectIdleTime(keys ...string) *DurationCmd
  • func (c *RingPipeline) ObjectRefCount(keys ...string) *IntCmd
  • func (c *RingPipeline) PExpire(key string, expiration time.Duration) *BoolCmd
  • func (c *RingPipeline) PExpireAt(key string, tm time.Time) *BoolCmd
  • func (c *RingPipeline) PTTL(key string) *DurationCmd
  • func (c *RingPipeline) Persist(key string) *BoolCmd
  • func (c *RingPipeline) Ping() *StatusCmd
  • func (c *RingPipeline) Process(cmd Cmder)
  • func (c *RingPipeline) PubSubChannels(pattern string) *StringSliceCmd
  • func (c *RingPipeline) PubSubNumPat() *IntCmd
  • func (c *RingPipeline) PubSubNumSub(channels ...string) *StringIntMapCmd
  • func (c *RingPipeline) Quit() *StatusCmd
  • func (c *RingPipeline) RPop(key string) *StringCmd
  • func (c *RingPipeline) RPopLPush(source, destination string) *StringCmd
  • func (c *RingPipeline) RPush(key string, values ...string) *IntCmd
  • func (c *RingPipeline) RPushX(key string, value string) *IntCmd
  • func (c *RingPipeline) RandomKey() *StringCmd
  • func (c *RingPipeline) Rename(key, newkey string) *StatusCmd
  • func (c *RingPipeline) RenameNX(key, newkey string) *BoolCmd
  • func (c *RingPipeline) Restore(key string, ttl time.Duration, value string) *StatusCmd
  • func (c *RingPipeline) RestoreReplace(key string, ttl time.Duration, value string) *StatusCmd
  • func (c *RingPipeline) SAdd(key string, members ...string) *IntCmd
  • func (c *RingPipeline) SCard(key string) *IntCmd
  • func (c *RingPipeline) SDiff(keys ...string) *StringSliceCmd
  • func (c *RingPipeline) SDiffStore(destination string, keys ...string) *IntCmd
  • func (c *RingPipeline) SInter(keys ...string) *StringSliceCmd
  • func (c *RingPipeline) SInterStore(destination string, keys ...string) *IntCmd
  • func (c *RingPipeline) SIsMember(key, member string) *BoolCmd
  • func (c *RingPipeline) SMembers(key string) *StringSliceCmd
  • func (c *RingPipeline) SMove(source, destination, member string) *BoolCmd
  • func (c *RingPipeline) SPop(key string) *StringCmd
  • func (c *RingPipeline) SRandMember(key string) *StringCmd
  • func (c *RingPipeline) SRandMemberN(key string, count int64) *StringSliceCmd
  • func (c *RingPipeline) SRem(key string, members ...string) *IntCmd
  • func (c *RingPipeline) SScan(key string, cursor int64, match string, count int64) *ScanCmd
  • func (c *RingPipeline) SUnion(keys ...string) *StringSliceCmd
  • func (c *RingPipeline) SUnionStore(destination string, keys ...string) *IntCmd
  • func (c *RingPipeline) Save() *StatusCmd
  • func (c *RingPipeline) Scan(cursor int64, match string, count int64) *ScanCmd
  • func (c *RingPipeline) ScriptExists(scripts ...string) *BoolSliceCmd
  • func (c *RingPipeline) ScriptFlush() *StatusCmd
  • func (c *RingPipeline) ScriptKill() *StatusCmd
  • func (c *RingPipeline) ScriptLoad(script string) *StringCmd
  • func (c *RingPipeline) Select(index int64) *StatusCmd
  • func (c *RingPipeline) Set(key string, value interface{}, expiration time.Duration) *StatusCmd
  • func (c *RingPipeline) SetBit(key string, offset int64, value int) *IntCmd
  • func (c *RingPipeline) SetNX(key string, value interface{}, expiration time.Duration) *BoolCmd
  • func (c *RingPipeline) SetRange(key string, offset int64, value string) *IntCmd
  • func (c *RingPipeline) Shutdown() *StatusCmd
  • func (c *RingPipeline) ShutdownNoSave() *StatusCmd
  • func (c *RingPipeline) ShutdownSave() *StatusCmd
  • func (c *RingPipeline) SlaveOf(host, port string) *StatusCmd
  • func (c *RingPipeline) SlowLog()
  • func (c *RingPipeline) Sort(key string, sort Sort) *StringSliceCmd
  • func (c *RingPipeline) StrLen(key string) *IntCmd
  • func (c *RingPipeline) Sync()
  • func (c *RingPipeline) TTL(key string) *DurationCmd
  • func (c *RingPipeline) Time() *StringSliceCmd
  • func (c *RingPipeline) Type(key string) *StatusCmd
  • func (c *RingPipeline) ZAdd(key string, members ...Z) *IntCmd
  • func (c *RingPipeline) ZAddCh(key string, members ...Z) *IntCmd
  • func (c *RingPipeline) ZAddNX(key string, members ...Z) *IntCmd
  • func (c *RingPipeline) ZAddNXCh(key string, members ...Z) *IntCmd
  • func (c *RingPipeline) ZAddXX(key string, members ...Z) *IntCmd
  • func (c *RingPipeline) ZAddXXCh(key string, members ...Z) *IntCmd
  • func (c *RingPipeline) ZCard(key string) *IntCmd
  • func (c *RingPipeline) ZCount(key, min, max string) *IntCmd
  • func (c *RingPipeline) ZIncr(key string, member Z) *FloatCmd
  • func (c *RingPipeline) ZIncrBy(key string, increment float64, member string) *FloatCmd
  • func (c *RingPipeline) ZIncrNX(key string, member Z) *FloatCmd
  • func (c *RingPipeline) ZIncrXX(key string, member Z) *FloatCmd
  • func (c *RingPipeline) ZInterStore(destination string, store ZStore, keys ...string) *IntCmd
  • func (c *RingPipeline) ZRange(key string, start, stop int64) *StringSliceCmd
  • func (c *RingPipeline) ZRangeByLex(key string, opt ZRangeByScore) *StringSliceCmd
  • func (c *RingPipeline) ZRangeByScore(key string, opt ZRangeByScore) *StringSliceCmd
  • func (c *RingPipeline) ZRangeByScoreWithScores(key string, opt ZRangeByScore) *ZSliceCmd
  • func (c *RingPipeline) ZRangeWithScores(key string, start, stop int64) *ZSliceCmd
  • func (c *RingPipeline) ZRank(key, member string) *IntCmd
  • func (c *RingPipeline) ZRem(key string, members ...string) *IntCmd
  • func (c *RingPipeline) ZRemRangeByRank(key string, start, stop int64) *IntCmd
  • func (c *RingPipeline) ZRemRangeByScore(key, min, max string) *IntCmd
  • func (c *RingPipeline) ZRevRange(key string, start, stop int64) *StringSliceCmd
  • func (c RingPipeline) ZRevRangeByLex(key string, opt ZRangeByScore) *StringSliceCmd
  • func (c *RingPipeline) ZRevRangeByScore(key string, opt ZRangeByScore) *StringSliceCmd
  • func (c *RingPipeline) ZRevRangeByScoreWithScores(key string, opt ZRangeByScore) *ZSliceCmd
  • func (c *RingPipeline) ZRevRangeWithScores(key string, start, stop int64) *ZSliceCmd
  • func (c *RingPipeline) ZRevRank(key, member string) *IntCmd
  • func (c *RingPipeline) ZScan(key string, cursor int64, match string, count int64) *ScanCmd
  • func (c *RingPipeline) ZScore(key, member string) *FloatCmd
  • func (c *RingPipeline) ZUnionStore(dest string, store ZStore, keys ...string) *IntCmd
• type ScanCmd
  • func NewScanCmd(args ...interface{}) *ScanCmd
  • func (cmd *ScanCmd) Err() error
  • func (cmd *ScanCmd) Result() (int64, []string, error)
  • func (cmd *ScanCmd) String() string
  • func (cmd *ScanCmd) Val() (int64, []string)
• type Script
  • func NewScript(src string) *Script
  • func (s *Script) Eval(c scripter, keys []string, args []string) *Cmd
  • func (s *Script) EvalSha(c scripter, keys []string, args []string) *Cmd
  • func (s *Script) Exists(c scripter) *BoolSliceCmd
  • func (s *Script) Load(c scripter) *StringCmd
  • func (s *Script) Run(c scripter, keys []string, args []string) *Cmd
• type SliceCmd
  • func NewSliceCmd(args ...interface{}) *SliceCmd
  • func (cmd *SliceCmd) Err() error
  • func (cmd *SliceCmd) Result() ([]interface{}, error)
  • func (cmd *SliceCmd) String() string
  • func (cmd *SliceCmd) Val() []interface{}
• type Sort
• type StatusCmd
  • func NewStatusCmd(args ...interface{}) *StatusCmd
  • func (cmd *StatusCmd) Err() error
  • func (cmd *StatusCmd) Result() (string, error)
  • func (cmd *StatusCmd) String() string
  • func (cmd *StatusCmd) Val() string
• type StringCmd
  • func NewStringCmd(args ...interface{}) *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
  • func NewStringIntMapCmd(args ...interface{}) *StringIntMapCmd
  • func (cmd *StringIntMapCmd) Err() error
  • func (cmd *StringIntMapCmd) Result() (map[string]int64, error)
  • func (cmd *StringIntMapCmd) String() string
  • func (cmd *StringIntMapCmd) Val() map[string]int64
• type StringSliceCmd
  • func NewStringSliceCmd(args ...interface{}) *StringSliceCmd
  • func (cmd *StringSliceCmd) Err() error
  • func (cmd *StringSliceCmd) Result() ([]string, error)
  • func (cmd *StringSliceCmd) String() string
  • func (cmd *StringSliceCmd) Val() []string
• type StringStringMapCmd
  • func NewStringStringMapCmd(args ...interface{}) *StringStringMapCmd
  • func (cmd *StringStringMapCmd) Err() error
  • func (cmd *StringStringMapCmd) Result() (map[string]string, error)
  • func (cmd *StringStringMapCmd) String() string
  • func (cmd *StringStringMapCmd) Val() map[string]string
• type Subscription
  • func (m *Subscription) String() string
• type Z
• type ZRangeByScore
• type ZSliceCmd
  • func NewZSliceCmd(args ...interface{}) *ZSliceCmd
  • func (cmd *ZSliceCmd) Err() error
  • func (cmd *ZSliceCmd) Result() ([]Z, error)
  • func (cmd *ZSliceCmd) String() string
  • func (cmd *ZSliceCmd) Val() []Z
• type ZStore

Examples

• Package (CustomCommand)
• Client
• Client.Incr
• Client.Pipelined
• Client.Scan
• Client.Set
• Multi
• NewClient
• NewClusterClient
• NewFailoverClient
• NewRing
• Pipeline
• PubSub
• PubSub.Receive
• Script

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.

Types

type BitCount

type BitCount struct {
	Start, End int64
}

type BoolCmd

type BoolCmd struct {
	// contains filtered or unexported fields
}

func NewBoolCmd

func NewBoolCmd(args ...interface{}) *BoolCmd

func (*BoolCmd) Err

func (cmd *BoolCmd) Err() error

func (*BoolCmd) Result

func (cmd *BoolCmd) Result() (bool, error)

func (*BoolCmd) String

func (cmd *BoolCmd) String() string

func (*BoolCmd) Val

func (cmd *BoolCmd) Val() bool

type BoolSliceCmd

type BoolSliceCmd struct {
	// contains filtered or unexported fields
}

func NewBoolSliceCmd

func NewBoolSliceCmd(args ...interface{}) *BoolSliceCmd

func (*BoolSliceCmd) Err

func (cmd *BoolSliceCmd) Err() error

func (*BoolSliceCmd) Result

func (cmd *BoolSliceCmd) Result() ([]bool, error)

func (*BoolSliceCmd) String

func (cmd *BoolSliceCmd) String() string

func (*BoolSliceCmd) Val

func (cmd *BoolSliceCmd) Val() []bool

type Client

type Client struct {
	// contains filtered or unexported fields
}

Client is a Redis client representing a pool of zero or more underlying connections. It's safe for concurrent use by multiple goroutines.

Example

err := client.Set("key", "value", 0).Err()
if err != nil {
	panic(err)
}

val, err := client.Get("key").Result()
if err != nil {
	panic(err)
}
fmt.Println("key", val)

val2, err := client.Get("key2").Result()
if err == redis.Nil {
	fmt.Println("key2 does not exists")
} else if err != nil {
	panic(err)
} else {
	fmt.Println("key2", val2)
}

Output:

key value
key2 does not exists

func NewClient

func NewClient(opt *Options) *Client

NewClient returns a client to the Redis Server specified by Options.

Example

client := redis.NewClient(&redis.Options{
	Addr:     "localhost:6379",
	Password: "", // no password set
	DB:       0,  // use default DB
})

pong, err := client.Ping().Result()
fmt.Println(pong, err)

Output:

PONG <nil>

func NewFailoverClient

func NewFailoverClient(failoverOpt *FailoverOptions) *Client

NewFailoverClient returns a Redis client that uses Redis Sentinel for automatic failover. It's safe for concurrent use by multiple goroutines.

Example

// See http://redis.io/topics/sentinel for instructions how to
// setup Redis Sentinel.
client := redis.NewFailoverClient(&redis.FailoverOptions{
	MasterName:    "master",
	SentinelAddrs: []string{":26379"},
})
client.Ping()

func (*Client) Append

func (c *Client) Append(key, value string) *IntCmd

func (*Client) Auth

func (c *Client) Auth(password string) *StatusCmd

func (*Client) BLPop

func (c *Client) BLPop(timeout time.Duration, keys ...string) *StringSliceCmd

func (*Client) BRPop

func (c *Client) BRPop(timeout time.Duration, keys ...string) *StringSliceCmd

func (*Client) BRPopLPush

func (c *Client) BRPopLPush(source, destination string, timeout time.Duration) *StringCmd

func (*Client) BgRewriteAOF

func (c *Client) BgRewriteAOF() *StatusCmd

func (*Client) BgSave

func (c *Client) BgSave() *StatusCmd

func (*Client) BitCount

func (c *Client) BitCount(key string, bitCount *BitCount) *IntCmd

func (*Client) BitOpAnd

func (c *Client) BitOpAnd(destKey string, keys ...string) *IntCmd

func (*Client) BitOpNot

func (c *Client) BitOpNot(destKey string, key string) *IntCmd

func (*Client) BitOpOr

func (c *Client) BitOpOr(destKey string, keys ...string) *IntCmd

func (*Client) BitOpXor

func (c *Client) BitOpXor(destKey string, keys ...string) *IntCmd

func (*Client) BitPos

func (c *Client) BitPos(key string, bit int64, pos ...int64) *IntCmd

func (*Client) ClientKill

func (c *Client) ClientKill(ipPort string) *StatusCmd

func (*Client) ClientList

func (c *Client) ClientList() *StringCmd

func (*Client) ClientPause

func (c *Client) ClientPause(dur time.Duration) *BoolCmd

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 (c *Client) ClusterAddSlots(slots ...int) *StatusCmd

func (*Client) ClusterAddSlotsRange

func (c *Client) ClusterAddSlotsRange(min, max int) *StatusCmd

func (*Client) ClusterFailover

func (c *Client) ClusterFailover() *StatusCmd

func (*Client) ClusterInfo

func (c *Client) ClusterInfo() *StringCmd

func (*Client) ClusterMeet

func (c *Client) ClusterMeet(host, port string) *StatusCmd

func (*Client) ClusterNodes

func (c *Client) ClusterNodes() *StringCmd

func (*Client) ClusterReplicate

func (c *Client) ClusterReplicate(nodeID string) *StatusCmd

func (*Client) ClusterSlots

func (c *Client) ClusterSlots() *ClusterSlotCmd

func (*Client) ConfigGet

func (c *Client) ConfigGet(parameter string) *SliceCmd

func (*Client) ConfigResetStat

func (c *Client) ConfigResetStat() *StatusCmd

func (*Client) ConfigSet

func (c *Client) ConfigSet(parameter, value string) *StatusCmd

func (*Client) DbSize

func (c *Client) DbSize() *IntCmd

func (*Client) DebugObject

func (c *Client) DebugObject(key string) *StringCmd

func (*Client) Decr

func (c *Client) Decr(key string) *IntCmd

func (*Client) DecrBy

func (c *Client) DecrBy(key string, decrement int64) *IntCmd

func (*Client) Del

func (c *Client) Del(keys ...string) *IntCmd

func (*Client) Dump

func (c *Client) Dump(key string) *StringCmd

func (*Client) Echo

func (c *Client) Echo(message string) *StringCmd

func (*Client) Eval

func (c *Client) Eval(script string, keys []string, args []string) *Cmd

func (*Client) EvalSha

func (c *Client) EvalSha(sha1 string, keys []string, args []string) *Cmd

func (*Client) Exists

func (c *Client) Exists(key string) *BoolCmd

func (*Client) Expire

func (c *Client) Expire(key string, expiration time.Duration) *BoolCmd

func (*Client) ExpireAt

func (c *Client) ExpireAt(key string, tm time.Time) *BoolCmd

func (*Client) FlushAll

func (c *Client) FlushAll() *StatusCmd

func (*Client) FlushDb

func (c *Client) FlushDb() *StatusCmd

func (*Client) Get

func (c *Client) Get(key string) *StringCmd

func (*Client) GetBit

func (c *Client) GetBit(key string, offset int64) *IntCmd

func (*Client) GetRange

func (c *Client) GetRange(key string, start, end int64) *StringCmd

func (*Client) GetSet

func (c *Client) GetSet(key string, value interface{}) *StringCmd

func (*Client) HDel

func (c *Client) HDel(key string, fields ...string) *IntCmd

func (*Client) HExists

func (c *Client) HExists(key, field string) *BoolCmd

func (*Client) HGet

func (c *Client) HGet(key, field string) *StringCmd

func (*Client) HGetAll

func (c *Client) HGetAll(key string) *StringSliceCmd

func (*Client) HGetAllMap

func (c *Client) HGetAllMap(key string) *StringStringMapCmd

func (*Client) HIncrBy

func (c *Client) HIncrBy(key, field string, incr int64) *IntCmd

func (*Client) HIncrByFloat

func (c *Client) HIncrByFloat(key, field string, incr float64) *FloatCmd

func (*Client) HKeys

func (c *Client) HKeys(key string) *StringSliceCmd

func (*Client) HLen

func (c *Client) HLen(key string) *IntCmd

func (*Client) HMGet

func (c *Client) HMGet(key string, fields ...string) *SliceCmd

func (*Client) HMSet

func (c *Client) HMSet(key, field, value string, pairs ...string) *StatusCmd

func (*Client) HScan

func (c *Client) HScan(key string, cursor int64, match string, count int64) *ScanCmd

func (*Client) HSet

func (c *Client) HSet(key, field, value string) *BoolCmd

func (*Client) HSetNX

func (c *Client) HSetNX(key, field, value string) *BoolCmd

func (*Client) HVals

func (c *Client) HVals(key string) *StringSliceCmd

func (*Client) Incr

func (c *Client) Incr(key string) *IntCmd

Example

if err := client.Incr("counter").Err(); err != nil {
	panic(err)
}

n, err := client.Get("counter").Int64()
fmt.Println(n, err)

Output:

1 <nil>

func (*Client) IncrBy

func (c *Client) IncrBy(key string, value int64) *IntCmd

func (*Client) IncrByFloat

func (c *Client) IncrByFloat(key string, value float64) *FloatCmd

func (*Client) Info

func (c *Client) Info() *StringCmd

func (*Client) Keys

func (c *Client) Keys(pattern string) *StringSliceCmd

func (*Client) LIndex

func (c *Client) LIndex(key string, index int64) *StringCmd

func (*Client) LInsert

func (c *Client) LInsert(key, op, pivot, value string) *IntCmd

func (*Client) LLen

func (c *Client) LLen(key string) *IntCmd

func (*Client) LPop

func (c *Client) LPop(key string) *StringCmd

func (*Client) LPush

func (c *Client) LPush(key string, values ...string) *IntCmd

func (*Client) LPushX

func (c *Client) LPushX(key, value string) *IntCmd

func (*Client) LRange

func (c *Client) LRange(key string, start, stop int64) *StringSliceCmd

func (*Client) LRem

func (c *Client) LRem(key string, count int64, value string) *IntCmd

func (*Client) LSet

func (c *Client) LSet(key string, index int64, value string) *StatusCmd

func (*Client) LTrim

func (c *Client) LTrim(key string, start, stop int64) *StatusCmd

func (*Client) LastSave

func (c *Client) LastSave() *IntCmd

func (*Client) MGet

func (c *Client) MGet(keys ...string) *SliceCmd

func (*Client) MSet

func (c *Client) MSet(pairs ...string) *StatusCmd

func (*Client) MSetNX

func (c *Client) MSetNX(pairs ...string) *BoolCmd

func (*Client) Migrate

func (c *Client) Migrate(host, port, key string, db int64, timeout time.Duration) *StatusCmd

func (*Client) Move

func (c *Client) Move(key string, db int64) *BoolCmd

func (*Client) Multi

func (c *Client) Multi() *Multi

func (*Client) ObjectEncoding

func (c *Client) ObjectEncoding(keys ...string) *StringCmd

func (*Client) ObjectIdleTime

func (c *Client) ObjectIdleTime(keys ...string) *DurationCmd

func (*Client) ObjectRefCount

func (c *Client) ObjectRefCount(keys ...string) *IntCmd

func (*Client) PExpire

func (c *Client) PExpire(key string, expiration time.Duration) *BoolCmd

func (*Client) PExpireAt

func (c *Client) PExpireAt(key string, tm time.Time) *BoolCmd

func (*Client) PSubscribe

func (c *Client) PSubscribe(channels ...string) (*PubSub, error)

Subscribes the client to the given patterns.

func (*Client) PTTL

func (c *Client) PTTL(key string) *DurationCmd

func (*Client) Persist

func (c *Client) Persist(key string) *BoolCmd

func (*Client) Ping

func (c *Client) Ping() *StatusCmd

func (*Client) Pipeline

func (c *Client) Pipeline() *Pipeline

func (*Client) Pipelined

func (c *Client) Pipelined(fn func(*Pipeline) error) ([]Cmder, error)

Example

var incr *redis.IntCmd
_, err := client.Pipelined(func(pipe *redis.Pipeline) error {
	incr = pipe.Incr("counter1")
	pipe.Expire("counter1", time.Hour)
	return nil
})
fmt.Println(incr.Val(), err)

Output:

1 <nil>

func (*Client) Process

func (c *Client) Process(cmd Cmder)

func (*Client) PubSub

func (c *Client) PubSub() *PubSub

Deprecated. Use Subscribe/PSubscribe instead.

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) Publish

func (c *Client) Publish(channel, message string) *IntCmd

Posts a message to the given channel.

func (*Client) Quit

func (c *Client) Quit() *StatusCmd

func (*Client) RPop

func (c *Client) RPop(key string) *StringCmd

func (*Client) RPopLPush

func (c *Client) RPopLPush(source, destination string) *StringCmd

func (*Client) RPush

func (c *Client) RPush(key string, values ...string) *IntCmd

func (*Client) RPushX

func (c *Client) RPushX(key string, value string) *IntCmd

func (*Client) RandomKey

func (c *Client) RandomKey() *StringCmd

func (*Client) Rename

func (c *Client) Rename(key, newkey string) *StatusCmd

func (*Client) RenameNX

func (c *Client) RenameNX(key, newkey string) *BoolCmd

func (*Client) Restore

func (c *Client) Restore(key string, ttl time.Duration, value string) *StatusCmd

func (*Client) RestoreReplace

func (c *Client) RestoreReplace(key string, ttl time.Duration, value string) *StatusCmd

func (*Client) SAdd

func (c *Client) SAdd(key string, members ...string) *IntCmd

func (*Client) SCard

func (c *Client) SCard(key string) *IntCmd

func (*Client) SDiff

func (c *Client) SDiff(keys ...string) *StringSliceCmd

func (*Client) SDiffStore

func (c *Client) SDiffStore(destination string, keys ...string) *IntCmd

func (*Client) SInter

func (c *Client) SInter(keys ...string) *StringSliceCmd

func (*Client) SInterStore

func (c *Client) SInterStore(destination string, keys ...string) *IntCmd

func (*Client) SIsMember

func (c *Client) SIsMember(key, member string) *BoolCmd

func (*Client) SMembers

func (c *Client) SMembers(key string) *StringSliceCmd

func (*Client) SMove

func (c *Client) SMove(source, destination, member string) *BoolCmd

func (*Client) SPop

func (c *Client) SPop(key string) *StringCmd

func (*Client) SRandMember

func (c *Client) SRandMember(key string) *StringCmd

Redis `SRANDMEMBER key` command.

func (*Client) SRandMemberN

func (c *Client) SRandMemberN(key string, count int64) *StringSliceCmd

Redis `SRANDMEMBER key count` command.

func (*Client) SRem

func (c *Client) SRem(key string, members ...string) *IntCmd

func (*Client) SScan

func (c *Client) SScan(key string, cursor int64, match string, count int64) *ScanCmd

func (*Client) SUnion

func (c *Client) SUnion(keys ...string) *StringSliceCmd

func (*Client) SUnionStore

func (c *Client) SUnionStore(destination string, keys ...string) *IntCmd

func (*Client) Save

func (c *Client) Save() *StatusCmd

func (*Client) Scan

func (c *Client) Scan(cursor int64, match string, count int64) *ScanCmd

Example

client.FlushDb()
for i := 0; i < 33; i++ {
	err := client.Set(fmt.Sprintf("key%d", i), "value", 0).Err()
	if err != nil {
		panic(err)
	}
}

var cursor int64
var n int
for {
	var keys []string
	var err error
	cursor, keys, err = client.Scan(cursor, "", 10).Result()
	if err != nil {
		panic(err)
	}
	n += len(keys)
	if cursor == 0 {
		break
	}
}

fmt.Printf("found %d keys\n", n)

Output:

found 33 keys

func (*Client) ScriptExists

func (c *Client) ScriptExists(scripts ...string) *BoolSliceCmd

func (*Client) ScriptFlush

func (c *Client) ScriptFlush() *StatusCmd

func (*Client) ScriptKill

func (c *Client) ScriptKill() *StatusCmd

func (*Client) ScriptLoad

func (c *Client) ScriptLoad(script string) *StringCmd

func (*Client) Select

func (c *Client) Select(index int64) *StatusCmd

func (*Client) Set

func (c *Client) Set(key string, value interface{}, expiration time.Duration) *StatusCmd

Redis `SET key value [expiration]` command.

Zero expiration means the key has no expiration time.

Example

// Last argument is expiration. Zero means the key has no
// expiration time.
err := client.Set("key", "value", 0).Err()
if err != nil {
	panic(err)
}

// key2 will expire in an hour.
err = client.Set("key2", "value", time.Hour).Err()
if err != nil {
	panic(err)
}

func (*Client) SetBit

func (c *Client) SetBit(key string, offset int64, value int) *IntCmd

func (*Client) SetNX

func (c *Client) SetNX(key string, value interface{}, expiration time.Duration) *BoolCmd

Redis `SET key value [expiration] NX` command.

Zero expiration means the key has no expiration time.

func (*Client) SetRange

func (c *Client) SetRange(key string, offset int64, value string) *IntCmd

func (*Client) SetXX

func (c *Client) SetXX(key string, value interface{}, expiration time.Duration) *BoolCmd

Redis `SET key value [expiration] XX` command.

Zero expiration means the key has no expiration time.

func (*Client) Shutdown

func (c *Client) Shutdown() *StatusCmd

func (*Client) ShutdownNoSave

func (c *Client) ShutdownNoSave() *StatusCmd

func (*Client) ShutdownSave

func (c *Client) ShutdownSave() *StatusCmd

func (*Client) SlaveOf

func (c *Client) SlaveOf(host, port string) *StatusCmd

func (*Client) SlowLog

func (c *Client) SlowLog()

func (*Client) Sort

func (c *Client) Sort(key string, sort Sort) *StringSliceCmd

func (*Client) StrLen

func (c *Client) StrLen(key string) *IntCmd

func (Client) String

func (c Client) String() string

func (*Client) Subscribe

func (c *Client) Subscribe(channels ...string) (*PubSub, error)

Subscribes the client to the specified channels.

func (*Client) Sync

func (c *Client) Sync()

func (*Client) TTL

func (c *Client) TTL(key string) *DurationCmd

func (*Client) Time

func (c *Client) Time() *StringSliceCmd

func (*Client) Type

func (c *Client) Type(key string) *StatusCmd

func (*Client) ZAdd

func (c *Client) ZAdd(key string, members ...Z) *IntCmd

Redis `ZADD key score member [score member ...]` command.

func (*Client) ZAddCh

func (c *Client) ZAddCh(key string, members ...Z) *IntCmd

Redis `ZADD key CH score member [score member ...]` command.

func (*Client) ZAddNX

func (c *Client) ZAddNX(key string, members ...Z) *IntCmd

Redis `ZADD key NX score member [score member ...]` command.

func (*Client) ZAddNXCh

func (c *Client) ZAddNXCh(key string, members ...Z) *IntCmd

Redis `ZADD key NX CH score member [score member ...]` command.

func (*Client) ZAddXX

func (c *Client) ZAddXX(key string, members ...Z) *IntCmd

Redis `ZADD key XX score member [score member ...]` command.

func (*Client) ZAddXXCh

func (c *Client) ZAddXXCh(key string, members ...Z) *IntCmd

Redis `ZADD key XX CH score member [score member ...]` command.

func (*Client) ZCard

func (c *Client) ZCard(key string) *IntCmd

func (*Client) ZCount

func (c *Client) ZCount(key, min, max string) *IntCmd

func (*Client) ZIncr

func (c *Client) ZIncr(key string, member Z) *FloatCmd

Redis `ZADD key INCR score member` command.

func (*Client) ZIncrBy

func (c *Client) ZIncrBy(key string, increment float64, member string) *FloatCmd

func (*Client) ZIncrNX

func (c *Client) ZIncrNX(key string, member Z) *FloatCmd

Redis `ZADD key NX INCR score member` command.

func (*Client) ZIncrXX

func (c *Client) ZIncrXX(key string, member Z) *FloatCmd

Redis `ZADD key XX INCR score member` command.

func (*Client) ZInterStore

func (c *Client) ZInterStore(
	destination string,
	store ZStore,
	keys ...string,
) *IntCmd

func (*Client) ZRange

func (c *Client) ZRange(key string, start, stop int64) *StringSliceCmd

func (*Client) ZRangeByLex

func (c *Client) ZRangeByLex(key string, opt ZRangeByScore) *StringSliceCmd

func (*Client) ZRangeByScore

func (c *Client) ZRangeByScore(key string, opt ZRangeByScore) *StringSliceCmd

func (*Client) ZRangeByScoreWithScores

func (c *Client) ZRangeByScoreWithScores(key string, opt ZRangeByScore) *ZSliceCmd

func (*Client) ZRangeWithScores

func (c *Client) ZRangeWithScores(key string, start, stop int64) *ZSliceCmd

func (*Client) ZRank

func (c *Client) ZRank(key, member string) *IntCmd

func (*Client) ZRem

func (c *Client) ZRem(key string, members ...string) *IntCmd

func (*Client) ZRemRangeByRank

func (c *Client) ZRemRangeByRank(key string, start, stop int64) *IntCmd

func (*Client) ZRemRangeByScore

func (c *Client) ZRemRangeByScore(key, min, max string) *IntCmd

func (*Client) ZRevRange

func (c *Client) ZRevRange(key string, start, stop int64) *StringSliceCmd

func (Client) ZRevRangeByLex

func (c Client) ZRevRangeByLex(key string, opt ZRangeByScore) *StringSliceCmd

func (*Client) ZRevRangeByScore

func (c *Client) ZRevRangeByScore(key string, opt ZRangeByScore) *StringSliceCmd

func (*Client) ZRevRangeByScoreWithScores

func (c *Client) ZRevRangeByScoreWithScores(key string, opt ZRangeByScore) *ZSliceCmd

func (*Client) ZRevRangeWithScores

func (c *Client) ZRevRangeWithScores(key string, start, stop int64) *ZSliceCmd

func (*Client) ZRevRank

func (c *Client) ZRevRank(key, member string) *IntCmd

func (*Client) ZScan

func (c *Client) ZScan(key string, cursor int64, match string, count int64) *ScanCmd

func (*Client) ZScore

func (c *Client) ZScore(key, member string) *FloatCmd

func (*Client) ZUnionStore

func (c *Client) ZUnionStore(dest string, store ZStore, keys ...string) *IntCmd

type ClusterClient

type ClusterClient struct {
	// contains filtered or unexported fields
}

ClusterClient is a Redis Cluster client representing a pool of zero or more underlying connections. It's safe for concurrent use by multiple goroutines.

func NewClusterClient

func NewClusterClient(opt *ClusterOptions) *ClusterClient

NewClusterClient returns a Redis Cluster client as described in http://redis.io/topics/cluster-spec.

Example

// See http://redis.io/topics/cluster-tutorial for instructions
// how to setup Redis Cluster.
client := redis.NewClusterClient(&redis.ClusterOptions{
	Addrs: []string{":7000", ":7001", ":7002", ":7003", ":7004", ":7005"},
})
client.Ping()

func (*ClusterClient) Append

func (c *ClusterClient) Append(key, value string) *IntCmd

func (*ClusterClient) Auth

func (c *ClusterClient) Auth(password string) *StatusCmd

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 (c *ClusterClient) BRPopLPush(source, destination string, timeout time.Duration) *StringCmd

func (*ClusterClient) BgRewriteAOF

func (c *ClusterClient) BgRewriteAOF() *StatusCmd

func (*ClusterClient) BgSave

func (c *ClusterClient) BgSave() *StatusCmd

func (*ClusterClient) BitCount

func (c *ClusterClient) BitCount(key string, bitCount *BitCount) *IntCmd

func (*ClusterClient) BitOpAnd

func (c *ClusterClient) BitOpAnd(destKey string, keys ...string) *IntCmd

func (*ClusterClient) BitOpNot

func (c *ClusterClient) BitOpNot(destKey string, key string) *IntCmd

func (*ClusterClient) BitOpOr

func (c *ClusterClient) BitOpOr(destKey string, keys ...string) *IntCmd

func (*ClusterClient) BitOpXor

func (c *ClusterClient) BitOpXor(destKey string, keys ...string) *IntCmd

func (*ClusterClient) BitPos

func (c *ClusterClient) BitPos(key string, bit int64, pos ...int64) *IntCmd

func (*ClusterClient) ClientKill

func (c *ClusterClient) ClientKill(ipPort string) *StatusCmd

func (*ClusterClient) ClientList

func (c *ClusterClient) ClientList() *StringCmd

func (*ClusterClient) ClientPause

func (c *ClusterClient) ClientPause(dur time.Duration) *BoolCmd

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 (c *ClusterClient) ClusterAddSlots(slots ...int) *StatusCmd

func (*ClusterClient) ClusterAddSlotsRange

func (c *ClusterClient) ClusterAddSlotsRange(min, max int) *StatusCmd

func (*ClusterClient) ClusterFailover

func (c *ClusterClient) ClusterFailover() *StatusCmd

func (*ClusterClient) ClusterInfo

func (c *ClusterClient) ClusterInfo() *StringCmd

func (*ClusterClient) ClusterMeet

func (c *ClusterClient) ClusterMeet(host, port string) *StatusCmd

func (*ClusterClient) ClusterNodes

func (c *ClusterClient) ClusterNodes() *StringCmd

func (*ClusterClient) ClusterReplicate

func (c *ClusterClient) ClusterReplicate(nodeID string) *StatusCmd

func (*ClusterClient) ClusterSlots

func (c *ClusterClient) ClusterSlots() *ClusterSlotCmd

func (*ClusterClient) ConfigGet

func (c *ClusterClient) ConfigGet(parameter string) *SliceCmd

func (*ClusterClient) ConfigResetStat

func (c *ClusterClient) ConfigResetStat() *StatusCmd

func (*ClusterClient) ConfigSet

func (c *ClusterClient) ConfigSet(parameter, value string) *StatusCmd

func (*ClusterClient) DbSize

func (c *ClusterClient) DbSize() *IntCmd

func (*ClusterClient) DebugObject

func (c *ClusterClient) DebugObject(key string) *StringCmd

func (*ClusterClient) Decr

func (c *ClusterClient) Decr(key string) *IntCmd

func (*ClusterClient) DecrBy

func (c *ClusterClient) DecrBy(key string, decrement int64) *IntCmd

func (*ClusterClient) Del

func (c *ClusterClient) Del(keys ...string) *IntCmd

func (*ClusterClient) Dump

func (c *ClusterClient) Dump(key string) *StringCmd

func (*ClusterClient) Echo

func (c *ClusterClient) Echo(message string) *StringCmd

func (*ClusterClient) Eval

func (c *ClusterClient) Eval(script string, keys []string, args []string) *Cmd

func (*ClusterClient) EvalSha

func (c *ClusterClient) EvalSha(sha1 string, keys []string, args []string) *Cmd

func (*ClusterClient) Exists

func (c *ClusterClient) Exists(key string) *BoolCmd

func (*ClusterClient) Expire

func (c *ClusterClient) Expire(key string, expiration time.Duration) *BoolCmd

func (*ClusterClient) ExpireAt

func (c *ClusterClient) ExpireAt(key string, tm time.Time) *BoolCmd

func (*ClusterClient) FlushAll

func (c *ClusterClient) FlushAll() *StatusCmd

func (*ClusterClient) FlushDb

func (c *ClusterClient) FlushDb() *StatusCmd

func (*ClusterClient) Get

func (c *ClusterClient) Get(key string) *StringCmd

func (*ClusterClient) GetBit

func (c *ClusterClient) GetBit(key string, offset int64) *IntCmd

func (*ClusterClient) GetRange

func (c *ClusterClient) GetRange(key string, start, end int64) *StringCmd

func (*ClusterClient) GetSet

func (c *ClusterClient) GetSet(key string, value interface{}) *StringCmd

func (*ClusterClient) HDel

func (c *ClusterClient) HDel(key string, fields ...string) *IntCmd

func (*ClusterClient) HExists

func (c *ClusterClient) HExists(key, field string) *BoolCmd

func (*ClusterClient) HGet

func (c *ClusterClient) HGet(key, field string) *StringCmd

func (*ClusterClient) HGetAll

func (c *ClusterClient) HGetAll(key string) *StringSliceCmd

func (*ClusterClient) HGetAllMap

func (c *ClusterClient) HGetAllMap(key string) *StringStringMapCmd

func (*ClusterClient) HIncrBy

func (c *ClusterClient) HIncrBy(key, field string, incr int64) *IntCmd

func (*ClusterClient) HIncrByFloat

func (c *ClusterClient) HIncrByFloat(key, field string, incr float64) *FloatCmd

func (*ClusterClient) HKeys

func (c *ClusterClient) HKeys(key string) *StringSliceCmd

func (*ClusterClient) HLen

func (c *ClusterClient) HLen(key string) *IntCmd

func (*ClusterClient) HMGet

func (c *ClusterClient) HMGet(key string, fields ...string) *SliceCmd

func (*ClusterClient) HMSet

func (c *ClusterClient) HMSet(key, field, value string, pairs ...string) *StatusCmd

func (*ClusterClient) HScan

func (c *ClusterClient) HScan(key string, cursor int64, match string, count int64) *ScanCmd

func (*ClusterClient) HSet

func (c *ClusterClient) HSet(key, field, value string) *BoolCmd

func (*ClusterClient) HSetNX

func (c *ClusterClient) HSetNX(key, field, value string) *BoolCmd

func (*ClusterClient) HVals

func (c *ClusterClient) HVals(key string) *StringSliceCmd

func (*ClusterClient) Incr

func (c *ClusterClient) Incr(key string) *IntCmd

func (*ClusterClient) IncrBy

func (c *ClusterClient) IncrBy(key string, value int64) *IntCmd

func (*ClusterClient) IncrByFloat

func (c *ClusterClient) IncrByFloat(key string, value float64) *FloatCmd

func (*ClusterClient) Info

func (c *ClusterClient) Info() *StringCmd

func (*ClusterClient) Keys

func (c *ClusterClient) Keys(pattern string) *StringSliceCmd

func (*ClusterClient) LIndex

func (c *ClusterClient) LIndex(key string, index int64) *StringCmd

func (*ClusterClient) LInsert

func (c *ClusterClient) LInsert(key, op, pivot, value string) *IntCmd

func (*ClusterClient) LLen

func (c *ClusterClient) LLen(key string) *IntCmd

func (*ClusterClient) LPop

func (c *ClusterClient) LPop(key string) *StringCmd

func (*ClusterClient) LPush

func (c *ClusterClient) LPush(key string, values ...string) *IntCmd

func (*ClusterClient) LPushX

func (c *ClusterClient) LPushX(key, value string) *IntCmd

func (*ClusterClient) LRange

func (c *ClusterClient) LRange(key string, start, stop int64) *StringSliceCmd

func (*ClusterClient) LRem

func (c *ClusterClient) LRem(key string, count int64, value string) *IntCmd

func (*ClusterClient) LSet

func (c *ClusterClient) LSet(key string, index int64, value string) *StatusCmd

func (*ClusterClient) LTrim

func (c *ClusterClient) LTrim(key string, start, stop int64) *StatusCmd

func (*ClusterClient) LastSave

func (c *ClusterClient) LastSave() *IntCmd

func (*ClusterClient) MGet

func (c *ClusterClient) MGet(keys ...string) *SliceCmd

func (*ClusterClient) MSet

func (c *ClusterClient) MSet(pairs ...string) *StatusCmd

func (*ClusterClient) MSetNX

func (c *ClusterClient) MSetNX(pairs ...string) *BoolCmd

func (*ClusterClient) Migrate

func (c *ClusterClient) Migrate(host, port, key string, db int64, timeout time.Duration) *StatusCmd

func (*ClusterClient) Move

func (c *ClusterClient) Move(key string, db int64) *BoolCmd

func (*ClusterClient) ObjectEncoding

func (c *ClusterClient) ObjectEncoding(keys ...string) *StringCmd

func (*ClusterClient) ObjectIdleTime

func (c *ClusterClient) ObjectIdleTime(keys ...string) *DurationCmd

func (*ClusterClient) ObjectRefCount

func (c *ClusterClient) ObjectRefCount(keys ...string) *IntCmd

func (*ClusterClient) PExpire

func (c *ClusterClient) PExpire(key string, expiration time.Duration) *BoolCmd

func (*ClusterClient) PExpireAt

func (c *ClusterClient) PExpireAt(key string, tm time.Time) *BoolCmd

func (*ClusterClient) PTTL

func (c *ClusterClient) PTTL(key string) *DurationCmd

func (*ClusterClient) Persist

func (c *ClusterClient) Persist(key string) *BoolCmd

func (*ClusterClient) Ping

func (c *ClusterClient) Ping() *StatusCmd

func (*ClusterClient) Pipeline

func (c *ClusterClient) Pipeline() *ClusterPipeline

Pipeline creates a new pipeline which is able to execute commands against multiple shards. It's NOT safe for concurrent use by multiple goroutines.

func (*ClusterClient) Process

func (c *ClusterClient) Process(cmd Cmder)

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) Quit

func (c *ClusterClient) Quit() *StatusCmd

func (*ClusterClient) RPop

func (c *ClusterClient) RPop(key string) *StringCmd

func (*ClusterClient) RPopLPush

func (c *ClusterClient) RPopLPush(source, destination string) *StringCmd

func (*ClusterClient) RPush

func (c *ClusterClient) RPush(key string, values ...string) *IntCmd

func (*ClusterClient) RPushX

func (c *ClusterClient) RPushX(key string, value string) *IntCmd

func (*ClusterClient) RandomKey

func (c *ClusterClient) RandomKey() *StringCmd

func (*ClusterClient) Rename

func (c *ClusterClient) Rename(key, newkey string) *StatusCmd

func (*ClusterClient) RenameNX

func (c *ClusterClient) RenameNX(key, newkey string) *BoolCmd

func (*ClusterClient) Restore

func (c *ClusterClient) Restore(key string, ttl time.Duration, value string) *StatusCmd

func (*ClusterClient) RestoreReplace

func (c *ClusterClient) RestoreReplace(key string, ttl time.Duration, value string) *StatusCmd

func (*ClusterClient) SAdd

func (c *ClusterClient) SAdd(key string, members ...string) *IntCmd

func (*ClusterClient) SCard

func (c *ClusterClient) SCard(key string) *IntCmd

func (*ClusterClient) SDiff

func (c *ClusterClient) SDiff(keys ...string) *StringSliceCmd

func (*ClusterClient) SDiffStore

func (c *ClusterClient) SDiffStore(destination string, keys ...string) *IntCmd

func (*ClusterClient) SInter

func (c *ClusterClient) SInter(keys ...string) *StringSliceCmd

func (*ClusterClient) SInterStore

func (c *ClusterClient) SInterStore(destination string, keys ...string) *IntCmd

func (*ClusterClient) SIsMember

func (c *ClusterClient) SIsMember(key, member string) *BoolCmd

func (*ClusterClient) SMembers

func (c *ClusterClient) SMembers(key string) *StringSliceCmd

func (*ClusterClient) SMove

func (c *ClusterClient) SMove(source, destination, member string) *BoolCmd

func (*ClusterClient) SPop

func (c *ClusterClient) SPop(key string) *StringCmd

func (*ClusterClient) SRandMember

func (c *ClusterClient) SRandMember(key string) *StringCmd

Redis `SRANDMEMBER key` command.

func (*ClusterClient) SRandMemberN

func (c *ClusterClient) SRandMemberN(key string, count int64) *StringSliceCmd

Redis `SRANDMEMBER key count` command.

func (*ClusterClient) SRem

func (c *ClusterClient) SRem(key string, members ...string) *IntCmd

func (*ClusterClient) SScan

func (c *ClusterClient) SScan(key string, cursor int64, match string, count int64) *ScanCmd

func (*ClusterClient) SUnion

func (c *ClusterClient) SUnion(keys ...string) *StringSliceCmd

func (*ClusterClient) SUnionStore

func (c *ClusterClient) SUnionStore(destination string, keys ...string) *IntCmd

func (*ClusterClient) Save

func (c *ClusterClient) Save() *StatusCmd

func (*ClusterClient) Scan

func (c *ClusterClient) Scan(cursor int64, match string, count int64) *ScanCmd

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 (c *ClusterClient) ScriptLoad(script string) *StringCmd

func (*ClusterClient) Select

func (c *ClusterClient) Select(index int64) *StatusCmd

func (*ClusterClient) Set

func (c *ClusterClient) Set(key string, value interface{}, expiration time.Duration) *StatusCmd

Redis `SET key value [expiration]` command.

Zero expiration means the key has no expiration time.

func (*ClusterClient) SetBit

func (c *ClusterClient) SetBit(key string, offset int64, value int) *IntCmd

func (*ClusterClient) SetNX

func (c *ClusterClient) SetNX(key string, value interface{}, expiration time.Duration) *BoolCmd

Redis `SET key value [expiration] NX` command.

Zero expiration means the key has no expiration time.

func (*ClusterClient) SetRange

func (c *ClusterClient) SetRange(key string, offset int64, value string) *IntCmd

func (*ClusterClient) Shutdown

func (c *ClusterClient) Shutdown() *StatusCmd

func (*ClusterClient) ShutdownNoSave

func (c *ClusterClient) ShutdownNoSave() *StatusCmd

func (*ClusterClient) ShutdownSave

func (c *ClusterClient) ShutdownSave() *StatusCmd

func (*ClusterClient) SlaveOf

func (c *ClusterClient) SlaveOf(host, port string) *StatusCmd

func (*ClusterClient) SlowLog

func (c *ClusterClient) SlowLog()

func (*ClusterClient) Sort

func (c *ClusterClient) Sort(key string, sort Sort) *StringSliceCmd

func (*ClusterClient) StrLen

func (c *ClusterClient) StrLen(key string) *IntCmd

func (*ClusterClient) Sync

func (c *ClusterClient) Sync()

func (*ClusterClient) TTL

func (c *ClusterClient) TTL(key string) *DurationCmd

func (*ClusterClient) Time

func (c *ClusterClient) Time() *StringSliceCmd

func (*ClusterClient) Type

func (c *ClusterClient) Type(key string) *StatusCmd

func (*ClusterClient) ZAdd

func (c *ClusterClient) ZAdd(key string, members ...Z) *IntCmd

Redis `ZADD key score member [score member ...]` command.

func (*ClusterClient) ZAddCh

func (c *ClusterClient) ZAddCh(key string, members ...Z) *IntCmd

Redis `ZADD key CH score member [score member ...]` command.

func (*ClusterClient) ZAddNX

func (c *ClusterClient) ZAddNX(key string, members ...Z) *IntCmd

Redis `ZADD key NX score member [score member ...]` command.

func (*ClusterClient) ZAddNXCh

func (c *ClusterClient) ZAddNXCh(key string, members ...Z) *IntCmd

Redis `ZADD key NX CH score member [score member ...]` command.

func (*ClusterClient) ZAddXX

func (c *ClusterClient) ZAddXX(key string, members ...Z) *IntCmd

Redis `ZADD key XX score member [score member ...]` command.

func (*ClusterClient) ZAddXXCh

func (c *ClusterClient) ZAddXXCh(key string, members ...Z) *IntCmd

Redis `ZADD key XX CH score member [score member ...]` command.

func (*ClusterClient) ZCard

func (c *ClusterClient) ZCard(key string) *IntCmd

func (*ClusterClient) ZCount

func (c *ClusterClient) ZCount(key, min, max string) *IntCmd

func (*ClusterClient) ZIncr

func (c *ClusterClient) ZIncr(key string, member Z) *FloatCmd

Redis `ZADD key INCR score member` command.

func (*ClusterClient) ZIncrBy

func (c *ClusterClient) ZIncrBy(key string, increment float64, member string) *FloatCmd

func (*ClusterClient) ZIncrNX

func (c *ClusterClient) ZIncrNX(key string, member Z) *FloatCmd

Redis `ZADD key NX INCR score member` command.

func (*ClusterClient) ZIncrXX

func (c *ClusterClient) ZIncrXX(key string, member Z) *FloatCmd

Redis `ZADD key XX INCR score member` command.

func (*ClusterClient) ZInterStore

func (c *ClusterClient) ZInterStore(
	destination string,
	store ZStore,
	keys ...string,
) *IntCmd

func (*ClusterClient) ZRange

func (c *ClusterClient) ZRange(key string, start, stop int64) *StringSliceCmd

func (*ClusterClient) ZRangeByLex

func (c *ClusterClient) ZRangeByLex(key string, opt ZRangeByScore) *StringSliceCmd

func (*ClusterClient) ZRangeByScore

func (c *ClusterClient) ZRangeByScore(key string, opt ZRangeByScore) *StringSliceCmd

func (*ClusterClient) ZRangeByScoreWithScores

func (c *ClusterClient) ZRangeByScoreWithScores(key string, opt ZRangeByScore) *ZSliceCmd

func (*ClusterClient) ZRangeWithScores

func (c *ClusterClient) ZRangeWithScores(key string, start, stop int64) *ZSliceCmd

func (*ClusterClient) ZRank

func (c *ClusterClient) ZRank(key, member string) *IntCmd

func (*ClusterClient) ZRem

func (c *ClusterClient) ZRem(key string, members ...string) *IntCmd

func (*ClusterClient) ZRemRangeByRank

func (c *ClusterClient) ZRemRangeByRank(key string, start, stop int64) *IntCmd

func (*ClusterClient) ZRemRangeByScore

func (c *ClusterClient) ZRemRangeByScore(key, min, max string) *IntCmd

func (*ClusterClient) ZRevRange

func (c *ClusterClient) ZRevRange(key string, start, stop int64) *StringSliceCmd

func (ClusterClient) ZRevRangeByLex

func (c ClusterClient) ZRevRangeByLex(key string, opt ZRangeByScore) *StringSliceCmd

func (*ClusterClient) ZRevRangeByScore

func (c *ClusterClient) ZRevRangeByScore(key string, opt ZRangeByScore) *StringSliceCmd

func (*ClusterClient) ZRevRangeByScoreWithScores

func (c *ClusterClient) ZRevRangeByScoreWithScores(key string, opt ZRangeByScore) *ZSliceCmd

func (*ClusterClient) ZRevRangeWithScores

func (c *ClusterClient) ZRevRangeWithScores(key string, start, stop int64) *ZSliceCmd

func (*ClusterClient) ZRevRank

func (c *ClusterClient) ZRevRank(key, member string) *IntCmd

func (*ClusterClient) ZScan

func (c *ClusterClient) ZScan(key string, cursor int64, match string, count int64) *ScanCmd

func (*ClusterClient) ZScore

func (c *ClusterClient) ZScore(key, member string) *FloatCmd

func (*ClusterClient) ZUnionStore

func (c *ClusterClient) ZUnionStore(dest string, store ZStore, keys ...string) *IntCmd

type ClusterOptions

type ClusterOptions struct {
	// A seed list of host:port addresses of cluster nodes.
	Addrs []string

	// The maximum number of MOVED/ASK redirects to follow before
	// giving up.
	// Default is 16
	MaxRedirects int

	Password string

	DialTimeout  time.Duration
	ReadTimeout  time.Duration
	WriteTimeout time.Duration

	PoolSize    int
	PoolTimeout time.Duration
	IdleTimeout time.Duration
}

ClusterOptions are used to configure a cluster client and should be passed to NewClusterClient.

type ClusterPipeline

type ClusterPipeline struct {
	// contains filtered or unexported fields
}

ClusterPipeline is not thread-safe.

func (*ClusterPipeline) Append

func (c *ClusterPipeline) Append(key, value string) *IntCmd

func (*ClusterPipeline) Auth

func (c *ClusterPipeline) Auth(password string) *StatusCmd

func (*ClusterPipeline) BLPop

func (c *ClusterPipeline) BLPop(timeout time.Duration, keys ...string) *StringSliceCmd

func (*ClusterPipeline) BRPop

func (c *ClusterPipeline) BRPop(timeout time.Duration, keys ...string) *StringSliceCmd

func (*ClusterPipeline) BRPopLPush

func (c *ClusterPipeline) BRPopLPush(source, destination string, timeout time.Duration) *StringCmd

func (*ClusterPipeline) BgRewriteAOF

func (c *ClusterPipeline) BgRewriteAOF() *StatusCmd

func (*ClusterPipeline) BgSave

func (c *ClusterPipeline) BgSave() *StatusCmd

func (*ClusterPipeline) BitCount

func (c *ClusterPipeline) BitCount(key string, bitCount *BitCount) *IntCmd

func (*ClusterPipeline) BitOpAnd

func (c *ClusterPipeline) BitOpAnd(destKey string, keys ...string) *IntCmd

func (*ClusterPipeline) BitOpNot

func (c *ClusterPipeline) BitOpNot(destKey string, key string) *IntCmd

func (*ClusterPipeline) BitOpOr

func (c *ClusterPipeline) BitOpOr(destKey string, keys ...string) *IntCmd

func (*ClusterPipeline) BitOpXor

func (c *ClusterPipeline) BitOpXor(destKey string, keys ...string) *IntCmd

func (*ClusterPipeline) BitPos

func (c *ClusterPipeline) BitPos(key string, bit int64, pos ...int64) *IntCmd

func (*ClusterPipeline) ClientKill

func (c *ClusterPipeline) ClientKill(ipPort string) *StatusCmd

func (*ClusterPipeline) ClientList

func (c *ClusterPipeline) ClientList() *StringCmd

func (*ClusterPipeline) ClientPause

func (c *ClusterPipeline) ClientPause(dur time.Duration) *BoolCmd

func (*ClusterPipeline) Close

func (pipe *ClusterPipeline) Close() error

Close closes the pipeline, releasing any open resources.

func (*ClusterPipeline) ClusterAddSlots

func (c *ClusterPipeline) ClusterAddSlots(slots ...int) *StatusCmd

func (*ClusterPipeline) ClusterAddSlotsRange

func (c *ClusterPipeline) ClusterAddSlotsRange(min, max int) *StatusCmd

func (*ClusterPipeline) ClusterFailover

func (c *ClusterPipeline) ClusterFailover() *StatusCmd

func (*ClusterPipeline) ClusterInfo

func (c *ClusterPipeline) ClusterInfo() *StringCmd

func (*ClusterPipeline) ClusterMeet

func (c *ClusterPipeline) ClusterMeet(host, port string) *StatusCmd

func (*ClusterPipeline) ClusterNodes

func (c *ClusterPipeline) ClusterNodes() *StringCmd

func (*ClusterPipeline) ClusterReplicate

func (c *ClusterPipeline) ClusterReplicate(nodeID string) *StatusCmd

func (*ClusterPipeline) ClusterSlots

func (c *ClusterPipeline) ClusterSlots() *ClusterSlotCmd

func (*ClusterPipeline) ConfigGet

func (c *ClusterPipeline) ConfigGet(parameter string) *SliceCmd

func (*ClusterPipeline) ConfigResetStat

func (c *ClusterPipeline) ConfigResetStat() *StatusCmd

func (*ClusterPipeline) ConfigSet

func (c *ClusterPipeline) ConfigSet(parameter, value string) *StatusCmd

func (*ClusterPipeline) DbSize

func (c *ClusterPipeline) DbSize() *IntCmd

func (*ClusterPipeline) DebugObject

func (c *ClusterPipeline) DebugObject(key string) *StringCmd

func (*ClusterPipeline) Decr

func (c *ClusterPipeline) Decr(key string) *IntCmd

func (*ClusterPipeline) DecrBy

func (c *ClusterPipeline) DecrBy(key string, decrement int64) *IntCmd

func (*ClusterPipeline) Del

func (c *ClusterPipeline) Del(keys ...string) *IntCmd

func (*ClusterPipeline) Discard

func (pipe *ClusterPipeline) Discard() error

Discard resets the pipeline and discards queued commands.

func (*ClusterPipeline) Dump

func (c *ClusterPipeline) Dump(key string) *StringCmd

func (*ClusterPipeline) Echo

func (c *ClusterPipeline) Echo(message string) *StringCmd

func (*ClusterPipeline) Eval

func (c *ClusterPipeline) Eval(script string, keys []string, args []string) *Cmd

func (*ClusterPipeline) EvalSha

func (c *ClusterPipeline) EvalSha(sha1 string, keys []string, args []string) *Cmd

func (*ClusterPipeline) Exec

func (pipe *ClusterPipeline) Exec() (cmds []Cmder, retErr error)

func (*ClusterPipeline) Exists

func (c *ClusterPipeline) Exists(key string) *BoolCmd

func (*ClusterPipeline) Expire

func (c *ClusterPipeline) Expire(key string, expiration time.Duration) *BoolCmd

func (*ClusterPipeline) ExpireAt

func (c *ClusterPipeline) ExpireAt(key string, tm time.Time) *BoolCmd

func (*ClusterPipeline) FlushAll

func (c *ClusterPipeline) FlushAll() *StatusCmd

func (*ClusterPipeline) FlushDb

func (c *ClusterPipeline) FlushDb() *StatusCmd

func (*ClusterPipeline) Get

func (c *ClusterPipeline) Get(key string) *StringCmd

func (*ClusterPipeline) GetBit

func (c *ClusterPipeline) GetBit(key string, offset int64) *IntCmd

func (*ClusterPipeline) GetRange

func (c *ClusterPipeline) GetRange(key string, start, end int64) *StringCmd

func (*ClusterPipeline) GetSet

func (c *ClusterPipeline) GetSet(key string, value interface{}) *StringCmd

func (*ClusterPipeline) HDel

func (c *ClusterPipeline) HDel(key string, fields ...string) *IntCmd

func (*ClusterPipeline) HExists

func (c *ClusterPipeline) HExists(key, field string) *BoolCmd

func (*ClusterPipeline) HGet

func (c *ClusterPipeline) HGet(key, field string) *StringCmd

func (*ClusterPipeline) HGetAll

func (c *ClusterPipeline) HGetAll(key string) *StringSliceCmd

func (*ClusterPipeline) HGetAllMap

func (c *ClusterPipeline) HGetAllMap(key string) *StringStringMapCmd

func (*ClusterPipeline) HIncrBy

func (c *ClusterPipeline) HIncrBy(key, field string, incr int64) *IntCmd

func (*ClusterPipeline) HIncrByFloat

func (c *ClusterPipeline) HIncrByFloat(key, field string, incr float64) *FloatCmd

func (*ClusterPipeline) HKeys

func (c *ClusterPipeline) HKeys(key string) *StringSliceCmd

func (*ClusterPipeline) HLen

func (c *ClusterPipeline) HLen(key string) *IntCmd

func (*ClusterPipeline) HMGet

func (c *ClusterPipeline) HMGet(key string, fields ...string) *SliceCmd

func (*ClusterPipeline) HMSet

func (c *ClusterPipeline) HMSet(key, field, value string, pairs ...string) *StatusCmd

func (*ClusterPipeline) HScan

func (c *ClusterPipeline) HScan(key string, cursor int64, match string, count int64) *ScanCmd

func (*ClusterPipeline) HSet

func (c *ClusterPipeline) HSet(key, field, value string) *BoolCmd

func (*ClusterPipeline) HSetNX

func (c *ClusterPipeline) HSetNX(key, field, value string) *BoolCmd

func (*ClusterPipeline) HVals

func (c *ClusterPipeline) HVals(key string) *StringSliceCmd

func (*ClusterPipeline) Incr

func (c *ClusterPipeline) Incr(key string) *IntCmd

func (*ClusterPipeline) IncrBy

func (c *ClusterPipeline) IncrBy(key string, value int64) *IntCmd

func (*ClusterPipeline) IncrByFloat

func (c *ClusterPipeline) IncrByFloat(key string, value float64) *FloatCmd

func (*ClusterPipeline) Info

func (c *ClusterPipeline) Info() *StringCmd

func (*ClusterPipeline) Keys

func (c *ClusterPipeline) Keys(pattern string) *StringSliceCmd

func (*ClusterPipeline) LIndex

func (c *ClusterPipeline) LIndex(key string, index int64) *StringCmd

func (*ClusterPipeline) LInsert

func (c *ClusterPipeline) LInsert(key, op, pivot, value string) *IntCmd

func (*ClusterPipeline) LLen

func (c *ClusterPipeline) LLen(key string) *IntCmd

func (*ClusterPipeline) LPop

func (c *ClusterPipeline) LPop(key string) *StringCmd

func (*ClusterPipeline) LPush

func (c *ClusterPipeline) LPush(key string, values ...string) *IntCmd

func (*ClusterPipeline) LPushX

func (c *ClusterPipeline) LPushX(key, value string) *IntCmd

func (*ClusterPipeline) LRange

func (c *ClusterPipeline) LRange(key string, start, stop int64) *StringSliceCmd

func (*ClusterPipeline) LRem

func (c *ClusterPipeline) LRem(key string, count int64, value string) *IntCmd

func (*ClusterPipeline) LSet

func (c *ClusterPipeline) LSet(key string, index int64, value string) *StatusCmd

func (*ClusterPipeline) LTrim

func (c *ClusterPipeline) LTrim(key string, start, stop int64) *StatusCmd

func (*ClusterPipeline) LastSave

func (c *ClusterPipeline) LastSave() *IntCmd

func (*ClusterPipeline) MGet

func (c *ClusterPipeline) MGet(keys ...string) *SliceCmd

func (*ClusterPipeline) MSet

func (c *ClusterPipeline) MSet(pairs ...string) *StatusCmd

func (*ClusterPipeline) MSetNX

func (c *ClusterPipeline) MSetNX(pairs ...string) *BoolCmd

func (*ClusterPipeline) Migrate

func (c *ClusterPipeline) Migrate(host, port, key string, db int64, timeout time.Duration) *StatusCmd

func (*ClusterPipeline) Move

func (c *ClusterPipeline) Move(key string, db int64) *BoolCmd

func (*ClusterPipeline) ObjectEncoding

func (c *ClusterPipeline) ObjectEncoding(keys ...string) *StringCmd

func (*ClusterPipeline) ObjectIdleTime

func (c *ClusterPipeline) ObjectIdleTime(keys ...string) *DurationCmd

func (*ClusterPipeline) ObjectRefCount

func (c *ClusterPipeline) ObjectRefCount(keys ...string) *IntCmd

func (*ClusterPipeline) PExpire

func (c *ClusterPipeline) PExpire(key string, expiration time.Duration) *BoolCmd

func (*ClusterPipeline) PExpireAt

func (c *ClusterPipeline) PExpireAt(key string, tm time.Time) *BoolCmd

func (*ClusterPipeline) PTTL

func (c *ClusterPipeline) PTTL(key string) *DurationCmd

func (*ClusterPipeline) Persist

func (c *ClusterPipeline) Persist(key string) *BoolCmd

func (*ClusterPipeline) Ping

func (c *ClusterPipeline) Ping() *StatusCmd

func (*ClusterPipeline) Process

func (c *ClusterPipeline) Process(cmd Cmder)

func (*ClusterPipeline) PubSubChannels

func (c *ClusterPipeline) PubSubChannels(pattern string) *StringSliceCmd

func (*ClusterPipeline) PubSubNumPat

func (c *ClusterPipeline) PubSubNumPat() *IntCmd

func (*ClusterPipeline) PubSubNumSub

func (c *ClusterPipeline) PubSubNumSub(channels ...string) *StringIntMapCmd

func (*ClusterPipeline) Quit

func (c *ClusterPipeline) Quit() *StatusCmd

func (*ClusterPipeline) RPop

func (c *ClusterPipeline) RPop(key string) *StringCmd

func (*ClusterPipeline) RPopLPush

func (c *ClusterPipeline) RPopLPush(source, destination string) *StringCmd

func (*ClusterPipeline) RPush

func (c *ClusterPipeline) RPush(key string, values ...string) *IntCmd

func (*ClusterPipeline) RPushX

func (c *ClusterPipeline) RPushX(key string, value string) *IntCmd

func (*ClusterPipeline) RandomKey

func (c *ClusterPipeline) RandomKey() *StringCmd

func (*ClusterPipeline) Rename

func (c *ClusterPipeline) Rename(key, newkey string) *StatusCmd

func (*ClusterPipeline) RenameNX

func (c *ClusterPipeline) RenameNX(key, newkey string) *BoolCmd

func (*ClusterPipeline) Restore

func (c *ClusterPipeline) Restore(key string, ttl time.Duration, value string) *StatusCmd

func (*ClusterPipeline) RestoreReplace

func (c *ClusterPipeline) RestoreReplace(key string, ttl time.Duration, value string) *StatusCmd

func (*ClusterPipeline) SAdd

func (c *ClusterPipeline) SAdd(key string, members ...string) *IntCmd

func (*ClusterPipeline) SCard

func (c *ClusterPipeline) SCard(key string) *IntCmd

func (*ClusterPipeline) SDiff

func (c *ClusterPipeline) SDiff(keys ...string) *StringSliceCmd

func (*ClusterPipeline) SDiffStore

func (c *ClusterPipeline) SDiffStore(destination string, keys ...string) *IntCmd

func (*ClusterPipeline) SInter

func (c *ClusterPipeline) SInter(keys ...string) *StringSliceCmd

func (*ClusterPipeline) SInterStore

func (c *ClusterPipeline) SInterStore(destination string, keys ...string) *IntCmd

func (*ClusterPipeline) SIsMember

func (c *ClusterPipeline) SIsMember(key, member string) *BoolCmd

func (*ClusterPipeline) SMembers

func (c *ClusterPipeline) SMembers(key string) *StringSliceCmd

func (*ClusterPipeline) SMove

func (c *ClusterPipeline) SMove(source, destination, member string) *BoolCmd

func (*ClusterPipeline) SPop

func (c *ClusterPipeline) SPop(key string) *StringCmd

func (*ClusterPipeline) SRandMember

func (c *ClusterPipeline) SRandMember(key string) *StringCmd

Redis `SRANDMEMBER key` command.

func (*ClusterPipeline) SRandMemberN

func (c *ClusterPipeline) SRandMemberN(key string, count int64) *StringSliceCmd

Redis `SRANDMEMBER key count` command.

func (*ClusterPipeline) SRem

func (c *ClusterPipeline) SRem(key string, members ...string) *IntCmd

func (*ClusterPipeline) SScan

func (c *ClusterPipeline) SScan(key string, cursor int64, match string, count int64) *ScanCmd

func (*ClusterPipeline) SUnion

func (c *ClusterPipeline) SUnion(keys ...string) *StringSliceCmd

func (*ClusterPipeline) SUnionStore

func (c *ClusterPipeline) SUnionStore(destination string, keys ...string) *IntCmd

func (*ClusterPipeline) Save

func (c *ClusterPipeline) Save() *StatusCmd

func (*ClusterPipeline) Scan

func (c *ClusterPipeline) Scan(cursor int64, match string, count int64) *ScanCmd

func (*ClusterPipeline) ScriptExists

func (c *ClusterPipeline) ScriptExists(scripts ...string) *BoolSliceCmd

func (*ClusterPipeline) ScriptFlush

func (c *ClusterPipeline) ScriptFlush() *StatusCmd

func (*ClusterPipeline) ScriptKill

func (c *ClusterPipeline) ScriptKill() *StatusCmd

func (*ClusterPipeline) ScriptLoad

func (c *ClusterPipeline) ScriptLoad(script string) *StringCmd

func (*ClusterPipeline) Select

func (c *ClusterPipeline) Select(index int64) *StatusCmd

func (*ClusterPipeline) Set

func (c *ClusterPipeline) Set(key string, value interface{}, expiration time.Duration) *StatusCmd

Redis `SET key value [expiration]` command.

Zero expiration means the key has no expiration time.

func (*ClusterPipeline) SetBit

func (c *ClusterPipeline) SetBit(key string, offset int64, value int) *IntCmd

func (*ClusterPipeline) SetNX

func (c *ClusterPipeline) SetNX(key string, value interface{}, expiration time.Duration) *BoolCmd

Redis `SET key value [expiration] NX` command.

Zero expiration means the key has no expiration time.

func (*ClusterPipeline) SetRange

func (c *ClusterPipeline) SetRange(key string, offset int64, value string) *IntCmd

func (*ClusterPipeline) Shutdown

func (c *ClusterPipeline) Shutdown() *StatusCmd

func (*ClusterPipeline) ShutdownNoSave

func (c *ClusterPipeline) ShutdownNoSave() *StatusCmd

func (*ClusterPipeline) ShutdownSave

func (c *ClusterPipeline) ShutdownSave() *StatusCmd

func (*ClusterPipeline) SlaveOf

func (c *ClusterPipeline) SlaveOf(host, port string) *StatusCmd

func (*ClusterPipeline) SlowLog

func (c *ClusterPipeline) SlowLog()

func (*ClusterPipeline) Sort

func (c *ClusterPipeline) Sort(key string, sort Sort) *StringSliceCmd

func (*ClusterPipeline) StrLen

func (c *ClusterPipeline) StrLen(key string) *IntCmd

func (*ClusterPipeline) Sync

func (c *ClusterPipeline) Sync()

func (*ClusterPipeline) TTL

func (c *ClusterPipeline) TTL(key string) *DurationCmd

func (*ClusterPipeline) Time

func (c *ClusterPipeline) Time() *StringSliceCmd

func (*ClusterPipeline) Type

func (c *ClusterPipeline) Type(key string) *StatusCmd

func (*ClusterPipeline) ZAdd

func (c *ClusterPipeline) ZAdd(key string, members ...Z) *IntCmd

Redis `ZADD key score member [score member ...]` command.

func (*ClusterPipeline) ZAddCh

func (c *ClusterPipeline) ZAddCh(key string, members ...Z) *IntCmd

Redis `ZADD key CH score member [score member ...]` command.

func (*ClusterPipeline) ZAddNX

func (c *ClusterPipeline) ZAddNX(key string, members ...Z) *IntCmd

Redis `ZADD key NX score member [score member ...]` command.

func (*ClusterPipeline) ZAddNXCh

func (c *ClusterPipeline) ZAddNXCh(key string, members ...Z) *IntCmd

Redis `ZADD key NX CH score member [score member ...]` command.

func (*ClusterPipeline) ZAddXX

func (c *ClusterPipeline) ZAddXX(key string, members ...Z) *IntCmd

Redis `ZADD key XX score member [score member ...]` command.

func (*ClusterPipeline) ZAddXXCh

func (c *ClusterPipeline) ZAddXXCh(key string, members ...Z) *IntCmd

Redis `ZADD key XX CH score member [score member ...]` command.

func (*ClusterPipeline) ZCard

func (c *ClusterPipeline) ZCard(key string) *IntCmd

func (*ClusterPipeline) ZCount

func (c *ClusterPipeline) ZCount(key, min, max string) *IntCmd

func (*ClusterPipeline) ZIncr

func (c *ClusterPipeline) ZIncr(key string, member Z) *FloatCmd

Redis `ZADD key INCR score member` command.

func (*ClusterPipeline) ZIncrBy

func (c *ClusterPipeline) ZIncrBy(key string, increment float64, member string) *FloatCmd

func (*ClusterPipeline) ZIncrNX

func (c *ClusterPipeline) ZIncrNX(key string, member Z) *FloatCmd

Redis `ZADD key NX INCR score member` command.

func (*ClusterPipeline) ZIncrXX

func (c *ClusterPipeline) ZIncrXX(key string, member Z) *FloatCmd

Redis `ZADD key XX INCR score member` command.

func (*ClusterPipeline) ZInterStore

func (c *ClusterPipeline) ZInterStore(
	destination string,
	store ZStore,
	keys ...string,
) *IntCmd

func (*ClusterPipeline) ZRange

func (c *ClusterPipeline) ZRange(key string, start, stop int64) *StringSliceCmd

func (*ClusterPipeline) ZRangeByLex

func (c *ClusterPipeline) ZRangeByLex(key string, opt ZRangeByScore) *StringSliceCmd

func (*ClusterPipeline) ZRangeByScore

func (c *ClusterPipeline) ZRangeByScore(key string, opt ZRangeByScore) *StringSliceCmd

func (*ClusterPipeline) ZRangeByScoreWithScores

func (c *ClusterPipeline) ZRangeByScoreWithScores(key string, opt ZRangeByScore) *ZSliceCmd

func (*ClusterPipeline) ZRangeWithScores

func (c *ClusterPipeline) ZRangeWithScores(key string, start, stop int64) *ZSliceCmd

func (*ClusterPipeline) ZRank

func (c *ClusterPipeline) ZRank(key, member string) *IntCmd

func (*ClusterPipeline) ZRem

func (c *ClusterPipeline) ZRem(key string, members ...string) *IntCmd

func (*ClusterPipeline) ZRemRangeByRank

func (c *ClusterPipeline) ZRemRangeByRank(key string, start, stop int64) *IntCmd

func (*ClusterPipeline) ZRemRangeByScore

func (c *ClusterPipeline) ZRemRangeByScore(key, min, max string) *IntCmd

func (*ClusterPipeline) ZRevRange

func (c *ClusterPipeline) ZRevRange(key string, start, stop int64) *StringSliceCmd

func (ClusterPipeline) ZRevRangeByLex

func (c ClusterPipeline) ZRevRangeByLex(key string, opt ZRangeByScore) *StringSliceCmd

func (*ClusterPipeline) ZRevRangeByScore

func (c *ClusterPipeline) ZRevRangeByScore(key string, opt ZRangeByScore) *StringSliceCmd

func (*ClusterPipeline) ZRevRangeByScoreWithScores

func (c *ClusterPipeline) ZRevRangeByScoreWithScores(key string, opt ZRangeByScore) *ZSliceCmd

func (*ClusterPipeline) ZRevRangeWithScores

func (c *ClusterPipeline) ZRevRangeWithScores(key string, start, stop int64) *ZSliceCmd

func (*ClusterPipeline) ZRevRank

func (c *ClusterPipeline) ZRevRank(key, member string) *IntCmd

func (*ClusterPipeline) ZScan

func (c *ClusterPipeline) ZScan(key string, cursor int64, match string, count int64) *ScanCmd

func (*ClusterPipeline) ZScore

func (c *ClusterPipeline) ZScore(key, member string) *FloatCmd

func (*ClusterPipeline) ZUnionStore

func (c *ClusterPipeline) ZUnionStore(dest string, store ZStore, keys ...string) *IntCmd

type ClusterSlotCmd

type ClusterSlotCmd struct {
	// contains filtered or unexported fields
}

func NewClusterSlotCmd

func NewClusterSlotCmd(args ...interface{}) *ClusterSlotCmd

func (*ClusterSlotCmd) Err

func (cmd *ClusterSlotCmd) Err() error

func (*ClusterSlotCmd) Result

func (cmd *ClusterSlotCmd) Result() ([]ClusterSlotInfo, error)

func (*ClusterSlotCmd) String

func (cmd *ClusterSlotCmd) String() string

func (*ClusterSlotCmd) Val

func (cmd *ClusterSlotCmd) Val() []ClusterSlotInfo

type ClusterSlotInfo

type ClusterSlotInfo struct {
	Start, End int
	Addrs      []string
}

type Cmd

type Cmd struct {
	// contains filtered or unexported fields
}

func NewCmd

func NewCmd(args ...interface{}) *Cmd

func (*Cmd) Err

func (cmd *Cmd) Err() error

func (*Cmd) Result

func (cmd *Cmd) Result() (interface{}, error)

func (*Cmd) String

func (cmd *Cmd) String() string

func (*Cmd) Val

func (cmd *Cmd) Val() interface{}

type Cmder

type Cmder interface {
	Err() error
	fmt.Stringer
	// contains filtered or unexported methods
}

type DurationCmd

type DurationCmd struct {
	// contains filtered or unexported fields
}

func NewDurationCmd

func NewDurationCmd(precision time.Duration, args ...interface{}) *DurationCmd

func (*DurationCmd) Err

func (cmd *DurationCmd) Err() error

func (*DurationCmd) Result

func (cmd *DurationCmd) Result() (time.Duration, error)

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       int64

	DialTimeout  time.Duration
	ReadTimeout  time.Duration
	WriteTimeout time.Duration

	PoolSize    int
	PoolTimeout time.Duration
	IdleTimeout time.Duration

	MaxRetries int
}

FailoverOptions are used to configure a failover client and should be passed to NewFailoverClient.

type FloatCmd

type FloatCmd struct {
	// contains filtered or unexported fields
}

func NewFloatCmd

func NewFloatCmd(args ...interface{}) *FloatCmd

func (*FloatCmd) Err

func (cmd *FloatCmd) Err() error

func (*FloatCmd) Result

func (cmd *FloatCmd) Result() (float64, error)

func (*FloatCmd) String

func (cmd *FloatCmd) String() string

func (*FloatCmd) Val

func (cmd *FloatCmd) Val() float64

type IntCmd

type IntCmd struct {
	// contains filtered or unexported fields
}

func NewIntCmd

func NewIntCmd(args ...interface{}) *IntCmd

func (*IntCmd) Err

func (cmd *IntCmd) Err() error

func (*IntCmd) Result

func (cmd *IntCmd) Result() (int64, error)

func (*IntCmd) String

func (cmd *IntCmd) String() string

func (*IntCmd) Val

func (cmd *IntCmd) Val() int64

type Message

type Message struct {
	Channel string
	Pattern string
	Payload string
}

Message received as result of a PUBLISH command issued by another client.

func (*Message) String

func (m *Message) String() string

type Multi

type Multi struct {
	// contains filtered or unexported fields
}

Multi implements Redis transactions as described in http://redis.io/topics/transactions. It's NOT safe for concurrent use by multiple goroutines.

Example

// Transactionally increments key using GET and SET commands.
incr := func(tx *redis.Multi, key string) error {
	err := tx.Watch(key).Err()
	if err != nil {
		return err
	}

	n, err := tx.Get(key).Int64()
	if err != nil && err != redis.Nil {
		return err
	}

	_, err = tx.Exec(func() error {
		tx.Set(key, strconv.FormatInt(n+1, 10), 0)
		return nil
	})
	return err
}

var wg sync.WaitGroup
for i := 0; i < 10; i++ {
	wg.Add(1)
	go func() {
		defer wg.Done()

		tx := client.Multi()
		defer tx.Close()

		for {
			err := incr(tx, "counter3")
			if err == redis.TxFailedErr {
				// Retry.
				continue
			} else if err != nil {
				panic(err)
			}
			break
		}
	}()
}
wg.Wait()

n, err := client.Get("counter3").Int64()
fmt.Println(n, err)

Output:

10 <nil>

func (*Multi) Append

func (c *Multi) Append(key, value string) *IntCmd

func (*Multi) Auth

func (c *Multi) Auth(password string) *StatusCmd

func (*Multi) BLPop

func (c *Multi) BLPop(timeout time.Duration, keys ...string) *StringSliceCmd

func (*Multi) BRPop

func (c *Multi) BRPop(timeout time.Duration, keys ...string) *StringSliceCmd

func (*Multi) BRPopLPush

func (c *Multi) BRPopLPush(source, destination string, timeout time.Duration) *StringCmd

func (*Multi) BgRewriteAOF

func (c *Multi) BgRewriteAOF() *StatusCmd

func (*Multi) BgSave

func (c *Multi) BgSave() *StatusCmd

func (*Multi) BitCount

func (c *Multi) BitCount(key string, bitCount *BitCount) *IntCmd

func (*Multi) BitOpAnd

func (c *Multi) BitOpAnd(destKey string, keys ...string) *IntCmd

func (*Multi) BitOpNot

func (c *Multi) BitOpNot(destKey string, key string) *IntCmd

func (*Multi) BitOpOr

func (c *Multi) BitOpOr(destKey string, keys ...string) *IntCmd

func (*Multi) BitOpXor

func (c *Multi) BitOpXor(destKey string, keys ...string) *IntCmd

func (*Multi) BitPos

func (c *Multi) BitPos(key string, bit int64, pos ...int64) *IntCmd

func (*Multi) ClientKill

func (c *Multi) ClientKill(ipPort string) *StatusCmd

func (*Multi) ClientList

func (c *Multi) ClientList() *StringCmd

func (*Multi) ClientPause

func (c *Multi) ClientPause(dur time.Duration) *BoolCmd

func (*Multi) Close

func (c *Multi) Close() error

func (*Multi) ClusterAddSlots

func (c *Multi) ClusterAddSlots(slots ...int) *StatusCmd

func (*Multi) ClusterAddSlotsRange

func (c *Multi) ClusterAddSlotsRange(min, max int) *StatusCmd

func (*Multi) ClusterFailover

func (c *Multi) ClusterFailover() *StatusCmd

func (*Multi) ClusterInfo

func (c *Multi) ClusterInfo() *StringCmd

func (*Multi) ClusterMeet

func (c *Multi) ClusterMeet(host, port string) *StatusCmd

func (*Multi) ClusterNodes

func (c *Multi) ClusterNodes() *StringCmd

func (*Multi) ClusterReplicate

func (c *Multi) ClusterReplicate(nodeID string) *StatusCmd

func (*Multi) ClusterSlots

func (c *Multi) ClusterSlots() *ClusterSlotCmd

func (*Multi) ConfigGet

func (c *Multi) ConfigGet(parameter string) *SliceCmd

func (*Multi) ConfigResetStat

func (c *Multi) ConfigResetStat() *StatusCmd

func (*Multi) ConfigSet

func (c *Multi) ConfigSet(parameter, value string) *StatusCmd

func (*Multi) DbSize

func (c *Multi) DbSize() *IntCmd

func (*Multi) DebugObject

func (c *Multi) DebugObject(key string) *StringCmd

func (*Multi) Decr

func (c *Multi) Decr(key string) *IntCmd

func (*Multi) DecrBy

func (c *Multi) DecrBy(key string, decrement int64) *IntCmd

func (*Multi) Del

func (c *Multi) Del(keys ...string) *IntCmd

func (*Multi) Discard

func (c *Multi) Discard() error

func (*Multi) Dump

func (c *Multi) Dump(key string) *StringCmd

func (*Multi) Echo

func (c *Multi) Echo(message string) *StringCmd

func (*Multi) Eval