rueidiscompat

package
v0.1.12 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 9, 2022 License: Apache-2.0 Imports: 12 Imported by: 1

Documentation

Index

Constants

View Source 
const KeepTTL = -1

Variables

This section is empty.

Functions

This section is empty.

Types

type BitCount 

type BitCount struct {
	Start, End int64
}

type BitField 

type BitField struct {
	Get       *BitFieldArg
	Set       *BitFieldArg
	IncrBy    *BitFieldArg
	Increment int64
	Overflow  string
}

type BitFieldArg 

type BitFieldArg struct {
	Encoding string
	Offset   int64
}

type BoolCmd 

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

func (*BoolCmd) Err 

func (cmd *BoolCmd) Err() error

func (*BoolCmd) Result 

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

func (*BoolCmd) SetErr 

func (cmd *BoolCmd) SetErr(err error)

func (*BoolCmd) SetVal 

func (cmd *BoolCmd) SetVal(val bool)

func (*BoolCmd) Val 

func (cmd *BoolCmd) Val() bool

type BoolSliceCmd 

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

func (*BoolSliceCmd) Err 

func (cmd *BoolSliceCmd) Err() error

func (*BoolSliceCmd) Result 

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

func (*BoolSliceCmd) SetErr 

func (cmd *BoolSliceCmd) SetErr(err error)

func (*BoolSliceCmd) SetVal 

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

func (*BoolSliceCmd) Val 

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

type CacheCompat 

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

func (CacheCompat) BitCount 

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

func (CacheCompat) BitPos 

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

func (CacheCompat) GeoDist 

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

func (CacheCompat) GeoHash 

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

func (CacheCompat) GeoPos 

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

func (CacheCompat) GeoRadius 

func (c CacheCompat) GeoRadius(ctx context.Context, key string, longitude, latitude float64, query GeoRadiusQuery) *GeoLocationCmd

GeoRadius is a read-only GEORADIUS_RO command.

func (CacheCompat) GeoRadiusByMember 

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

GeoRadiusByMember is a read-only GEORADIUSBYMEMBER_RO command.

func (CacheCompat) GeoSearch 

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

func (CacheCompat) Get 

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

func (CacheCompat) GetBit 

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

func (CacheCompat) GetRange 

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

func (CacheCompat) HExists 

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

func (CacheCompat) HGet 

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

func (CacheCompat) HGetAll 

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

func (CacheCompat) HKeys 

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

func (CacheCompat) HLen 

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

func (CacheCompat) HMGet 

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

func (CacheCompat) HVals 

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

func (CacheCompat) LIndex 

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

func (CacheCompat) LLen 

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

func (CacheCompat) LPos 

func (c CacheCompat) LPos(ctx context.Context, key string, element string, a LPosArgs) *IntCmd

func (CacheCompat) LRange 

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

func (CacheCompat) PTTL 

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

func (CacheCompat) SCard 

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

func (CacheCompat) SIsMember 

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

func (CacheCompat) SMIsMember 

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

func (CacheCompat) SMembers 

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

func (CacheCompat) Sort 

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

func (CacheCompat) StrLen 

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

func (CacheCompat) TTL 

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

func (CacheCompat) Type 

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

func (CacheCompat) ZCard 

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

func (CacheCompat) ZCount 

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

func (CacheCompat) ZLexCount 

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

func (CacheCompat) ZMScore 

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

func (CacheCompat) ZRangeArgs 

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

func (CacheCompat) ZRangeArgsWithScores 

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

func (CacheCompat) ZRangeByLex 

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

func (CacheCompat) ZRangeByScore 

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

func (CacheCompat) ZRangeByScoreWithScores 

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

func (CacheCompat) ZRangeWithScores 

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

func (CacheCompat) ZRank 

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

func (CacheCompat) ZRevRange 

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

func (CacheCompat) ZRevRangeByLex 

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

func (CacheCompat) ZRevRangeByScore 

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

func (CacheCompat) ZRevRangeByScoreWithScores 

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

func (CacheCompat) ZRevRangeWithScores 

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

func (CacheCompat) ZRevRank 

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

func (CacheCompat) ZScore 

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

type ClusterNode 

type ClusterNode struct {
	ID   string
	Addr string
}

type ClusterSlot 

type ClusterSlot struct {
	Start int64
	End   int64
	Nodes []ClusterNode
}

type ClusterSlotsCmd 

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

func (*ClusterSlotsCmd) Err 

func (cmd *ClusterSlotsCmd) Err() error

func (*ClusterSlotsCmd) Result 

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

func (*ClusterSlotsCmd) SetErr 

func (cmd *ClusterSlotsCmd) SetErr(err error)

func (*ClusterSlotsCmd) SetVal 

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

func (*ClusterSlotsCmd) Val 

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

type Cmd 

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

func (*Cmd) Bool 

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

func (*Cmd) BoolSlice 

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

func (*Cmd) Err 

func (cmd *Cmd) Err() error

func (*Cmd) Float32 

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

func (*Cmd) Float32Slice 

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

func (*Cmd) Float64 

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

func (*Cmd) Float64Slice 

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

func (*Cmd) Int 

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

func (*Cmd) Int64 

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

func (*Cmd) Int64Slice 

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

func (*Cmd) Result 

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

func (*Cmd) SetErr 

func (cmd *Cmd) SetErr(err error)

func (*Cmd) SetVal 

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

func (*Cmd) Slice 

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

func (*Cmd) StringSlice 

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

func (*Cmd) Text 

func (cmd *Cmd) Text() (string, error)

func (*Cmd) Uint64 

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

func (*Cmd) Uint64Slice 

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

func (*Cmd) Val 

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

type Cmdable 

type Cmdable interface {
	Cache(ttl time.Duration) CacheCompat

	Command(ctx context.Context) *CommandsInfoCmd
	ClientGetName(ctx context.Context) *StringCmd
	Echo(ctx context.Context, message interface{}) *StringCmd
	Ping(ctx context.Context) *StatusCmd
	Quit(ctx context.Context) *StatusCmd
	Del(ctx context.Context, keys ...string) *IntCmd
	Unlink(ctx context.Context, keys ...string) *IntCmd
	Dump(ctx context.Context, key string) *StringCmd
	Exists(ctx context.Context, keys ...string) *IntCmd
	Expire(ctx context.Context, key string, expiration time.Duration) *BoolCmd
	ExpireAt(ctx context.Context, key string, tm time.Time) *BoolCmd
	ExpireNX(ctx context.Context, key string, expiration time.Duration) *BoolCmd
	ExpireXX(ctx context.Context, key string, expiration time.Duration) *BoolCmd
	ExpireGT(ctx context.Context, key string, expiration time.Duration) *BoolCmd
	ExpireLT(ctx context.Context, key string, expiration time.Duration) *BoolCmd
	Keys(ctx context.Context, pattern string) *StringSliceCmd
	Migrate(ctx context.Context, host string, port int64, key string, db int64, timeout time.Duration) *StatusCmd
	Move(ctx context.Context, key string, db int64) *BoolCmd
	ObjectRefCount(ctx context.Context, key string) *IntCmd
	ObjectEncoding(ctx context.Context, key string) *StringCmd
	ObjectIdleTime(ctx context.Context, key string) *DurationCmd
	Persist(ctx context.Context, key string) *BoolCmd
	PExpire(ctx context.Context, key string, expiration time.Duration) *BoolCmd
	PExpireAt(ctx context.Context, key string, tm time.Time) *BoolCmd
	PTTL(ctx context.Context, key string) *DurationCmd
	RandomKey(ctx context.Context) *StringCmd
	Rename(ctx context.Context, key, newkey string) *StatusCmd
	RenameNX(ctx context.Context, key, newkey string) *BoolCmd
	Restore(ctx context.Context, key string, ttl time.Duration, value string) *StatusCmd
	RestoreReplace(ctx context.Context, key string, ttl time.Duration, value string) *StatusCmd
	Sort(ctx context.Context, key string, sort Sort) *StringSliceCmd
	SortStore(ctx context.Context, key, store string, sort Sort) *IntCmd
	SortInterfaces(ctx context.Context, key string, sort Sort) *SliceCmd
	Touch(ctx context.Context, keys ...string) *IntCmd
	TTL(ctx context.Context, key string) *DurationCmd
	Type(ctx context.Context, key string) *StatusCmd
	Append(ctx context.Context, key, value string) *IntCmd
	Decr(ctx context.Context, key string) *IntCmd
	DecrBy(ctx context.Context, key string, decrement int64) *IntCmd
	Get(ctx context.Context, key string) *StringCmd
	GetRange(ctx context.Context, key string, start, end int64) *StringCmd
	GetSet(ctx context.Context, key string, value interface{}) *StringCmd
	GetEx(ctx context.Context, key string, expiration time.Duration) *StringCmd
	GetDel(ctx context.Context, key string) *StringCmd
	Incr(ctx context.Context, key string) *IntCmd
	IncrBy(ctx context.Context, key string, value int64) *IntCmd
	IncrByFloat(ctx context.Context, key string, value float64) *FloatCmd
	MGet(ctx context.Context, keys ...string) *SliceCmd
	MSet(ctx context.Context, values ...interface{}) *StatusCmd
	MSetNX(ctx context.Context, values ...interface{}) *BoolCmd
	Set(ctx context.Context, key string, value interface{}, expiration time.Duration) *StatusCmd
	SetArgs(ctx context.Context, key string, value interface{}, a SetArgs) *StatusCmd
	SetEX(ctx context.Context, key string, value interface{}, expiration time.Duration) *StatusCmd
	SetNX(ctx context.Context, key string, value interface{}, expiration time.Duration) *BoolCmd
	SetXX(ctx context.Context, key string, value interface{}, expiration time.Duration) *BoolCmd
	SetRange(ctx context.Context, key string, offset int64, value string) *IntCmd
	StrLen(ctx context.Context, key string) *IntCmd
	Copy(ctx context.Context, sourceKey string, destKey string, db int64, replace bool) *IntCmd

	GetBit(ctx context.Context, key string, offset int64) *IntCmd
	SetBit(ctx context.Context, key string, offset int64, value int64) *IntCmd
	BitCount(ctx context.Context, key string, bitCount *BitCount) *IntCmd
	BitOpAnd(ctx context.Context, destKey string, keys ...string) *IntCmd
	BitOpOr(ctx context.Context, destKey string, keys ...string) *IntCmd
	BitOpXor(ctx context.Context, destKey string, keys ...string) *IntCmd
	BitOpNot(ctx context.Context, destKey string, key string) *IntCmd
	BitPos(ctx context.Context, key string, bit int64, pos ...int64) *IntCmd
	BitField(ctx context.Context, key string, args ...interface{}) *IntSliceCmd

	Scan(ctx context.Context, cursor uint64, match string, count int64) *ScanCmd
	ScanType(ctx context.Context, cursor uint64, match string, count int64, keyType string) *ScanCmd
	SScan(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd
	HScan(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd
	ZScan(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd

	HDel(ctx context.Context, key string, fields ...string) *IntCmd
	HExists(ctx context.Context, key, field string) *BoolCmd
	HGet(ctx context.Context, key, field string) *StringCmd
	HGetAll(ctx context.Context, key string) *StringStringMapCmd
	HIncrBy(ctx context.Context, key, field string, incr int64) *IntCmd
	HIncrByFloat(ctx context.Context, key, field string, incr float64) *FloatCmd
	HKeys(ctx context.Context, key string) *StringSliceCmd
	HLen(ctx context.Context, key string) *IntCmd
	HMGet(ctx context.Context, key string, fields ...string) *SliceCmd
	HSet(ctx context.Context, key string, values ...interface{}) *IntCmd
	HMSet(ctx context.Context, key string, values ...interface{}) *BoolCmd
	HSetNX(ctx context.Context, key, field string, value interface{}) *BoolCmd
	HVals(ctx context.Context, key string) *StringSliceCmd
	HRandField(ctx context.Context, key string, count int64, withValues bool) *StringSliceCmd

	BLPop(ctx context.Context, timeout time.Duration, keys ...string) *StringSliceCmd
	BRPop(ctx context.Context, timeout time.Duration, keys ...string) *StringSliceCmd
	BRPopLPush(ctx context.Context, source, destination string, timeout time.Duration) *StringCmd
	LIndex(ctx context.Context, key string, index int64) *StringCmd
	LInsert(ctx context.Context, key, op string, pivot, value interface{}) *IntCmd
	LInsertBefore(ctx context.Context, key string, pivot, value interface{}) *IntCmd
	LInsertAfter(ctx context.Context, key string, pivot, value interface{}) *IntCmd
	LLen(ctx context.Context, key string) *IntCmd
	LPop(ctx context.Context, key string) *StringCmd
	LPopCount(ctx context.Context, key string, count int64) *StringSliceCmd
	LPos(ctx context.Context, key string, value string, args LPosArgs) *IntCmd
	LPosCount(ctx context.Context, key string, value string, count int64, args LPosArgs) *IntSliceCmd
	LPush(ctx context.Context, key string, values ...interface{}) *IntCmd
	LPushX(ctx context.Context, key string, values ...interface{}) *IntCmd
	LRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd
	LRem(ctx context.Context, key string, count int64, value interface{}) *IntCmd
	LSet(ctx context.Context, key string, index int64, value interface{}) *StatusCmd
	LTrim(ctx context.Context, key string, start, stop int64) *StatusCmd
	RPop(ctx context.Context, key string) *StringCmd
	RPopCount(ctx context.Context, key string, count int64) *StringSliceCmd
	RPopLPush(ctx context.Context, source, destination string) *StringCmd
	RPush(ctx context.Context, key string, values ...interface{}) *IntCmd
	RPushX(ctx context.Context, key string, values ...interface{}) *IntCmd
	LMove(ctx context.Context, source, destination, srcpos, destpos string) *StringCmd
	BLMove(ctx context.Context, source, destination, srcpos, destpos string, timeout time.Duration) *StringCmd

	SAdd(ctx context.Context, key string, members ...interface{}) *IntCmd
	SCard(ctx context.Context, key string) *IntCmd
	SDiff(ctx context.Context, keys ...string) *StringSliceCmd
	SDiffStore(ctx context.Context, destination string, keys ...string) *IntCmd
	SInter(ctx context.Context, keys ...string) *StringSliceCmd
	SInterStore(ctx context.Context, destination string, keys ...string) *IntCmd
	SIsMember(ctx context.Context, key string, member interface{}) *BoolCmd
	SMIsMember(ctx context.Context, key string, members ...interface{}) *BoolSliceCmd
	SMembers(ctx context.Context, key string) *StringSliceCmd
	SMembersMap(ctx context.Context, key string) *StringStructMapCmd
	SMove(ctx context.Context, source, destination string, member interface{}) *BoolCmd
	SPop(ctx context.Context, key string) *StringCmd
	SPopN(ctx context.Context, key string, count int64) *StringSliceCmd
	SRandMember(ctx context.Context, key string) *StringCmd
	SRandMemberN(ctx context.Context, key string, count int64) *StringSliceCmd
	SRem(ctx context.Context, key string, members ...interface{}) *IntCmd
	SUnion(ctx context.Context, keys ...string) *StringSliceCmd
	SUnionStore(ctx context.Context, destination string, keys ...string) *IntCmd

	XAdd(ctx context.Context, a XAddArgs) *StringCmd
	XDel(ctx context.Context, stream string, ids ...string) *IntCmd
	XLen(ctx context.Context, stream string) *IntCmd
	XRange(ctx context.Context, stream, start, stop string) *XMessageSliceCmd
	XRangeN(ctx context.Context, stream, start, stop string, count int64) *XMessageSliceCmd
	XRevRange(ctx context.Context, stream, start, stop string) *XMessageSliceCmd
	XRevRangeN(ctx context.Context, stream string, start, stop string, count int64) *XMessageSliceCmd
	XRead(ctx context.Context, a XReadArgs) *XStreamSliceCmd
	XReadStreams(ctx context.Context, streams ...string) *XStreamSliceCmd
	XGroupCreate(ctx context.Context, stream, group, start string) *StatusCmd
	XGroupCreateMkStream(ctx context.Context, stream, group, start string) *StatusCmd
	XGroupSetID(ctx context.Context, stream, group, start string) *StatusCmd
	XGroupDestroy(ctx context.Context, stream, group string) *IntCmd
	XGroupCreateConsumer(ctx context.Context, stream, group, consumer string) *IntCmd
	XGroupDelConsumer(ctx context.Context, stream, group, consumer string) *IntCmd
	XReadGroup(ctx context.Context, a XReadGroupArgs) *XStreamSliceCmd
	XAck(ctx context.Context, stream, group string, ids ...string) *IntCmd
	XPending(ctx context.Context, stream, group string) *XPendingCmd
	XPendingExt(ctx context.Context, a XPendingExtArgs) *XPendingExtCmd
	XClaim(ctx context.Context, a XClaimArgs) *XMessageSliceCmd
	XClaimJustID(ctx context.Context, a XClaimArgs) *StringSliceCmd
	XAutoClaim(ctx context.Context, a XAutoClaimArgs) *XAutoClaimCmd
	XAutoClaimJustID(ctx context.Context, a XAutoClaimArgs) *XAutoClaimJustIDCmd

	XTrimMaxLen(ctx context.Context, key string, maxLen int64) *IntCmd
	XTrimMaxLenApprox(ctx context.Context, key string, maxLen, limit int64) *IntCmd
	XTrimMinID(ctx context.Context, key string, minID string) *IntCmd
	XTrimMinIDApprox(ctx context.Context, key string, minID string, limit int64) *IntCmd
	XInfoGroups(ctx context.Context, key string) *XInfoGroupsCmd
	XInfoStream(ctx context.Context, key string) *XInfoStreamCmd
	XInfoStreamFull(ctx context.Context, key string, count int64) *XInfoStreamFullCmd
	XInfoConsumers(ctx context.Context, key string, group string) *XInfoConsumersCmd

	BZPopMax(ctx context.Context, timeout time.Duration, keys ...string) *ZWithKeyCmd
	BZPopMin(ctx context.Context, timeout time.Duration, keys ...string) *ZWithKeyCmd

	ZAdd(ctx context.Context, key string, members ...Z) *IntCmd
	ZAddNX(ctx context.Context, key string, members ...Z) *IntCmd
	ZAddXX(ctx context.Context, key string, members ...Z) *IntCmd
	ZAddArgs(ctx context.Context, key string, args ZAddArgs) *IntCmd
	ZAddArgsIncr(ctx context.Context, key string, args ZAddArgs) *FloatCmd
	ZCard(ctx context.Context, key string) *IntCmd
	ZCount(ctx context.Context, key string, min, max string) *IntCmd
	ZLexCount(ctx context.Context, key, min, max string) *IntCmd
	ZIncrBy(ctx context.Context, key string, increment float64, member string) *FloatCmd
	ZInter(ctx context.Context, store ZStore) *StringSliceCmd
	ZInterWithScores(ctx context.Context, store ZStore) *ZSliceCmd
	ZInterStore(ctx context.Context, destination string, store ZStore) *IntCmd
	ZMScore(ctx context.Context, key string, members ...string) *FloatSliceCmd
	ZPopMax(ctx context.Context, key string, count ...int64) *ZSliceCmd
	ZPopMin(ctx context.Context, key string, count ...int64) *ZSliceCmd
	ZRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd
	ZRangeWithScores(ctx context.Context, key string, start, stop int64) *ZSliceCmd
	ZRangeByScore(ctx context.Context, key string, opt ZRangeBy) *StringSliceCmd
	ZRangeByLex(ctx context.Context, key string, opt ZRangeBy) *StringSliceCmd
	ZRangeByScoreWithScores(ctx context.Context, key string, opt ZRangeBy) *ZSliceCmd
	ZRangeArgs(ctx context.Context, z ZRangeArgs) *StringSliceCmd
	ZRangeArgsWithScores(ctx context.Context, z ZRangeArgs) *ZSliceCmd
	ZRangeStore(ctx context.Context, dst string, z ZRangeArgs) *IntCmd
	ZRank(ctx context.Context, key, member string) *IntCmd
	ZRem(ctx context.Context, key string, members ...interface{}) *IntCmd
	ZRemRangeByRank(ctx context.Context, key string, start, stop int64) *IntCmd
	ZRemRangeByScore(ctx context.Context, key string, min, max string) *IntCmd
	ZRemRangeByLex(ctx context.Context, key, min, max string) *IntCmd
	ZRevRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd
	ZRevRangeWithScores(ctx context.Context, key string, start, stop int64) *ZSliceCmd
	ZRevRangeByScore(ctx context.Context, key string, opt ZRangeBy) *StringSliceCmd
	ZRevRangeByLex(ctx context.Context, key string, opt ZRangeBy) *StringSliceCmd
	ZRevRangeByScoreWithScores(ctx context.Context, key string, opt ZRangeBy) *ZSliceCmd
	ZRevRank(ctx context.Context, key, member string) *IntCmd
	ZScore(ctx context.Context, key, member string) *FloatCmd
	ZUnionStore(ctx context.Context, dest string, store ZStore) *IntCmd
	ZUnion(ctx context.Context, store ZStore) *StringSliceCmd
	ZUnionWithScores(ctx context.Context, store ZStore) *ZSliceCmd
	ZRandMember(ctx context.Context, key string, count int64) *StringSliceCmd
	ZRandMemberWithScores(ctx context.Context, key string, count int64) *ZSliceCmd
	ZDiff(ctx context.Context, keys ...string) *StringSliceCmd
	ZDiffWithScores(ctx context.Context, keys ...string) *ZSliceCmd
	ZDiffStore(ctx context.Context, destination string, keys ...string) *IntCmd

	PFAdd(ctx context.Context, key string, els ...interface{}) *IntCmd
	PFCount(ctx context.Context, keys ...string) *IntCmd
	PFMerge(ctx context.Context, dest string, keys ...string) *StatusCmd

	BgRewriteAOF(ctx context.Context) *StatusCmd
	BgSave(ctx context.Context) *StatusCmd
	ClientKill(ctx context.Context, ipPort string) *StatusCmd
	ClientKillByFilter(ctx context.Context, keys ...string) *IntCmd
	ClientList(ctx context.Context) *StringCmd
	ClientPause(ctx context.Context, dur time.Duration) *BoolCmd
	ClientUnpause(ctx context.Context) *BoolCmd
	ClientID(ctx context.Context) *IntCmd
	ConfigGet(ctx context.Context, parameter string) *SliceCmd
	ConfigResetStat(ctx context.Context) *StatusCmd
	ConfigSet(ctx context.Context, parameter, value string) *StatusCmd
	ConfigRewrite(ctx context.Context) *StatusCmd
	DBSize(ctx context.Context) *IntCmd
	FlushAll(ctx context.Context) *StatusCmd
	FlushAllAsync(ctx context.Context) *StatusCmd
	FlushDB(ctx context.Context) *StatusCmd
	FlushDBAsync(ctx context.Context) *StatusCmd
	Info(ctx context.Context, section ...string) *StringCmd
	LastSave(ctx context.Context) *IntCmd
	Save(ctx context.Context) *StatusCmd
	Shutdown(ctx context.Context) *StatusCmd
	ShutdownSave(ctx context.Context) *StatusCmd
	ShutdownNoSave(ctx context.Context) *StatusCmd
	SlaveOf(ctx context.Context, host string, port string) *StatusCmd
	Time(ctx context.Context) *TimeCmd
	DebugObject(ctx context.Context, key string) *StringCmd
	ReadOnly(ctx context.Context) *StatusCmd
	ReadWrite(ctx context.Context) *StatusCmd
	MemoryUsage(ctx context.Context, key string, samples ...int64) *IntCmd

	Eval(ctx context.Context, script string, keys []string, args ...interface{}) *Cmd
	EvalSha(ctx context.Context, sha1 string, keys []string, args ...interface{}) *Cmd
	ScriptExists(ctx context.Context, hashes ...string) *BoolSliceCmd
	ScriptFlush(ctx context.Context) *StatusCmd
	ScriptKill(ctx context.Context) *StatusCmd
	ScriptLoad(ctx context.Context, script string) *StringCmd

	Publish(ctx context.Context, channel string, message interface{}) *IntCmd
	PubSubChannels(ctx context.Context, pattern string) *StringSliceCmd
	PubSubNumSub(ctx context.Context, channels ...string) *StringIntMapCmd
	PubSubNumPat(ctx context.Context) *IntCmd

	ClusterSlots(ctx context.Context) *ClusterSlotsCmd
	ClusterNodes(ctx context.Context) *StringCmd
	ClusterMeet(ctx context.Context, host string, port int64) *StatusCmd
	ClusterForget(ctx context.Context, nodeID string) *StatusCmd
	ClusterReplicate(ctx context.Context, nodeID string) *StatusCmd
	ClusterResetSoft(ctx context.Context) *StatusCmd
	ClusterResetHard(ctx context.Context) *StatusCmd
	ClusterInfo(ctx context.Context) *StringCmd
	ClusterKeySlot(ctx context.Context, key string) *IntCmd
	ClusterGetKeysInSlot(ctx context.Context, slot int64, count int64) *StringSliceCmd
	ClusterCountFailureReports(ctx context.Context, nodeID string) *IntCmd
	ClusterCountKeysInSlot(ctx context.Context, slot int64) *IntCmd
	ClusterDelSlots(ctx context.Context, slots ...int64) *StatusCmd
	ClusterDelSlotsRange(ctx context.Context, min, max int64) *StatusCmd
	ClusterSaveConfig(ctx context.Context) *StatusCmd
	ClusterSlaves(ctx context.Context, nodeID string) *StringSliceCmd
	ClusterFailover(ctx context.Context) *StatusCmd
	ClusterAddSlots(ctx context.Context, slots ...int64) *StatusCmd
	ClusterAddSlotsRange(ctx context.Context, min, max int64) *StatusCmd

	GeoAdd(ctx context.Context, key string, geoLocation ...GeoLocation) *IntCmd
	GeoPos(ctx context.Context, key string, members ...string) *GeoPosCmd
	GeoRadius(ctx context.Context, key string, longitude, latitude float64, query GeoRadiusQuery) *GeoLocationCmd
	GeoRadiusStore(ctx context.Context, key string, longitude, latitude float64, query GeoRadiusQuery) *IntCmd
	GeoRadiusByMember(ctx context.Context, key, member string, query GeoRadiusQuery) *GeoLocationCmd
	GeoRadiusByMemberStore(ctx context.Context, key, member string, query GeoRadiusQuery) *IntCmd
	GeoSearch(ctx context.Context, key string, q GeoSearchQuery) *StringSliceCmd
	GeoSearchLocation(ctx context.Context, key string, q GeoSearchLocationQuery) *GeoLocationCmd
	GeoSearchStore(ctx context.Context, src, dest string, q GeoSearchStoreQuery) *IntCmd
	GeoDist(ctx context.Context, key, member1, member2, unit string) *FloatCmd
	GeoHash(ctx context.Context, key string, members ...string) *StringSliceCmd
}

func NewAdapter 

func NewAdapter(client rueidis.Client) Cmdable

type CommandInfo 

type CommandInfo struct {
	Flags       []string
	ACLFlags    []string
	Name        string
	Arity       int64
	FirstKeyPos int64
	LastKeyPos  int64
	StepCount   int64
	ReadOnly    bool
}

type CommandsInfoCmd 

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

func (*CommandsInfoCmd) Err 

func (cmd *CommandsInfoCmd) Err() error

func (*CommandsInfoCmd) Result 

func (cmd *CommandsInfoCmd) Result() (map[string]CommandInfo, error)

func (*CommandsInfoCmd) SetErr 

func (cmd *CommandsInfoCmd) SetErr(err error)

func (*CommandsInfoCmd) SetVal 

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

func (*CommandsInfoCmd) Val 

func (cmd *CommandsInfoCmd) Val() map[string]CommandInfo

type Compat 

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

func (*Compat) Append 

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

func (*Compat) BLMove 

func (c *Compat) BLMove(ctx context.Context, source, destination, srcpos, destpos string, timeout time.Duration) *StringCmd

func (*Compat) BLPop 

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

func (*Compat) BRPop 

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

func (*Compat) BRPopLPush 

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

func (*Compat) BZPopMax 

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

BZPopMax Redis `BZPOPMAX key [key ...] timeout` command.

func (*Compat) BZPopMin 

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

BZPopMin Redis `BZPOPMIN key [key ...] timeout` command.

func (*Compat) BgRewriteAOF 

func (c *Compat) BgRewriteAOF(ctx context.Context) *StatusCmd

func (*Compat) BgSave 

func (c *Compat) BgSave(ctx context.Context) *StatusCmd

func (*Compat) BitCount 

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

func (*Compat) BitField 

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

func (*Compat) BitOpAnd 

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

func (*Compat) BitOpNot 

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

func (*Compat) BitOpOr 

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

func (*Compat) BitOpXor 

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

func (*Compat) BitPos 

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

func (*Compat) Cache 

func (c *Compat) Cache(ttl time.Duration) CacheCompat

func (*Compat) ClientGetName 

func (c *Compat) ClientGetName(ctx context.Context) *StringCmd

func (*Compat) ClientID 

func (c *Compat) ClientID(ctx context.Context) *IntCmd

func (*Compat) ClientKill 

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

func (*Compat) ClientKillByFilter 

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

func (*Compat) ClientList 

func (c *Compat) ClientList(ctx context.Context) *StringCmd

func (*Compat) ClientPause 

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

func (*Compat) ClientUnpause 

func (c *Compat) ClientUnpause(ctx context.Context) *BoolCmd

func (*Compat) ClusterAddSlots 

func (c *Compat) ClusterAddSlots(ctx context.Context, slots ...int64) *StatusCmd

func (*Compat) ClusterAddSlotsRange 

func (c *Compat) ClusterAddSlotsRange(ctx context.Context, min, max int64) *StatusCmd

func (*Compat) ClusterCountFailureReports 

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

func (*Compat) ClusterCountKeysInSlot 

func (c *Compat) ClusterCountKeysInSlot(ctx context.Context, slot int64) *IntCmd

func (*Compat) ClusterDelSlots 

func (c *Compat) ClusterDelSlots(ctx context.Context, slots ...int64) *StatusCmd

func (*Compat) ClusterDelSlotsRange 

func (c *Compat) ClusterDelSlotsRange(ctx context.Context, min, max int64) *StatusCmd

func (*Compat) ClusterFailover 

func (c *Compat) ClusterFailover(ctx context.Context) *StatusCmd

func (*Compat) ClusterForget 

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

func (*Compat) ClusterGetKeysInSlot 

func (c *Compat) ClusterGetKeysInSlot(ctx context.Context, slot int64, count int64) *StringSliceCmd

func (*Compat) ClusterInfo 

func (c *Compat) ClusterInfo(ctx context.Context) *StringCmd

func (*Compat) ClusterKeySlot 

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

func (*Compat) ClusterMeet 

func (c *Compat) ClusterMeet(ctx context.Context, host string, port int64) *StatusCmd

func (*Compat) ClusterNodes 

func (c *Compat) ClusterNodes(ctx context.Context) *StringCmd

func (*Compat) ClusterReplicate 

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

func (*Compat) ClusterResetHard 

func (c *Compat) ClusterResetHard(ctx context.Context) *StatusCmd

func (*Compat) ClusterResetSoft 

func (c *Compat) ClusterResetSoft(ctx context.Context) *StatusCmd

func (*Compat) ClusterSaveConfig 

func (c *Compat) ClusterSaveConfig(ctx context.Context) *StatusCmd

func (*Compat) ClusterSlaves 

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

func (*Compat) ClusterSlots 

func (c *Compat) ClusterSlots(ctx context.Context) *ClusterSlotsCmd

func (*Compat) Command 

func (c *Compat) Command(ctx context.Context) *CommandsInfoCmd

func (*Compat) ConfigGet 

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

func (*Compat) ConfigResetStat 

func (c *Compat) ConfigResetStat(ctx context.Context) *StatusCmd

func (*Compat) ConfigRewrite 

func (c *Compat) ConfigRewrite(ctx context.Context) *StatusCmd

func (*Compat) ConfigSet 

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

func (*Compat) Copy 

func (c *Compat) Copy(ctx context.Context, source string, destination string, db int64, replace bool) *IntCmd

func (*Compat) DBSize 

func (c *Compat) DBSize(ctx context.Context) *IntCmd

func (*Compat) DebugObject 

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

func (*Compat) Decr 

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

func (*Compat) DecrBy 

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

func (*Compat) Del 

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

func (*Compat) Dump 

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

func (*Compat) Echo 

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

func (*Compat) Eval 

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

func (*Compat) EvalSha 

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

func (*Compat) Exists 

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

func (*Compat) Expire 

func (c *Compat) Expire(ctx context.Context, key string, seconds time.Duration) *BoolCmd

func (*Compat) ExpireAt 

func (c *Compat) ExpireAt(ctx context.Context, key string, timestamp time.Time) *BoolCmd

func (*Compat) ExpireGT 

func (c *Compat) ExpireGT(ctx context.Context, key string, seconds time.Duration) *BoolCmd

func (*Compat) ExpireLT 

func (c *Compat) ExpireLT(ctx context.Context, key string, seconds time.Duration) *BoolCmd

func (*Compat) ExpireNX 

func (c *Compat) ExpireNX(ctx context.Context, key string, seconds time.Duration) *BoolCmd

func (*Compat) ExpireXX 

func (c *Compat) ExpireXX(ctx context.Context, key string, seconds time.Duration) *BoolCmd

func (*Compat) FlushAll 

func (c *Compat) FlushAll(ctx context.Context) *StatusCmd

func (*Compat) FlushAllAsync 

func (c *Compat) FlushAllAsync(ctx context.Context) *StatusCmd

func (*Compat) FlushDB 

func (c *Compat) FlushDB(ctx context.Context) *StatusCmd

func (*Compat) FlushDBAsync 

func (c *Compat) FlushDBAsync(ctx context.Context) *StatusCmd

func (*Compat) GeoAdd 

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

func (*Compat) GeoDist 

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

func (*Compat) GeoHash 

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

func (*Compat) GeoPos 

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

func (*Compat) GeoRadius 

func (c *Compat) GeoRadius(ctx context.Context, key string, longitude, latitude float64, query GeoRadiusQuery) *GeoLocationCmd

GeoRadius is a read-only GEORADIUS_RO command.

func (*Compat) GeoRadiusByMember 

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

GeoRadiusByMember is a read-only GEORADIUSBYMEMBER_RO command.

func (*Compat) GeoRadiusByMemberStore 

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

GeoRadiusByMemberStore is a writing GEORADIUSBYMEMBER command.

func (*Compat) GeoRadiusStore 

func (c *Compat) GeoRadiusStore(ctx context.Context, key string, longitude, latitude float64, query GeoRadiusQuery) *IntCmd

GeoRadiusStore is a writing GEORADIUS command.

func (*Compat) GeoSearch 

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

func (*Compat) GeoSearchLocation 

func (c *Compat) GeoSearchLocation(ctx context.Context, key string, q GeoSearchLocationQuery) *GeoLocationCmd

func (*Compat) GeoSearchStore 

func (c *Compat) GeoSearchStore(ctx context.Context, src, dest string, q GeoSearchStoreQuery) *IntCmd

func (*Compat) Get 

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

func (*Compat) GetBit 

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

func (*Compat) GetDel 

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

func (*Compat) GetEx 

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

GetEx An expiration of zero removes the TTL associated with the key (i.e. GETEX key persist). Requires Redis >= 6.2.0.

func (*Compat) GetRange 

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

func (*Compat) GetSet 

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

func (*Compat) HDel 

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

func (*Compat) HExists 

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

func (*Compat) HGet 

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

func (*Compat) HGetAll 

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

func (*Compat) HIncrBy 

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

func (*Compat) HIncrByFloat 

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

func (*Compat) HKeys 

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

func (*Compat) HLen 

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

func (*Compat) HMGet 

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

func (*Compat) HMSet 

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

HMSet is a deprecated version of HSet left for compatibility with Redis 3.

func (*Compat) HRandField 

func (c *Compat) HRandField(ctx context.Context, key string, count int64, withValues bool) *StringSliceCmd

func (*Compat) HScan 

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

func (*Compat) HSet 

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

HSet requires Redis v4 for multiple field/value pairs support.

func (*Compat) HSetNX 

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

func (*Compat) HVals 

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

func (*Compat) Incr 

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

func (*Compat) IncrBy 

func (c *Compat) IncrBy(ctx context.Context, key string, increment int64) *IntCmd

func (*Compat) IncrByFloat 

func (c *Compat) IncrByFloat(ctx context.Context, key string, increment float64) *FloatCmd

func (*Compat) Info 

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

func (*Compat) Keys 

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

func (*Compat) LIndex 

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

func (*Compat) LInsert 

func (c *Compat) LInsert(ctx context.Context, key, op string, pivot, element interface{}) *IntCmd

func (*Compat) LInsertAfter 

func (c *Compat) LInsertAfter(ctx context.Context, key string, pivot, element interface{}) *IntCmd

func (*Compat) LInsertBefore 

func (c *Compat) LInsertBefore(ctx context.Context, key string, pivot, element interface{}) *IntCmd

func (*Compat) LLen 

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

func (*Compat) LMove 

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

func (*Compat) LPop 

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

func (*Compat) LPopCount 

func (c *Compat) LPopCount(ctx context.Context, key string, count int64) *StringSliceCmd

func (*Compat) LPos 

func (c *Compat) LPos(ctx context.Context, key string, element string, a LPosArgs) *IntCmd

func (*Compat) LPosCount 

func (c *Compat) LPosCount(ctx context.Context, key string, element string, count int64, a LPosArgs) *IntSliceCmd

func (*Compat) LPush 

func (c *Compat) LPush(ctx context.Context, key string, elements ...interface{}) *IntCmd

func (*Compat) LPushX 

func (c *Compat) LPushX(ctx context.Context, key string, elements ...interface{}) *IntCmd

func (*Compat) LRange 

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

func (*Compat) LRem 

func (c *Compat) LRem(ctx context.Context, key string, count int64, element interface{}) *IntCmd

func (*Compat) LSet 

func (c *Compat) LSet(ctx context.Context, key string, index int64, element interface{}) *StatusCmd

func (*Compat) LTrim 

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

func (*Compat) LastSave 

func (c *Compat) LastSave(ctx context.Context) *IntCmd

func (*Compat) MGet 

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

func (*Compat) MSet 

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

func (*Compat) MSetNX 

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

func (*Compat) MemoryUsage 

func (c *Compat) MemoryUsage(ctx context.Context, key string, samples ...int64) *IntCmd

func (*Compat) Migrate 

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

func (*Compat) Move 

func (c *Compat) Move(ctx context.Context, key string, db int64) *BoolCmd

func (*Compat) ObjectEncoding 

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

func (*Compat) ObjectIdleTime 

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

func (*Compat) ObjectRefCount 

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

func (*Compat) PExpire 

func (c *Compat) PExpire(ctx context.Context, key string, milliseconds time.Duration) *BoolCmd

func (*Compat) PExpireAt 

func (c *Compat) PExpireAt(ctx context.Context, key string, millisecondsTimestamp time.Time) *BoolCmd

func (*Compat) PFAdd 

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

func (*Compat) PFCount 

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

func (*Compat) PFMerge 

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

func (*Compat) PTTL 

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

func (*Compat) Persist 

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

func (*Compat) Ping 

func (c *Compat) Ping(ctx context.Context) *StatusCmd

func (*Compat) PubSubChannels 

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

func (*Compat) PubSubNumPat 

func (c *Compat) PubSubNumPat(ctx context.Context) *IntCmd

func (*Compat) PubSubNumSub 

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

func (*Compat) Publish 

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

func (*Compat) Quit 

func (c *Compat) Quit(ctx context.Context) *StatusCmd

func (*Compat) RPop 

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

func (*Compat) RPopCount 

func (c *Compat) RPopCount(ctx context.Context, key string, count int64) *StringSliceCmd

func (*Compat) RPopLPush 

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

func (*Compat) RPush 

func (c *Compat) RPush(ctx context.Context, key string, elements ...interface{}) *IntCmd

func (*Compat) RPushX 

func (c *Compat) RPushX(ctx context.Context, key string, elements ...interface{}) *IntCmd

func (*Compat) RandomKey 

func (c *Compat) RandomKey(ctx context.Context) *StringCmd

func (*Compat) ReadOnly 

func (c *Compat) ReadOnly(ctx context.Context) *StatusCmd

func (*Compat) ReadWrite 

func (c *Compat) ReadWrite(ctx context.Context) *StatusCmd

func (*Compat) Rename 

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

func (*Compat) RenameNX 

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

func (*Compat) Restore 

func (c *Compat) Restore(ctx context.Context, key string, ttl time.Duration, serializedValue string) *StatusCmd

func (*Compat) RestoreReplace 

func (c *Compat) RestoreReplace(ctx context.Context, key string, ttl time.Duration, serializedValue string) *StatusCmd

func (*Compat) SAdd 

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

func (*Compat) SCard 

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

func (*Compat) SDiff 

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

func (*Compat) SDiffStore 

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

func (*Compat) SInter 

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

func (*Compat) SInterStore 

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

func (*Compat) SIsMember 

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

func (*Compat) SMIsMember 

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

func (*Compat) SMembers 

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

func (*Compat) SMembersMap 

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

func (*Compat) SMove 

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

func (*Compat) SPop 

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

func (*Compat) SPopN 

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

func (*Compat) SRandMember 

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

func (*Compat) SRandMemberN 

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

func (*Compat) SRem 

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

func (*Compat) SScan 

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

func (*Compat) SUnion 

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

func (*Compat) SUnionStore 

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

func (*Compat) Save 

func (c *Compat) Save(ctx context.Context) *StatusCmd

func (*Compat) Scan 

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

func (*Compat) ScanType 

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

func (*Compat) ScriptExists 

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

func (*Compat) ScriptFlush 

func (c *Compat) ScriptFlush(ctx context.Context) *StatusCmd

func (*Compat) ScriptKill 

func (c *Compat) ScriptKill(ctx context.Context) *StatusCmd

func (*Compat) ScriptLoad 

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

func (*Compat) Set 

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

Set key value [expiration]

For no expiration use 0.

For KEEPTTL use -1.

For more options, use SetArgs.

func (*Compat) SetArgs 

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

func (*Compat) SetBit 

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

func (*Compat) SetEX 

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

func (*Compat) SetNX 

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

func (*Compat) SetRange 

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

func (*Compat) SetXX 

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

func (*Compat) Shutdown 

func (c *Compat) Shutdown(ctx context.Context) *StatusCmd

func (*Compat) ShutdownNoSave 

func (c *Compat) ShutdownNoSave(ctx context.Context) *StatusCmd

func (*Compat) ShutdownSave 

func (c *Compat) ShutdownSave(ctx context.Context) *StatusCmd

func (*Compat) SlaveOf 

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

func (*Compat) Sort 

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

func (*Compat) SortInterfaces 

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

func (*Compat) SortStore 

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

func (*Compat) StrLen 

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

func (*Compat) TTL 

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

func (*Compat) Time 

func (c *Compat) Time(ctx context.Context) *TimeCmd

func (*Compat) Touch 

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

func (*Compat) Type 

func (c *Compat) Type(ctx context.Context, key string) *StatusCmd
func (c *Compat) Unlink(ctx context.Context, keys ...string) *IntCmd

func (*Compat) XAck 

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

func (*Compat) XAdd 

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

func (*Compat) XAutoClaim 

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

func (*Compat) XAutoClaimJustID 

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

func (*Compat) XClaim 

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

func (*Compat) XClaimJustID 

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

func (*Compat) XDel 

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

func (*Compat) XGroupCreate 

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

func (*Compat) XGroupCreateConsumer 

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

func (*Compat) XGroupCreateMkStream 

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

func (*Compat) XGroupDelConsumer 

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

func (*Compat) XGroupDestroy 

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

func (*Compat) XGroupSetID 

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

func (*Compat) XInfoConsumers 

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

func (*Compat) XInfoGroups 

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

func (*Compat) XInfoStream 

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

func (*Compat) XInfoStreamFull 

func (c *Compat) XInfoStreamFull(ctx context.Context, key string, count int64) *XInfoStreamFullCmd

func (*Compat) XLen 

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

func (*Compat) XPending 

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

func (*Compat) XPendingExt 

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

func (*Compat) XRange 

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

func (*Compat) XRangeN 

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

func (*Compat) XRead 

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

func (*Compat) XReadGroup 

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

func (*Compat) XReadStreams 

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

func (*Compat) XRevRange 

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

func (*Compat) XRevRangeN 

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

func (*Compat) XTrimMaxLen 

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

XTrimMaxLen No `~` rules are used, `limit` cannot be used. cmd: XTRIM key MAXLEN maxLen

func (*Compat) XTrimMaxLenApprox 

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

XTrimMaxLenApprox LIMIT has a bug, please confirm it and use it. issue: https://github.com/redis/redis/issues/9046 cmd: XTRIM key MAXLEN ~ maxLen LIMIT limit

func (*Compat) XTrimMinID 

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

XTrimMinID No `~` rules are used, `limit` cannot be used. cmd: XTRIM key MINID minID

func (*Compat) XTrimMinIDApprox 

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

XTrimMinIDApprox LIMIT has a bug, please confirm it and use it. issue: https://github.com/redis/redis/issues/9046 cmd: XTRIM key MINID ~ minID LIMIT limit

func (*Compat) ZAdd 

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

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

func (*Compat) ZAddArgs 

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

func (*Compat) ZAddArgsIncr 

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

func (*Compat) ZAddNX 

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

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

func (*Compat) ZAddXX 

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

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

func (*Compat) ZCard 

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

func (*Compat) ZCount 

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

func (*Compat) ZDiff 

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

func (*Compat) ZDiffStore 

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

func (*Compat) ZDiffWithScores 

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

func (*Compat) ZIncrBy 

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

func (*Compat) ZInter 

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

func (*Compat) ZInterStore 

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

func (*Compat) ZInterWithScores 

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

func (*Compat) ZLexCount 

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

func (*Compat) ZMScore 

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

func (*Compat) ZPopMax 

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

func (*Compat) ZPopMin 

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

func (*Compat) ZRandMember 

func (c *Compat) ZRandMember(ctx context.Context, key string, count int64) *StringSliceCmd

func (*Compat) ZRandMemberWithScores added in v0.1.4 

func (c *Compat) ZRandMemberWithScores(ctx context.Context, key string, count int64) *ZSliceCmd

func (*Compat) ZRange 

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

func (*Compat) ZRangeArgs 

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

func (*Compat) ZRangeArgsWithScores 

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

func (*Compat) ZRangeByLex 

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

func (*Compat) ZRangeByScore 

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

func (*Compat) ZRangeByScoreWithScores 

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

func (*Compat) ZRangeStore 

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

func (*Compat) ZRangeWithScores 

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

func (*Compat) ZRank 

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

func (*Compat) ZRem 

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

func (*Compat) ZRemRangeByLex 

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

func (*Compat) ZRemRangeByRank 

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

func (*Compat) ZRemRangeByScore 

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

func (*Compat) ZRevRange 

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

func (*Compat) ZRevRangeByLex 

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

func (*Compat) ZRevRangeByScore 

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

func (*Compat) ZRevRangeByScoreWithScores 

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

func (*Compat) ZRevRangeWithScores 

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

func (*Compat) ZRevRank 

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

func (*Compat) ZScan 

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

func (*Compat) ZScore 

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

func (*Compat) ZUnion 

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

func (*Compat) ZUnionStore 

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

func (*Compat) ZUnionWithScores 

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

type DurationCmd 

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

func (*DurationCmd) Err 

func (cmd *DurationCmd) Err() error

func (*DurationCmd) Result 

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

func (*DurationCmd) SetErr 

func (cmd *DurationCmd) SetErr(err error)

func (*DurationCmd) SetVal 

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

func (*DurationCmd) Val 

func (cmd *DurationCmd) Val() time.Duration

type FloatCmd 

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

func (*FloatCmd) Err 

func (cmd *FloatCmd) Err() error

func (*FloatCmd) Result 

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

func (*FloatCmd) SetErr 

func (cmd *FloatCmd) SetErr(err error)

func (*FloatCmd) SetVal 

func (cmd *FloatCmd) SetVal(val float64)

func (*FloatCmd) Val 

func (cmd *FloatCmd) Val() float64

type FloatSliceCmd 

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

func (*FloatSliceCmd) Err 

func (cmd *FloatSliceCmd) Err() error

func (*FloatSliceCmd) Result 

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

func (*FloatSliceCmd) SetErr 

func (cmd *FloatSliceCmd) SetErr(err error)

func (*FloatSliceCmd) SetVal 

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

func (*FloatSliceCmd) Val 

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

type GeoLocation 

type GeoLocation struct {
	Name                      string
	Longitude, Latitude, Dist float64
	GeoHash                   int64
}

type GeoLocationCmd 

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

func (*GeoLocationCmd) Err 

func (cmd *GeoLocationCmd) Err() error

func (*GeoLocationCmd) Result 

func (cmd *GeoLocationCmd) Result() ([]GeoLocation, error)

func (*GeoLocationCmd) SetErr 

func (cmd *GeoLocationCmd) SetErr(err error)

func (*GeoLocationCmd) SetVal 

func (cmd *GeoLocationCmd) SetVal(val []GeoLocation)

func (*GeoLocationCmd) Val 

func (cmd *GeoLocationCmd) Val() []GeoLocation

type GeoPos 

type GeoPos struct {
	Longitude, Latitude float64
}

type GeoPosCmd 

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

func (*GeoPosCmd) Err 

func (cmd *GeoPosCmd) Err() error

func (*GeoPosCmd) Result 

func (cmd *GeoPosCmd) Result() ([]*GeoPos, error)

func (*GeoPosCmd) SetErr 

func (cmd *GeoPosCmd) SetErr(err error)

func (*GeoPosCmd) SetVal 

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

func (*GeoPosCmd) Val 

func (cmd *GeoPosCmd) Val() []*GeoPos

type GeoRadiusQuery 

type GeoRadiusQuery struct {
	Radius float64
	// Can be m, km, ft, or mi. Default is km.
	Unit        string
	WithCoord   bool
	WithDist    bool
	WithGeoHash bool
	Count       int64
	// Can be ASC or DESC. Default is no sort order.
	Sort      string
	Store     string
	StoreDist string
}

GeoRadiusQuery is used with GeoRadius to query geospatial index.

type GeoSearchLocationQuery 

type GeoSearchLocationQuery struct {
	GeoSearchQuery

	WithCoord bool
	WithDist  bool
	WithHash  bool
}

type GeoSearchQuery 

type GeoSearchQuery struct {
	Member string

	// Latitude and Longitude when using FromLonLat option.
	Longitude float64
	Latitude  float64

	// Distance and unit when using ByRadius option.
	// Can use m, km, ft, or mi. Default is km.
	Radius     float64
	RadiusUnit string

	// Height, width and unit when using ByBox option.
	// Can be m, km, ft, or mi. Default is km.
	BoxWidth  float64
	BoxHeight float64
	BoxUnit   string

	// Can be ASC or DESC. Default is no sort order.
	Sort     string
	Count    int64
	CountAny bool
}

GeoSearchQuery is used for GEOSearch/GEOSearchStore command query.

type GeoSearchStoreQuery 

type GeoSearchStoreQuery struct {
	GeoSearchQuery

	// When using the StoreDist option, the command stores the items in a
	// sorted set populated with their distance from the center of the circle or box,
	// as a floating-point number, in the same unit specified for that shape.
	StoreDist bool
}

type IntCmd 

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

func (*IntCmd) Err 

func (cmd *IntCmd) Err() error

func (*IntCmd) Result 

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

func (*IntCmd) SetErr 

func (cmd *IntCmd) SetErr(err error)

func (*IntCmd) SetVal 

func (cmd *IntCmd) SetVal(val int64)

func (*IntCmd) Uint64 

func (cmd *IntCmd) Uint64() (uint64, error)

func (*IntCmd) Val 

func (cmd *IntCmd) Val() int64

type IntSliceCmd 

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

func (*IntSliceCmd) Err 

func (cmd *IntSliceCmd) Err() error

func (*IntSliceCmd) Result 

func (cmd *IntSliceCmd) Result() ([]int64, error)

func (*IntSliceCmd) SetErr 

func (cmd *IntSliceCmd) SetErr(err error)

func (*IntSliceCmd) SetVal 

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

func (*IntSliceCmd) Val 

func (cmd *IntSliceCmd) Val() []int64

type LPosArgs 

type LPosArgs struct {
	Rank, MaxLen int64
}

type ScanCmd 

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

func (*ScanCmd) Err 

func (cmd *ScanCmd) Err() error

func (*ScanCmd) Result 

func (cmd *ScanCmd) Result() (keys []string, cursor uint64, err error)

func (*ScanCmd) SetVal 

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

func (*ScanCmd) Val 

func (cmd *ScanCmd) Val() (keys []string, cursor uint64)

type SetArgs 

type SetArgs struct {
	// Mode can be `NX` or `XX` or empty.
	Mode string

	// Zero `TTL` or `Expiration` means that the key has no expiration time.
	TTL      time.Duration
	ExpireAt time.Time

	// When Get is true, the command returns the old value stored at key, or nil when key did not exist.
	Get bool

	// KeepTTL is a Redis KEEPTTL option to keep existing TTL, it requires your redis-server version >= 6.0,
	// otherwise you will receive an error: (error) ERR syntax error.
	KeepTTL bool
}

SetArgs provides arguments for the SetArgs function.

type SliceCmd 

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

func (*SliceCmd) Err 

func (cmd *SliceCmd) Err() error

func (*SliceCmd) Result 

func (cmd *SliceCmd) Result() ([]interface{}, error)

func (*SliceCmd) SetErr 

func (cmd *SliceCmd) SetErr(err error)

func (*SliceCmd) SetVal 

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

func (*SliceCmd) Val 

func (cmd *SliceCmd) Val() []interface{}

type Sort 

type Sort struct {
	By            string
	Offset, Count int64
	Get           []string
	Order         string
	Alpha         bool
}

type StatusCmd 

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

func (*StatusCmd) Err 

func (cmd *StatusCmd) Err() error

func (*StatusCmd) Result 

func (cmd *StatusCmd) Result() (string, error)

func (*StatusCmd) SetErr 

func (cmd *StatusCmd) SetErr(err error)

func (*StatusCmd) SetVal 

func (cmd *StatusCmd) SetVal(val string)

func (*StatusCmd) Val 

func (cmd *StatusCmd) Val() string

type StringCmd 

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

func (*StringCmd) Bool 

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

func (*StringCmd) Bytes 

func (cmd *StringCmd) Bytes() ([]byte, error)

func (*StringCmd) Err 

func (cmd *StringCmd) Err() error

func (*StringCmd) Float32 

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

func (*StringCmd) Float64 

func (cmd *StringCmd) Float64() (float64, error)

func (*StringCmd) Int 

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

func (*StringCmd) Int64 

func (cmd *StringCmd) Int64() (int64, error)

func (*StringCmd) Result 

func (cmd *StringCmd) Result() (string, error)

func (*StringCmd) SetErr 

func (cmd *StringCmd) SetErr(err error)

func (*StringCmd) SetVal 

func (cmd *StringCmd) SetVal(val string)

func (*StringCmd) String 

func (cmd *StringCmd) String() string

func (*StringCmd) Time 

func (cmd *StringCmd) Time() (time.Time, error)

func (*StringCmd) Uint64 

func (cmd *StringCmd) Uint64() (uint64, error)

func (*StringCmd) Val 

func (cmd *StringCmd) Val() string

type StringIntMapCmd 

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

func (*StringIntMapCmd) Err 

func (cmd *StringIntMapCmd) Err() error

func (*StringIntMapCmd) Result 

func (cmd *StringIntMapCmd) Result() (map[string]int64, error)

func (*StringIntMapCmd) SetErr 

func (cmd *StringIntMapCmd) SetErr(err error)

func (*StringIntMapCmd) SetVal 

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

func (*StringIntMapCmd) Val 

func (cmd *StringIntMapCmd) Val() map[string]int64

type StringSliceCmd 

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

func (*StringSliceCmd) Err 

func (cmd *StringSliceCmd) Err() error

func (*StringSliceCmd) Result 

func (cmd *StringSliceCmd) Result() ([]string, error)

func (*StringSliceCmd) SetErr 

func (cmd *StringSliceCmd) SetErr(err error)

func (*StringSliceCmd) SetVal 

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

func (*StringSliceCmd) Val 

func (cmd *StringSliceCmd) Val() []string

type StringStringMapCmd 

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

func (*StringStringMapCmd) Err 

func (cmd *StringStringMapCmd) Err() error

func (*StringStringMapCmd) Result 

func (cmd *StringStringMapCmd) Result() (map[string]string, error)

func (*StringStringMapCmd) SetErr 

func (cmd *StringStringMapCmd) SetErr(err error)

func (*StringStringMapCmd) SetVal 

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

func (*StringStringMapCmd) Val 

func (cmd *StringStringMapCmd) Val() map[string]string

type StringStructMapCmd 

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

func (*StringStructMapCmd) Err 

func (cmd *StringStructMapCmd) Err() error

func (*StringStructMapCmd) Result 

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

func (*StringStructMapCmd) SetErr 

func (cmd *StringStructMapCmd) SetErr(err error)

func (*StringStructMapCmd) SetVal 

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

func (*StringStructMapCmd) Val 

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

type TimeCmd 

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

func (*TimeCmd) Err 

func (cmd *TimeCmd) Err() error

func (*TimeCmd) Result 

func (cmd *TimeCmd) Result() (time.Time, error)

func (*TimeCmd) SetErr 

func (cmd *TimeCmd) SetErr(err error)

func (*TimeCmd) SetVal 

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

func (*TimeCmd) Val 

func (cmd *TimeCmd) Val() time.Time

type XAddArgs 

type XAddArgs struct {
	Stream     string
	NoMkStream bool
	MaxLen     int64 // MAXLEN N

	MinID string
	// Approx causes MaxLen and MinID to use "~" matcher (instead of "=").
	Approx bool
	Limit  int64
	ID     string
	Values interface{}
}

Note: MaxLen/MaxLenApprox and MinID are in conflict, only one of them can be used.

type XAutoClaimArgs 

type XAutoClaimArgs struct {
	Stream   string
	Group    string
	MinIdle  time.Duration
	Start    string
	Count    int64
	Consumer string
}

type XAutoClaimCmd 

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

func (*XAutoClaimCmd) Err 

func (cmd *XAutoClaimCmd) Err() error

func (*XAutoClaimCmd) Result 

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

func (*XAutoClaimCmd) SetErr 

func (cmd *XAutoClaimCmd) SetErr(err error)

func (*XAutoClaimCmd) SetVal 

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

func (*XAutoClaimCmd) Val 

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

type XAutoClaimJustIDCmd 

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

func (*XAutoClaimJustIDCmd) Err 

func (cmd *XAutoClaimJustIDCmd) Err() error

func (*XAutoClaimJustIDCmd) Result 

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

func (*XAutoClaimJustIDCmd) SetErr 

func (cmd *XAutoClaimJustIDCmd) SetErr(err error)

func (*XAutoClaimJustIDCmd) SetVal 

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

func (*XAutoClaimJustIDCmd) Val 

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

type XClaimArgs 

type XClaimArgs struct {
	Stream   string
	Group    string
	Consumer string
	MinIdle  time.Duration
	Messages []string
}

type XInfoConsumer 

type XInfoConsumer struct {
	Name    string
	Pending int64
	Idle    time.Duration
}

type XInfoConsumersCmd 

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

func (*XInfoConsumersCmd) Err 

func (cmd *XInfoConsumersCmd) Err() error

func (*XInfoConsumersCmd) Result 

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

func (*XInfoConsumersCmd) SetErr 

func (cmd *XInfoConsumersCmd) SetErr(err error)

func (*XInfoConsumersCmd) SetVal 

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

func (*XInfoConsumersCmd) Val 

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

type XInfoGroup 

type XInfoGroup struct {
	Name            string
	Consumers       int64
	Pending         int64
	EntriesRead     int64
	Lag             int64
	LastDeliveredID string
}

type XInfoGroupsCmd 

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

func (*XInfoGroupsCmd) Err 

func (cmd *XInfoGroupsCmd) Err() error

func (*XInfoGroupsCmd) Result 

func (cmd *XInfoGroupsCmd) Result() ([]XInfoGroup, error)

func (*XInfoGroupsCmd) SetErr 

func (cmd *XInfoGroupsCmd) SetErr(err error)

func (*XInfoGroupsCmd) SetVal 

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

func (*XInfoGroupsCmd) Val 

func (cmd *XInfoGroupsCmd) Val() []XInfoGroup

type XInfoStream 

type XInfoStream struct {
	Length               int64
	RadixTreeKeys        int64
	RadixTreeNodes       int64
	Groups               int64
	LastGeneratedID      string
	MaxDeletedEntryID    string
	EntriesAdded         int64
	FirstEntry           XMessage
	LastEntry            XMessage
	RecordedFirstEntryID string
}

type XInfoStreamCmd 

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

func (*XInfoStreamCmd) Err 

func (cmd *XInfoStreamCmd) Err() error

func (*XInfoStreamCmd) Result 

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

func (*XInfoStreamCmd) SetErr 

func (cmd *XInfoStreamCmd) SetErr(err error)

func (*XInfoStreamCmd) SetVal 

func (cmd *XInfoStreamCmd) SetVal(val XInfoStream)

func (*XInfoStreamCmd) Val 

func (cmd *XInfoStreamCmd) Val() XInfoStream

type XInfoStreamConsumer 

type XInfoStreamConsumer struct {
	Name     string
	SeenTime time.Time
	PelCount int64
	Pending  []XInfoStreamConsumerPending
}

type XInfoStreamConsumerPending 

type XInfoStreamConsumerPending struct {
	ID            string
	DeliveryTime  time.Time
	DeliveryCount int64
}

type XInfoStreamFull 

type XInfoStreamFull struct {
	Length               int64
	RadixTreeKeys        int64
	RadixTreeNodes       int64
	LastGeneratedID      string
	MaxDeletedEntryID    string
	EntriesAdded         int64
	Entries              []XMessage
	Groups               []XInfoStreamGroup
	RecordedFirstEntryID string
}

type XInfoStreamFullCmd 

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

func (*XInfoStreamFullCmd) Err 

func (cmd *XInfoStreamFullCmd) Err() error

func (*XInfoStreamFullCmd) Result 

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

func (*XInfoStreamFullCmd) SetErr 

func (cmd *XInfoStreamFullCmd) SetErr(err error)

func (*XInfoStreamFullCmd) SetVal 

func (cmd *XInfoStreamFullCmd) SetVal(val XInfoStreamFull)

func (*XInfoStreamFullCmd) Val 

func (cmd *XInfoStreamFullCmd) Val() XInfoStreamFull

type XInfoStreamGroup 

type XInfoStreamGroup struct {
	Name            string
	LastDeliveredID string
	EntriesRead     int64
	Lag             int64
	PelCount        int64
	Pending         []XInfoStreamGroupPending
	Consumers       []XInfoStreamConsumer
}

type XInfoStreamGroupPending 

type XInfoStreamGroupPending struct {
	ID            string
	Consumer      string
	DeliveryTime  time.Time
	DeliveryCount int64
}

type XMessage 

type XMessage struct {
	ID     string
	Values map[string]interface{}
}

type XMessageSliceCmd 

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

func (*XMessageSliceCmd) Err 

func (cmd *XMessageSliceCmd) Err() error

func (*XMessageSliceCmd) Result 

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

func (*XMessageSliceCmd) SetErr 

func (cmd *XMessageSliceCmd) SetErr(err error)

func (*XMessageSliceCmd) SetVal 

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

func (*XMessageSliceCmd) Val 

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

type XPending 

type XPending struct {
	Count     int64
	Lower     string
	Higher    string
	Consumers map[string]int64
}

type XPendingCmd 

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

func (*XPendingCmd) Err 

func (cmd *XPendingCmd) Err() error

func (*XPendingCmd) Result 

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

func (*XPendingCmd) SetErr 

func (cmd *XPendingCmd) SetErr(err error)

func (*XPendingCmd) SetVal 

func (cmd *XPendingCmd) SetVal(val XPending)

func (*XPendingCmd) Val 

func (cmd *XPendingCmd) Val() XPending

type XPendingExt 

type XPendingExt struct {
	ID         string
	Consumer   string
	Idle       time.Duration
	RetryCount int64
}

type XPendingExtArgs 

type XPendingExtArgs struct {
	Stream   string
	Group    string
	Idle     time.Duration
	Start    string
	End      string
	Count    int64
	Consumer string
}

type XPendingExtCmd 

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

func (*XPendingExtCmd) Err 

func (cmd *XPendingExtCmd) Err() error

func (*XPendingExtCmd) Result 

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

func (*XPendingExtCmd) SetErr 

func (cmd *XPendingExtCmd) SetErr(err error)

func (*XPendingExtCmd) SetVal 

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

func (*XPendingExtCmd) Val 

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

type XReadArgs 

type XReadArgs struct {
	Streams []string // list of streams
	Count   int64
	Block   time.Duration
}

type XReadGroupArgs 

type XReadGroupArgs struct {
	Group    string
	Consumer string
	Streams  []string // list of streams
	Count    int64
	Block    time.Duration
	NoAck    bool
}

type XStream 

type XStream struct {
	Stream   string
	Messages []XMessage
}

type XStreamSliceCmd 

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

func (*XStreamSliceCmd) Err 

func (cmd *XStreamSliceCmd) Err() error

func (*XStreamSliceCmd) Result 

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

func (*XStreamSliceCmd) SetErr 

func (cmd *XStreamSliceCmd) SetErr(err error)

func (*XStreamSliceCmd) SetVal 

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

func (*XStreamSliceCmd) Val 

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

type Z 

type Z struct {
	Score  float64
	Member interface{}
}

Z represents sorted set member.

type ZAddArgs 

type ZAddArgs struct {
	NX      bool
	XX      bool
	LT      bool
	GT      bool
	Ch      bool
	Members []Z
}

Note: The GT, LT and NX options are mutually exclusive.

type ZRangeArgs 

type ZRangeArgs struct {
	Key string

	Start interface{}
	Stop  interface{}

	// The ByScore and ByLex options are mutually exclusive.
	ByScore bool
	ByLex   bool

	Rev bool

	// limit offset count.
	Offset int64
	Count  int64
}

ZRangeArgs is all the options of the ZRange command. In version> 6.2.0, you can replace the(cmd): 

ZREVRANGE,
ZRANGEBYSCORE,
ZREVRANGEBYSCORE,
ZRANGEBYLEX,
ZREVRANGEBYLEX.

Please pay attention to your redis-server version.

Rev, ByScore, ByLex and Offset+Count options require redis-server 6.2.0 and higher.

type ZRangeBy 

type ZRangeBy struct {
	Min, Max      string
	Offset, Count int64
}

type ZSliceCmd 

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

func (*ZSliceCmd) Err 

func (cmd *ZSliceCmd) Err() error

func (*ZSliceCmd) Result 

func (cmd *ZSliceCmd) Result() ([]Z, error)

func (*ZSliceCmd) SetErr 

func (cmd *ZSliceCmd) SetErr(err error)

func (*ZSliceCmd) SetVal 

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

func (*ZSliceCmd) Val 

func (cmd *ZSliceCmd) Val() []Z

type ZStore 

type ZStore struct {
	Keys    []string
	Weights []int64
	// Can be SUM, MIN or MAX.
	Aggregate string
}

ZStore is used as an arg to ZInter/ZInterStore and ZUnion/ZUnionStore.

type ZWithKey 

type ZWithKey struct {
	Z
	Key string
}

ZWithKey represents sorted set member including the name of the key where it was popped.

type ZWithKeyCmd 

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

func (*ZWithKeyCmd) Err 

func (cmd *ZWithKeyCmd) Err() error

func (*ZWithKeyCmd) Result 

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

func (*ZWithKeyCmd) SetErr 

func (cmd *ZWithKeyCmd) SetErr(err error)

func (*ZWithKeyCmd) SetVal 

func (cmd *ZWithKeyCmd) SetVal(val ZWithKey)

func (*ZWithKeyCmd) Val 

func (cmd *ZWithKeyCmd) Val() ZWithKey

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.