Documentation ¶
Index ¶
- Constants
- type BitCount
- type BitField
- type BitFieldArg
- type BoolCmd
- type BoolSliceCmd
- type CacheCompat
- 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
- 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() (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
- type CommandInfo
- type CommandsInfoCmd
- type Compat
- 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) *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) 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
- type FloatCmd
- type FloatSliceCmd
- type GeoLocation
- type GeoLocationCmd
- type GeoPos
- type GeoPosCmd
- type GeoRadiusQuery
- type GeoSearchLocationQuery
- type GeoSearchQuery
- type GeoSearchStoreQuery
- type IntCmd
- type IntSliceCmd
- type LPosArgs
- type ScanCmd
- type SetArgs
- type SliceCmd
- 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() (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
- type StringSliceCmd
- type StringStringMapCmd
- type StringStructMapCmd
- type TimeCmd
- 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 ZStore
- type ZWithKey
- type ZWithKeyCmd
Constants ¶
const KeepTTL = -1
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BitField ¶
type BitField struct { Get *BitFieldArg Set *BitFieldArg IncrBy *BitFieldArg Increment int64 Overflow string }
type BitFieldArg ¶
type BoolSliceCmd ¶
type BoolSliceCmd struct {
// contains filtered or unexported fields
}
func (*BoolSliceCmd) Err ¶
func (cmd *BoolSliceCmd) Err() error
func (*BoolSliceCmd) Result ¶
func (cmd *BoolSliceCmd) Result() ([]bool, error)
func (*BoolSliceCmd) SetErr ¶
func (cmd *BoolSliceCmd) SetErr(err error)
func (*BoolSliceCmd) SetVal ¶
func (cmd *BoolSliceCmd) SetVal(val []bool)
func (*BoolSliceCmd) Val ¶
func (cmd *BoolSliceCmd) Val() []bool
type CacheCompat ¶
type CacheCompat struct {
// contains filtered or unexported fields
}
func (CacheCompat) 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) 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) SIsMember ¶
func (c CacheCompat) SIsMember(ctx context.Context, key string, member interface{}) *BoolCmd
func (CacheCompat) SMIsMember ¶
func (c CacheCompat) SMIsMember(ctx context.Context, key string, members ...interface{}) *BoolSliceCmd
func (CacheCompat) SMembers ¶
func (c CacheCompat) SMembers(ctx context.Context, key string) *StringSliceCmd
func (CacheCompat) Sort ¶
func (c CacheCompat) Sort(ctx context.Context, key string, sort Sort) *StringSliceCmd
func (CacheCompat) TTL ¶
func (c CacheCompat) TTL(ctx context.Context, key string) *DurationCmd
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) 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 ¶
type ClusterNode ¶
type ClusterSlot ¶
type ClusterSlot struct { Start int64 End int64 Nodes []ClusterNode }
type ClusterSlotsCmd ¶
type ClusterSlotsCmd struct {
// contains filtered or unexported fields
}
func (*ClusterSlotsCmd) Err ¶
func (cmd *ClusterSlotsCmd) Err() error
func (*ClusterSlotsCmd) Result ¶
func (cmd *ClusterSlotsCmd) Result() ([]ClusterSlot, error)
func (*ClusterSlotsCmd) SetErr ¶
func (cmd *ClusterSlotsCmd) SetErr(err error)
func (*ClusterSlotsCmd) SetVal ¶
func (cmd *ClusterSlotsCmd) SetVal(val []ClusterSlot)
func (*ClusterSlotsCmd) Val ¶
func (cmd *ClusterSlotsCmd) Val() []ClusterSlot
type Cmd ¶
type Cmd struct {
// contains filtered or unexported fields
}
func (*Cmd) 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 ClientGetName(ctx context.Context) *StringCmd Echo(ctx context.Context, message interface{}) *StringCmd Ping(ctx context.Context) *StatusCmd Quit(ctx context.Context) *StatusCmd Del(ctx context.Context, keys ...string) *IntCmd Unlink(ctx context.Context, keys ...string) *IntCmd Dump(ctx context.Context, key string) *StringCmd Exists(ctx context.Context, keys ...string) *IntCmd Expire(ctx context.Context, key string, expiration time.Duration) *BoolCmd ExpireAt(ctx context.Context, key string, tm time.Time) *BoolCmd ExpireNX(ctx context.Context, key string, expiration time.Duration) *BoolCmd ExpireXX(ctx context.Context, key string, expiration time.Duration) *BoolCmd ExpireGT(ctx context.Context, key string, expiration time.Duration) *BoolCmd ExpireLT(ctx context.Context, key string, expiration time.Duration) *BoolCmd Keys(ctx context.Context, pattern string) *StringSliceCmd Migrate(ctx context.Context, host string, port int64, key string, db int64, timeout time.Duration) *StatusCmd Move(ctx context.Context, key string, db int64) *BoolCmd ObjectRefCount(ctx context.Context, key string) *IntCmd ObjectEncoding(ctx context.Context, key string) *StringCmd ObjectIdleTime(ctx context.Context, key string) *DurationCmd Persist(ctx context.Context, key string) *BoolCmd PExpire(ctx context.Context, key string, expiration time.Duration) *BoolCmd PExpireAt(ctx context.Context, key string, tm time.Time) *BoolCmd PTTL(ctx context.Context, key string) *DurationCmd RandomKey(ctx context.Context) *StringCmd Rename(ctx context.Context, key, newkey string) *StatusCmd RenameNX(ctx context.Context, key, newkey string) *BoolCmd Restore(ctx context.Context, key string, ttl time.Duration, value string) *StatusCmd RestoreReplace(ctx context.Context, key string, ttl time.Duration, value string) *StatusCmd Sort(ctx context.Context, key string, sort Sort) *StringSliceCmd SortStore(ctx context.Context, key, store string, sort Sort) *IntCmd SortInterfaces(ctx context.Context, key string, sort Sort) *SliceCmd Touch(ctx context.Context, keys ...string) *IntCmd TTL(ctx context.Context, key string) *DurationCmd Type(ctx context.Context, key string) *StatusCmd Append(ctx context.Context, key, value string) *IntCmd Decr(ctx context.Context, key string) *IntCmd DecrBy(ctx context.Context, key string, decrement int64) *IntCmd Get(ctx context.Context, key string) *StringCmd GetRange(ctx context.Context, key string, start, end int64) *StringCmd GetSet(ctx context.Context, key string, value interface{}) *StringCmd GetEx(ctx context.Context, key string, expiration time.Duration) *StringCmd GetDel(ctx context.Context, key string) *StringCmd Incr(ctx context.Context, key string) *IntCmd IncrBy(ctx context.Context, key string, value int64) *IntCmd IncrByFloat(ctx context.Context, key string, value float64) *FloatCmd MGet(ctx context.Context, keys ...string) *SliceCmd MSet(ctx context.Context, values ...interface{}) *StatusCmd MSetNX(ctx context.Context, values ...interface{}) *BoolCmd Set(ctx context.Context, key string, value interface{}, expiration time.Duration) *StatusCmd SetArgs(ctx context.Context, key string, value interface{}, a SetArgs) *StatusCmd SetEX(ctx context.Context, key string, value interface{}, expiration time.Duration) *StatusCmd SetNX(ctx context.Context, key string, value interface{}, expiration time.Duration) *BoolCmd SetXX(ctx context.Context, key string, value interface{}, expiration time.Duration) *BoolCmd SetRange(ctx context.Context, key string, offset int64, value string) *IntCmd StrLen(ctx context.Context, key string) *IntCmd Copy(ctx context.Context, sourceKey string, destKey string, db int64, replace bool) *IntCmd GetBit(ctx context.Context, key string, offset int64) *IntCmd SetBit(ctx context.Context, key string, offset int64, value int64) *IntCmd BitCount(ctx context.Context, key string, bitCount *BitCount) *IntCmd BitOpAnd(ctx context.Context, destKey string, keys ...string) *IntCmd BitOpOr(ctx context.Context, destKey string, keys ...string) *IntCmd BitOpXor(ctx context.Context, destKey string, keys ...string) *IntCmd BitOpNot(ctx context.Context, destKey string, key string) *IntCmd BitPos(ctx context.Context, key string, bit int64, pos ...int64) *IntCmd BitField(ctx context.Context, key string, args ...interface{}) *IntSliceCmd Scan(ctx context.Context, cursor uint64, match string, count int64) *ScanCmd ScanType(ctx context.Context, cursor uint64, match string, count int64, keyType string) *ScanCmd SScan(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd HScan(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd ZScan(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd HDel(ctx context.Context, key string, fields ...string) *IntCmd HExists(ctx context.Context, key, field string) *BoolCmd HGet(ctx context.Context, key, field string) *StringCmd HGetAll(ctx context.Context, key string) *StringStringMapCmd HIncrBy(ctx context.Context, key, field string, incr int64) *IntCmd HIncrByFloat(ctx context.Context, key, field string, incr float64) *FloatCmd HKeys(ctx context.Context, key string) *StringSliceCmd HLen(ctx context.Context, key string) *IntCmd HMGet(ctx context.Context, key string, fields ...string) *SliceCmd HSet(ctx context.Context, key string, values ...interface{}) *IntCmd HMSet(ctx context.Context, key string, values ...interface{}) *BoolCmd HSetNX(ctx context.Context, key, field string, value interface{}) *BoolCmd HVals(ctx context.Context, key string) *StringSliceCmd HRandField(ctx context.Context, key string, count int64, withValues bool) *StringSliceCmd BLPop(ctx context.Context, timeout time.Duration, keys ...string) *StringSliceCmd BRPop(ctx context.Context, timeout time.Duration, keys ...string) *StringSliceCmd BRPopLPush(ctx context.Context, source, destination string, timeout time.Duration) *StringCmd LIndex(ctx context.Context, key string, index int64) *StringCmd LInsert(ctx context.Context, key, op string, pivot, value interface{}) *IntCmd LInsertBefore(ctx context.Context, key string, pivot, value interface{}) *IntCmd LInsertAfter(ctx context.Context, key string, pivot, value interface{}) *IntCmd LLen(ctx context.Context, key string) *IntCmd LPop(ctx context.Context, key string) *StringCmd LPopCount(ctx context.Context, key string, count int64) *StringSliceCmd LPos(ctx context.Context, key string, value string, args LPosArgs) *IntCmd LPosCount(ctx context.Context, key string, value string, count int64, args LPosArgs) *IntSliceCmd LPush(ctx context.Context, key string, values ...interface{}) *IntCmd LPushX(ctx context.Context, key string, values ...interface{}) *IntCmd LRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd LRem(ctx context.Context, key string, count int64, value interface{}) *IntCmd LSet(ctx context.Context, key string, index int64, value interface{}) *StatusCmd LTrim(ctx context.Context, key string, start, stop int64) *StatusCmd RPop(ctx context.Context, key string) *StringCmd RPopCount(ctx context.Context, key string, count int64) *StringSliceCmd RPopLPush(ctx context.Context, source, destination string) *StringCmd RPush(ctx context.Context, key string, values ...interface{}) *IntCmd RPushX(ctx context.Context, key string, values ...interface{}) *IntCmd LMove(ctx context.Context, source, destination, srcpos, destpos string) *StringCmd BLMove(ctx context.Context, source, destination, srcpos, destpos string, timeout time.Duration) *StringCmd SAdd(ctx context.Context, key string, members ...interface{}) *IntCmd SCard(ctx context.Context, key string) *IntCmd SDiff(ctx context.Context, keys ...string) *StringSliceCmd SDiffStore(ctx context.Context, destination string, keys ...string) *IntCmd SInter(ctx context.Context, keys ...string) *StringSliceCmd SInterStore(ctx context.Context, destination string, keys ...string) *IntCmd SIsMember(ctx context.Context, key string, member interface{}) *BoolCmd SMIsMember(ctx context.Context, key string, members ...interface{}) *BoolSliceCmd SMembers(ctx context.Context, key string) *StringSliceCmd SMembersMap(ctx context.Context, key string) *StringStructMapCmd SMove(ctx context.Context, source, destination string, member interface{}) *BoolCmd SPop(ctx context.Context, key string) *StringCmd SPopN(ctx context.Context, key string, count int64) *StringSliceCmd SRandMember(ctx context.Context, key string) *StringCmd SRandMemberN(ctx context.Context, key string, count int64) *StringSliceCmd SRem(ctx context.Context, key string, members ...interface{}) *IntCmd SUnion(ctx context.Context, keys ...string) *StringSliceCmd SUnionStore(ctx context.Context, destination string, keys ...string) *IntCmd XAdd(ctx context.Context, a XAddArgs) *StringCmd XDel(ctx context.Context, stream string, ids ...string) *IntCmd XLen(ctx context.Context, stream string) *IntCmd XRange(ctx context.Context, stream, start, stop string) *XMessageSliceCmd XRangeN(ctx context.Context, stream, start, stop string, count int64) *XMessageSliceCmd XRevRange(ctx context.Context, stream, start, stop string) *XMessageSliceCmd XRevRangeN(ctx context.Context, stream string, start, stop string, count int64) *XMessageSliceCmd XRead(ctx context.Context, a XReadArgs) *XStreamSliceCmd XReadStreams(ctx context.Context, streams ...string) *XStreamSliceCmd XGroupCreate(ctx context.Context, stream, group, start string) *StatusCmd XGroupCreateMkStream(ctx context.Context, stream, group, start string) *StatusCmd XGroupSetID(ctx context.Context, stream, group, start string) *StatusCmd XGroupDestroy(ctx context.Context, stream, group string) *IntCmd XGroupCreateConsumer(ctx context.Context, stream, group, consumer string) *IntCmd XGroupDelConsumer(ctx context.Context, stream, group, consumer string) *IntCmd XReadGroup(ctx context.Context, a XReadGroupArgs) *XStreamSliceCmd XAck(ctx context.Context, stream, group string, ids ...string) *IntCmd XPending(ctx context.Context, stream, group string) *XPendingCmd XPendingExt(ctx context.Context, a XPendingExtArgs) *XPendingExtCmd XClaim(ctx context.Context, a XClaimArgs) *XMessageSliceCmd XClaimJustID(ctx context.Context, a XClaimArgs) *StringSliceCmd XAutoClaim(ctx context.Context, a XAutoClaimArgs) *XAutoClaimCmd XAutoClaimJustID(ctx context.Context, a XAutoClaimArgs) *XAutoClaimJustIDCmd XTrimMaxLen(ctx context.Context, key string, maxLen int64) *IntCmd XTrimMaxLenApprox(ctx context.Context, key string, maxLen, limit int64) *IntCmd XTrimMinID(ctx context.Context, key string, minID string) *IntCmd XTrimMinIDApprox(ctx context.Context, key string, minID string, limit int64) *IntCmd XInfoGroups(ctx context.Context, key string) *XInfoGroupsCmd XInfoStream(ctx context.Context, key string) *XInfoStreamCmd XInfoStreamFull(ctx context.Context, key string, count int64) *XInfoStreamFullCmd XInfoConsumers(ctx context.Context, key string, group string) *XInfoConsumersCmd BZPopMax(ctx context.Context, timeout time.Duration, keys ...string) *ZWithKeyCmd BZPopMin(ctx context.Context, timeout time.Duration, keys ...string) *ZWithKeyCmd ZAdd(ctx context.Context, key string, members ...Z) *IntCmd ZAddNX(ctx context.Context, key string, members ...Z) *IntCmd ZAddXX(ctx context.Context, key string, members ...Z) *IntCmd ZAddArgs(ctx context.Context, key string, args ZAddArgs) *IntCmd ZAddArgsIncr(ctx context.Context, key string, args ZAddArgs) *FloatCmd ZCard(ctx context.Context, key string) *IntCmd ZCount(ctx context.Context, key string, min, max string) *IntCmd ZLexCount(ctx context.Context, key, min, max string) *IntCmd ZIncrBy(ctx context.Context, key string, increment float64, member string) *FloatCmd ZInter(ctx context.Context, store ZStore) *StringSliceCmd ZInterWithScores(ctx context.Context, store ZStore) *ZSliceCmd ZInterStore(ctx context.Context, destination string, store ZStore) *IntCmd ZMScore(ctx context.Context, key string, members ...string) *FloatSliceCmd ZPopMax(ctx context.Context, key string, count ...int64) *ZSliceCmd ZPopMin(ctx context.Context, key string, count ...int64) *ZSliceCmd ZRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd ZRangeWithScores(ctx context.Context, key string, start, stop int64) *ZSliceCmd ZRangeByScore(ctx context.Context, key string, opt ZRangeBy) *StringSliceCmd ZRangeByLex(ctx context.Context, key string, opt ZRangeBy) *StringSliceCmd ZRangeByScoreWithScores(ctx context.Context, key string, opt ZRangeBy) *ZSliceCmd ZRangeArgs(ctx context.Context, z ZRangeArgs) *StringSliceCmd ZRangeArgsWithScores(ctx context.Context, z ZRangeArgs) *ZSliceCmd ZRangeStore(ctx context.Context, dst string, z ZRangeArgs) *IntCmd ZRank(ctx context.Context, key, member string) *IntCmd ZRem(ctx context.Context, key string, members ...interface{}) *IntCmd ZRemRangeByRank(ctx context.Context, key string, start, stop int64) *IntCmd ZRemRangeByScore(ctx context.Context, key string, min, max string) *IntCmd ZRemRangeByLex(ctx context.Context, key, min, max string) *IntCmd ZRevRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd ZRevRangeWithScores(ctx context.Context, key string, start, stop int64) *ZSliceCmd ZRevRangeByScore(ctx context.Context, key string, opt ZRangeBy) *StringSliceCmd ZRevRangeByLex(ctx context.Context, key string, opt ZRangeBy) *StringSliceCmd ZRevRangeByScoreWithScores(ctx context.Context, key string, opt ZRangeBy) *ZSliceCmd ZRevRank(ctx context.Context, key, member string) *IntCmd ZScore(ctx context.Context, key, member string) *FloatCmd ZUnionStore(ctx context.Context, dest string, store ZStore) *IntCmd ZUnion(ctx context.Context, store ZStore) *StringSliceCmd ZUnionWithScores(ctx context.Context, store ZStore) *ZSliceCmd ZRandMember(ctx context.Context, key string, count int64) *StringSliceCmd ZRandMemberWithScores(ctx context.Context, key string, count int64) *ZSliceCmd ZDiff(ctx context.Context, keys ...string) *StringSliceCmd ZDiffWithScores(ctx context.Context, keys ...string) *ZSliceCmd ZDiffStore(ctx context.Context, destination string, keys ...string) *IntCmd PFAdd(ctx context.Context, key string, els ...interface{}) *IntCmd PFCount(ctx context.Context, keys ...string) *IntCmd PFMerge(ctx context.Context, dest string, keys ...string) *StatusCmd BgRewriteAOF(ctx context.Context) *StatusCmd BgSave(ctx context.Context) *StatusCmd ClientKill(ctx context.Context, ipPort string) *StatusCmd ClientKillByFilter(ctx context.Context, keys ...string) *IntCmd ClientList(ctx context.Context) *StringCmd ClientPause(ctx context.Context, dur time.Duration) *BoolCmd ClientUnpause(ctx context.Context) *BoolCmd ClientID(ctx context.Context) *IntCmd ConfigGet(ctx context.Context, parameter string) *SliceCmd ConfigResetStat(ctx context.Context) *StatusCmd ConfigSet(ctx context.Context, parameter, value string) *StatusCmd ConfigRewrite(ctx context.Context) *StatusCmd DBSize(ctx context.Context) *IntCmd FlushAll(ctx context.Context) *StatusCmd FlushAllAsync(ctx context.Context) *StatusCmd FlushDB(ctx context.Context) *StatusCmd FlushDBAsync(ctx context.Context) *StatusCmd Info(ctx context.Context, section ...string) *StringCmd LastSave(ctx context.Context) *IntCmd Save(ctx context.Context) *StatusCmd Shutdown(ctx context.Context) *StatusCmd ShutdownSave(ctx context.Context) *StatusCmd ShutdownNoSave(ctx context.Context) *StatusCmd SlaveOf(ctx context.Context, host string, port string) *StatusCmd Time(ctx context.Context) *TimeCmd DebugObject(ctx context.Context, key string) *StringCmd ReadOnly(ctx context.Context) *StatusCmd ReadWrite(ctx context.Context) *StatusCmd MemoryUsage(ctx context.Context, key string, samples ...int64) *IntCmd Eval(ctx context.Context, script string, keys []string, args ...interface{}) *Cmd EvalSha(ctx context.Context, sha1 string, keys []string, args ...interface{}) *Cmd ScriptExists(ctx context.Context, hashes ...string) *BoolSliceCmd ScriptFlush(ctx context.Context) *StatusCmd ScriptKill(ctx context.Context) *StatusCmd ScriptLoad(ctx context.Context, script string) *StringCmd Publish(ctx context.Context, channel string, message interface{}) *IntCmd PubSubChannels(ctx context.Context, pattern string) *StringSliceCmd PubSubNumSub(ctx context.Context, channels ...string) *StringIntMapCmd PubSubNumPat(ctx context.Context) *IntCmd ClusterSlots(ctx context.Context) *ClusterSlotsCmd ClusterNodes(ctx context.Context) *StringCmd ClusterMeet(ctx context.Context, host string, port int64) *StatusCmd ClusterForget(ctx context.Context, nodeID string) *StatusCmd ClusterReplicate(ctx context.Context, nodeID string) *StatusCmd ClusterResetSoft(ctx context.Context) *StatusCmd ClusterResetHard(ctx context.Context) *StatusCmd ClusterInfo(ctx context.Context) *StringCmd ClusterKeySlot(ctx context.Context, key string) *IntCmd ClusterGetKeysInSlot(ctx context.Context, slot int64, count int64) *StringSliceCmd ClusterCountFailureReports(ctx context.Context, nodeID string) *IntCmd ClusterCountKeysInSlot(ctx context.Context, slot int64) *IntCmd ClusterDelSlots(ctx context.Context, slots ...int64) *StatusCmd ClusterDelSlotsRange(ctx context.Context, min, max int64) *StatusCmd ClusterSaveConfig(ctx context.Context) *StatusCmd ClusterSlaves(ctx context.Context, nodeID string) *StringSliceCmd ClusterFailover(ctx context.Context) *StatusCmd ClusterAddSlots(ctx context.Context, slots ...int64) *StatusCmd ClusterAddSlotsRange(ctx context.Context, min, max int64) *StatusCmd GeoAdd(ctx context.Context, key string, geoLocation ...GeoLocation) *IntCmd GeoPos(ctx context.Context, key string, members ...string) *GeoPosCmd GeoRadius(ctx context.Context, key string, longitude, latitude float64, query GeoRadiusQuery) *GeoLocationCmd GeoRadiusStore(ctx context.Context, key string, longitude, latitude float64, query GeoRadiusQuery) *IntCmd GeoRadiusByMember(ctx context.Context, key, member string, query GeoRadiusQuery) *GeoLocationCmd GeoRadiusByMemberStore(ctx context.Context, key, member string, query GeoRadiusQuery) *IntCmd GeoSearch(ctx context.Context, key string, q GeoSearchQuery) *StringSliceCmd GeoSearchLocation(ctx context.Context, key string, q GeoSearchLocationQuery) *GeoLocationCmd GeoSearchStore(ctx context.Context, src, dest string, q GeoSearchStoreQuery) *IntCmd GeoDist(ctx context.Context, key, member1, member2, unit string) *FloatCmd GeoHash(ctx context.Context, key string, members ...string) *StringSliceCmd }
func NewAdapter ¶
type CommandInfo ¶
type CommandsInfoCmd ¶
type CommandsInfoCmd struct {
// contains filtered or unexported fields
}
func (*CommandsInfoCmd) Err ¶
func (cmd *CommandsInfoCmd) Err() error
func (*CommandsInfoCmd) Result ¶
func (cmd *CommandsInfoCmd) Result() (map[string]CommandInfo, error)
func (*CommandsInfoCmd) SetErr ¶
func (cmd *CommandsInfoCmd) SetErr(err error)
func (*CommandsInfoCmd) SetVal ¶
func (cmd *CommandsInfoCmd) SetVal(val map[string]CommandInfo)
func (*CommandsInfoCmd) Val ¶
func (cmd *CommandsInfoCmd) Val() map[string]CommandInfo
type Compat ¶
type Compat struct {
// contains filtered or unexported fields
}
func (*Compat) BRPopLPush ¶
func (*Compat) BitField ¶
func (c *Compat) BitField(ctx context.Context, key string, args ...interface{}) *IntSliceCmd
func (*Compat) ClientKill ¶
func (*Compat) ClientKillByFilter ¶
func (*Compat) ClientPause ¶
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) ClusterSlaves ¶
func (c *Compat) ClusterSlaves(ctx context.Context, nodeID string) *StringSliceCmd
func (*Compat) ClusterSlots ¶
func (c *Compat) ClusterSlots(ctx context.Context) *ClusterSlotsCmd
func (*Compat) DebugObject ¶
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) IncrByFloat ¶
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) 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) RestoreReplace ¶
func (*Compat) SDiffStore ¶
func (*Compat) SInter ¶
func (c *Compat) SInter(ctx context.Context, keys ...string) *StringSliceCmd
func (*Compat) SInterStore ¶
func (*Compat) SMIsMember ¶
func (c *Compat) SMIsMember(ctx context.Context, key string, members ...interface{}) *BoolSliceCmd
func (*Compat) SMembers ¶
func (c *Compat) SMembers(ctx context.Context, key string) *StringSliceCmd
func (*Compat) SMembersMap ¶
func (c *Compat) SMembersMap(ctx context.Context, key string) *StringStructMapCmd
func (*Compat) SRandMember ¶
func (*Compat) SRandMemberN ¶
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 interface{}, expiration time.Duration) *StatusCmd
Set key value [expiration]
For no expiration use 0.
For KEEPTTL use -1.
For more options, use SetArgs.
func (*Compat) SortInterfaces ¶
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) 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) ZRemRangeByLex ¶
func (*Compat) ZRemRangeByRank ¶
func (*Compat) ZRemRangeByScore ¶
func (*Compat) ZRevRangeByLex ¶
func (*Compat) ZRevRangeByScore ¶
func (*Compat) ZRevRangeByScoreWithScores ¶
func (*Compat) ZRevRangeWithScores ¶
func (*Compat) ZUnionStore ¶
type DurationCmd ¶
type DurationCmd struct {
// contains filtered or unexported fields
}
func (*DurationCmd) Err ¶
func (cmd *DurationCmd) Err() error
func (*DurationCmd) SetErr ¶
func (cmd *DurationCmd) SetErr(err error)
func (*DurationCmd) SetVal ¶
func (cmd *DurationCmd) SetVal(val time.Duration)
func (*DurationCmd) Val ¶
func (cmd *DurationCmd) Val() time.Duration
type FloatSliceCmd ¶
type FloatSliceCmd struct {
// contains filtered or unexported fields
}
func (*FloatSliceCmd) Err ¶
func (cmd *FloatSliceCmd) Err() error
func (*FloatSliceCmd) Result ¶
func (cmd *FloatSliceCmd) Result() ([]float64, error)
func (*FloatSliceCmd) SetErr ¶
func (cmd *FloatSliceCmd) SetErr(err error)
func (*FloatSliceCmd) SetVal ¶
func (cmd *FloatSliceCmd) SetVal(val []float64)
func (*FloatSliceCmd) Val ¶
func (cmd *FloatSliceCmd) Val() []float64
type GeoLocation ¶
type GeoLocationCmd ¶
type GeoLocationCmd struct {
// contains filtered or unexported fields
}
func (*GeoLocationCmd) Err ¶
func (cmd *GeoLocationCmd) Err() error
func (*GeoLocationCmd) Result ¶
func (cmd *GeoLocationCmd) Result() ([]GeoLocation, error)
func (*GeoLocationCmd) SetErr ¶
func (cmd *GeoLocationCmd) SetErr(err error)
func (*GeoLocationCmd) SetVal ¶
func (cmd *GeoLocationCmd) SetVal(val []GeoLocation)
func (*GeoLocationCmd) Val ¶
func (cmd *GeoLocationCmd) Val() []GeoLocation
type GeoRadiusQuery ¶
type GeoRadiusQuery struct { Radius float64 // Can be m, km, ft, or mi. Default is km. Unit string WithCoord bool WithDist bool WithGeoHash bool Count int64 // Can be ASC or DESC. Default is no sort order. Sort string Store string StoreDist string }
GeoRadiusQuery is used with GeoRadius to query geospatial index.
type GeoSearchLocationQuery ¶
type GeoSearchLocationQuery struct { GeoSearchQuery WithCoord bool WithDist bool WithHash bool }
type GeoSearchQuery ¶
type GeoSearchQuery struct { Member string // Latitude and Longitude when using FromLonLat option. Longitude float64 Latitude float64 // Distance and unit when using ByRadius option. // Can use m, km, ft, or mi. Default is km. Radius float64 RadiusUnit string // Height, width and unit when using ByBox option. // Can be m, km, ft, or mi. Default is km. BoxWidth float64 BoxHeight float64 BoxUnit string // Can be ASC or DESC. Default is no sort order. Sort string Count int64 CountAny bool }
GeoSearchQuery is used for GEOSearch/GEOSearchStore command query.
type GeoSearchStoreQuery ¶
type GeoSearchStoreQuery struct { GeoSearchQuery // When using the StoreDist option, the command stores the items in a // sorted set populated with their distance from the center of the circle or box, // as a floating-point number, in the same unit specified for that shape. StoreDist bool }
type 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 SetArgs ¶
type SetArgs struct { // Mode can be `NX` or `XX` or empty. Mode string // Zero `TTL` or `Expiration` means that the key has no expiration time. TTL time.Duration ExpireAt time.Time // When Get is true, the command returns the old value stored at key, or nil when key did not exist. Get bool // KeepTTL is a Redis KEEPTTL option to keep existing TTL, it requires your redis-server version >= 6.0, // otherwise you will receive an error: (error) ERR syntax error. KeepTTL bool }
SetArgs provides arguments for the SetArgs function.
type StringIntMapCmd ¶
type StringIntMapCmd struct {
// contains filtered or unexported fields
}
func (*StringIntMapCmd) Err ¶
func (cmd *StringIntMapCmd) Err() error
func (*StringIntMapCmd) SetErr ¶
func (cmd *StringIntMapCmd) SetErr(err error)
func (*StringIntMapCmd) SetVal ¶
func (cmd *StringIntMapCmd) SetVal(val map[string]int64)
func (*StringIntMapCmd) Val ¶
func (cmd *StringIntMapCmd) Val() map[string]int64
type StringSliceCmd ¶
type StringSliceCmd struct {
// contains filtered or unexported fields
}
func (*StringSliceCmd) Err ¶
func (cmd *StringSliceCmd) Err() error
func (*StringSliceCmd) Result ¶
func (cmd *StringSliceCmd) Result() ([]string, error)
func (*StringSliceCmd) SetErr ¶
func (cmd *StringSliceCmd) SetErr(err error)
func (*StringSliceCmd) SetVal ¶
func (cmd *StringSliceCmd) SetVal(val []string)
func (*StringSliceCmd) Val ¶
func (cmd *StringSliceCmd) Val() []string
type StringStringMapCmd ¶
type StringStringMapCmd struct {
// contains filtered or unexported fields
}
func (*StringStringMapCmd) Err ¶
func (cmd *StringStringMapCmd) Err() error
func (*StringStringMapCmd) Result ¶
func (cmd *StringStringMapCmd) Result() (map[string]string, error)
func (*StringStringMapCmd) SetErr ¶
func (cmd *StringStringMapCmd) SetErr(err error)
func (*StringStringMapCmd) SetVal ¶
func (cmd *StringStringMapCmd) SetVal(val map[string]string)
func (*StringStringMapCmd) Val ¶
func (cmd *StringStringMapCmd) Val() map[string]string
type StringStructMapCmd ¶
type StringStructMapCmd struct {
// contains filtered or unexported fields
}
func (*StringStructMapCmd) Err ¶
func (cmd *StringStructMapCmd) Err() error
func (*StringStructMapCmd) Result ¶
func (cmd *StringStructMapCmd) Result() (map[string]struct{}, error)
func (*StringStructMapCmd) SetErr ¶
func (cmd *StringStructMapCmd) SetErr(err error)
func (*StringStructMapCmd) SetVal ¶
func (cmd *StringStructMapCmd) SetVal(val map[string]struct{})
func (*StringStructMapCmd) Val ¶
func (cmd *StringStructMapCmd) Val() map[string]struct{}
type XAddArgs ¶
type XAddArgs struct { Stream string NoMkStream bool MaxLen int64 // MAXLEN N MinID string // Approx causes MaxLen and MinID to use "~" matcher (instead of "="). Approx bool Limit int64 ID string Values interface{} }
Note: MaxLen/MaxLenApprox and MinID are in conflict, only one of them can be used.
type XAutoClaimArgs ¶
type 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
}
func (*XInfoConsumersCmd) Err ¶
func (cmd *XInfoConsumersCmd) Err() error
func (*XInfoConsumersCmd) Result ¶
func (cmd *XInfoConsumersCmd) Result() ([]XInfoConsumer, error)
func (*XInfoConsumersCmd) SetErr ¶
func (cmd *XInfoConsumersCmd) SetErr(err error)
func (*XInfoConsumersCmd) SetVal ¶
func (cmd *XInfoConsumersCmd) SetVal(val []XInfoConsumer)
func (*XInfoConsumersCmd) Val ¶
func (cmd *XInfoConsumersCmd) Val() []XInfoConsumer
type XInfoGroup ¶
type XInfoGroupsCmd ¶
type XInfoGroupsCmd struct {
// contains filtered or unexported fields
}
func (*XInfoGroupsCmd) Err ¶
func (cmd *XInfoGroupsCmd) Err() error
func (*XInfoGroupsCmd) Result ¶
func (cmd *XInfoGroupsCmd) Result() ([]XInfoGroup, error)
func (*XInfoGroupsCmd) SetErr ¶
func (cmd *XInfoGroupsCmd) SetErr(err error)
func (*XInfoGroupsCmd) SetVal ¶
func (cmd *XInfoGroupsCmd) SetVal(val []XInfoGroup)
func (*XInfoGroupsCmd) Val ¶
func (cmd *XInfoGroupsCmd) Val() []XInfoGroup
type XInfoStream ¶
type XInfoStreamCmd ¶
type XInfoStreamCmd struct {
// contains filtered or unexported fields
}
func (*XInfoStreamCmd) Err ¶
func (cmd *XInfoStreamCmd) Err() error
func (*XInfoStreamCmd) Result ¶
func (cmd *XInfoStreamCmd) Result() (XInfoStream, error)
func (*XInfoStreamCmd) SetErr ¶
func (cmd *XInfoStreamCmd) SetErr(err error)
func (*XInfoStreamCmd) SetVal ¶
func (cmd *XInfoStreamCmd) SetVal(val XInfoStream)
func (*XInfoStreamCmd) Val ¶
func (cmd *XInfoStreamCmd) Val() XInfoStream
type XInfoStreamConsumer ¶
type XInfoStreamConsumer struct { Name string SeenTime time.Time PelCount int64 Pending []XInfoStreamConsumerPending }
type XInfoStreamFull ¶
type XInfoStreamFullCmd ¶
type XInfoStreamFullCmd struct {
// contains filtered or unexported fields
}
func (*XInfoStreamFullCmd) Err ¶
func (cmd *XInfoStreamFullCmd) Err() error
func (*XInfoStreamFullCmd) Result ¶
func (cmd *XInfoStreamFullCmd) Result() (XInfoStreamFull, error)
func (*XInfoStreamFullCmd) SetErr ¶
func (cmd *XInfoStreamFullCmd) SetErr(err error)
func (*XInfoStreamFullCmd) SetVal ¶
func (cmd *XInfoStreamFullCmd) SetVal(val XInfoStreamFull)
func (*XInfoStreamFullCmd) Val ¶
func (cmd *XInfoStreamFullCmd) Val() XInfoStreamFull
type XInfoStreamGroup ¶
type XInfoStreamGroup struct { Name string LastDeliveredID string EntriesRead int64 Lag int64 PelCount int64 Pending []XInfoStreamGroupPending Consumers []XInfoStreamConsumer }
type XInfoStreamGroupPending ¶
type XMessageSliceCmd ¶
type XMessageSliceCmd struct {
// contains filtered or unexported fields
}
func (*XMessageSliceCmd) Err ¶
func (cmd *XMessageSliceCmd) Err() error
func (*XMessageSliceCmd) Result ¶
func (cmd *XMessageSliceCmd) Result() ([]XMessage, error)
func (*XMessageSliceCmd) SetErr ¶
func (cmd *XMessageSliceCmd) SetErr(err error)
func (*XMessageSliceCmd) SetVal ¶
func (cmd *XMessageSliceCmd) SetVal(val []XMessage)
func (*XMessageSliceCmd) Val ¶
func (cmd *XMessageSliceCmd) Val() []XMessage
type XPendingCmd ¶
type XPendingCmd struct {
// contains filtered or unexported fields
}
func (*XPendingCmd) Err ¶
func (cmd *XPendingCmd) Err() error
func (*XPendingCmd) Result ¶
func (cmd *XPendingCmd) Result() (XPending, error)
func (*XPendingCmd) SetErr ¶
func (cmd *XPendingCmd) SetErr(err error)
func (*XPendingCmd) SetVal ¶
func (cmd *XPendingCmd) SetVal(val XPending)
func (*XPendingCmd) Val ¶
func (cmd *XPendingCmd) Val() XPending
type XPendingExt ¶
type XPendingExtArgs ¶
type XPendingExtCmd ¶
type XPendingExtCmd struct {
// contains filtered or unexported fields
}
func (*XPendingExtCmd) Err ¶
func (cmd *XPendingExtCmd) Err() error
func (*XPendingExtCmd) Result ¶
func (cmd *XPendingExtCmd) Result() ([]XPendingExt, error)
func (*XPendingExtCmd) SetErr ¶
func (cmd *XPendingExtCmd) SetErr(err error)
func (*XPendingExtCmd) SetVal ¶
func (cmd *XPendingExtCmd) SetVal(val []XPendingExt)
func (*XPendingExtCmd) Val ¶
func (cmd *XPendingExtCmd) Val() []XPendingExt
type XReadGroupArgs ¶
type XStreamSliceCmd ¶
type XStreamSliceCmd struct {
// contains filtered or unexported fields
}
func (*XStreamSliceCmd) Err ¶
func (cmd *XStreamSliceCmd) Err() error
func (*XStreamSliceCmd) Result ¶
func (cmd *XStreamSliceCmd) Result() ([]XStream, error)
func (*XStreamSliceCmd) SetErr ¶
func (cmd *XStreamSliceCmd) SetErr(err error)
func (*XStreamSliceCmd) SetVal ¶
func (cmd *XStreamSliceCmd) SetVal(val []XStream)
func (*XStreamSliceCmd) Val ¶
func (cmd *XStreamSliceCmd) Val() []XStream
type ZRangeArgs ¶
type ZRangeArgs struct { Key string Start interface{} Stop interface{} // The ByScore and ByLex options are mutually exclusive. ByScore bool ByLex bool Rev bool // limit offset count. Offset int64 Count int64 }
ZRangeArgs is all the options of the ZRange command. In version> 6.2.0, you can replace the(cmd):
ZREVRANGE, ZRANGEBYSCORE, ZREVRANGEBYSCORE, ZRANGEBYLEX, ZREVRANGEBYLEX.
Please pay attention to your redis-server version.
Rev, ByScore, ByLex and Offset+Count options require redis-server 6.2.0 and higher.
type 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
}
func (*ZWithKeyCmd) Err ¶
func (cmd *ZWithKeyCmd) Err() error
func (*ZWithKeyCmd) Result ¶
func (cmd *ZWithKeyCmd) Result() (ZWithKey, error)
func (*ZWithKeyCmd) SetErr ¶
func (cmd *ZWithKeyCmd) SetErr(err error)
func (*ZWithKeyCmd) SetVal ¶
func (cmd *ZWithKeyCmd) SetVal(val ZWithKey)
func (*ZWithKeyCmd) Val ¶
func (cmd *ZWithKeyCmd) Val() ZWithKey