Versions in this module Expand all Collapse all v0 v0.1.12 Nov 9, 2022 v0.1.11 Sep 19, 2022 v0.1.10 Sep 19, 2022 v0.1.9 Sep 13, 2022 v0.1.8 Aug 31, 2022 v0.1.7 Aug 26, 2022 v0.1.6 Aug 25, 2022 v0.1.5 Aug 24, 2022 v0.1.4 Aug 12, 2022 Changes in this version type Cmdable + ZRandMemberWithScores func(ctx context.Context, key string, count int64) *ZSliceCmd type Compat + func (c *Compat) ZRandMemberWithScores(ctx context.Context, key string, count int64) *ZSliceCmd v0.1.3 Aug 2, 2022 v0.1.2 Aug 2, 2022 v0.1.1 Aug 2, 2022 v0.1.0 Jul 26, 2022 v0.0.66 Jul 26, 2022 Changes in this version + const KeepTTL + type BitCount struct + End int64 + Start int64 + type BitField struct + Get *BitFieldArg + IncrBy *BitFieldArg + Increment int64 + Overflow string + Set *BitFieldArg + type BitFieldArg struct + Encoding string + Offset int64 + type BoolCmd struct + func (cmd *BoolCmd) Err() error + func (cmd *BoolCmd) Result() (bool, error) + func (cmd *BoolCmd) SetErr(err error) + func (cmd *BoolCmd) SetVal(val bool) + func (cmd *BoolCmd) Val() bool + type BoolSliceCmd struct + func (cmd *BoolSliceCmd) Err() error + func (cmd *BoolSliceCmd) Result() ([]bool, error) + func (cmd *BoolSliceCmd) SetErr(err error) + func (cmd *BoolSliceCmd) SetVal(val []bool) + func (cmd *BoolSliceCmd) Val() []bool + type CacheCompat struct + 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) 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) 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 interface{}) *BoolCmd + func (c CacheCompat) SMIsMember(ctx context.Context, key string, members ...interface{}) *BoolSliceCmd + func (c CacheCompat) SMembers(ctx context.Context, key string) *StringSliceCmd + func (c CacheCompat) Sort(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) 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 string, 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) 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) ZScore(ctx context.Context, key, member string) *FloatCmd + type ClusterNode struct + Addr string + ID string + type ClusterSlot struct + End int64 + Nodes []ClusterNode + Start int64 + type ClusterSlotsCmd struct + func (cmd *ClusterSlotsCmd) Err() error + func (cmd *ClusterSlotsCmd) Result() ([]ClusterSlot, error) + func (cmd *ClusterSlotsCmd) SetErr(err error) + func (cmd *ClusterSlotsCmd) SetVal(val []ClusterSlot) + func (cmd *ClusterSlotsCmd) Val() []ClusterSlot + type Cmd struct + 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() (interface{}, error) + func (cmd *Cmd) SetErr(err error) + func (cmd *Cmd) SetVal(val interface{}) + func (cmd *Cmd) Slice() ([]interface{}, 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() interface{} + type Cmdable interface + Append func(ctx context.Context, key, value string) *IntCmd + BLMove func(ctx context.Context, source, destination, srcpos, destpos string, ...) *StringCmd + BLPop func(ctx context.Context, timeout time.Duration, keys ...string) *StringSliceCmd + BRPop func(ctx context.Context, timeout time.Duration, keys ...string) *StringSliceCmd + BRPopLPush func(ctx context.Context, source, destination string, timeout time.Duration) *StringCmd + BZPopMax func(ctx context.Context, timeout time.Duration, keys ...string) *ZWithKeyCmd + BZPopMin func(ctx context.Context, timeout time.Duration, keys ...string) *ZWithKeyCmd + BgRewriteAOF func(ctx context.Context) *StatusCmd + BgSave func(ctx context.Context) *StatusCmd + BitCount func(ctx context.Context, key string, bitCount *BitCount) *IntCmd + BitField func(ctx context.Context, key string, args ...interface{}) *IntSliceCmd + BitOpAnd func(ctx context.Context, destKey string, keys ...string) *IntCmd + BitOpNot func(ctx context.Context, destKey string, key string) *IntCmd + BitOpOr func(ctx context.Context, destKey string, keys ...string) *IntCmd + BitOpXor func(ctx context.Context, destKey string, keys ...string) *IntCmd + BitPos func(ctx context.Context, key string, bit int64, pos ...int64) *IntCmd + Cache func(ttl time.Duration) CacheCompat + ClientGetName func(ctx context.Context) *StringCmd + ClientID func(ctx context.Context) *IntCmd + ClientKill func(ctx context.Context, ipPort string) *StatusCmd + ClientKillByFilter func(ctx context.Context, keys ...string) *IntCmd + ClientList func(ctx context.Context) *StringCmd + ClientPause func(ctx context.Context, dur time.Duration) *BoolCmd + ClientUnpause func(ctx context.Context) *BoolCmd + ClusterAddSlots func(ctx context.Context, slots ...int64) *StatusCmd + ClusterAddSlotsRange func(ctx context.Context, min, max int64) *StatusCmd + ClusterCountFailureReports func(ctx context.Context, nodeID string) *IntCmd + ClusterCountKeysInSlot func(ctx context.Context, slot int64) *IntCmd + ClusterDelSlots func(ctx context.Context, slots ...int64) *StatusCmd + ClusterDelSlotsRange func(ctx context.Context, min, max int64) *StatusCmd + ClusterFailover func(ctx context.Context) *StatusCmd + ClusterForget func(ctx context.Context, nodeID string) *StatusCmd + ClusterGetKeysInSlot func(ctx context.Context, slot int64, count int64) *StringSliceCmd + ClusterInfo func(ctx context.Context) *StringCmd + ClusterKeySlot func(ctx context.Context, key string) *IntCmd + ClusterMeet func(ctx context.Context, host string, port int64) *StatusCmd + ClusterNodes func(ctx context.Context) *StringCmd + ClusterReplicate func(ctx context.Context, nodeID string) *StatusCmd + ClusterResetHard func(ctx context.Context) *StatusCmd + ClusterResetSoft func(ctx context.Context) *StatusCmd + ClusterSaveConfig func(ctx context.Context) *StatusCmd + ClusterSlaves func(ctx context.Context, nodeID string) *StringSliceCmd + ClusterSlots func(ctx context.Context) *ClusterSlotsCmd + Command func(ctx context.Context) *CommandsInfoCmd + ConfigGet func(ctx context.Context, parameter string) *SliceCmd + ConfigResetStat func(ctx context.Context) *StatusCmd + ConfigRewrite func(ctx context.Context) *StatusCmd + ConfigSet func(ctx context.Context, parameter, value string) *StatusCmd + Copy func(ctx context.Context, sourceKey string, destKey string, db int64, replace bool) *IntCmd + DBSize func(ctx context.Context) *IntCmd + DebugObject func(ctx context.Context, key string) *StringCmd + Decr func(ctx context.Context, key string) *IntCmd + DecrBy func(ctx context.Context, key string, decrement int64) *IntCmd + Del func(ctx context.Context, keys ...string) *IntCmd + Dump func(ctx context.Context, key string) *StringCmd + Echo func(ctx context.Context, message interface{}) *StringCmd + Eval func(ctx context.Context, script string, keys []string, args ...interface{}) *Cmd + EvalSha func(ctx context.Context, sha1 string, keys []string, args ...interface{}) *Cmd + Exists func(ctx context.Context, keys ...string) *IntCmd + Expire func(ctx context.Context, key string, expiration time.Duration) *BoolCmd + ExpireAt func(ctx context.Context, key string, tm time.Time) *BoolCmd + ExpireGT func(ctx context.Context, key string, expiration time.Duration) *BoolCmd + ExpireLT func(ctx context.Context, key string, expiration time.Duration) *BoolCmd + ExpireNX func(ctx context.Context, key string, expiration time.Duration) *BoolCmd + ExpireXX func(ctx context.Context, key string, expiration time.Duration) *BoolCmd + FlushAll func(ctx context.Context) *StatusCmd + FlushAllAsync func(ctx context.Context) *StatusCmd + FlushDB func(ctx context.Context) *StatusCmd + FlushDBAsync func(ctx context.Context) *StatusCmd + GeoAdd func(ctx context.Context, key string, geoLocation ...GeoLocation) *IntCmd + GeoDist func(ctx context.Context, key, member1, member2, unit string) *FloatCmd + GeoHash func(ctx context.Context, key string, members ...string) *StringSliceCmd + GeoPos func(ctx context.Context, key string, members ...string) *GeoPosCmd + GeoRadius func(ctx context.Context, key string, longitude, latitude float64, ...) *GeoLocationCmd + GeoRadiusByMember func(ctx context.Context, key, member string, query GeoRadiusQuery) *GeoLocationCmd + GeoRadiusByMemberStore func(ctx context.Context, key, member string, query GeoRadiusQuery) *IntCmd + GeoRadiusStore func(ctx context.Context, key string, longitude, latitude float64, ...) *IntCmd + GeoSearch func(ctx context.Context, key string, q GeoSearchQuery) *StringSliceCmd + GeoSearchLocation func(ctx context.Context, key string, q GeoSearchLocationQuery) *GeoLocationCmd + GeoSearchStore func(ctx context.Context, src, dest string, q GeoSearchStoreQuery) *IntCmd + Get func(ctx context.Context, key string) *StringCmd + GetBit func(ctx context.Context, key string, offset int64) *IntCmd + GetDel func(ctx context.Context, key string) *StringCmd + GetEx func(ctx context.Context, key string, expiration time.Duration) *StringCmd + GetRange func(ctx context.Context, key string, start, end int64) *StringCmd + GetSet func(ctx context.Context, key string, value interface{}) *StringCmd + HDel func(ctx context.Context, key string, fields ...string) *IntCmd + HExists func(ctx context.Context, key, field string) *BoolCmd + HGet func(ctx context.Context, key, field string) *StringCmd + HGetAll func(ctx context.Context, key string) *StringStringMapCmd + HIncrBy func(ctx context.Context, key, field string, incr int64) *IntCmd + HIncrByFloat func(ctx context.Context, key, field string, incr float64) *FloatCmd + HKeys func(ctx context.Context, key string) *StringSliceCmd + HLen func(ctx context.Context, key string) *IntCmd + HMGet func(ctx context.Context, key string, fields ...string) *SliceCmd + HMSet func(ctx context.Context, key string, values ...interface{}) *BoolCmd + HRandField func(ctx context.Context, key string, count int64, withValues bool) *StringSliceCmd + HScan func(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd + HSet func(ctx context.Context, key string, values ...interface{}) *IntCmd + HSetNX func(ctx context.Context, key, field string, value interface{}) *BoolCmd + HVals func(ctx context.Context, key string) *StringSliceCmd + Incr func(ctx context.Context, key string) *IntCmd + IncrBy func(ctx context.Context, key string, value int64) *IntCmd + IncrByFloat func(ctx context.Context, key string, value float64) *FloatCmd + Info func(ctx context.Context, section ...string) *StringCmd + Keys func(ctx context.Context, pattern string) *StringSliceCmd + LIndex func(ctx context.Context, key string, index int64) *StringCmd + LInsert func(ctx context.Context, key, op string, pivot, value interface{}) *IntCmd + LInsertAfter func(ctx context.Context, key string, pivot, value interface{}) *IntCmd + LInsertBefore func(ctx context.Context, key string, pivot, value interface{}) *IntCmd + LLen func(ctx context.Context, key string) *IntCmd + LMove func(ctx context.Context, source, destination, srcpos, destpos string) *StringCmd + LPop func(ctx context.Context, key string) *StringCmd + LPopCount func(ctx context.Context, key string, count int64) *StringSliceCmd + LPos func(ctx context.Context, key string, value string, args LPosArgs) *IntCmd + LPosCount func(ctx context.Context, key string, value string, count int64, args LPosArgs) *IntSliceCmd + LPush func(ctx context.Context, key string, values ...interface{}) *IntCmd + LPushX func(ctx context.Context, key string, values ...interface{}) *IntCmd + LRange func(ctx context.Context, key string, start, stop int64) *StringSliceCmd + LRem func(ctx context.Context, key string, count int64, value interface{}) *IntCmd + LSet func(ctx context.Context, key string, index int64, value interface{}) *StatusCmd + LTrim func(ctx context.Context, key string, start, stop int64) *StatusCmd + LastSave func(ctx context.Context) *IntCmd + MGet func(ctx context.Context, keys ...string) *SliceCmd + MSet func(ctx context.Context, values ...interface{}) *StatusCmd + MSetNX func(ctx context.Context, values ...interface{}) *BoolCmd + MemoryUsage func(ctx context.Context, key string, samples ...int64) *IntCmd + Migrate func(ctx context.Context, host string, port int64, key string, db int64, ...) *StatusCmd + Move func(ctx context.Context, key string, db int64) *BoolCmd + ObjectEncoding func(ctx context.Context, key string) *StringCmd + ObjectIdleTime func(ctx context.Context, key string) *DurationCmd + ObjectRefCount func(ctx context.Context, key string) *IntCmd + PExpire func(ctx context.Context, key string, expiration time.Duration) *BoolCmd + PExpireAt func(ctx context.Context, key string, tm time.Time) *BoolCmd + PFAdd func(ctx context.Context, key string, els ...interface{}) *IntCmd + PFCount func(ctx context.Context, keys ...string) *IntCmd + PFMerge func(ctx context.Context, dest string, keys ...string) *StatusCmd + PTTL func(ctx context.Context, key string) *DurationCmd + Persist func(ctx context.Context, key string) *BoolCmd + Ping func(ctx context.Context) *StatusCmd + PubSubChannels func(ctx context.Context, pattern string) *StringSliceCmd + PubSubNumPat func(ctx context.Context) *IntCmd + PubSubNumSub func(ctx context.Context, channels ...string) *StringIntMapCmd + Publish func(ctx context.Context, channel string, message interface{}) *IntCmd + Quit func(ctx context.Context) *StatusCmd + RPop func(ctx context.Context, key string) *StringCmd + RPopCount func(ctx context.Context, key string, count int64) *StringSliceCmd + RPopLPush func(ctx context.Context, source, destination string) *StringCmd + RPush func(ctx context.Context, key string, values ...interface{}) *IntCmd + RPushX func(ctx context.Context, key string, values ...interface{}) *IntCmd + RandomKey func(ctx context.Context) *StringCmd + ReadOnly func(ctx context.Context) *StatusCmd + ReadWrite func(ctx context.Context) *StatusCmd + Rename func(ctx context.Context, key, newkey string) *StatusCmd + RenameNX func(ctx context.Context, key, newkey string) *BoolCmd + Restore func(ctx context.Context, key string, ttl time.Duration, value string) *StatusCmd + RestoreReplace func(ctx context.Context, key string, ttl time.Duration, value string) *StatusCmd + SAdd func(ctx context.Context, key string, members ...interface{}) *IntCmd + SCard func(ctx context.Context, key string) *IntCmd + SDiff func(ctx context.Context, keys ...string) *StringSliceCmd + SDiffStore func(ctx context.Context, destination string, keys ...string) *IntCmd + SInter func(ctx context.Context, keys ...string) *StringSliceCmd + SInterStore func(ctx context.Context, destination string, keys ...string) *IntCmd + SIsMember func(ctx context.Context, key string, member interface{}) *BoolCmd + SMIsMember func(ctx context.Context, key string, members ...interface{}) *BoolSliceCmd + SMembers func(ctx context.Context, key string) *StringSliceCmd + SMembersMap func(ctx context.Context, key string) *StringStructMapCmd + SMove func(ctx context.Context, source, destination string, member interface{}) *BoolCmd + SPop func(ctx context.Context, key string) *StringCmd + SPopN func(ctx context.Context, key string, count int64) *StringSliceCmd + SRandMember func(ctx context.Context, key string) *StringCmd + SRandMemberN func(ctx context.Context, key string, count int64) *StringSliceCmd + SRem func(ctx context.Context, key string, members ...interface{}) *IntCmd + SScan func(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd + SUnion func(ctx context.Context, keys ...string) *StringSliceCmd + SUnionStore func(ctx context.Context, destination string, keys ...string) *IntCmd + Save func(ctx context.Context) *StatusCmd + Scan func(ctx context.Context, cursor uint64, match string, count int64) *ScanCmd + ScanType func(ctx context.Context, cursor uint64, match string, count int64, keyType string) *ScanCmd + ScriptExists func(ctx context.Context, hashes ...string) *BoolSliceCmd + ScriptFlush func(ctx context.Context) *StatusCmd + ScriptKill func(ctx context.Context) *StatusCmd + ScriptLoad func(ctx context.Context, script string) *StringCmd + Set func(ctx context.Context, key string, value interface{}, expiration time.Duration) *StatusCmd + SetArgs func(ctx context.Context, key string, value interface{}, a SetArgs) *StatusCmd + SetBit func(ctx context.Context, key string, offset int64, value int64) *IntCmd + SetEX func(ctx context.Context, key string, value interface{}, expiration time.Duration) *StatusCmd + SetNX func(ctx context.Context, key string, value interface{}, expiration time.Duration) *BoolCmd + SetRange func(ctx context.Context, key string, offset int64, value string) *IntCmd + SetXX func(ctx context.Context, key string, value interface{}, expiration time.Duration) *BoolCmd + Shutdown func(ctx context.Context) *StatusCmd + ShutdownNoSave func(ctx context.Context) *StatusCmd + ShutdownSave func(ctx context.Context) *StatusCmd + SlaveOf func(ctx context.Context, host string, port string) *StatusCmd + Sort func(ctx context.Context, key string, sort Sort) *StringSliceCmd + SortInterfaces func(ctx context.Context, key string, sort Sort) *SliceCmd + SortStore func(ctx context.Context, key, store string, sort Sort) *IntCmd + StrLen func(ctx context.Context, key string) *IntCmd + TTL func(ctx context.Context, key string) *DurationCmd + Time func(ctx context.Context) *TimeCmd + Touch func(ctx context.Context, keys ...string) *IntCmd + Type func(ctx context.Context, key string) *StatusCmd + Unlink func(ctx context.Context, keys ...string) *IntCmd + XAck func(ctx context.Context, stream, group string, ids ...string) *IntCmd + XAdd func(ctx context.Context, a XAddArgs) *StringCmd + XAutoClaim func(ctx context.Context, a XAutoClaimArgs) *XAutoClaimCmd + XAutoClaimJustID func(ctx context.Context, a XAutoClaimArgs) *XAutoClaimJustIDCmd + XClaim func(ctx context.Context, a XClaimArgs) *XMessageSliceCmd + XClaimJustID func(ctx context.Context, a XClaimArgs) *StringSliceCmd + XDel func(ctx context.Context, stream string, ids ...string) *IntCmd + XGroupCreate func(ctx context.Context, stream, group, start string) *StatusCmd + XGroupCreateConsumer func(ctx context.Context, stream, group, consumer string) *IntCmd + XGroupCreateMkStream func(ctx context.Context, stream, group, start string) *StatusCmd + XGroupDelConsumer func(ctx context.Context, stream, group, consumer string) *IntCmd + XGroupDestroy func(ctx context.Context, stream, group string) *IntCmd + XGroupSetID func(ctx context.Context, stream, group, start string) *StatusCmd + XInfoConsumers func(ctx context.Context, key string, group string) *XInfoConsumersCmd + XInfoGroups func(ctx context.Context, key string) *XInfoGroupsCmd + XInfoStream func(ctx context.Context, key string) *XInfoStreamCmd + XInfoStreamFull func(ctx context.Context, key string, count int64) *XInfoStreamFullCmd + XLen func(ctx context.Context, stream string) *IntCmd + XPending func(ctx context.Context, stream, group string) *XPendingCmd + XPendingExt func(ctx context.Context, a XPendingExtArgs) *XPendingExtCmd + XRange func(ctx context.Context, stream, start, stop string) *XMessageSliceCmd + XRangeN func(ctx context.Context, stream, start, stop string, count int64) *XMessageSliceCmd + XRead func(ctx context.Context, a XReadArgs) *XStreamSliceCmd + XReadGroup func(ctx context.Context, a XReadGroupArgs) *XStreamSliceCmd + XReadStreams func(ctx context.Context, streams ...string) *XStreamSliceCmd + XRevRange func(ctx context.Context, stream, start, stop string) *XMessageSliceCmd + XRevRangeN func(ctx context.Context, stream string, start, stop string, count int64) *XMessageSliceCmd + XTrimMaxLen func(ctx context.Context, key string, maxLen int64) *IntCmd + XTrimMaxLenApprox func(ctx context.Context, key string, maxLen, limit int64) *IntCmd + XTrimMinID func(ctx context.Context, key string, minID string) *IntCmd + XTrimMinIDApprox func(ctx context.Context, key string, minID string, limit int64) *IntCmd + ZAdd func(ctx context.Context, key string, members ...Z) *IntCmd + ZAddArgs func(ctx context.Context, key string, args ZAddArgs) *IntCmd + ZAddArgsIncr func(ctx context.Context, key string, args ZAddArgs) *FloatCmd + ZAddNX func(ctx context.Context, key string, members ...Z) *IntCmd + ZAddXX func(ctx context.Context, key string, members ...Z) *IntCmd + ZCard func(ctx context.Context, key string) *IntCmd + ZCount func(ctx context.Context, key string, min, max string) *IntCmd + ZDiff func(ctx context.Context, keys ...string) *StringSliceCmd + ZDiffStore func(ctx context.Context, destination string, keys ...string) *IntCmd + ZDiffWithScores func(ctx context.Context, keys ...string) *ZSliceCmd + ZIncrBy func(ctx context.Context, key string, increment float64, member string) *FloatCmd + ZInter func(ctx context.Context, store ZStore) *StringSliceCmd + ZInterStore func(ctx context.Context, destination string, store ZStore) *IntCmd + ZInterWithScores func(ctx context.Context, store ZStore) *ZSliceCmd + ZLexCount func(ctx context.Context, key, min, max string) *IntCmd + ZMScore func(ctx context.Context, key string, members ...string) *FloatSliceCmd + ZPopMax func(ctx context.Context, key string, count ...int64) *ZSliceCmd + ZPopMin func(ctx context.Context, key string, count ...int64) *ZSliceCmd + ZRandMember func(ctx context.Context, key string, count int64, withScores bool) *StringSliceCmd + ZRange func(ctx context.Context, key string, start, stop int64) *StringSliceCmd + ZRangeArgs func(ctx context.Context, z ZRangeArgs) *StringSliceCmd + ZRangeArgsWithScores func(ctx context.Context, z ZRangeArgs) *ZSliceCmd + ZRangeByLex func(ctx context.Context, key string, opt ZRangeBy) *StringSliceCmd + ZRangeByScore func(ctx context.Context, key string, opt ZRangeBy) *StringSliceCmd + ZRangeByScoreWithScores func(ctx context.Context, key string, opt ZRangeBy) *ZSliceCmd + ZRangeStore func(ctx context.Context, dst string, z ZRangeArgs) *IntCmd + ZRangeWithScores func(ctx context.Context, key string, start, stop int64) *ZSliceCmd + ZRank func(ctx context.Context, key, member string) *IntCmd + ZRem func(ctx context.Context, key string, members ...interface{}) *IntCmd + ZRemRangeByLex func(ctx context.Context, key, min, max string) *IntCmd + ZRemRangeByRank func(ctx context.Context, key string, start, stop int64) *IntCmd + ZRemRangeByScore func(ctx context.Context, key string, min, max string) *IntCmd + ZRevRange func(ctx context.Context, key string, start, stop int64) *StringSliceCmd + ZRevRangeByLex func(ctx context.Context, key string, opt ZRangeBy) *StringSliceCmd + ZRevRangeByScore func(ctx context.Context, key string, opt ZRangeBy) *StringSliceCmd + ZRevRangeByScoreWithScores func(ctx context.Context, key string, opt ZRangeBy) *ZSliceCmd + ZRevRangeWithScores func(ctx context.Context, key string, start, stop int64) *ZSliceCmd + ZRevRank func(ctx context.Context, key, member string) *IntCmd + ZScan func(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd + ZScore func(ctx context.Context, key, member string) *FloatCmd + ZUnion func(ctx context.Context, store ZStore) *StringSliceCmd + ZUnionStore func(ctx context.Context, dest string, store ZStore) *IntCmd + ZUnionWithScores func(ctx context.Context, store ZStore) *ZSliceCmd + func NewAdapter(client rueidis.Client) Cmdable + type CommandInfo struct + ACLFlags []string + Arity int8 + FirstKeyPos int8 + Flags []string + LastKeyPos int8 + Name string + ReadOnly bool + StepCount int8 + type CommandsInfoCmd struct + func (cmd *CommandsInfoCmd) Err() error + func (cmd *CommandsInfoCmd) Result() (map[string]CommandInfo, error) + func (cmd *CommandsInfoCmd) SetErr(err error) + func (cmd *CommandsInfoCmd) SetVal(val map[string]CommandInfo) + func (cmd *CommandsInfoCmd) Val() map[string]CommandInfo + type Compat struct + func (c *Compat) Append(ctx context.Context, key, value string) *IntCmd + 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) 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 ...interface{}) *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) 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) 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) 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) ConfigGet(ctx context.Context, parameter string) *SliceCmd + 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 interface{}) *StringCmd + func (c *Compat) Eval(ctx context.Context, script string, keys []string, args ...interface{}) *Cmd + func (c *Compat) EvalSha(ctx context.Context, sha1 string, keys []string, args ...interface{}) *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) ExpireXX(ctx context.Context, key string, seconds time.Duration) *BoolCmd + 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) 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 interface{}) *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 ...interface{}) *BoolCmd + func (c *Compat) HRandField(ctx context.Context, key string, count int64, withValues bool) *StringSliceCmd + 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 ...interface{}) *IntCmd + func (c *Compat) HSetNX(ctx context.Context, key, field string, value interface{}) *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) 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 interface{}) *IntCmd + func (c *Compat) LInsertAfter(ctx context.Context, key string, pivot, element interface{}) *IntCmd + func (c *Compat) LInsertBefore(ctx context.Context, key string, pivot, element interface{}) *IntCmd + func (c *Compat) LLen(ctx context.Context, key string) *IntCmd + 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 ...interface{}) *IntCmd + func (c *Compat) LPushX(ctx context.Context, key string, elements ...interface{}) *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 interface{}) *IntCmd + func (c *Compat) LSet(ctx context.Context, key string, index int64, element interface{}) *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 ...interface{}) *StatusCmd + func (c *Compat) MSetNX(ctx context.Context, values ...interface{}) *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) PFAdd(ctx context.Context, key string, els ...interface{}) *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) 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) Publish(ctx context.Context, channel string, message interface{}) *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 ...interface{}) *IntCmd + func (c *Compat) RPushX(ctx context.Context, key string, elements ...interface{}) *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 ...interface{}) *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) SInterStore(ctx context.Context, destination string, keys ...string) *IntCmd + func (c *Compat) SIsMember(ctx context.Context, key string, member interface{}) *BoolCmd + func (c *Compat) SMIsMember(ctx context.Context, key string, members ...interface{}) *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 interface{}) *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) 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 ...interface{}) *IntCmd + func (c *Compat) SScan(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd + 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 interface{}, expiration time.Duration) *StatusCmd + func (c *Compat) SetArgs(ctx context.Context, key string, value interface{}, 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 interface{}, expiration time.Duration) *StatusCmd + func (c *Compat) SetNX(ctx context.Context, key string, value interface{}, 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 interface{}, 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) SlaveOf(ctx context.Context, host string, port string) *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) SortStore(ctx context.Context, key, store string, sort Sort) *IntCmd + func (c *Compat) StrLen(ctx context.Context, key string) *IntCmd + func (c *Compat) TTL(ctx context.Context, key string) *DurationCmd + func (c *Compat) Time(ctx context.Context) *TimeCmd + 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) 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 string, 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) 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) 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, withScores bool) *StringSliceCmd + 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) ZRem(ctx context.Context, key string, members ...interface{}) *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 string, 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) 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 struct + func (cmd *DurationCmd) Err() error + func (cmd *DurationCmd) Result() (time.Duration, error) + func (cmd *DurationCmd) SetErr(err error) + func (cmd *DurationCmd) SetVal(val time.Duration) + func (cmd *DurationCmd) Val() time.Duration + type FloatCmd struct + func (cmd *FloatCmd) Err() error + func (cmd *FloatCmd) Result() (float64, error) + func (cmd *FloatCmd) SetErr(err error) + func (cmd *FloatCmd) SetVal(val float64) + func (cmd *FloatCmd) Val() float64 + type FloatSliceCmd struct + func (cmd *FloatSliceCmd) Err() error + func (cmd *FloatSliceCmd) Result() ([]float64, error) + func (cmd *FloatSliceCmd) SetErr(err error) + func (cmd *FloatSliceCmd) SetVal(val []float64) + func (cmd *FloatSliceCmd) Val() []float64 + type GeoLocation struct + Dist float64 + GeoHash int64 + Latitude float64 + Longitude float64 + Name string + type GeoLocationCmd struct + func (cmd *GeoLocationCmd) Err() error + func (cmd *GeoLocationCmd) Result() ([]GeoLocation, error) + func (cmd *GeoLocationCmd) SetErr(err error) + func (cmd *GeoLocationCmd) SetVal(val []GeoLocation) + func (cmd *GeoLocationCmd) Val() []GeoLocation + type GeoPos struct + Latitude float64 + Longitude float64 + type GeoPosCmd struct + func (cmd *GeoPosCmd) Err() error + func (cmd *GeoPosCmd) Result() ([]*GeoPos, error) + func (cmd *GeoPosCmd) SetErr(err error) + func (cmd *GeoPosCmd) SetVal(val []*GeoPos) + func (cmd *GeoPosCmd) Val() []*GeoPos + type GeoRadiusQuery struct + Count int64 + Radius float64 + Sort string + Store string + StoreDist string + Unit string + WithCoord bool + WithDist bool + WithGeoHash bool + type GeoSearchLocationQuery struct + WithCoord bool + WithDist bool + WithHash bool + type GeoSearchQuery struct + BoxHeight float64 + BoxUnit string + BoxWidth float64 + Count int64 + CountAny bool + Latitude float64 + Longitude float64 + Member string + Radius float64 + RadiusUnit string + Sort string + type GeoSearchStoreQuery struct + StoreDist bool + type IntCmd struct + func (cmd *IntCmd) Err() error + func (cmd *IntCmd) Result() (int64, error) + func (cmd *IntCmd) SetErr(err error) + func (cmd *IntCmd) SetVal(val int64) + func (cmd *IntCmd) Uint64() (uint64, error) + func (cmd *IntCmd) Val() int64 + type IntSliceCmd struct + func (cmd *IntSliceCmd) Err() error + func (cmd *IntSliceCmd) Result() ([]int64, error) + func (cmd *IntSliceCmd) SetErr(err error) + func (cmd *IntSliceCmd) SetVal(val []int64) + func (cmd *IntSliceCmd) Val() []int64 + type LPosArgs struct + MaxLen int64 + Rank int64 + type ScanCmd struct + func (cmd *ScanCmd) Err() error + func (cmd *ScanCmd) Result() (keys []string, cursor uint64, err error) + func (cmd *ScanCmd) SetVal(keys []string, cursor uint64) + func (cmd *ScanCmd) Val() (keys []string, cursor uint64) + type SetArgs struct + ExpireAt time.Time + Get bool + KeepTTL bool + Mode string + TTL time.Duration + type SliceCmd struct + func (cmd *SliceCmd) Err() error + func (cmd *SliceCmd) Result() ([]interface{}, error) + func (cmd *SliceCmd) SetErr(err error) + func (cmd *SliceCmd) SetVal(val []interface{}) + func (cmd *SliceCmd) Val() []interface{} + type Sort struct + Alpha bool + By string + Count int64 + Get []string + Offset int64 + Order string + type StatusCmd struct + func (cmd *StatusCmd) Err() error + func (cmd *StatusCmd) Result() (string, error) + func (cmd *StatusCmd) SetErr(err error) + func (cmd *StatusCmd) SetVal(val string) + func (cmd *StatusCmd) Val() string + type StringCmd struct + 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() (string, error) + func (cmd *StringCmd) SetErr(err error) + func (cmd *StringCmd) SetVal(val string) + func (cmd *StringCmd) String() string + func (cmd *StringCmd) Time() (time.Time, error) + func (cmd *StringCmd) Uint64() (uint64, error) + func (cmd *StringCmd) Val() string + type StringIntMapCmd struct + func (cmd *StringIntMapCmd) Err() error + func (cmd *StringIntMapCmd) Result() (map[string]int64, error) + func (cmd *StringIntMapCmd) SetErr(err error) + func (cmd *StringIntMapCmd) SetVal(val map[string]int64) + func (cmd *StringIntMapCmd) Val() map[string]int64 + type StringSliceCmd struct + func (cmd *StringSliceCmd) Err() error + func (cmd *StringSliceCmd) Result() ([]string, error) + func (cmd *StringSliceCmd) SetErr(err error) + func (cmd *StringSliceCmd) SetVal(val []string) + func (cmd *StringSliceCmd) Val() []string + type StringStringMapCmd struct + func (cmd *StringStringMapCmd) Err() error + func (cmd *StringStringMapCmd) Result() (map[string]string, error) + func (cmd *StringStringMapCmd) SetErr(err error) + func (cmd *StringStringMapCmd) SetVal(val map[string]string) + func (cmd *StringStringMapCmd) Val() map[string]string + type StringStructMapCmd struct + func (cmd *StringStructMapCmd) Err() error + func (cmd *StringStructMapCmd) Result() (map[string]struct{}, error) + func (cmd *StringStructMapCmd) SetErr(err error) + func (cmd *StringStructMapCmd) SetVal(val map[string]struct{}) + func (cmd *StringStructMapCmd) Val() map[string]struct{} + type TimeCmd struct + func (cmd *TimeCmd) Err() error + func (cmd *TimeCmd) Result() (time.Time, error) + func (cmd *TimeCmd) SetErr(err error) + func (cmd *TimeCmd) SetVal(val time.Time) + func (cmd *TimeCmd) Val() time.Time + type XAddArgs struct + Approx bool + ID string + Limit int64 + MaxLen int64 + MinID string + NoMkStream bool + Stream string + Values interface{} + type XAutoClaimArgs struct + Consumer string + Count int64 + Group string + MinIdle time.Duration + Start string + Stream string + type XAutoClaimCmd struct + func (cmd *XAutoClaimCmd) Err() error + func (cmd *XAutoClaimCmd) Result() (messages []XMessage, start string, err error) + func (cmd *XAutoClaimCmd) SetErr(err error) + func (cmd *XAutoClaimCmd) SetVal(val []XMessage, start string) + func (cmd *XAutoClaimCmd) Val() (messages []XMessage, start string) + type XAutoClaimJustIDCmd struct + 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 struct + Consumer string + Group string + Messages []string + MinIdle time.Duration + Stream string + type XInfoConsumer struct + Idle time.Duration + Name string + Pending int64 + type XInfoConsumersCmd struct + func (cmd *XInfoConsumersCmd) Err() error + func (cmd *XInfoConsumersCmd) Result() ([]XInfoConsumer, error) + func (cmd *XInfoConsumersCmd) SetErr(err error) + func (cmd *XInfoConsumersCmd) SetVal(val []XInfoConsumer) + func (cmd *XInfoConsumersCmd) Val() []XInfoConsumer + type XInfoGroup struct + Consumers int64 + EntriesRead int64 + Lag int64 + LastDeliveredID string + Name string + Pending int64 + type XInfoGroupsCmd struct + func (cmd *XInfoGroupsCmd) Err() error + func (cmd *XInfoGroupsCmd) Result() ([]XInfoGroup, error) + func (cmd *XInfoGroupsCmd) SetErr(err error) + func (cmd *XInfoGroupsCmd) SetVal(val []XInfoGroup) + func (cmd *XInfoGroupsCmd) Val() []XInfoGroup + type XInfoStream struct + EntriesAdded int64 + FirstEntry XMessage + Groups int64 + LastEntry XMessage + LastGeneratedID string + Length int64 + MaxDeletedEntryID string + RadixTreeKeys int64 + RadixTreeNodes int64 + RecordedFirstEntryID string + type XInfoStreamCmd struct + func (cmd *XInfoStreamCmd) Err() error + func (cmd *XInfoStreamCmd) Result() (XInfoStream, error) + func (cmd *XInfoStreamCmd) SetErr(err error) + func (cmd *XInfoStreamCmd) SetVal(val XInfoStream) + func (cmd *XInfoStreamCmd) Val() XInfoStream + type XInfoStreamConsumer struct + Name string + PelCount int64 + Pending []XInfoStreamConsumerPending + SeenTime time.Time + type XInfoStreamConsumerPending struct + DeliveryCount int64 + DeliveryTime time.Time + ID string + type XInfoStreamFull struct + Entries []XMessage + EntriesAdded int64 + Groups []XInfoStreamGroup + LastGeneratedID string + Length int64 + MaxDeletedEntryID string + RadixTreeKeys int64 + RadixTreeNodes int64 + RecordedFirstEntryID string + type XInfoStreamFullCmd struct + func (cmd *XInfoStreamFullCmd) Err() error + func (cmd *XInfoStreamFullCmd) Result() (XInfoStreamFull, error) + func (cmd *XInfoStreamFullCmd) SetErr(err error) + func (cmd *XInfoStreamFullCmd) SetVal(val XInfoStreamFull) + func (cmd *XInfoStreamFullCmd) Val() XInfoStreamFull + type XInfoStreamGroup struct + Consumers []XInfoStreamConsumer + EntriesRead int64 + Lag int64 + LastDeliveredID string + Name string + PelCount int64 + Pending []XInfoStreamGroupPending + type XInfoStreamGroupPending struct + Consumer string + DeliveryCount int64 + DeliveryTime time.Time + ID string + type XMessage struct + ID string + Values map[string]interface{} + type XMessageSliceCmd struct + func (cmd *XMessageSliceCmd) Err() error + func (cmd *XMessageSliceCmd) Result() ([]XMessage, error) + func (cmd *XMessageSliceCmd) SetErr(err error) + func (cmd *XMessageSliceCmd) SetVal(val []XMessage) + func (cmd *XMessageSliceCmd) Val() []XMessage + type XPending struct + Consumers map[string]int64 + Count int64 + Higher string + Lower string + type XPendingCmd struct + func (cmd *XPendingCmd) Err() error + func (cmd *XPendingCmd) Result() (XPending, error) + func (cmd *XPendingCmd) SetErr(err error) + func (cmd *XPendingCmd) SetVal(val XPending) + func (cmd *XPendingCmd) Val() XPending + type XPendingExt struct + Consumer string + ID string + Idle time.Duration + RetryCount int64 + type XPendingExtArgs struct + Consumer string + Count int64 + End string + Group string + Idle time.Duration + Start string + Stream string + type XPendingExtCmd struct + func (cmd *XPendingExtCmd) Err() error + func (cmd *XPendingExtCmd) Result() ([]XPendingExt, error) + func (cmd *XPendingExtCmd) SetErr(err error) + func (cmd *XPendingExtCmd) SetVal(val []XPendingExt) + func (cmd *XPendingExtCmd) Val() []XPendingExt + type XReadArgs struct + Block time.Duration + Count int64 + Streams []string + type XReadGroupArgs struct + Block time.Duration + Consumer string + Count int64 + Group string + NoAck bool + Streams []string + type XStream struct + Messages []XMessage + Stream string + type XStreamSliceCmd struct + func (cmd *XStreamSliceCmd) Err() error + func (cmd *XStreamSliceCmd) Result() ([]XStream, error) + func (cmd *XStreamSliceCmd) SetErr(err error) + func (cmd *XStreamSliceCmd) SetVal(val []XStream) + func (cmd *XStreamSliceCmd) Val() []XStream + type Z struct + Member interface{} + Score float64 + type ZAddArgs struct + Ch bool + GT bool + Incr bool + LT bool + Members []Z + NX bool + XX bool + type ZRangeArgs struct + ByLex bool + ByScore bool + Count int64 + Key string + Offset int64 + Rev bool + Start interface{} + Stop interface{} + type ZRangeBy struct + Count int64 + Max string + Min string + Offset int64 + type ZSliceCmd struct + func (cmd *ZSliceCmd) Err() error + func (cmd *ZSliceCmd) Result() ([]Z, error) + func (cmd *ZSliceCmd) SetErr(err error) + func (cmd *ZSliceCmd) SetVal(val []Z) + func (cmd *ZSliceCmd) Val() []Z + type ZStore struct + Aggregate string + Keys []string + Weights []int64 + type ZWithKey struct + Key string + type ZWithKeyCmd struct + func (cmd *ZWithKeyCmd) Err() error + func (cmd *ZWithKeyCmd) Result() (ZWithKey, error) + func (cmd *ZWithKeyCmd) SetErr(err error) + func (cmd *ZWithKeyCmd) SetVal(val ZWithKey) + func (cmd *ZWithKeyCmd) Val() ZWithKey
Go to main page