Documentation ¶
Index ¶
- Constants
- func Scan(dst interface{}, keys []string, vals []interface{}) error
- type Aggregator
- type BFInfo
- type BFInfoCmd
- type BFInsertOptions
- type BFReserveOptions
- type BitCount
- type BitField
- type BitFieldArg
- type BoolCmd
- type BoolSliceCmd
- type CFInfo
- type CFInfoCmd
- type CFInsertOptions
- type CFReserveOptions
- type CMSInfo
- type CMSInfoCmd
- type CacheCompat
- func (c CacheCompat) BFExists(ctx context.Context, key string, element interface{}) *BoolCmd
- func (c CacheCompat) BFInfo(ctx context.Context, key string) *BFInfoCmd
- func (c CacheCompat) BFInfoArg(ctx context.Context, key, option string) *BFInfoCmd
- func (c CacheCompat) BFInfoCapacity(ctx context.Context, key string) *BFInfoCmd
- func (c CacheCompat) BFInfoExpansion(ctx context.Context, key string) *BFInfoCmd
- func (c CacheCompat) BFInfoFilters(ctx context.Context, key string) *BFInfoCmd
- func (c CacheCompat) BFInfoItems(ctx context.Context, key string) *BFInfoCmd
- func (c CacheCompat) BFInfoSize(ctx context.Context, key string) *BFInfoCmd
- func (c CacheCompat) BitCount(ctx context.Context, key string, bitCount *BitCount) *IntCmd
- func (c CacheCompat) BitPos(ctx context.Context, key string, bit int64, pos ...int64) *IntCmd
- func (c CacheCompat) BitPosSpan(ctx context.Context, key string, bit, start, end int64, span string) *IntCmd
- func (c *CacheCompat) CFCount(ctx context.Context, key string, element interface{}) *IntCmd
- func (c *CacheCompat) CFExists(ctx context.Context, key string, element interface{}) *BoolCmd
- func (c *CacheCompat) CFInfo(ctx context.Context, key string) *CFInfoCmd
- func (c *CacheCompat) CMSInfo(ctx context.Context, key string) *CMSInfoCmd
- func (c *CacheCompat) CMSQuery(ctx context.Context, key string, elements ...interface{}) *IntSliceCmd
- func (c CacheCompat) EvalRO(ctx context.Context, script string, keys []string, args ...any) *Cmd
- func (c CacheCompat) EvalShaRO(ctx context.Context, sha1 string, keys []string, args ...any) *Cmd
- func (c CacheCompat) FCallRO(ctx context.Context, function string, keys []string, args ...any) *Cmd
- func (c CacheCompat) GeoDist(ctx context.Context, key, member1, member2, unit string) *FloatCmd
- func (c CacheCompat) GeoHash(ctx context.Context, key string, members ...string) *StringSliceCmd
- func (c CacheCompat) GeoPos(ctx context.Context, key string, members ...string) *GeoPosCmd
- func (c CacheCompat) GeoRadius(ctx context.Context, key string, longitude, latitude float64, ...) *GeoLocationCmd
- func (c CacheCompat) GeoRadiusByMember(ctx context.Context, key, member string, query GeoRadiusQuery) *GeoLocationCmd
- func (c CacheCompat) GeoSearch(ctx context.Context, key string, q GeoSearchQuery) *StringSliceCmd
- func (c CacheCompat) Get(ctx context.Context, key string) *StringCmd
- func (c CacheCompat) GetBit(ctx context.Context, key string, offset int64) *IntCmd
- func (c CacheCompat) GetRange(ctx context.Context, key string, start, end int64) *StringCmd
- func (c CacheCompat) HExists(ctx context.Context, key, field string) *BoolCmd
- func (c CacheCompat) HGet(ctx context.Context, key, field string) *StringCmd
- func (c CacheCompat) HGetAll(ctx context.Context, key string) *StringStringMapCmd
- func (c CacheCompat) HKeys(ctx context.Context, key string) *StringSliceCmd
- func (c CacheCompat) HLen(ctx context.Context, key string) *IntCmd
- func (c CacheCompat) HMGet(ctx context.Context, key string, fields ...string) *SliceCmd
- func (c CacheCompat) HVals(ctx context.Context, key string) *StringSliceCmd
- func (c *CacheCompat) JSONArrIndex(ctx context.Context, key, path string, value ...interface{}) *IntSliceCmd
- func (c *CacheCompat) JSONArrLen(ctx context.Context, key, path string) *IntSliceCmd
- func (c *CacheCompat) JSONGet(ctx context.Context, key string, paths ...string) *JSONCmd
- func (c *CacheCompat) JSONMGet(ctx context.Context, path string, keys ...string) *JSONSliceCmd
- func (c *CacheCompat) JSONObjKeys(ctx context.Context, key, path string) *SliceCmd
- func (c *CacheCompat) JSONObjLen(ctx context.Context, key, path string) *IntPointerSliceCmd
- func (c *CacheCompat) JSONStrLen(ctx context.Context, key, path string) *IntPointerSliceCmd
- func (c *CacheCompat) JSONType(ctx context.Context, key, path string) *JSONSliceCmd
- func (c CacheCompat) LIndex(ctx context.Context, key string, index int64) *StringCmd
- func (c CacheCompat) LLen(ctx context.Context, key string) *IntCmd
- func (c CacheCompat) LPos(ctx context.Context, key string, element string, a LPosArgs) *IntCmd
- func (c CacheCompat) LRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd
- func (c CacheCompat) PTTL(ctx context.Context, key string) *DurationCmd
- func (c CacheCompat) SCard(ctx context.Context, key string) *IntCmd
- func (c CacheCompat) SIsMember(ctx context.Context, key string, member any) *BoolCmd
- func (c CacheCompat) SMIsMember(ctx context.Context, key string, members ...any) *BoolSliceCmd
- func (c CacheCompat) SMembers(ctx context.Context, key string) *StringSliceCmd
- func (c CacheCompat) SortRO(ctx context.Context, key string, sort Sort) *StringSliceCmd
- func (c CacheCompat) StrLen(ctx context.Context, key string) *IntCmd
- func (c CacheCompat) TTL(ctx context.Context, key string) *DurationCmd
- func (c *CacheCompat) TopKInfo(ctx context.Context, key string) *TopKInfoCmd
- func (c *CacheCompat) TopKList(ctx context.Context, key string) *StringSliceCmd
- func (c *CacheCompat) TopKQuery(ctx context.Context, key string, elements ...interface{}) *BoolSliceCmd
- func (c CacheCompat) Type(ctx context.Context, key string) *StatusCmd
- func (c CacheCompat) ZCard(ctx context.Context, key string) *IntCmd
- func (c CacheCompat) ZCount(ctx context.Context, key, min, max string) *IntCmd
- func (c CacheCompat) ZLexCount(ctx context.Context, key, min, max string) *IntCmd
- func (c CacheCompat) ZMScore(ctx context.Context, key string, members ...string) *FloatSliceCmd
- func (c CacheCompat) ZRangeArgs(ctx context.Context, z ZRangeArgs) *StringSliceCmd
- func (c CacheCompat) ZRangeArgsWithScores(ctx context.Context, z ZRangeArgs) *ZSliceCmd
- func (c CacheCompat) ZRangeByLex(ctx context.Context, key string, opt ZRangeBy) *StringSliceCmd
- func (c CacheCompat) ZRangeByScore(ctx context.Context, key string, opt ZRangeBy) *StringSliceCmd
- func (c CacheCompat) ZRangeByScoreWithScores(ctx context.Context, key string, opt ZRangeBy) *ZSliceCmd
- func (c CacheCompat) ZRangeWithScores(ctx context.Context, key string, start, stop int64) *ZSliceCmd
- func (c CacheCompat) ZRank(ctx context.Context, key, member string) *IntCmd
- func (c CacheCompat) ZRankWithScore(ctx context.Context, key, member string) *RankWithScoreCmd
- func (c CacheCompat) ZRevRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd
- func (c CacheCompat) ZRevRangeByLex(ctx context.Context, key string, opt ZRangeBy) *StringSliceCmd
- func (c CacheCompat) ZRevRangeByScore(ctx context.Context, key string, opt ZRangeBy) *StringSliceCmd
- func (c CacheCompat) ZRevRangeByScoreWithScores(ctx context.Context, key string, opt ZRangeBy) *ZSliceCmd
- func (c CacheCompat) ZRevRangeWithScores(ctx context.Context, key string, start, stop int64) *ZSliceCmd
- func (c CacheCompat) ZRevRank(ctx context.Context, key, member string) *IntCmd
- func (c CacheCompat) ZRevRankWithScore(ctx context.Context, key, member string) *RankWithScoreCmd
- func (c CacheCompat) ZScore(ctx context.Context, key, member string) *FloatCmd
- type ChannelOption
- type ClusterNode
- type ClusterShard
- type ClusterShardsCmd
- type ClusterSlot
- type ClusterSlotsCmd
- type Cmd
- func (cmd *Cmd) Bool() (bool, error)
- func (cmd *Cmd) BoolSlice() ([]bool, error)
- func (cmd *Cmd) Err() error
- func (cmd *Cmd) Float32() (float32, error)
- func (cmd *Cmd) Float32Slice() ([]float32, error)
- func (cmd *Cmd) Float64() (float64, error)
- func (cmd *Cmd) Float64Slice() ([]float64, error)
- func (cmd *Cmd) Int() (int, error)
- func (cmd *Cmd) Int64() (int64, error)
- func (cmd *Cmd) Int64Slice() ([]int64, error)
- func (cmd *Cmd) Result() (T, error)
- func (cmd *Cmd) SetErr(err error)
- func (cmd *Cmd) SetVal(val T)
- func (cmd *Cmd) Slice() ([]any, error)
- func (cmd *Cmd) StringSlice() ([]string, error)
- func (cmd *Cmd) Text() (string, error)
- func (cmd *Cmd) Uint64() (uint64, error)
- func (cmd *Cmd) Uint64Slice() ([]uint64, error)
- func (cmd *Cmd) Val() T
- type Cmdable
- type CommandInfo
- type CommandsInfoCmd
- type Compat
- func (c *Compat) ACLDryRun(ctx context.Context, username string, command ...any) *StringCmd
- func (c *Compat) Append(ctx context.Context, key, value string) *IntCmd
- func (c *Compat) BFAdd(ctx context.Context, key string, element interface{}) *BoolCmd
- func (c *Compat) BFCard(ctx context.Context, key string) *IntCmd
- func (c *Compat) BFExists(ctx context.Context, key string, element interface{}) *BoolCmd
- func (c *Compat) BFInfo(ctx context.Context, key string) *BFInfoCmd
- func (c *Compat) BFInfoArg(ctx context.Context, key, option string) *BFInfoCmd
- func (c *Compat) BFInfoCapacity(ctx context.Context, key string) *BFInfoCmd
- func (c *Compat) BFInfoExpansion(ctx context.Context, key string) *BFInfoCmd
- func (c *Compat) BFInfoFilters(ctx context.Context, key string) *BFInfoCmd
- func (c *Compat) BFInfoItems(ctx context.Context, key string) *BFInfoCmd
- func (c *Compat) BFInfoSize(ctx context.Context, key string) *BFInfoCmd
- func (c *Compat) BFInsert(ctx context.Context, key string, options *BFInsertOptions, ...) *BoolSliceCmd
- func (c *Compat) BFLoadChunk(ctx context.Context, key string, iterator int64, data interface{}) *StatusCmd
- func (c *Compat) BFMAdd(ctx context.Context, key string, elements ...interface{}) *BoolSliceCmd
- func (c *Compat) BFMExists(ctx context.Context, key string, elements ...interface{}) *BoolSliceCmd
- func (c *Compat) BFReserve(ctx context.Context, key string, errorRate float64, capacity int64) *StatusCmd
- func (c *Compat) BFReserveExpansion(ctx context.Context, key string, errorRate float64, capacity, expansion int64) *StatusCmd
- func (c *Compat) BFReserveNonScaling(ctx context.Context, key string, errorRate float64, capacity int64) *StatusCmd
- func (c *Compat) BFReserveWithArgs(ctx context.Context, key string, options *BFReserveOptions) *StatusCmd
- func (c *Compat) BFScanDump(ctx context.Context, key string, iterator int64) *ScanDumpCmd
- func (c *Compat) BLMPop(ctx context.Context, timeout time.Duration, direction string, count int64, ...) *KeyValuesCmd
- func (c *Compat) BLMove(ctx context.Context, source, destination, srcpos, destpos string, ...) *StringCmd
- func (c *Compat) BLPop(ctx context.Context, timeout time.Duration, keys ...string) *StringSliceCmd
- func (c *Compat) BRPop(ctx context.Context, timeout time.Duration, keys ...string) *StringSliceCmd
- func (c *Compat) BRPopLPush(ctx context.Context, source, destination string, timeout time.Duration) *StringCmd
- func (c *Compat) BZMPop(ctx context.Context, timeout time.Duration, order string, count int64, ...) *ZSliceWithKeyCmd
- func (c *Compat) BZPopMax(ctx context.Context, timeout time.Duration, keys ...string) *ZWithKeyCmd
- func (c *Compat) BZPopMin(ctx context.Context, timeout time.Duration, keys ...string) *ZWithKeyCmd
- func (c *Compat) BgRewriteAOF(ctx context.Context) *StatusCmd
- func (c *Compat) BgSave(ctx context.Context) *StatusCmd
- func (c *Compat) BitCount(ctx context.Context, key string, bitCount *BitCount) *IntCmd
- func (c *Compat) BitField(ctx context.Context, key string, args ...any) *IntSliceCmd
- func (c *Compat) BitOpAnd(ctx context.Context, destKey string, keys ...string) *IntCmd
- func (c *Compat) BitOpNot(ctx context.Context, destKey string, key string) *IntCmd
- func (c *Compat) BitOpOr(ctx context.Context, destKey string, keys ...string) *IntCmd
- func (c *Compat) BitOpXor(ctx context.Context, destKey string, keys ...string) *IntCmd
- func (c *Compat) BitPos(ctx context.Context, key string, bit int64, pos ...int64) *IntCmd
- func (c *Compat) BitPosSpan(ctx context.Context, key string, bit, start, end int64, span string) *IntCmd
- func (c *Compat) CFAdd(ctx context.Context, key string, element interface{}) *BoolCmd
- func (c *Compat) CFAddNX(ctx context.Context, key string, element interface{}) *BoolCmd
- func (c *Compat) CFCount(ctx context.Context, key string, element interface{}) *IntCmd
- func (c *Compat) CFDel(ctx context.Context, key string, element interface{}) *BoolCmd
- func (c *Compat) CFExists(ctx context.Context, key string, element interface{}) *BoolCmd
- func (c *Compat) CFInfo(ctx context.Context, key string) *CFInfoCmd
- func (c *Compat) CFInsert(ctx context.Context, key string, options *CFInsertOptions, ...) *BoolSliceCmd
- func (c *Compat) CFInsertNX(ctx context.Context, key string, options *CFInsertOptions, ...) *IntSliceCmd
- func (c *Compat) CFLoadChunk(ctx context.Context, key string, iterator int64, data interface{}) *StatusCmd
- func (c *Compat) CFMExists(ctx context.Context, key string, elements ...interface{}) *BoolSliceCmd
- func (c *Compat) CFReserve(ctx context.Context, key string, capacity int64) *StatusCmd
- func (c *Compat) CFReserveBucketSize(ctx context.Context, key string, capacity int64, bucketsize int64) *StatusCmd
- func (c *Compat) CFReserveExpansion(ctx context.Context, key string, capacity int64, expansion int64) *StatusCmd
- func (c *Compat) CFReserveMaxIterations(ctx context.Context, key string, capacity int64, maxiterations int64) *StatusCmd
- func (c *Compat) CFReserveWithArgs(ctx context.Context, key string, options *CFReserveOptions) *StatusCmd
- func (c *Compat) CFScanDump(ctx context.Context, key string, iterator int64) *ScanDumpCmd
- func (c *Compat) CMSIncrBy(ctx context.Context, key string, elements ...interface{}) *IntSliceCmd
- func (c *Compat) CMSInfo(ctx context.Context, key string) *CMSInfoCmd
- func (c *Compat) CMSInitByDim(ctx context.Context, key string, width, height int64) *StatusCmd
- func (c *Compat) CMSInitByProb(ctx context.Context, key string, errorRate, probability float64) *StatusCmd
- func (c *Compat) CMSMerge(ctx context.Context, destKey string, sourceKeys ...string) *StatusCmd
- func (c *Compat) CMSMergeWithWeight(ctx context.Context, destKey string, sourceKeys map[string]int64) *StatusCmd
- func (c *Compat) CMSQuery(ctx context.Context, key string, elements ...interface{}) *IntSliceCmd
- func (c *Compat) Cache(ttl time.Duration) CacheCompat
- func (c *Compat) ClientGetName(ctx context.Context) *StringCmd
- func (c *Compat) ClientID(ctx context.Context) *IntCmd
- func (c *Compat) ClientKill(ctx context.Context, ipPort string) *StatusCmd
- func (c *Compat) ClientKillByFilter(ctx context.Context, keys ...string) *IntCmd
- func (c *Compat) ClientList(ctx context.Context) *StringCmd
- func (c *Compat) ClientPause(ctx context.Context, dur time.Duration) *BoolCmd
- func (c *Compat) ClientUnblock(ctx context.Context, id int64) *IntCmd
- func (c *Compat) ClientUnblockWithError(ctx context.Context, id int64) *IntCmd
- func (c *Compat) ClientUnpause(ctx context.Context) *BoolCmd
- func (c *Compat) ClusterAddSlots(ctx context.Context, slots ...int64) *StatusCmd
- func (c *Compat) ClusterAddSlotsRange(ctx context.Context, min, max int64) *StatusCmd
- func (c *Compat) ClusterCountFailureReports(ctx context.Context, nodeID string) *IntCmd
- func (c *Compat) ClusterCountKeysInSlot(ctx context.Context, slot int64) *IntCmd
- func (c *Compat) ClusterDelSlots(ctx context.Context, slots ...int64) *StatusCmd
- func (c *Compat) ClusterDelSlotsRange(ctx context.Context, min, max int64) *StatusCmd
- func (c *Compat) ClusterFailover(ctx context.Context) *StatusCmd
- func (c *Compat) ClusterForget(ctx context.Context, nodeID string) *StatusCmd
- func (c *Compat) ClusterGetKeysInSlot(ctx context.Context, slot int64, count int64) *StringSliceCmd
- func (c *Compat) ClusterInfo(ctx context.Context) *StringCmd
- func (c *Compat) ClusterKeySlot(ctx context.Context, key string) *IntCmd
- func (c *Compat) ClusterMeet(ctx context.Context, host string, port int64) *StatusCmd
- func (c *Compat) ClusterNodes(ctx context.Context) *StringCmd
- func (c *Compat) ClusterReplicate(ctx context.Context, nodeID string) *StatusCmd
- func (c *Compat) ClusterResetHard(ctx context.Context) *StatusCmd
- func (c *Compat) ClusterResetSoft(ctx context.Context) *StatusCmd
- func (c *Compat) ClusterSaveConfig(ctx context.Context) *StatusCmd
- func (c *Compat) ClusterShards(ctx context.Context) *ClusterShardsCmd
- func (c *Compat) ClusterSlaves(ctx context.Context, nodeID string) *StringSliceCmd
- func (c *Compat) ClusterSlots(ctx context.Context) *ClusterSlotsCmd
- func (c *Compat) Command(ctx context.Context) *CommandsInfoCmd
- func (c *Compat) CommandGetKeys(ctx context.Context, commands ...any) *StringSliceCmd
- func (c *Compat) CommandGetKeysAndFlags(ctx context.Context, commands ...any) *KeyFlagsCmd
- func (c *Compat) CommandList(ctx context.Context, filter FilterBy) *StringSliceCmd
- func (c *Compat) ConfigGet(ctx context.Context, parameter string) *StringStringMapCmd
- func (c *Compat) ConfigResetStat(ctx context.Context) *StatusCmd
- func (c *Compat) ConfigRewrite(ctx context.Context) *StatusCmd
- func (c *Compat) ConfigSet(ctx context.Context, parameter, value string) *StatusCmd
- func (c *Compat) Copy(ctx context.Context, source string, destination string, db int64, replace bool) *IntCmd
- func (c *Compat) DBSize(ctx context.Context) *IntCmd
- func (c *Compat) DebugObject(ctx context.Context, key string) *StringCmd
- func (c *Compat) Decr(ctx context.Context, key string) *IntCmd
- func (c *Compat) DecrBy(ctx context.Context, key string, decrement int64) *IntCmd
- func (c *Compat) Del(ctx context.Context, keys ...string) *IntCmd
- func (c *Compat) Dump(ctx context.Context, key string) *StringCmd
- func (c *Compat) Echo(ctx context.Context, message any) *StringCmd
- func (c *Compat) Eval(ctx context.Context, script string, keys []string, args ...any) *Cmd
- func (c *Compat) EvalRO(ctx context.Context, script string, keys []string, args ...any) *Cmd
- func (c *Compat) EvalSha(ctx context.Context, sha1 string, keys []string, args ...any) *Cmd
- func (c *Compat) EvalShaRO(ctx context.Context, sha1 string, keys []string, args ...any) *Cmd
- func (c *Compat) Exists(ctx context.Context, keys ...string) *IntCmd
- func (c *Compat) Expire(ctx context.Context, key string, seconds time.Duration) *BoolCmd
- func (c *Compat) ExpireAt(ctx context.Context, key string, timestamp time.Time) *BoolCmd
- func (c *Compat) ExpireGT(ctx context.Context, key string, seconds time.Duration) *BoolCmd
- func (c *Compat) ExpireLT(ctx context.Context, key string, seconds time.Duration) *BoolCmd
- func (c *Compat) ExpireNX(ctx context.Context, key string, seconds time.Duration) *BoolCmd
- func (c *Compat) ExpireTime(ctx context.Context, key string) *DurationCmd
- func (c *Compat) ExpireXX(ctx context.Context, key string, seconds time.Duration) *BoolCmd
- func (c *Compat) FCall(ctx context.Context, function string, keys []string, args ...any) *Cmd
- func (c *Compat) FCallRO(ctx context.Context, function string, keys []string, args ...any) *Cmd
- func (c *Compat) FlushAll(ctx context.Context) *StatusCmd
- func (c *Compat) FlushAllAsync(ctx context.Context) *StatusCmd
- func (c *Compat) FlushDB(ctx context.Context) *StatusCmd
- func (c *Compat) FlushDBAsync(ctx context.Context) *StatusCmd
- func (c *Compat) FunctionDelete(ctx context.Context, libName string) *StringCmd
- func (c *Compat) FunctionDump(ctx context.Context) *StringCmd
- func (c *Compat) FunctionFlush(ctx context.Context) *StringCmd
- func (c *Compat) FunctionFlushAsync(ctx context.Context) *StringCmd
- func (c *Compat) FunctionKill(ctx context.Context) *StringCmd
- func (c *Compat) FunctionList(ctx context.Context, q FunctionListQuery) *FunctionListCmd
- func (c *Compat) FunctionLoad(ctx context.Context, code string) *StringCmd
- func (c *Compat) FunctionLoadReplace(ctx context.Context, code string) *StringCmd
- func (c *Compat) FunctionRestore(ctx context.Context, libDump string) *StringCmd
- func (c *Compat) GeoAdd(ctx context.Context, key string, geoLocation ...GeoLocation) *IntCmd
- func (c *Compat) GeoDist(ctx context.Context, key, member1, member2, unit string) *FloatCmd
- func (c *Compat) GeoHash(ctx context.Context, key string, members ...string) *StringSliceCmd
- func (c *Compat) GeoPos(ctx context.Context, key string, members ...string) *GeoPosCmd
- func (c *Compat) GeoRadius(ctx context.Context, key string, longitude, latitude float64, ...) *GeoLocationCmd
- func (c *Compat) GeoRadiusByMember(ctx context.Context, key, member string, query GeoRadiusQuery) *GeoLocationCmd
- func (c *Compat) GeoRadiusByMemberStore(ctx context.Context, key, member string, query GeoRadiusQuery) *IntCmd
- func (c *Compat) GeoRadiusStore(ctx context.Context, key string, longitude, latitude float64, ...) *IntCmd
- func (c *Compat) GeoSearch(ctx context.Context, key string, q GeoSearchQuery) *StringSliceCmd
- func (c *Compat) GeoSearchLocation(ctx context.Context, key string, q GeoSearchLocationQuery) *GeoLocationCmd
- func (c *Compat) GeoSearchStore(ctx context.Context, src, dest string, q GeoSearchStoreQuery) *IntCmd
- func (c *Compat) Get(ctx context.Context, key string) *StringCmd
- func (c *Compat) GetBit(ctx context.Context, key string, offset int64) *IntCmd
- func (c *Compat) GetDel(ctx context.Context, key string) *StringCmd
- func (c *Compat) GetEx(ctx context.Context, key string, expiration time.Duration) *StringCmd
- func (c *Compat) GetRange(ctx context.Context, key string, start, end int64) *StringCmd
- func (c *Compat) GetSet(ctx context.Context, key string, value any) *StringCmd
- func (c *Compat) HDel(ctx context.Context, key string, fields ...string) *IntCmd
- func (c *Compat) HExists(ctx context.Context, key, field string) *BoolCmd
- func (c *Compat) HGet(ctx context.Context, key, field string) *StringCmd
- func (c *Compat) HGetAll(ctx context.Context, key string) *StringStringMapCmd
- func (c *Compat) HIncrBy(ctx context.Context, key, field string, incr int64) *IntCmd
- func (c *Compat) HIncrByFloat(ctx context.Context, key, field string, incr float64) *FloatCmd
- func (c *Compat) HKeys(ctx context.Context, key string) *StringSliceCmd
- func (c *Compat) HLen(ctx context.Context, key string) *IntCmd
- func (c *Compat) HMGet(ctx context.Context, key string, fields ...string) *SliceCmd
- func (c *Compat) HMSet(ctx context.Context, key string, values ...any) *BoolCmd
- func (c *Compat) HRandField(ctx context.Context, key string, count int64) *StringSliceCmd
- func (c *Compat) HRandFieldWithValues(ctx context.Context, key string, count int64) *KeyValueSliceCmd
- func (c *Compat) HScan(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd
- func (c *Compat) HSet(ctx context.Context, key string, values ...any) *IntCmd
- func (c *Compat) HSetNX(ctx context.Context, key, field string, value any) *BoolCmd
- func (c *Compat) HVals(ctx context.Context, key string) *StringSliceCmd
- func (c *Compat) Incr(ctx context.Context, key string) *IntCmd
- func (c *Compat) IncrBy(ctx context.Context, key string, increment int64) *IntCmd
- func (c *Compat) IncrByFloat(ctx context.Context, key string, increment float64) *FloatCmd
- func (c *Compat) Info(ctx context.Context, section ...string) *StringCmd
- func (c *Compat) JSONArrAppend(ctx context.Context, key, path string, values ...interface{}) *IntSliceCmd
- func (c *Compat) JSONArrIndex(ctx context.Context, key, path string, value ...interface{}) *IntSliceCmd
- func (c *Compat) JSONArrIndexWithArgs(ctx context.Context, key, path string, options *JSONArrIndexArgs, ...) *IntSliceCmd
- func (c *Compat) JSONArrInsert(ctx context.Context, key, path string, index int64, values ...interface{}) *IntSliceCmd
- func (c *Compat) JSONArrLen(ctx context.Context, key, path string) *IntSliceCmd
- func (c *Compat) JSONArrPop(ctx context.Context, key, path string, index int) *StringSliceCmd
- func (c *Compat) JSONArrTrim(ctx context.Context, key, path string) *IntSliceCmd
- func (c *Compat) JSONArrTrimWithArgs(ctx context.Context, key, path string, options *JSONArrTrimArgs) *IntSliceCmd
- func (c *Compat) JSONClear(ctx context.Context, key, path string) *IntCmd
- func (c *Compat) JSONDebugMemory(ctx context.Context, key, path string) *IntCmd
- func (c *Compat) JSONDel(ctx context.Context, key, path string) *IntCmd
- func (c *Compat) JSONForget(ctx context.Context, key, path string) *IntCmd
- func (c *Compat) JSONGet(ctx context.Context, key string, paths ...string) *JSONCmd
- func (c *Compat) JSONGetWithArgs(ctx context.Context, key string, options *JSONGetArgs, paths ...string) *JSONCmd
- func (c *Compat) JSONMGet(ctx context.Context, path string, keys ...string) *JSONSliceCmd
- func (c *Compat) JSONMSet(ctx context.Context, params ...interface{}) *StatusCmd
- func (c *Compat) JSONMSetArgs(ctx context.Context, docs []JSONSetArgs) *StatusCmd
- func (c *Compat) JSONMerge(ctx context.Context, key, path string, value string) *StatusCmd
- func (c *Compat) JSONNumIncrBy(ctx context.Context, key, path string, value float64) *JSONCmd
- func (c *Compat) JSONObjKeys(ctx context.Context, key, path string) *SliceCmd
- func (c *Compat) JSONObjLen(ctx context.Context, key, path string) *IntPointerSliceCmd
- func (c *Compat) JSONSet(ctx context.Context, key, path string, value interface{}) *StatusCmd
- func (c *Compat) JSONSetMode(ctx context.Context, key, path string, value interface{}, mode string) *StatusCmd
- func (c *Compat) JSONStrAppend(ctx context.Context, key, path, value string) *IntPointerSliceCmd
- func (c *Compat) JSONStrLen(ctx context.Context, key, path string) *IntPointerSliceCmd
- func (c *Compat) JSONToggle(ctx context.Context, key, path string) *IntPointerSliceCmd
- func (c *Compat) JSONType(ctx context.Context, key, path string) *JSONSliceCmd
- func (c *Compat) Keys(ctx context.Context, pattern string) *StringSliceCmd
- func (c *Compat) LIndex(ctx context.Context, key string, index int64) *StringCmd
- func (c *Compat) LInsert(ctx context.Context, key, op string, pivot, element any) *IntCmd
- func (c *Compat) LInsertAfter(ctx context.Context, key string, pivot, element any) *IntCmd
- func (c *Compat) LInsertBefore(ctx context.Context, key string, pivot, element any) *IntCmd
- func (c *Compat) LLen(ctx context.Context, key string) *IntCmd
- func (c *Compat) LMPop(ctx context.Context, direction string, count int64, keys ...string) *KeyValuesCmd
- func (c *Compat) LMove(ctx context.Context, source, destination, srcpos, destpos string) *StringCmd
- func (c *Compat) LPop(ctx context.Context, key string) *StringCmd
- func (c *Compat) LPopCount(ctx context.Context, key string, count int64) *StringSliceCmd
- func (c *Compat) LPos(ctx context.Context, key string, element string, a LPosArgs) *IntCmd
- func (c *Compat) LPosCount(ctx context.Context, key string, element string, count int64, a LPosArgs) *IntSliceCmd
- func (c *Compat) LPush(ctx context.Context, key string, elements ...any) *IntCmd
- func (c *Compat) LPushX(ctx context.Context, key string, elements ...any) *IntCmd
- func (c *Compat) LRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd
- func (c *Compat) LRem(ctx context.Context, key string, count int64, element any) *IntCmd
- func (c *Compat) LSet(ctx context.Context, key string, index int64, element any) *StatusCmd
- func (c *Compat) LTrim(ctx context.Context, key string, start, stop int64) *StatusCmd
- func (c *Compat) LastSave(ctx context.Context) *IntCmd
- func (c *Compat) MGet(ctx context.Context, keys ...string) *SliceCmd
- func (c *Compat) MSet(ctx context.Context, values ...any) *StatusCmd
- func (c *Compat) MSetNX(ctx context.Context, values ...any) *BoolCmd
- func (c *Compat) MemoryUsage(ctx context.Context, key string, samples ...int64) *IntCmd
- func (c *Compat) Migrate(ctx context.Context, host string, port int64, key string, db int64, ...) *StatusCmd
- func (c *Compat) Move(ctx context.Context, key string, db int64) *BoolCmd
- func (c *Compat) ObjectEncoding(ctx context.Context, key string) *StringCmd
- func (c *Compat) ObjectIdleTime(ctx context.Context, key string) *DurationCmd
- func (c *Compat) ObjectRefCount(ctx context.Context, key string) *IntCmd
- func (c *Compat) PExpire(ctx context.Context, key string, milliseconds time.Duration) *BoolCmd
- func (c *Compat) PExpireAt(ctx context.Context, key string, millisecondsTimestamp time.Time) *BoolCmd
- func (c *Compat) PExpireTime(ctx context.Context, key string) *DurationCmd
- func (c *Compat) PFAdd(ctx context.Context, key string, els ...any) *IntCmd
- func (c *Compat) PFCount(ctx context.Context, keys ...string) *IntCmd
- func (c *Compat) PFMerge(ctx context.Context, dest string, keys ...string) *StatusCmd
- func (c *Compat) PSubscribe(ctx context.Context, patterns ...string) PubSub
- func (c *Compat) PTTL(ctx context.Context, key string) *DurationCmd
- func (c *Compat) Persist(ctx context.Context, key string) *BoolCmd
- func (c *Compat) Ping(ctx context.Context) *StatusCmd
- func (c *Compat) PubSubChannels(ctx context.Context, pattern string) *StringSliceCmd
- func (c *Compat) PubSubNumPat(ctx context.Context) *IntCmd
- func (c *Compat) PubSubNumSub(ctx context.Context, channels ...string) *StringIntMapCmd
- func (c *Compat) PubSubShardChannels(ctx context.Context, pattern string) *StringSliceCmd
- func (c *Compat) PubSubShardNumSub(ctx context.Context, channels ...string) *StringIntMapCmd
- func (c *Compat) Publish(ctx context.Context, channel string, message any) *IntCmd
- func (c *Compat) Quit(ctx context.Context) *StatusCmd
- func (c *Compat) RPop(ctx context.Context, key string) *StringCmd
- func (c *Compat) RPopCount(ctx context.Context, key string, count int64) *StringSliceCmd
- func (c *Compat) RPopLPush(ctx context.Context, source, destination string) *StringCmd
- func (c *Compat) RPush(ctx context.Context, key string, elements ...any) *IntCmd
- func (c *Compat) RPushX(ctx context.Context, key string, elements ...any) *IntCmd
- func (c *Compat) RandomKey(ctx context.Context) *StringCmd
- func (c *Compat) ReadOnly(ctx context.Context) *StatusCmd
- func (c *Compat) ReadWrite(ctx context.Context) *StatusCmd
- func (c *Compat) Rename(ctx context.Context, key, newkey string) *StatusCmd
- func (c *Compat) RenameNX(ctx context.Context, key, newkey string) *BoolCmd
- func (c *Compat) Restore(ctx context.Context, key string, ttl time.Duration, serializedValue string) *StatusCmd
- func (c *Compat) RestoreReplace(ctx context.Context, key string, ttl time.Duration, serializedValue string) *StatusCmd
- func (c *Compat) SAdd(ctx context.Context, key string, members ...any) *IntCmd
- func (c *Compat) SCard(ctx context.Context, key string) *IntCmd
- func (c *Compat) SDiff(ctx context.Context, keys ...string) *StringSliceCmd
- func (c *Compat) SDiffStore(ctx context.Context, destination string, keys ...string) *IntCmd
- func (c *Compat) SInter(ctx context.Context, keys ...string) *StringSliceCmd
- func (c *Compat) SInterCard(ctx context.Context, limit int64, keys ...string) *IntCmd
- func (c *Compat) SInterStore(ctx context.Context, destination string, keys ...string) *IntCmd
- func (c *Compat) SIsMember(ctx context.Context, key string, member any) *BoolCmd
- func (c *Compat) SMIsMember(ctx context.Context, key string, members ...any) *BoolSliceCmd
- func (c *Compat) SMembers(ctx context.Context, key string) *StringSliceCmd
- func (c *Compat) SMembersMap(ctx context.Context, key string) *StringStructMapCmd
- func (c *Compat) SMove(ctx context.Context, source, destination string, member any) *BoolCmd
- func (c *Compat) SPop(ctx context.Context, key string) *StringCmd
- func (c *Compat) SPopN(ctx context.Context, key string, count int64) *StringSliceCmd
- func (c *Compat) SPublish(ctx context.Context, channel string, message any) *IntCmd
- func (c *Compat) SRandMember(ctx context.Context, key string) *StringCmd
- func (c *Compat) SRandMemberN(ctx context.Context, key string, count int64) *StringSliceCmd
- func (c *Compat) SRem(ctx context.Context, key string, members ...any) *IntCmd
- func (c *Compat) SScan(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd
- func (c *Compat) SSubscribe(ctx context.Context, channels ...string) PubSub
- func (c *Compat) SUnion(ctx context.Context, keys ...string) *StringSliceCmd
- func (c *Compat) SUnionStore(ctx context.Context, destination string, keys ...string) *IntCmd
- func (c *Compat) Save(ctx context.Context) *StatusCmd
- func (c *Compat) Scan(ctx context.Context, cursor uint64, match string, count int64) *ScanCmd
- func (c *Compat) ScanType(ctx context.Context, cursor uint64, match string, count int64, keyType string) *ScanCmd
- func (c *Compat) ScriptExists(ctx context.Context, hashes ...string) *BoolSliceCmd
- func (c *Compat) ScriptFlush(ctx context.Context) *StatusCmd
- func (c *Compat) ScriptKill(ctx context.Context) *StatusCmd
- func (c *Compat) ScriptLoad(ctx context.Context, script string) *StringCmd
- func (c *Compat) Set(ctx context.Context, key string, value any, expiration time.Duration) *StatusCmd
- func (c *Compat) SetArgs(ctx context.Context, key string, value any, a SetArgs) *StatusCmd
- func (c *Compat) SetBit(ctx context.Context, key string, offset int64, value int64) *IntCmd
- func (c *Compat) SetEX(ctx context.Context, key string, value any, expiration time.Duration) *StatusCmd
- func (c *Compat) SetNX(ctx context.Context, key string, value any, expiration time.Duration) *BoolCmd
- func (c *Compat) SetRange(ctx context.Context, key string, offset int64, value string) *IntCmd
- func (c *Compat) SetXX(ctx context.Context, key string, value any, expiration time.Duration) *BoolCmd
- func (c *Compat) Shutdown(ctx context.Context) *StatusCmd
- func (c *Compat) ShutdownNoSave(ctx context.Context) *StatusCmd
- func (c *Compat) ShutdownSave(ctx context.Context) *StatusCmd
- func (c *Compat) Sort(ctx context.Context, key string, sort Sort) *StringSliceCmd
- func (c *Compat) SortInterfaces(ctx context.Context, key string, sort Sort) *SliceCmd
- func (c *Compat) SortRO(ctx context.Context, key string, sort Sort) *StringSliceCmd
- func (c *Compat) SortStore(ctx context.Context, key, store string, sort Sort) *IntCmd
- func (c *Compat) StrLen(ctx context.Context, key string) *IntCmd
- func (c *Compat) Subscribe(ctx context.Context, channels ...string) PubSub
- func (c *Compat) TDigestAdd(ctx context.Context, key string, elements ...float64) *StatusCmd
- func (c *Compat) TDigestByRank(ctx context.Context, key string, rank ...uint64) *FloatSliceCmd
- func (c *Compat) TDigestByRevRank(ctx context.Context, key string, rank ...uint64) *FloatSliceCmd
- func (c *Compat) TDigestCDF(ctx context.Context, key string, elements ...float64) *FloatSliceCmd
- func (c *Compat) TDigestCreate(ctx context.Context, key string) *StatusCmd
- func (c *Compat) TDigestCreateWithCompression(ctx context.Context, key string, compression int64) *StatusCmd
- func (c *Compat) TDigestInfo(ctx context.Context, key string) *TDigestInfoCmd
- func (c *Compat) TDigestMax(ctx context.Context, key string) *FloatCmd
- func (c *Compat) TDigestMerge(ctx context.Context, destKey string, options *TDigestMergeOptions, ...) *StatusCmd
- func (c *Compat) TDigestMin(ctx context.Context, key string) *FloatCmd
- func (c *Compat) TDigestQuantile(ctx context.Context, key string, elements ...float64) *FloatSliceCmd
- func (c *Compat) TDigestRank(ctx context.Context, key string, values ...float64) *IntSliceCmd
- func (c *Compat) TDigestReset(ctx context.Context, key string) *StatusCmd
- func (c *Compat) TDigestRevRank(ctx context.Context, key string, values ...float64) *IntSliceCmd
- func (c *Compat) TDigestTrimmedMean(ctx context.Context, key string, lowCutQuantile, highCutQuantile float64) *FloatCmd
- func (c *Compat) TFCall(ctx context.Context, libName string, funcName string, numKeys int) *Cmd
- func (c *Compat) TFCallASYNC(ctx context.Context, libName string, funcName string, numKeys int) *Cmd
- func (c *Compat) TFCallASYNCArgs(ctx context.Context, libName string, funcName string, numKeys int, ...) *Cmd
- func (c *Compat) TFCallArgs(ctx context.Context, libName string, funcName string, numKeys int, ...) *Cmd
- func (c *Compat) TFunctionDelete(ctx context.Context, libName string) *StatusCmd
- func (c *Compat) TFunctionList(ctx context.Context) *MapStringInterfaceSliceCmd
- func (c *Compat) TFunctionListArgs(ctx context.Context, options *TFunctionListOptions) *MapStringInterfaceSliceCmd
- func (c *Compat) TFunctionLoad(ctx context.Context, lib string) *StatusCmd
- func (c *Compat) TFunctionLoadArgs(ctx context.Context, lib string, options *TFunctionLoadOptions) *StatusCmd
- func (c *Compat) TSAdd(ctx context.Context, key string, timestamp interface{}, value float64) *IntCmd
- func (c *Compat) TSAddWithArgs(ctx context.Context, key string, timestamp interface{}, value float64, ...) *IntCmd
- func (c *Compat) TSAlter(ctx context.Context, key string, options *TSAlterOptions) *StatusCmd
- func (c *Compat) TSCreate(ctx context.Context, key string) *StatusCmd
- func (c *Compat) TSCreateRule(ctx context.Context, sourceKey string, destKey string, aggregator Aggregator, ...) *StatusCmd
- func (c *Compat) TSCreateRuleWithArgs(ctx context.Context, sourceKey string, destKey string, aggregator Aggregator, ...) *StatusCmd
- func (c *Compat) TSCreateWithArgs(ctx context.Context, key string, options *TSOptions) *StatusCmd
- func (c *Compat) TSDecrBy(ctx context.Context, Key string, timestamp float64) *IntCmd
- func (c *Compat) TSDecrByWithArgs(ctx context.Context, key string, timestamp float64, options *TSIncrDecrOptions) *IntCmd
- func (c *Compat) TSDel(ctx context.Context, Key string, fromTimestamp int, toTimestamp int) *IntCmd
- func (c *Compat) TSDeleteRule(ctx context.Context, sourceKey string, destKey string) *StatusCmd
- func (c *Compat) TSGet(ctx context.Context, key string) *TSTimestampValueCmd
- func (c *Compat) TSGetWithArgs(ctx context.Context, key string, options *TSGetOptions) *TSTimestampValueCmd
- func (c *Compat) TSIncrBy(ctx context.Context, Key string, timestamp float64) *IntCmd
- func (c *Compat) TSIncrByWithArgs(ctx context.Context, key string, timestamp float64, options *TSIncrDecrOptions) *IntCmd
- func (c *Compat) TSInfo(ctx context.Context, key string) *MapStringInterfaceCmd
- func (c *Compat) TSInfoWithArgs(ctx context.Context, key string, options *TSInfoOptions) *MapStringInterfaceCmd
- func (c *Compat) TSMAdd(ctx context.Context, ktvSlices [][]interface{}) *IntSliceCmd
- func (c *Compat) TSMGet(ctx context.Context, filters []string) *MapStringSliceInterfaceCmd
- func (c *Compat) TSMGetWithArgs(ctx context.Context, filters []string, options *TSMGetOptions) *MapStringSliceInterfaceCmd
- func (c *Compat) TSMRange(ctx context.Context, fromTimestamp int, toTimestamp int, filterExpr []string) *MapStringSliceInterfaceCmd
- func (c *Compat) TSMRangeWithArgs(ctx context.Context, fromTimestamp int, toTimestamp int, filterExpr []string, ...) *MapStringSliceInterfaceCmd
- func (c *Compat) TSMRevRange(ctx context.Context, fromTimestamp int, toTimestamp int, filterExpr []string) *MapStringSliceInterfaceCmd
- func (c *Compat) TSMRevRangeWithArgs(ctx context.Context, fromTimestamp int, toTimestamp int, filterExpr []string, ...) *MapStringSliceInterfaceCmd
- func (c *Compat) TSQueryIndex(ctx context.Context, filterExpr []string) *StringSliceCmd
- func (c *Compat) TSRange(ctx context.Context, key string, fromTimestamp int, toTimestamp int) *TSTimestampValueSliceCmd
- func (c *Compat) TSRangeWithArgs(ctx context.Context, key string, fromTimestamp int, toTimestamp int, ...) *TSTimestampValueSliceCmd
- func (c *Compat) TSRevRange(ctx context.Context, key string, fromTimestamp int, toTimestamp int) *TSTimestampValueSliceCmd
- func (c *Compat) TSRevRangeWithArgs(ctx context.Context, key string, fromTimestamp int, toTimestamp int, ...) *TSTimestampValueSliceCmd
- func (c *Compat) TTL(ctx context.Context, key string) *DurationCmd
- func (c *Compat) Time(ctx context.Context) *TimeCmd
- func (c *Compat) TopKAdd(ctx context.Context, key string, elements ...interface{}) *StringSliceCmd
- func (c *Compat) TopKCount(ctx context.Context, key string, elements ...interface{}) *IntSliceCmd
- func (c *Compat) TopKIncrBy(ctx context.Context, key string, elements ...interface{}) *StringSliceCmd
- func (c *Compat) TopKInfo(ctx context.Context, key string) *TopKInfoCmd
- func (c *Compat) TopKList(ctx context.Context, key string) *StringSliceCmd
- func (c *Compat) TopKListWithCount(ctx context.Context, key string) *MapStringIntCmd
- func (c *Compat) TopKQuery(ctx context.Context, key string, elements ...interface{}) *BoolSliceCmd
- func (c *Compat) TopKReserve(ctx context.Context, key string, k int64) *StatusCmd
- func (c *Compat) TopKReserveWithOptions(ctx context.Context, key string, k int64, width, depth int64, decay float64) *StatusCmd
- func (c *Compat) Touch(ctx context.Context, keys ...string) *IntCmd
- func (c *Compat) Type(ctx context.Context, key string) *StatusCmd
- func (c *Compat) Unlink(ctx context.Context, keys ...string) *IntCmd
- func (c *Compat) XAck(ctx context.Context, stream, group string, ids ...string) *IntCmd
- func (c *Compat) XAdd(ctx context.Context, a XAddArgs) *StringCmd
- func (c *Compat) XAutoClaim(ctx context.Context, a XAutoClaimArgs) *XAutoClaimCmd
- func (c *Compat) XAutoClaimJustID(ctx context.Context, a XAutoClaimArgs) *XAutoClaimJustIDCmd
- func (c *Compat) XClaim(ctx context.Context, a XClaimArgs) *XMessageSliceCmd
- func (c *Compat) XClaimJustID(ctx context.Context, a XClaimArgs) *StringSliceCmd
- func (c *Compat) XDel(ctx context.Context, stream string, ids ...string) *IntCmd
- func (c *Compat) XGroupCreate(ctx context.Context, stream, group, start string) *StatusCmd
- func (c *Compat) XGroupCreateConsumer(ctx context.Context, stream, group, consumer string) *IntCmd
- func (c *Compat) XGroupCreateMkStream(ctx context.Context, stream, group, start string) *StatusCmd
- func (c *Compat) XGroupDelConsumer(ctx context.Context, stream, group, consumer string) *IntCmd
- func (c *Compat) XGroupDestroy(ctx context.Context, stream, group string) *IntCmd
- func (c *Compat) XGroupSetID(ctx context.Context, stream, group, start string) *StatusCmd
- func (c *Compat) XInfoConsumers(ctx context.Context, key, group string) *XInfoConsumersCmd
- func (c *Compat) XInfoGroups(ctx context.Context, key string) *XInfoGroupsCmd
- func (c *Compat) XInfoStream(ctx context.Context, key string) *XInfoStreamCmd
- func (c *Compat) XInfoStreamFull(ctx context.Context, key string, count int64) *XInfoStreamFullCmd
- func (c *Compat) XLen(ctx context.Context, stream string) *IntCmd
- func (c *Compat) XPending(ctx context.Context, stream, group string) *XPendingCmd
- func (c *Compat) XPendingExt(ctx context.Context, a XPendingExtArgs) *XPendingExtCmd
- func (c *Compat) XRange(ctx context.Context, stream, start, stop string) *XMessageSliceCmd
- func (c *Compat) XRangeN(ctx context.Context, stream, start, stop string, count int64) *XMessageSliceCmd
- func (c *Compat) XRead(ctx context.Context, a XReadArgs) *XStreamSliceCmd
- func (c *Compat) XReadGroup(ctx context.Context, a XReadGroupArgs) *XStreamSliceCmd
- func (c *Compat) XReadStreams(ctx context.Context, streams ...string) *XStreamSliceCmd
- func (c *Compat) XRevRange(ctx context.Context, stream, stop, start string) *XMessageSliceCmd
- func (c *Compat) XRevRangeN(ctx context.Context, stream, stop, start string, count int64) *XMessageSliceCmd
- func (c *Compat) XTrimMaxLen(ctx context.Context, key string, maxLen int64) *IntCmd
- func (c *Compat) XTrimMaxLenApprox(ctx context.Context, key string, maxLen, limit int64) *IntCmd
- func (c *Compat) XTrimMinID(ctx context.Context, key string, minID string) *IntCmd
- func (c *Compat) XTrimMinIDApprox(ctx context.Context, key string, minID string, limit int64) *IntCmd
- func (c *Compat) ZAdd(ctx context.Context, key string, members ...Z) *IntCmd
- func (c *Compat) ZAddArgs(ctx context.Context, key string, args ZAddArgs) *IntCmd
- func (c *Compat) ZAddArgsIncr(ctx context.Context, key string, args ZAddArgs) *FloatCmd
- func (c *Compat) ZAddGT(ctx context.Context, key string, members ...Z) *IntCmd
- func (c *Compat) ZAddLT(ctx context.Context, key string, members ...Z) *IntCmd
- func (c *Compat) ZAddNX(ctx context.Context, key string, members ...Z) *IntCmd
- func (c *Compat) ZAddXX(ctx context.Context, key string, members ...Z) *IntCmd
- func (c *Compat) ZCard(ctx context.Context, key string) *IntCmd
- func (c *Compat) ZCount(ctx context.Context, key, min, max string) *IntCmd
- func (c *Compat) ZDiff(ctx context.Context, keys ...string) *StringSliceCmd
- func (c *Compat) ZDiffStore(ctx context.Context, destination string, keys ...string) *IntCmd
- func (c *Compat) ZDiffWithScores(ctx context.Context, keys ...string) *ZSliceCmd
- func (c *Compat) ZIncrBy(ctx context.Context, key string, increment float64, member string) *FloatCmd
- func (c *Compat) ZInter(ctx context.Context, store ZStore) *StringSliceCmd
- func (c *Compat) ZInterCard(ctx context.Context, limit int64, keys ...string) *IntCmd
- func (c *Compat) ZInterStore(ctx context.Context, destination string, store ZStore) *IntCmd
- func (c *Compat) ZInterWithScores(ctx context.Context, store ZStore) *ZSliceCmd
- func (c *Compat) ZLexCount(ctx context.Context, key, min, max string) *IntCmd
- func (c *Compat) ZMPop(ctx context.Context, order string, count int64, keys ...string) *ZSliceWithKeyCmd
- func (c *Compat) ZMScore(ctx context.Context, key string, members ...string) *FloatSliceCmd
- func (c *Compat) ZPopMax(ctx context.Context, key string, count ...int64) *ZSliceCmd
- func (c *Compat) ZPopMin(ctx context.Context, key string, count ...int64) *ZSliceCmd
- func (c *Compat) ZRandMember(ctx context.Context, key string, count int64) *StringSliceCmd
- func (c *Compat) ZRandMemberWithScores(ctx context.Context, key string, count int64) *ZSliceCmd
- func (c *Compat) ZRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd
- func (c *Compat) ZRangeArgs(ctx context.Context, z ZRangeArgs) *StringSliceCmd
- func (c *Compat) ZRangeArgsWithScores(ctx context.Context, z ZRangeArgs) *ZSliceCmd
- func (c *Compat) ZRangeByLex(ctx context.Context, key string, opt ZRangeBy) *StringSliceCmd
- func (c *Compat) ZRangeByScore(ctx context.Context, key string, opt ZRangeBy) *StringSliceCmd
- func (c *Compat) ZRangeByScoreWithScores(ctx context.Context, key string, opt ZRangeBy) *ZSliceCmd
- func (c *Compat) ZRangeStore(ctx context.Context, dst string, z ZRangeArgs) *IntCmd
- func (c *Compat) ZRangeWithScores(ctx context.Context, key string, start, stop int64) *ZSliceCmd
- func (c *Compat) ZRank(ctx context.Context, key, member string) *IntCmd
- func (c *Compat) ZRankWithScore(ctx context.Context, key, member string) *RankWithScoreCmd
- func (c *Compat) ZRem(ctx context.Context, key string, members ...any) *IntCmd
- func (c *Compat) ZRemRangeByLex(ctx context.Context, key string, min, max string) *IntCmd
- func (c *Compat) ZRemRangeByRank(ctx context.Context, key string, start, stop int64) *IntCmd
- func (c *Compat) ZRemRangeByScore(ctx context.Context, key, min, max string) *IntCmd
- func (c *Compat) ZRevRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd
- func (c *Compat) ZRevRangeByLex(ctx context.Context, key string, opt ZRangeBy) *StringSliceCmd
- func (c *Compat) ZRevRangeByScore(ctx context.Context, key string, opt ZRangeBy) *StringSliceCmd
- func (c *Compat) ZRevRangeByScoreWithScores(ctx context.Context, key string, opt ZRangeBy) *ZSliceCmd
- func (c *Compat) ZRevRangeWithScores(ctx context.Context, key string, start, stop int64) *ZSliceCmd
- func (c *Compat) ZRevRank(ctx context.Context, key, member string) *IntCmd
- func (c *Compat) ZRevRankWithScore(ctx context.Context, key, member string) *RankWithScoreCmd
- func (c *Compat) ZScan(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd
- func (c *Compat) ZScore(ctx context.Context, key, member string) *FloatCmd
- func (c *Compat) ZUnion(ctx context.Context, store ZStore) *StringSliceCmd
- func (c *Compat) ZUnionStore(ctx context.Context, dest string, store ZStore) *IntCmd
- func (c *Compat) ZUnionWithScores(ctx context.Context, store ZStore) *ZSliceCmd
- type DurationCmd
- type FilterBy
- type FloatCmd
- type FloatSliceCmd
- type Function
- type FunctionListCmd
- type FunctionListQuery
- type GearsCmdable
- type GeoLocation
- type GeoLocationCmd
- type GeoPos
- type GeoPosCmd
- type GeoRadiusQuery
- type GeoSearchLocationQuery
- type GeoSearchQuery
- type GeoSearchStoreQuery
- type IntCmd
- type IntPointerSliceCmd
- type IntSliceCmd
- type JSONArrIndexArgs
- type JSONArrTrimArgs
- type JSONCmd
- type JSONCmdable
- type JSONGetArgs
- type JSONSetArgs
- type JSONSliceCmd
- type KeyFlags
- type KeyFlagsCmd
- type KeyValue
- type KeyValueSliceCmd
- type KeyValuesCmd
- type LPosArgs
- type Library
- type MapStringIntCmd
- type MapStringInterfaceCmd
- type MapStringInterfaceSliceCmd
- type MapStringSliceInterfaceCmd
- type Message
- type Node
- type ProbabilisticCmdable
- type PubSub
- type RankScore
- type RankWithScoreCmd
- type ScanCmd
- type ScanDump
- type ScanDumpCmd
- type Scanner
- type SetArgs
- type SliceCmd
- type SlotRange
- type Sort
- type StatusCmd
- type StringCmd
- func (cmd *StringCmd) Bool() (bool, error)
- 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) Int() (int, error)
- func (cmd *StringCmd) Int64() (int64, error)
- func (cmd *StringCmd) Result() (T, error)
- func (cmd *StringCmd) SetErr(err error)
- func (cmd *StringCmd) SetVal(val T)
- func (cmd *StringCmd) String() string
- func (cmd *StringCmd) Time() (time.Time, error)
- func (cmd *StringCmd) Uint64() (uint64, error)
- func (cmd *StringCmd) Val() T
- type StringIntMapCmd
- type StringSliceCmd
- type StringStringMapCmd
- type StringStructMapCmd
- type StructValue
- type Subscription
- type TDigestInfo
- type TDigestInfoCmd
- type TDigestMergeOptions
- type TFCallOptions
- type TFunctionListOptions
- type TFunctionLoadOptions
- type TSAlterOptions
- type TSCreateRuleOptions
- type TSGetOptions
- type TSIncrDecrOptions
- type TSInfoOptions
- type TSMGetOptions
- type TSMRangeOptions
- type TSMRevRangeOptions
- type TSOptions
- type TSRangeOptions
- type TSRevRangeOptions
- type TSTimestampValue
- type TSTimestampValueCmd
- type TSTimestampValueSliceCmd
- type TimeCmd
- type TimeseriesCmdable
- type TopKInfo
- type TopKInfoCmd
- type XAddArgs
- type XAutoClaimArgs
- type XAutoClaimCmd
- type XAutoClaimJustIDCmd
- func (cmd *XAutoClaimJustIDCmd) Err() error
- func (cmd *XAutoClaimJustIDCmd) Result() (ids []string, start string, err error)
- func (cmd *XAutoClaimJustIDCmd) SetErr(err error)
- func (cmd *XAutoClaimJustIDCmd) SetVal(val []string, start string)
- func (cmd *XAutoClaimJustIDCmd) Val() (ids []string, start string)
- type XClaimArgs
- type XInfoConsumer
- type XInfoConsumersCmd
- type XInfoGroup
- type XInfoGroupsCmd
- type XInfoStream
- type XInfoStreamCmd
- type XInfoStreamConsumer
- type XInfoStreamConsumerPending
- type XInfoStreamFull
- type XInfoStreamFullCmd
- type XInfoStreamGroup
- type XInfoStreamGroupPending
- type XMessage
- type XMessageSliceCmd
- type XPending
- type XPendingCmd
- type XPendingExt
- type XPendingExtArgs
- type XPendingExtCmd
- type XReadArgs
- type XReadGroupArgs
- type XStream
- type XStreamSliceCmd
- type Z
- type ZAddArgs
- type ZRangeArgs
- type ZRangeBy
- type ZSliceCmd
- type ZSliceWithKeyCmd
- type ZStore
- type ZWithKey
- type ZWithKeyCmd
Constants ¶
const ( KeepTTL = -1 BitCountIndexByte = "BYTE" BitCountIndexBit = "BIT" )
const ( Invalid = Aggregator(iota) Avg Sum Min Max Range Count First Last StdP StdS VarP VarS Twa )
const ( TYP_STRING jsonCmdTyp = iota TYP_ARRAY )
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Aggregator ¶
type Aggregator int
func (Aggregator) String ¶
func (a Aggregator) String() string
type BFInsertOptions ¶
type BFReserveOptions ¶
type BitField ¶
type BitField struct { Get *BitFieldArg Set *BitFieldArg IncrBy *BitFieldArg Overflow string Increment int64 }
type BitFieldArg ¶
type BoolSliceCmd ¶
type BoolSliceCmd struct {
// contains filtered or unexported fields
}
type CFInfo ¶
type CFInfo struct { Size int64 `redis:"Size"` NumBuckets int64 `redis:"Number of buckets"` NumFilters int64 `redis:"Number of filters"` NumItemsInserted int64 `redis:"Number of items inserted"` NumItemsDeleted int64 `redis:"Number of items deleted"` BucketSize int64 `redis:"Bucket size"` ExpansionRate int64 `redis:"Expansion rate"` MaxIteration int64 `redis:"Max iterations"` }
type CFInsertOptions ¶
type CFReserveOptions ¶
type CMSInfoCmd ¶
type CMSInfoCmd struct {
// contains filtered or unexported fields
}
type CacheCompat ¶
type CacheCompat struct {
// contains filtered or unexported fields
}
CacheCompat implements commands that support client-side caching.
func (CacheCompat) BFExists ¶
func (c CacheCompat) BFExists(ctx context.Context, key string, element interface{}) *BoolCmd
func (CacheCompat) BFInfoArg ¶
func (c CacheCompat) BFInfoArg(ctx context.Context, key, option string) *BFInfoCmd
func (CacheCompat) BFInfoCapacity ¶
func (c CacheCompat) BFInfoCapacity(ctx context.Context, key string) *BFInfoCmd
func (CacheCompat) BFInfoExpansion ¶
func (c CacheCompat) BFInfoExpansion(ctx context.Context, key string) *BFInfoCmd
func (CacheCompat) BFInfoFilters ¶
func (c CacheCompat) BFInfoFilters(ctx context.Context, key string) *BFInfoCmd
func (CacheCompat) BFInfoItems ¶
func (c CacheCompat) BFInfoItems(ctx context.Context, key string) *BFInfoCmd
func (CacheCompat) BFInfoSize ¶
func (c CacheCompat) BFInfoSize(ctx context.Context, key string) *BFInfoCmd
func (CacheCompat) BitPosSpan ¶
func (*CacheCompat) CFCount ¶
func (c *CacheCompat) CFCount(ctx context.Context, key string, element interface{}) *IntCmd
func (*CacheCompat) CFExists ¶
func (c *CacheCompat) CFExists(ctx context.Context, key string, element interface{}) *BoolCmd
func (*CacheCompat) CFInfo ¶
func (c *CacheCompat) CFInfo(ctx context.Context, key string) *CFInfoCmd
func (*CacheCompat) CMSInfo ¶
func (c *CacheCompat) CMSInfo(ctx context.Context, key string) *CMSInfoCmd
func (*CacheCompat) CMSQuery ¶
func (c *CacheCompat) CMSQuery(ctx context.Context, key string, elements ...interface{}) *IntSliceCmd
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) 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) 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) HVals ¶
func (c CacheCompat) HVals(ctx context.Context, key string) *StringSliceCmd
func (*CacheCompat) JSONArrIndex ¶
func (c *CacheCompat) JSONArrIndex(ctx context.Context, key, path string, value ...interface{}) *IntSliceCmd
func (*CacheCompat) JSONArrLen ¶
func (c *CacheCompat) JSONArrLen(ctx context.Context, key, path string) *IntSliceCmd
func (*CacheCompat) JSONMGet ¶
func (c *CacheCompat) JSONMGet(ctx context.Context, path string, keys ...string) *JSONSliceCmd
func (*CacheCompat) JSONObjKeys ¶
func (c *CacheCompat) JSONObjKeys(ctx context.Context, key, path string) *SliceCmd
func (*CacheCompat) JSONObjLen ¶
func (c *CacheCompat) JSONObjLen(ctx context.Context, key, path string) *IntPointerSliceCmd
func (*CacheCompat) JSONStrLen ¶
func (c *CacheCompat) JSONStrLen(ctx context.Context, key, path string) *IntPointerSliceCmd
func (*CacheCompat) JSONType ¶
func (c *CacheCompat) JSONType(ctx context.Context, key, path string) *JSONSliceCmd
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) SMIsMember ¶
func (c CacheCompat) SMIsMember(ctx context.Context, key string, members ...any) *BoolSliceCmd
func (CacheCompat) SMembers ¶
func (c CacheCompat) SMembers(ctx context.Context, key string) *StringSliceCmd
func (CacheCompat) SortRO ¶
func (c CacheCompat) SortRO(ctx context.Context, key string, sort Sort) *StringSliceCmd
func (CacheCompat) TTL ¶
func (c CacheCompat) TTL(ctx context.Context, key string) *DurationCmd
func (*CacheCompat) TopKInfo ¶
func (c *CacheCompat) TopKInfo(ctx context.Context, key string) *TopKInfoCmd
func (*CacheCompat) TopKList ¶
func (c *CacheCompat) TopKList(ctx context.Context, key string) *StringSliceCmd
func (*CacheCompat) TopKQuery ¶
func (c *CacheCompat) TopKQuery(ctx context.Context, key string, elements ...interface{}) *BoolSliceCmd
func (CacheCompat) ZCount ¶
func (c CacheCompat) ZCount(ctx context.Context, key, 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 (CacheCompat) ZRangeWithScores ¶
func (CacheCompat) ZRank ¶
func (c CacheCompat) ZRank(ctx context.Context, key, member string) *IntCmd
func (CacheCompat) ZRankWithScore ¶
func (c CacheCompat) ZRankWithScore(ctx context.Context, key, member string) *RankWithScoreCmd
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 (CacheCompat) ZRevRangeWithScores ¶
func (CacheCompat) ZRevRank ¶
func (c CacheCompat) ZRevRank(ctx context.Context, key, member string) *IntCmd
func (CacheCompat) ZRevRankWithScore ¶
func (c CacheCompat) ZRevRankWithScore(ctx context.Context, key, member string) *RankWithScoreCmd
type ChannelOption ¶ added in v1.0.42
type ChannelOption func(c *chopt)
func WithChannelHealthCheckInterval ¶ added in v1.0.42
func WithChannelHealthCheckInterval(_ time.Duration) ChannelOption
WithChannelHealthCheckInterval is an empty ChannelOption to keep compatibility
func WithChannelSendTimeout ¶ added in v1.0.42
func WithChannelSendTimeout(_ time.Duration) ChannelOption
WithChannelSendTimeout is an empty ChannelOption to keep compatibility
func WithChannelSize ¶ added in v1.0.42
func WithChannelSize(size int) ChannelOption
WithChannelSize specifies the Go chan size that is used to buffer incoming messages. The default is 1000 messages.
type ClusterNode ¶
type ClusterShard ¶
type ClusterShardsCmd ¶
type ClusterShardsCmd struct {
// contains filtered or unexported fields
}
type ClusterSlot ¶
type ClusterSlot struct { Nodes []ClusterNode Start int64 End int64 }
type ClusterSlotsCmd ¶
type ClusterSlotsCmd struct {
// contains filtered or unexported fields
}
type Cmd ¶
type Cmd struct {
// contains filtered or unexported fields
}
func (*Cmd) Float32Slice ¶
func (*Cmd) Float64Slice ¶
func (*Cmd) Int64Slice ¶
func (*Cmd) StringSlice ¶
func (*Cmd) Uint64Slice ¶
type Cmdable ¶
type Cmdable interface { Cache(ttl time.Duration) CacheCompat Command(ctx context.Context) *CommandsInfoCmd CommandList(ctx context.Context, filter FilterBy) *StringSliceCmd CommandGetKeys(ctx context.Context, commands ...any) *StringSliceCmd CommandGetKeysAndFlags(ctx context.Context, commands ...any) *KeyFlagsCmd ClientGetName(ctx context.Context) *StringCmd Echo(ctx context.Context, message any) *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 ExpireTime(ctx context.Context, key string) *DurationCmd 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 PExpireTime(ctx context.Context, key string) *DurationCmd 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 SortRO(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 any) *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 ...any) *StatusCmd MSetNX(ctx context.Context, values ...any) *BoolCmd Set(ctx context.Context, key string, value any, expiration time.Duration) *StatusCmd SetArgs(ctx context.Context, key string, value any, a SetArgs) *StatusCmd SetEX(ctx context.Context, key string, value any, expiration time.Duration) *StatusCmd SetNX(ctx context.Context, key string, value any, expiration time.Duration) *BoolCmd SetXX(ctx context.Context, key string, value any, 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 BitPosSpan(ctx context.Context, key string, bit int64, start, end int64, span string) *IntCmd BitField(ctx context.Context, key string, args ...any) *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 ...any) *IntCmd HMSet(ctx context.Context, key string, values ...any) *BoolCmd HSetNX(ctx context.Context, key, field string, value any) *BoolCmd HVals(ctx context.Context, key string) *StringSliceCmd HRandField(ctx context.Context, key string, count int64) *StringSliceCmd HRandFieldWithValues(ctx context.Context, key string, count int64) *KeyValueSliceCmd BLPop(ctx context.Context, timeout time.Duration, keys ...string) *StringSliceCmd BLMPop(ctx context.Context, timeout time.Duration, direction string, count int64, keys ...string) *KeyValuesCmd BRPop(ctx context.Context, timeout time.Duration, keys ...string) *StringSliceCmd BRPopLPush(ctx context.Context, source, destination string, timeout time.Duration) *StringCmd // TODO LCS(ctx context.Context, q *LCSQuery) *LCSCmd LIndex(ctx context.Context, key string, index int64) *StringCmd LInsert(ctx context.Context, key, op string, pivot, value any) *IntCmd LInsertBefore(ctx context.Context, key string, pivot, value any) *IntCmd LInsertAfter(ctx context.Context, key string, pivot, value any) *IntCmd LLen(ctx context.Context, key string) *IntCmd LMPop(ctx context.Context, direction string, count int64, keys ...string) *KeyValuesCmd 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 ...any) *IntCmd LPushX(ctx context.Context, key string, values ...any) *IntCmd LRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd LRem(ctx context.Context, key string, count int64, value any) *IntCmd LSet(ctx context.Context, key string, index int64, value any) *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 ...any) *IntCmd RPushX(ctx context.Context, key string, values ...any) *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 ...any) *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 SInterCard(ctx context.Context, limit int64, keys ...string) *IntCmd SInterStore(ctx context.Context, destination string, keys ...string) *IntCmd SIsMember(ctx context.Context, key string, member any) *BoolCmd SMIsMember(ctx context.Context, key string, members ...any) *BoolSliceCmd SMembers(ctx context.Context, key string) *StringSliceCmd SMembersMap(ctx context.Context, key string) *StringStructMapCmd SMove(ctx context.Context, source, destination string, member any) *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 ...any) *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 string, 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 BZMPop(ctx context.Context, timeout time.Duration, order string, count int64, keys ...string) *ZSliceWithKeyCmd ZAdd(ctx context.Context, key string, members ...Z) *IntCmd ZAddLT(ctx context.Context, key string, members ...Z) *IntCmd ZAddGT(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, 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 ZInterCard(ctx context.Context, limit int64, keys ...string) *IntCmd ZInterStore(ctx context.Context, destination string, store ZStore) *IntCmd ZMPop(ctx context.Context, order string, count int64, keys ...string) *ZSliceWithKeyCmd 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 ZRankWithScore(ctx context.Context, key, member string) *RankWithScoreCmd ZRem(ctx context.Context, key string, members ...any) *IntCmd ZRemRangeByRank(ctx context.Context, key string, start, stop int64) *IntCmd ZRemRangeByScore(ctx context.Context, key, 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 ZRevRankWithScore(ctx context.Context, key, member string) *RankWithScoreCmd ZScore(ctx context.Context, key, member string) *FloatCmd ZUnionStore(ctx context.Context, dest string, store ZStore) *IntCmd ZRandMember(ctx context.Context, key string, count int64) *StringSliceCmd ZRandMemberWithScores(ctx context.Context, key string, count int64) *ZSliceCmd ZUnion(ctx context.Context, store ZStore) *StringSliceCmd ZUnionWithScores(ctx context.Context, store ZStore) *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 ...any) *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 // TODO ClientInfo(ctx context.Context) *ClientInfoCmd ClientPause(ctx context.Context, dur time.Duration) *BoolCmd ClientUnpause(ctx context.Context) *BoolCmd ClientID(ctx context.Context) *IntCmd ClientUnblock(ctx context.Context, id int64) *IntCmd ClientUnblockWithError(ctx context.Context, id int64) *IntCmd ConfigGet(ctx context.Context, parameter string) *StringStringMapCmd 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 // TODO SlaveOf(ctx context.Context, host, port string) *StatusCmd // TODO SlowLogGet(ctx context.Context, num int64) *SlowLogCmd 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 ...any) *Cmd EvalSha(ctx context.Context, sha1 string, keys []string, args ...any) *Cmd EvalRO(ctx context.Context, script string, keys []string, args ...any) *Cmd EvalShaRO(ctx context.Context, sha1 string, keys []string, args ...any) *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 FunctionLoad(ctx context.Context, code string) *StringCmd FunctionLoadReplace(ctx context.Context, code string) *StringCmd FunctionDelete(ctx context.Context, libName string) *StringCmd FunctionFlush(ctx context.Context) *StringCmd FunctionKill(ctx context.Context) *StringCmd FunctionFlushAsync(ctx context.Context) *StringCmd FunctionList(ctx context.Context, q FunctionListQuery) *FunctionListCmd FunctionDump(ctx context.Context) *StringCmd FunctionRestore(ctx context.Context, libDump string) *StringCmd // TODO FunctionStats(ctx context.Context) *FunctionStatsCmd FCall(ctx context.Context, function string, keys []string, args ...any) *Cmd FCallRO(ctx context.Context, function string, keys []string, args ...any) *Cmd Publish(ctx context.Context, channel string, message any) *IntCmd SPublish(ctx context.Context, channel string, message any) *IntCmd PubSubChannels(ctx context.Context, pattern string) *StringSliceCmd PubSubNumSub(ctx context.Context, channels ...string) *StringIntMapCmd PubSubNumPat(ctx context.Context) *IntCmd PubSubShardChannels(ctx context.Context, pattern string) *StringSliceCmd PubSubShardNumSub(ctx context.Context, channels ...string) *StringIntMapCmd // TODO ClusterMyShardID(ctx context.Context) *StringCmd ClusterSlots(ctx context.Context) *ClusterSlotsCmd ClusterShards(ctx context.Context) *ClusterShardsCmd // TODO ClusterLinks(ctx context.Context) *ClusterLinksCmd 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, key, store string, q GeoSearchStoreQuery) *IntCmd GeoDist(ctx context.Context, key string, member1, member2, unit string) *FloatCmd GeoHash(ctx context.Context, key string, members ...string) *StringSliceCmd ACLDryRun(ctx context.Context, username string, command ...any) *StringCmd // TODO ModuleLoadex(ctx context.Context, conf *ModuleLoadexConfig) *StringCmd GearsCmdable ProbabilisticCmdable TimeseriesCmdable JSONCmdable }
func NewAdapter ¶
type CommandInfo ¶
type CommandsInfoCmd ¶
type CommandsInfoCmd struct {
// contains filtered or unexported fields
}
type Compat ¶
type Compat struct {
// contains filtered or unexported fields
}
func (*Compat) BFInfoCapacity ¶
func (*Compat) BFInfoExpansion ¶
func (*Compat) BFInfoFilters ¶
func (*Compat) BFInfoItems ¶
func (*Compat) BFInsert ¶
func (c *Compat) BFInsert(ctx context.Context, key string, options *BFInsertOptions, elements ...interface{}) *BoolSliceCmd
func (*Compat) BFLoadChunk ¶
func (*Compat) BFMAdd ¶
func (c *Compat) BFMAdd(ctx context.Context, key string, elements ...interface{}) *BoolSliceCmd
func (*Compat) BFMExists ¶
func (c *Compat) BFMExists(ctx context.Context, key string, elements ...interface{}) *BoolSliceCmd
func (*Compat) BFReserveExpansion ¶
func (*Compat) BFReserveNonScaling ¶
func (*Compat) BFReserveWithArgs ¶
func (*Compat) BFScanDump ¶
func (*Compat) BRPopLPush ¶
func (*Compat) BitPosSpan ¶
func (*Compat) CFInsert ¶
func (c *Compat) CFInsert(ctx context.Context, key string, options *CFInsertOptions, elements ...interface{}) *BoolSliceCmd
func (*Compat) CFInsertNX ¶
func (c *Compat) CFInsertNX(ctx context.Context, key string, options *CFInsertOptions, elements ...interface{}) *IntSliceCmd
func (*Compat) CFLoadChunk ¶
func (*Compat) CFMExists ¶
func (c *Compat) CFMExists(ctx context.Context, key string, elements ...interface{}) *BoolSliceCmd
func (*Compat) CFReserveBucketSize ¶
func (*Compat) CFReserveExpansion ¶
func (*Compat) CFReserveMaxIterations ¶
func (*Compat) CFReserveWithArgs ¶
func (*Compat) CFScanDump ¶
func (*Compat) CMSIncrBy ¶
func (c *Compat) CMSIncrBy(ctx context.Context, key string, elements ...interface{}) *IntSliceCmd
func (*Compat) CMSInitByDim ¶
func (*Compat) CMSInitByProb ¶
func (*Compat) CMSMergeWithWeight ¶
func (*Compat) CMSQuery ¶
func (c *Compat) CMSQuery(ctx context.Context, key string, elements ...interface{}) *IntSliceCmd
func (*Compat) ClientKill ¶
func (*Compat) ClientKillByFilter ¶
func (*Compat) ClientPause ¶
func (*Compat) ClientUnblock ¶
func (*Compat) ClientUnblockWithError ¶
func (*Compat) ClusterAddSlots ¶
func (*Compat) ClusterAddSlotsRange ¶
func (*Compat) ClusterCountFailureReports ¶
func (*Compat) ClusterCountKeysInSlot ¶
func (*Compat) ClusterDelSlots ¶
func (*Compat) ClusterDelSlotsRange ¶
func (*Compat) ClusterForget ¶
func (*Compat) ClusterGetKeysInSlot ¶
func (*Compat) ClusterKeySlot ¶
func (*Compat) ClusterMeet ¶
func (*Compat) ClusterReplicate ¶
func (*Compat) ClusterSaveConfig ¶
func (*Compat) ClusterShards ¶
func (c *Compat) ClusterShards(ctx context.Context) *ClusterShardsCmd
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) CommandGetKeys ¶
func (c *Compat) CommandGetKeys(ctx context.Context, commands ...any) *StringSliceCmd
func (*Compat) CommandGetKeysAndFlags ¶
func (c *Compat) CommandGetKeysAndFlags(ctx context.Context, commands ...any) *KeyFlagsCmd
func (*Compat) CommandList ¶
func (c *Compat) CommandList(ctx context.Context, filter FilterBy) *StringSliceCmd
func (*Compat) ConfigGet ¶
func (c *Compat) ConfigGet(ctx context.Context, parameter string) *StringStringMapCmd
func (*Compat) DebugObject ¶
func (*Compat) ExpireTime ¶
func (c *Compat) ExpireTime(ctx context.Context, key string) *DurationCmd
func (*Compat) FunctionDelete ¶
func (*Compat) FunctionFlushAsync ¶
func (*Compat) FunctionList ¶
func (c *Compat) FunctionList(ctx context.Context, q FunctionListQuery) *FunctionListCmd
func (*Compat) FunctionLoad ¶
func (*Compat) FunctionLoadReplace ¶
func (*Compat) FunctionRestore ¶
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 (*Compat) GetEx ¶
GetEx An expiration of zero removes the TTL associated with the key (i.e. GETEX key persist). Requires Redis >= 6.2.0.
func (*Compat) HGetAll ¶
func (c *Compat) HGetAll(ctx context.Context, key string) *StringStringMapCmd
func (*Compat) HIncrByFloat ¶
func (*Compat) HRandField ¶
func (*Compat) HRandFieldWithValues ¶
func (*Compat) IncrByFloat ¶
func (*Compat) JSONArrAppend ¶
func (c *Compat) JSONArrAppend(ctx context.Context, key, path string, values ...interface{}) *IntSliceCmd
JSONArrAppend adds the provided JSON values to the end of the array at the given path. For more information, see https://redis.io/commands/json.arrappend
func (*Compat) JSONArrIndex ¶
func (c *Compat) JSONArrIndex(ctx context.Context, key, path string, value ...interface{}) *IntSliceCmd
JSONArrIndex searches for the first occurrence of the provided JSON value in the array at the given path. For more information, see https://redis.io/commands/json.arrindex NOTE: value should have the format value start [stop]
func (*Compat) JSONArrIndexWithArgs ¶
func (c *Compat) JSONArrIndexWithArgs(ctx context.Context, key, path string, options *JSONArrIndexArgs, value ...interface{}) *IntSliceCmd
JSONArrIndex searches for the first occurrence of the provided JSON value in the array at the given path. For more information, see https://redis.io/commands/json.arrindex
func (*Compat) JSONArrInsert ¶
func (*Compat) JSONArrLen ¶
func (c *Compat) JSONArrLen(ctx context.Context, key, path string) *IntSliceCmd
func (*Compat) JSONArrPop ¶
func (*Compat) JSONArrTrim ¶
func (c *Compat) JSONArrTrim(ctx context.Context, key, path string) *IntSliceCmd
func (*Compat) JSONArrTrimWithArgs ¶
func (c *Compat) JSONArrTrimWithArgs(ctx context.Context, key, path string, options *JSONArrTrimArgs) *IntSliceCmd
func (*Compat) JSONDebugMemory ¶
func (*Compat) JSONForget ¶
func (*Compat) JSONGetWithArgs ¶
func (*Compat) JSONMSetArgs ¶
func (c *Compat) JSONMSetArgs(ctx context.Context, docs []JSONSetArgs) *StatusCmd
func (*Compat) JSONNumIncrBy ¶
func (*Compat) JSONObjKeys ¶
func (*Compat) JSONObjLen ¶
func (c *Compat) JSONObjLen(ctx context.Context, key, path string) *IntPointerSliceCmd
func (*Compat) JSONSetMode ¶
func (c *Compat) JSONSetMode(ctx context.Context, key, path string, value interface{}, mode string) *StatusCmd
JSONSetMode sets the JSON value at the given path in the given key and allows the mode to be set (the mode value must be "XX" or "NX"). The value must be something that can be marshaled to JSON (using encoding/JSON) unless the argument is a string or []byte when we assume that it can be passed directly as JSON. For more information, see https://redis.io/commands/json.set
func (*Compat) JSONStrAppend ¶
func (c *Compat) JSONStrAppend(ctx context.Context, key, path, value string) *IntPointerSliceCmd
func (*Compat) JSONStrLen ¶
func (c *Compat) JSONStrLen(ctx context.Context, key, path string) *IntPointerSliceCmd
func (*Compat) JSONToggle ¶
func (c *Compat) JSONToggle(ctx context.Context, key, path string) *IntPointerSliceCmd
func (*Compat) JSONType ¶
func (c *Compat) JSONType(ctx context.Context, key, path string) *JSONSliceCmd
func (*Compat) LInsertAfter ¶
func (*Compat) LInsertBefore ¶
func (*Compat) MemoryUsage ¶
func (*Compat) ObjectEncoding ¶
func (*Compat) ObjectIdleTime ¶
func (c *Compat) ObjectIdleTime(ctx context.Context, key string) *DurationCmd
func (*Compat) ObjectRefCount ¶
func (*Compat) PExpireTime ¶
func (c *Compat) PExpireTime(ctx context.Context, key string) *DurationCmd
func (*Compat) PSubscribe ¶ added in v1.0.42
func (*Compat) PubSubChannels ¶
func (c *Compat) PubSubChannels(ctx context.Context, pattern string) *StringSliceCmd
func (*Compat) PubSubNumSub ¶
func (c *Compat) PubSubNumSub(ctx context.Context, channels ...string) *StringIntMapCmd
func (*Compat) PubSubShardChannels ¶
func (c *Compat) PubSubShardChannels(ctx context.Context, pattern string) *StringSliceCmd
func (*Compat) PubSubShardNumSub ¶
func (c *Compat) PubSubShardNumSub(ctx context.Context, channels ...string) *StringIntMapCmd
func (*Compat) RestoreReplace ¶
func (*Compat) SDiffStore ¶
func (*Compat) SInter ¶
func (c *Compat) SInter(ctx context.Context, keys ...string) *StringSliceCmd
func (*Compat) SInterCard ¶
func (*Compat) SInterStore ¶
func (*Compat) SMIsMember ¶
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) SRandMember ¶
func (*Compat) SRandMemberN ¶
func (*Compat) SSubscribe ¶ added in v1.0.42
func (*Compat) SUnion ¶
func (c *Compat) SUnion(ctx context.Context, keys ...string) *StringSliceCmd
func (*Compat) SUnionStore ¶
func (*Compat) ScriptExists ¶
func (c *Compat) ScriptExists(ctx context.Context, hashes ...string) *BoolSliceCmd
func (*Compat) ScriptLoad ¶
func (*Compat) Set ¶
func (c *Compat) Set(ctx context.Context, key string, value any, expiration time.Duration) *StatusCmd
Set key value [expiration]
For no expiration use 0.
For KEEPTTL use -1.
For more options, use SetArgs.
func (*Compat) SortInterfaces ¶
func (*Compat) TDigestAdd ¶
func (*Compat) TDigestByRank ¶
func (*Compat) TDigestByRevRank ¶
func (*Compat) TDigestCDF ¶
func (*Compat) TDigestCreate ¶
func (*Compat) TDigestCreateWithCompression ¶
func (*Compat) TDigestInfo ¶
func (c *Compat) TDigestInfo(ctx context.Context, key string) *TDigestInfoCmd
func (*Compat) TDigestMerge ¶
func (*Compat) TDigestQuantile ¶
func (*Compat) TDigestRank ¶
func (*Compat) TDigestReset ¶
func (*Compat) TDigestRevRank ¶
func (*Compat) TDigestTrimmedMean ¶
func (*Compat) TFCallASYNC ¶
func (*Compat) TFCallASYNCArgs ¶
func (*Compat) TFCallArgs ¶
func (*Compat) TFunctionDelete ¶
func (*Compat) TFunctionList ¶
func (c *Compat) TFunctionList(ctx context.Context) *MapStringInterfaceSliceCmd
func (*Compat) TFunctionListArgs ¶
func (c *Compat) TFunctionListArgs(ctx context.Context, options *TFunctionListOptions) *MapStringInterfaceSliceCmd
func (*Compat) TFunctionLoad ¶
func (*Compat) TFunctionLoadArgs ¶
func (c *Compat) TFunctionLoadArgs(ctx context.Context, lib string, options *TFunctionLoadOptions) *StatusCmd
FIXME: should check nil of options
func (*Compat) TSAdd ¶
func (c *Compat) TSAdd(ctx context.Context, key string, timestamp interface{}, value float64) *IntCmd
TSAdd - Adds one or more observations to a t-digest sketch. For more information - https://redis.io/commands/ts.add/
func (*Compat) TSAddWithArgs ¶
func (c *Compat) TSAddWithArgs(ctx context.Context, key string, timestamp interface{}, value float64, options *TSOptions) *IntCmd
TSAddWithArgs - Adds one or more observations to a t-digest sketch. This function also allows for specifying additional options such as: Retention, ChunkSize, Encoding, DuplicatePolicy and Labels. For more information - https://redis.io/commands/ts.add/
func (*Compat) TSAlter ¶
TSAlter - Alters an existing time-series key with additional options. This function allows for specifying additional options such as: Retention, ChunkSize and DuplicatePolicy. For more information - https://redis.io/commands/ts.alter/
func (*Compat) TSCreate ¶
TSCreate - Creates a new time-series key. For more information - https://redis.io/commands/ts.create/
func (*Compat) TSCreateRule ¶
func (c *Compat) TSCreateRule(ctx context.Context, sourceKey string, destKey string, aggregator Aggregator, bucketDuration int) *StatusCmd
TSCreateRule - Creates a compaction rule from sourceKey to destKey. For more information - https://redis.io/commands/ts.createrule/
func (*Compat) TSCreateRuleWithArgs ¶
func (c *Compat) TSCreateRuleWithArgs(ctx context.Context, sourceKey string, destKey string, aggregator Aggregator, bucketDuration int, options *TSCreateRuleOptions) *StatusCmd
TSCreateRuleWithArgs - Creates a compaction rule from sourceKey to destKey with additional option. This function allows for specifying additional option such as: alignTimestamp. For more information - https://redis.io/commands/ts.createrule/
func (*Compat) TSCreateWithArgs ¶
TSCreateWithArgs - Creates a new time-series key with additional options. This function allows for specifying additional options such as: Retention, ChunkSize, Encoding, DuplicatePolicy and Labels. For more information - https://redis.io/commands/ts.create/
func (*Compat) TSDecrBy ¶
TSDecrBy - Decrements the value of a time-series key by the specified timestamp. For more information - https://redis.io/commands/ts.decrby/ FIXME: timestamp should be subtrahend
func (*Compat) TSDecrByWithArgs ¶
func (c *Compat) TSDecrByWithArgs(ctx context.Context, key string, timestamp float64, options *TSIncrDecrOptions) *IntCmd
TSDecrByWithArgs - Decrements the value of a time-series key by the specified timestamp with additional options. This function allows for specifying additional options such as: Timestamp, Retention, ChunkSize, Uncompressed and Labels. For more information - https://redis.io/commands/ts.decrby/
func (*Compat) TSDel ¶
TSDel - Deletes a range of samples from a time-series key. For more information - https://redis.io/commands/ts.del/
func (*Compat) TSDeleteRule ¶
TSDeleteRule - Deletes a compaction rule from sourceKey to destKey. For more information - https://redis.io/commands/ts.deleterule/
func (*Compat) TSGet ¶
func (c *Compat) TSGet(ctx context.Context, key string) *TSTimestampValueCmd
TSGet - Gets the last sample of a time-series key. For more information - https://redis.io/commands/ts.get/
func (*Compat) TSGetWithArgs ¶
func (c *Compat) TSGetWithArgs(ctx context.Context, key string, options *TSGetOptions) *TSTimestampValueCmd
TSGetWithArgs - Gets the last sample of a time-series key with additional option. This function allows for specifying additional option such as: Latest. For more information - https://redis.io/commands/ts.get/
func (*Compat) TSIncrBy ¶
TSIncrBy - Increments the value of a time-series key by the specified timestamp. For more information - https://redis.io/commands/ts.incrby/ FIXME: timestamp should be addend
func (*Compat) TSIncrByWithArgs ¶
func (c *Compat) TSIncrByWithArgs(ctx context.Context, key string, timestamp float64, options *TSIncrDecrOptions) *IntCmd
TSIncrByWithArgs - Increments the value of a time-series key by the specified timestamp with additional options. This function allows for specifying additional options such as: Timestamp, Retention, ChunkSize, Uncompressed and Labels. For more information - https://redis.io/commands/ts.incrby/ FIXME: timestamp should be addend
func (*Compat) TSInfo ¶
func (c *Compat) TSInfo(ctx context.Context, key string) *MapStringInterfaceCmd
TSInfo - Returns information about a time-series key. For more information - https://redis.io/commands/ts.info/
func (*Compat) TSInfoWithArgs ¶
func (c *Compat) TSInfoWithArgs(ctx context.Context, key string, options *TSInfoOptions) *MapStringInterfaceCmd
TSInfoWithArgs - Returns information about a time-series key with additional option. This function allows for specifying additional option such as: Debug. For more information - https://redis.io/commands/ts.info/
func (*Compat) TSMAdd ¶
func (c *Compat) TSMAdd(ctx context.Context, ktvSlices [][]interface{}) *IntSliceCmd
TSMAdd - Adds multiple samples to multiple time-series keys. For more information - https://redis.io/commands/ts.madd/
func (*Compat) TSMGet ¶
func (c *Compat) TSMGet(ctx context.Context, filters []string) *MapStringSliceInterfaceCmd
TSMGet - Returns the last sample of multiple time-series keys. For more information - https://redis.io/commands/ts.mget/
func (*Compat) TSMGetWithArgs ¶
func (c *Compat) TSMGetWithArgs(ctx context.Context, filters []string, options *TSMGetOptions) *MapStringSliceInterfaceCmd
TSMGetWithArgs - Returns the last sample of multiple time-series keys with additional options. This function allows for specifying additional options such as: Latest, WithLabels and SelectedLabels. For more information - https://redis.io/commands/ts.mget/
func (*Compat) TSMRange ¶
func (c *Compat) TSMRange(ctx context.Context, fromTimestamp int, toTimestamp int, filterExpr []string) *MapStringSliceInterfaceCmd
TSMRange - Returns a range of samples from multiple time-series keys. For more information - https://redis.io/commands/ts.mrange/
func (*Compat) TSMRangeWithArgs ¶
func (c *Compat) TSMRangeWithArgs(ctx context.Context, fromTimestamp int, toTimestamp int, filterExpr []string, options *TSMRangeOptions) *MapStringSliceInterfaceCmd
TSMRangeWithArgs - Returns a range of samples from multiple time-series keys with additional options. This function allows for specifying additional options such as: Latest, FilterByTS, FilterByValue, WithLabels, SelectedLabels, Count, Align, Aggregator, BucketDuration, BucketTimestamp, Empty, GroupByLabel and Reducer. For more information - https://redis.io/commands/ts.mrange/
func (*Compat) TSMRevRange ¶
func (c *Compat) TSMRevRange(ctx context.Context, fromTimestamp int, toTimestamp int, filterExpr []string) *MapStringSliceInterfaceCmd
TSMRevRange - Returns a range of samples from multiple time-series keys in reverse order. For more information - https://redis.io/commands/ts.mrevrange/
func (*Compat) TSMRevRangeWithArgs ¶
func (c *Compat) TSMRevRangeWithArgs(ctx context.Context, fromTimestamp int, toTimestamp int, filterExpr []string, options *TSMRevRangeOptions) *MapStringSliceInterfaceCmd
TSMRevRangeWithArgs - Returns a range of samples from multiple time-series keys in reverse order with additional options. This function allows for specifying additional options such as: Latest, FilterByTS, FilterByValue, WithLabels, SelectedLabels, Count, Align, Aggregator, BucketDuration, BucketTimestamp, Empty, GroupByLabel and Reducer. For more information - https://redis.io/commands/ts.mrevrange/
func (*Compat) TSQueryIndex ¶
func (c *Compat) TSQueryIndex(ctx context.Context, filterExpr []string) *StringSliceCmd
TSQueryIndex - Returns all the keys matching the filter expression. For more information - https://redis.io/commands/ts.queryindex/
func (*Compat) TSRange ¶
func (c *Compat) TSRange(ctx context.Context, key string, fromTimestamp int, toTimestamp int) *TSTimestampValueSliceCmd
TSRange - Returns a range of samples from a time-series key. For more information - https://redis.io/commands/ts.range/
func (*Compat) TSRangeWithArgs ¶
func (c *Compat) TSRangeWithArgs(ctx context.Context, key string, fromTimestamp int, toTimestamp int, options *TSRangeOptions) *TSTimestampValueSliceCmd
TSRangeWithArgs - Returns a range of samples from a time-series key with additional options. This function allows for specifying additional options such as: Latest, FilterByTS, FilterByValue, Count, Align, Aggregator, BucketDuration, BucketTimestamp and Empty. For more information - https://redis.io/commands/ts.range/
func (*Compat) TSRevRange ¶
func (c *Compat) TSRevRange(ctx context.Context, key string, fromTimestamp int, toTimestamp int) *TSTimestampValueSliceCmd
TSRevRange - Returns a range of samples from a time-series key in reverse order. For more information - https://redis.io/commands/ts.revrange/
func (*Compat) TSRevRangeWithArgs ¶
func (c *Compat) TSRevRangeWithArgs(ctx context.Context, key string, fromTimestamp int, toTimestamp int, options *TSRevRangeOptions) *TSTimestampValueSliceCmd
TSRevRangeWithArgs - Returns a range of samples from a time-series key in reverse order with additional options. This function allows for specifying additional options such as: Latest, FilterByTS, FilterByValue, Count, Align, Aggregator, BucketDuration, BucketTimestamp and Empty. For more information - https://redis.io/commands/ts.revrange/
func (*Compat) TopKAdd ¶
func (c *Compat) TopKAdd(ctx context.Context, key string, elements ...interface{}) *StringSliceCmd
func (*Compat) TopKCount ¶
func (c *Compat) TopKCount(ctx context.Context, key string, elements ...interface{}) *IntSliceCmd
func (*Compat) TopKIncrBy ¶
func (c *Compat) TopKIncrBy(ctx context.Context, key string, elements ...interface{}) *StringSliceCmd
func (*Compat) TopKList ¶
func (c *Compat) TopKList(ctx context.Context, key string) *StringSliceCmd
func (*Compat) TopKListWithCount ¶
func (c *Compat) TopKListWithCount(ctx context.Context, key string) *MapStringIntCmd
func (*Compat) TopKQuery ¶
func (c *Compat) TopKQuery(ctx context.Context, key string, elements ...interface{}) *BoolSliceCmd
func (*Compat) TopKReserve ¶
func (*Compat) TopKReserveWithOptions ¶
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) XGroupCreate ¶
func (*Compat) XGroupCreateConsumer ¶
func (*Compat) XGroupCreateMkStream ¶
func (*Compat) XGroupDelConsumer ¶
func (*Compat) XGroupDestroy ¶
func (*Compat) XGroupSetID ¶
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 (*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) 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 (*Compat) XTrimMaxLen ¶
XTrimMaxLen No `~` rules are used, `limit` cannot be used. cmd: XTRIM key MAXLEN maxLen
func (*Compat) XTrimMaxLenApprox ¶
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 ¶
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) ZAddArgsIncr ¶
func (*Compat) ZDiffStore ¶
func (*Compat) ZDiffWithScores ¶
func (*Compat) ZInterCard ¶
func (*Compat) ZInterStore ¶
func (*Compat) ZInterWithScores ¶
func (*Compat) ZRandMember ¶
func (*Compat) ZRandMemberWithScores ¶
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 (*Compat) ZRangeByScore ¶
func (*Compat) ZRangeByScoreWithScores ¶
func (*Compat) ZRangeStore ¶
func (*Compat) ZRangeWithScores ¶
func (*Compat) ZRankWithScore ¶
func (c *Compat) ZRankWithScore(ctx context.Context, key, member string) *RankWithScoreCmd
func (*Compat) ZRemRangeByLex ¶
func (*Compat) ZRemRangeByRank ¶
func (*Compat) ZRemRangeByScore ¶
func (*Compat) ZRevRangeByLex ¶
func (*Compat) ZRevRangeByScore ¶
func (*Compat) ZRevRangeByScoreWithScores ¶
func (*Compat) ZRevRangeWithScores ¶
func (*Compat) ZRevRankWithScore ¶
func (c *Compat) ZRevRankWithScore(ctx context.Context, key, member string) *RankWithScoreCmd
func (*Compat) ZUnionStore ¶
type DurationCmd ¶
type DurationCmd struct {
// contains filtered or unexported fields
}
type FloatSliceCmd ¶
type FloatSliceCmd struct {
// contains filtered or unexported fields
}
type FunctionListCmd ¶
type FunctionListCmd struct {
// contains filtered or unexported fields
}
func (*FunctionListCmd) First ¶
func (cmd *FunctionListCmd) First() (*Library, error)
type FunctionListQuery ¶
type GearsCmdable ¶
type GearsCmdable interface { TFunctionLoad(ctx context.Context, lib string) *StatusCmd TFunctionLoadArgs(ctx context.Context, lib string, options *TFunctionLoadOptions) *StatusCmd TFunctionDelete(ctx context.Context, libName string) *StatusCmd TFunctionList(ctx context.Context) *MapStringInterfaceSliceCmd TFunctionListArgs(ctx context.Context, options *TFunctionListOptions) *MapStringInterfaceSliceCmd TFCall(ctx context.Context, libName string, funcName string, numKeys int) *Cmd TFCallArgs(ctx context.Context, libName string, funcName string, numKeys int, options *TFCallOptions) *Cmd TFCallASYNC(ctx context.Context, libName string, funcName string, numKeys int) *Cmd TFCallASYNCArgs(ctx context.Context, libName string, funcName string, numKeys int, options *TFCallOptions) *Cmd }
Align with go-redis https://github.com/redis/go-redis/blob/f994ff1cd96299a5c8029ae3403af7b17ef06e8a/gears_commands.go#L9-L19
type GeoLocation ¶
type GeoLocation = rueidis.GeoLocation
type GeoLocationCmd ¶
type GeoLocationCmd struct {
// contains filtered or unexported fields
}
type GeoRadiusQuery ¶
type GeoRadiusQuery struct { Unit string Sort string Store string StoreDist string Radius float64 Count int64 WithCoord bool WithDist bool WithGeoHash bool }
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 RadiusUnit string BoxUnit string Sort string Longitude float64 Latitude float64 Radius float64 BoxWidth float64 BoxHeight float64 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 IntPointerSliceCmd ¶
type IntPointerSliceCmd struct {
// contains filtered or unexported fields
}
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 JSONArrIndexArgs ¶
type JSONArrTrimArgs ¶
type JSONCmd ¶
type JSONCmd struct {
// contains filtered or unexported fields
}
type JSONCmdable ¶
type JSONCmdable interface { JSONArrAppend(ctx context.Context, key, path string, values ...interface{}) *IntSliceCmd JSONArrIndex(ctx context.Context, key, path string, value ...interface{}) *IntSliceCmd JSONArrIndexWithArgs(ctx context.Context, key, path string, options *JSONArrIndexArgs, value ...interface{}) *IntSliceCmd JSONArrInsert(ctx context.Context, key, path string, index int64, values ...interface{}) *IntSliceCmd JSONArrLen(ctx context.Context, key, path string) *IntSliceCmd JSONArrPop(ctx context.Context, key, path string, index int) *StringSliceCmd JSONArrTrim(ctx context.Context, key, path string) *IntSliceCmd JSONArrTrimWithArgs(ctx context.Context, key, path string, options *JSONArrTrimArgs) *IntSliceCmd JSONClear(ctx context.Context, key, path string) *IntCmd JSONDebugMemory(ctx context.Context, key, path string) *IntCmd JSONDel(ctx context.Context, key, path string) *IntCmd JSONForget(ctx context.Context, key, path string) *IntCmd JSONGet(ctx context.Context, key string, paths ...string) *JSONCmd JSONGetWithArgs(ctx context.Context, key string, options *JSONGetArgs, paths ...string) *JSONCmd JSONMerge(ctx context.Context, key, path string, value string) *StatusCmd JSONMSetArgs(ctx context.Context, docs []JSONSetArgs) *StatusCmd JSONMSet(ctx context.Context, params ...interface{}) *StatusCmd JSONMGet(ctx context.Context, path string, keys ...string) *JSONSliceCmd JSONNumIncrBy(ctx context.Context, key, path string, value float64) *JSONCmd JSONObjKeys(ctx context.Context, key, path string) *SliceCmd JSONObjLen(ctx context.Context, key, path string) *IntPointerSliceCmd JSONSet(ctx context.Context, key, path string, value interface{}) *StatusCmd JSONSetMode(ctx context.Context, key, path string, value interface{}, mode string) *StatusCmd JSONStrAppend(ctx context.Context, key, path, value string) *IntPointerSliceCmd JSONStrLen(ctx context.Context, key, path string) *IntPointerSliceCmd JSONToggle(ctx context.Context, key, path string) *IntPointerSliceCmd JSONType(ctx context.Context, key, path string) *JSONSliceCmd }
type JSONGetArgs ¶
type JSONSetArgs ¶
type JSONSliceCmd ¶
type JSONSliceCmd struct {
// contains filtered or unexported fields
}
type KeyFlagsCmd ¶
type KeyFlagsCmd struct {
// contains filtered or unexported fields
}
type KeyValueSliceCmd ¶
type KeyValueSliceCmd struct {
// contains filtered or unexported fields
}
type KeyValuesCmd ¶
type KeyValuesCmd struct {
// contains filtered or unexported fields
}
func (*KeyValuesCmd) Err ¶
func (cmd *KeyValuesCmd) Err() error
func (*KeyValuesCmd) SetErr ¶
func (cmd *KeyValuesCmd) SetErr(err error)
func (*KeyValuesCmd) SetVal ¶
func (cmd *KeyValuesCmd) SetVal(key string, val []string)
func (*KeyValuesCmd) Val ¶
func (cmd *KeyValuesCmd) Val() (string, []string)
type MapStringIntCmd ¶
type MapStringIntCmd struct {
// contains filtered or unexported fields
}
type MapStringInterfaceCmd ¶
type MapStringInterfaceCmd struct {
// contains filtered or unexported fields
}
type MapStringInterfaceSliceCmd ¶
type MapStringInterfaceSliceCmd struct {
// contains filtered or unexported fields
}
func (*MapStringInterfaceSliceCmd) Result ¶
func (cmd *MapStringInterfaceSliceCmd) Result() (T, error)
type MapStringSliceInterfaceCmd ¶
type MapStringSliceInterfaceCmd struct {
// contains filtered or unexported fields
}
func (*MapStringSliceInterfaceCmd) Result ¶
func (cmd *MapStringSliceInterfaceCmd) Result() (T, error)
type Message ¶ added in v1.0.42
Message received as result of a PUBLISH command issued by another client.
type ProbabilisticCmdable ¶
type ProbabilisticCmdable interface { BFAdd(ctx context.Context, key string, element interface{}) *BoolCmd BFCard(ctx context.Context, key string) *IntCmd BFExists(ctx context.Context, key string, element interface{}) *BoolCmd BFInfo(ctx context.Context, key string) *BFInfoCmd BFInfoArg(ctx context.Context, key, option string) *BFInfoCmd BFInfoCapacity(ctx context.Context, key string) *BFInfoCmd BFInfoSize(ctx context.Context, key string) *BFInfoCmd BFInfoFilters(ctx context.Context, key string) *BFInfoCmd BFInfoItems(ctx context.Context, key string) *BFInfoCmd BFInfoExpansion(ctx context.Context, key string) *BFInfoCmd BFInsert(ctx context.Context, key string, options *BFInsertOptions, elements ...interface{}) *BoolSliceCmd BFMAdd(ctx context.Context, key string, elements ...interface{}) *BoolSliceCmd BFMExists(ctx context.Context, key string, elements ...interface{}) *BoolSliceCmd BFReserve(ctx context.Context, key string, errorRate float64, capacity int64) *StatusCmd BFReserveExpansion(ctx context.Context, key string, errorRate float64, capacity, expansion int64) *StatusCmd BFReserveNonScaling(ctx context.Context, key string, errorRate float64, capacity int64) *StatusCmd BFReserveWithArgs(ctx context.Context, key string, options *BFReserveOptions) *StatusCmd BFScanDump(ctx context.Context, key string, iterator int64) *ScanDumpCmd BFLoadChunk(ctx context.Context, key string, iterator int64, data interface{}) *StatusCmd CFAdd(ctx context.Context, key string, element interface{}) *BoolCmd CFAddNX(ctx context.Context, key string, element interface{}) *BoolCmd CFCount(ctx context.Context, key string, element interface{}) *IntCmd CFDel(ctx context.Context, key string, element interface{}) *BoolCmd CFExists(ctx context.Context, key string, element interface{}) *BoolCmd CFInfo(ctx context.Context, key string) *CFInfoCmd CFInsert(ctx context.Context, key string, options *CFInsertOptions, elements ...interface{}) *BoolSliceCmd CFInsertNX(ctx context.Context, key string, options *CFInsertOptions, elements ...interface{}) *IntSliceCmd CFMExists(ctx context.Context, key string, elements ...interface{}) *BoolSliceCmd CFReserve(ctx context.Context, key string, capacity int64) *StatusCmd CFReserveWithArgs(ctx context.Context, key string, options *CFReserveOptions) *StatusCmd CFReserveExpansion(ctx context.Context, key string, capacity int64, expansion int64) *StatusCmd CFReserveBucketSize(ctx context.Context, key string, capacity int64, bucketsize int64) *StatusCmd CFReserveMaxIterations(ctx context.Context, key string, capacity int64, maxiterations int64) *StatusCmd CFScanDump(ctx context.Context, key string, iterator int64) *ScanDumpCmd CFLoadChunk(ctx context.Context, key string, iterator int64, data interface{}) *StatusCmd CMSIncrBy(ctx context.Context, key string, elements ...interface{}) *IntSliceCmd CMSInfo(ctx context.Context, key string) *CMSInfoCmd CMSInitByDim(ctx context.Context, key string, width, height int64) *StatusCmd CMSInitByProb(ctx context.Context, key string, errorRate, probability float64) *StatusCmd CMSMerge(ctx context.Context, destKey string, sourceKeys ...string) *StatusCmd CMSMergeWithWeight(ctx context.Context, destKey string, sourceKeys map[string]int64) *StatusCmd CMSQuery(ctx context.Context, key string, elements ...interface{}) *IntSliceCmd TopKAdd(ctx context.Context, key string, elements ...interface{}) *StringSliceCmd TopKCount(ctx context.Context, key string, elements ...interface{}) *IntSliceCmd TopKIncrBy(ctx context.Context, key string, elements ...interface{}) *StringSliceCmd TopKInfo(ctx context.Context, key string) *TopKInfoCmd TopKList(ctx context.Context, key string) *StringSliceCmd TopKListWithCount(ctx context.Context, key string) *MapStringIntCmd TopKQuery(ctx context.Context, key string, elements ...interface{}) *BoolSliceCmd TopKReserve(ctx context.Context, key string, k int64) *StatusCmd TopKReserveWithOptions(ctx context.Context, key string, k int64, width, depth int64, decay float64) *StatusCmd TDigestAdd(ctx context.Context, key string, elements ...float64) *StatusCmd TDigestByRank(ctx context.Context, key string, rank ...uint64) *FloatSliceCmd TDigestByRevRank(ctx context.Context, key string, rank ...uint64) *FloatSliceCmd TDigestCDF(ctx context.Context, key string, elements ...float64) *FloatSliceCmd TDigestCreate(ctx context.Context, key string) *StatusCmd TDigestCreateWithCompression(ctx context.Context, key string, compression int64) *StatusCmd TDigestInfo(ctx context.Context, key string) *TDigestInfoCmd TDigestMax(ctx context.Context, key string) *FloatCmd TDigestMin(ctx context.Context, key string) *FloatCmd TDigestMerge(ctx context.Context, destKey string, options *TDigestMergeOptions, sourceKeys ...string) *StatusCmd TDigestQuantile(ctx context.Context, key string, elements ...float64) *FloatSliceCmd TDigestRank(ctx context.Context, key string, values ...float64) *IntSliceCmd TDigestReset(ctx context.Context, key string) *StatusCmd TDigestRevRank(ctx context.Context, key string, values ...float64) *IntSliceCmd TDigestTrimmedMean(ctx context.Context, key string, lowCutQuantile, highCutQuantile float64) *FloatCmd Subscribe(ctx context.Context, channels ...string) PubSub PSubscribe(ctx context.Context, patterns ...string) PubSub SSubscribe(ctx context.Context, channels ...string) PubSub }
https://github.com/redis/go-redis/blob/af4872cbd0de349855ce3f0978929c2f56eb995f/probabilistic.go#L10
type PubSub ¶ added in v1.0.42
type PubSub interface { Close() error Subscribe(ctx context.Context, channels ...string) error PSubscribe(ctx context.Context, patterns ...string) error SSubscribe(ctx context.Context, channels ...string) error Unsubscribe(ctx context.Context, channels ...string) error PUnsubscribe(ctx context.Context, patterns ...string) error SUnsubscribe(ctx context.Context, channels ...string) error Ping(ctx context.Context, payload ...string) error ReceiveTimeout(ctx context.Context, timeout time.Duration) (any, error) Receive(ctx context.Context) (any, error) ReceiveMessage(ctx context.Context) (*Message, error) Channel(opts ...ChannelOption) <-chan *Message ChannelWithSubscriptions(opts ...ChannelOption) <-chan any String() string }
type RankWithScoreCmd ¶
type RankWithScoreCmd struct {
// contains filtered or unexported fields
}
type ScanDumpCmd ¶
type ScanDumpCmd struct {
// contains filtered or unexported fields
}
type Scanner ¶
Scanner is the interface implemented by themselves, which will override the decoding behavior of decoderFunc.
type SliceCmd ¶
type SliceCmd struct {
// contains filtered or unexported fields
}
type StringIntMapCmd ¶
type StringIntMapCmd struct {
// contains filtered or unexported fields
}
type StringSliceCmd ¶
type StringSliceCmd struct {
// contains filtered or unexported fields
}
type StringStringMapCmd ¶
type StringStringMapCmd struct {
// contains filtered or unexported fields
}
func (*StringStringMapCmd) Scan ¶
func (cmd *StringStringMapCmd) Scan(dest interface{}) error
Scan scans the results from the map into a destination struct. The map keys are matched in the Redis struct fields by the `redis:"field"` tag.
type StringStructMapCmd ¶
type StringStructMapCmd struct {
// contains filtered or unexported fields
}
type StructValue ¶
type StructValue struct {
// contains filtered or unexported fields
}
func Struct ¶
func Struct(dst interface{}) (StructValue, error)
type Subscription ¶ added in v1.0.42
type Subscription struct { // Can be "subscribe", "unsubscribe", "psubscribe" or "punsubscribe". Kind string // Channel name we have subscribed to. Channel string // Number of channels we are currently subscribed to. Count int }
Subscription received after a successful subscription to channel.
func (*Subscription) String ¶ added in v1.0.42
func (m *Subscription) String() string
type TDigestInfo ¶
type TDigestInfo struct { Compression int64 `redis:"Compression"` Capacity int64 `redis:"Capacity"` MergedNodes int64 `redis:"Merged nodes"` UnmergedNodes int64 `redis:"UnmergedNodes"` MergedWeight int64 `redis:"MergedWeight"` UnmergedWeight int64 `redis:"Unmerged weight"` Observations int64 `redis:"Observations"` TotalCompressions int64 `redis:"Total compressions"` MemoryUsage int64 `redis:"Memory usage"` }
type TDigestInfoCmd ¶
type TDigestInfoCmd struct {
// contains filtered or unexported fields
}
type TDigestMergeOptions ¶
type TFCallOptions ¶
type TFunctionListOptions ¶
type TFunctionLoadOptions ¶
type TSAlterOptions ¶
type TSCreateRuleOptions ¶
type TSCreateRuleOptions struct {
// contains filtered or unexported fields
}
type TSGetOptions ¶
type TSGetOptions struct {
Latest bool
}
type TSIncrDecrOptions ¶
type TSInfoOptions ¶
type TSInfoOptions struct {
Debug bool
}
type TSMGetOptions ¶
type TSMRangeOptions ¶
type TSMRevRangeOptions ¶
type TSRangeOptions ¶
type TSRevRangeOptions ¶
type TSTimestampValue ¶
type TSTimestampValueCmd ¶
type TSTimestampValueCmd struct {
// contains filtered or unexported fields
}
type TSTimestampValueSliceCmd ¶
type TSTimestampValueSliceCmd struct {
// contains filtered or unexported fields
}
type TimeseriesCmdable ¶
type TimeseriesCmdable interface { TSAdd(ctx context.Context, key string, timestamp interface{}, value float64) *IntCmd TSAddWithArgs(ctx context.Context, key string, timestamp interface{}, value float64, options *TSOptions) *IntCmd TSCreate(ctx context.Context, key string) *StatusCmd TSCreateWithArgs(ctx context.Context, key string, options *TSOptions) *StatusCmd TSAlter(ctx context.Context, key string, options *TSAlterOptions) *StatusCmd TSCreateRule(ctx context.Context, sourceKey string, destKey string, aggregator Aggregator, bucketDuration int) *StatusCmd TSCreateRuleWithArgs(ctx context.Context, sourceKey string, destKey string, aggregator Aggregator, bucketDuration int, options *TSCreateRuleOptions) *StatusCmd TSIncrBy(ctx context.Context, Key string, timestamp float64) *IntCmd TSIncrByWithArgs(ctx context.Context, key string, timestamp float64, options *TSIncrDecrOptions) *IntCmd TSDecrBy(ctx context.Context, Key string, timestamp float64) *IntCmd TSDecrByWithArgs(ctx context.Context, key string, timestamp float64, options *TSIncrDecrOptions) *IntCmd TSDel(ctx context.Context, Key string, fromTimestamp int, toTimestamp int) *IntCmd TSDeleteRule(ctx context.Context, sourceKey string, destKey string) *StatusCmd TSGet(ctx context.Context, key string) *TSTimestampValueCmd TSGetWithArgs(ctx context.Context, key string, options *TSGetOptions) *TSTimestampValueCmd TSInfo(ctx context.Context, key string) *MapStringInterfaceCmd TSInfoWithArgs(ctx context.Context, key string, options *TSInfoOptions) *MapStringInterfaceCmd TSMAdd(ctx context.Context, ktvSlices [][]interface{}) *IntSliceCmd TSQueryIndex(ctx context.Context, filterExpr []string) *StringSliceCmd TSRevRange(ctx context.Context, key string, fromTimestamp int, toTimestamp int) *TSTimestampValueSliceCmd TSRevRangeWithArgs(ctx context.Context, key string, fromTimestamp int, toTimestamp int, options *TSRevRangeOptions) *TSTimestampValueSliceCmd TSRange(ctx context.Context, key string, fromTimestamp int, toTimestamp int) *TSTimestampValueSliceCmd TSRangeWithArgs(ctx context.Context, key string, fromTimestamp int, toTimestamp int, options *TSRangeOptions) *TSTimestampValueSliceCmd TSMRange(ctx context.Context, fromTimestamp int, toTimestamp int, filterExpr []string) *MapStringSliceInterfaceCmd TSMRangeWithArgs(ctx context.Context, fromTimestamp int, toTimestamp int, filterExpr []string, options *TSMRangeOptions) *MapStringSliceInterfaceCmd TSMRevRange(ctx context.Context, fromTimestamp int, toTimestamp int, filterExpr []string) *MapStringSliceInterfaceCmd TSMRevRangeWithArgs(ctx context.Context, fromTimestamp int, toTimestamp int, filterExpr []string, options *TSMRevRangeOptions) *MapStringSliceInterfaceCmd TSMGet(ctx context.Context, filters []string) *MapStringSliceInterfaceCmd TSMGetWithArgs(ctx context.Context, filters []string, options *TSMGetOptions) *MapStringSliceInterfaceCmd }
type TopKInfoCmd ¶
type TopKInfoCmd struct {
// contains filtered or unexported fields
}
type XAddArgs ¶
type XAddArgs struct { Values any Stream string MinID string ID string MaxLen int64 Limit int64 NoMkStream bool Approx bool }
Note: MaxLen/MaxLenApprox and MinID are in conflict, only one of them can be used.
type XAutoClaimArgs ¶
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 XInfoConsumersCmd ¶
type XInfoConsumersCmd struct {
// contains filtered or unexported fields
}
type XInfoGroup ¶
type XInfoGroupsCmd ¶
type XInfoGroupsCmd struct {
// contains filtered or unexported fields
}
type XInfoStream ¶
type XInfoStreamCmd ¶
type XInfoStreamCmd struct {
// contains filtered or unexported fields
}
type XInfoStreamConsumer ¶
type XInfoStreamConsumer struct { SeenTime time.Time Name string Pending []XInfoStreamConsumerPending PelCount int64 }
type XInfoStreamFull ¶
type XInfoStreamFullCmd ¶
type XInfoStreamFullCmd struct {
// contains filtered or unexported fields
}
type XInfoStreamGroup ¶
type XInfoStreamGroup struct { Name string LastDeliveredID string Pending []XInfoStreamGroupPending Consumers []XInfoStreamConsumer EntriesRead int64 Lag int64 PelCount int64 }
type XInfoStreamGroupPending ¶
type XMessageSliceCmd ¶
type XMessageSliceCmd struct {
// contains filtered or unexported fields
}
type XPendingCmd ¶
type XPendingCmd struct {
// contains filtered or unexported fields
}
type XPendingExt ¶
type XPendingExtArgs ¶
type XPendingExtCmd ¶
type XPendingExtCmd struct {
// contains filtered or unexported fields
}
type XReadGroupArgs ¶
type XStreamSliceCmd ¶
type XStreamSliceCmd struct {
// contains filtered or unexported fields
}
type ZRangeArgs ¶
type ZRangeArgs struct { Start any Stop any Key string Offset int64 Count int64 ByScore bool ByLex bool Rev bool }
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 ZSliceWithKeyCmd ¶
type ZSliceWithKeyCmd struct {
// contains filtered or unexported fields
}
func (*ZSliceWithKeyCmd) Err ¶
func (cmd *ZSliceWithKeyCmd) Err() error
func (*ZSliceWithKeyCmd) SetErr ¶
func (cmd *ZSliceWithKeyCmd) SetErr(err error)
func (*ZSliceWithKeyCmd) SetVal ¶
func (cmd *ZSliceWithKeyCmd) SetVal(key string, val []Z)
func (*ZSliceWithKeyCmd) Val ¶
func (cmd *ZSliceWithKeyCmd) Val() (string, []Z)
type ZWithKey ¶
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
}