redis

package module

Go to main page

Versions in this module

v6

v6.15.8

May 21, 2020

v6.15.7

Feb 2, 2020

v6.15.6

Oct 8, 2019

v6.15.5

Sep 3, 2019

Changes in this version

type Cmd

+ func (cmd *Cmd) Float32() (float32, error)

type PubSub

+ func (c *PubSub) ChannelSize(size int) <-chan *Message

+ func (c *PubSub) String() string

type Ring

+ func (c *Ring) Watch(fn func(*Tx) error, keys ...string) error

type SentinelClient

+ func (c *SentinelClient) FlushConfig() *StatusCmd

+ func (c *SentinelClient) Master(name string) *StringStringMapCmd

type StringCmd

+ func (cmd *StringCmd) Float32() (float32, error)

type UniversalClient

+ WrapProcessPipeline func(fn func(oldProcess func([]Cmder) error) func([]Cmder) error)

v6.15.2

Feb 27, 2019

Changes in this version

type Client

+ func (c *Client) ClusterGetKeysInSlot(slot int, count int) *StringSliceCmd

type ClusterClient

+ func (c *ClusterClient) ClusterGetKeysInSlot(slot int, count int) *StringSliceCmd

type Cmdable

+ ClusterGetKeysInSlot func(slot int, count int) *StringSliceCmd

type Pipeline

+ func (c *Pipeline) Do(args ...interface{}) *Cmd

type Pipeliner

+ Do func(args ...interface{}) *Cmd

type Ring

+ func (c *Ring) ClusterGetKeysInSlot(slot int, count int) *StringSliceCmd

type SentinelClient

+ func (c *SentinelClient) Failover(name string) *StatusCmd

+ func (c *SentinelClient) Reset(pattern string) *IntCmd

v6.15.1

Jan 8, 2019

v6.15.0

Dec 17, 2018

Changes in this version

type Client

+ func (c *Client) BZPopMax(timeout time.Duration, keys ...string) *ZWithKeyCmd

+ func (c *Client) BZPopMin(timeout time.Duration, keys ...string) *ZWithKeyCmd

+ func (c *Client) ClientID() *IntCmd

+ func (c *Client) ClientUnblock(id int64) *IntCmd

+ func (c *Client) ClientUnblockWithError(id int64) *IntCmd

+ func (c *Client) SetLimiter(l Limiter) *Client

+ func (c *Client) XDel(stream string, ids ...string) *IntCmd

+ func (c *Client) XGroupCreateMkStream(stream, group, start string) *StatusCmd

type ClusterClient

+ func (c *ClusterClient) BZPopMax(timeout time.Duration, keys ...string) *ZWithKeyCmd

+ func (c *ClusterClient) BZPopMin(timeout time.Duration, keys ...string) *ZWithKeyCmd

+ func (c *ClusterClient) ClientID() *IntCmd

+ func (c *ClusterClient) ClientUnblock(id int64) *IntCmd

+ func (c *ClusterClient) ClientUnblockWithError(id int64) *IntCmd

+ func (c *ClusterClient) XDel(stream string, ids ...string) *IntCmd

+ func (c *ClusterClient) XGroupCreateMkStream(stream, group, start string) *StatusCmd

type ClusterOptions

+ OnNewNode func(*Client)

type Cmdable

+ BZPopMax func(timeout time.Duration, keys ...string) *ZWithKeyCmd

+ BZPopMin func(timeout time.Duration, keys ...string) *ZWithKeyCmd

+ ClientID func() *IntCmd

+ XDel func(stream string, ids ...string) *IntCmd

+ XGroupCreateMkStream func(stream, group, start string) *StatusCmd

+ type Limiter interface

+ Allow func() error

+ ReportResult func(result error)

type Ring

+ func (c *Ring) BZPopMax(timeout time.Duration, keys ...string) *ZWithKeyCmd

+ func (c *Ring) BZPopMin(timeout time.Duration, keys ...string) *ZWithKeyCmd

+ func (c *Ring) ClientID() *IntCmd

+ func (c *Ring) ClientUnblock(id int64) *IntCmd

+ func (c *Ring) ClientUnblockWithError(id int64) *IntCmd

+ func (c *Ring) XDel(stream string, ids ...string) *IntCmd

+ func (c *Ring) XGroupCreateMkStream(stream, group, start string) *StatusCmd

type XReadGroupArgs

+ NoAck bool

+ type ZWithKey struct

+ Key string

+ type ZWithKeyCmd struct

+ func NewZWithKeyCmd(args ...interface{}) *ZWithKeyCmd

+ func (cmd *ZWithKeyCmd) Args() []interface{}

+ func (cmd *ZWithKeyCmd) Err() error

+ func (cmd *ZWithKeyCmd) Name() string

+ func (cmd *ZWithKeyCmd) Result() (ZWithKey, error)

+ func (cmd *ZWithKeyCmd) String() string

+ func (cmd *ZWithKeyCmd) Val() ZWithKey

v6.14.2

Oct 25, 2018

Changes in this version

type SentinelClient

+ func (c *SentinelClient) PSubscribe(channels ...string) *PubSub

+ func (c *SentinelClient) Subscribe(channels ...string) *PubSub

v6.14.1

Sep 3, 2018

Changes in this version

type Client

+ func (c *Client) ZPopMax(key string, count ...int64) *ZSliceCmd

+ func (c *Client) ZPopMin(key string, count ...int64) *ZSliceCmd

type ClusterClient

+ func (c *ClusterClient) ZPopMax(key string, count ...int64) *ZSliceCmd

+ func (c *ClusterClient) ZPopMin(key string, count ...int64) *ZSliceCmd

type Cmdable

+ ZPopMax func(key string, count ...int64) *ZSliceCmd

+ ZPopMin func(key string, count ...int64) *ZSliceCmd

type Ring

+ func (c *Ring) ZPopMax(key string, count ...int64) *ZSliceCmd

+ func (c *Ring) ZPopMin(key string, count ...int64) *ZSliceCmd

v6.14.0

Aug 23, 2018

Changes in this version

type Client

+ func (c *Client) Do(args ...interface{}) *Cmd

+ func (c *Client) XAck(stream, group string, ids ...string) *IntCmd

+ func (c *Client) XClaim(a *XClaimArgs) *XMessageSliceCmd

+ func (c *Client) XClaimJustID(a *XClaimArgs) *StringSliceCmd

+ func (c *Client) XGroupCreate(stream, group, start string) *StatusCmd

+ func (c *Client) XGroupDelConsumer(stream, group, consumer string) *IntCmd

+ func (c *Client) XGroupDestroy(stream, group string) *IntCmd

+ func (c *Client) XGroupSetID(stream, group, start string) *StatusCmd

+ func (c *Client) XPending(stream, group string) *XPendingCmd

+ func (c *Client) XPendingExt(a *XPendingExtArgs) *XPendingExtCmd

+ func (c *Client) XReadGroup(a *XReadGroupArgs) *XStreamSliceCmd

+ func (c *Client) XReadStreams(streams ...string) *XStreamSliceCmd

+ func (c *Client) XTrim(key string, maxLen int64) *IntCmd

+ func (c *Client) XTrimApprox(key string, maxLen int64) *IntCmd

type ClusterClient

+ func (c *ClusterClient) Do(args ...interface{}) *Cmd

+ func (c *ClusterClient) XAck(stream, group string, ids ...string) *IntCmd

+ func (c *ClusterClient) XClaim(a *XClaimArgs) *XMessageSliceCmd

+ func (c *ClusterClient) XClaimJustID(a *XClaimArgs) *StringSliceCmd

+ func (c *ClusterClient) XGroupCreate(stream, group, start string) *StatusCmd

+ func (c *ClusterClient) XGroupDelConsumer(stream, group, consumer string) *IntCmd

+ func (c *ClusterClient) XGroupDestroy(stream, group string) *IntCmd

+ func (c *ClusterClient) XGroupSetID(stream, group, start string) *StatusCmd

+ func (c *ClusterClient) XPending(stream, group string) *XPendingCmd

+ func (c *ClusterClient) XPendingExt(a *XPendingExtArgs) *XPendingExtCmd

+ func (c *ClusterClient) XReadGroup(a *XReadGroupArgs) *XStreamSliceCmd

+ func (c *ClusterClient) XReadStreams(streams ...string) *XStreamSliceCmd

+ func (c *ClusterClient) XTrim(key string, maxLen int64) *IntCmd

+ func (c *ClusterClient) XTrimApprox(key string, maxLen int64) *IntCmd

type ClusterOptions

+ MaxConnAge time.Duration

+ MinIdleConns int

type Cmd

+ func (cmd *Cmd) Bool() (bool, error)

+ func (cmd *Cmd) Float64() (float64, error)

+ func (cmd *Cmd) Int() (int, error)

+ func (cmd *Cmd) Int64() (int64, error)

+ func (cmd *Cmd) Uint64() (uint64, error)

type Cmdable

+ XAck func(stream, group string, ids ...string) *IntCmd

+ XClaim func(a *XClaimArgs) *XMessageSliceCmd

+ XClaimJustID func(a *XClaimArgs) *StringSliceCmd

+ XGroupCreate func(stream, group, start string) *StatusCmd

+ XGroupDelConsumer func(stream, group, consumer string) *IntCmd

+ XGroupDestroy func(stream, group string) *IntCmd

+ XGroupSetID func(stream, group, start string) *StatusCmd

+ XPending func(stream, group string) *XPendingCmd

+ XPendingExt func(a *XPendingExtArgs) *XPendingExtCmd

+ XReadGroup func(a *XReadGroupArgs) *XStreamSliceCmd

+ XReadStreams func(streams ...string) *XStreamSliceCmd

+ XTrim func(key string, maxLen int64) *IntCmd

+ XTrimApprox func(key string, maxLen int64) *IntCmd

type Conn

+ func (c *Conn) Do(args ...interface{}) *Cmd

type FailoverOptions

+ MaxConnAge time.Duration

+ MaxRetryBackoff time.Duration

+ MinIdleConns int

+ MinRetryBackoff time.Duration

type Options

+ MaxConnAge time.Duration

+ MinIdleConns int

type Ring

+ func (c *Ring) Do(args ...interface{}) *Cmd

+ func (c *Ring) XAck(stream, group string, ids ...string) *IntCmd

+ func (c *Ring) XClaim(a *XClaimArgs) *XMessageSliceCmd

+ func (c *Ring) XClaimJustID(a *XClaimArgs) *StringSliceCmd

+ func (c *Ring) XGroupCreate(stream, group, start string) *StatusCmd

+ func (c *Ring) XGroupDelConsumer(stream, group, consumer string) *IntCmd

+ func (c *Ring) XGroupDestroy(stream, group string) *IntCmd

+ func (c *Ring) XGroupSetID(stream, group, start string) *StatusCmd

+ func (c *Ring) XPending(stream, group string) *XPendingCmd

+ func (c *Ring) XPendingExt(a *XPendingExtArgs) *XPendingExtCmd

+ func (c *Ring) XReadGroup(a *XReadGroupArgs) *XStreamSliceCmd

+ func (c *Ring) XReadStreams(streams ...string) *XStreamSliceCmd

+ func (c *Ring) XTrim(key string, maxLen int64) *IntCmd

+ func (c *Ring) XTrimApprox(key string, maxLen int64) *IntCmd

type RingOptions

+ MaxConnAge time.Duration

+ MinIdleConns int

type SentinelClient

+ func (c *SentinelClient) Do(args ...interface{}) *Cmd

type StringCmd

+ func (cmd *StringCmd) Int() (int, error)

type Tx

+ func (c *Tx) Do(args ...interface{}) *Cmd

type UniversalOptions

+ MaxConnAge time.Duration

+ MaxRetryBackoff time.Duration

+ MinIdleConns int

+ MinRetryBackoff time.Duration

+ RouteRandomly bool

+ type XAddArgs struct

+ ID string

+ MaxLen int64

+ MaxLenApprox int64

+ Stream string

+ Values map[string]interface{}

+ type XClaimArgs struct

+ Consumer string

+ Group string

+ Messages []string

+ MinIdle time.Duration

+ Stream string

+ type XPending struct

+ Consumers map[string]int64

+ Count int64

+ Higher string

+ Lower string

+ type XPendingCmd struct

+ func NewXPendingCmd(args ...interface{}) *XPendingCmd

+ func (cmd *XPendingCmd) Args() []interface{}

+ func (cmd *XPendingCmd) Err() error

+ func (cmd *XPendingCmd) Name() string

+ func (cmd *XPendingCmd) Result() (*XPending, error)

+ func (cmd *XPendingCmd) String() string

+ func (cmd *XPendingCmd) Val() *XPending

+ type XPendingExt struct

+ Consumer string

+ Id string

+ Idle time.Duration

+ RetryCount int64

+ type XPendingExtArgs struct

+ Consumer string

+ Count int64

+ End string

+ Group string

+ Start string

+ Stream string

+ type XPendingExtCmd struct

+ func NewXPendingExtCmd(args ...interface{}) *XPendingExtCmd

+ func (cmd *XPendingExtCmd) Args() []interface{}

+ func (cmd *XPendingExtCmd) Err() error

+ func (cmd *XPendingExtCmd) Name() string

+ func (cmd *XPendingExtCmd) Result() ([]XPendingExt, error)

+ func (cmd *XPendingExtCmd) String() string

+ func (cmd *XPendingExtCmd) Val() []XPendingExt

+ type XReadArgs struct

+ Block time.Duration

+ Count int64

+ Streams []string

+ type XReadGroupArgs struct

+ Block time.Duration

+ Consumer string

+ Count int64

+ Group string

+ Streams []string

v6.13.2

Jul 24, 2018

Changes in this version

type Client

+ func (c *Client) ClientKillByFilter(keys ...string) *IntCmd

type ClusterClient

+ func (c *ClusterClient) ClientKillByFilter(keys ...string) *IntCmd

type Cmdable

+ ClientKillByFilter func(keys ...string) *IntCmd

type Ring

+ func (c *Ring) ClientKillByFilter(keys ...string) *IntCmd

v6.13.1

Jul 23, 2018

Changes in this version

type Ring

+ func (c *Ring) Len() int

v6.13.0

Jul 22, 2018

Changes in this version

type Client

+ func (c *Client) MemoryUsage(key string, samples ...int) *IntCmd

+ func (c *Client) XAdd(stream, id string, values map[string]interface{}) *StringCmd

+ func (c *Client) XAddExt(opt *XAddExt) *StringCmd

+ func (c *Client) XLen(key string) *IntCmd

+ func (c *Client) XRange(stream, start, stop string) *XMessageSliceCmd

+ func (c *Client) XRangeN(stream, start, stop string, count int64) *XMessageSliceCmd

+ func (c *Client) XRead(streams ...string) *XStreamSliceCmd

+ func (c *Client) XReadBlock(block time.Duration, streams ...string) *XStreamSliceCmd

+ func (c *Client) XReadExt(opt *XReadExt) *XStreamSliceCmd

+ func (c *Client) XReadN(count int64, streams ...string) *XStreamSliceCmd

+ func (c *Client) XRevRange(stream, start, stop string) *XMessageSliceCmd

+ func (c *Client) XRevRangeN(stream, start, stop string, count int64) *XMessageSliceCmd

type ClusterClient

+ func (c *ClusterClient) MemoryUsage(key string, samples ...int) *IntCmd

+ func (c *ClusterClient) ReloadState() error

+ func (c *ClusterClient) XAdd(stream, id string, values map[string]interface{}) *StringCmd

+ func (c *ClusterClient) XAddExt(opt *XAddExt) *StringCmd

+ func (c *ClusterClient) XLen(key string) *IntCmd

+ func (c *ClusterClient) XRange(stream, start, stop string) *XMessageSliceCmd

+ func (c *ClusterClient) XRangeN(stream, start, stop string, count int64) *XMessageSliceCmd

+ func (c *ClusterClient) XRead(streams ...string) *XStreamSliceCmd

+ func (c *ClusterClient) XReadBlock(block time.Duration, streams ...string) *XStreamSliceCmd

+ func (c *ClusterClient) XReadExt(opt *XReadExt) *XStreamSliceCmd

+ func (c *ClusterClient) XReadN(count int64, streams ...string) *XStreamSliceCmd

+ func (c *ClusterClient) XRevRange(stream, start, stop string) *XMessageSliceCmd

+ func (c *ClusterClient) XRevRangeN(stream, start, stop string, count int64) *XMessageSliceCmd

type ClusterOptions

+ ClusterSlots func() ([]ClusterSlot, error)

type Cmdable

+ MemoryUsage func(key string, samples ...int) *IntCmd

+ XAdd func(stream, id string, els map[string]interface{}) *StringCmd

+ XAddExt func(opt *XAddExt) *StringCmd

+ XLen func(key string) *IntCmd

+ XRange func(stream, start, stop string) *XMessageSliceCmd

+ XRangeN func(stream, start, stop string, count int64) *XMessageSliceCmd

+ XRead func(streams ...string) *XStreamSliceCmd

+ XReadExt func(opt *XReadExt) *XStreamSliceCmd

+ XReadN func(count int64, streams ...string) *XStreamSliceCmd

+ XRevRange func(stream string, start, stop string) *XMessageSliceCmd

+ XRevRangeN func(stream string, start, stop string, count int64) *XMessageSliceCmd

+ type Hash consistenthash.Hash

type Ring

+ func (c *Ring) MemoryUsage(key string, samples ...int) *IntCmd

+ func (c *Ring) XAdd(stream, id string, values map[string]interface{}) *StringCmd

+ func (c *Ring) XAddExt(opt *XAddExt) *StringCmd

+ func (c *Ring) XLen(key string) *IntCmd

+ func (c *Ring) XRange(stream, start, stop string) *XMessageSliceCmd

+ func (c *Ring) XRangeN(stream, start, stop string, count int64) *XMessageSliceCmd

+ func (c *Ring) XRead(streams ...string) *XStreamSliceCmd

+ func (c *Ring) XReadBlock(block time.Duration, streams ...string) *XStreamSliceCmd

+ func (c *Ring) XReadExt(opt *XReadExt) *XStreamSliceCmd

+ func (c *Ring) XReadN(count int64, streams ...string) *XStreamSliceCmd

+ func (c *Ring) XRevRange(stream, start, stop string) *XMessageSliceCmd

+ func (c *Ring) XRevRangeN(stream, start, stop string, count int64) *XMessageSliceCmd

type RingOptions

+ Hash Hash

+ HashReplicas int

+ type XAddExt struct

+ ID string

+ MaxLen int64

+ MaxLenApprox int64

+ Stream string

+ Values map[string]interface{}

+ type XMessage struct

+ ID string

+ Values map[string]interface{}

+ type XMessageSliceCmd struct

+ func NewXMessageSliceCmd(args ...interface{}) *XMessageSliceCmd

+ func (cmd *XMessageSliceCmd) Args() []interface{}

+ func (cmd *XMessageSliceCmd) Err() error

+ func (cmd *XMessageSliceCmd) Name() string

+ func (cmd *XMessageSliceCmd) Result() ([]*XMessage, error)

+ func (cmd *XMessageSliceCmd) String() string

+ func (cmd *XMessageSliceCmd) Val() []*XMessage

+ type XReadExt struct

+ Block time.Duration

+ Count int64

+ Streams []string

+ type XStream struct

+ Messages []*XMessage

+ Stream string

+ type XStreamSliceCmd struct

+ func NewXStreamSliceCmd(args ...interface{}) *XStreamSliceCmd

+ func (cmd *XStreamSliceCmd) Args() []interface{}

+ func (cmd *XStreamSliceCmd) Err() error

+ func (cmd *XStreamSliceCmd) Name() string

+ func (cmd *XStreamSliceCmd) Result() ([]*XStream, error)

+ func (cmd *XStreamSliceCmd) String() string

+ func (cmd *XStreamSliceCmd) Val() []*XStream

v6.12.0

May 31, 2018

Changes in this version

+ type SentinelClient struct

+ func NewSentinelClient(opt *Options) *SentinelClient

+ func (c *SentinelClient) Close() error

+ func (c *SentinelClient) GetMasterAddrByName(name string) *StringSliceCmd

+ func (c *SentinelClient) Process(cmd Cmder) error

+ func (c *SentinelClient) PubSub() *PubSub

+ func (c *SentinelClient) Sentinels(name string) *SliceCmd

+ func (c *SentinelClient) String() string

+ func (c *SentinelClient) WrapProcess(fn func(oldProcess func(cmd Cmder) error) func(cmd Cmder) error)

+ func (c *SentinelClient) WrapProcessPipeline(fn func(oldProcess func([]Cmder) error) func([]Cmder) error)

v6.11.0

May 24, 2018

Changes in this version

type Client

+ func (c *Client) ReadOnly() *StatusCmd

+ func (c *Client) ReadWrite() *StatusCmd

type ClusterClient

+ func (c *ClusterClient) ReadOnly() *StatusCmd

+ func (c *ClusterClient) ReadWrite() *StatusCmd

type ClusterOptions

+ TLSConfig *tls.Config

type Cmdable

+ ReadOnly func() *StatusCmd

+ ReadWrite func() *StatusCmd

type FailoverOptions

+ TLSConfig *tls.Config

type Ring

+ func (c *Ring) ReadOnly() *StatusCmd

+ func (c *Ring) ReadWrite() *StatusCmd

type UniversalClient

+ Watch func(fn func(*Tx) error, keys ...string) error

type UniversalOptions

+ OnConnect func(*Conn) error

+ TLSConfig *tls.Config

v6.10.2

Mar 14, 2018

v6.10.1

Mar 13, 2018

v6.10.0

Mar 8, 2018

Changes in this version

type Client

+ func (c *Client) ConfigRewrite() *StatusCmd

type ClusterClient

+ func (c *ClusterClient) ConfigRewrite() *StatusCmd

+ func (c *ClusterClient) Context() context.Context

+ func (c *ClusterClient) WithContext(ctx context.Context) *ClusterClient

type ClusterOptions

+ RouteRandomly bool

type Cmdable

+ ConfigRewrite func() *StatusCmd

type Ring

+ func (c *Ring) ConfigRewrite() *StatusCmd

+ func (c *Ring) Context() context.Context

+ func (c *Ring) WithContext(ctx context.Context) *Ring

type UniversalClient

+ WrapProcess func(fn func(oldProcess func(cmd Cmder) error) func(cmd Cmder) error)

v6.9.2

Feb 27, 2018

v6.9.1

Feb 22, 2018

v6.9.0

Feb 16, 2018

Changes in this version

type Client

+ func (c *Client) SortStore(key, store string, sort *Sort) *IntCmd

+ func (c *Client) Touch(keys ...string) *IntCmd

type ClusterClient

+ func (c *ClusterClient) SortStore(key, store string, sort *Sort) *IntCmd

+ func (c *ClusterClient) Touch(keys ...string) *IntCmd

type Cmdable

+ SortStore func(key, store string, sort *Sort) *IntCmd

+ Touch func(keys ...string) *IntCmd

type Conn

+ func (c *Conn) SwapDB(index1, index2 int) *StatusCmd

type Pipeline

+ func (c *Pipeline) SwapDB(index1, index2 int) *StatusCmd

type Ring

+ func (c *Ring) SortStore(key, store string, sort *Sort) *IntCmd

+ func (c *Ring) Touch(keys ...string) *IntCmd

type Sort

+ Alpha bool

type StatefulCmdable

+ SwapDB func(index1, index2 int) *StatusCmd

type Tx

+ func (c *Tx) SwapDB(index1, index2 int) *StatusCmd

v6.8.3

Jan 30, 2018

Changes in this version

type Client

+ func (c *Client) WrapProcessPipeline(fn func(oldProcess func([]Cmder) error) func([]Cmder) error)

type ClusterClient

+ func (c *ClusterClient) WrapProcess(fn func(oldProcess func(Cmder) error) func(Cmder) error)

+ func (c *ClusterClient) WrapProcessPipeline(fn func(oldProcess func([]Cmder) error) func([]Cmder) error)

type Conn

+ func (c *Conn) WrapProcessPipeline(fn func(oldProcess func([]Cmder) error) func([]Cmder) error)

type Ring

+ func (c *Ring) WrapProcess(fn func(oldProcess func(cmd Cmder) error) func(cmd Cmder) error)

+ func (c *Ring) WrapProcessPipeline(fn func(oldProcess func([]Cmder) error) func([]Cmder) error)

type Tx

+ func (c *Tx) WrapProcessPipeline(fn func(oldProcess func([]Cmder) error) func([]Cmder) error)

v6.8.2

Jan 17, 2018

v6.8.1

Jan 15, 2018

v6.8.0

Dec 28, 2017

v6.7.5

Dec 15, 2017

Changes in this version

type UniversalClient

+ PSubscribe func(channels ...string) *PubSub

+ Subscribe func(channels ...string) *PubSub

v6.7.4

Nov 20, 2017

Changes in this version

type Client

+ func (c *Client) SMembersMap(key string) *StringStructMapCmd

type ClusterClient

+ func (c *ClusterClient) SMembersMap(key string) *StringStructMapCmd

type Cmdable

+ SMembersMap func(key string) *StringStructMapCmd

type Ring

+ func (c *Ring) SMembersMap(key string) *StringStructMapCmd

+ type StringStructMapCmd struct

+ func NewStringStructMapCmd(args ...interface{}) *StringStructMapCmd

+ func (cmd *StringStructMapCmd) Args() []interface{}

+ func (cmd *StringStructMapCmd) Err() error

+ func (cmd *StringStructMapCmd) Name() string

+ func (cmd *StringStructMapCmd) Result() (map[string]struct{}, error)

+ func (cmd *StringStructMapCmd) String() string

+ func (cmd *StringStructMapCmd) Val() map[string]struct{}

v6.7.3

Nov 1, 2017

v6.7.2

Oct 12, 2017

Changes in this version

type Cmdable

+ Publish func(channel string, message interface{}) *IntCmd

v6.7.1

Sep 29, 2017

Changes in this version

type BoolCmd

+ func (cmd *BoolCmd) Args() []interface{}

type BoolSliceCmd

+ func (cmd *BoolSliceCmd) Args() []interface{}

type ClusterSlotsCmd

+ func (cmd *ClusterSlotsCmd) Args() []interface{}

type Cmd

+ func (cmd *Cmd) Args() []interface{}

type Cmdable

+ TxPipeline func() Pipeliner

+ TxPipelined func(fn func(Pipeliner) error) ([]Cmder, error)

type Cmder

+ Args func() []interface{}

type CommandsInfoCmd

+ func (cmd *CommandsInfoCmd) Args() []interface{}

type DurationCmd

+ func (cmd *DurationCmd) Args() []interface{}

type FloatCmd

+ func (cmd *FloatCmd) Args() []interface{}

type GeoLocationCmd

+ func (cmd *GeoLocationCmd) Args() []interface{}

type GeoPosCmd

+ func (cmd *GeoPosCmd) Args() []interface{}

type IntCmd

+ func (cmd *IntCmd) Args() []interface{}

type Pipeline

+ func (c *Pipeline) TxPipeline() Pipeliner

+ func (c *Pipeline) TxPipelined(fn func(Pipeliner) error) ([]Cmder, error)

type Ring

+ func (c *Ring) TxPipeline() Pipeliner

+ func (c *Ring) TxPipelined(fn func(Pipeliner) error) ([]Cmder, error)

type ScanCmd

+ func (cmd *ScanCmd) Args() []interface{}

type SliceCmd

+ func (cmd *SliceCmd) Args() []interface{}

type StatusCmd

+ func (cmd *StatusCmd) Args() []interface{}

type StringCmd

+ func (cmd *StringCmd) Args() []interface{}

type StringIntMapCmd

+ func (cmd *StringIntMapCmd) Args() []interface{}

type StringSliceCmd

+ func (cmd *StringSliceCmd) Args() []interface{}

type StringStringMapCmd

+ func (cmd *StringStringMapCmd) Args() []interface{}

type TimeCmd

+ func (cmd *TimeCmd) Args() []interface{}

type Tx

+ func (c *Tx) TxPipeline() Pipeliner

+ func (c *Tx) TxPipelined(fn func(Pipeliner) error) ([]Cmder, error)

type ZSliceCmd

+ func (cmd *ZSliceCmd) Args() []interface{}

v6.7.0

Sep 22, 2017

v6.6.1

Sep 11, 2017

v6.6.0

Sep 1, 2017

Changes in this version

type RingOptions

+ MaxRetryBackoff time.Duration

+ MinRetryBackoff time.Duration

v6.5.7

Aug 15, 2017

Changes in this version

type Client

+ func (c *Client) DBSize() *IntCmd

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

type ClusterClient

+ func (c *ClusterClient) DBSize() *IntCmd

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

type Cmdable

+ DBSize func() *IntCmd

+ ZLexCount func(key, min, max string) *IntCmd

type Ring

+ func (c *Ring) DBSize() *IntCmd

+ func (c *Ring) ZLexCount(key, min, max string) *IntCmd

v6.5.6

Aug 4, 2017

v6.5.5

Aug 1, 2017

v6.5.4

Jul 19, 2017

Changes in this version

type Client

+ func (c *Client) GeoRadiusByMemberRO(key, member string, query *GeoRadiusQuery) *GeoLocationCmd

+ func (c *Client) GeoRadiusRO(key string, longitude, latitude float64, query *GeoRadiusQuery) *GeoLocationCmd

type ClusterClient

+ func (c *ClusterClient) GeoRadiusByMemberRO(key, member string, query *GeoRadiusQuery) *GeoLocationCmd

+ func (c *ClusterClient) GeoRadiusRO(key string, longitude, latitude float64, query *GeoRadiusQuery) *GeoLocationCmd

type Cmdable

+ GeoRadiusByMemberRO func(key, member string, query *GeoRadiusQuery) *GeoLocationCmd

+ GeoRadiusRO func(key string, longitude, latitude float64, query *GeoRadiusQuery) *GeoLocationCmd

type GeoRadiusQuery

+ Store string

+ StoreDist string

type Ring

+ func (c *Ring) GeoRadiusByMemberRO(key, member string, query *GeoRadiusQuery) *GeoLocationCmd

+ func (c *Ring) GeoRadiusRO(key string, longitude, latitude float64, query *GeoRadiusQuery) *GeoLocationCmd

v6.5.3

Jul 11, 2017

Changes in this version

type ClusterClient

+ func (c *ClusterClient) ForEachSlave(fn func(client *Client) error) error

+ func (c *ClusterClient) PSubscribe(channels ...string) *PubSub

+ func (c *ClusterClient) Subscribe(channels ...string) *PubSub

type ClusterOptions

+ MaxRetryBackoff time.Duration

+ MinRetryBackoff time.Duration

type Options

+ MinRetryBackoff time.Duration

v6.5.2

Jul 1, 2017

v6.5.1

Jun 29, 2017

v6.5.0

Jun 17, 2017

Changes in this version

type Client

+ func (c *Client) FlushAllAsync() *StatusCmd

+ func (c *Client) FlushDB() *StatusCmd

+ func (c *Client) FlushDBAsync() *StatusCmd

type ClusterClient

+ func (c *ClusterClient) FlushAllAsync() *StatusCmd

+ func (c *ClusterClient) FlushDB() *StatusCmd

+ func (c *ClusterClient) FlushDBAsync() *StatusCmd

type Cmdable

+ FlushAllAsync func() *StatusCmd

+ FlushDB func() *StatusCmd

+ FlushDBAsync func() *StatusCmd

type Ring

+ func (c *Ring) FlushAllAsync() *StatusCmd

+ func (c *Ring) FlushDB() *StatusCmd

+ func (c *Ring) FlushDBAsync() *StatusCmd

v6.4.2

Jun 17, 2017

v6.4.1

May 30, 2017

v6.4.0

May 26, 2017

Changes in this version

type Client

+ func (c *Client) ClientGetName() *StringCmd

type ClusterClient

+ func (c *ClusterClient) ClientGetName() *StringCmd

type ClusterOptions

+ OnConnect func(*Conn) error

type Cmdable

+ ClientGetName func() *StringCmd

+ type Conn struct

+ func (c *Conn) Auth(password string) *StatusCmd

+ func (c *Conn) ClientSetName(name string) *BoolCmd

+ func (c *Conn) Close() error

+ func (c *Conn) Pipeline() Pipeliner

+ func (c *Conn) Pipelined(fn func(Pipeliner) error) ([]Cmder, error)

+ func (c *Conn) Process(cmd Cmder) error

+ func (c *Conn) ReadOnly() *StatusCmd

+ func (c *Conn) ReadWrite() *StatusCmd

+ func (c *Conn) Select(index int) *StatusCmd

+ func (c *Conn) String() string

+ func (c *Conn) TxPipeline() Pipeliner

+ func (c *Conn) TxPipelined(fn func(Pipeliner) error) ([]Cmder, error)

+ func (c *Conn) WrapProcess(fn func(oldProcess func(cmd Cmder) error) func(cmd Cmder) error)

type FailoverOptions

+ OnConnect func(*Conn) error

type Options

+ MaxRetryBackoff time.Duration

+ OnConnect func(*Conn) error

type Ring

+ func (c *Ring) ClientGetName() *StringCmd

type RingOptions

+ OnConnect func(*Conn) error

v6.3.3

May 24, 2017

Changes in this version

type Script

+ func (s *Script) Hash() string

v6.3.2

May 9, 2017

Changes in this version

type BoolCmd

+ func (cmd *BoolCmd) Name() string

type BoolSliceCmd

+ func (cmd *BoolSliceCmd) Name() string

type ClusterSlotsCmd

+ func (cmd *ClusterSlotsCmd) Name() string

type Cmd

+ func (cmd *Cmd) Name() string

type Cmder

+ Name func() string

type CommandsInfoCmd

+ func (cmd *CommandsInfoCmd) Name() string

type DurationCmd

+ func (cmd *DurationCmd) Name() string

type FloatCmd

+ func (cmd *FloatCmd) Name() string

type GeoLocationCmd

+ func (cmd *GeoLocationCmd) Name() string

type GeoPosCmd

+ func (cmd *GeoPosCmd) Name() string

type IntCmd

+ func (cmd *IntCmd) Name() string

type ScanCmd

+ func (cmd *ScanCmd) Name() string

type SliceCmd

+ func (cmd *SliceCmd) Name() string

type StatusCmd

+ func (cmd *StatusCmd) Name() string

type StringCmd

+ func (cmd *StringCmd) Name() string

type StringIntMapCmd

+ func (cmd *StringIntMapCmd) Name() string

type StringSliceCmd

+ func (cmd *StringSliceCmd) Name() string

type StringStringMapCmd

+ func (cmd *StringStringMapCmd) Name() string

type TimeCmd

+ func (cmd *TimeCmd) Name() string

type ZSliceCmd

+ func (cmd *ZSliceCmd) Name() string

v6.3.1

May 3, 2017

v6.3.0

May 3, 2017

Changes in this version

type Pipeline

+ func (c *Pipeline) Pipeline() Pipeliner

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

+ type Pipeliner interface

+ Close func() error

+ Discard func() error

+ Exec func() ([]Cmder, error)

+ Process func(cmd Cmder) error

+ type StatefulCmdable interface

+ Auth func(password string) *StatusCmd

+ ClientGetName func() *StringCmd

+ ClientSetName func(name string) *BoolCmd

+ ReadOnly func() *StatusCmd

+ ReadWrite func() *StatusCmd

+ Select func(index int) *StatusCmd

v6.2.5

Apr 24, 2017

v6.2.4

Apr 22, 2017

v6.2.3

Apr 18, 2017

v6.2.2

Apr 17, 2017

v6.1.3

Apr 13, 2017

v6.1.2

Apr 12, 2017

v6.1.1

Apr 12, 2017

Changes in this version

type Ring

+ func (c *Ring) PSubscribe(channels ...string) *PubSub

+ func (c *Ring) Subscribe(channels ...string) *PubSub

v6.1.0

Apr 11, 2017

Changes in this version

type PubSub

+ func (c *PubSub) Channel() <-chan *Message

v6.0.0

Mar 20, 2017

Changes in this version

+ const Nil

+ const TxFailedErr

+ func SetLogger(logger *log.Logger)

+ type BitCount struct

+ End int64

+ Start int64

+ type BoolCmd struct

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

+ func NewBoolResult(val bool, err error) *BoolCmd

+ func (cmd *BoolCmd) Err() error

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

+ func (cmd *BoolCmd) String() string

+ func (cmd *BoolCmd) Val() bool

+ type BoolSliceCmd struct

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

+ func NewBoolSliceResult(val []bool, err error) *BoolSliceCmd

+ func (cmd *BoolSliceCmd) Err() error

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

+ func (cmd *BoolSliceCmd) String() string

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

+ type Client struct

+ func NewClient(opt *Options) *Client

+ func NewFailoverClient(failoverOpt *FailoverOptions) *Client

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

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

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

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

+ func (c *Client) BgRewriteAOF() *StatusCmd

+ func (c *Client) BgSave() *StatusCmd

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

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

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

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

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

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

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

+ func (c *Client) ClientList() *StringCmd

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

+ func (c *Client) Close() error

+ func (c *Client) ClusterAddSlots(slots ...int) *StatusCmd

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

+ func (c *Client) ClusterCountFailureReports(nodeID string) *IntCmd

+ func (c *Client) ClusterCountKeysInSlot(slot int) *IntCmd

+ func (c *Client) ClusterDelSlots(slots ...int) *StatusCmd

+ func (c *Client) ClusterDelSlotsRange(min, max int) *StatusCmd

+ func (c *Client) ClusterFailover() *StatusCmd

+ func (c *Client) ClusterForget(nodeID string) *StatusCmd

+ func (c *Client) ClusterInfo() *StringCmd

+ func (c *Client) ClusterKeySlot(key string) *IntCmd

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

+ func (c *Client) ClusterNodes() *StringCmd

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

+ func (c *Client) ClusterResetHard() *StatusCmd

+ func (c *Client) ClusterResetSoft() *StatusCmd

+ func (c *Client) ClusterSaveConfig() *StatusCmd

+ func (c *Client) ClusterSlaves(nodeID string) *StringSliceCmd

+ func (c *Client) ClusterSlots() *ClusterSlotsCmd

+ func (c *Client) Command() *CommandsInfoCmd

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

+ func (c *Client) ConfigResetStat() *StatusCmd

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

+ func (c *Client) Context() context.Context

+ func (c *Client) DbSize() *IntCmd

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

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

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

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

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

+ func (c *Client) Echo(message interface{}) *StringCmd

+ func (c *Client) Eval(script string, keys []string, args ...interface{}) *Cmd

+ func (c *Client) EvalSha(sha1 string, keys []string, args ...interface{}) *Cmd

+ func (c *Client) Exists(keys ...string) *IntCmd

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

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

+ func (c *Client) FlushAll() *StatusCmd

+ func (c *Client) FlushDb() *StatusCmd

+ func (c *Client) GeoAdd(key string, geoLocation ...*GeoLocation) *IntCmd

+ func (c *Client) GeoDist(key string, member1, member2, unit string) *FloatCmd

+ func (c *Client) GeoHash(key string, members ...string) *StringSliceCmd

+ func (c *Client) GeoPos(key string, members ...string) *GeoPosCmd

+ func (c *Client) GeoRadius(key string, longitude, latitude float64, query *GeoRadiusQuery) *GeoLocationCmd

+ func (c *Client) GeoRadiusByMember(key, member string, query *GeoRadiusQuery) *GeoLocationCmd

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

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

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

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

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

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

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

+ func (c *Client) HGetAll(key string) *StringStringMapCmd

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

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

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

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

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

+ func (c *Client) HMSet(key string, fields map[string]interface{}) *StatusCmd

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

+ func (c *Client) HSet(key, field string, value interface{}) *BoolCmd

+ func (c *Client) HSetNX(key, field string, value interface{}) *BoolCmd

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

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

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

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

+ func (c *Client) Info(section ...string) *StringCmd

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

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

+ func (c *Client) LInsert(key, op string, pivot, value interface{}) *IntCmd

+ func (c *Client) LInsertAfter(key string, pivot, value interface{}) *IntCmd

+ func (c *Client) LInsertBefore(key string, pivot, value interface{}) *IntCmd

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

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

+ func (c *Client) LPush(key string, values ...interface{}) *IntCmd

+ func (c *Client) LPushX(key string, value interface{}) *IntCmd

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

+ func (c *Client) LRem(key string, count int64, value interface{}) *IntCmd

+ func (c *Client) LSet(key string, index int64, value interface{}) *StatusCmd

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

+ func (c *Client) LastSave() *IntCmd

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

+ func (c *Client) MSet(pairs ...interface{}) *StatusCmd

+ func (c *Client) MSetNX(pairs ...interface{}) *BoolCmd

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

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

+ func (c *Client) ObjectEncoding(key string) *StringCmd

+ func (c *Client) ObjectIdleTime(key string) *DurationCmd

+ func (c *Client) ObjectRefCount(key string) *IntCmd

+ func (c *Client) Options() *Options

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

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

+ func (c *Client) PFAdd(key string, els ...interface{}) *IntCmd

+ func (c *Client) PFCount(keys ...string) *IntCmd

+ func (c *Client) PFMerge(dest string, keys ...string) *StatusCmd

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

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

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

+ func (c *Client) Ping() *StatusCmd

+ func (c *Client) Pipeline() *Pipeline

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

+ func (c *Client) PoolStats() *PoolStats

+ func (c *Client) Process(cmd Cmder) error

+ func (c *Client) PubSubChannels(pattern string) *StringSliceCmd

+ func (c *Client) PubSubNumPat() *IntCmd

+ func (c *Client) PubSubNumSub(channels ...string) *StringIntMapCmd

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

+ func (c *Client) Quit() *StatusCmd

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

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

+ func (c *Client) RPush(key string, values ...interface{}) *IntCmd

+ func (c *Client) RPushX(key string, value interface{}) *IntCmd

+ func (c *Client) RandomKey() *StringCmd

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

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

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

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

+ func (c *Client) SAdd(key string, members ...interface{}) *IntCmd

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

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

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

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

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

+ func (c *Client) SIsMember(key string, member interface{}) *BoolCmd

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

+ func (c *Client) SMove(source, destination string, member interface{}) *BoolCmd

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

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

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

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

+ func (c *Client) SRem(key string, members ...interface{}) *IntCmd

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

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

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

+ func (c *Client) Save() *StatusCmd

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

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

+ func (c *Client) ScriptFlush() *StatusCmd

+ func (c *Client) ScriptKill() *StatusCmd

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

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

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

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

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

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

+ func (c *Client) Shutdown() *StatusCmd

+ func (c *Client) ShutdownNoSave() *StatusCmd

+ func (c *Client) ShutdownSave() *StatusCmd

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

+ func (c *Client) SlowLog()

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

+ func (c *Client) SortInterfaces(key string, sort Sort) *SliceCmd

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

+ func (c *Client) String() string

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

+ func (c *Client) Sync()

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

+ func (c *Client) Time() *TimeCmd

+ func (c *Client) TxPipeline() *Pipeline

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

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

+ func (c *Client) Unlink(keys ...string) *IntCmd

+ func (c *Client) Wait(numSlaves int, timeout time.Duration) *IntCmd

+ func (c *Client) Watch(fn func(*Tx) error, keys ...string) error

+ func (c *Client) WithContext(ctx context.Context) *Client

+ func (c *Client) WrapProcess(fn func(oldProcess func(cmd Cmder) error) func(cmd Cmder) error)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (c *Client) ZRem(key string, members ...interface{}) *IntCmd

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

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

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

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

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

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

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

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

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

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

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

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

+ type ClusterClient struct

+ func NewClusterClient(opt *ClusterOptions) *ClusterClient

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

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

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

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

+ func (c *ClusterClient) BgRewriteAOF() *StatusCmd

+ func (c *ClusterClient) BgSave() *StatusCmd

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

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

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

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

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

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

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

+ func (c *ClusterClient) ClientList() *StringCmd

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

+ func (c *ClusterClient) Close() error

+ func (c *ClusterClient) ClusterAddSlots(slots ...int) *StatusCmd

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

+ func (c *ClusterClient) ClusterCountFailureReports(nodeID string) *IntCmd

+ func (c *ClusterClient) ClusterCountKeysInSlot(slot int) *IntCmd

+ func (c *ClusterClient) ClusterDelSlots(slots ...int) *StatusCmd

+ func (c *ClusterClient) ClusterDelSlotsRange(min, max int) *StatusCmd

+ func (c *ClusterClient) ClusterFailover() *StatusCmd

+ func (c *ClusterClient) ClusterForget(nodeID string) *StatusCmd

+ func (c *ClusterClient) ClusterInfo() *StringCmd

+ func (c *ClusterClient) ClusterKeySlot(key string) *IntCmd

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

+ func (c *ClusterClient) ClusterNodes() *StringCmd

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

+ func (c *ClusterClient) ClusterResetHard() *StatusCmd

+ func (c *ClusterClient) ClusterResetSoft() *StatusCmd

+ func (c *ClusterClient) ClusterSaveConfig() *StatusCmd

+ func (c *ClusterClient) ClusterSlaves(nodeID string) *StringSliceCmd

+ func (c *ClusterClient) ClusterSlots() *ClusterSlotsCmd

+ func (c *ClusterClient) Command() *CommandsInfoCmd

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

+ func (c *ClusterClient) ConfigResetStat() *StatusCmd

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

+ func (c *ClusterClient) DbSize() *IntCmd

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

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

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

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

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

+ func (c *ClusterClient) Echo(message interface{}) *StringCmd

+ func (c *ClusterClient) Eval(script string, keys []string, args ...interface{}) *Cmd

+ func (c *ClusterClient) EvalSha(sha1 string, keys []string, args ...interface{}) *Cmd

+ func (c *ClusterClient) Exists(keys ...string) *IntCmd

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

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

+ func (c *ClusterClient) FlushAll() *StatusCmd

+ func (c *ClusterClient) FlushDb() *StatusCmd

+ func (c *ClusterClient) ForEachMaster(fn func(client *Client) error) error

+ func (c *ClusterClient) ForEachNode(fn func(client *Client) error) error

+ func (c *ClusterClient) GeoAdd(key string, geoLocation ...*GeoLocation) *IntCmd

+ func (c *ClusterClient) GeoDist(key string, member1, member2, unit string) *FloatCmd

+ func (c *ClusterClient) GeoHash(key string, members ...string) *StringSliceCmd

+ func (c *ClusterClient) GeoPos(key string, members ...string) *GeoPosCmd

+ func (c *ClusterClient) GeoRadius(key string, longitude, latitude float64, query *GeoRadiusQuery) *GeoLocationCmd

+ func (c *ClusterClient) GeoRadiusByMember(key, member string, query *GeoRadiusQuery) *GeoLocationCmd

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

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

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

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

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

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

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

+ func (c *ClusterClient) HGetAll(key string) *StringStringMapCmd

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

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

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

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

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

+ func (c *ClusterClient) HMSet(key string, fields map[string]interface{}) *StatusCmd

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

+ func (c *ClusterClient) HSet(key, field string, value interface{}) *BoolCmd

+ func (c *ClusterClient) HSetNX(key, field string, value interface{}) *BoolCmd

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

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

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

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

+ func (c *ClusterClient) Info(section ...string) *StringCmd

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

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

+ func (c *ClusterClient) LInsert(key, op string, pivot, value interface{}) *IntCmd

+ func (c *ClusterClient) LInsertAfter(key string, pivot, value interface{}) *IntCmd

+ func (c *ClusterClient) LInsertBefore(key string, pivot, value interface{}) *IntCmd

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

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

+ func (c *ClusterClient) LPush(key string, values ...interface{}) *IntCmd

+ func (c *ClusterClient) LPushX(key string, value interface{}) *IntCmd

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

+ func (c *ClusterClient) LRem(key string, count int64, value interface{}) *IntCmd

+ func (c *ClusterClient) LSet(key string, index int64, value interface{}) *StatusCmd

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

+ func (c *ClusterClient) LastSave() *IntCmd

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

+ func (c *ClusterClient) MSet(pairs ...interface{}) *StatusCmd

+ func (c *ClusterClient) MSetNX(pairs ...interface{}) *BoolCmd

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

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

+ func (c *ClusterClient) ObjectEncoding(key string) *StringCmd

+ func (c *ClusterClient) ObjectIdleTime(key string) *DurationCmd

+ func (c *ClusterClient) ObjectRefCount(key string) *IntCmd

+ func (c *ClusterClient) Options() *ClusterOptions

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

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

+ func (c *ClusterClient) PFAdd(key string, els ...interface{}) *IntCmd

+ func (c *ClusterClient) PFCount(keys ...string) *IntCmd

+ func (c *ClusterClient) PFMerge(dest string, keys ...string) *StatusCmd

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

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

+ func (c *ClusterClient) Ping() *StatusCmd

+ func (c *ClusterClient) Pipeline() *Pipeline

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

+ func (c *ClusterClient) PoolStats() *PoolStats

+ func (c *ClusterClient) Process(cmd Cmder) error

+ func (c *ClusterClient) PubSubChannels(pattern string) *StringSliceCmd

+ func (c *ClusterClient) PubSubNumPat() *IntCmd

+ func (c *ClusterClient) PubSubNumSub(channels ...string) *StringIntMapCmd

+ func (c *ClusterClient) Publish(channel, message string) *IntCmd

+ func (c *ClusterClient) Quit() *StatusCmd

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

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

+ func (c *ClusterClient) RPush(key string, values ...interface{}) *IntCmd

+ func (c *ClusterClient) RPushX(key string, value interface{}) *IntCmd

+ func (c *ClusterClient) RandomKey() *StringCmd

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

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

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

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

+ func (c *ClusterClient) SAdd(key string, members ...interface{}) *IntCmd

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

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

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

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

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

+ func (c *ClusterClient) SIsMember(key string, member interface{}) *BoolCmd

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

+ func (c *ClusterClient) SMove(source, destination string, member interface{}) *BoolCmd

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

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

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

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

+ func (c *ClusterClient) SRem(key string, members ...interface{}) *IntCmd

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

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

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

+ func (c *ClusterClient) Save() *StatusCmd

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

+ func (c *ClusterClient) ScriptExists(scripts ...string) *BoolSliceCmd

+ func (c *ClusterClient) ScriptFlush() *StatusCmd

+ func (c *ClusterClient) ScriptKill() *StatusCmd

+ func (c *ClusterClient) ScriptLoad(script string) *StringCmd

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

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

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

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

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

+ func (c *ClusterClient) Shutdown() *StatusCmd

+ func (c *ClusterClient) ShutdownNoSave() *StatusCmd

+ func (c *ClusterClient) ShutdownSave() *StatusCmd

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

+ func (c *ClusterClient) SlowLog()

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

+ func (c *ClusterClient) SortInterfaces(key string, sort Sort) *SliceCmd

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

+ func (c *ClusterClient) Sync()

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

+ func (c *ClusterClient) Time() *TimeCmd

+ func (c *ClusterClient) TxPipeline() *Pipeline

+ func (c *ClusterClient) TxPipelined(fn func(*Pipeline) error) ([]Cmder, error)

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

+ func (c *ClusterClient) Unlink(keys ...string) *IntCmd

+ func (c *ClusterClient) Wait(numSlaves int, timeout time.Duration) *IntCmd

+ func (c *ClusterClient) Watch(fn func(*Tx) error, keys ...string) error

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (c *ClusterClient) ZRem(key string, members ...interface{}) *IntCmd

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

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

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

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

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

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

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

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

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

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

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

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

+ type ClusterNode struct

+ Addr string

+ Id string

+ type ClusterOptions struct

+ Addrs []string

+ DialTimeout time.Duration

+ IdleCheckFrequency time.Duration

+ IdleTimeout time.Duration

+ MaxRedirects int

+ MaxRetries int

+ Password string

+ PoolSize int

+ PoolTimeout time.Duration

+ ReadOnly bool

+ ReadTimeout time.Duration

+ RouteByLatency bool

+ WriteTimeout time.Duration

+ type ClusterSlot struct

+ End int

+ Nodes []ClusterNode

+ Start int

+ type ClusterSlotsCmd struct

+ func NewClusterSlotsCmd(args ...interface{}) *ClusterSlotsCmd

+ func NewClusterSlotsCmdResult(val []ClusterSlot, err error) *ClusterSlotsCmd

+ func (cmd *ClusterSlotsCmd) Err() error

+ func (cmd *ClusterSlotsCmd) Result() ([]ClusterSlot, error)

+ func (cmd *ClusterSlotsCmd) String() string

+ func (cmd *ClusterSlotsCmd) Val() []ClusterSlot

+ type Cmd struct

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

+ func NewCmdResult(val interface{}, err error) *Cmd

+ func (cmd *Cmd) Err() error

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

+ func (cmd *Cmd) String() string

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

+ type Cmdable interface

+ Append func(key, value string) *IntCmd

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

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

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

+ BgRewriteAOF func() *StatusCmd

+ BgSave func() *StatusCmd

+ BitCount func(key string, bitCount *BitCount) *IntCmd

+ BitOpAnd func(destKey string, keys ...string) *IntCmd

+ BitOpNot func(destKey string, key string) *IntCmd

+ BitOpOr func(destKey string, keys ...string) *IntCmd

+ BitOpXor func(destKey string, keys ...string) *IntCmd

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

+ ClientKill func(ipPort string) *StatusCmd

+ ClientList func() *StringCmd

+ ClientPause func(dur time.Duration) *BoolCmd

+ ClusterAddSlots func(slots ...int) *StatusCmd

+ ClusterAddSlotsRange func(min, max int) *StatusCmd

+ ClusterCountFailureReports func(nodeID string) *IntCmd

+ ClusterCountKeysInSlot func(slot int) *IntCmd

+ ClusterDelSlots func(slots ...int) *StatusCmd

+ ClusterDelSlotsRange func(min, max int) *StatusCmd

+ ClusterFailover func() *StatusCmd

+ ClusterForget func(nodeID string) *StatusCmd

+ ClusterInfo func() *StringCmd

+ ClusterKeySlot func(key string) *IntCmd

+ ClusterMeet func(host, port string) *StatusCmd

+ ClusterNodes func() *StringCmd

+ ClusterReplicate func(nodeID string) *StatusCmd

+ ClusterResetHard func() *StatusCmd

+ ClusterResetSoft func() *StatusCmd

+ ClusterSaveConfig func() *StatusCmd

+ ClusterSlaves func(nodeID string) *StringSliceCmd

+ ClusterSlots func() *ClusterSlotsCmd

+ Command func() *CommandsInfoCmd

+ ConfigGet func(parameter string) *SliceCmd

+ ConfigResetStat func() *StatusCmd

+ ConfigSet func(parameter, value string) *StatusCmd

+ DbSize func() *IntCmd

+ DebugObject func(key string) *StringCmd

+ Decr func(key string) *IntCmd

+ DecrBy func(key string, decrement int64) *IntCmd

+ Del func(keys ...string) *IntCmd

+ Dump func(key string) *StringCmd

+ Echo func(message interface{}) *StringCmd

+ Eval func(script string, keys []string, args ...interface{}) *Cmd

+ EvalSha func(sha1 string, keys []string, args ...interface{}) *Cmd

+ Exists func(keys ...string) *IntCmd

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

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

+ FlushAll func() *StatusCmd

+ FlushDb func() *StatusCmd

+ GeoAdd func(key string, geoLocation ...*GeoLocation) *IntCmd

+ GeoDist func(key string, member1, member2, unit string) *FloatCmd

+ GeoHash func(key string, members ...string) *StringSliceCmd

+ GeoPos func(key string, members ...string) *GeoPosCmd

+ GeoRadius func(key string, longitude, latitude float64, query *GeoRadiusQuery) *GeoLocationCmd

+ GeoRadiusByMember func(key, member string, query *GeoRadiusQuery) *GeoLocationCmd

+ Get func(key string) *StringCmd

+ GetBit func(key string, offset int64) *IntCmd

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

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

+ HDel func(key string, fields ...string) *IntCmd

+ HExists func(key, field string) *BoolCmd

+ HGet func(key, field string) *StringCmd

+ HGetAll func(key string) *StringStringMapCmd

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

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

+ HKeys func(key string) *StringSliceCmd

+ HLen func(key string) *IntCmd

+ HMGet func(key string, fields ...string) *SliceCmd

+ HMSet func(key string, fields map[string]interface{}) *StatusCmd

+ HScan func(key string, cursor uint64, match string, count int64) *ScanCmd

+ HSet func(key, field string, value interface{}) *BoolCmd

+ HSetNX func(key, field string, value interface{}) *BoolCmd

+ HVals func(key string) *StringSliceCmd

+ Incr func(key string) *IntCmd

+ IncrBy func(key string, value int64) *IntCmd

+ IncrByFloat func(key string, value float64) *FloatCmd

+ Info func(section ...string) *StringCmd

+ Keys func(pattern string) *StringSliceCmd

+ LIndex func(key string, index int64) *StringCmd

+ LInsert func(key, op string, pivot, value interface{}) *IntCmd

+ LInsertAfter func(key string, pivot, value interface{}) *IntCmd

+ LInsertBefore func(key string, pivot, value interface{}) *IntCmd

+ LLen func(key string) *IntCmd

+ LPop func(key string) *StringCmd

+ LPush func(key string, values ...interface{}) *IntCmd

+ LPushX func(key string, value interface{}) *IntCmd

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

+ LRem func(key string, count int64, value interface{}) *IntCmd

+ LSet func(key string, index int64, value interface{}) *StatusCmd

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

+ LastSave func() *IntCmd

+ MGet func(keys ...string) *SliceCmd

+ MSet func(pairs ...interface{}) *StatusCmd

+ MSetNX func(pairs ...interface{}) *BoolCmd

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

+ Move func(key string, db int64) *BoolCmd

+ ObjectEncoding func(key string) *StringCmd

+ ObjectIdleTime func(key string) *DurationCmd

+ ObjectRefCount func(key string) *IntCmd

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

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

+ PFAdd func(key string, els ...interface{}) *IntCmd

+ PFCount func(keys ...string) *IntCmd

+ PFMerge func(dest string, keys ...string) *StatusCmd

+ PTTL func(key string) *DurationCmd

+ Persist func(key string) *BoolCmd

+ Ping func() *StatusCmd

+ Pipeline func() *Pipeline

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

+ PubSubChannels func(pattern string) *StringSliceCmd

+ PubSubNumPat func() *IntCmd

+ PubSubNumSub func(channels ...string) *StringIntMapCmd

+ Quit func() *StatusCmd

+ RPop func(key string) *StringCmd

+ RPopLPush func(source, destination string) *StringCmd

+ RPush func(key string, values ...interface{}) *IntCmd

+ RPushX func(key string, value interface{}) *IntCmd

+ RandomKey func() *StringCmd

+ Rename func(key, newkey string) *StatusCmd

+ RenameNX func(key, newkey string) *BoolCmd

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

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

+ SAdd func(key string, members ...interface{}) *IntCmd

+ SCard func(key string) *IntCmd

+ SDiff func(keys ...string) *StringSliceCmd

+ SDiffStore func(destination string, keys ...string) *IntCmd

+ SInter func(keys ...string) *StringSliceCmd

+ SInterStore func(destination string, keys ...string) *IntCmd

+ SIsMember func(key string, member interface{}) *BoolCmd

+ SMembers func(key string) *StringSliceCmd

+ SMove func(source, destination string, member interface{}) *BoolCmd

+ SPop func(key string) *StringCmd

+ SPopN func(key string, count int64) *StringSliceCmd

+ SRandMember func(key string) *StringCmd

+ SRandMemberN func(key string, count int64) *StringSliceCmd

+ SRem func(key string, members ...interface{}) *IntCmd

+ SScan func(key string, cursor uint64, match string, count int64) *ScanCmd

+ SUnion func(keys ...string) *StringSliceCmd

+ SUnionStore func(destination string, keys ...string) *IntCmd

+ Save func() *StatusCmd

+ Scan func(cursor uint64, match string, count int64) *ScanCmd

+ ScriptExists func(scripts ...string) *BoolSliceCmd

+ ScriptFlush func() *StatusCmd

+ ScriptKill func() *StatusCmd

+ ScriptLoad func(script string) *StringCmd

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

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

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

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

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

+ Shutdown func() *StatusCmd

+ ShutdownNoSave func() *StatusCmd

+ ShutdownSave func() *StatusCmd

+ SlaveOf func(host, port string) *StatusCmd

+ Sort func(key string, sort Sort) *StringSliceCmd

+ SortInterfaces func(key string, sort Sort) *SliceCmd

+ StrLen func(key string) *IntCmd

+ TTL func(key string) *DurationCmd

+ Time func() *TimeCmd

+ Type func(key string) *StatusCmd

+ Unlink func(keys ...string) *IntCmd

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

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

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

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

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

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

+ ZCard func(key string) *IntCmd

+ ZCount func(key, min, max string) *IntCmd

+ ZIncr func(key string, member Z) *FloatCmd

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

+ ZIncrNX func(key string, member Z) *FloatCmd

+ ZIncrXX func(key string, member Z) *FloatCmd

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

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

+ ZRangeByLex func(key string, opt ZRangeBy) *StringSliceCmd

+ ZRangeByScore func(key string, opt ZRangeBy) *StringSliceCmd

+ ZRangeByScoreWithScores func(key string, opt ZRangeBy) *ZSliceCmd

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

+ ZRank func(key, member string) *IntCmd

+ ZRem func(key string, members ...interface{}) *IntCmd

+ ZRemRangeByLex func(key, min, max string) *IntCmd

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

+ ZRemRangeByScore func(key, min, max string) *IntCmd

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

+ ZRevRangeByLex func(key string, opt ZRangeBy) *StringSliceCmd

+ ZRevRangeByScore func(key string, opt ZRangeBy) *StringSliceCmd

+ ZRevRangeByScoreWithScores func(key string, opt ZRangeBy) *ZSliceCmd

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

+ ZRevRank func(key, member string) *IntCmd

+ ZScan func(key string, cursor uint64, match string, count int64) *ScanCmd

+ ZScore func(key, member string) *FloatCmd

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

+ type Cmder interface

+ Err func() error

+ type CommandInfo struct

+ Arity int8

+ FirstKeyPos int8

+ Flags []string

+ LastKeyPos int8

+ Name string

+ ReadOnly bool

+ StepCount int8

+ type CommandsInfoCmd struct

+ func NewCommandsInfoCmd(args ...interface{}) *CommandsInfoCmd

+ func NewCommandsInfoCmdResult(val map[string]*CommandInfo, err error) *CommandsInfoCmd

+ func (cmd *CommandsInfoCmd) Err() error

+ func (cmd *CommandsInfoCmd) Result() (map[string]*CommandInfo, error)

+ func (cmd *CommandsInfoCmd) String() string

+ func (cmd *CommandsInfoCmd) Val() map[string]*CommandInfo

+ type DurationCmd struct

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

+ func NewDurationResult(val time.Duration, err error) *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 struct

+ DB int

+ DialTimeout time.Duration

+ IdleCheckFrequency time.Duration

+ IdleTimeout time.Duration

+ MasterName string

+ MaxRetries int

+ Password string

+ PoolSize int

+ PoolTimeout time.Duration

+ ReadTimeout time.Duration

+ SentinelAddrs []string

+ WriteTimeout time.Duration

+ type FloatCmd struct

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

+ func NewFloatResult(val float64, err error) *FloatCmd

+ func (cmd *FloatCmd) Err() error

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

+ func (cmd *FloatCmd) String() string

+ func (cmd *FloatCmd) Val() float64

+ type GeoLocation struct

+ Dist float64

+ GeoHash int64

+ Latitude float64

+ Longitude float64

+ Name string

+ type GeoLocationCmd struct

+ func NewGeoLocationCmd(q *GeoRadiusQuery, args ...interface{}) *GeoLocationCmd

+ func NewGeoLocationCmdResult(val []GeoLocation, err error) *GeoLocationCmd

+ func (cmd *GeoLocationCmd) Err() error

+ func (cmd *GeoLocationCmd) Result() ([]GeoLocation, error)

+ func (cmd *GeoLocationCmd) String() string

+ func (cmd *GeoLocationCmd) Val() []GeoLocation

+ type GeoPos struct

+ Latitude float64

+ Longitude float64

+ type GeoPosCmd struct

+ func NewGeoPosCmd(args ...interface{}) *GeoPosCmd

+ func (cmd *GeoPosCmd) Err() error

+ func (cmd *GeoPosCmd) Result() ([]*GeoPos, error)

+ func (cmd *GeoPosCmd) String() string

+ func (cmd *GeoPosCmd) Val() []*GeoPos

+ type GeoRadiusQuery struct

+ Count int

+ Radius float64

+ Sort string

+ Unit string

+ WithCoord bool

+ WithDist bool

+ WithGeoHash bool

+ type IntCmd struct

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

+ func NewIntResult(val int64, err error) *IntCmd

+ func (cmd *IntCmd) Err() error

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

+ func (cmd *IntCmd) String() string

+ func (cmd *IntCmd) Val() int64

+ type Message struct

+ Channel string

+ Pattern string

+ Payload string

+ func (m *Message) String() string

+ type Options struct

+ Addr string

+ DB int

+ DialTimeout time.Duration

+ Dialer func() (net.Conn, error)

+ IdleCheckFrequency time.Duration

+ IdleTimeout time.Duration

+ MaxRetries int

+ Network string

+ Password string

+ PoolSize int

+ PoolTimeout time.Duration

+ ReadOnly bool

+ ReadTimeout time.Duration

+ TLSConfig *tls.Config

+ WriteTimeout time.Duration

+ func ParseURL(redisURL string) (*Options, error)

+ type Pipeline struct

+ func (c *Pipeline) Append(key, value string) *IntCmd

+ func (c *Pipeline) Auth(password string) *StatusCmd

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

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

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

+ func (c *Pipeline) BgRewriteAOF() *StatusCmd

+ func (c *Pipeline) BgSave() *StatusCmd

+ func (c *Pipeline) BitCount(key string, bitCount *BitCount) *IntCmd

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

+ func (c *Pipeline) BitOpNot(destKey string, key string) *IntCmd

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

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

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

+ func (c *Pipeline) ClientGetName() *StringCmd

+ func (c *Pipeline) ClientKill(ipPort string) *StatusCmd

+ func (c *Pipeline) ClientList() *StringCmd

+ func (c *Pipeline) ClientPause(dur time.Duration) *BoolCmd

+ func (c *Pipeline) ClientSetName(name string) *BoolCmd

+ func (c *Pipeline) Close() error

+ func (c *Pipeline) ClusterAddSlots(slots ...int) *StatusCmd

+ func (c *Pipeline) ClusterAddSlotsRange(min, max int) *StatusCmd

+ func (c *Pipeline) ClusterCountFailureReports(nodeID string) *IntCmd

+ func (c *Pipeline) ClusterCountKeysInSlot(slot int) *IntCmd

+ func (c *Pipeline) ClusterDelSlots(slots ...int) *StatusCmd

+ func (c *Pipeline) ClusterDelSlotsRange(min, max int) *StatusCmd

+ func (c *Pipeline) ClusterFailover() *StatusCmd

+ func (c *Pipeline) ClusterForget(nodeID string) *StatusCmd

+ func (c *Pipeline) ClusterInfo() *StringCmd

+ func (c *Pipeline) ClusterKeySlot(key string) *IntCmd

+ func (c *Pipeline) ClusterMeet(host, port string) *StatusCmd

+ func (c *Pipeline) ClusterNodes() *StringCmd

+ func (c *Pipeline) ClusterReplicate(nodeID string) *StatusCmd

+ func (c *Pipeline) ClusterResetHard() *StatusCmd

+ func (c *Pipeline) ClusterResetSoft() *StatusCmd

+ func (c *Pipeline) ClusterSaveConfig() *StatusCmd

+ func (c *Pipeline) ClusterSlaves(nodeID string) *StringSliceCmd

+ func (c *Pipeline) ClusterSlots() *ClusterSlotsCmd

+ func (c *Pipeline) Command() *CommandsInfoCmd

+ func (c *Pipeline) ConfigGet(parameter string) *SliceCmd

+ func (c *Pipeline) ConfigResetStat() *StatusCmd

+ func (c *Pipeline) ConfigSet(parameter, value string) *StatusCmd

+ func (c *Pipeline) DbSize() *IntCmd

+ func (c *Pipeline) DebugObject(key string) *StringCmd

+ func (c *Pipeline) Decr(key string) *IntCmd

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

+ func (c *Pipeline) Del(keys ...string) *IntCmd

+ func (c *Pipeline) Discard() error

+ func (c *Pipeline) Dump(key string) *StringCmd

+ func (c *Pipeline) Echo(message interface{}) *StringCmd

+ func (c *Pipeline) Eval(script string, keys []string, args ...interface{}) *Cmd

+ func (c *Pipeline) EvalSha(sha1 string, keys []string, args ...interface{}) *Cmd

+ func (c *Pipeline) Exec() ([]Cmder, error)

+ func (c *Pipeline) Exists(keys ...string) *IntCmd

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

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

+ func (c *Pipeline) FlushAll() *StatusCmd

+ func (c *Pipeline) FlushDb() *StatusCmd

+ func (c *Pipeline) GeoAdd(key string, geoLocation ...*GeoLocation) *IntCmd

+ func (c *Pipeline) GeoDist(key string, member1, member2, unit string) *FloatCmd

+ func (c *Pipeline) GeoHash(key string, members ...string) *StringSliceCmd

+ func (c *Pipeline) GeoPos(key string, members ...string) *GeoPosCmd

+ func (c *Pipeline) GeoRadius(key string, longitude, latitude float64, query *GeoRadiusQuery) *GeoLocationCmd

+ func (c *Pipeline) GeoRadiusByMember(key, member string, query *GeoRadiusQuery) *GeoLocationCmd

+ func (c *Pipeline) Get(key string) *StringCmd

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

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

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

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

+ func (c *Pipeline) HExists(key, field string) *BoolCmd

+ func (c *Pipeline) HGet(key, field string) *StringCmd

+ func (c *Pipeline) HGetAll(key string) *StringStringMapCmd

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

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

+ func (c *Pipeline) HKeys(key string) *StringSliceCmd

+ func (c *Pipeline) HLen(key string) *IntCmd

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

+ func (c *Pipeline) HMSet(key string, fields map[string]interface{}) *StatusCmd

+ func (c *Pipeline) HScan(key string, cursor uint64, match string, count int64) *ScanCmd

+ func (c *Pipeline) HSet(key, field string, value interface{}) *BoolCmd

+ func (c *Pipeline) HSetNX(key, field string, value interface{}) *BoolCmd

+ func (c *Pipeline) HVals(key string) *StringSliceCmd

+ func (c *Pipeline) Incr(key string) *IntCmd

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

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

+ func (c *Pipeline) Info(section ...string) *StringCmd

+ func (c *Pipeline) Keys(pattern string) *StringSliceCmd

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

+ func (c *Pipeline) LInsert(key, op string, pivot, value interface{}) *IntCmd

+ func (c *Pipeline) LInsertAfter(key string, pivot, value interface{}) *IntCmd

+ func (c *Pipeline) LInsertBefore(key string, pivot, value interface{}) *IntCmd

+ func (c *Pipeline) LLen(key string) *IntCmd

+ func (c *Pipeline) LPop(key string) *StringCmd

+ func (c *Pipeline) LPush(key string, values ...interface{}) *IntCmd

+ func (c *Pipeline) LPushX(key string, value interface{}) *IntCmd

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

+ func (c *Pipeline) LRem(key string, count int64, value interface{}) *IntCmd

+ func (c *Pipeline) LSet(key string, index int64, value interface{}) *StatusCmd

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

+ func (c *Pipeline) LastSave() *IntCmd

+ func (c *Pipeline) MGet(keys ...string) *SliceCmd

+ func (c *Pipeline) MSet(pairs ...interface{}) *StatusCmd

+ func (c *Pipeline) MSetNX(pairs ...interface{}) *BoolCmd

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

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

+ func (c *Pipeline) ObjectEncoding(key string) *StringCmd

+ func (c *Pipeline) ObjectIdleTime(key string) *DurationCmd

+ func (c *Pipeline) ObjectRefCount(key string) *IntCmd

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

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

+ func (c *Pipeline) PFAdd(key string, els ...interface{}) *IntCmd

+ func (c *Pipeline) PFCount(keys ...string) *IntCmd

+ func (c *Pipeline) PFMerge(dest string, keys ...string) *StatusCmd

+ func (c *Pipeline) PTTL(key string) *DurationCmd

+ func (c *Pipeline) Persist(key string) *BoolCmd

+ func (c *Pipeline) Ping() *StatusCmd

+ func (c *Pipeline) Process(cmd Cmder) error

+ func (c *Pipeline) PubSubChannels(pattern string) *StringSliceCmd

+ func (c *Pipeline) PubSubNumPat() *IntCmd

+ func (c *Pipeline) PubSubNumSub(channels ...string) *StringIntMapCmd

+ func (c *Pipeline) Publish(channel, message string) *IntCmd

+ func (c *Pipeline) Quit() *StatusCmd

+ func (c *Pipeline) RPop(key string) *StringCmd

+ func (c *Pipeline) RPopLPush(source, destination string) *StringCmd

+ func (c *Pipeline) RPush(key string, values ...interface{}) *IntCmd

+ func (c *Pipeline) RPushX(key string, value interface{}) *IntCmd

+ func (c *Pipeline) RandomKey() *StringCmd

+ func (c *Pipeline) ReadOnly() *StatusCmd

+ func (c *Pipeline) ReadWrite() *StatusCmd

+ func (c *Pipeline) Rename(key, newkey string) *StatusCmd

+ func (c *Pipeline) RenameNX(key, newkey string) *BoolCmd

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

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

+ func (c *Pipeline) SAdd(key string, members ...interface{}) *IntCmd

+ func (c *Pipeline) SCard(key string) *IntCmd

+ func (c *Pipeline) SDiff(keys ...string) *StringSliceCmd

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

+ func (c *Pipeline) SInter(keys ...string) *StringSliceCmd

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

+ func (c *Pipeline) SIsMember(key string, member interface{}) *BoolCmd

+ func (c *Pipeline) SMembers(key string) *StringSliceCmd

+ func (c *Pipeline) SMove(source, destination string, member interface{}) *BoolCmd

+ func (c *Pipeline) SPop(key string) *StringCmd

+ func (c *Pipeline) SPopN(key string, count int64) *StringSliceCmd

+ func (c *Pipeline) SRandMember(key string) *StringCmd

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

+ func (c *Pipeline) SRem(key string, members ...interface{}) *IntCmd

+ func (c *Pipeline) SScan(key string, cursor uint64, match string, count int64) *ScanCmd

+ func (c *Pipeline) SUnion(keys ...string) *StringSliceCmd

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

+ func (c *Pipeline) Save() *StatusCmd

+ func (c *Pipeline) Scan(cursor uint64, match string, count int64) *ScanCmd

+ func (c *Pipeline) ScriptExists(scripts ...string) *BoolSliceCmd

+ func (c *Pipeline) ScriptFlush() *StatusCmd

+ func (c *Pipeline) ScriptKill() *StatusCmd

+ func (c *Pipeline) ScriptLoad(script string) *StringCmd

+ func (c *Pipeline) Select(index int) *StatusCmd

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

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

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

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

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

+ func (c *Pipeline) Shutdown() *StatusCmd

+ func (c *Pipeline) ShutdownNoSave() *StatusCmd

+ func (c *Pipeline) ShutdownSave() *StatusCmd

+ func (c *Pipeline) SlaveOf(host, port string) *StatusCmd

+ func (c *Pipeline) SlowLog()

+ func (c *Pipeline) Sort(key string, sort Sort) *StringSliceCmd

+ func (c *Pipeline) SortInterfaces(key string, sort Sort) *SliceCmd

+ func (c *Pipeline) StrLen(key string) *IntCmd

+ func (c *Pipeline) Sync()

+ func (c *Pipeline) TTL(key string) *DurationCmd

+ func (c *Pipeline) Time() *TimeCmd

+ func (c *Pipeline) Type(key string) *StatusCmd

+ func (c *Pipeline) Unlink(keys ...string) *IntCmd

+ func (c *Pipeline) Wait(numSlaves int, timeout time.Duration) *IntCmd

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

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

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

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

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

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

+ func (c *Pipeline) ZCard(key string) *IntCmd

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

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

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

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

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

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

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

+ func (c *Pipeline) ZRangeByLex(key string, opt ZRangeBy) *StringSliceCmd

+ func (c *Pipeline) ZRangeByScore(key string, opt ZRangeBy) *StringSliceCmd

+ func (c *Pipeline) ZRangeByScoreWithScores(key string, opt ZRangeBy) *ZSliceCmd

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

+ func (c *Pipeline) ZRank(key, member string) *IntCmd

+ func (c *Pipeline) ZRem(key string, members ...interface{}) *IntCmd

+ func (c *Pipeline) ZRemRangeByLex(key, min, max string) *IntCmd

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

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

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

+ func (c *Pipeline) ZRevRangeByLex(key string, opt ZRangeBy) *StringSliceCmd

+ func (c *Pipeline) ZRevRangeByScore(key string, opt ZRangeBy) *StringSliceCmd

+ func (c *Pipeline) ZRevRangeByScoreWithScores(key string, opt ZRangeBy) *ZSliceCmd

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

+ func (c *Pipeline) ZRevRank(key, member string) *IntCmd

+ func (c *Pipeline) ZScan(key string, cursor uint64, match string, count int64) *ScanCmd

+ func (c *Pipeline) ZScore(key, member string) *FloatCmd

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

+ type Pong struct

+ Payload string

+ func (p *Pong) String() string

+ type PoolStats struct

+ FreeConns uint32

+ Hits uint32

+ Requests uint32

+ Timeouts uint32

+ TotalConns uint32

+ type PubSub struct

+ func (c *PubSub) Close() error

+ func (c *PubSub) PSubscribe(patterns ...string) error

+ func (c *PubSub) PUnsubscribe(patterns ...string) error

+ func (c *PubSub) Ping(payload ...string) error

+ func (c *PubSub) Receive() (interface{}, error)

+ func (c *PubSub) ReceiveMessage() (*Message, error)

+ func (c *PubSub) ReceiveTimeout(timeout time.Duration) (interface{}, error)

+ func (c *PubSub) Subscribe(channels ...string) error

+ func (c *PubSub) Unsubscribe(channels ...string) error

+ type Ring struct

+ func NewRing(opt *RingOptions) *Ring

+ func (c *Ring) Append(key, value string) *IntCmd

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

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

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

+ func (c *Ring) BgRewriteAOF() *StatusCmd

+ func (c *Ring) BgSave() *StatusCmd

+ func (c *Ring) BitCount(key string, bitCount *BitCount) *IntCmd

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

+ func (c *Ring) BitOpNot(destKey string, key string) *IntCmd

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

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

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

+ func (c *Ring) ClientKill(ipPort string) *StatusCmd

+ func (c *Ring) ClientList() *StringCmd

+ func (c *Ring) ClientPause(dur time.Duration) *BoolCmd

+ func (c *Ring) Close() error

+ func (c *Ring) ClusterAddSlots(slots ...int) *StatusCmd

+ func (c *Ring) ClusterAddSlotsRange(min, max int) *StatusCmd

+ func (c *Ring) ClusterCountFailureReports(nodeID string) *IntCmd

+ func (c *Ring) ClusterCountKeysInSlot(slot int) *IntCmd

+ func (c *Ring) ClusterDelSlots(slots ...int) *StatusCmd

+ func (c *Ring) ClusterDelSlotsRange(min, max int) *StatusCmd

+ func (c *Ring) ClusterFailover() *StatusCmd

+ func (c *Ring) ClusterForget(nodeID string) *StatusCmd

+ func (c *Ring) ClusterInfo() *StringCmd

+ func (c *Ring) ClusterKeySlot(key string) *IntCmd

+ func (c *Ring) ClusterMeet(host, port string) *StatusCmd

+ func (c *Ring) ClusterNodes() *StringCmd

+ func (c *Ring) ClusterReplicate(nodeID string) *StatusCmd

+ func (c *Ring) ClusterResetHard() *StatusCmd

+ func (c *Ring) ClusterResetSoft() *StatusCmd

+ func (c *Ring) ClusterSaveConfig() *StatusCmd

+ func (c *Ring) ClusterSlaves(nodeID string) *StringSliceCmd

+ func (c *Ring) ClusterSlots() *ClusterSlotsCmd

+ func (c *Ring) Command() *CommandsInfoCmd

+ func (c *Ring) ConfigGet(parameter string) *SliceCmd

+ func (c *Ring) ConfigResetStat() *StatusCmd

+ func (c *Ring) ConfigSet(parameter, value string) *StatusCmd

+ func (c *Ring) DbSize() *IntCmd

+ func (c *Ring) DebugObject(key string) *StringCmd

+ func (c *Ring) Decr(key string) *IntCmd

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

+ func (c *Ring) Del(keys ...string) *IntCmd

+ func (c *Ring) Dump(key string) *StringCmd

+ func (c *Ring) Echo(message interface{}) *StringCmd

+ func (c *Ring) Eval(script string, keys []string, args ...interface{}) *Cmd

+ func (c *Ring) EvalSha(sha1 string, keys []string, args ...interface{}) *Cmd

+ func (c *Ring) Exists(keys ...string) *IntCmd

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

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

+ func (c *Ring) FlushAll() *StatusCmd

+ func (c *Ring) FlushDb() *StatusCmd

+ func (c *Ring) ForEachShard(fn func(client *Client) error) error

+ func (c *Ring) GeoAdd(key string, geoLocation ...*GeoLocation) *IntCmd

+ func (c *Ring) GeoDist(key string, member1, member2, unit string) *FloatCmd

+ func (c *Ring) GeoHash(key string, members ...string) *StringSliceCmd

+ func (c *Ring) GeoPos(key string, members ...string) *GeoPosCmd

+ func (c *Ring) GeoRadius(key string, longitude, latitude float64, query *GeoRadiusQuery) *GeoLocationCmd

+ func (c *Ring) GeoRadiusByMember(key, member string, query *GeoRadiusQuery) *GeoLocationCmd

+ func (c *Ring) Get(key string) *StringCmd

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

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

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

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

+ func (c *Ring) HExists(key, field string) *BoolCmd

+ func (c *Ring) HGet(key, field string) *StringCmd

+ func (c *Ring) HGetAll(key string) *StringStringMapCmd

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

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

+ func (c *Ring) HKeys(key string) *StringSliceCmd

+ func (c *Ring) HLen(key string) *IntCmd

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

+ func (c *Ring) HMSet(key string, fields map[string]interface{}) *StatusCmd

+ func (c *Ring) HScan(key string, cursor uint64, match string, count int64) *ScanCmd

+ func (c *Ring) HSet(key, field string, value interface{}) *BoolCmd

+ func (c *Ring) HSetNX(key, field string, value interface{}) *BoolCmd

+ func (c *Ring) HVals(key string) *StringSliceCmd

+ func (c *Ring) Incr(key string) *IntCmd

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

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

+ func (c *Ring) Info(section ...string) *StringCmd

+ func (c *Ring) Keys(pattern string) *StringSliceCmd

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

+ func (c *Ring) LInsert(key, op string, pivot, value interface{}) *IntCmd

+ func (c *Ring) LInsertAfter(key string, pivot, value interface{}) *IntCmd

+ func (c *Ring) LInsertBefore(key string, pivot, value interface{}) *IntCmd

+ func (c *Ring) LLen(key string) *IntCmd

+ func (c *Ring) LPop(key string) *StringCmd

+ func (c *Ring) LPush(key string, values ...interface{}) *IntCmd

+ func (c *Ring) LPushX(key string, value interface{}) *IntCmd

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

+ func (c *Ring) LRem(key string, count int64, value interface{}) *IntCmd

+ func (c *Ring) LSet(key string, index int64, value interface{}) *StatusCmd

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

+ func (c *Ring) LastSave() *IntCmd

+ func (c *Ring) MGet(keys ...string) *SliceCmd

+ func (c *Ring) MSet(pairs ...interface{}) *StatusCmd

+ func (c *Ring) MSetNX(pairs ...interface{}) *BoolCmd

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

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

+ func (c *Ring) ObjectEncoding(key string) *StringCmd

+ func (c *Ring) ObjectIdleTime(key string) *DurationCmd

+ func (c *Ring) ObjectRefCount(key string) *IntCmd

+ func (c *Ring) Options() *RingOptions

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

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

+ func (c *Ring) PFAdd(key string, els ...interface{}) *IntCmd

+ func (c *Ring) PFCount(keys ...string) *IntCmd

+ func (c *Ring) PFMerge(dest string, keys ...string) *StatusCmd

+ func (c *Ring) PTTL(key string) *DurationCmd

+ func (c *Ring) Persist(key string) *BoolCmd

+ func (c *Ring) Ping() *StatusCmd

+ func (c *Ring) Pipeline() *Pipeline

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

+ func (c *Ring) PoolStats() *PoolStats

+ func (c *Ring) Process(cmd Cmder) error

+ func (c *Ring) PubSubChannels(pattern string) *StringSliceCmd

+ func (c *Ring) PubSubNumPat() *IntCmd

+ func (c *Ring) PubSubNumSub(channels ...string) *StringIntMapCmd

+ func (c *Ring) Publish(channel, message string) *IntCmd

+ func (c *Ring) Quit() *StatusCmd

+ func (c *Ring) RPop(key string) *StringCmd

+ func (c *Ring) RPopLPush(source, destination string) *StringCmd

+ func (c *Ring) RPush(key string, values ...interface{}) *IntCmd

+ func (c *Ring) RPushX(key string, value interface{}) *IntCmd

+ func (c *Ring) RandomKey() *StringCmd

+ func (c *Ring) Rename(key, newkey string) *StatusCmd

+ func (c *Ring) RenameNX(key, newkey string) *BoolCmd

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

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

+ func (c *Ring) SAdd(key string, members ...interface{}) *IntCmd

+ func (c *Ring) SCard(key string) *IntCmd

+ func (c *Ring) SDiff(keys ...string) *StringSliceCmd

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

+ func (c *Ring) SInter(keys ...string) *StringSliceCmd

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

+ func (c *Ring) SIsMember(key string, member interface{}) *BoolCmd

+ func (c *Ring) SMembers(key string) *StringSliceCmd

+ func (c *Ring) SMove(source, destination string, member interface{}) *BoolCmd

+ func (c *Ring) SPop(key string) *StringCmd

+ func (c *Ring) SPopN(key string, count int64) *StringSliceCmd

+ func (c *Ring) SRandMember(key string) *StringCmd

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

+ func (c *Ring) SRem(key string, members ...interface{}) *IntCmd

+ func (c *Ring) SScan(key string, cursor uint64, match string, count int64) *ScanCmd

+ func (c *Ring) SUnion(keys ...string) *StringSliceCmd

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

+ func (c *Ring) Save() *StatusCmd

+ func (c *Ring) Scan(cursor uint64, match string, count int64) *ScanCmd

+ func (c *Ring) ScriptExists(scripts ...string) *BoolSliceCmd

+ func (c *Ring) ScriptFlush() *StatusCmd

+ func (c *Ring) ScriptKill() *StatusCmd

+ func (c *Ring) ScriptLoad(script string) *StringCmd

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

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

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

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

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

+ func (c *Ring) Shutdown() *StatusCmd

+ func (c *Ring) ShutdownNoSave() *StatusCmd

+ func (c *Ring) ShutdownSave() *StatusCmd

+ func (c *Ring) SlaveOf(host, port string) *StatusCmd

+ func (c *Ring) SlowLog()

+ func (c *Ring) Sort(key string, sort Sort) *StringSliceCmd

+ func (c *Ring) SortInterfaces(key string, sort Sort) *SliceCmd

+ func (c *Ring) StrLen(key string) *IntCmd

+ func (c *Ring) Sync()

+ func (c *Ring) TTL(key string) *DurationCmd

+ func (c *Ring) Time() *TimeCmd

+ func (c *Ring) Type(key string) *StatusCmd

+ func (c *Ring) Unlink(keys ...string) *IntCmd

+ func (c *Ring) Wait(numSlaves int, timeout time.Duration) *IntCmd

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

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

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

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

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

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

+ func (c *Ring) ZCard(key string) *IntCmd

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

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

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

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

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

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

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

+ func (c *Ring) ZRangeByLex(key string, opt ZRangeBy) *StringSliceCmd

+ func (c *Ring) ZRangeByScore(key string, opt ZRangeBy) *StringSliceCmd

+ func (c *Ring) ZRangeByScoreWithScores(key string, opt ZRangeBy) *ZSliceCmd

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

+ func (c *Ring) ZRank(key, member string) *IntCmd

+ func (c *Ring) ZRem(key string, members ...interface{}) *IntCmd

+ func (c *Ring) ZRemRangeByLex(key, min, max string) *IntCmd

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

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

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

+ func (c *Ring) ZRevRangeByLex(key string, opt ZRangeBy) *StringSliceCmd

+ func (c *Ring) ZRevRangeByScore(key string, opt ZRangeBy) *StringSliceCmd

+ func (c *Ring) ZRevRangeByScoreWithScores(key string, opt ZRangeBy) *ZSliceCmd

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

+ func (c *Ring) ZRevRank(key, member string) *IntCmd

+ func (c *Ring) ZScan(key string, cursor uint64, match string, count int64) *ScanCmd

+ func (c *Ring) ZScore(key, member string) *FloatCmd

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

+ type RingOptions struct

+ Addrs map[string]string

+ DB int

+ DialTimeout time.Duration

+ HeartbeatFrequency time.Duration

+ IdleCheckFrequency time.Duration

+ IdleTimeout time.Duration

+ MaxRetries int

+ Password string

+ PoolSize int

+ PoolTimeout time.Duration

+ ReadTimeout time.Duration

+ WriteTimeout time.Duration

+ type ScanCmd struct

+ func NewScanCmd(process func(cmd Cmder) error, args ...interface{}) *ScanCmd

+ func NewScanCmdResult(keys []string, cursor uint64, err error) *ScanCmd

+ func (cmd *ScanCmd) Err() error

+ func (cmd *ScanCmd) Iterator() *ScanIterator

+ func (cmd *ScanCmd) Result() (keys []string, cursor uint64, err error)

+ func (cmd *ScanCmd) String() string

+ func (cmd *ScanCmd) Val() (keys []string, cursor uint64)

+ type ScanIterator struct

+ func (it *ScanIterator) Err() error

+ func (it *ScanIterator) Next() bool

+ func (it *ScanIterator) Val() string

+ type Script struct

+ func NewScript(src string) *Script

+ func (s *Script) Eval(c scripter, keys []string, args ...interface{}) *Cmd

+ func (s *Script) EvalSha(c scripter, keys []string, args ...interface{}) *Cmd

+ func (s *Script) Exists(c scripter) *BoolSliceCmd

+ func (s *Script) Load(c scripter) *StringCmd

+ func (s *Script) Run(c scripter, keys []string, args ...interface{}) *Cmd

+ type SliceCmd struct

+ func NewSliceCmd(args ...interface{}) *SliceCmd

+ func NewSliceResult(val []interface{}, err error) *SliceCmd

+ func (cmd *SliceCmd) Err() error

+ func (cmd *SliceCmd) Result() ([]interface{}, error)

+ func (cmd *SliceCmd) String() string

+ func (cmd *SliceCmd) Val() []interface{}

+ type Sort struct

+ By string

+ Count float64

+ Get []string

+ IsAlpha bool

+ Offset float64

+ Order string

+ Store string

+ type StatusCmd struct

+ func NewStatusCmd(args ...interface{}) *StatusCmd

+ func NewStatusResult(val string, err error) *StatusCmd

+ func (cmd *StatusCmd) Err() error

+ func (cmd *StatusCmd) Result() (string, error)

+ func (cmd *StatusCmd) String() string

+ func (cmd *StatusCmd) Val() string

+ type StringCmd struct

+ func NewStringCmd(args ...interface{}) *StringCmd

+ func NewStringResult(val string, err error) *StringCmd

+ func (cmd *StringCmd) 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 struct

+ func NewStringIntMapCmd(args ...interface{}) *StringIntMapCmd

+ func NewStringIntMapCmdResult(val map[string]int64, err error) *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 struct

+ func NewStringSliceCmd(args ...interface{}) *StringSliceCmd

+ func NewStringSliceResult(val []string, err error) *StringSliceCmd

+ func (cmd *StringSliceCmd) Err() error

+ func (cmd *StringSliceCmd) Result() ([]string, error)

+ func (cmd *StringSliceCmd) ScanSlice(container interface{}) error

+ func (cmd *StringSliceCmd) String() string

+ func (cmd *StringSliceCmd) Val() []string

+ type StringStringMapCmd struct

+ func NewStringStringMapCmd(args ...interface{}) *StringStringMapCmd

+ func NewStringStringMapResult(val map[string]string, err error) *StringStringMapCmd

+ func (cmd *StringStringMapCmd) Err() error

+ func (cmd *StringStringMapCmd) Result() (map[string]string, error)

+ func (cmd *StringStringMapCmd) String() string

+ func (cmd *StringStringMapCmd) Val() map[string]string

+ type Subscription struct

+ Channel string

+ Count int

+ Kind string

+ func (m *Subscription) String() string

+ type TimeCmd struct

+ func NewTimeCmd(args ...interface{}) *TimeCmd

+ func (cmd *TimeCmd) Err() error

+ func (cmd *TimeCmd) Result() (time.Time, error)

+ func (cmd *TimeCmd) String() string

+ func (cmd *TimeCmd) Val() time.Time

+ type Tx struct

+ func (c *Tx) Append(key, value string) *IntCmd

+ func (c *Tx) Auth(password string) *StatusCmd

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

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

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

+ func (c *Tx) BgRewriteAOF() *StatusCmd

+ func (c *Tx) BgSave() *StatusCmd

+ func (c *Tx) BitCount(key string, bitCount *BitCount) *IntCmd

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

+ func (c *Tx) BitOpNot(destKey string, key string) *IntCmd

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

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

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

+ func (c *Tx) ClientGetName() *StringCmd

+ func (c *Tx) ClientKill(ipPort string) *StatusCmd

+ func (c *Tx) ClientList() *StringCmd

+ func (c *Tx) ClientPause(dur time.Duration) *BoolCmd

+ func (c *Tx) ClientSetName(name string) *BoolCmd

+ func (c *Tx) Close() error

+ func (c *Tx) ClusterAddSlots(slots ...int) *StatusCmd

+ func (c *Tx) ClusterAddSlotsRange(min, max int) *StatusCmd

+ func (c *Tx) ClusterCountFailureReports(nodeID string) *IntCmd

+ func (c *Tx) ClusterCountKeysInSlot(slot int) *IntCmd

+ func (c *Tx) ClusterDelSlots(slots ...int) *StatusCmd

+ func (c *Tx) ClusterDelSlotsRange(min, max int) *StatusCmd

+ func (c *Tx) ClusterFailover() *StatusCmd

+ func (c *Tx) ClusterForget(nodeID string) *StatusCmd

+ func (c *Tx) ClusterInfo() *StringCmd

+ func (c *Tx) ClusterKeySlot(key string) *IntCmd

+ func (c *Tx) ClusterMeet(host, port string) *StatusCmd

+ func (c *Tx) ClusterNodes() *StringCmd

+ func (c *Tx) ClusterReplicate(nodeID string) *StatusCmd

+ func (c *Tx) ClusterResetHard() *StatusCmd

+ func (c *Tx) ClusterResetSoft() *StatusCmd

+ func (c *Tx) ClusterSaveConfig() *StatusCmd

+ func (c *Tx) ClusterSlaves(nodeID string) *StringSliceCmd

+ func (c *Tx) ClusterSlots() *ClusterSlotsCmd

+ func (c *Tx) Command() *CommandsInfoCmd

+ func (c *Tx) ConfigGet(parameter string) *SliceCmd

+ func (c *Tx) ConfigResetStat() *StatusCmd

+ func (c *Tx) ConfigSet(parameter, value string) *StatusCmd

+ func (c *Tx) DbSize() *IntCmd

+ func (c *Tx) DebugObject(key string) *StringCmd

+ func (c *Tx) Decr(key string) *IntCmd

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

+ func (c *Tx) Del(keys ...string) *IntCmd

+ func (c *Tx) Dump(key string) *StringCmd

+ func (c *Tx) Echo(message interface{}) *StringCmd

+ func (c *Tx) Eval(script string, keys []string, args ...interface{}) *Cmd

+ func (c *Tx) EvalSha(sha1 string, keys []string, args ...interface{}) *Cmd

+ func (c *Tx) Exists(keys ...string) *IntCmd

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

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

+ func (c *Tx) FlushAll() *StatusCmd

+ func (c *Tx) FlushDb() *StatusCmd

+ func (c *Tx) GeoAdd(key string, geoLocation ...*GeoLocation) *IntCmd

+ func (c *Tx) GeoDist(key string, member1, member2, unit string) *FloatCmd

+ func (c *Tx) GeoHash(key string, members ...string) *StringSliceCmd

+ func (c *Tx) GeoPos(key string, members ...string) *GeoPosCmd

+ func (c *Tx) GeoRadius(key string, longitude, latitude float64, query *GeoRadiusQuery) *GeoLocationCmd

+ func (c *Tx) GeoRadiusByMember(key, member string, query *GeoRadiusQuery) *GeoLocationCmd

+ func (c *Tx) Get(key string) *StringCmd

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

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

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

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

+ func (c *Tx) HExists(key, field string) *BoolCmd

+ func (c *Tx) HGet(key, field string) *StringCmd

+ func (c *Tx) HGetAll(key string) *StringStringMapCmd

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

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

+ func (c *Tx) HKeys(key string) *StringSliceCmd

+ func (c *Tx) HLen(key string) *IntCmd

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

+ func (c *Tx) HMSet(key string, fields map[string]interface{}) *StatusCmd

+ func (c *Tx) HScan(key string, cursor uint64, match string, count int64) *ScanCmd

+ func (c *Tx) HSet(key, field string, value interface{}) *BoolCmd

+ func (c *Tx) HSetNX(key, field string, value interface{}) *BoolCmd

+ func (c *Tx) HVals(key string) *StringSliceCmd

+ func (c *Tx) Incr(key string) *IntCmd

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

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

+ func (c *Tx) Info(section ...string) *StringCmd

+ func (c *Tx) Keys(pattern string) *StringSliceCmd

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

+ func (c *Tx) LInsert(key, op string, pivot, value interface{}) *IntCmd

+ func (c *Tx) LInsertAfter(key string, pivot, value interface{}) *IntCmd

+ func (c *Tx) LInsertBefore(key string, pivot, value interface{}) *IntCmd

+ func (c *Tx) LLen(key string) *IntCmd

+ func (c *Tx) LPop(key string) *StringCmd

+ func (c *Tx) LPush(key string, values ...interface{}) *IntCmd

+ func (c *Tx) LPushX(key string, value interface{}) *IntCmd

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

+ func (c *Tx) LRem(key string, count int64, value interface{}) *IntCmd

+ func (c *Tx) LSet(key string, index int64, value interface{}) *StatusCmd

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

+ func (c *Tx) LastSave() *IntCmd

+ func (c *Tx) MGet(keys ...string) *SliceCmd

+ func (c *Tx) MSet(pairs ...interface{}) *StatusCmd

+ func (c *Tx) MSetNX(pairs ...interface{}) *BoolCmd

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

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

+ func (c *Tx) ObjectEncoding(key string) *StringCmd

+ func (c *Tx) ObjectIdleTime(key string) *DurationCmd

+ func (c *Tx) ObjectRefCount(key string) *IntCmd

+ func (c *Tx) Options() *Options

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

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

+ func (c *Tx) PFAdd(key string, els ...interface{}) *IntCmd

+ func (c *Tx) PFCount(keys ...string) *IntCmd

+ func (c *Tx) PFMerge(dest string, keys ...string) *StatusCmd

+ func (c *Tx) PTTL(key string) *DurationCmd

+ func (c *Tx) Persist(key string) *BoolCmd

+ func (c *Tx) Ping() *StatusCmd

+ func (c *Tx) Pipeline() *Pipeline

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

+ func (c *Tx) Process(cmd Cmder) error

+ func (c *Tx) PubSubChannels(pattern string) *StringSliceCmd

+ func (c *Tx) PubSubNumPat() *IntCmd

+ func (c *Tx) PubSubNumSub(channels ...string) *StringIntMapCmd

+ func (c *Tx) Publish(channel, message string) *IntCmd

+ func (c *Tx) Quit() *StatusCmd

+ func (c *Tx) RPop(key string) *StringCmd

+ func (c *Tx) RPopLPush(source, destination string) *StringCmd

+ func (c *Tx) RPush(key string, values ...interface{}) *IntCmd

+ func (c *Tx) RPushX(key string, value interface{}) *IntCmd

+ func (c *Tx) RandomKey() *StringCmd

+ func (c *Tx) ReadOnly() *StatusCmd

+ func (c *Tx) ReadWrite() *StatusCmd

+ func (c *Tx) Rename(key, newkey string) *StatusCmd

+ func (c *Tx) RenameNX(key, newkey string) *BoolCmd

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

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

+ func (c *Tx) SAdd(key string, members ...interface{}) *IntCmd

+ func (c *Tx) SCard(key string) *IntCmd

+ func (c *Tx) SDiff(keys ...string) *StringSliceCmd

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

+ func (c *Tx) SInter(keys ...string) *StringSliceCmd

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

+ func (c *Tx) SIsMember(key string, member interface{}) *BoolCmd

+ func (c *Tx) SMembers(key string) *StringSliceCmd

+ func (c *Tx) SMove(source, destination string, member interface{}) *BoolCmd

+ func (c *Tx) SPop(key string) *StringCmd

+ func (c *Tx) SPopN(key string, count int64) *StringSliceCmd

+ func (c *Tx) SRandMember(key string) *StringCmd

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

+ func (c *Tx) SRem(key string, members ...interface{}) *IntCmd

+ func (c *Tx) SScan(key string, cursor uint64, match string, count int64) *ScanCmd

+ func (c *Tx) SUnion(keys ...string) *StringSliceCmd

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

+ func (c *Tx) Save() *StatusCmd

+ func (c *Tx) Scan(cursor uint64, match string, count int64) *ScanCmd

+ func (c *Tx) ScriptExists(scripts ...string) *BoolSliceCmd

+ func (c *Tx) ScriptFlush() *StatusCmd

+ func (c *Tx) ScriptKill() *StatusCmd

+ func (c *Tx) ScriptLoad(script string) *StringCmd

+ func (c *Tx) Select(index int) *StatusCmd

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

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

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

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

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

+ func (c *Tx) Shutdown() *StatusCmd

+ func (c *Tx) ShutdownNoSave() *StatusCmd

+ func (c *Tx) ShutdownSave() *StatusCmd

+ func (c *Tx) SlaveOf(host, port string) *StatusCmd

+ func (c *Tx) SlowLog()

+ func (c *Tx) Sort(key string, sort Sort) *StringSliceCmd

+ func (c *Tx) SortInterfaces(key string, sort Sort) *SliceCmd

+ func (c *Tx) StrLen(key string) *IntCmd

+ func (c *Tx) String() string

+ func (c *Tx) Sync()

+ func (c *Tx) TTL(key string) *DurationCmd

+ func (c *Tx) Time() *TimeCmd

+ func (c *Tx) Type(key string) *StatusCmd

+ func (c *Tx) Unlink(keys ...string) *IntCmd

+ func (c *Tx) Unwatch(keys ...string) *StatusCmd

+ func (c *Tx) Wait(numSlaves int, timeout time.Duration) *IntCmd

+ func (c *Tx) Watch(keys ...string) *StatusCmd

+ func (c *Tx) WrapProcess(fn func(oldProcess func(cmd Cmder) error) func(cmd Cmder) error)

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

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

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

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

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

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

+ func (c *Tx) ZCard(key string) *IntCmd

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

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

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

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

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

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

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

+ func (c *Tx) ZRangeByLex(key string, opt ZRangeBy) *StringSliceCmd

+ func (c *Tx) ZRangeByScore(key string, opt ZRangeBy) *StringSliceCmd

+ func (c *Tx) ZRangeByScoreWithScores(key string, opt ZRangeBy) *ZSliceCmd

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

+ func (c *Tx) ZRank(key, member string) *IntCmd

+ func (c *Tx) ZRem(key string, members ...interface{}) *IntCmd

+ func (c *Tx) ZRemRangeByLex(key, min, max string) *IntCmd

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

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

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

+ func (c *Tx) ZRevRangeByLex(key string, opt ZRangeBy) *StringSliceCmd

+ func (c *Tx) ZRevRangeByScore(key string, opt ZRangeBy) *StringSliceCmd

+ func (c *Tx) ZRevRangeByScoreWithScores(key string, opt ZRangeBy) *ZSliceCmd

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

+ func (c *Tx) ZRevRank(key, member string) *IntCmd

+ func (c *Tx) ZScan(key string, cursor uint64, match string, count int64) *ScanCmd

+ func (c *Tx) ZScore(key, member string) *FloatCmd

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

+ type UniversalClient interface

+ Close func() error

+ Process func(cmd Cmder) error

+ func NewUniversalClient(opts *UniversalOptions) UniversalClient

+ type UniversalOptions struct

+ Addrs []string

+ DB int

+ DialTimeout time.Duration

+ IdleCheckFrequency time.Duration

+ IdleTimeout time.Duration

+ MasterName string

+ MaxRedirects int

+ MaxRetries int

+ Password string

+ PoolSize int

+ PoolTimeout time.Duration

+ ReadOnly bool

+ ReadTimeout time.Duration

+ RouteByLatency bool

+ WriteTimeout time.Duration

+ type Z struct

+ Member interface{}

+ Score float64

+ type ZRangeBy struct

+ Count int64

+ Max string

+ Min string

+ Offset int64

+ type ZSliceCmd struct

+ func NewZSliceCmd(args ...interface{}) *ZSliceCmd

+ func NewZSliceCmdResult(val []Z, err error) *ZSliceCmd

+ func (cmd *ZSliceCmd) Err() error

+ func (cmd *ZSliceCmd) Result() ([]Z, error)

+ func (cmd *ZSliceCmd) String() string

+ func (cmd *ZSliceCmd) Val() []Z

+ type ZStore struct

+ Aggregate string

+ Weights []float64

Other modules containing this package

gopkg.in/freshcn/redis.v2

gopkg.in/freshcn/redis.v5

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL