redis

package module

Go to main page

Versions in this module

v8

v8.11.5

Mar 17, 2022

Changes in this version

type BoolCmd

+ func (cmd *BoolCmd) SetFirstKeyPos(keyPos int8)

type BoolSliceCmd

+ func (cmd *BoolSliceCmd) SetFirstKeyPos(keyPos int8)

type Client

+ func (c Client) Copy(ctx context.Context, sourceKey, destKey string, db int, replace bool) *IntCmd

+ func (c Client) ExpireGT(ctx context.Context, key string, expiration time.Duration) *BoolCmd

+ func (c Client) ExpireLT(ctx context.Context, key string, expiration time.Duration) *BoolCmd

+ func (c Client) ExpireNX(ctx context.Context, key string, expiration time.Duration) *BoolCmd

+ func (c Client) ExpireXX(ctx context.Context, key string, expiration time.Duration) *BoolCmd

type ClusterClient

+ func (c ClusterClient) Copy(ctx context.Context, sourceKey, destKey string, db int, replace bool) *IntCmd

+ func (c ClusterClient) ExpireGT(ctx context.Context, key string, expiration time.Duration) *BoolCmd

+ func (c ClusterClient) ExpireLT(ctx context.Context, key string, expiration time.Duration) *BoolCmd

+ func (c ClusterClient) ExpireNX(ctx context.Context, key string, expiration time.Duration) *BoolCmd

+ func (c ClusterClient) ExpireXX(ctx context.Context, key string, expiration time.Duration) *BoolCmd

type ClusterSlotsCmd

+ func (cmd *ClusterSlotsCmd) SetFirstKeyPos(keyPos int8)

type Cmd

+ func (cmd *Cmd) SetFirstKeyPos(keyPos int8)

type Cmdable

+ Copy func(ctx context.Context, sourceKey string, destKey string, db int, replace bool) *IntCmd

+ ExpireGT func(ctx context.Context, key string, expiration time.Duration) *BoolCmd

+ ExpireLT func(ctx context.Context, key string, expiration time.Duration) *BoolCmd

+ ExpireNX func(ctx context.Context, key string, expiration time.Duration) *BoolCmd

+ ExpireXX func(ctx context.Context, key string, expiration time.Duration) *BoolCmd

type Cmder

+ SetFirstKeyPos func(int8)

type CommandsInfoCmd

+ func (cmd *CommandsInfoCmd) SetFirstKeyPos(keyPos int8)

type DurationCmd

+ func (cmd *DurationCmd) SetFirstKeyPos(keyPos int8)

type FloatCmd

+ func (cmd *FloatCmd) SetFirstKeyPos(keyPos int8)

type FloatSliceCmd

+ func (cmd *FloatSliceCmd) SetFirstKeyPos(keyPos int8)

type GeoLocationCmd

+ func (cmd *GeoLocationCmd) SetFirstKeyPos(keyPos int8)

type GeoPosCmd

+ func (cmd *GeoPosCmd) SetFirstKeyPos(keyPos int8)

type GeoSearchLocationCmd

+ func (cmd *GeoSearchLocationCmd) SetFirstKeyPos(keyPos int8)

type IntCmd

+ func (cmd *IntCmd) SetFirstKeyPos(keyPos int8)

type IntSliceCmd

+ func (cmd *IntSliceCmd) SetFirstKeyPos(keyPos int8)

type Pipeline

+ func (c *Pipeline) Len() int

+ func (c Pipeline) Copy(ctx context.Context, sourceKey, destKey string, db int, replace bool) *IntCmd

+ func (c Pipeline) ExpireGT(ctx context.Context, key string, expiration time.Duration) *BoolCmd

+ func (c Pipeline) ExpireLT(ctx context.Context, key string, expiration time.Duration) *BoolCmd

+ func (c Pipeline) ExpireNX(ctx context.Context, key string, expiration time.Duration) *BoolCmd

+ func (c Pipeline) ExpireXX(ctx context.Context, key string, expiration time.Duration) *BoolCmd

type Pipeliner

+ Len func() int

type Ring

+ func (c Ring) Copy(ctx context.Context, sourceKey, destKey string, db int, replace bool) *IntCmd

+ func (c Ring) ExpireGT(ctx context.Context, key string, expiration time.Duration) *BoolCmd

+ func (c Ring) ExpireLT(ctx context.Context, key string, expiration time.Duration) *BoolCmd

+ func (c Ring) ExpireNX(ctx context.Context, key string, expiration time.Duration) *BoolCmd

+ func (c Ring) ExpireXX(ctx context.Context, key string, expiration time.Duration) *BoolCmd

type ScanCmd

+ func (cmd *ScanCmd) SetFirstKeyPos(keyPos int8)

type SliceCmd

+ func (cmd *SliceCmd) SetFirstKeyPos(keyPos int8)

type SlowLogCmd

+ func (cmd *SlowLogCmd) SetFirstKeyPos(keyPos int8)

type StatusCmd

+ func (cmd *StatusCmd) SetFirstKeyPos(keyPos int8)

type StringCmd

+ func (cmd *StringCmd) SetFirstKeyPos(keyPos int8)

type StringIntMapCmd

+ func (cmd *StringIntMapCmd) SetFirstKeyPos(keyPos int8)

type StringSliceCmd

+ func (cmd *StringSliceCmd) SetFirstKeyPos(keyPos int8)

type StringStringMapCmd

+ func (cmd *StringStringMapCmd) SetFirstKeyPos(keyPos int8)

type StringStructMapCmd

+ func (cmd *StringStructMapCmd) SetFirstKeyPos(keyPos int8)

type TimeCmd

+ func (cmd *TimeCmd) SetFirstKeyPos(keyPos int8)

type Tx

+ func (c Tx) Copy(ctx context.Context, sourceKey, destKey string, db int, replace bool) *IntCmd

+ func (c Tx) ExpireGT(ctx context.Context, key string, expiration time.Duration) *BoolCmd

+ func (c Tx) ExpireLT(ctx context.Context, key string, expiration time.Duration) *BoolCmd

+ func (c Tx) ExpireNX(ctx context.Context, key string, expiration time.Duration) *BoolCmd

+ func (c Tx) ExpireXX(ctx context.Context, key string, expiration time.Duration) *BoolCmd

type UniversalOptions

+ SentinelUsername string

type XAutoClaimCmd

+ func (cmd *XAutoClaimCmd) SetFirstKeyPos(keyPos int8)

type XAutoClaimJustIDCmd

+ func (cmd *XAutoClaimJustIDCmd) SetFirstKeyPos(keyPos int8)

type XInfoConsumersCmd

+ func (cmd *XInfoConsumersCmd) SetFirstKeyPos(keyPos int8)

type XInfoGroupsCmd

+ func (cmd *XInfoGroupsCmd) SetFirstKeyPos(keyPos int8)

type XInfoStreamCmd

+ func (cmd *XInfoStreamCmd) SetFirstKeyPos(keyPos int8)

type XInfoStreamFullCmd

+ func (cmd *XInfoStreamFullCmd) SetFirstKeyPos(keyPos int8)

type XMessageSliceCmd

+ func (cmd *XMessageSliceCmd) SetFirstKeyPos(keyPos int8)

type XPendingCmd

+ func (cmd *XPendingCmd) SetFirstKeyPos(keyPos int8)

type XPendingExtCmd

+ func (cmd *XPendingExtCmd) SetFirstKeyPos(keyPos int8)

type XStreamSliceCmd

+ func (cmd *XStreamSliceCmd) SetFirstKeyPos(keyPos int8)

type ZSliceCmd

+ func (cmd *ZSliceCmd) SetFirstKeyPos(keyPos int8)

type ZWithKeyCmd

+ func (cmd *ZWithKeyCmd) SetFirstKeyPos(keyPos int8)

v8.11.4

Oct 4, 2021

Changes in this version

type BoolCmd

+ func (cmd *BoolCmd) SetVal(val bool)

type BoolSliceCmd

+ func (cmd *BoolSliceCmd) SetVal(val []bool)

type Client

+ func (c Client) BLMove(ctx context.Context, source, destination, srcpos, destpos string, ...) *StringCmd

type ClusterClient

+ func (c ClusterClient) BLMove(ctx context.Context, source, destination, srcpos, destpos string, ...) *StringCmd

type ClusterSlotsCmd

+ func (cmd *ClusterSlotsCmd) SetVal(val []ClusterSlot)

type Cmd

+ func (cmd *Cmd) BoolSlice() ([]bool, error)

+ func (cmd *Cmd) Float32Slice() ([]float32, error)

+ func (cmd *Cmd) Float64Slice() ([]float64, error)

+ func (cmd *Cmd) Int64Slice() ([]int64, error)

+ func (cmd *Cmd) SetVal(val interface{})

+ func (cmd *Cmd) Slice() ([]interface{}, error)

+ func (cmd *Cmd) StringSlice() ([]string, error)

+ func (cmd *Cmd) Uint64Slice() ([]uint64, error)

type Cmdable

+ BLMove func(ctx context.Context, source, destination, srcpos, destpos string, ...) *StringCmd

type CommandsInfoCmd

+ func (cmd *CommandsInfoCmd) SetVal(val map[string]*CommandInfo)

type DurationCmd

+ func (cmd *DurationCmd) SetVal(val time.Duration)

type FailoverOptions

+ SentinelUsername string

type FloatCmd

+ func (cmd *FloatCmd) SetVal(val float64)

type FloatSliceCmd

+ func (cmd *FloatSliceCmd) SetVal(val []float64)

type GeoLocationCmd

+ func (cmd *GeoLocationCmd) SetVal(locations []GeoLocation)

type GeoPosCmd

+ func (cmd *GeoPosCmd) SetVal(val []*GeoPos)

type GeoSearchLocationCmd

+ func (cmd *GeoSearchLocationCmd) SetVal(val []GeoLocation)

type IntCmd

+ func (cmd *IntCmd) SetVal(val int64)

type IntSliceCmd

+ func (cmd *IntSliceCmd) SetVal(val []int64)

type Pipeline

+ func (c Pipeline) BLMove(ctx context.Context, source, destination, srcpos, destpos string, ...) *StringCmd

type Ring

+ func (c Ring) BLMove(ctx context.Context, source, destination, srcpos, destpos string, ...) *StringCmd

type ScanCmd

+ func (cmd *ScanCmd) SetVal(page []string, cursor uint64)

type SliceCmd

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

type SlowLogCmd

+ func (cmd *SlowLogCmd) SetVal(val []SlowLog)

type StatusCmd

+ func (cmd *StatusCmd) SetVal(val string)

type StringCmd

+ func (cmd *StringCmd) SetVal(val string)

type StringIntMapCmd

+ func (cmd *StringIntMapCmd) SetVal(val map[string]int64)

type StringSliceCmd

+ func (cmd *StringSliceCmd) SetVal(val []string)

type StringStringMapCmd

+ func (cmd *StringStringMapCmd) SetVal(val map[string]string)

type StringStructMapCmd

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

type TimeCmd

+ func (cmd *TimeCmd) SetVal(val time.Time)

type Tx

+ func (c Tx) BLMove(ctx context.Context, source, destination, srcpos, destpos string, ...) *StringCmd

type XAutoClaimCmd

+ func (cmd *XAutoClaimCmd) SetVal(val []XMessage, start string)

type XAutoClaimJustIDCmd

+ func (cmd *XAutoClaimJustIDCmd) SetVal(val []string, start string)

type XInfoConsumersCmd

+ func (cmd *XInfoConsumersCmd) SetVal(val []XInfoConsumer)

type XInfoGroupsCmd

+ func (cmd *XInfoGroupsCmd) SetVal(val []XInfoGroup)

type XInfoStreamCmd

+ func (cmd *XInfoStreamCmd) SetVal(val *XInfoStream)

type XInfoStreamFullCmd

+ func (cmd *XInfoStreamFullCmd) SetVal(val *XInfoStreamFull)

type XMessageSliceCmd

+ func (cmd *XMessageSliceCmd) SetVal(val []XMessage)

type XPendingCmd

+ func (cmd *XPendingCmd) SetVal(val *XPending)

type XPendingExtCmd

+ func (cmd *XPendingExtCmd) SetVal(val []XPendingExt)

type XStreamSliceCmd

+ func (cmd *XStreamSliceCmd) SetVal(val []XStream)

type ZSliceCmd

+ func (cmd *ZSliceCmd) SetVal(val []Z)

type ZWithKeyCmd

+ func (cmd *ZWithKeyCmd) SetVal(val *ZWithKey)

v8.11.3

Aug 12, 2021

Changes in this version

+ func Version() string

type Cmdable

+ XInfoStreamFull func(ctx context.Context, key string, count int) *XInfoStreamFullCmd

v8.11.2

Aug 6, 2021

v8.11.1

Jul 28, 2021

Changes in this version

type Client

+ func (c Client) GeoSearch(ctx context.Context, key string, q *GeoSearchQuery) *StringSliceCmd

+ func (c Client) GeoSearchLocation(ctx context.Context, key string, q *GeoSearchLocationQuery) *GeoSearchLocationCmd

+ func (c Client) GeoSearchStore(ctx context.Context, key, store string, q *GeoSearchStoreQuery) *IntCmd

+ func (c Client) RPopCount(ctx context.Context, key string, count int) *StringSliceCmd

type ClusterClient

+ func (c ClusterClient) GeoSearch(ctx context.Context, key string, q *GeoSearchQuery) *StringSliceCmd

+ func (c ClusterClient) GeoSearchLocation(ctx context.Context, key string, q *GeoSearchLocationQuery) *GeoSearchLocationCmd

+ func (c ClusterClient) GeoSearchStore(ctx context.Context, key, store string, q *GeoSearchStoreQuery) *IntCmd

+ func (c ClusterClient) RPopCount(ctx context.Context, key string, count int) *StringSliceCmd

type ClusterOptions

+ PoolFIFO bool

type Cmdable

+ GeoSearch func(ctx context.Context, key string, q *GeoSearchQuery) *StringSliceCmd

+ GeoSearchLocation func(ctx context.Context, key string, q *GeoSearchLocationQuery) *GeoSearchLocationCmd

+ GeoSearchStore func(ctx context.Context, key, store string, q *GeoSearchStoreQuery) *IntCmd

+ RPopCount func(ctx context.Context, key string, count int) *StringSliceCmd

+ XAutoClaim func(ctx context.Context, a *XAutoClaimArgs) *XAutoClaimCmd

+ XAutoClaimJustID func(ctx context.Context, a *XAutoClaimArgs) *XAutoClaimJustIDCmd

type FailoverOptions

+ PoolFIFO bool

+ type GeoSearchLocationCmd struct

+ func NewGeoSearchLocationCmd(ctx context.Context, opt *GeoSearchLocationQuery, args ...interface{}) *GeoSearchLocationCmd

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

+ func (cmd *GeoSearchLocationCmd) Err() error

+ func (cmd *GeoSearchLocationCmd) FullName() string

+ func (cmd *GeoSearchLocationCmd) Name() string

+ func (cmd *GeoSearchLocationCmd) Result() ([]GeoLocation, error)

+ func (cmd *GeoSearchLocationCmd) SetErr(e error)

+ func (cmd *GeoSearchLocationCmd) String() string

+ func (cmd *GeoSearchLocationCmd) Val() []GeoLocation

+ type GeoSearchLocationQuery struct

+ WithCoord bool

+ WithDist bool

+ WithHash bool

+ type GeoSearchQuery struct

+ BoxHeight float64

+ BoxUnit string

+ BoxWidth float64

+ Count int

+ CountAny bool

+ Latitude float64

+ Longitude float64

+ Member string

+ Radius float64

+ RadiusUnit string

+ Sort string

+ type GeoSearchStoreQuery struct

+ StoreDist bool

type Options

+ PoolFIFO bool

type Pipeline

+ func (c Pipeline) GeoSearch(ctx context.Context, key string, q *GeoSearchQuery) *StringSliceCmd

+ func (c Pipeline) GeoSearchLocation(ctx context.Context, key string, q *GeoSearchLocationQuery) *GeoSearchLocationCmd

+ func (c Pipeline) GeoSearchStore(ctx context.Context, key, store string, q *GeoSearchStoreQuery) *IntCmd

+ func (c Pipeline) RPopCount(ctx context.Context, key string, count int) *StringSliceCmd

type Ring

+ func (c Ring) GeoSearch(ctx context.Context, key string, q *GeoSearchQuery) *StringSliceCmd

+ func (c Ring) GeoSearchLocation(ctx context.Context, key string, q *GeoSearchLocationQuery) *GeoSearchLocationCmd

+ func (c Ring) GeoSearchStore(ctx context.Context, key, store string, q *GeoSearchStoreQuery) *IntCmd

+ func (c Ring) RPopCount(ctx context.Context, key string, count int) *StringSliceCmd

type RingOptions

+ PoolFIFO bool

type Tx

+ func (c Tx) GeoSearch(ctx context.Context, key string, q *GeoSearchQuery) *StringSliceCmd

+ func (c Tx) GeoSearchLocation(ctx context.Context, key string, q *GeoSearchLocationQuery) *GeoSearchLocationCmd

+ func (c Tx) GeoSearchStore(ctx context.Context, key, store string, q *GeoSearchStoreQuery) *IntCmd

+ func (c Tx) RPopCount(ctx context.Context, key string, count int) *StringSliceCmd

type UniversalOptions

+ PoolFIFO bool

v8.11.0

Jun 30, 2021

Changes in this version

type Client

+ func (c Client) XAutoClaim(ctx context.Context, a *XAutoClaimArgs) *XAutoClaimCmd

+ func (c Client) XAutoClaimJustID(ctx context.Context, a *XAutoClaimArgs) *XAutoClaimJustIDCmd

+ func (c Client) XGroupCreateConsumer(ctx context.Context, stream, group, consumer string) *IntCmd

+ func (c Client) XTrimMaxLen(ctx context.Context, key string, maxLen int64) *IntCmd

+ func (c Client) XTrimMaxLenApprox(ctx context.Context, key string, maxLen, limit int64) *IntCmd

+ func (c Client) XTrimMinID(ctx context.Context, key string, minID string) *IntCmd

+ func (c Client) XTrimMinIDApprox(ctx context.Context, key string, minID string, limit int64) *IntCmd

+ func (c Client) ZAddArgs(ctx context.Context, key string, args ZAddArgs) *IntCmd

+ func (c Client) ZAddArgsIncr(ctx context.Context, key string, args ZAddArgs) *FloatCmd

+ func (c Client) ZRangeArgs(ctx context.Context, z ZRangeArgs) *StringSliceCmd

+ func (c Client) ZRangeArgsWithScores(ctx context.Context, z ZRangeArgs) *ZSliceCmd

+ func (c Client) ZRangeStore(ctx context.Context, dst string, z ZRangeArgs) *IntCmd

+ func (c Client) ZUnion(ctx context.Context, store ZStore) *StringSliceCmd

+ func (c Client) ZUnionWithScores(ctx context.Context, store ZStore) *ZSliceCmd

type ClusterClient

+ func (c ClusterClient) XAutoClaim(ctx context.Context, a *XAutoClaimArgs) *XAutoClaimCmd

+ func (c ClusterClient) XAutoClaimJustID(ctx context.Context, a *XAutoClaimArgs) *XAutoClaimJustIDCmd

+ func (c ClusterClient) XGroupCreateConsumer(ctx context.Context, stream, group, consumer string) *IntCmd

+ func (c ClusterClient) XTrimMaxLen(ctx context.Context, key string, maxLen int64) *IntCmd

+ func (c ClusterClient) XTrimMaxLenApprox(ctx context.Context, key string, maxLen, limit int64) *IntCmd

+ func (c ClusterClient) XTrimMinID(ctx context.Context, key string, minID string) *IntCmd

+ func (c ClusterClient) XTrimMinIDApprox(ctx context.Context, key string, minID string, limit int64) *IntCmd

+ func (c ClusterClient) ZAddArgs(ctx context.Context, key string, args ZAddArgs) *IntCmd

+ func (c ClusterClient) ZAddArgsIncr(ctx context.Context, key string, args ZAddArgs) *FloatCmd

+ func (c ClusterClient) ZRangeArgs(ctx context.Context, z ZRangeArgs) *StringSliceCmd

+ func (c ClusterClient) ZRangeArgsWithScores(ctx context.Context, z ZRangeArgs) *ZSliceCmd

+ func (c ClusterClient) ZRangeStore(ctx context.Context, dst string, z ZRangeArgs) *IntCmd

+ func (c ClusterClient) ZUnion(ctx context.Context, store ZStore) *StringSliceCmd

+ func (c ClusterClient) ZUnionWithScores(ctx context.Context, store ZStore) *ZSliceCmd

type Cmdable

+ XGroupCreateConsumer func(ctx context.Context, stream, group, consumer string) *IntCmd

+ XTrimMaxLen func(ctx context.Context, key string, maxLen int64) *IntCmd

+ XTrimMaxLenApprox func(ctx context.Context, key string, maxLen, limit int64) *IntCmd

+ XTrimMinID func(ctx context.Context, key string, minID string) *IntCmd

+ XTrimMinIDApprox func(ctx context.Context, key string, minID string, limit int64) *IntCmd

+ ZAddArgs func(ctx context.Context, key string, args ZAddArgs) *IntCmd

+ ZAddArgsIncr func(ctx context.Context, key string, args ZAddArgs) *FloatCmd

+ ZRangeArgs func(ctx context.Context, z ZRangeArgs) *StringSliceCmd

+ ZRangeArgsWithScores func(ctx context.Context, z ZRangeArgs) *ZSliceCmd

+ ZRangeStore func(ctx context.Context, dst string, z ZRangeArgs) *IntCmd

+ ZUnion func(ctx context.Context, store ZStore) *StringSliceCmd

+ ZUnionWithScores func(ctx context.Context, store ZStore) *ZSliceCmd

type Pipeline

+ func (c Pipeline) XAutoClaim(ctx context.Context, a *XAutoClaimArgs) *XAutoClaimCmd

+ func (c Pipeline) XAutoClaimJustID(ctx context.Context, a *XAutoClaimArgs) *XAutoClaimJustIDCmd

+ func (c Pipeline) XGroupCreateConsumer(ctx context.Context, stream, group, consumer string) *IntCmd

+ func (c Pipeline) XTrimMaxLen(ctx context.Context, key string, maxLen int64) *IntCmd

+ func (c Pipeline) XTrimMaxLenApprox(ctx context.Context, key string, maxLen, limit int64) *IntCmd

+ func (c Pipeline) XTrimMinID(ctx context.Context, key string, minID string) *IntCmd

+ func (c Pipeline) XTrimMinIDApprox(ctx context.Context, key string, minID string, limit int64) *IntCmd

+ func (c Pipeline) ZAddArgs(ctx context.Context, key string, args ZAddArgs) *IntCmd

+ func (c Pipeline) ZAddArgsIncr(ctx context.Context, key string, args ZAddArgs) *FloatCmd

+ func (c Pipeline) ZRangeArgs(ctx context.Context, z ZRangeArgs) *StringSliceCmd

+ func (c Pipeline) ZRangeArgsWithScores(ctx context.Context, z ZRangeArgs) *ZSliceCmd

+ func (c Pipeline) ZRangeStore(ctx context.Context, dst string, z ZRangeArgs) *IntCmd

+ func (c Pipeline) ZUnion(ctx context.Context, store ZStore) *StringSliceCmd

+ func (c Pipeline) ZUnionWithScores(ctx context.Context, store ZStore) *ZSliceCmd

type Ring

+ func (c Ring) XAutoClaim(ctx context.Context, a *XAutoClaimArgs) *XAutoClaimCmd

+ func (c Ring) XAutoClaimJustID(ctx context.Context, a *XAutoClaimArgs) *XAutoClaimJustIDCmd

+ func (c Ring) XGroupCreateConsumer(ctx context.Context, stream, group, consumer string) *IntCmd

+ func (c Ring) XTrimMaxLen(ctx context.Context, key string, maxLen int64) *IntCmd

+ func (c Ring) XTrimMaxLenApprox(ctx context.Context, key string, maxLen, limit int64) *IntCmd

+ func (c Ring) XTrimMinID(ctx context.Context, key string, minID string) *IntCmd

+ func (c Ring) XTrimMinIDApprox(ctx context.Context, key string, minID string, limit int64) *IntCmd

+ func (c Ring) ZAddArgs(ctx context.Context, key string, args ZAddArgs) *IntCmd

+ func (c Ring) ZAddArgsIncr(ctx context.Context, key string, args ZAddArgs) *FloatCmd

+ func (c Ring) ZRangeArgs(ctx context.Context, z ZRangeArgs) *StringSliceCmd

+ func (c Ring) ZRangeArgsWithScores(ctx context.Context, z ZRangeArgs) *ZSliceCmd

+ func (c Ring) ZRangeStore(ctx context.Context, dst string, z ZRangeArgs) *IntCmd

+ func (c Ring) ZUnion(ctx context.Context, store ZStore) *StringSliceCmd

+ func (c Ring) ZUnionWithScores(ctx context.Context, store ZStore) *ZSliceCmd

type Tx

+ func (c Tx) XAutoClaim(ctx context.Context, a *XAutoClaimArgs) *XAutoClaimCmd

+ func (c Tx) XAutoClaimJustID(ctx context.Context, a *XAutoClaimArgs) *XAutoClaimJustIDCmd

+ func (c Tx) XGroupCreateConsumer(ctx context.Context, stream, group, consumer string) *IntCmd

+ func (c Tx) XTrimMaxLen(ctx context.Context, key string, maxLen int64) *IntCmd

+ func (c Tx) XTrimMaxLenApprox(ctx context.Context, key string, maxLen, limit int64) *IntCmd

+ func (c Tx) XTrimMinID(ctx context.Context, key string, minID string) *IntCmd

+ func (c Tx) XTrimMinIDApprox(ctx context.Context, key string, minID string, limit int64) *IntCmd

+ func (c Tx) ZAddArgs(ctx context.Context, key string, args ZAddArgs) *IntCmd

+ func (c Tx) ZAddArgsIncr(ctx context.Context, key string, args ZAddArgs) *FloatCmd

+ func (c Tx) ZRangeArgs(ctx context.Context, z ZRangeArgs) *StringSliceCmd

+ func (c Tx) ZRangeArgsWithScores(ctx context.Context, z ZRangeArgs) *ZSliceCmd

+ func (c Tx) ZRangeStore(ctx context.Context, dst string, z ZRangeArgs) *IntCmd

+ func (c Tx) ZUnion(ctx context.Context, store ZStore) *StringSliceCmd

+ func (c Tx) ZUnionWithScores(ctx context.Context, store ZStore) *ZSliceCmd

type XAddArgs

+ Approx bool

+ Limit int64

+ MinID string

+ NoMkStream bool

+ type XAutoClaimArgs struct

+ Consumer string

+ Count int64

+ Group string

+ MinIdle time.Duration

+ Start string

+ Stream string

+ type XAutoClaimCmd struct

+ func NewXAutoClaimCmd(ctx context.Context, args ...interface{}) *XAutoClaimCmd

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

+ func (cmd *XAutoClaimCmd) Err() error

+ func (cmd *XAutoClaimCmd) FullName() string

+ func (cmd *XAutoClaimCmd) Name() string

+ func (cmd *XAutoClaimCmd) Result() (messages []XMessage, start string, err error)

+ func (cmd *XAutoClaimCmd) SetErr(e error)

+ func (cmd *XAutoClaimCmd) String() string

+ func (cmd *XAutoClaimCmd) Val() (messages []XMessage, start string)

+ type XAutoClaimJustIDCmd struct

+ func NewXAutoClaimJustIDCmd(ctx context.Context, args ...interface{}) *XAutoClaimJustIDCmd

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

+ func (cmd *XAutoClaimJustIDCmd) Err() error

+ func (cmd *XAutoClaimJustIDCmd) FullName() string

+ func (cmd *XAutoClaimJustIDCmd) Name() string

+ func (cmd *XAutoClaimJustIDCmd) Result() (ids []string, start string, err error)

+ func (cmd *XAutoClaimJustIDCmd) SetErr(e error)

+ func (cmd *XAutoClaimJustIDCmd) String() string

+ func (cmd *XAutoClaimJustIDCmd) Val() (ids []string, start string)

+ type ZAddArgs struct

+ Ch bool

+ GT bool

+ LT bool

+ Members []Z

+ NX bool

+ XX bool

+ type ZRangeArgs struct

+ ByLex bool

+ ByScore bool

+ Count int64

+ Key string

+ Offset int64

+ Rev bool

+ Start interface{}

+ Stop interface{}

v8.10.0

Jun 3, 2021

Changes in this version

type Client

+ func (c Client) ZDiffStore(ctx context.Context, destination string, keys ...string) *IntCmd

+ func (c Client) ZInter(ctx context.Context, store *ZStore) *StringSliceCmd

+ func (c Client) ZInterWithScores(ctx context.Context, store *ZStore) *ZSliceCmd

type ClusterClient

+ func (c ClusterClient) ZDiffStore(ctx context.Context, destination string, keys ...string) *IntCmd

+ func (c ClusterClient) ZInter(ctx context.Context, store *ZStore) *StringSliceCmd

+ func (c ClusterClient) ZInterWithScores(ctx context.Context, store *ZStore) *ZSliceCmd

type Cmdable

+ ZDiffStore func(ctx context.Context, destination string, keys ...string) *IntCmd

+ ZInter func(ctx context.Context, store *ZStore) *StringSliceCmd

+ ZInterWithScores func(ctx context.Context, store *ZStore) *ZSliceCmd

type Pipeline

+ func (c Pipeline) ZDiffStore(ctx context.Context, destination string, keys ...string) *IntCmd

+ func (c Pipeline) ZInter(ctx context.Context, store *ZStore) *StringSliceCmd

+ func (c Pipeline) ZInterWithScores(ctx context.Context, store *ZStore) *ZSliceCmd

type Ring

+ func (c Ring) ZDiffStore(ctx context.Context, destination string, keys ...string) *IntCmd

+ func (c Ring) ZInter(ctx context.Context, store *ZStore) *StringSliceCmd

+ func (c Ring) ZInterWithScores(ctx context.Context, store *ZStore) *ZSliceCmd

type Tx

+ func (c Tx) ZDiffStore(ctx context.Context, destination string, keys ...string) *IntCmd

+ func (c Tx) ZInter(ctx context.Context, store *ZStore) *StringSliceCmd

+ func (c Tx) ZInterWithScores(ctx context.Context, store *ZStore) *ZSliceCmd

v8.9.0

May 26, 2021

Changes in this version

+ type ChannelOption func(c *channel)

+ func WithChannelHealthCheckInterval(d time.Duration) ChannelOption

+ func WithChannelSendTimeout(d time.Duration) ChannelOption

+ func WithChannelSize(size int) ChannelOption

type Client

+ func (c Client) XInfoStreamFull(ctx context.Context, key string, count int) *XInfoStreamFullCmd

+ func (c Client) ZDiff(ctx context.Context, keys ...string) *StringSliceCmd

+ func (c Client) ZDiffWithScores(ctx context.Context, keys ...string) *ZSliceCmd

type ClusterClient

+ func (c ClusterClient) XInfoStreamFull(ctx context.Context, key string, count int) *XInfoStreamFullCmd

+ func (c ClusterClient) ZDiff(ctx context.Context, keys ...string) *StringSliceCmd

+ func (c ClusterClient) ZDiffWithScores(ctx context.Context, keys ...string) *ZSliceCmd

type Cmdable

+ ZDiff func(ctx context.Context, keys ...string) *StringSliceCmd

+ ZDiffWithScores func(ctx context.Context, keys ...string) *ZSliceCmd

type Pipeline

+ func (c Pipeline) XInfoStreamFull(ctx context.Context, key string, count int) *XInfoStreamFullCmd

+ func (c Pipeline) ZDiff(ctx context.Context, keys ...string) *StringSliceCmd

+ func (c Pipeline) ZDiffWithScores(ctx context.Context, keys ...string) *ZSliceCmd

type Ring

+ func (c Ring) XInfoStreamFull(ctx context.Context, key string, count int) *XInfoStreamFullCmd

+ func (c Ring) ZDiff(ctx context.Context, keys ...string) *StringSliceCmd

+ func (c Ring) ZDiffWithScores(ctx context.Context, keys ...string) *ZSliceCmd

type Tx

+ func (c Tx) XInfoStreamFull(ctx context.Context, key string, count int) *XInfoStreamFullCmd

+ func (c Tx) ZDiff(ctx context.Context, keys ...string) *StringSliceCmd

+ func (c Tx) ZDiffWithScores(ctx context.Context, keys ...string) *ZSliceCmd

+ type XInfoStreamConsumer struct

+ Name string

+ PelCount int64

+ Pending []XInfoStreamConsumerPending

+ SeenTime time.Time

+ type XInfoStreamConsumerPending struct

+ DeliveryCount int64

+ DeliveryTime time.Time

+ ID string

+ type XInfoStreamFull struct

+ Entries []XMessage

+ Groups []XInfoStreamGroup

+ LastGeneratedID string

+ Length int64

+ RadixTreeKeys int64

+ RadixTreeNodes int64

+ type XInfoStreamFullCmd struct

+ func NewXInfoStreamFullCmd(ctx context.Context, args ...interface{}) *XInfoStreamFullCmd

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

+ func (cmd *XInfoStreamFullCmd) Err() error

+ func (cmd *XInfoStreamFullCmd) FullName() string

+ func (cmd *XInfoStreamFullCmd) Name() string

+ func (cmd *XInfoStreamFullCmd) Result() (*XInfoStreamFull, error)

+ func (cmd *XInfoStreamFullCmd) SetErr(e error)

+ func (cmd *XInfoStreamFullCmd) String() string

+ func (cmd *XInfoStreamFullCmd) Val() *XInfoStreamFull

+ type XInfoStreamGroup struct

+ Consumers []XInfoStreamConsumer

+ LastDeliveredID string

+ Name string

+ PelCount int64

+ Pending []XInfoStreamGroupPending

+ type XInfoStreamGroupPending struct

+ Consumer string

+ DeliveryCount int64

+ DeliveryTime time.Time

+ ID string

v8.8.3

May 15, 2021

Changes in this version

type Client

+ func (c Client) LPopCount(ctx context.Context, key string, count int) *StringSliceCmd

+ func (c Client) SMIsMember(ctx context.Context, key string, members ...interface{}) *BoolSliceCmd

type ClusterClient

+ func (c ClusterClient) LPopCount(ctx context.Context, key string, count int) *StringSliceCmd

+ func (c ClusterClient) SMIsMember(ctx context.Context, key string, members ...interface{}) *BoolSliceCmd

type Cmdable

+ LPopCount func(ctx context.Context, key string, count int) *StringSliceCmd

+ SMIsMember func(ctx context.Context, key string, members ...interface{}) *BoolSliceCmd

type Pipeline

+ func (c Pipeline) LPopCount(ctx context.Context, key string, count int) *StringSliceCmd

+ func (c Pipeline) SMIsMember(ctx context.Context, key string, members ...interface{}) *BoolSliceCmd

type Ring

+ func (c Ring) LPopCount(ctx context.Context, key string, count int) *StringSliceCmd

+ func (c Ring) SMIsMember(ctx context.Context, key string, members ...interface{}) *BoolSliceCmd

type Tx

+ func (c Tx) LPopCount(ctx context.Context, key string, count int) *StringSliceCmd

+ func (c Tx) SMIsMember(ctx context.Context, key string, members ...interface{}) *BoolSliceCmd

type XPendingExtArgs

+ Idle time.Duration

v8.8.2

Apr 16, 2021

v8.8.1

Apr 16, 2021

Changes in this version

type Client

+ func (c Client) GetDel(ctx context.Context, key string) *StringCmd

+ func (c Client) GetEx(ctx context.Context, key string, expiration time.Duration) *StringCmd

+ func (c Client) HRandField(ctx context.Context, key string, count int, withValues bool) *StringSliceCmd

+ func (c Client) LMove(ctx context.Context, source, destination, srcpos, destpos string) *StringCmd

+ func (c Client) ZRandMember(ctx context.Context, key string, count int, withScores bool) *StringSliceCmd

type ClusterClient

+ func (c ClusterClient) GetDel(ctx context.Context, key string) *StringCmd

+ func (c ClusterClient) GetEx(ctx context.Context, key string, expiration time.Duration) *StringCmd

+ func (c ClusterClient) HRandField(ctx context.Context, key string, count int, withValues bool) *StringSliceCmd

+ func (c ClusterClient) LMove(ctx context.Context, source, destination, srcpos, destpos string) *StringCmd

+ func (c ClusterClient) ZRandMember(ctx context.Context, key string, count int, withScores bool) *StringSliceCmd

type Cmdable

+ GetDel func(ctx context.Context, key string) *StringCmd

+ GetEx func(ctx context.Context, key string, expiration time.Duration) *StringCmd

+ HRandField func(ctx context.Context, key string, count int, withValues bool) *StringSliceCmd

+ LMove func(ctx context.Context, source, destination, srcpos, destpos string) *StringCmd

+ XInfoConsumers func(ctx context.Context, key string, group string) *XInfoConsumersCmd

+ ZRandMember func(ctx context.Context, key string, count int, withScores bool) *StringSliceCmd

type Pipeline

+ func (c Pipeline) GetDel(ctx context.Context, key string) *StringCmd

+ func (c Pipeline) GetEx(ctx context.Context, key string, expiration time.Duration) *StringCmd

+ func (c Pipeline) HRandField(ctx context.Context, key string, count int, withValues bool) *StringSliceCmd

+ func (c Pipeline) LMove(ctx context.Context, source, destination, srcpos, destpos string) *StringCmd

+ func (c Pipeline) ZRandMember(ctx context.Context, key string, count int, withScores bool) *StringSliceCmd

type Ring

+ func (c Ring) GetDel(ctx context.Context, key string) *StringCmd

+ func (c Ring) GetEx(ctx context.Context, key string, expiration time.Duration) *StringCmd

+ func (c Ring) HRandField(ctx context.Context, key string, count int, withValues bool) *StringSliceCmd

+ func (c Ring) LMove(ctx context.Context, source, destination, srcpos, destpos string) *StringCmd

+ func (c Ring) ZRandMember(ctx context.Context, key string, count int, withScores bool) *StringSliceCmd

type Tx

+ func (c Tx) GetDel(ctx context.Context, key string) *StringCmd

+ func (c Tx) GetEx(ctx context.Context, key string, expiration time.Duration) *StringCmd

+ func (c Tx) HRandField(ctx context.Context, key string, count int, withValues bool) *StringSliceCmd

+ func (c Tx) LMove(ctx context.Context, source, destination, srcpos, destpos string) *StringCmd

+ func (c Tx) ZRandMember(ctx context.Context, key string, count int, withScores bool) *StringSliceCmd

v8.8.0

Mar 23, 2021

Changes in this version

type Client

+ func (c Client) ZMScore(ctx context.Context, key string, members ...string) *FloatSliceCmd

type ClusterClient

+ func (c ClusterClient) ZMScore(ctx context.Context, key string, members ...string) *FloatSliceCmd

type Cmdable

+ ZMScore func(ctx context.Context, key string, members ...string) *FloatSliceCmd

+ type FloatSliceCmd struct

+ func NewFloatSliceCmd(ctx context.Context, args ...interface{}) *FloatSliceCmd

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

+ func (cmd *FloatSliceCmd) Err() error

+ func (cmd *FloatSliceCmd) FullName() string

+ func (cmd *FloatSliceCmd) Name() string

+ func (cmd *FloatSliceCmd) Result() ([]float64, error)

+ func (cmd *FloatSliceCmd) SetErr(e error)

+ func (cmd *FloatSliceCmd) String() string

+ func (cmd *FloatSliceCmd) Val() []float64

type Pipeline

+ func (c Pipeline) ZMScore(ctx context.Context, key string, members ...string) *FloatSliceCmd

type Ring

+ func (c Ring) ZMScore(ctx context.Context, key string, members ...string) *FloatSliceCmd

type StringCmd

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

type Tx

+ func (c Tx) ZMScore(ctx context.Context, key string, members ...string) *FloatSliceCmd

v8.7.1

Mar 5, 2021

v8.7.0

Mar 5, 2021

Changes in this version

type Cmdable

+ SetArgs func(ctx context.Context, key string, value interface{}, a SetArgs) *StatusCmd

v8.6.0

Feb 17, 2021

Changes in this version

type Client

+ func (c Client) SetArgs(ctx context.Context, key string, value interface{}, a SetArgs) *StatusCmd

+ func (c Client) XInfoConsumers(ctx context.Context, key string, group string) *XInfoConsumersCmd

type ClusterClient

+ func (c ClusterClient) SetArgs(ctx context.Context, key string, value interface{}, a SetArgs) *StatusCmd

+ func (c ClusterClient) XInfoConsumers(ctx context.Context, key string, group string) *XInfoConsumersCmd

type FailoverOptions

+ QuerySentinelRandomly bool

+ UseDisconnectedSlaves bool

type Pipeline

+ func (c Pipeline) SetArgs(ctx context.Context, key string, value interface{}, a SetArgs) *StatusCmd

+ func (c Pipeline) XInfoConsumers(ctx context.Context, key string, group string) *XInfoConsumersCmd

type Ring

+ func (c Ring) SetArgs(ctx context.Context, key string, value interface{}, a SetArgs) *StatusCmd

+ func (c Ring) XInfoConsumers(ctx context.Context, key string, group string) *XInfoConsumersCmd

+ type SetArgs struct

+ ExpireAt time.Time

+ Get bool

+ KeepTTL bool

+ Mode string

+ TTL time.Duration

type Tx

+ func (c Tx) SetArgs(ctx context.Context, key string, value interface{}, a SetArgs) *StatusCmd

+ func (c Tx) XInfoConsumers(ctx context.Context, key string, group string) *XInfoConsumersCmd

+ type XInfoConsumer struct

+ Idle int64

+ Name string

+ Pending int64

+ type XInfoConsumersCmd struct

+ func NewXInfoConsumersCmd(ctx context.Context, stream string, group string) *XInfoConsumersCmd

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

+ func (cmd *XInfoConsumersCmd) Err() error

+ func (cmd *XInfoConsumersCmd) FullName() string

+ func (cmd *XInfoConsumersCmd) Name() string

+ func (cmd *XInfoConsumersCmd) Result() ([]XInfoConsumer, error)

+ func (cmd *XInfoConsumersCmd) SetErr(e error)

+ func (cmd *XInfoConsumersCmd) String() string

+ func (cmd *XInfoConsumersCmd) Val() []XInfoConsumer

v8.5.0

Feb 4, 2021

Changes in this version

type SliceCmd

+ func (cmd *SliceCmd) Scan(dst interface{}) error

type StringStringMapCmd

+ func (cmd *StringStringMapCmd) Scan(dst interface{}) error

v8.4.11

Jan 26, 2021

Changes in this version

+ type Scripter interface

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

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

+ ScriptExists func(ctx context.Context, hashes ...string) *BoolSliceCmd

+ ScriptLoad func(ctx context.Context, script string) *StringCmd

v8.4.10

Jan 22, 2021

v8.4.9

Jan 19, 2021

v8.4.8

Jan 10, 2021

v8.4.7

Jan 9, 2021

Changes in this version

type Client

+ func (c Client) ScanType(ctx context.Context, cursor uint64, match string, count int64, keyType string) *ScanCmd

type ClusterClient

+ func (c ClusterClient) ScanType(ctx context.Context, cursor uint64, match string, count int64, keyType string) *ScanCmd

type Cmdable

+ ScanType func(ctx context.Context, cursor uint64, match string, count int64, keyType string) *ScanCmd

type Pipeline

+ func (c Pipeline) ScanType(ctx context.Context, cursor uint64, match string, count int64, keyType string) *ScanCmd

type Ring

+ func (c Ring) ScanType(ctx context.Context, cursor uint64, match string, count int64, keyType string) *ScanCmd

type Tx

+ func (c Tx) ScanType(ctx context.Context, cursor uint64, match string, count int64, keyType string) *ScanCmd

v8.4.6

Jan 9, 2021

v8.4.5

Jan 9, 2021

v8.4.4

Dec 16, 2020

Changes in this version

type ClusterClient

+ func (c *ClusterClient) SlaveForKey(ctx context.Context, key string) (*Client, error)

v8.4.3

Dec 16, 2020

Changes in this version

type ClusterClient

+ func (c *ClusterClient) MasterForKey(ctx context.Context, key string) (*Client, error)

+ func (c *ClusterClient) ReplicaForKey(ctx context.Context, key string) (*Client, error)

v8.4.2

Dec 6, 2020

v8.4.1

Dec 6, 2020

v8.4.0

Nov 21, 2020

v8.3.4

Nov 17, 2020

Changes in this version

type Client

+ func (c Client) LPos(ctx context.Context, key string, value string, a LPosArgs) *IntCmd

+ func (c Client) LPosCount(ctx context.Context, key string, value string, count int64, a LPosArgs) *IntSliceCmd

type ClusterClient

+ func (c ClusterClient) LPos(ctx context.Context, key string, value string, a LPosArgs) *IntCmd

+ func (c ClusterClient) LPosCount(ctx context.Context, key string, value string, count int64, a LPosArgs) *IntSliceCmd

type Cmdable

+ LPos func(ctx context.Context, key string, value string, args LPosArgs) *IntCmd

+ LPosCount func(ctx context.Context, key string, value string, count int64, args LPosArgs) *IntSliceCmd

+ type LPosArgs struct

+ MaxLen int64

+ Rank int64

type Pipeline

+ func (c Pipeline) LPos(ctx context.Context, key string, value string, a LPosArgs) *IntCmd

+ func (c Pipeline) LPosCount(ctx context.Context, key string, value string, count int64, a LPosArgs) *IntSliceCmd

type Ring

+ func (c Ring) LPos(ctx context.Context, key string, value string, a LPosArgs) *IntCmd

+ func (c Ring) LPosCount(ctx context.Context, key string, value string, count int64, a LPosArgs) *IntSliceCmd

type Tx

+ func (c Tx) LPos(ctx context.Context, key string, value string, a LPosArgs) *IntCmd

+ func (c Tx) LPosCount(ctx context.Context, key string, value string, count int64, a LPosArgs) *IntSliceCmd

v8.3.3

Oct 28, 2020

Changes in this version

type Client

+ func (c Client) SetEX(ctx context.Context, key string, value interface{}, expiration time.Duration) *StatusCmd

type ClusterClient

+ func (c ClusterClient) SetEX(ctx context.Context, key string, value interface{}, expiration time.Duration) *StatusCmd

type Cmdable

+ SetEX func(ctx context.Context, key string, value interface{}, expiration time.Duration) *StatusCmd

type Pipeline

+ func (c Pipeline) SetEX(ctx context.Context, key string, value interface{}, expiration time.Duration) *StatusCmd

type Ring

+ func (c Ring) SetEX(ctx context.Context, key string, value interface{}, expiration time.Duration) *StatusCmd

type Tx

+ func (c Tx) SetEX(ctx context.Context, key string, value interface{}, expiration time.Duration) *StatusCmd

v8.3.2

Oct 17, 2020

v8.3.1

Oct 13, 2020

v8.3.0

Oct 10, 2020

Changes in this version

type UniversalClient

+ PoolStats func() *PoolStats

v8.2.3

Sep 28, 2020

v8.2.2

Sep 24, 2020

v8.2.1

Sep 24, 2020

Changes in this version

type Client

+ func (c Client) XInfoStream(ctx context.Context, key string) *XInfoStreamCmd

type ClusterClient

+ func (c ClusterClient) XInfoStream(ctx context.Context, key string) *XInfoStreamCmd

type Cmdable

+ XInfoStream func(ctx context.Context, key string) *XInfoStreamCmd

type Pipeline

+ func (c Pipeline) XInfoStream(ctx context.Context, key string) *XInfoStreamCmd

type Ring

+ func (c Ring) XInfoStream(ctx context.Context, key string) *XInfoStreamCmd

type Tx

+ func (c Tx) XInfoStream(ctx context.Context, key string) *XInfoStreamCmd

+ type XInfoStream struct

+ FirstEntry XMessage

+ Groups int64

+ LastEntry XMessage

+ LastGeneratedID string

+ Length int64

+ RadixTreeKeys int64

+ RadixTreeNodes int64

+ type XInfoStreamCmd struct

+ func NewXInfoStreamCmd(ctx context.Context, stream string) *XInfoStreamCmd

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

+ func (cmd *XInfoStreamCmd) Err() error

+ func (cmd *XInfoStreamCmd) FullName() string

+ func (cmd *XInfoStreamCmd) Name() string

+ func (cmd *XInfoStreamCmd) Result() (*XInfoStream, error)

+ func (cmd *XInfoStreamCmd) SetErr(e error)

+ func (cmd *XInfoStreamCmd) String() string

+ func (cmd *XInfoStreamCmd) Val() *XInfoStream

v8.2.0

Sep 23, 2020

Changes in this version

+ type XInfoGroup struct

+ Consumers int64

+ LastDeliveredID string

+ Name string

+ Pending int64

v8.1.3

Sep 18, 2020

Changes in this version

+ const KeepTTL

v8.1.2

Sep 18, 2020

v8.1.1

Sep 17, 2020

v8.1.0

Sep 17, 2020

Changes in this version

type SentinelClient

+ func (hs *SentinelClient) AddHook(hook Hook)

v8.0.0

Sep 14, 2020

Changes in this version

+ const Nil

+ const TxFailedErr

+ var ErrClosed = pool.ErrClosed

+ func SetLogger(logger internal.Logging)

+ type BitCount struct

+ End int64

+ Start int64

+ type BoolCmd struct

+ func NewBoolCmd(ctx context.Context, args ...interface{}) *BoolCmd

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

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

+ func (cmd *BoolCmd) Err() error

+ func (cmd *BoolCmd) FullName() string

+ func (cmd *BoolCmd) Name() string

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

+ func (cmd *BoolCmd) SetErr(e error)

+ func (cmd *BoolCmd) String() string

+ func (cmd *BoolCmd) Val() bool

+ type BoolSliceCmd struct

+ func NewBoolSliceCmd(ctx context.Context, args ...interface{}) *BoolSliceCmd

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

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

+ func (cmd *BoolSliceCmd) Err() error

+ func (cmd *BoolSliceCmd) FullName() string

+ func (cmd *BoolSliceCmd) Name() string

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

+ func (cmd *BoolSliceCmd) SetErr(e 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) Conn(ctx context.Context) *Conn

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

+ func (c *Client) Do(ctx context.Context, args ...interface{}) *Cmd

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

+ func (c *Client) PSubscribe(ctx context.Context, channels ...string) *PubSub

+ func (c *Client) Pipeline() Pipeliner

+ func (c *Client) Pipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error)

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

+ func (c *Client) Process(ctx context.Context, cmd Cmder) error

+ func (c *Client) Subscribe(ctx context.Context, channels ...string) *PubSub

+ func (c *Client) TxPipeline() Pipeliner

+ func (c *Client) TxPipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error)

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

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

+ func (c *Client) WithTimeout(timeout time.Duration) *Client

+ func (c Client) Append(ctx context.Context, key, value string) *IntCmd

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

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

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

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

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

+ func (c Client) BgRewriteAOF(ctx context.Context) *StatusCmd

+ func (c Client) BgSave(ctx context.Context) *StatusCmd

+ func (c Client) BitCount(ctx context.Context, key string, bitCount *BitCount) *IntCmd

+ func (c Client) BitField(ctx context.Context, key string, args ...interface{}) *IntSliceCmd

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

+ func (c Client) BitOpNot(ctx context.Context, destKey string, key string) *IntCmd

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

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

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

+ func (c Client) ClientGetName(ctx context.Context) *StringCmd

+ func (c Client) ClientID(ctx context.Context) *IntCmd

+ func (c Client) ClientKill(ctx context.Context, ipPort string) *StatusCmd

+ func (c Client) ClientKillByFilter(ctx context.Context, keys ...string) *IntCmd

+ func (c Client) ClientList(ctx context.Context) *StringCmd

+ func (c Client) ClientPause(ctx context.Context, dur time.Duration) *BoolCmd

+ func (c Client) ClientUnblock(ctx context.Context, id int64) *IntCmd

+ func (c Client) ClientUnblockWithError(ctx context.Context, id int64) *IntCmd

+ func (c Client) Close() error

+ func (c Client) ClusterAddSlots(ctx context.Context, slots ...int) *StatusCmd

+ func (c Client) ClusterAddSlotsRange(ctx context.Context, min, max int) *StatusCmd

+ func (c Client) ClusterCountFailureReports(ctx context.Context, nodeID string) *IntCmd

+ func (c Client) ClusterCountKeysInSlot(ctx context.Context, slot int) *IntCmd

+ func (c Client) ClusterDelSlots(ctx context.Context, slots ...int) *StatusCmd

+ func (c Client) ClusterDelSlotsRange(ctx context.Context, min, max int) *StatusCmd

+ func (c Client) ClusterFailover(ctx context.Context) *StatusCmd

+ func (c Client) ClusterForget(ctx context.Context, nodeID string) *StatusCmd

+ func (c Client) ClusterGetKeysInSlot(ctx context.Context, slot int, count int) *StringSliceCmd

+ func (c Client) ClusterInfo(ctx context.Context) *StringCmd

+ func (c Client) ClusterKeySlot(ctx context.Context, key string) *IntCmd

+ func (c Client) ClusterMeet(ctx context.Context, host, port string) *StatusCmd

+ func (c Client) ClusterNodes(ctx context.Context) *StringCmd

+ func (c Client) ClusterReplicate(ctx context.Context, nodeID string) *StatusCmd

+ func (c Client) ClusterResetHard(ctx context.Context) *StatusCmd

+ func (c Client) ClusterResetSoft(ctx context.Context) *StatusCmd

+ func (c Client) ClusterSaveConfig(ctx context.Context) *StatusCmd

+ func (c Client) ClusterSlaves(ctx context.Context, nodeID string) *StringSliceCmd

+ func (c Client) ClusterSlots(ctx context.Context) *ClusterSlotsCmd

+ func (c Client) Command(ctx context.Context) *CommandsInfoCmd

+ func (c Client) ConfigGet(ctx context.Context, parameter string) *SliceCmd

+ func (c Client) ConfigResetStat(ctx context.Context) *StatusCmd

+ func (c Client) ConfigRewrite(ctx context.Context) *StatusCmd

+ func (c Client) ConfigSet(ctx context.Context, parameter, value string) *StatusCmd

+ func (c Client) DBSize(ctx context.Context) *IntCmd

+ func (c Client) DebugObject(ctx context.Context, key string) *StringCmd

+ func (c Client) Decr(ctx context.Context, key string) *IntCmd

+ func (c Client) DecrBy(ctx context.Context, key string, decrement int64) *IntCmd

+ func (c Client) Del(ctx context.Context, keys ...string) *IntCmd

+ func (c Client) Dump(ctx context.Context, key string) *StringCmd

+ func (c Client) Echo(ctx context.Context, message interface{}) *StringCmd

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

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

+ func (c Client) Exists(ctx context.Context, keys ...string) *IntCmd

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

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

+ func (c Client) FlushAll(ctx context.Context) *StatusCmd

+ func (c Client) FlushAllAsync(ctx context.Context) *StatusCmd

+ func (c Client) FlushDB(ctx context.Context) *StatusCmd

+ func (c Client) FlushDBAsync(ctx context.Context) *StatusCmd

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

+ func (c Client) GeoDist(ctx context.Context, key string, member1, member2, unit string) *FloatCmd

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

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

+ func (c Client) GeoRadius(ctx context.Context, key string, longitude, latitude float64, ...) *GeoLocationCmd

+ func (c Client) GeoRadiusByMember(ctx context.Context, key, member string, query *GeoRadiusQuery) *GeoLocationCmd

+ func (c Client) GeoRadiusByMemberStore(ctx context.Context, key, member string, query *GeoRadiusQuery) *IntCmd

+ func (c Client) GeoRadiusStore(ctx context.Context, key string, longitude, latitude float64, ...) *IntCmd

+ func (c Client) Get(ctx context.Context, key string) *StringCmd

+ func (c Client) GetBit(ctx context.Context, key string, offset int64) *IntCmd

+ func (c Client) GetRange(ctx context.Context, key string, start, end int64) *StringCmd

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

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

+ func (c Client) HExists(ctx context.Context, key, field string) *BoolCmd

+ func (c Client) HGet(ctx context.Context, key, field string) *StringCmd

+ func (c Client) HGetAll(ctx context.Context, key string) *StringStringMapCmd

+ func (c Client) HIncrBy(ctx context.Context, key, field string, incr int64) *IntCmd

+ func (c Client) HIncrByFloat(ctx context.Context, key, field string, incr float64) *FloatCmd

+ func (c Client) HKeys(ctx context.Context, key string) *StringSliceCmd

+ func (c Client) HLen(ctx context.Context, key string) *IntCmd

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

+ func (c Client) HMSet(ctx context.Context, key string, values ...interface{}) *BoolCmd

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

+ func (c Client) HSet(ctx context.Context, key string, values ...interface{}) *IntCmd

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

+ func (c Client) HVals(ctx context.Context, key string) *StringSliceCmd

+ func (c Client) Incr(ctx context.Context, key string) *IntCmd

+ func (c Client) IncrBy(ctx context.Context, key string, value int64) *IntCmd

+ func (c Client) IncrByFloat(ctx context.Context, key string, value float64) *FloatCmd

+ func (c Client) Info(ctx context.Context, section ...string) *StringCmd

+ func (c Client) Keys(ctx context.Context, pattern string) *StringSliceCmd

+ func (c Client) LIndex(ctx context.Context, key string, index int64) *StringCmd

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

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

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

+ func (c Client) LLen(ctx context.Context, key string) *IntCmd

+ func (c Client) LPop(ctx context.Context, key string) *StringCmd

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

+ func (c Client) LPushX(ctx context.Context, key string, values ...interface{}) *IntCmd

+ func (c Client) LRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd

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

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

+ func (c Client) LTrim(ctx context.Context, key string, start, stop int64) *StatusCmd

+ func (c Client) LastSave(ctx context.Context) *IntCmd

+ func (c Client) MGet(ctx context.Context, keys ...string) *SliceCmd

+ func (c Client) MSet(ctx context.Context, values ...interface{}) *StatusCmd

+ func (c Client) MSetNX(ctx context.Context, values ...interface{}) *BoolCmd

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

+ func (c Client) Migrate(ctx context.Context, host, port, key string, db int, timeout time.Duration) *StatusCmd

+ func (c Client) Move(ctx context.Context, key string, db int) *BoolCmd

+ func (c Client) ObjectEncoding(ctx context.Context, key string) *StringCmd

+ func (c Client) ObjectIdleTime(ctx context.Context, key string) *DurationCmd

+ func (c Client) ObjectRefCount(ctx context.Context, key string) *IntCmd

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

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

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

+ func (c Client) PFCount(ctx context.Context, keys ...string) *IntCmd

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

+ func (c Client) PTTL(ctx context.Context, key string) *DurationCmd

+ func (c Client) Persist(ctx context.Context, key string) *BoolCmd

+ func (c Client) Ping(ctx context.Context) *StatusCmd

+ func (c Client) PubSubChannels(ctx context.Context, pattern string) *StringSliceCmd

+ func (c Client) PubSubNumPat(ctx context.Context) *IntCmd

+ func (c Client) PubSubNumSub(ctx context.Context, channels ...string) *StringIntMapCmd

+ func (c Client) Publish(ctx context.Context, channel string, message interface{}) *IntCmd

+ func (c Client) Quit(ctx context.Context) *StatusCmd

+ func (c Client) RPop(ctx context.Context, key string) *StringCmd

+ func (c Client) RPopLPush(ctx context.Context, source, destination string) *StringCmd

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

+ func (c Client) RPushX(ctx context.Context, key string, values ...interface{}) *IntCmd

+ func (c Client) RandomKey(ctx context.Context) *StringCmd

+ func (c Client) ReadOnly(ctx context.Context) *StatusCmd

+ func (c Client) ReadWrite(ctx context.Context) *StatusCmd

+ func (c Client) Rename(ctx context.Context, key, newkey string) *StatusCmd

+ func (c Client) RenameNX(ctx context.Context, key, newkey string) *BoolCmd

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

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

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

+ func (c Client) SCard(ctx context.Context, key string) *IntCmd

+ func (c Client) SDiff(ctx context.Context, keys ...string) *StringSliceCmd

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

+ func (c Client) SInter(ctx context.Context, keys ...string) *StringSliceCmd

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

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

+ func (c Client) SMembers(ctx context.Context, key string) *StringSliceCmd

+ func (c Client) SMembersMap(ctx context.Context, key string) *StringStructMapCmd

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

+ func (c Client) SPop(ctx context.Context, key string) *StringCmd

+ func (c Client) SPopN(ctx context.Context, key string, count int64) *StringSliceCmd

+ func (c Client) SRandMember(ctx context.Context, key string) *StringCmd

+ func (c Client) SRandMemberN(ctx context.Context, key string, count int64) *StringSliceCmd

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

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

+ func (c Client) SUnion(ctx context.Context, keys ...string) *StringSliceCmd

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

+ func (c Client) Save(ctx context.Context) *StatusCmd

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

+ func (c Client) ScriptExists(ctx context.Context, hashes ...string) *BoolSliceCmd

+ func (c Client) ScriptFlush(ctx context.Context) *StatusCmd

+ func (c Client) ScriptKill(ctx context.Context) *StatusCmd

+ func (c Client) ScriptLoad(ctx context.Context, script string) *StringCmd

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

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

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

+ func (c Client) SetRange(ctx context.Context, key string, offset int64, value string) *IntCmd

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

+ func (c Client) Shutdown(ctx context.Context) *StatusCmd

+ func (c Client) ShutdownNoSave(ctx context.Context) *StatusCmd

+ func (c Client) ShutdownSave(ctx context.Context) *StatusCmd

+ func (c Client) SlaveOf(ctx context.Context, host, port string) *StatusCmd

+ func (c Client) SlowLogGet(ctx context.Context, num int64) *SlowLogCmd

+ func (c Client) Sort(ctx context.Context, key string, sort *Sort) *StringSliceCmd

+ func (c Client) SortInterfaces(ctx context.Context, key string, sort *Sort) *SliceCmd

+ func (c Client) SortStore(ctx context.Context, key, store string, sort *Sort) *IntCmd

+ func (c Client) StrLen(ctx context.Context, key string) *IntCmd

+ func (c Client) String() string

+ func (c Client) Sync(ctx context.Context)

+ func (c Client) TTL(ctx context.Context, key string) *DurationCmd

+ func (c Client) Time(ctx context.Context) *TimeCmd

+ func (c Client) Touch(ctx context.Context, keys ...string) *IntCmd

+ func (c Client) Type(ctx context.Context, key string) *StatusCmd

+ func (c Client) Unlink(ctx context.Context, keys ...string) *IntCmd

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

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

+ func (c Client) XAdd(ctx context.Context, a *XAddArgs) *StringCmd

+ func (c Client) XClaim(ctx context.Context, a *XClaimArgs) *XMessageSliceCmd

+ func (c Client) XClaimJustID(ctx context.Context, a *XClaimArgs) *StringSliceCmd

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

+ func (c Client) XGroupCreate(ctx context.Context, stream, group, start string) *StatusCmd

+ func (c Client) XGroupCreateMkStream(ctx context.Context, stream, group, start string) *StatusCmd

+ func (c Client) XGroupDelConsumer(ctx context.Context, stream, group, consumer string) *IntCmd

+ func (c Client) XGroupDestroy(ctx context.Context, stream, group string) *IntCmd

+ func (c Client) XGroupSetID(ctx context.Context, stream, group, start string) *StatusCmd

+ func (c Client) XInfoGroups(ctx context.Context, key string) *XInfoGroupsCmd

+ func (c Client) XLen(ctx context.Context, stream string) *IntCmd

+ func (c Client) XPending(ctx context.Context, stream, group string) *XPendingCmd

+ func (c Client) XPendingExt(ctx context.Context, a *XPendingExtArgs) *XPendingExtCmd

+ func (c Client) XRange(ctx context.Context, stream, start, stop string) *XMessageSliceCmd

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

+ func (c Client) XRead(ctx context.Context, a *XReadArgs) *XStreamSliceCmd

+ func (c Client) XReadGroup(ctx context.Context, a *XReadGroupArgs) *XStreamSliceCmd

+ func (c Client) XReadStreams(ctx context.Context, streams ...string) *XStreamSliceCmd

+ func (c Client) XRevRange(ctx context.Context, stream, start, stop string) *XMessageSliceCmd

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

+ func (c Client) XTrim(ctx context.Context, key string, maxLen int64) *IntCmd

+ func (c Client) XTrimApprox(ctx context.Context, key string, maxLen int64) *IntCmd

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

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

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

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

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

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

+ func (c Client) ZCard(ctx context.Context, key string) *IntCmd

+ func (c Client) ZCount(ctx context.Context, key, min, max string) *IntCmd

+ func (c Client) ZIncr(ctx context.Context, key string, member *Z) *FloatCmd

+ func (c Client) ZIncrBy(ctx context.Context, key string, increment float64, member string) *FloatCmd

+ func (c Client) ZIncrNX(ctx context.Context, key string, member *Z) *FloatCmd

+ func (c Client) ZIncrXX(ctx context.Context, key string, member *Z) *FloatCmd

+ func (c Client) ZInterStore(ctx context.Context, destination string, store *ZStore) *IntCmd

+ func (c Client) ZLexCount(ctx context.Context, key, min, max string) *IntCmd

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

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

+ func (c Client) ZRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd

+ func (c Client) ZRangeByLex(ctx context.Context, key string, opt *ZRangeBy) *StringSliceCmd

+ func (c Client) ZRangeByScore(ctx context.Context, key string, opt *ZRangeBy) *StringSliceCmd

+ func (c Client) ZRangeByScoreWithScores(ctx context.Context, key string, opt *ZRangeBy) *ZSliceCmd

+ func (c Client) ZRangeWithScores(ctx context.Context, key string, start, stop int64) *ZSliceCmd

+ func (c Client) ZRank(ctx context.Context, key, member string) *IntCmd

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

+ func (c Client) ZRemRangeByLex(ctx context.Context, key, min, max string) *IntCmd

+ func (c Client) ZRemRangeByRank(ctx context.Context, key string, start, stop int64) *IntCmd

+ func (c Client) ZRemRangeByScore(ctx context.Context, key, min, max string) *IntCmd

+ func (c Client) ZRevRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd

+ func (c Client) ZRevRangeByLex(ctx context.Context, key string, opt *ZRangeBy) *StringSliceCmd

+ func (c Client) ZRevRangeByScore(ctx context.Context, key string, opt *ZRangeBy) *StringSliceCmd

+ func (c Client) ZRevRangeByScoreWithScores(ctx context.Context, key string, opt *ZRangeBy) *ZSliceCmd

+ func (c Client) ZRevRangeWithScores(ctx context.Context, key string, start, stop int64) *ZSliceCmd

+ func (c Client) ZRevRank(ctx context.Context, key, member string) *IntCmd

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

+ func (c Client) ZScore(ctx context.Context, key, member string) *FloatCmd

+ func (c Client) ZUnionStore(ctx context.Context, dest string, store *ZStore) *IntCmd

+ func (hs *Client) AddHook(hook Hook)

+ type ClusterClient struct

+ func NewClusterClient(opt *ClusterOptions) *ClusterClient

+ func NewFailoverClusterClient(failoverOpt *FailoverOptions) *ClusterClient

+ func (c *ClusterClient) Close() error

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

+ func (c *ClusterClient) DBSize(ctx context.Context) *IntCmd

+ func (c *ClusterClient) Do(ctx context.Context, args ...interface{}) *Cmd

+ func (c *ClusterClient) ForEachMaster(ctx context.Context, fn func(ctx context.Context, client *Client) error) error

+ func (c *ClusterClient) ForEachShard(ctx context.Context, fn func(ctx context.Context, client *Client) error) error

+ func (c *ClusterClient) ForEachSlave(ctx context.Context, fn func(ctx context.Context, client *Client) error) error

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

+ func (c *ClusterClient) PSubscribe(ctx context.Context, channels ...string) *PubSub

+ func (c *ClusterClient) Pipeline() Pipeliner

+ func (c *ClusterClient) Pipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error)

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

+ func (c *ClusterClient) Process(ctx context.Context, cmd Cmder) error

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

+ func (c *ClusterClient) Subscribe(ctx context.Context, channels ...string) *PubSub

+ func (c *ClusterClient) TxPipeline() Pipeliner

+ func (c *ClusterClient) TxPipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error)

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

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

+ func (c ClusterClient) Append(ctx context.Context, key, value string) *IntCmd

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

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

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

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

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

+ func (c ClusterClient) BgRewriteAOF(ctx context.Context) *StatusCmd

+ func (c ClusterClient) BgSave(ctx context.Context) *StatusCmd

+ func (c ClusterClient) BitCount(ctx context.Context, key string, bitCount *BitCount) *IntCmd

+ func (c ClusterClient) BitField(ctx context.Context, key string, args ...interface{}) *IntSliceCmd

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

+ func (c ClusterClient) BitOpNot(ctx context.Context, destKey string, key string) *IntCmd

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

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

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

+ func (c ClusterClient) ClientGetName(ctx context.Context) *StringCmd

+ func (c ClusterClient) ClientID(ctx context.Context) *IntCmd

+ func (c ClusterClient) ClientKill(ctx context.Context, ipPort string) *StatusCmd

+ func (c ClusterClient) ClientKillByFilter(ctx context.Context, keys ...string) *IntCmd

+ func (c ClusterClient) ClientList(ctx context.Context) *StringCmd

+ func (c ClusterClient) ClientPause(ctx context.Context, dur time.Duration) *BoolCmd

+ func (c ClusterClient) ClientUnblock(ctx context.Context, id int64) *IntCmd

+ func (c ClusterClient) ClientUnblockWithError(ctx context.Context, id int64) *IntCmd

+ func (c ClusterClient) ClusterAddSlots(ctx context.Context, slots ...int) *StatusCmd

+ func (c ClusterClient) ClusterAddSlotsRange(ctx context.Context, min, max int) *StatusCmd

+ func (c ClusterClient) ClusterCountFailureReports(ctx context.Context, nodeID string) *IntCmd

+ func (c ClusterClient) ClusterCountKeysInSlot(ctx context.Context, slot int) *IntCmd

+ func (c ClusterClient) ClusterDelSlots(ctx context.Context, slots ...int) *StatusCmd

+ func (c ClusterClient) ClusterDelSlotsRange(ctx context.Context, min, max int) *StatusCmd

+ func (c ClusterClient) ClusterFailover(ctx context.Context) *StatusCmd

+ func (c ClusterClient) ClusterForget(ctx context.Context, nodeID string) *StatusCmd

+ func (c ClusterClient) ClusterGetKeysInSlot(ctx context.Context, slot int, count int) *StringSliceCmd

+ func (c ClusterClient) ClusterInfo(ctx context.Context) *StringCmd

+ func (c ClusterClient) ClusterKeySlot(ctx context.Context, key string) *IntCmd

+ func (c ClusterClient) ClusterMeet(ctx context.Context, host, port string) *StatusCmd

+ func (c ClusterClient) ClusterNodes(ctx context.Context) *StringCmd

+ func (c ClusterClient) ClusterReplicate(ctx context.Context, nodeID string) *StatusCmd

+ func (c ClusterClient) ClusterResetHard(ctx context.Context) *StatusCmd

+ func (c ClusterClient) ClusterResetSoft(ctx context.Context) *StatusCmd

+ func (c ClusterClient) ClusterSaveConfig(ctx context.Context) *StatusCmd

+ func (c ClusterClient) ClusterSlaves(ctx context.Context, nodeID string) *StringSliceCmd

+ func (c ClusterClient) ClusterSlots(ctx context.Context) *ClusterSlotsCmd

+ func (c ClusterClient) Command(ctx context.Context) *CommandsInfoCmd

+ func (c ClusterClient) ConfigGet(ctx context.Context, parameter string) *SliceCmd

+ func (c ClusterClient) ConfigResetStat(ctx context.Context) *StatusCmd

+ func (c ClusterClient) ConfigRewrite(ctx context.Context) *StatusCmd

+ func (c ClusterClient) ConfigSet(ctx context.Context, parameter, value string) *StatusCmd

+ func (c ClusterClient) DebugObject(ctx context.Context, key string) *StringCmd

+ func (c ClusterClient) Decr(ctx context.Context, key string) *IntCmd

+ func (c ClusterClient) DecrBy(ctx context.Context, key string, decrement int64) *IntCmd

+ func (c ClusterClient) Del(ctx context.Context, keys ...string) *IntCmd

+ func (c ClusterClient) Dump(ctx context.Context, key string) *StringCmd

+ func (c ClusterClient) Echo(ctx context.Context, message interface{}) *StringCmd

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

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

+ func (c ClusterClient) Exists(ctx context.Context, keys ...string) *IntCmd

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

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

+ func (c ClusterClient) FlushAll(ctx context.Context) *StatusCmd

+ func (c ClusterClient) FlushAllAsync(ctx context.Context) *StatusCmd

+ func (c ClusterClient) FlushDB(ctx context.Context) *StatusCmd

+ func (c ClusterClient) FlushDBAsync(ctx context.Context) *StatusCmd

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

+ func (c ClusterClient) GeoDist(ctx context.Context, key string, member1, member2, unit string) *FloatCmd

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

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

+ func (c ClusterClient) GeoRadius(ctx context.Context, key string, longitude, latitude float64, ...) *GeoLocationCmd

+ func (c ClusterClient) GeoRadiusByMember(ctx context.Context, key, member string, query *GeoRadiusQuery) *GeoLocationCmd

+ func (c ClusterClient) GeoRadiusByMemberStore(ctx context.Context, key, member string, query *GeoRadiusQuery) *IntCmd

+ func (c ClusterClient) GeoRadiusStore(ctx context.Context, key string, longitude, latitude float64, ...) *IntCmd

+ func (c ClusterClient) Get(ctx context.Context, key string) *StringCmd

+ func (c ClusterClient) GetBit(ctx context.Context, key string, offset int64) *IntCmd

+ func (c ClusterClient) GetRange(ctx context.Context, key string, start, end int64) *StringCmd

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

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

+ func (c ClusterClient) HExists(ctx context.Context, key, field string) *BoolCmd

+ func (c ClusterClient) HGet(ctx context.Context, key, field string) *StringCmd

+ func (c ClusterClient) HGetAll(ctx context.Context, key string) *StringStringMapCmd

+ func (c ClusterClient) HIncrBy(ctx context.Context, key, field string, incr int64) *IntCmd

+ func (c ClusterClient) HIncrByFloat(ctx context.Context, key, field string, incr float64) *FloatCmd

+ func (c ClusterClient) HKeys(ctx context.Context, key string) *StringSliceCmd

+ func (c ClusterClient) HLen(ctx context.Context, key string) *IntCmd

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

+ func (c ClusterClient) HMSet(ctx context.Context, key string, values ...interface{}) *BoolCmd

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

+ func (c ClusterClient) HSet(ctx context.Context, key string, values ...interface{}) *IntCmd

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

+ func (c ClusterClient) HVals(ctx context.Context, key string) *StringSliceCmd

+ func (c ClusterClient) Incr(ctx context.Context, key string) *IntCmd

+ func (c ClusterClient) IncrBy(ctx context.Context, key string, value int64) *IntCmd

+ func (c ClusterClient) IncrByFloat(ctx context.Context, key string, value float64) *FloatCmd

+ func (c ClusterClient) Info(ctx context.Context, section ...string) *StringCmd

+ func (c ClusterClient) Keys(ctx context.Context, pattern string) *StringSliceCmd

+ func (c ClusterClient) LIndex(ctx context.Context, key string, index int64) *StringCmd

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

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

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

+ func (c ClusterClient) LLen(ctx context.Context, key string) *IntCmd

+ func (c ClusterClient) LPop(ctx context.Context, key string) *StringCmd

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

+ func (c ClusterClient) LPushX(ctx context.Context, key string, values ...interface{}) *IntCmd

+ func (c ClusterClient) LRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd

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

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

+ func (c ClusterClient) LTrim(ctx context.Context, key string, start, stop int64) *StatusCmd

+ func (c ClusterClient) LastSave(ctx context.Context) *IntCmd

+ func (c ClusterClient) MGet(ctx context.Context, keys ...string) *SliceCmd

+ func (c ClusterClient) MSet(ctx context.Context, values ...interface{}) *StatusCmd

+ func (c ClusterClient) MSetNX(ctx context.Context, values ...interface{}) *BoolCmd

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

+ func (c ClusterClient) Migrate(ctx context.Context, host, port, key string, db int, timeout time.Duration) *StatusCmd

+ func (c ClusterClient) Move(ctx context.Context, key string, db int) *BoolCmd

+ func (c ClusterClient) ObjectEncoding(ctx context.Context, key string) *StringCmd

+ func (c ClusterClient) ObjectIdleTime(ctx context.Context, key string) *DurationCmd

+ func (c ClusterClient) ObjectRefCount(ctx context.Context, key string) *IntCmd

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

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

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

+ func (c ClusterClient) PFCount(ctx context.Context, keys ...string) *IntCmd

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

+ func (c ClusterClient) PTTL(ctx context.Context, key string) *DurationCmd

+ func (c ClusterClient) Persist(ctx context.Context, key string) *BoolCmd

+ func (c ClusterClient) Ping(ctx context.Context) *StatusCmd

+ func (c ClusterClient) PubSubChannels(ctx context.Context, pattern string) *StringSliceCmd

+ func (c ClusterClient) PubSubNumPat(ctx context.Context) *IntCmd

+ func (c ClusterClient) PubSubNumSub(ctx context.Context, channels ...string) *StringIntMapCmd

+ func (c ClusterClient) Publish(ctx context.Context, channel string, message interface{}) *IntCmd

+ func (c ClusterClient) Quit(ctx context.Context) *StatusCmd

+ func (c ClusterClient) RPop(ctx context.Context, key string) *StringCmd

+ func (c ClusterClient) RPopLPush(ctx context.Context, source, destination string) *StringCmd

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

+ func (c ClusterClient) RPushX(ctx context.Context, key string, values ...interface{}) *IntCmd

+ func (c ClusterClient) RandomKey(ctx context.Context) *StringCmd

+ func (c ClusterClient) ReadOnly(ctx context.Context) *StatusCmd

+ func (c ClusterClient) ReadWrite(ctx context.Context) *StatusCmd

+ func (c ClusterClient) Rename(ctx context.Context, key, newkey string) *StatusCmd

+ func (c ClusterClient) RenameNX(ctx context.Context, key, newkey string) *BoolCmd

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

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

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

+ func (c ClusterClient) SCard(ctx context.Context, key string) *IntCmd

+ func (c ClusterClient) SDiff(ctx context.Context, keys ...string) *StringSliceCmd

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

+ func (c ClusterClient) SInter(ctx context.Context, keys ...string) *StringSliceCmd

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

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

+ func (c ClusterClient) SMembers(ctx context.Context, key string) *StringSliceCmd

+ func (c ClusterClient) SMembersMap(ctx context.Context, key string) *StringStructMapCmd

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

+ func (c ClusterClient) SPop(ctx context.Context, key string) *StringCmd

+ func (c ClusterClient) SPopN(ctx context.Context, key string, count int64) *StringSliceCmd

+ func (c ClusterClient) SRandMember(ctx context.Context, key string) *StringCmd

+ func (c ClusterClient) SRandMemberN(ctx context.Context, key string, count int64) *StringSliceCmd

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

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

+ func (c ClusterClient) SUnion(ctx context.Context, keys ...string) *StringSliceCmd

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

+ func (c ClusterClient) Save(ctx context.Context) *StatusCmd

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

+ func (c ClusterClient) ScriptExists(ctx context.Context, hashes ...string) *BoolSliceCmd

+ func (c ClusterClient) ScriptFlush(ctx context.Context) *StatusCmd

+ func (c ClusterClient) ScriptKill(ctx context.Context) *StatusCmd

+ func (c ClusterClient) ScriptLoad(ctx context.Context, script string) *StringCmd

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

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

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

+ func (c ClusterClient) SetRange(ctx context.Context, key string, offset int64, value string) *IntCmd

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

+ func (c ClusterClient) Shutdown(ctx context.Context) *StatusCmd

+ func (c ClusterClient) ShutdownNoSave(ctx context.Context) *StatusCmd

+ func (c ClusterClient) ShutdownSave(ctx context.Context) *StatusCmd

+ func (c ClusterClient) SlaveOf(ctx context.Context, host, port string) *StatusCmd

+ func (c ClusterClient) SlowLogGet(ctx context.Context, num int64) *SlowLogCmd

+ func (c ClusterClient) Sort(ctx context.Context, key string, sort *Sort) *StringSliceCmd

+ func (c ClusterClient) SortInterfaces(ctx context.Context, key string, sort *Sort) *SliceCmd

+ func (c ClusterClient) SortStore(ctx context.Context, key, store string, sort *Sort) *IntCmd

+ func (c ClusterClient) StrLen(ctx context.Context, key string) *IntCmd

+ func (c ClusterClient) Sync(ctx context.Context)

+ func (c ClusterClient) TTL(ctx context.Context, key string) *DurationCmd

+ func (c ClusterClient) Time(ctx context.Context) *TimeCmd

+ func (c ClusterClient) Touch(ctx context.Context, keys ...string) *IntCmd

+ func (c ClusterClient) Type(ctx context.Context, key string) *StatusCmd

+ func (c ClusterClient) Unlink(ctx context.Context, keys ...string) *IntCmd

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

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

+ func (c ClusterClient) XAdd(ctx context.Context, a *XAddArgs) *StringCmd

+ func (c ClusterClient) XClaim(ctx context.Context, a *XClaimArgs) *XMessageSliceCmd

+ func (c ClusterClient) XClaimJustID(ctx context.Context, a *XClaimArgs) *StringSliceCmd

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

+ func (c ClusterClient) XGroupCreate(ctx context.Context, stream, group, start string) *StatusCmd

+ func (c ClusterClient) XGroupCreateMkStream(ctx context.Context, stream, group, start string) *StatusCmd

+ func (c ClusterClient) XGroupDelConsumer(ctx context.Context, stream, group, consumer string) *IntCmd

+ func (c ClusterClient) XGroupDestroy(ctx context.Context, stream, group string) *IntCmd

+ func (c ClusterClient) XGroupSetID(ctx context.Context, stream, group, start string) *StatusCmd

+ func (c ClusterClient) XInfoGroups(ctx context.Context, key string) *XInfoGroupsCmd

+ func (c ClusterClient) XLen(ctx context.Context, stream string) *IntCmd

+ func (c ClusterClient) XPending(ctx context.Context, stream, group string) *XPendingCmd

+ func (c ClusterClient) XPendingExt(ctx context.Context, a *XPendingExtArgs) *XPendingExtCmd

+ func (c ClusterClient) XRange(ctx context.Context, stream, start, stop string) *XMessageSliceCmd

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

+ func (c ClusterClient) XRead(ctx context.Context, a *XReadArgs) *XStreamSliceCmd

+ func (c ClusterClient) XReadGroup(ctx context.Context, a *XReadGroupArgs) *XStreamSliceCmd

+ func (c ClusterClient) XReadStreams(ctx context.Context, streams ...string) *XStreamSliceCmd

+ func (c ClusterClient) XRevRange(ctx context.Context, stream, start, stop string) *XMessageSliceCmd

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

+ func (c ClusterClient) XTrim(ctx context.Context, key string, maxLen int64) *IntCmd

+ func (c ClusterClient) XTrimApprox(ctx context.Context, key string, maxLen int64) *IntCmd

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

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

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

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

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

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

+ func (c ClusterClient) ZCard(ctx context.Context, key string) *IntCmd

+ func (c ClusterClient) ZCount(ctx context.Context, key, min, max string) *IntCmd

+ func (c ClusterClient) ZIncr(ctx context.Context, key string, member *Z) *FloatCmd

+ func (c ClusterClient) ZIncrBy(ctx context.Context, key string, increment float64, member string) *FloatCmd

+ func (c ClusterClient) ZIncrNX(ctx context.Context, key string, member *Z) *FloatCmd

+ func (c ClusterClient) ZIncrXX(ctx context.Context, key string, member *Z) *FloatCmd

+ func (c ClusterClient) ZInterStore(ctx context.Context, destination string, store *ZStore) *IntCmd

+ func (c ClusterClient) ZLexCount(ctx context.Context, key, min, max string) *IntCmd

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

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

+ func (c ClusterClient) ZRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd

+ func (c ClusterClient) ZRangeByLex(ctx context.Context, key string, opt *ZRangeBy) *StringSliceCmd

+ func (c ClusterClient) ZRangeByScore(ctx context.Context, key string, opt *ZRangeBy) *StringSliceCmd

+ func (c ClusterClient) ZRangeByScoreWithScores(ctx context.Context, key string, opt *ZRangeBy) *ZSliceCmd

+ func (c ClusterClient) ZRangeWithScores(ctx context.Context, key string, start, stop int64) *ZSliceCmd

+ func (c ClusterClient) ZRank(ctx context.Context, key, member string) *IntCmd

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

+ func (c ClusterClient) ZRemRangeByLex(ctx context.Context, key, min, max string) *IntCmd

+ func (c ClusterClient) ZRemRangeByRank(ctx context.Context, key string, start, stop int64) *IntCmd

+ func (c ClusterClient) ZRemRangeByScore(ctx context.Context, key, min, max string) *IntCmd

+ func (c ClusterClient) ZRevRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd

+ func (c ClusterClient) ZRevRangeByLex(ctx context.Context, key string, opt *ZRangeBy) *StringSliceCmd

+ func (c ClusterClient) ZRevRangeByScore(ctx context.Context, key string, opt *ZRangeBy) *StringSliceCmd

+ func (c ClusterClient) ZRevRangeByScoreWithScores(ctx context.Context, key string, opt *ZRangeBy) *ZSliceCmd

+ func (c ClusterClient) ZRevRangeWithScores(ctx context.Context, key string, start, stop int64) *ZSliceCmd

+ func (c ClusterClient) ZRevRank(ctx context.Context, key, member string) *IntCmd

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

+ func (c ClusterClient) ZScore(ctx context.Context, key, member string) *FloatCmd

+ func (c ClusterClient) ZUnionStore(ctx context.Context, dest string, store *ZStore) *IntCmd

+ func (hs *ClusterClient) AddHook(hook Hook)

+ type ClusterNode struct

+ Addr string

+ ID string

+ type ClusterOptions struct

+ Addrs []string

+ ClusterSlots func(context.Context) ([]ClusterSlot, error)

+ DialTimeout time.Duration

+ Dialer func(ctx context.Context, network, addr string) (net.Conn, error)

+ IdleCheckFrequency time.Duration

+ IdleTimeout time.Duration

+ MaxConnAge time.Duration

+ MaxRedirects int

+ MaxRetries int

+ MaxRetryBackoff time.Duration

+ MinIdleConns int

+ MinRetryBackoff time.Duration

+ NewClient func(opt *Options) *Client

+ OnConnect func(ctx context.Context, cn *Conn) error

+ Password string

+ PoolSize int

+ PoolTimeout time.Duration

+ ReadOnly bool

+ ReadTimeout time.Duration

+ RouteByLatency bool

+ RouteRandomly bool

+ TLSConfig *tls.Config

+ Username string

+ WriteTimeout time.Duration

+ type ClusterSlot struct

+ End int

+ Nodes []ClusterNode

+ Start int

+ type ClusterSlotsCmd struct

+ func NewClusterSlotsCmd(ctx context.Context, args ...interface{}) *ClusterSlotsCmd

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

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

+ func (cmd *ClusterSlotsCmd) Err() error

+ func (cmd *ClusterSlotsCmd) FullName() string

+ func (cmd *ClusterSlotsCmd) Name() string

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

+ func (cmd *ClusterSlotsCmd) SetErr(e error)

+ func (cmd *ClusterSlotsCmd) String() string

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

+ type Cmd struct

+ func NewCmd(ctx context.Context, args ...interface{}) *Cmd

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

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

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

+ func (cmd *Cmd) Err() error

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

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

+ func (cmd *Cmd) FullName() string

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

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

+ func (cmd *Cmd) Name() string

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

+ func (cmd *Cmd) SetErr(e error)

+ func (cmd *Cmd) String() string

+ func (cmd *Cmd) Text() (string, error)

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

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

+ type Cmdable interface

+ Append func(ctx context.Context, key, value string) *IntCmd

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

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

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

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

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

+ BgRewriteAOF func(ctx context.Context) *StatusCmd

+ BgSave func(ctx context.Context) *StatusCmd

+ BitCount func(ctx context.Context, key string, bitCount *BitCount) *IntCmd

+ BitField func(ctx context.Context, key string, args ...interface{}) *IntSliceCmd

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

+ BitOpNot func(ctx context.Context, destKey string, key string) *IntCmd

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

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

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

+ ClientGetName func(ctx context.Context) *StringCmd

+ ClientID func(ctx context.Context) *IntCmd

+ ClientKill func(ctx context.Context, ipPort string) *StatusCmd

+ ClientKillByFilter func(ctx context.Context, keys ...string) *IntCmd

+ ClientList func(ctx context.Context) *StringCmd

+ ClientPause func(ctx context.Context, dur time.Duration) *BoolCmd

+ ClusterAddSlots func(ctx context.Context, slots ...int) *StatusCmd

+ ClusterAddSlotsRange func(ctx context.Context, min, max int) *StatusCmd

+ ClusterCountFailureReports func(ctx context.Context, nodeID string) *IntCmd

+ ClusterCountKeysInSlot func(ctx context.Context, slot int) *IntCmd

+ ClusterDelSlots func(ctx context.Context, slots ...int) *StatusCmd

+ ClusterDelSlotsRange func(ctx context.Context, min, max int) *StatusCmd

+ ClusterFailover func(ctx context.Context) *StatusCmd

+ ClusterForget func(ctx context.Context, nodeID string) *StatusCmd

+ ClusterGetKeysInSlot func(ctx context.Context, slot int, count int) *StringSliceCmd

+ ClusterInfo func(ctx context.Context) *StringCmd

+ ClusterKeySlot func(ctx context.Context, key string) *IntCmd

+ ClusterMeet func(ctx context.Context, host, port string) *StatusCmd

+ ClusterNodes func(ctx context.Context) *StringCmd

+ ClusterReplicate func(ctx context.Context, nodeID string) *StatusCmd

+ ClusterResetHard func(ctx context.Context) *StatusCmd

+ ClusterResetSoft func(ctx context.Context) *StatusCmd

+ ClusterSaveConfig func(ctx context.Context) *StatusCmd

+ ClusterSlaves func(ctx context.Context, nodeID string) *StringSliceCmd

+ ClusterSlots func(ctx context.Context) *ClusterSlotsCmd

+ Command func(ctx context.Context) *CommandsInfoCmd

+ ConfigGet func(ctx context.Context, parameter string) *SliceCmd

+ ConfigResetStat func(ctx context.Context) *StatusCmd

+ ConfigRewrite func(ctx context.Context) *StatusCmd

+ ConfigSet func(ctx context.Context, parameter, value string) *StatusCmd

+ DBSize func(ctx context.Context) *IntCmd

+ DebugObject func(ctx context.Context, key string) *StringCmd

+ Decr func(ctx context.Context, key string) *IntCmd

+ DecrBy func(ctx context.Context, key string, decrement int64) *IntCmd

+ Del func(ctx context.Context, keys ...string) *IntCmd

+ Dump func(ctx context.Context, key string) *StringCmd

+ Echo func(ctx context.Context, message interface{}) *StringCmd

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

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

+ Exists func(ctx context.Context, keys ...string) *IntCmd

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

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

+ FlushAll func(ctx context.Context) *StatusCmd

+ FlushAllAsync func(ctx context.Context) *StatusCmd

+ FlushDB func(ctx context.Context) *StatusCmd

+ FlushDBAsync func(ctx context.Context) *StatusCmd

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

+ GeoDist func(ctx context.Context, key string, member1, member2, unit string) *FloatCmd

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

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

+ GeoRadius func(ctx context.Context, key string, longitude, latitude float64, ...) *GeoLocationCmd

+ GeoRadiusByMember func(ctx context.Context, key, member string, query *GeoRadiusQuery) *GeoLocationCmd

+ GeoRadiusByMemberStore func(ctx context.Context, key, member string, query *GeoRadiusQuery) *IntCmd

+ GeoRadiusStore func(ctx context.Context, key string, longitude, latitude float64, ...) *IntCmd

+ Get func(ctx context.Context, key string) *StringCmd

+ GetBit func(ctx context.Context, key string, offset int64) *IntCmd

+ GetRange func(ctx context.Context, key string, start, end int64) *StringCmd

+ GetSet func(ctx context.Context, key string, value interface{}) *StringCmd

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

+ HExists func(ctx context.Context, key, field string) *BoolCmd

+ HGet func(ctx context.Context, key, field string) *StringCmd

+ HGetAll func(ctx context.Context, key string) *StringStringMapCmd

+ HIncrBy func(ctx context.Context, key, field string, incr int64) *IntCmd

+ HIncrByFloat func(ctx context.Context, key, field string, incr float64) *FloatCmd

+ HKeys func(ctx context.Context, key string) *StringSliceCmd

+ HLen func(ctx context.Context, key string) *IntCmd

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

+ HMSet func(ctx context.Context, key string, values ...interface{}) *BoolCmd

+ HScan func(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd

+ HSet func(ctx context.Context, key string, values ...interface{}) *IntCmd

+ HSetNX func(ctx context.Context, key, field string, value interface{}) *BoolCmd

+ HVals func(ctx context.Context, key string) *StringSliceCmd

+ Incr func(ctx context.Context, key string) *IntCmd

+ IncrBy func(ctx context.Context, key string, value int64) *IntCmd

+ IncrByFloat func(ctx context.Context, key string, value float64) *FloatCmd

+ Info func(ctx context.Context, section ...string) *StringCmd

+ Keys func(ctx context.Context, pattern string) *StringSliceCmd

+ LIndex func(ctx context.Context, key string, index int64) *StringCmd

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

+ LInsertAfter func(ctx context.Context, key string, pivot, value interface{}) *IntCmd

+ LInsertBefore func(ctx context.Context, key string, pivot, value interface{}) *IntCmd

+ LLen func(ctx context.Context, key string) *IntCmd

+ LPop func(ctx context.Context, key string) *StringCmd

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

+ LPushX func(ctx context.Context, key string, values ...interface{}) *IntCmd

+ LRange func(ctx context.Context, key string, start, stop int64) *StringSliceCmd

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

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

+ LTrim func(ctx context.Context, key string, start, stop int64) *StatusCmd

+ LastSave func(ctx context.Context) *IntCmd

+ MGet func(ctx context.Context, keys ...string) *SliceCmd

+ MSet func(ctx context.Context, values ...interface{}) *StatusCmd

+ MSetNX func(ctx context.Context, values ...interface{}) *BoolCmd

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

+ Migrate func(ctx context.Context, host, port, key string, db int, timeout time.Duration) *StatusCmd

+ Move func(ctx context.Context, key string, db int) *BoolCmd

+ ObjectEncoding func(ctx context.Context, key string) *StringCmd

+ ObjectIdleTime func(ctx context.Context, key string) *DurationCmd

+ ObjectRefCount func(ctx context.Context, key string) *IntCmd

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

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

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

+ PFCount func(ctx context.Context, keys ...string) *IntCmd

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

+ PTTL func(ctx context.Context, key string) *DurationCmd

+ Persist func(ctx context.Context, key string) *BoolCmd

+ Ping func(ctx context.Context) *StatusCmd

+ Pipeline func() Pipeliner

+ Pipelined func(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error)

+ PubSubChannels func(ctx context.Context, pattern string) *StringSliceCmd

+ PubSubNumPat func(ctx context.Context) *IntCmd

+ PubSubNumSub func(ctx context.Context, channels ...string) *StringIntMapCmd

+ Publish func(ctx context.Context, channel string, message interface{}) *IntCmd

+ Quit func(ctx context.Context) *StatusCmd

+ RPop func(ctx context.Context, key string) *StringCmd

+ RPopLPush func(ctx context.Context, source, destination string) *StringCmd

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

+ RPushX func(ctx context.Context, key string, values ...interface{}) *IntCmd

+ RandomKey func(ctx context.Context) *StringCmd

+ ReadOnly func(ctx context.Context) *StatusCmd

+ ReadWrite func(ctx context.Context) *StatusCmd

+ Rename func(ctx context.Context, key, newkey string) *StatusCmd

+ RenameNX func(ctx context.Context, key, newkey string) *BoolCmd

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

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

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

+ SCard func(ctx context.Context, key string) *IntCmd

+ SDiff func(ctx context.Context, keys ...string) *StringSliceCmd

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

+ SInter func(ctx context.Context, keys ...string) *StringSliceCmd

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

+ SIsMember func(ctx context.Context, key string, member interface{}) *BoolCmd

+ SMembers func(ctx context.Context, key string) *StringSliceCmd

+ SMembersMap func(ctx context.Context, key string) *StringStructMapCmd

+ SMove func(ctx context.Context, source, destination string, member interface{}) *BoolCmd

+ SPop func(ctx context.Context, key string) *StringCmd

+ SPopN func(ctx context.Context, key string, count int64) *StringSliceCmd

+ SRandMember func(ctx context.Context, key string) *StringCmd

+ SRandMemberN func(ctx context.Context, key string, count int64) *StringSliceCmd

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

+ SScan func(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd

+ SUnion func(ctx context.Context, keys ...string) *StringSliceCmd

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

+ Save func(ctx context.Context) *StatusCmd

+ Scan func(ctx context.Context, cursor uint64, match string, count int64) *ScanCmd

+ ScriptExists func(ctx context.Context, hashes ...string) *BoolSliceCmd

+ ScriptFlush func(ctx context.Context) *StatusCmd

+ ScriptKill func(ctx context.Context) *StatusCmd

+ ScriptLoad func(ctx context.Context, script string) *StringCmd

+ Set func(ctx context.Context, key string, value interface{}, expiration time.Duration) *StatusCmd

+ SetBit func(ctx context.Context, key string, offset int64, value int) *IntCmd

+ SetNX func(ctx context.Context, key string, value interface{}, expiration time.Duration) *BoolCmd

+ SetRange func(ctx context.Context, key string, offset int64, value string) *IntCmd

+ SetXX func(ctx context.Context, key string, value interface{}, expiration time.Duration) *BoolCmd

+ Shutdown func(ctx context.Context) *StatusCmd

+ ShutdownNoSave func(ctx context.Context) *StatusCmd

+ ShutdownSave func(ctx context.Context) *StatusCmd

+ SlaveOf func(ctx context.Context, host, port string) *StatusCmd

+ Sort func(ctx context.Context, key string, sort *Sort) *StringSliceCmd

+ SortInterfaces func(ctx context.Context, key string, sort *Sort) *SliceCmd

+ SortStore func(ctx context.Context, key, store string, sort *Sort) *IntCmd

+ StrLen func(ctx context.Context, key string) *IntCmd

+ TTL func(ctx context.Context, key string) *DurationCmd

+ Time func(ctx context.Context) *TimeCmd

+ Touch func(ctx context.Context, keys ...string) *IntCmd

+ TxPipeline func() Pipeliner

+ TxPipelined func(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error)

+ Type func(ctx context.Context, key string) *StatusCmd

+ Unlink func(ctx context.Context, keys ...string) *IntCmd

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

+ XAdd func(ctx context.Context, a *XAddArgs) *StringCmd

+ XClaim func(ctx context.Context, a *XClaimArgs) *XMessageSliceCmd

+ XClaimJustID func(ctx context.Context, a *XClaimArgs) *StringSliceCmd

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

+ XGroupCreate func(ctx context.Context, stream, group, start string) *StatusCmd

+ XGroupCreateMkStream func(ctx context.Context, stream, group, start string) *StatusCmd

+ XGroupDelConsumer func(ctx context.Context, stream, group, consumer string) *IntCmd

+ XGroupDestroy func(ctx context.Context, stream, group string) *IntCmd

+ XGroupSetID func(ctx context.Context, stream, group, start string) *StatusCmd

+ XInfoGroups func(ctx context.Context, key string) *XInfoGroupsCmd

+ XLen func(ctx context.Context, stream string) *IntCmd

+ XPending func(ctx context.Context, stream, group string) *XPendingCmd

+ XPendingExt func(ctx context.Context, a *XPendingExtArgs) *XPendingExtCmd

+ XRange func(ctx context.Context, stream, start, stop string) *XMessageSliceCmd

+ XRangeN func(ctx context.Context, stream, start, stop string, count int64) *XMessageSliceCmd

+ XRead func(ctx context.Context, a *XReadArgs) *XStreamSliceCmd

+ XReadGroup func(ctx context.Context, a *XReadGroupArgs) *XStreamSliceCmd

+ XReadStreams func(ctx context.Context, streams ...string) *XStreamSliceCmd

+ XRevRange func(ctx context.Context, stream string, start, stop string) *XMessageSliceCmd

+ XRevRangeN func(ctx context.Context, stream string, start, stop string, count int64) *XMessageSliceCmd

+ XTrim func(ctx context.Context, key string, maxLen int64) *IntCmd

+ XTrimApprox func(ctx context.Context, key string, maxLen int64) *IntCmd

+ ZAdd func(ctx context.Context, key string, members ...*Z) *IntCmd

+ ZAddCh func(ctx context.Context, key string, members ...*Z) *IntCmd

+ ZAddNX func(ctx context.Context, key string, members ...*Z) *IntCmd

+ ZAddNXCh func(ctx context.Context, key string, members ...*Z) *IntCmd

+ ZAddXX func(ctx context.Context, key string, members ...*Z) *IntCmd

+ ZAddXXCh func(ctx context.Context, key string, members ...*Z) *IntCmd

+ ZCard func(ctx context.Context, key string) *IntCmd

+ ZCount func(ctx context.Context, key, min, max string) *IntCmd

+ ZIncr func(ctx context.Context, key string, member *Z) *FloatCmd

+ ZIncrBy func(ctx context.Context, key string, increment float64, member string) *FloatCmd

+ ZIncrNX func(ctx context.Context, key string, member *Z) *FloatCmd

+ ZIncrXX func(ctx context.Context, key string, member *Z) *FloatCmd

+ ZInterStore func(ctx context.Context, destination string, store *ZStore) *IntCmd

+ ZLexCount func(ctx context.Context, key, min, max string) *IntCmd

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

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

+ ZRange func(ctx context.Context, key string, start, stop int64) *StringSliceCmd

+ ZRangeByLex func(ctx context.Context, key string, opt *ZRangeBy) *StringSliceCmd

+ ZRangeByScore func(ctx context.Context, key string, opt *ZRangeBy) *StringSliceCmd

+ ZRangeByScoreWithScores func(ctx context.Context, key string, opt *ZRangeBy) *ZSliceCmd

+ ZRangeWithScores func(ctx context.Context, key string, start, stop int64) *ZSliceCmd

+ ZRank func(ctx context.Context, key, member string) *IntCmd

+ ZRem func(ctx context.Context, key string, members ...interface{}) *IntCmd

+ ZRemRangeByLex func(ctx context.Context, key, min, max string) *IntCmd

+ ZRemRangeByRank func(ctx context.Context, key string, start, stop int64) *IntCmd

+ ZRemRangeByScore func(ctx context.Context, key, min, max string) *IntCmd

+ ZRevRange func(ctx context.Context, key string, start, stop int64) *StringSliceCmd

+ ZRevRangeByLex func(ctx context.Context, key string, opt *ZRangeBy) *StringSliceCmd

+ ZRevRangeByScore func(ctx context.Context, key string, opt *ZRangeBy) *StringSliceCmd

+ ZRevRangeByScoreWithScores func(ctx context.Context, key string, opt *ZRangeBy) *ZSliceCmd

+ ZRevRangeWithScores func(ctx context.Context, key string, start, stop int64) *ZSliceCmd

+ ZRevRank func(ctx context.Context, key, member string) *IntCmd

+ ZScan func(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd

+ ZScore func(ctx context.Context, key, member string) *FloatCmd

+ ZUnionStore func(ctx context.Context, dest string, store *ZStore) *IntCmd

+ type Cmder interface

+ Args func() []interface{}

+ Err func() error

+ FullName func() string

+ Name func() string

+ SetErr func(error)

+ String func() string

+ type CommandInfo struct

+ ACLFlags []string

+ Arity int8

+ FirstKeyPos int8

+ Flags []string

+ LastKeyPos int8

+ Name string

+ ReadOnly bool

+ StepCount int8

+ type CommandsInfoCmd struct

+ func NewCommandsInfoCmd(ctx context.Context, args ...interface{}) *CommandsInfoCmd

+ func NewCommandsInfoCmdResult(val map[string]*CommandInfo, err error) *CommandsInfoCmd

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

+ func (cmd *CommandsInfoCmd) Err() error

+ func (cmd *CommandsInfoCmd) FullName() string

+ func (cmd *CommandsInfoCmd) Name() string

+ func (cmd *CommandsInfoCmd) Result() (map[string]*CommandInfo, error)

+ func (cmd *CommandsInfoCmd) SetErr(e error)

+ func (cmd *CommandsInfoCmd) String() string

+ func (cmd *CommandsInfoCmd) Val() map[string]*CommandInfo

+ type Conn struct

+ func (c *Conn) Pipeline() Pipeliner

+ func (c *Conn) Pipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error)

+ func (c *Conn) Process(ctx context.Context, cmd Cmder) error

+ func (c *Conn) TxPipeline() Pipeliner

+ func (c *Conn) TxPipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error)

+ type ConsistentHash interface

+ Get func(string) string

+ type DurationCmd struct

+ func NewDurationCmd(ctx context.Context, precision time.Duration, args ...interface{}) *DurationCmd

+ func NewDurationResult(val time.Duration, err error) *DurationCmd

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

+ func (cmd *DurationCmd) Err() error

+ func (cmd *DurationCmd) FullName() string

+ func (cmd *DurationCmd) Name() string

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

+ func (cmd *DurationCmd) SetErr(e error)

+ func (cmd *DurationCmd) String() string

+ func (cmd *DurationCmd) Val() time.Duration

+ type Error interface

+ RedisError func()

+ type FailoverOptions struct

+ DB int

+ DialTimeout time.Duration

+ Dialer func(ctx context.Context, network, addr string) (net.Conn, error)

+ IdleCheckFrequency time.Duration

+ IdleTimeout time.Duration

+ MasterName string

+ MaxConnAge time.Duration

+ MaxRetries int

+ MaxRetryBackoff time.Duration

+ MinIdleConns int

+ MinRetryBackoff time.Duration

+ OnConnect func(ctx context.Context, cn *Conn) error

+ Password string

+ PoolSize int

+ PoolTimeout time.Duration

+ ReadTimeout time.Duration

+ RouteByLatency bool

+ RouteRandomly bool

+ SentinelAddrs []string

+ SentinelPassword string

+ SlaveOnly bool

+ TLSConfig *tls.Config

+ Username string

+ WriteTimeout time.Duration

+ type FloatCmd struct

+ func NewFloatCmd(ctx context.Context, args ...interface{}) *FloatCmd

+ func NewFloatResult(val float64, err error) *FloatCmd

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

+ func (cmd *FloatCmd) Err() error

+ func (cmd *FloatCmd) FullName() string

+ func (cmd *FloatCmd) Name() string

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

+ func (cmd *FloatCmd) SetErr(e 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(ctx context.Context, q *GeoRadiusQuery, args ...interface{}) *GeoLocationCmd

+ func NewGeoLocationCmdResult(val []GeoLocation, err error) *GeoLocationCmd

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

+ func (cmd *GeoLocationCmd) Err() error

+ func (cmd *GeoLocationCmd) FullName() string

+ func (cmd *GeoLocationCmd) Name() string

+ func (cmd *GeoLocationCmd) Result() ([]GeoLocation, error)

+ func (cmd *GeoLocationCmd) SetErr(e error)

+ func (cmd *GeoLocationCmd) String() string

+ func (cmd *GeoLocationCmd) Val() []GeoLocation

+ type GeoPos struct

+ Latitude float64

+ Longitude float64

+ type GeoPosCmd struct

+ func NewGeoPosCmd(ctx context.Context, args ...interface{}) *GeoPosCmd

+ func NewGeoPosCmdResult(val []*GeoPos, err error) *GeoPosCmd

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

+ func (cmd *GeoPosCmd) Err() error

+ func (cmd *GeoPosCmd) FullName() string

+ func (cmd *GeoPosCmd) Name() string

+ func (cmd *GeoPosCmd) Result() ([]*GeoPos, error)

+ func (cmd *GeoPosCmd) SetErr(e error)

+ func (cmd *GeoPosCmd) String() string

+ func (cmd *GeoPosCmd) Val() []*GeoPos

+ type GeoRadiusQuery struct

+ Count int

+ Radius float64

+ Sort string

+ Store string

+ StoreDist string

+ Unit string

+ WithCoord bool

+ WithDist bool

+ WithGeoHash bool

+ type Hook interface

+ AfterProcess func(ctx context.Context, cmd Cmder) error

+ AfterProcessPipeline func(ctx context.Context, cmds []Cmder) error

+ BeforeProcess func(ctx context.Context, cmd Cmder) (context.Context, error)

+ BeforeProcessPipeline func(ctx context.Context, cmds []Cmder) (context.Context, error)

+ type IntCmd struct

+ func NewIntCmd(ctx context.Context, args ...interface{}) *IntCmd

+ func NewIntResult(val int64, err error) *IntCmd

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

+ func (cmd *IntCmd) Err() error

+ func (cmd *IntCmd) FullName() string

+ func (cmd *IntCmd) Name() string

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

+ func (cmd *IntCmd) SetErr(e error)

+ func (cmd *IntCmd) String() string

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

+ func (cmd *IntCmd) Val() int64

+ type IntSliceCmd struct

+ func NewIntSliceCmd(ctx context.Context, args ...interface{}) *IntSliceCmd

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

+ func (cmd *IntSliceCmd) Err() error

+ func (cmd *IntSliceCmd) FullName() string

+ func (cmd *IntSliceCmd) Name() string

+ func (cmd *IntSliceCmd) Result() ([]int64, error)

+ func (cmd *IntSliceCmd) SetErr(e error)

+ func (cmd *IntSliceCmd) String() string

+ func (cmd *IntSliceCmd) Val() []int64

+ type Limiter interface

+ Allow func() error

+ ReportResult func(result error)

+ type Message struct

+ Channel string

+ Pattern string

+ Payload string

+ PayloadSlice []string

+ func (m *Message) String() string

+ type Options struct

+ Addr string

+ DB int

+ DialTimeout time.Duration

+ Dialer func(ctx context.Context, network, addr string) (net.Conn, error)

+ IdleCheckFrequency time.Duration

+ IdleTimeout time.Duration

+ Limiter Limiter

+ MaxConnAge time.Duration

+ MaxRetries int

+ MaxRetryBackoff time.Duration

+ MinIdleConns int

+ MinRetryBackoff time.Duration

+ Network string

+ OnConnect func(ctx context.Context, cn *Conn) error

+ Password string

+ PoolSize int

+ PoolTimeout time.Duration

+ ReadTimeout time.Duration

+ TLSConfig *tls.Config

+ Username string

+ WriteTimeout time.Duration

+ func ParseURL(redisURL string) (*Options, error)

+ type Pipeline struct

+ func (c *Pipeline) Close() error

+ func (c *Pipeline) Discard() error

+ func (c *Pipeline) Do(ctx context.Context, args ...interface{}) *Cmd

+ func (c *Pipeline) Exec(ctx context.Context) ([]Cmder, error)

+ func (c *Pipeline) Pipeline() Pipeliner

+ func (c *Pipeline) Pipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error)

+ func (c *Pipeline) Process(ctx context.Context, cmd Cmder) error

+ func (c *Pipeline) TxPipeline() Pipeliner

+ func (c *Pipeline) TxPipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error)

+ func (c Pipeline) Append(ctx context.Context, key, value string) *IntCmd

+ func (c Pipeline) Auth(ctx context.Context, password string) *StatusCmd

+ func (c Pipeline) AuthACL(ctx context.Context, username, password string) *StatusCmd

+ func (c Pipeline) BLPop(ctx context.Context, timeout time.Duration, keys ...string) *StringSliceCmd

+ func (c Pipeline) BRPop(ctx context.Context, timeout time.Duration, keys ...string) *StringSliceCmd

+ func (c Pipeline) BRPopLPush(ctx context.Context, source, destination string, timeout time.Duration) *StringCmd

+ func (c Pipeline) BZPopMax(ctx context.Context, timeout time.Duration, keys ...string) *ZWithKeyCmd

+ func (c Pipeline) BZPopMin(ctx context.Context, timeout time.Duration, keys ...string) *ZWithKeyCmd

+ func (c Pipeline) BgRewriteAOF(ctx context.Context) *StatusCmd

+ func (c Pipeline) BgSave(ctx context.Context) *StatusCmd

+ func (c Pipeline) BitCount(ctx context.Context, key string, bitCount *BitCount) *IntCmd

+ func (c Pipeline) BitField(ctx context.Context, key string, args ...interface{}) *IntSliceCmd

+ func (c Pipeline) BitOpAnd(ctx context.Context, destKey string, keys ...string) *IntCmd

+ func (c Pipeline) BitOpNot(ctx context.Context, destKey string, key string) *IntCmd

+ func (c Pipeline) BitOpOr(ctx context.Context, destKey string, keys ...string) *IntCmd

+ func (c Pipeline) BitOpXor(ctx context.Context, destKey string, keys ...string) *IntCmd

+ func (c Pipeline) BitPos(ctx context.Context, key string, bit int64, pos ...int64) *IntCmd

+ func (c Pipeline) ClientGetName(ctx context.Context) *StringCmd

+ func (c Pipeline) ClientID(ctx context.Context) *IntCmd

+ func (c Pipeline) ClientKill(ctx context.Context, ipPort string) *StatusCmd

+ func (c Pipeline) ClientKillByFilter(ctx context.Context, keys ...string) *IntCmd

+ func (c Pipeline) ClientList(ctx context.Context) *StringCmd

+ func (c Pipeline) ClientPause(ctx context.Context, dur time.Duration) *BoolCmd

+ func (c Pipeline) ClientSetName(ctx context.Context, name string) *BoolCmd

+ func (c Pipeline) ClientUnblock(ctx context.Context, id int64) *IntCmd

+ func (c Pipeline) ClientUnblockWithError(ctx context.Context, id int64) *IntCmd

+ func (c Pipeline) ClusterAddSlots(ctx context.Context, slots ...int) *StatusCmd

+ func (c Pipeline) ClusterAddSlotsRange(ctx context.Context, min, max int) *StatusCmd

+ func (c Pipeline) ClusterCountFailureReports(ctx context.Context, nodeID string) *IntCmd

+ func (c Pipeline) ClusterCountKeysInSlot(ctx context.Context, slot int) *IntCmd

+ func (c Pipeline) ClusterDelSlots(ctx context.Context, slots ...int) *StatusCmd

+ func (c Pipeline) ClusterDelSlotsRange(ctx context.Context, min, max int) *StatusCmd

+ func (c Pipeline) ClusterFailover(ctx context.Context) *StatusCmd

+ func (c Pipeline) ClusterForget(ctx context.Context, nodeID string) *StatusCmd

+ func (c Pipeline) ClusterGetKeysInSlot(ctx context.Context, slot int, count int) *StringSliceCmd

+ func (c Pipeline) ClusterInfo(ctx context.Context) *StringCmd

+ func (c Pipeline) ClusterKeySlot(ctx context.Context, key string) *IntCmd

+ func (c Pipeline) ClusterMeet(ctx context.Context, host, port string) *StatusCmd

+ func (c Pipeline) ClusterNodes(ctx context.Context) *StringCmd

+ func (c Pipeline) ClusterReplicate(ctx context.Context, nodeID string) *StatusCmd

+ func (c Pipeline) ClusterResetHard(ctx context.Context) *StatusCmd

+ func (c Pipeline) ClusterResetSoft(ctx context.Context) *StatusCmd

+ func (c Pipeline) ClusterSaveConfig(ctx context.Context) *StatusCmd

+ func (c Pipeline) ClusterSlaves(ctx context.Context, nodeID string) *StringSliceCmd

+ func (c Pipeline) ClusterSlots(ctx context.Context) *ClusterSlotsCmd

+ func (c Pipeline) Command(ctx context.Context) *CommandsInfoCmd

+ func (c Pipeline) ConfigGet(ctx context.Context, parameter string) *SliceCmd

+ func (c Pipeline) ConfigResetStat(ctx context.Context) *StatusCmd

+ func (c Pipeline) ConfigRewrite(ctx context.Context) *StatusCmd

+ func (c Pipeline) ConfigSet(ctx context.Context, parameter, value string) *StatusCmd

+ func (c Pipeline) DBSize(ctx context.Context) *IntCmd

+ func (c Pipeline) DebugObject(ctx context.Context, key string) *StringCmd

+ func (c Pipeline) Decr(ctx context.Context, key string) *IntCmd

+ func (c Pipeline) DecrBy(ctx context.Context, key string, decrement int64) *IntCmd

+ func (c Pipeline) Del(ctx context.Context, keys ...string) *IntCmd

+ func (c Pipeline) Dump(ctx context.Context, key string) *StringCmd

+ func (c Pipeline) Echo(ctx context.Context, message interface{}) *StringCmd

+ func (c Pipeline) Eval(ctx context.Context, script string, keys []string, args ...interface{}) *Cmd

+ func (c Pipeline) EvalSha(ctx context.Context, sha1 string, keys []string, args ...interface{}) *Cmd

+ func (c Pipeline) Exists(ctx context.Context, keys ...string) *IntCmd

+ func (c Pipeline) Expire(ctx context.Context, key string, expiration time.Duration) *BoolCmd

+ func (c Pipeline) ExpireAt(ctx context.Context, key string, tm time.Time) *BoolCmd

+ func (c Pipeline) FlushAll(ctx context.Context) *StatusCmd

+ func (c Pipeline) FlushAllAsync(ctx context.Context) *StatusCmd

+ func (c Pipeline) FlushDB(ctx context.Context) *StatusCmd

+ func (c Pipeline) FlushDBAsync(ctx context.Context) *StatusCmd

+ func (c Pipeline) GeoAdd(ctx context.Context, key string, geoLocation ...*GeoLocation) *IntCmd

+ func (c Pipeline) GeoDist(ctx context.Context, key string, member1, member2, unit string) *FloatCmd

+ func (c Pipeline) GeoHash(ctx context.Context, key string, members ...string) *StringSliceCmd

+ func (c Pipeline) GeoPos(ctx context.Context, key string, members ...string) *GeoPosCmd

+ func (c Pipeline) GeoRadius(ctx context.Context, key string, longitude, latitude float64, ...) *GeoLocationCmd

+ func (c Pipeline) GeoRadiusByMember(ctx context.Context, key, member string, query *GeoRadiusQuery) *GeoLocationCmd

+ func (c Pipeline) GeoRadiusByMemberStore(ctx context.Context, key, member string, query *GeoRadiusQuery) *IntCmd

+ func (c Pipeline) GeoRadiusStore(ctx context.Context, key string, longitude, latitude float64, ...) *IntCmd

+ func (c Pipeline) Get(ctx context.Context, key string) *StringCmd

+ func (c Pipeline) GetBit(ctx context.Context, key string, offset int64) *IntCmd

+ func (c Pipeline) GetRange(ctx context.Context, key string, start, end int64) *StringCmd

+ func (c Pipeline) GetSet(ctx context.Context, key string, value interface{}) *StringCmd

+ func (c Pipeline) HDel(ctx context.Context, key string, fields ...string) *IntCmd

+ func (c Pipeline) HExists(ctx context.Context, key, field string) *BoolCmd

+ func (c Pipeline) HGet(ctx context.Context, key, field string) *StringCmd

+ func (c Pipeline) HGetAll(ctx context.Context, key string) *StringStringMapCmd

+ func (c Pipeline) HIncrBy(ctx context.Context, key, field string, incr int64) *IntCmd

+ func (c Pipeline) HIncrByFloat(ctx context.Context, key, field string, incr float64) *FloatCmd

+ func (c Pipeline) HKeys(ctx context.Context, key string) *StringSliceCmd

+ func (c Pipeline) HLen(ctx context.Context, key string) *IntCmd

+ func (c Pipeline) HMGet(ctx context.Context, key string, fields ...string) *SliceCmd

+ func (c Pipeline) HMSet(ctx context.Context, key string, values ...interface{}) *BoolCmd

+ func (c Pipeline) HScan(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd

+ func (c Pipeline) HSet(ctx context.Context, key string, values ...interface{}) *IntCmd

+ func (c Pipeline) HSetNX(ctx context.Context, key, field string, value interface{}) *BoolCmd

+ func (c Pipeline) HVals(ctx context.Context, key string) *StringSliceCmd

+ func (c Pipeline) Incr(ctx context.Context, key string) *IntCmd

+ func (c Pipeline) IncrBy(ctx context.Context, key string, value int64) *IntCmd

+ func (c Pipeline) IncrByFloat(ctx context.Context, key string, value float64) *FloatCmd

+ func (c Pipeline) Info(ctx context.Context, section ...string) *StringCmd

+ func (c Pipeline) Keys(ctx context.Context, pattern string) *StringSliceCmd

+ func (c Pipeline) LIndex(ctx context.Context, key string, index int64) *StringCmd

+ func (c Pipeline) LInsert(ctx context.Context, key, op string, pivot, value interface{}) *IntCmd

+ func (c Pipeline) LInsertAfter(ctx context.Context, key string, pivot, value interface{}) *IntCmd

+ func (c Pipeline) LInsertBefore(ctx context.Context, key string, pivot, value interface{}) *IntCmd

+ func (c Pipeline) LLen(ctx context.Context, key string) *IntCmd

+ func (c Pipeline) LPop(ctx context.Context, key string) *StringCmd

+ func (c Pipeline) LPush(ctx context.Context, key string, values ...interface{}) *IntCmd

+ func (c Pipeline) LPushX(ctx context.Context, key string, values ...interface{}) *IntCmd

+ func (c Pipeline) LRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd

+ func (c Pipeline) LRem(ctx context.Context, key string, count int64, value interface{}) *IntCmd

+ func (c Pipeline) LSet(ctx context.Context, key string, index int64, value interface{}) *StatusCmd

+ func (c Pipeline) LTrim(ctx context.Context, key string, start, stop int64) *StatusCmd

+ func (c Pipeline) LastSave(ctx context.Context) *IntCmd

+ func (c Pipeline) MGet(ctx context.Context, keys ...string) *SliceCmd

+ func (c Pipeline) MSet(ctx context.Context, values ...interface{}) *StatusCmd

+ func (c Pipeline) MSetNX(ctx context.Context, values ...interface{}) *BoolCmd

+ func (c Pipeline) MemoryUsage(ctx context.Context, key string, samples ...int) *IntCmd

+ func (c Pipeline) Migrate(ctx context.Context, host, port, key string, db int, timeout time.Duration) *StatusCmd

+ func (c Pipeline) Move(ctx context.Context, key string, db int) *BoolCmd

+ func (c Pipeline) ObjectEncoding(ctx context.Context, key string) *StringCmd

+ func (c Pipeline) ObjectIdleTime(ctx context.Context, key string) *DurationCmd

+ func (c Pipeline) ObjectRefCount(ctx context.Context, key string) *IntCmd

+ func (c Pipeline) PExpire(ctx context.Context, key string, expiration time.Duration) *BoolCmd

+ func (c Pipeline) PExpireAt(ctx context.Context, key string, tm time.Time) *BoolCmd

+ func (c Pipeline) PFAdd(ctx context.Context, key string, els ...interface{}) *IntCmd

+ func (c Pipeline) PFCount(ctx context.Context, keys ...string) *IntCmd

+ func (c Pipeline) PFMerge(ctx context.Context, dest string, keys ...string) *StatusCmd

+ func (c Pipeline) PTTL(ctx context.Context, key string) *DurationCmd

+ func (c Pipeline) Persist(ctx context.Context, key string) *BoolCmd

+ func (c Pipeline) Ping(ctx context.Context) *StatusCmd

+ func (c Pipeline) PubSubChannels(ctx context.Context, pattern string) *StringSliceCmd

+ func (c Pipeline) PubSubNumPat(ctx context.Context) *IntCmd

+ func (c Pipeline) PubSubNumSub(ctx context.Context, channels ...string) *StringIntMapCmd

+ func (c Pipeline) Publish(ctx context.Context, channel string, message interface{}) *IntCmd

+ func (c Pipeline) Quit(ctx context.Context) *StatusCmd

+ func (c Pipeline) RPop(ctx context.Context, key string) *StringCmd

+ func (c Pipeline) RPopLPush(ctx context.Context, source, destination string) *StringCmd

+ func (c Pipeline) RPush(ctx context.Context, key string, values ...interface{}) *IntCmd

+ func (c Pipeline) RPushX(ctx context.Context, key string, values ...interface{}) *IntCmd

+ func (c Pipeline) RandomKey(ctx context.Context) *StringCmd

+ func (c Pipeline) ReadOnly(ctx context.Context) *StatusCmd

+ func (c Pipeline) ReadWrite(ctx context.Context) *StatusCmd

+ func (c Pipeline) Rename(ctx context.Context, key, newkey string) *StatusCmd

+ func (c Pipeline) RenameNX(ctx context.Context, key, newkey string) *BoolCmd

+ func (c Pipeline) Restore(ctx context.Context, key string, ttl time.Duration, value string) *StatusCmd

+ func (c Pipeline) RestoreReplace(ctx context.Context, key string, ttl time.Duration, value string) *StatusCmd

+ func (c Pipeline) SAdd(ctx context.Context, key string, members ...interface{}) *IntCmd

+ func (c Pipeline) SCard(ctx context.Context, key string) *IntCmd

+ func (c Pipeline) SDiff(ctx context.Context, keys ...string) *StringSliceCmd

+ func (c Pipeline) SDiffStore(ctx context.Context, destination string, keys ...string) *IntCmd

+ func (c Pipeline) SInter(ctx context.Context, keys ...string) *StringSliceCmd

+ func (c Pipeline) SInterStore(ctx context.Context, destination string, keys ...string) *IntCmd

+ func (c Pipeline) SIsMember(ctx context.Context, key string, member interface{}) *BoolCmd

+ func (c Pipeline) SMembers(ctx context.Context, key string) *StringSliceCmd

+ func (c Pipeline) SMembersMap(ctx context.Context, key string) *StringStructMapCmd

+ func (c Pipeline) SMove(ctx context.Context, source, destination string, member interface{}) *BoolCmd

+ func (c Pipeline) SPop(ctx context.Context, key string) *StringCmd

+ func (c Pipeline) SPopN(ctx context.Context, key string, count int64) *StringSliceCmd

+ func (c Pipeline) SRandMember(ctx context.Context, key string) *StringCmd

+ func (c Pipeline) SRandMemberN(ctx context.Context, key string, count int64) *StringSliceCmd

+ func (c Pipeline) SRem(ctx context.Context, key string, members ...interface{}) *IntCmd

+ func (c Pipeline) SScan(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd

+ func (c Pipeline) SUnion(ctx context.Context, keys ...string) *StringSliceCmd

+ func (c Pipeline) SUnionStore(ctx context.Context, destination string, keys ...string) *IntCmd

+ func (c Pipeline) Save(ctx context.Context) *StatusCmd

+ func (c Pipeline) Scan(ctx context.Context, cursor uint64, match string, count int64) *ScanCmd

+ func (c Pipeline) ScriptExists(ctx context.Context, hashes ...string) *BoolSliceCmd

+ func (c Pipeline) ScriptFlush(ctx context.Context) *StatusCmd

+ func (c Pipeline) ScriptKill(ctx context.Context) *StatusCmd

+ func (c Pipeline) ScriptLoad(ctx context.Context, script string) *StringCmd

+ func (c Pipeline) Select(ctx context.Context, index int) *StatusCmd

+ func (c Pipeline) Set(ctx context.Context, key string, value interface{}, expiration time.Duration) *StatusCmd

+ func (c Pipeline) SetBit(ctx context.Context, key string, offset int64, value int) *IntCmd

+ func (c Pipeline) SetNX(ctx context.Context, key string, value interface{}, expiration time.Duration) *BoolCmd

+ func (c Pipeline) SetRange(ctx context.Context, key string, offset int64, value string) *IntCmd

+ func (c Pipeline) SetXX(ctx context.Context, key string, value interface{}, expiration time.Duration) *BoolCmd

+ func (c Pipeline) Shutdown(ctx context.Context) *StatusCmd

+ func (c Pipeline) ShutdownNoSave(ctx context.Context) *StatusCmd

+ func (c Pipeline) ShutdownSave(ctx context.Context) *StatusCmd

+ func (c Pipeline) SlaveOf(ctx context.Context, host, port string) *StatusCmd

+ func (c Pipeline) SlowLogGet(ctx context.Context, num int64) *SlowLogCmd

+ func (c Pipeline) Sort(ctx context.Context, key string, sort *Sort) *StringSliceCmd

+ func (c Pipeline) SortInterfaces(ctx context.Context, key string, sort *Sort) *SliceCmd

+ func (c Pipeline) SortStore(ctx context.Context, key, store string, sort *Sort) *IntCmd

+ func (c Pipeline) StrLen(ctx context.Context, key string) *IntCmd

+ func (c Pipeline) SwapDB(ctx context.Context, index1, index2 int) *StatusCmd

+ func (c Pipeline) Sync(ctx context.Context)

+ func (c Pipeline) TTL(ctx context.Context, key string) *DurationCmd

+ func (c Pipeline) Time(ctx context.Context) *TimeCmd

+ func (c Pipeline) Touch(ctx context.Context, keys ...string) *IntCmd

+ func (c Pipeline) Type(ctx context.Context, key string) *StatusCmd

+ func (c Pipeline) Unlink(ctx context.Context, keys ...string) *IntCmd

+ func (c Pipeline) Wait(ctx context.Context, numSlaves int, timeout time.Duration) *IntCmd

+ func (c Pipeline) XAck(ctx context.Context, stream, group string, ids ...string) *IntCmd

+ func (c Pipeline) XAdd(ctx context.Context, a *XAddArgs) *StringCmd

+ func (c Pipeline) XClaim(ctx context.Context, a *XClaimArgs) *XMessageSliceCmd

+ func (c Pipeline) XClaimJustID(ctx context.Context, a *XClaimArgs) *StringSliceCmd

+ func (c Pipeline) XDel(ctx context.Context, stream string, ids ...string) *IntCmd

+ func (c Pipeline) XGroupCreate(ctx context.Context, stream, group, start string) *StatusCmd

+ func (c Pipeline) XGroupCreateMkStream(ctx context.Context, stream, group, start string) *StatusCmd

+ func (c Pipeline) XGroupDelConsumer(ctx context.Context, stream, group, consumer string) *IntCmd

+ func (c Pipeline) XGroupDestroy(ctx context.Context, stream, group string) *IntCmd

+ func (c Pipeline) XGroupSetID(ctx context.Context, stream, group, start string) *StatusCmd

+ func (c Pipeline) XInfoGroups(ctx context.Context, key string) *XInfoGroupsCmd

+ func (c Pipeline) XLen(ctx context.Context, stream string) *IntCmd

+ func (c Pipeline) XPending(ctx context.Context, stream, group string) *XPendingCmd

+ func (c Pipeline) XPendingExt(ctx context.Context, a *XPendingExtArgs) *XPendingExtCmd

+ func (c Pipeline) XRange(ctx context.Context, stream, start, stop string) *XMessageSliceCmd

+ func (c Pipeline) XRangeN(ctx context.Context, stream, start, stop string, count int64) *XMessageSliceCmd

+ func (c Pipeline) XRead(ctx context.Context, a *XReadArgs) *XStreamSliceCmd

+ func (c Pipeline) XReadGroup(ctx context.Context, a *XReadGroupArgs) *XStreamSliceCmd

+ func (c Pipeline) XReadStreams(ctx context.Context, streams ...string) *XStreamSliceCmd

+ func (c Pipeline) XRevRange(ctx context.Context, stream, start, stop string) *XMessageSliceCmd

+ func (c Pipeline) XRevRangeN(ctx context.Context, stream, start, stop string, count int64) *XMessageSliceCmd

+ func (c Pipeline) XTrim(ctx context.Context, key string, maxLen int64) *IntCmd

+ func (c Pipeline) XTrimApprox(ctx context.Context, key string, maxLen int64) *IntCmd

+ func (c Pipeline) ZAdd(ctx context.Context, key string, members ...*Z) *IntCmd

+ func (c Pipeline) ZAddCh(ctx context.Context, key string, members ...*Z) *IntCmd

+ func (c Pipeline) ZAddNX(ctx context.Context, key string, members ...*Z) *IntCmd

+ func (c Pipeline) ZAddNXCh(ctx context.Context, key string, members ...*Z) *IntCmd

+ func (c Pipeline) ZAddXX(ctx context.Context, key string, members ...*Z) *IntCmd

+ func (c Pipeline) ZAddXXCh(ctx context.Context, key string, members ...*Z) *IntCmd

+ func (c Pipeline) ZCard(ctx context.Context, key string) *IntCmd

+ func (c Pipeline) ZCount(ctx context.Context, key, min, max string) *IntCmd

+ func (c Pipeline) ZIncr(ctx context.Context, key string, member *Z) *FloatCmd

+ func (c Pipeline) ZIncrBy(ctx context.Context, key string, increment float64, member string) *FloatCmd

+ func (c Pipeline) ZIncrNX(ctx context.Context, key string, member *Z) *FloatCmd

+ func (c Pipeline) ZIncrXX(ctx context.Context, key string, member *Z) *FloatCmd

+ func (c Pipeline) ZInterStore(ctx context.Context, destination string, store *ZStore) *IntCmd

+ func (c Pipeline) ZLexCount(ctx context.Context, key, min, max string) *IntCmd

+ func (c Pipeline) ZPopMax(ctx context.Context, key string, count ...int64) *ZSliceCmd

+ func (c Pipeline) ZPopMin(ctx context.Context, key string, count ...int64) *ZSliceCmd

+ func (c Pipeline) ZRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd

+ func (c Pipeline) ZRangeByLex(ctx context.Context, key string, opt *ZRangeBy) *StringSliceCmd

+ func (c Pipeline) ZRangeByScore(ctx context.Context, key string, opt *ZRangeBy) *StringSliceCmd

+ func (c Pipeline) ZRangeByScoreWithScores(ctx context.Context, key string, opt *ZRangeBy) *ZSliceCmd

+ func (c Pipeline) ZRangeWithScores(ctx context.Context, key string, start, stop int64) *ZSliceCmd

+ func (c Pipeline) ZRank(ctx context.Context, key, member string) *IntCmd

+ func (c Pipeline) ZRem(ctx context.Context, key string, members ...interface{}) *IntCmd

+ func (c Pipeline) ZRemRangeByLex(ctx context.Context, key, min, max string) *IntCmd

+ func (c Pipeline) ZRemRangeByRank(ctx context.Context, key string, start, stop int64) *IntCmd

+ func (c Pipeline) ZRemRangeByScore(ctx context.Context, key, min, max string) *IntCmd

+ func (c Pipeline) ZRevRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd

+ func (c Pipeline) ZRevRangeByLex(ctx context.Context, key string, opt *ZRangeBy) *StringSliceCmd

+ func (c Pipeline) ZRevRangeByScore(ctx context.Context, key string, opt *ZRangeBy) *StringSliceCmd

+ func (c Pipeline) ZRevRangeByScoreWithScores(ctx context.Context, key string, opt *ZRangeBy) *ZSliceCmd

+ func (c Pipeline) ZRevRangeWithScores(ctx context.Context, key string, start, stop int64) *ZSliceCmd

+ func (c Pipeline) ZRevRank(ctx context.Context, key, member string) *IntCmd

+ func (c Pipeline) ZScan(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd

+ func (c Pipeline) ZScore(ctx context.Context, key, member string) *FloatCmd

+ func (c Pipeline) ZUnionStore(ctx context.Context, dest string, store *ZStore) *IntCmd

+ type Pipeliner interface

+ Close func() error

+ Discard func() error

+ Do func(ctx context.Context, args ...interface{}) *Cmd

+ Exec func(ctx context.Context) ([]Cmder, error)

+ Process func(ctx context.Context, cmd Cmder) error

+ type Pong struct

+ Payload string

+ func (p *Pong) String() string

+ type PoolStats pool.Stats

+ type PubSub struct

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

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

+ func (c *PubSub) ChannelWithSubscriptions(ctx context.Context, size int) <-chan interface{}

+ func (c *PubSub) Close() error

+ func (c *PubSub) PSubscribe(ctx context.Context, patterns ...string) error

+ func (c *PubSub) PUnsubscribe(ctx context.Context, patterns ...string) error

+ func (c *PubSub) Ping(ctx context.Context, payload ...string) error

+ func (c *PubSub) Receive(ctx context.Context) (interface{}, error)

+ func (c *PubSub) ReceiveMessage(ctx context.Context) (*Message, error)

+ func (c *PubSub) ReceiveTimeout(ctx context.Context, timeout time.Duration) (interface{}, error)

+ func (c *PubSub) String() string

+ func (c *PubSub) Subscribe(ctx context.Context, channels ...string) error

+ func (c *PubSub) Unsubscribe(ctx context.Context, channels ...string) error

+ type Ring struct

+ func NewRing(opt *RingOptions) *Ring

+ func (c *Ring) Close() error

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

+ func (c *Ring) Do(ctx context.Context, args ...interface{}) *Cmd

+ func (c *Ring) ForEachShard(ctx context.Context, fn func(ctx context.Context, client *Client) error) error

+ func (c *Ring) Len() int

+ func (c *Ring) Options() *RingOptions

+ func (c *Ring) PSubscribe(ctx context.Context, channels ...string) *PubSub

+ func (c *Ring) Pipeline() Pipeliner

+ func (c *Ring) Pipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error)

+ func (c *Ring) PoolStats() *PoolStats

+ func (c *Ring) Process(ctx context.Context, cmd Cmder) error

+ func (c *Ring) Subscribe(ctx context.Context, channels ...string) *PubSub

+ func (c *Ring) TxPipeline() Pipeliner

+ func (c *Ring) TxPipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error)

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

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

+ func (c Ring) Append(ctx context.Context, key, value string) *IntCmd

+ func (c Ring) BLPop(ctx context.Context, timeout time.Duration, keys ...string) *StringSliceCmd

+ func (c Ring) BRPop(ctx context.Context, timeout time.Duration, keys ...string) *StringSliceCmd

+ func (c Ring) BRPopLPush(ctx context.Context, source, destination string, timeout time.Duration) *StringCmd

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

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

+ func (c Ring) BgRewriteAOF(ctx context.Context) *StatusCmd

+ func (c Ring) BgSave(ctx context.Context) *StatusCmd

+ func (c Ring) BitCount(ctx context.Context, key string, bitCount *BitCount) *IntCmd

+ func (c Ring) BitField(ctx context.Context, key string, args ...interface{}) *IntSliceCmd

+ func (c Ring) BitOpAnd(ctx context.Context, destKey string, keys ...string) *IntCmd

+ func (c Ring) BitOpNot(ctx context.Context, destKey string, key string) *IntCmd

+ func (c Ring) BitOpOr(ctx context.Context, destKey string, keys ...string) *IntCmd

+ func (c Ring) BitOpXor(ctx context.Context, destKey string, keys ...string) *IntCmd

+ func (c Ring) BitPos(ctx context.Context, key string, bit int64, pos ...int64) *IntCmd

+ func (c Ring) ClientGetName(ctx context.Context) *StringCmd

+ func (c Ring) ClientID(ctx context.Context) *IntCmd

+ func (c Ring) ClientKill(ctx context.Context, ipPort string) *StatusCmd

+ func (c Ring) ClientKillByFilter(ctx context.Context, keys ...string) *IntCmd

+ func (c Ring) ClientList(ctx context.Context) *StringCmd

+ func (c Ring) ClientPause(ctx context.Context, dur time.Duration) *BoolCmd

+ func (c Ring) ClientUnblock(ctx context.Context, id int64) *IntCmd

+ func (c Ring) ClientUnblockWithError(ctx context.Context, id int64) *IntCmd

+ func (c Ring) ClusterAddSlots(ctx context.Context, slots ...int) *StatusCmd

+ func (c Ring) ClusterAddSlotsRange(ctx context.Context, min, max int) *StatusCmd

+ func (c Ring) ClusterCountFailureReports(ctx context.Context, nodeID string) *IntCmd

+ func (c Ring) ClusterCountKeysInSlot(ctx context.Context, slot int) *IntCmd

+ func (c Ring) ClusterDelSlots(ctx context.Context, slots ...int) *StatusCmd

+ func (c Ring) ClusterDelSlotsRange(ctx context.Context, min, max int) *StatusCmd

+ func (c Ring) ClusterFailover(ctx context.Context) *StatusCmd

+ func (c Ring) ClusterForget(ctx context.Context, nodeID string) *StatusCmd

+ func (c Ring) ClusterGetKeysInSlot(ctx context.Context, slot int, count int) *StringSliceCmd

+ func (c Ring) ClusterInfo(ctx context.Context) *StringCmd

+ func (c Ring) ClusterKeySlot(ctx context.Context, key string) *IntCmd

+ func (c Ring) ClusterMeet(ctx context.Context, host, port string) *StatusCmd

+ func (c Ring) ClusterNodes(ctx context.Context) *StringCmd

+ func (c Ring) ClusterReplicate(ctx context.Context, nodeID string) *StatusCmd

+ func (c Ring) ClusterResetHard(ctx context.Context) *StatusCmd

+ func (c Ring) ClusterResetSoft(ctx context.Context) *StatusCmd

+ func (c Ring) ClusterSaveConfig(ctx context.Context) *StatusCmd

+ func (c Ring) ClusterSlaves(ctx context.Context, nodeID string) *StringSliceCmd

+ func (c Ring) ClusterSlots(ctx context.Context) *ClusterSlotsCmd

+ func (c Ring) Command(ctx context.Context) *CommandsInfoCmd

+ func (c Ring) ConfigGet(ctx context.Context, parameter string) *SliceCmd

+ func (c Ring) ConfigResetStat(ctx context.Context) *StatusCmd

+ func (c Ring) ConfigRewrite(ctx context.Context) *StatusCmd

+ func (c Ring) ConfigSet(ctx context.Context, parameter, value string) *StatusCmd

+ func (c Ring) DBSize(ctx context.Context) *IntCmd

+ func (c Ring) DebugObject(ctx context.Context, key string) *StringCmd

+ func (c Ring) Decr(ctx context.Context, key string) *IntCmd

+ func (c Ring) DecrBy(ctx context.Context, key string, decrement int64) *IntCmd

+ func (c Ring) Del(ctx context.Context, keys ...string) *IntCmd

+ func (c Ring) Dump(ctx context.Context, key string) *StringCmd

+ func (c Ring) Echo(ctx context.Context, message interface{}) *StringCmd

+ func (c Ring) Eval(ctx context.Context, script string, keys []string, args ...interface{}) *Cmd

+ func (c Ring) EvalSha(ctx context.Context, sha1 string, keys []string, args ...interface{}) *Cmd

+ func (c Ring) Exists(ctx context.Context, keys ...string) *IntCmd

+ func (c Ring) Expire(ctx context.Context, key string, expiration time.Duration) *BoolCmd

+ func (c Ring) ExpireAt(ctx context.Context, key string, tm time.Time) *BoolCmd

+ func (c Ring) FlushAll(ctx context.Context) *StatusCmd

+ func (c Ring) FlushAllAsync(ctx context.Context) *StatusCmd

+ func (c Ring) FlushDB(ctx context.Context) *StatusCmd

+ func (c Ring) FlushDBAsync(ctx context.Context) *StatusCmd

+ func (c Ring) GeoAdd(ctx context.Context, key string, geoLocation ...*GeoLocation) *IntCmd

+ func (c Ring) GeoDist(ctx context.Context, key string, member1, member2, unit string) *FloatCmd

+ func (c Ring) GeoHash(ctx context.Context, key string, members ...string) *StringSliceCmd

+ func (c Ring) GeoPos(ctx context.Context, key string, members ...string) *GeoPosCmd

+ func (c Ring) GeoRadius(ctx context.Context, key string, longitude, latitude float64, ...) *GeoLocationCmd

+ func (c Ring) GeoRadiusByMember(ctx context.Context, key, member string, query *GeoRadiusQuery) *GeoLocationCmd

+ func (c Ring) GeoRadiusByMemberStore(ctx context.Context, key, member string, query *GeoRadiusQuery) *IntCmd

+ func (c Ring) GeoRadiusStore(ctx context.Context, key string, longitude, latitude float64, ...) *IntCmd

+ func (c Ring) Get(ctx context.Context, key string) *StringCmd

+ func (c Ring) GetBit(ctx context.Context, key string, offset int64) *IntCmd

+ func (c Ring) GetRange(ctx context.Context, key string, start, end int64) *StringCmd

+ func (c Ring) GetSet(ctx context.Context, key string, value interface{}) *StringCmd

+ func (c Ring) HDel(ctx context.Context, key string, fields ...string) *IntCmd

+ func (c Ring) HExists(ctx context.Context, key, field string) *BoolCmd

+ func (c Ring) HGet(ctx context.Context, key, field string) *StringCmd

+ func (c Ring) HGetAll(ctx context.Context, key string) *StringStringMapCmd

+ func (c Ring) HIncrBy(ctx context.Context, key, field string, incr int64) *IntCmd

+ func (c Ring) HIncrByFloat(ctx context.Context, key, field string, incr float64) *FloatCmd

+ func (c Ring) HKeys(ctx context.Context, key string) *StringSliceCmd

+ func (c Ring) HLen(ctx context.Context, key string) *IntCmd

+ func (c Ring) HMGet(ctx context.Context, key string, fields ...string) *SliceCmd

+ func (c Ring) HMSet(ctx context.Context, key string, values ...interface{}) *BoolCmd

+ func (c Ring) HScan(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd

+ func (c Ring) HSet(ctx context.Context, key string, values ...interface{}) *IntCmd

+ func (c Ring) HSetNX(ctx context.Context, key, field string, value interface{}) *BoolCmd

+ func (c Ring) HVals(ctx context.Context, key string) *StringSliceCmd

+ func (c Ring) Incr(ctx context.Context, key string) *IntCmd

+ func (c Ring) IncrBy(ctx context.Context, key string, value int64) *IntCmd

+ func (c Ring) IncrByFloat(ctx context.Context, key string, value float64) *FloatCmd

+ func (c Ring) Info(ctx context.Context, section ...string) *StringCmd

+ func (c Ring) Keys(ctx context.Context, pattern string) *StringSliceCmd

+ func (c Ring) LIndex(ctx context.Context, key string, index int64) *StringCmd

+ func (c Ring) LInsert(ctx context.Context, key, op string, pivot, value interface{}) *IntCmd

+ func (c Ring) LInsertAfter(ctx context.Context, key string, pivot, value interface{}) *IntCmd

+ func (c Ring) LInsertBefore(ctx context.Context, key string, pivot, value interface{}) *IntCmd

+ func (c Ring) LLen(ctx context.Context, key string) *IntCmd

+ func (c Ring) LPop(ctx context.Context, key string) *StringCmd

+ func (c Ring) LPush(ctx context.Context, key string, values ...interface{}) *IntCmd

+ func (c Ring) LPushX(ctx context.Context, key string, values ...interface{}) *IntCmd

+ func (c Ring) LRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd

+ func (c Ring) LRem(ctx context.Context, key string, count int64, value interface{}) *IntCmd

+ func (c Ring) LSet(ctx context.Context, key string, index int64, value interface{}) *StatusCmd

+ func (c Ring) LTrim(ctx context.Context, key string, start, stop int64) *StatusCmd

+ func (c Ring) LastSave(ctx context.Context) *IntCmd

+ func (c Ring) MGet(ctx context.Context, keys ...string) *SliceCmd

+ func (c Ring) MSet(ctx context.Context, values ...interface{}) *StatusCmd

+ func (c Ring) MSetNX(ctx context.Context, values ...interface{}) *BoolCmd

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

+ func (c Ring) Migrate(ctx context.Context, host, port, key string, db int, timeout time.Duration) *StatusCmd

+ func (c Ring) Move(ctx context.Context, key string, db int) *BoolCmd

+ func (c Ring) ObjectEncoding(ctx context.Context, key string) *StringCmd

+ func (c Ring) ObjectIdleTime(ctx context.Context, key string) *DurationCmd

+ func (c Ring) ObjectRefCount(ctx context.Context, key string) *IntCmd

+ func (c Ring) PExpire(ctx context.Context, key string, expiration time.Duration) *BoolCmd

+ func (c Ring) PExpireAt(ctx context.Context, key string, tm time.Time) *BoolCmd

+ func (c Ring) PFAdd(ctx context.Context, key string, els ...interface{}) *IntCmd

+ func (c Ring) PFCount(ctx context.Context, keys ...string) *IntCmd

+ func (c Ring) PFMerge(ctx context.Context, dest string, keys ...string) *StatusCmd

+ func (c Ring) PTTL(ctx context.Context, key string) *DurationCmd

+ func (c Ring) Persist(ctx context.Context, key string) *BoolCmd

+ func (c Ring) Ping(ctx context.Context) *StatusCmd

+ func (c Ring) PubSubChannels(ctx context.Context, pattern string) *StringSliceCmd

+ func (c Ring) PubSubNumPat(ctx context.Context) *IntCmd

+ func (c Ring) PubSubNumSub(ctx context.Context, channels ...string) *StringIntMapCmd

+ func (c Ring) Publish(ctx context.Context, channel string, message interface{}) *IntCmd

+ func (c Ring) Quit(ctx context.Context) *StatusCmd

+ func (c Ring) RPop(ctx context.Context, key string) *StringCmd

+ func (c Ring) RPopLPush(ctx context.Context, source, destination string) *StringCmd

+ func (c Ring) RPush(ctx context.Context, key string, values ...interface{}) *IntCmd

+ func (c Ring) RPushX(ctx context.Context, key string, values ...interface{}) *IntCmd

+ func (c Ring) RandomKey(ctx context.Context) *StringCmd

+ func (c Ring) ReadOnly(ctx context.Context) *StatusCmd

+ func (c Ring) ReadWrite(ctx context.Context) *StatusCmd

+ func (c Ring) Rename(ctx context.Context, key, newkey string) *StatusCmd

+ func (c Ring) RenameNX(ctx context.Context, key, newkey string) *BoolCmd

+ func (c Ring) Restore(ctx context.Context, key string, ttl time.Duration, value string) *StatusCmd

+ func (c Ring) RestoreReplace(ctx context.Context, key string, ttl time.Duration, value string) *StatusCmd

+ func (c Ring) SAdd(ctx context.Context, key string, members ...interface{}) *IntCmd

+ func (c Ring) SCard(ctx context.Context, key string) *IntCmd

+ func (c Ring) SDiff(ctx context.Context, keys ...string) *StringSliceCmd

+ func (c Ring) SDiffStore(ctx context.Context, destination string, keys ...string) *IntCmd

+ func (c Ring) SInter(ctx context.Context, keys ...string) *StringSliceCmd

+ func (c Ring) SInterStore(ctx context.Context, destination string, keys ...string) *IntCmd

+ func (c Ring) SIsMember(ctx context.Context, key string, member interface{}) *BoolCmd

+ func (c Ring) SMembers(ctx context.Context, key string) *StringSliceCmd

+ func (c Ring) SMembersMap(ctx context.Context, key string) *StringStructMapCmd

+ func (c Ring) SMove(ctx context.Context, source, destination string, member interface{}) *BoolCmd

+ func (c Ring) SPop(ctx context.Context, key string) *StringCmd

+ func (c Ring) SPopN(ctx context.Context, key string, count int64) *StringSliceCmd

+ func (c Ring) SRandMember(ctx context.Context, key string) *StringCmd

+ func (c Ring) SRandMemberN(ctx context.Context, key string, count int64) *StringSliceCmd

+ func (c Ring) SRem(ctx context.Context, key string, members ...interface{}) *IntCmd

+ func (c Ring) SScan(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd

+ func (c Ring) SUnion(ctx context.Context, keys ...string) *StringSliceCmd

+ func (c Ring) SUnionStore(ctx context.Context, destination string, keys ...string) *IntCmd

+ func (c Ring) Save(ctx context.Context) *StatusCmd

+ func (c Ring) Scan(ctx context.Context, cursor uint64, match string, count int64) *ScanCmd

+ func (c Ring) ScriptExists(ctx context.Context, hashes ...string) *BoolSliceCmd

+ func (c Ring) ScriptFlush(ctx context.Context) *StatusCmd

+ func (c Ring) ScriptKill(ctx context.Context) *StatusCmd

+ func (c Ring) ScriptLoad(ctx context.Context, script string) *StringCmd

+ func (c Ring) Set(ctx context.Context, key string, value interface{}, expiration time.Duration) *StatusCmd

+ func (c Ring) SetBit(ctx context.Context, key string, offset int64, value int) *IntCmd

+ func (c Ring) SetNX(ctx context.Context, key string, value interface{}, expiration time.Duration) *BoolCmd

+ func (c Ring) SetRange(ctx context.Context, key string, offset int64, value string) *IntCmd

+ func (c Ring) SetXX(ctx context.Context, key string, value interface{}, expiration time.Duration) *BoolCmd

+ func (c Ring) Shutdown(ctx context.Context) *StatusCmd

+ func (c Ring) ShutdownNoSave(ctx context.Context) *StatusCmd

+ func (c Ring) ShutdownSave(ctx context.Context) *StatusCmd

+ func (c Ring) SlaveOf(ctx context.Context, host, port string) *StatusCmd

+ func (c Ring) SlowLogGet(ctx context.Context, num int64) *SlowLogCmd

+ func (c Ring) Sort(ctx context.Context, key string, sort *Sort) *StringSliceCmd

+ func (c Ring) SortInterfaces(ctx context.Context, key string, sort *Sort) *SliceCmd

+ func (c Ring) SortStore(ctx context.Context, key, store string, sort *Sort) *IntCmd

+ func (c Ring) StrLen(ctx context.Context, key string) *IntCmd

+ func (c Ring) Sync(ctx context.Context)

+ func (c Ring) TTL(ctx context.Context, key string) *DurationCmd

+ func (c Ring) Time(ctx context.Context) *TimeCmd

+ func (c Ring) Touch(ctx context.Context, keys ...string) *IntCmd

+ func (c Ring) Type(ctx context.Context, key string) *StatusCmd

+ func (c Ring) Unlink(ctx context.Context, keys ...string) *IntCmd

+ func (c Ring) Wait(ctx context.Context, numSlaves int, timeout time.Duration) *IntCmd

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

+ func (c Ring) XAdd(ctx context.Context, a *XAddArgs) *StringCmd

+ func (c Ring) XClaim(ctx context.Context, a *XClaimArgs) *XMessageSliceCmd

+ func (c Ring) XClaimJustID(ctx context.Context, a *XClaimArgs) *StringSliceCmd

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

+ func (c Ring) XGroupCreate(ctx context.Context, stream, group, start string) *StatusCmd

+ func (c Ring) XGroupCreateMkStream(ctx context.Context, stream, group, start string) *StatusCmd

+ func (c Ring) XGroupDelConsumer(ctx context.Context, stream, group, consumer string) *IntCmd

+ func (c Ring) XGroupDestroy(ctx context.Context, stream, group string) *IntCmd

+ func (c Ring) XGroupSetID(ctx context.Context, stream, group, start string) *StatusCmd

+ func (c Ring) XInfoGroups(ctx context.Context, key string) *XInfoGroupsCmd

+ func (c Ring) XLen(ctx context.Context, stream string) *IntCmd

+ func (c Ring) XPending(ctx context.Context, stream, group string) *XPendingCmd

+ func (c Ring) XPendingExt(ctx context.Context, a *XPendingExtArgs) *XPendingExtCmd

+ func (c Ring) XRange(ctx context.Context, stream, start, stop string) *XMessageSliceCmd

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

+ func (c Ring) XRead(ctx context.Context, a *XReadArgs) *XStreamSliceCmd

+ func (c Ring) XReadGroup(ctx context.Context, a *XReadGroupArgs) *XStreamSliceCmd

+ func (c Ring) XReadStreams(ctx context.Context, streams ...string) *XStreamSliceCmd

+ func (c Ring) XRevRange(ctx context.Context, stream, start, stop string) *XMessageSliceCmd

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

+ func (c Ring) XTrim(ctx context.Context, key string, maxLen int64) *IntCmd

+ func (c Ring) XTrimApprox(ctx context.Context, key string, maxLen int64) *IntCmd

+ func (c Ring) ZAdd(ctx context.Context, key string, members ...*Z) *IntCmd

+ func (c Ring) ZAddCh(ctx context.Context, key string, members ...*Z) *IntCmd

+ func (c Ring) ZAddNX(ctx context.Context, key string, members ...*Z) *IntCmd

+ func (c Ring) ZAddNXCh(ctx context.Context, key string, members ...*Z) *IntCmd

+ func (c Ring) ZAddXX(ctx context.Context, key string, members ...*Z) *IntCmd

+ func (c Ring) ZAddXXCh(ctx context.Context, key string, members ...*Z) *IntCmd

+ func (c Ring) ZCard(ctx context.Context, key string) *IntCmd

+ func (c Ring) ZCount(ctx context.Context, key, min, max string) *IntCmd

+ func (c Ring) ZIncr(ctx context.Context, key string, member *Z) *FloatCmd

+ func (c Ring) ZIncrBy(ctx context.Context, key string, increment float64, member string) *FloatCmd

+ func (c Ring) ZIncrNX(ctx context.Context, key string, member *Z) *FloatCmd

+ func (c Ring) ZIncrXX(ctx context.Context, key string, member *Z) *FloatCmd

+ func (c Ring) ZInterStore(ctx context.Context, destination string, store *ZStore) *IntCmd

+ func (c Ring) ZLexCount(ctx context.Context, key, min, max string) *IntCmd

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

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

+ func (c Ring) ZRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd

+ func (c Ring) ZRangeByLex(ctx context.Context, key string, opt *ZRangeBy) *StringSliceCmd

+ func (c Ring) ZRangeByScore(ctx context.Context, key string, opt *ZRangeBy) *StringSliceCmd

+ func (c Ring) ZRangeByScoreWithScores(ctx context.Context, key string, opt *ZRangeBy) *ZSliceCmd

+ func (c Ring) ZRangeWithScores(ctx context.Context, key string, start, stop int64) *ZSliceCmd

+ func (c Ring) ZRank(ctx context.Context, key, member string) *IntCmd

+ func (c Ring) ZRem(ctx context.Context, key string, members ...interface{}) *IntCmd

+ func (c Ring) ZRemRangeByLex(ctx context.Context, key, min, max string) *IntCmd

+ func (c Ring) ZRemRangeByRank(ctx context.Context, key string, start, stop int64) *IntCmd

+ func (c Ring) ZRemRangeByScore(ctx context.Context, key, min, max string) *IntCmd

+ func (c Ring) ZRevRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd

+ func (c Ring) ZRevRangeByLex(ctx context.Context, key string, opt *ZRangeBy) *StringSliceCmd

+ func (c Ring) ZRevRangeByScore(ctx context.Context, key string, opt *ZRangeBy) *StringSliceCmd

+ func (c Ring) ZRevRangeByScoreWithScores(ctx context.Context, key string, opt *ZRangeBy) *ZSliceCmd

+ func (c Ring) ZRevRangeWithScores(ctx context.Context, key string, start, stop int64) *ZSliceCmd

+ func (c Ring) ZRevRank(ctx context.Context, key, member string) *IntCmd

+ func (c Ring) ZScan(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd

+ func (c Ring) ZScore(ctx context.Context, key, member string) *FloatCmd

+ func (c Ring) ZUnionStore(ctx context.Context, dest string, store *ZStore) *IntCmd

+ func (hs *Ring) AddHook(hook Hook)

+ type RingOptions struct

+ Addrs map[string]string

+ DB int

+ DialTimeout time.Duration

+ Dialer func(ctx context.Context, network, addr string) (net.Conn, error)

+ HeartbeatFrequency time.Duration

+ IdleCheckFrequency time.Duration

+ IdleTimeout time.Duration

+ Limiter Limiter

+ MaxConnAge time.Duration

+ MaxRetries int

+ MaxRetryBackoff time.Duration

+ MinIdleConns int

+ MinRetryBackoff time.Duration

+ NewClient func(name string, opt *Options) *Client

+ NewConsistentHash func(shards []string) ConsistentHash

+ OnConnect func(ctx context.Context, cn *Conn) error

+ Password string

+ PoolSize int

+ PoolTimeout time.Duration

+ ReadTimeout time.Duration

+ TLSConfig *tls.Config

+ Username string

+ WriteTimeout time.Duration

+ type ScanCmd struct

+ func NewScanCmd(ctx context.Context, process cmdable, args ...interface{}) *ScanCmd

+ func NewScanCmdResult(keys []string, cursor uint64, err error) *ScanCmd

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

+ func (cmd *ScanCmd) Err() error

+ func (cmd *ScanCmd) FullName() string

+ func (cmd *ScanCmd) Iterator() *ScanIterator

+ func (cmd *ScanCmd) Name() string

+ func (cmd *ScanCmd) Result() (keys []string, cursor uint64, err error)

+ func (cmd *ScanCmd) SetErr(e 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(ctx context.Context) bool

+ func (it *ScanIterator) Val() string

+ type Script struct

+ func NewScript(src string) *Script

+ func (s *Script) Eval(ctx context.Context, c scripter, keys []string, args ...interface{}) *Cmd

+ func (s *Script) EvalSha(ctx context.Context, c scripter, keys []string, args ...interface{}) *Cmd

+ func (s *Script) Exists(ctx context.Context, c scripter) *BoolSliceCmd

+ func (s *Script) Hash() string

+ func (s *Script) Load(ctx context.Context, c scripter) *StringCmd

+ func (s *Script) Run(ctx context.Context, c scripter, keys []string, args ...interface{}) *Cmd

+ type SentinelClient struct

+ func NewSentinelClient(opt *Options) *SentinelClient

+ func (c *SentinelClient) CkQuorum(ctx context.Context, name string) *StringCmd

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

+ func (c *SentinelClient) Failover(ctx context.Context, name string) *StatusCmd

+ func (c *SentinelClient) FlushConfig(ctx context.Context) *StatusCmd

+ func (c *SentinelClient) GetMasterAddrByName(ctx context.Context, name string) *StringSliceCmd

+ func (c *SentinelClient) Master(ctx context.Context, name string) *StringStringMapCmd

+ func (c *SentinelClient) Masters(ctx context.Context) *SliceCmd

+ func (c *SentinelClient) Monitor(ctx context.Context, name, ip, port, quorum string) *StringCmd

+ func (c *SentinelClient) PSubscribe(ctx context.Context, channels ...string) *PubSub

+ func (c *SentinelClient) Ping(ctx context.Context) *StringCmd

+ func (c *SentinelClient) Process(ctx context.Context, cmd Cmder) error

+ func (c *SentinelClient) Remove(ctx context.Context, name string) *StringCmd

+ func (c *SentinelClient) Reset(ctx context.Context, pattern string) *IntCmd

+ func (c *SentinelClient) Sentinels(ctx context.Context, name string) *SliceCmd

+ func (c *SentinelClient) Set(ctx context.Context, name, option, value string) *StringCmd

+ func (c *SentinelClient) Slaves(ctx context.Context, name string) *SliceCmd

+ func (c *SentinelClient) Subscribe(ctx context.Context, channels ...string) *PubSub

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

+ func (c SentinelClient) Close() error

+ func (c SentinelClient) String() string

+ type SliceCmd struct

+ func NewSliceCmd(ctx context.Context, args ...interface{}) *SliceCmd

+ func NewSliceResult(val []interface{}, err error) *SliceCmd

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

+ func (cmd *SliceCmd) Err() error

+ func (cmd *SliceCmd) FullName() string

+ func (cmd *SliceCmd) Name() string

+ func (cmd *SliceCmd) Result() ([]interface{}, error)

+ func (cmd *SliceCmd) SetErr(e error)

+ func (cmd *SliceCmd) String() string

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

+ type SlowLog struct

+ Args []string

+ ClientAddr string

+ ClientName string

+ Duration time.Duration

+ ID int64

+ Time time.Time

+ type SlowLogCmd struct

+ func NewSlowLogCmd(ctx context.Context, args ...interface{}) *SlowLogCmd

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

+ func (cmd *SlowLogCmd) Err() error

+ func (cmd *SlowLogCmd) FullName() string

+ func (cmd *SlowLogCmd) Name() string

+ func (cmd *SlowLogCmd) Result() ([]SlowLog, error)

+ func (cmd *SlowLogCmd) SetErr(e error)

+ func (cmd *SlowLogCmd) String() string

+ func (cmd *SlowLogCmd) Val() []SlowLog

+ type Sort struct

+ Alpha bool

+ By string

+ Count int64

+ Get []string

+ Offset int64

+ Order string

+ type StatefulCmdable interface

+ Auth func(ctx context.Context, password string) *StatusCmd

+ AuthACL func(ctx context.Context, username, password string) *StatusCmd

+ ClientSetName func(ctx context.Context, name string) *BoolCmd

+ Select func(ctx context.Context, index int) *StatusCmd

+ SwapDB func(ctx context.Context, index1, index2 int) *StatusCmd

+ type StatusCmd struct

+ func NewStatusCmd(ctx context.Context, args ...interface{}) *StatusCmd

+ func NewStatusResult(val string, err error) *StatusCmd

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

+ func (cmd *StatusCmd) Err() error

+ func (cmd *StatusCmd) FullName() string

+ func (cmd *StatusCmd) Name() string

+ func (cmd *StatusCmd) Result() (string, error)

+ func (cmd *StatusCmd) SetErr(e error)

+ func (cmd *StatusCmd) String() string

+ func (cmd *StatusCmd) Val() string

+ type StringCmd struct

+ func NewStringCmd(ctx context.Context, args ...interface{}) *StringCmd

+ func NewStringResult(val string, err error) *StringCmd

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

+ func (cmd *StringCmd) Bytes() ([]byte, error)

+ func (cmd *StringCmd) Err() error

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

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

+ func (cmd *StringCmd) FullName() string

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

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

+ func (cmd *StringCmd) Name() string

+ func (cmd *StringCmd) Result() (string, error)

+ func (cmd *StringCmd) Scan(val interface{}) error

+ func (cmd *StringCmd) SetErr(e error)

+ func (cmd *StringCmd) String() string

+ func (cmd *StringCmd) Time() (time.Time, error)

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

+ func (cmd *StringCmd) Val() string

+ type StringIntMapCmd struct

+ func NewStringIntMapCmd(ctx context.Context, args ...interface{}) *StringIntMapCmd

+ func NewStringIntMapCmdResult(val map[string]int64, err error) *StringIntMapCmd

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

+ func (cmd *StringIntMapCmd) Err() error

+ func (cmd *StringIntMapCmd) FullName() string

+ func (cmd *StringIntMapCmd) Name() string

+ func (cmd *StringIntMapCmd) Result() (map[string]int64, error)

+ func (cmd *StringIntMapCmd) SetErr(e error)

+ func (cmd *StringIntMapCmd) String() string

+ func (cmd *StringIntMapCmd) Val() map[string]int64

+ type StringSliceCmd struct

+ func NewStringSliceCmd(ctx context.Context, args ...interface{}) *StringSliceCmd

+ func NewStringSliceResult(val []string, err error) *StringSliceCmd

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

+ func (cmd *StringSliceCmd) Err() error

+ func (cmd *StringSliceCmd) FullName() string

+ func (cmd *StringSliceCmd) Name() string

+ func (cmd *StringSliceCmd) Result() ([]string, error)

+ func (cmd *StringSliceCmd) ScanSlice(container interface{}) error

+ func (cmd *StringSliceCmd) SetErr(e error)

+ func (cmd *StringSliceCmd) String() string

+ func (cmd *StringSliceCmd) Val() []string

+ type StringStringMapCmd struct

+ func NewStringStringMapCmd(ctx context.Context, args ...interface{}) *StringStringMapCmd

+ func NewStringStringMapResult(val map[string]string, err error) *StringStringMapCmd

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

+ func (cmd *StringStringMapCmd) Err() error

+ func (cmd *StringStringMapCmd) FullName() string

+ func (cmd *StringStringMapCmd) Name() string

+ func (cmd *StringStringMapCmd) Result() (map[string]string, error)

+ func (cmd *StringStringMapCmd) SetErr(e error)

+ func (cmd *StringStringMapCmd) String() string

+ func (cmd *StringStringMapCmd) Val() map[string]string

+ type StringStructMapCmd struct

+ func NewStringStructMapCmd(ctx context.Context, args ...interface{}) *StringStructMapCmd

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

+ func (cmd *StringStructMapCmd) Err() error

+ func (cmd *StringStructMapCmd) FullName() string

+ func (cmd *StringStructMapCmd) Name() string

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

+ func (cmd *StringStructMapCmd) SetErr(e error)

+ func (cmd *StringStructMapCmd) String() string

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

+ type Subscription struct

+ Channel string

+ Count int

+ Kind string

+ func (m *Subscription) String() string

+ type TimeCmd struct

+ func NewTimeCmd(ctx context.Context, args ...interface{}) *TimeCmd

+ func NewTimeCmdResult(val time.Time, err error) *TimeCmd

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

+ func (cmd *TimeCmd) Err() error

+ func (cmd *TimeCmd) FullName() string

+ func (cmd *TimeCmd) Name() string

+ func (cmd *TimeCmd) Result() (time.Time, error)

+ func (cmd *TimeCmd) SetErr(e error)

+ func (cmd *TimeCmd) String() string

+ func (cmd *TimeCmd) Val() time.Time

+ type Tx struct

+ func (c *Tx) Close(ctx context.Context) error

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

+ func (c *Tx) Pipeline() Pipeliner

+ func (c *Tx) Pipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error)

+ func (c *Tx) Process(ctx context.Context, cmd Cmder) error

+ func (c *Tx) String() string

+ func (c *Tx) TxPipeline() Pipeliner

+ func (c *Tx) TxPipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error)

+ func (c *Tx) Unwatch(ctx context.Context, keys ...string) *StatusCmd

+ func (c *Tx) Watch(ctx context.Context, keys ...string) *StatusCmd

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

+ func (c Tx) Append(ctx context.Context, key, value string) *IntCmd

+ func (c Tx) Auth(ctx context.Context, password string) *StatusCmd

+ func (c Tx) AuthACL(ctx context.Context, username, password string) *StatusCmd

+ func (c Tx) BLPop(ctx context.Context, timeout time.Duration, keys ...string) *StringSliceCmd

+ func (c Tx) BRPop(ctx context.Context, timeout time.Duration, keys ...string) *StringSliceCmd

+ func (c Tx) BRPopLPush(ctx context.Context, source, destination string, timeout time.Duration) *StringCmd

+ func (c Tx) BZPopMax(ctx context.Context, timeout time.Duration, keys ...string) *ZWithKeyCmd

+ func (c Tx) BZPopMin(ctx context.Context, timeout time.Duration, keys ...string) *ZWithKeyCmd

+ func (c Tx) BgRewriteAOF(ctx context.Context) *StatusCmd

+ func (c Tx) BgSave(ctx context.Context) *StatusCmd

+ func (c Tx) BitCount(ctx context.Context, key string, bitCount *BitCount) *IntCmd

+ func (c Tx) BitField(ctx context.Context, key string, args ...interface{}) *IntSliceCmd

+ func (c Tx) BitOpAnd(ctx context.Context, destKey string, keys ...string) *IntCmd

+ func (c Tx) BitOpNot(ctx context.Context, destKey string, key string) *IntCmd

+ func (c Tx) BitOpOr(ctx context.Context, destKey string, keys ...string) *IntCmd

+ func (c Tx) BitOpXor(ctx context.Context, destKey string, keys ...string) *IntCmd

+ func (c Tx) BitPos(ctx context.Context, key string, bit int64, pos ...int64) *IntCmd

+ func (c Tx) ClientGetName(ctx context.Context) *StringCmd

+ func (c Tx) ClientID(ctx context.Context) *IntCmd

+ func (c Tx) ClientKill(ctx context.Context, ipPort string) *StatusCmd

+ func (c Tx) ClientKillByFilter(ctx context.Context, keys ...string) *IntCmd

+ func (c Tx) ClientList(ctx context.Context) *StringCmd

+ func (c Tx) ClientPause(ctx context.Context, dur time.Duration) *BoolCmd

+ func (c Tx) ClientSetName(ctx context.Context, name string) *BoolCmd

+ func (c Tx) ClientUnblock(ctx context.Context, id int64) *IntCmd

+ func (c Tx) ClientUnblockWithError(ctx context.Context, id int64) *IntCmd

+ func (c Tx) ClusterAddSlots(ctx context.Context, slots ...int) *StatusCmd

+ func (c Tx) ClusterAddSlotsRange(ctx context.Context, min, max int) *StatusCmd

+ func (c Tx) ClusterCountFailureReports(ctx context.Context, nodeID string) *IntCmd

+ func (c Tx) ClusterCountKeysInSlot(ctx context.Context, slot int) *IntCmd

+ func (c Tx) ClusterDelSlots(ctx context.Context, slots ...int) *StatusCmd

+ func (c Tx) ClusterDelSlotsRange(ctx context.Context, min, max int) *StatusCmd

+ func (c Tx) ClusterFailover(ctx context.Context) *StatusCmd

+ func (c Tx) ClusterForget(ctx context.Context, nodeID string) *StatusCmd

+ func (c Tx) ClusterGetKeysInSlot(ctx context.Context, slot int, count int) *StringSliceCmd

+ func (c Tx) ClusterInfo(ctx context.Context) *StringCmd

+ func (c Tx) ClusterKeySlot(ctx context.Context, key string) *IntCmd

+ func (c Tx) ClusterMeet(ctx context.Context, host, port string) *StatusCmd

+ func (c Tx) ClusterNodes(ctx context.Context) *StringCmd

+ func (c Tx) ClusterReplicate(ctx context.Context, nodeID string) *StatusCmd

+ func (c Tx) ClusterResetHard(ctx context.Context) *StatusCmd

+ func (c Tx) ClusterResetSoft(ctx context.Context) *StatusCmd

+ func (c Tx) ClusterSaveConfig(ctx context.Context) *StatusCmd

+ func (c Tx) ClusterSlaves(ctx context.Context, nodeID string) *StringSliceCmd

+ func (c Tx) ClusterSlots(ctx context.Context) *ClusterSlotsCmd

+ func (c Tx) Command(ctx context.Context) *CommandsInfoCmd

+ func (c Tx) ConfigGet(ctx context.Context, parameter string) *SliceCmd

+ func (c Tx) ConfigResetStat(ctx context.Context) *StatusCmd

+ func (c Tx) ConfigRewrite(ctx context.Context) *StatusCmd

+ func (c Tx) ConfigSet(ctx context.Context, parameter, value string) *StatusCmd

+ func (c Tx) DBSize(ctx context.Context) *IntCmd

+ func (c Tx) DebugObject(ctx context.Context, key string) *StringCmd

+ func (c Tx) Decr(ctx context.Context, key string) *IntCmd

+ func (c Tx) DecrBy(ctx context.Context, key string, decrement int64) *IntCmd

+ func (c Tx) Del(ctx context.Context, keys ...string) *IntCmd

+ func (c Tx) Dump(ctx context.Context, key string) *StringCmd

+ func (c Tx) Echo(ctx context.Context, message interface{}) *StringCmd

+ func (c Tx) Eval(ctx context.Context, script string, keys []string, args ...interface{}) *Cmd

+ func (c Tx) EvalSha(ctx context.Context, sha1 string, keys []string, args ...interface{}) *Cmd

+ func (c Tx) Exists(ctx context.Context, keys ...string) *IntCmd

+ func (c Tx) Expire(ctx context.Context, key string, expiration time.Duration) *BoolCmd

+ func (c Tx) ExpireAt(ctx context.Context, key string, tm time.Time) *BoolCmd

+ func (c Tx) FlushAll(ctx context.Context) *StatusCmd

+ func (c Tx) FlushAllAsync(ctx context.Context) *StatusCmd

+ func (c Tx) FlushDB(ctx context.Context) *StatusCmd

+ func (c Tx) FlushDBAsync(ctx context.Context) *StatusCmd

+ func (c Tx) GeoAdd(ctx context.Context, key string, geoLocation ...*GeoLocation) *IntCmd

+ func (c Tx) GeoDist(ctx context.Context, key string, member1, member2, unit string) *FloatCmd

+ func (c Tx) GeoHash(ctx context.Context, key string, members ...string) *StringSliceCmd

+ func (c Tx) GeoPos(ctx context.Context, key string, members ...string) *GeoPosCmd

+ func (c Tx) GeoRadius(ctx context.Context, key string, longitude, latitude float64, ...) *GeoLocationCmd

+ func (c Tx) GeoRadiusByMember(ctx context.Context, key, member string, query *GeoRadiusQuery) *GeoLocationCmd

+ func (c Tx) GeoRadiusByMemberStore(ctx context.Context, key, member string, query *GeoRadiusQuery) *IntCmd

+ func (c Tx) GeoRadiusStore(ctx context.Context, key string, longitude, latitude float64, ...) *IntCmd

+ func (c Tx) Get(ctx context.Context, key string) *StringCmd

+ func (c Tx) GetBit(ctx context.Context, key string, offset int64) *IntCmd

+ func (c Tx) GetRange(ctx context.Context, key string, start, end int64) *StringCmd

+ func (c Tx) GetSet(ctx context.Context, key string, value interface{}) *StringCmd

+ func (c Tx) HDel(ctx context.Context, key string, fields ...string) *IntCmd

+ func (c Tx) HExists(ctx context.Context, key, field string) *BoolCmd

+ func (c Tx) HGet(ctx context.Context, key, field string) *StringCmd

+ func (c Tx) HGetAll(ctx context.Context, key string) *StringStringMapCmd

+ func (c Tx) HIncrBy(ctx context.Context, key, field string, incr int64) *IntCmd

+ func (c Tx) HIncrByFloat(ctx context.Context, key, field string, incr float64) *FloatCmd

+ func (c Tx) HKeys(ctx context.Context, key string) *StringSliceCmd

+ func (c Tx) HLen(ctx context.Context, key string) *IntCmd

+ func (c Tx) HMGet(ctx context.Context, key string, fields ...string) *SliceCmd

+ func (c Tx) HMSet(ctx context.Context, key string, values ...interface{}) *BoolCmd

+ func (c Tx) HScan(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd

+ func (c Tx) HSet(ctx context.Context, key string, values ...interface{}) *IntCmd

+ func (c Tx) HSetNX(ctx context.Context, key, field string, value interface{}) *BoolCmd

+ func (c Tx) HVals(ctx context.Context, key string) *StringSliceCmd

+ func (c Tx) Incr(ctx context.Context, key string) *IntCmd

+ func (c Tx) IncrBy(ctx context.Context, key string, value int64) *IntCmd

+ func (c Tx) IncrByFloat(ctx context.Context, key string, value float64) *FloatCmd

+ func (c Tx) Info(ctx context.Context, section ...string) *StringCmd

+ func (c Tx) Keys(ctx context.Context, pattern string) *StringSliceCmd

+ func (c Tx) LIndex(ctx context.Context, key string, index int64) *StringCmd

+ func (c Tx) LInsert(ctx context.Context, key, op string, pivot, value interface{}) *IntCmd

+ func (c Tx) LInsertAfter(ctx context.Context, key string, pivot, value interface{}) *IntCmd

+ func (c Tx) LInsertBefore(ctx context.Context, key string, pivot, value interface{}) *IntCmd

+ func (c Tx) LLen(ctx context.Context, key string) *IntCmd

+ func (c Tx) LPop(ctx context.Context, key string) *StringCmd

+ func (c Tx) LPush(ctx context.Context, key string, values ...interface{}) *IntCmd

+ func (c Tx) LPushX(ctx context.Context, key string, values ...interface{}) *IntCmd

+ func (c Tx) LRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd

+ func (c Tx) LRem(ctx context.Context, key string, count int64, value interface{}) *IntCmd

+ func (c Tx) LSet(ctx context.Context, key string, index int64, value interface{}) *StatusCmd

+ func (c Tx) LTrim(ctx context.Context, key string, start, stop int64) *StatusCmd

+ func (c Tx) LastSave(ctx context.Context) *IntCmd

+ func (c Tx) MGet(ctx context.Context, keys ...string) *SliceCmd

+ func (c Tx) MSet(ctx context.Context, values ...interface{}) *StatusCmd

+ func (c Tx) MSetNX(ctx context.Context, values ...interface{}) *BoolCmd

+ func (c Tx) MemoryUsage(ctx context.Context, key string, samples ...int) *IntCmd

+ func (c Tx) Migrate(ctx context.Context, host, port, key string, db int, timeout time.Duration) *StatusCmd

+ func (c Tx) Move(ctx context.Context, key string, db int) *BoolCmd

+ func (c Tx) ObjectEncoding(ctx context.Context, key string) *StringCmd

+ func (c Tx) ObjectIdleTime(ctx context.Context, key string) *DurationCmd

+ func (c Tx) ObjectRefCount(ctx context.Context, key string) *IntCmd

+ func (c Tx) PExpire(ctx context.Context, key string, expiration time.Duration) *BoolCmd

+ func (c Tx) PExpireAt(ctx context.Context, key string, tm time.Time) *BoolCmd

+ func (c Tx) PFAdd(ctx context.Context, key string, els ...interface{}) *IntCmd

+ func (c Tx) PFCount(ctx context.Context, keys ...string) *IntCmd

+ func (c Tx) PFMerge(ctx context.Context, dest string, keys ...string) *StatusCmd

+ func (c Tx) PTTL(ctx context.Context, key string) *DurationCmd

+ func (c Tx) Persist(ctx context.Context, key string) *BoolCmd

+ func (c Tx) Ping(ctx context.Context) *StatusCmd

+ func (c Tx) PubSubChannels(ctx context.Context, pattern string) *StringSliceCmd

+ func (c Tx) PubSubNumPat(ctx context.Context) *IntCmd

+ func (c Tx) PubSubNumSub(ctx context.Context, channels ...string) *StringIntMapCmd

+ func (c Tx) Publish(ctx context.Context, channel string, message interface{}) *IntCmd

+ func (c Tx) Quit(ctx context.Context) *StatusCmd

+ func (c Tx) RPop(ctx context.Context, key string) *StringCmd

+ func (c Tx) RPopLPush(ctx context.Context, source, destination string) *StringCmd

+ func (c Tx) RPush(ctx context.Context, key string, values ...interface{}) *IntCmd

+ func (c Tx) RPushX(ctx context.Context, key string, values ...interface{}) *IntCmd

+ func (c Tx) RandomKey(ctx context.Context) *StringCmd

+ func (c Tx) ReadOnly(ctx context.Context) *StatusCmd

+ func (c Tx) ReadWrite(ctx context.Context) *StatusCmd

+ func (c Tx) Rename(ctx context.Context, key, newkey string) *StatusCmd

+ func (c Tx) RenameNX(ctx context.Context, key, newkey string) *BoolCmd

+ func (c Tx) Restore(ctx context.Context, key string, ttl time.Duration, value string) *StatusCmd

+ func (c Tx) RestoreReplace(ctx context.Context, key string, ttl time.Duration, value string) *StatusCmd

+ func (c Tx) SAdd(ctx context.Context, key string, members ...interface{}) *IntCmd

+ func (c Tx) SCard(ctx context.Context, key string) *IntCmd

+ func (c Tx) SDiff(ctx context.Context, keys ...string) *StringSliceCmd

+ func (c Tx) SDiffStore(ctx context.Context, destination string, keys ...string) *IntCmd

+ func (c Tx) SInter(ctx context.Context, keys ...string) *StringSliceCmd

+ func (c Tx) SInterStore(ctx context.Context, destination string, keys ...string) *IntCmd

+ func (c Tx) SIsMember(ctx context.Context, key string, member interface{}) *BoolCmd

+ func (c Tx) SMembers(ctx context.Context, key string) *StringSliceCmd

+ func (c Tx) SMembersMap(ctx context.Context, key string) *StringStructMapCmd

+ func (c Tx) SMove(ctx context.Context, source, destination string, member interface{}) *BoolCmd

+ func (c Tx) SPop(ctx context.Context, key string) *StringCmd

+ func (c Tx) SPopN(ctx context.Context, key string, count int64) *StringSliceCmd

+ func (c Tx) SRandMember(ctx context.Context, key string) *StringCmd

+ func (c Tx) SRandMemberN(ctx context.Context, key string, count int64) *StringSliceCmd

+ func (c Tx) SRem(ctx context.Context, key string, members ...interface{}) *IntCmd

+ func (c Tx) SScan(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd

+ func (c Tx) SUnion(ctx context.Context, keys ...string) *StringSliceCmd

+ func (c Tx) SUnionStore(ctx context.Context, destination string, keys ...string) *IntCmd

+ func (c Tx) Save(ctx context.Context) *StatusCmd

+ func (c Tx) Scan(ctx context.Context, cursor uint64, match string, count int64) *ScanCmd

+ func (c Tx) ScriptExists(ctx context.Context, hashes ...string) *BoolSliceCmd

+ func (c Tx) ScriptFlush(ctx context.Context) *StatusCmd

+ func (c Tx) ScriptKill(ctx context.Context) *StatusCmd

+ func (c Tx) ScriptLoad(ctx context.Context, script string) *StringCmd

+ func (c Tx) Select(ctx context.Context, index int) *StatusCmd

+ func (c Tx) Set(ctx context.Context, key string, value interface{}, expiration time.Duration) *StatusCmd

+ func (c Tx) SetBit(ctx context.Context, key string, offset int64, value int) *IntCmd

+ func (c Tx) SetNX(ctx context.Context, key string, value interface{}, expiration time.Duration) *BoolCmd

+ func (c Tx) SetRange(ctx context.Context, key string, offset int64, value string) *IntCmd

+ func (c Tx) SetXX(ctx context.Context, key string, value interface{}, expiration time.Duration) *BoolCmd

+ func (c Tx) Shutdown(ctx context.Context) *StatusCmd

+ func (c Tx) ShutdownNoSave(ctx context.Context) *StatusCmd

+ func (c Tx) ShutdownSave(ctx context.Context) *StatusCmd

+ func (c Tx) SlaveOf(ctx context.Context, host, port string) *StatusCmd

+ func (c Tx) SlowLogGet(ctx context.Context, num int64) *SlowLogCmd

+ func (c Tx) Sort(ctx context.Context, key string, sort *Sort) *StringSliceCmd

+ func (c Tx) SortInterfaces(ctx context.Context, key string, sort *Sort) *SliceCmd

+ func (c Tx) SortStore(ctx context.Context, key, store string, sort *Sort) *IntCmd

+ func (c Tx) StrLen(ctx context.Context, key string) *IntCmd

+ func (c Tx) SwapDB(ctx context.Context, index1, index2 int) *StatusCmd

+ func (c Tx) Sync(ctx context.Context)

+ func (c Tx) TTL(ctx context.Context, key string) *DurationCmd

+ func (c Tx) Time(ctx context.Context) *TimeCmd

+ func (c Tx) Touch(ctx context.Context, keys ...string) *IntCmd

+ func (c Tx) Type(ctx context.Context, key string) *StatusCmd

+ func (c Tx) Unlink(ctx context.Context, keys ...string) *IntCmd

+ func (c Tx) Wait(ctx context.Context, numSlaves int, timeout time.Duration) *IntCmd

+ func (c Tx) XAck(ctx context.Context, stream, group string, ids ...string) *IntCmd

+ func (c Tx) XAdd(ctx context.Context, a *XAddArgs) *StringCmd

+ func (c Tx) XClaim(ctx context.Context, a *XClaimArgs) *XMessageSliceCmd

+ func (c Tx) XClaimJustID(ctx context.Context, a *XClaimArgs) *StringSliceCmd

+ func (c Tx) XDel(ctx context.Context, stream string, ids ...string) *IntCmd

+ func (c Tx) XGroupCreate(ctx context.Context, stream, group, start string) *StatusCmd

+ func (c Tx) XGroupCreateMkStream(ctx context.Context, stream, group, start string) *StatusCmd

+ func (c Tx) XGroupDelConsumer(ctx context.Context, stream, group, consumer string) *IntCmd

+ func (c Tx) XGroupDestroy(ctx context.Context, stream, group string) *IntCmd

+ func (c Tx) XGroupSetID(ctx context.Context, stream, group, start string) *StatusCmd

+ func (c Tx) XInfoGroups(ctx context.Context, key string) *XInfoGroupsCmd

+ func (c Tx) XLen(ctx context.Context, stream string) *IntCmd

+ func (c Tx) XPending(ctx context.Context, stream, group string) *XPendingCmd

+ func (c Tx) XPendingExt(ctx context.Context, a *XPendingExtArgs) *XPendingExtCmd

+ func (c Tx) XRange(ctx context.Context, stream, start, stop string) *XMessageSliceCmd

+ func (c Tx) XRangeN(ctx context.Context, stream, start, stop string, count int64) *XMessageSliceCmd

+ func (c Tx) XRead(ctx context.Context, a *XReadArgs) *XStreamSliceCmd

+ func (c Tx) XReadGroup(ctx context.Context, a *XReadGroupArgs) *XStreamSliceCmd

+ func (c Tx) XReadStreams(ctx context.Context, streams ...string) *XStreamSliceCmd

+ func (c Tx) XRevRange(ctx context.Context, stream, start, stop string) *XMessageSliceCmd

+ func (c Tx) XRevRangeN(ctx context.Context, stream, start, stop string, count int64) *XMessageSliceCmd

+ func (c Tx) XTrim(ctx context.Context, key string, maxLen int64) *IntCmd

+ func (c Tx) XTrimApprox(ctx context.Context, key string, maxLen int64) *IntCmd

+ func (c Tx) ZAdd(ctx context.Context, key string, members ...*Z) *IntCmd

+ func (c Tx) ZAddCh(ctx context.Context, key string, members ...*Z) *IntCmd

+ func (c Tx) ZAddNX(ctx context.Context, key string, members ...*Z) *IntCmd

+ func (c Tx) ZAddNXCh(ctx context.Context, key string, members ...*Z) *IntCmd

+ func (c Tx) ZAddXX(ctx context.Context, key string, members ...*Z) *IntCmd

+ func (c Tx) ZAddXXCh(ctx context.Context, key string, members ...*Z) *IntCmd

+ func (c Tx) ZCard(ctx context.Context, key string) *IntCmd

+ func (c Tx) ZCount(ctx context.Context, key, min, max string) *IntCmd

+ func (c Tx) ZIncr(ctx context.Context, key string, member *Z) *FloatCmd

+ func (c Tx) ZIncrBy(ctx context.Context, key string, increment float64, member string) *FloatCmd

+ func (c Tx) ZIncrNX(ctx context.Context, key string, member *Z) *FloatCmd

+ func (c Tx) ZIncrXX(ctx context.Context, key string, member *Z) *FloatCmd

+ func (c Tx) ZInterStore(ctx context.Context, destination string, store *ZStore) *IntCmd

+ func (c Tx) ZLexCount(ctx context.Context, key, min, max string) *IntCmd

+ func (c Tx) ZPopMax(ctx context.Context, key string, count ...int64) *ZSliceCmd

+ func (c Tx) ZPopMin(ctx context.Context, key string, count ...int64) *ZSliceCmd

+ func (c Tx) ZRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd

+ func (c Tx) ZRangeByLex(ctx context.Context, key string, opt *ZRangeBy) *StringSliceCmd

+ func (c Tx) ZRangeByScore(ctx context.Context, key string, opt *ZRangeBy) *StringSliceCmd

+ func (c Tx) ZRangeByScoreWithScores(ctx context.Context, key string, opt *ZRangeBy) *ZSliceCmd

+ func (c Tx) ZRangeWithScores(ctx context.Context, key string, start, stop int64) *ZSliceCmd

+ func (c Tx) ZRank(ctx context.Context, key, member string) *IntCmd

+ func (c Tx) ZRem(ctx context.Context, key string, members ...interface{}) *IntCmd

+ func (c Tx) ZRemRangeByLex(ctx context.Context, key, min, max string) *IntCmd

+ func (c Tx) ZRemRangeByRank(ctx context.Context, key string, start, stop int64) *IntCmd

+ func (c Tx) ZRemRangeByScore(ctx context.Context, key, min, max string) *IntCmd

+ func (c Tx) ZRevRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd

+ func (c Tx) ZRevRangeByLex(ctx context.Context, key string, opt *ZRangeBy) *StringSliceCmd

+ func (c Tx) ZRevRangeByScore(ctx context.Context, key string, opt *ZRangeBy) *StringSliceCmd

+ func (c Tx) ZRevRangeByScoreWithScores(ctx context.Context, key string, opt *ZRangeBy) *ZSliceCmd

+ func (c Tx) ZRevRangeWithScores(ctx context.Context, key string, start, stop int64) *ZSliceCmd

+ func (c Tx) ZRevRank(ctx context.Context, key, member string) *IntCmd

+ func (c Tx) ZScan(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd

+ func (c Tx) ZScore(ctx context.Context, key, member string) *FloatCmd

+ func (c Tx) ZUnionStore(ctx context.Context, dest string, store *ZStore) *IntCmd

+ func (hs *Tx) AddHook(hook Hook)

+ type UniversalClient interface

+ AddHook func(Hook)

+ Close func() error

+ Context func() context.Context

+ Do func(ctx context.Context, args ...interface{}) *Cmd

+ PSubscribe func(ctx context.Context, channels ...string) *PubSub

+ Process func(ctx context.Context, cmd Cmder) error

+ Subscribe func(ctx context.Context, channels ...string) *PubSub

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

+ func NewUniversalClient(opts *UniversalOptions) UniversalClient

+ type UniversalOptions struct

+ Addrs []string

+ DB int

+ DialTimeout time.Duration

+ Dialer func(ctx context.Context, network, addr string) (net.Conn, error)

+ IdleCheckFrequency time.Duration

+ IdleTimeout time.Duration

+ MasterName string

+ MaxConnAge time.Duration

+ MaxRedirects int

+ MaxRetries int

+ MaxRetryBackoff time.Duration

+ MinIdleConns int

+ MinRetryBackoff time.Duration

+ OnConnect func(ctx context.Context, cn *Conn) error

+ Password string

+ PoolSize int

+ PoolTimeout time.Duration

+ ReadOnly bool

+ ReadTimeout time.Duration

+ RouteByLatency bool

+ RouteRandomly bool

+ SentinelPassword string

+ TLSConfig *tls.Config

+ Username string

+ WriteTimeout time.Duration

+ func (o *UniversalOptions) Cluster() *ClusterOptions

+ func (o *UniversalOptions) Failover() *FailoverOptions

+ func (o *UniversalOptions) Simple() *Options

+ type XAddArgs struct

+ ID string

+ MaxLen int64

+ MaxLenApprox int64

+ Stream string

+ Values interface{}

+ type XClaimArgs struct

+ Consumer string

+ Group string

+ Messages []string

+ MinIdle time.Duration

+ Stream string

+ type XInfoGroups struct

+ Consumers int64

+ LastDeliveredID string

+ Name string

+ Pending int64

+ type XInfoGroupsCmd struct

+ func NewXInfoGroupsCmd(ctx context.Context, stream string) *XInfoGroupsCmd

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

+ func (cmd *XInfoGroupsCmd) Err() error

+ func (cmd *XInfoGroupsCmd) FullName() string

+ func (cmd *XInfoGroupsCmd) Name() string

+ func (cmd *XInfoGroupsCmd) Result() ([]XInfoGroups, error)

+ func (cmd *XInfoGroupsCmd) SetErr(e error)

+ func (cmd *XInfoGroupsCmd) String() string

+ func (cmd *XInfoGroupsCmd) Val() []XInfoGroups

+ type XMessage struct

+ ID string

+ Values map[string]interface{}

+ type XMessageSliceCmd struct

+ func NewXMessageSliceCmd(ctx context.Context, args ...interface{}) *XMessageSliceCmd

+ func NewXMessageSliceCmdResult(val []XMessage, err error) *XMessageSliceCmd

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

+ func (cmd *XMessageSliceCmd) Err() error

+ func (cmd *XMessageSliceCmd) FullName() string

+ func (cmd *XMessageSliceCmd) Name() string

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

+ func (cmd *XMessageSliceCmd) SetErr(e error)

+ func (cmd *XMessageSliceCmd) String() string

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

+ type XPending struct

+ Consumers map[string]int64

+ Count int64

+ Higher string

+ Lower string

+ type XPendingCmd struct

+ func NewXPendingCmd(ctx context.Context, args ...interface{}) *XPendingCmd

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

+ func (cmd *XPendingCmd) Err() error

+ func (cmd *XPendingCmd) FullName() string

+ func (cmd *XPendingCmd) Name() string

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

+ func (cmd *XPendingCmd) SetErr(e 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(ctx context.Context, args ...interface{}) *XPendingExtCmd

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

+ func (cmd *XPendingExtCmd) Err() error

+ func (cmd *XPendingExtCmd) FullName() string

+ func (cmd *XPendingExtCmd) Name() string

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

+ func (cmd *XPendingExtCmd) SetErr(e 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

+ NoAck bool

+ Streams []string

+ type XStream struct

+ Messages []XMessage

+ Stream string

+ type XStreamSliceCmd struct

+ func NewXStreamSliceCmd(ctx context.Context, args ...interface{}) *XStreamSliceCmd

+ func NewXStreamSliceCmdResult(val []XStream, err error) *XStreamSliceCmd

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

+ func (cmd *XStreamSliceCmd) Err() error

+ func (cmd *XStreamSliceCmd) FullName() string

+ func (cmd *XStreamSliceCmd) Name() string

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

+ func (cmd *XStreamSliceCmd) SetErr(e error)

+ func (cmd *XStreamSliceCmd) String() string

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

+ type Z struct

+ Member interface{}

+ Score float64

+ type ZRangeBy struct

+ Count int64

+ Max string

+ Min string

+ Offset int64

+ type ZSliceCmd struct

+ func NewZSliceCmd(ctx context.Context, args ...interface{}) *ZSliceCmd

+ func NewZSliceCmdResult(val []Z, err error) *ZSliceCmd

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

+ func (cmd *ZSliceCmd) Err() error

+ func (cmd *ZSliceCmd) FullName() string

+ func (cmd *ZSliceCmd) Name() string

+ func (cmd *ZSliceCmd) Result() ([]Z, error)

+ func (cmd *ZSliceCmd) SetErr(e error)

+ func (cmd *ZSliceCmd) String() string

+ func (cmd *ZSliceCmd) Val() []Z

+ type ZStore struct

+ Aggregate string

+ Keys []string

+ Weights []float64

+ type ZWithKey struct

+ Key string

+ type ZWithKeyCmd struct

+ func NewZWithKeyCmd(ctx context.Context, args ...interface{}) *ZWithKeyCmd

+ func NewZWithKeyCmdResult(val *ZWithKey, err error) *ZWithKeyCmd

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

+ func (cmd *ZWithKeyCmd) Err() error

+ func (cmd *ZWithKeyCmd) FullName() string

+ func (cmd *ZWithKeyCmd) Name() string

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

+ func (cmd *ZWithKeyCmd) SetErr(e error)

+ func (cmd *ZWithKeyCmd) String() string

+ func (cmd *ZWithKeyCmd) Val() *ZWithKey

v8.0.0-beta.12

Sep 11, 2020

v8.0.0-beta.11

Sep 9, 2020

v8.0.0-beta.10

Sep 5, 2020

v8.0.0-beta.9

Sep 1, 2020

v8.0.0-beta.8

Aug 24, 2020

v8.0.0-beta.7

Jul 24, 2020

v8.0.0-beta.6

Jun 30, 2020

v8.0.0-beta.5

Jun 12, 2020

v8.0.0-beta.4

Jun 8, 2020

v8.0.0-beta.3

Jun 5, 2020

v8.0.0-beta.2

May 21, 2020

v8.0.0-beta.1

May 19, 2020

v8.0.0-alpha.2

Apr 19, 2020

v8.0.0-alpha.1

Mar 13, 2020

v8.0.0-alpha.0

Mar 11, 2020

Other modules containing this package

github.com/go-redis/redis

github.com/go-redis/redis/v7

github.com/go-redis/redis/v9

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL