Documentation
¶
Index ¶
- type Conf
- type Redis
- func (r *Redis) ACLDryRun(ctx context.Context, username string, command ...interface{}) *redis.StringCmd
- func (r *Redis) ACLLog(ctx context.Context, count int64) *redis.ACLLogCmd
- func (r *Redis) ACLLogReset(ctx context.Context) *redis.StatusCmd
- func (r *Redis) Append(ctx context.Context, key, value string) *redis.IntCmd
- func (r *Redis) BFAdd(ctx context.Context, key string, element interface{}) *redis.BoolCmd
- func (r *Redis) BFCard(ctx context.Context, key string) *redis.IntCmd
- func (r *Redis) BFExists(ctx context.Context, key string, element interface{}) *redis.BoolCmd
- func (r *Redis) BFInfo(ctx context.Context, key string) *redis.BFInfoCmd
- func (r *Redis) BFInfoArg(ctx context.Context, key string, option string) *redis.BFInfoCmd
- func (r *Redis) BFInfoCapacity(ctx context.Context, key string) *redis.BFInfoCmd
- func (r *Redis) BFInfoExpansion(ctx context.Context, key string) *redis.BFInfoCmd
- func (r *Redis) BFInfoFilters(ctx context.Context, key string) *redis.BFInfoCmd
- func (r *Redis) BFInfoItems(ctx context.Context, key string) *redis.BFInfoCmd
- func (r *Redis) BFInfoSize(ctx context.Context, key string) *redis.BFInfoCmd
- func (r *Redis) BFInsert(ctx context.Context, key string, options *redis.BFInsertOptions, ...) *redis.BoolSliceCmd
- func (r *Redis) BFLoadChunk(ctx context.Context, key string, iterator int64, data interface{}) *redis.StatusCmd
- func (r *Redis) BFMAdd(ctx context.Context, key string, elements ...interface{}) *redis.BoolSliceCmd
- func (r *Redis) BFMExists(ctx context.Context, key string, elements ...interface{}) *redis.BoolSliceCmd
- func (r *Redis) BFReserve(ctx context.Context, key string, errorRate float64, capacity int64) *redis.StatusCmd
- func (r *Redis) BFReserveArgs(ctx context.Context, key string, options *redis.BFReserveOptions) *redis.StatusCmd
- func (r *Redis) BFReserveExpansion(ctx context.Context, key string, errorRate float64, capacity int64, ...) *redis.StatusCmd
- func (r *Redis) BFReserveNonScaling(ctx context.Context, key string, errorRate float64, capacity int64) *redis.StatusCmd
- func (r *Redis) BFScanDump(ctx context.Context, key string, iterator int64) *redis.ScanDumpCmd
- func (r *Redis) BLMPop(ctx context.Context, timeout time.Duration, direction string, count int64, ...) *redis.KeyValuesCmd
- func (r *Redis) BLMove(ctx context.Context, source string, destination string, srcpos string, ...) *redis.StringCmd
- func (r *Redis) BLPop(ctx context.Context, timeout time.Duration, keys ...string) *redis.StringSliceCmd
- func (r *Redis) BRPop(ctx context.Context, timeout time.Duration, keys ...string) *redis.StringSliceCmd
- func (r *Redis) BRPopLPush(ctx context.Context, source, destination string, timeout time.Duration) *redis.StringCmd
- func (r *Redis) BZMPop(ctx context.Context, timeout time.Duration, order string, count int64, ...) *redis.ZSliceWithKeyCmd
- func (r *Redis) BZPopMax(ctx context.Context, timeout time.Duration, keys ...string) *redis.ZWithKeyCmd
- func (r *Redis) BZPopMin(ctx context.Context, timeout time.Duration, keys ...string) *redis.ZWithKeyCmd
- func (r *Redis) BgRewriteAOF(ctx context.Context) *redis.StatusCmd
- func (r *Redis) BgSave(ctx context.Context) *redis.StatusCmd
- func (r *Redis) BitCount(ctx context.Context, key string, bitCount *redis.BitCount) *redis.IntCmd
- func (r *Redis) BitField(ctx context.Context, key string, args ...interface{}) *redis.IntSliceCmd
- func (r *Redis) BitOpAnd(ctx context.Context, destKey string, keys ...string) *redis.IntCmd
- func (r *Redis) BitOpNot(ctx context.Context, destKey string, key string) *redis.IntCmd
- func (r *Redis) BitOpOr(ctx context.Context, destKey string, keys ...string) *redis.IntCmd
- func (r *Redis) BitOpXor(ctx context.Context, destKey string, keys ...string) *redis.IntCmd
- func (r *Redis) BitPos(ctx context.Context, key string, bit int64, pos ...int64) *redis.IntCmd
- func (r *Redis) BitPosSpan(ctx context.Context, key string, bit int8, start int64, end int64, span string) *redis.IntCmd
- func (r *Redis) CFAdd(ctx context.Context, key string, element interface{}) *redis.BoolCmd
- func (r *Redis) CFAddNX(ctx context.Context, key string, element interface{}) *redis.BoolCmd
- func (r *Redis) CFCount(ctx context.Context, key string, element interface{}) *redis.IntCmd
- func (r *Redis) CFDel(ctx context.Context, key string, element interface{}) *redis.BoolCmd
- func (r *Redis) CFExists(ctx context.Context, key string, element interface{}) *redis.BoolCmd
- func (r *Redis) CFInfo(ctx context.Context, key string) *redis.CFInfoCmd
- func (r *Redis) CFInsert(ctx context.Context, key string, options *redis.CFInsertOptions, ...) *redis.BoolSliceCmd
- func (r *Redis) CFInsertNX(ctx context.Context, key string, options *redis.CFInsertOptions, ...) *redis.IntSliceCmd
- func (r *Redis) CFLoadChunk(ctx context.Context, key string, iterator int64, data interface{}) *redis.StatusCmd
- func (r *Redis) CFMExists(ctx context.Context, key string, elements ...interface{}) *redis.BoolSliceCmd
- func (r *Redis) CFReserve(ctx context.Context, key string, capacity int64) *redis.StatusCmd
- func (r *Redis) CFReserveArgs(ctx context.Context, key string, options *redis.CFReserveOptions) *redis.StatusCmd
- func (r *Redis) CFReserveBucketSize(ctx context.Context, key string, capacity int64, bucketsize int64) *redis.StatusCmd
- func (r *Redis) CFReserveExpansion(ctx context.Context, key string, capacity int64, expansion int64) *redis.StatusCmd
- func (r *Redis) CFReserveMaxIterations(ctx context.Context, key string, capacity int64, maxiterations int64) *redis.StatusCmd
- func (r *Redis) CFScanDump(ctx context.Context, key string, iterator int64) *redis.ScanDumpCmd
- func (r *Redis) CMSIncrBy(ctx context.Context, key string, elements ...interface{}) *redis.IntSliceCmd
- func (r *Redis) CMSInfo(ctx context.Context, key string) *redis.CMSInfoCmd
- func (r *Redis) CMSInitByDim(ctx context.Context, key string, width int64, height int64) *redis.StatusCmd
- func (r *Redis) CMSInitByProb(ctx context.Context, key string, errorRate float64, probability float64) *redis.StatusCmd
- func (r *Redis) CMSMerge(ctx context.Context, destKey string, sourceKeys ...string) *redis.StatusCmd
- func (r *Redis) CMSMergeWithWeight(ctx context.Context, destKey string, sourceKeys map[string]int64) *redis.StatusCmd
- func (r *Redis) CMSQuery(ctx context.Context, key string, elements ...interface{}) *redis.IntSliceCmd
- func (r *Redis) ClientGetName(ctx context.Context) *redis.StringCmd
- func (r *Redis) ClientID(ctx context.Context) *redis.IntCmd
- func (r *Redis) ClientInfo(ctx context.Context) *redis.ClientInfoCmd
- func (r *Redis) ClientKill(ctx context.Context, ipPort string) *redis.StatusCmd
- func (r *Redis) ClientKillByFilter(ctx context.Context, keys ...string) *redis.IntCmd
- func (r *Redis) ClientList(ctx context.Context) *redis.StringCmd
- func (r *Redis) ClientPause(ctx context.Context, dur time.Duration) *redis.BoolCmd
- func (r *Redis) ClientUnblock(ctx context.Context, id int64) *redis.IntCmd
- func (r *Redis) ClientUnblockWithError(ctx context.Context, id int64) *redis.IntCmd
- func (r *Redis) ClientUnpause(ctx context.Context) *redis.BoolCmd
- func (r *Redis) ClusterAddSlots(ctx context.Context, slots ...int) *redis.StatusCmd
- func (r *Redis) ClusterAddSlotsRange(ctx context.Context, min, max int) *redis.StatusCmd
- func (r *Redis) ClusterCountFailureReports(ctx context.Context, nodeID string) *redis.IntCmd
- func (r *Redis) ClusterCountKeysInSlot(ctx context.Context, slot int) *redis.IntCmd
- func (r *Redis) ClusterDelSlots(ctx context.Context, slots ...int) *redis.StatusCmd
- func (r *Redis) ClusterDelSlotsRange(ctx context.Context, min, max int) *redis.StatusCmd
- func (r *Redis) ClusterFailover(ctx context.Context) *redis.StatusCmd
- func (r *Redis) ClusterForget(ctx context.Context, nodeID string) *redis.StatusCmd
- func (r *Redis) ClusterGetKeysInSlot(ctx context.Context, slot int, count int) *redis.StringSliceCmd
- func (r *Redis) ClusterInfo(ctx context.Context) *redis.StringCmd
- func (r *Redis) ClusterKeySlot(ctx context.Context, key string) *redis.IntCmd
- func (r *Redis) ClusterLinks(ctx context.Context) *redis.ClusterLinksCmd
- func (r *Redis) ClusterMeet(ctx context.Context, host, port string) *redis.StatusCmd
- func (r *Redis) ClusterMyShardID(ctx context.Context) *redis.StringCmd
- func (r *Redis) ClusterNodes(ctx context.Context) *redis.StringCmd
- func (r *Redis) ClusterReplicate(ctx context.Context, nodeID string) *redis.StatusCmd
- func (r *Redis) ClusterResetHard(ctx context.Context) *redis.StatusCmd
- func (r *Redis) ClusterResetSoft(ctx context.Context) *redis.StatusCmd
- func (r *Redis) ClusterSaveConfig(ctx context.Context) *redis.StatusCmd
- func (r *Redis) ClusterShards(ctx context.Context) *redis.ClusterShardsCmd
- func (r *Redis) ClusterSlaves(ctx context.Context, nodeID string) *redis.StringSliceCmd
- func (r *Redis) ClusterSlots(ctx context.Context) *redis.ClusterSlotsCmd
- func (r *Redis) Command(ctx context.Context) *redis.CommandsInfoCmd
- func (r *Redis) CommandGetKeys(ctx context.Context, commands ...interface{}) *redis.StringSliceCmd
- func (r *Redis) CommandGetKeysAndFlags(ctx context.Context, commands ...interface{}) *redis.KeyFlagsCmd
- func (r *Redis) CommandList(ctx context.Context, filter *redis.FilterBy) *redis.StringSliceCmd
- func (r *Redis) ConfigGet(ctx context.Context, parameter string) *redis.MapStringStringCmd
- func (r *Redis) ConfigResetStat(ctx context.Context) *redis.StatusCmd
- func (r *Redis) ConfigRewrite(ctx context.Context) *redis.StatusCmd
- func (r *Redis) ConfigSet(ctx context.Context, parameter, value string) *redis.StatusCmd
- func (r *Redis) Copy(ctx context.Context, sourceKey string, destKey string, db int, replace bool) *redis.IntCmd
- func (r *Redis) DBSize(ctx context.Context) *redis.IntCmd
- func (r *Redis) DebugObject(ctx context.Context, key string) *redis.StringCmd
- func (r *Redis) Decr(ctx context.Context, key string) *redis.IntCmd
- func (r *Redis) DecrBy(ctx context.Context, key string, decrement int64) *redis.IntCmd
- func (r *Redis) Del(ctx context.Context, keys ...string) *redis.IntCmd
- func (r *Redis) Dump(ctx context.Context, key string) *redis.StringCmd
- func (r *Redis) Echo(ctx context.Context, message interface{}) *redis.StringCmd
- func (r *Redis) Eval(ctx context.Context, script string, keys []string, args ...interface{}) *redis.Cmd
- func (r *Redis) EvalRO(ctx context.Context, script string, keys []string, args ...interface{}) *redis.Cmd
- func (r *Redis) EvalSha(ctx context.Context, sha1 string, keys []string, args ...interface{}) *redis.Cmd
- func (r *Redis) EvalShaRO(ctx context.Context, sha1 string, keys []string, args ...interface{}) *redis.Cmd
- func (r *Redis) Exists(ctx context.Context, keys ...string) *redis.IntCmd
- func (r *Redis) Expire(ctx context.Context, key string, expiration time.Duration) *redis.BoolCmd
- func (r *Redis) ExpireAt(ctx context.Context, key string, tm time.Time) *redis.BoolCmd
- func (r *Redis) ExpireGT(ctx context.Context, key string, expiration time.Duration) *redis.BoolCmd
- func (r *Redis) ExpireLT(ctx context.Context, key string, expiration time.Duration) *redis.BoolCmd
- func (r *Redis) ExpireNX(ctx context.Context, key string, expiration time.Duration) *redis.BoolCmd
- func (r *Redis) ExpireTime(ctx context.Context, key string) *redis.DurationCmd
- func (r *Redis) ExpireXX(ctx context.Context, key string, expiration time.Duration) *redis.BoolCmd
- func (r *Redis) FCall(ctx context.Context, function string, keys []string, args ...interface{}) *redis.Cmd
- func (r *Redis) FCallRO(ctx context.Context, function string, keys []string, args ...interface{}) *redis.Cmd
- func (r *Redis) FCallRo(ctx context.Context, function string, keys []string, args ...interface{}) *redis.Cmd
- func (r *Redis) FlushAll(ctx context.Context) *redis.StatusCmd
- func (r *Redis) FlushAllAsync(ctx context.Context) *redis.StatusCmd
- func (r *Redis) FlushDB(ctx context.Context) *redis.StatusCmd
- func (r *Redis) FlushDBAsync(ctx context.Context) *redis.StatusCmd
- func (r *Redis) FunctionDelete(ctx context.Context, libName string) *redis.StringCmd
- func (r *Redis) FunctionDump(ctx context.Context) *redis.StringCmd
- func (r *Redis) FunctionFlush(ctx context.Context) *redis.StringCmd
- func (r *Redis) FunctionFlushAsync(ctx context.Context) *redis.StringCmd
- func (r *Redis) FunctionKill(ctx context.Context) *redis.StringCmd
- func (r *Redis) FunctionList(ctx context.Context, q redis.FunctionListQuery) *redis.FunctionListCmd
- func (r *Redis) FunctionLoad(ctx context.Context, code string) *redis.StringCmd
- func (r *Redis) FunctionLoadReplace(ctx context.Context, code string) *redis.StringCmd
- func (r *Redis) FunctionRestore(ctx context.Context, libDump string) *redis.StringCmd
- func (r *Redis) FunctionStats(ctx context.Context) *redis.FunctionStatsCmd
- func (r *Redis) GeoAdd(ctx context.Context, key string, geoLocation ...*redis.GeoLocation) *redis.IntCmd
- func (r *Redis) GeoDist(ctx context.Context, key string, member1, member2, unit string) *redis.FloatCmd
- func (r *Redis) GeoHash(ctx context.Context, key string, members ...string) *redis.StringSliceCmd
- func (r *Redis) GeoPos(ctx context.Context, key string, members ...string) *redis.GeoPosCmd
- func (r *Redis) GeoRadius(ctx context.Context, key string, longitude, latitude float64, ...) *redis.GeoLocationCmd
- func (r *Redis) GeoRadiusByMember(ctx context.Context, key, member string, query *redis.GeoRadiusQuery) *redis.GeoLocationCmd
- func (r *Redis) GeoRadiusByMemberStore(ctx context.Context, key string, member string, query *redis.GeoRadiusQuery) *redis.IntCmd
- func (r *Redis) GeoRadiusStore(ctx context.Context, key string, longitude float64, latitude float64, ...) *redis.IntCmd
- func (r *Redis) GeoSearch(ctx context.Context, key string, q *redis.GeoSearchQuery) *redis.StringSliceCmd
- func (r *Redis) GeoSearchLocation(ctx context.Context, key string, q *redis.GeoSearchLocationQuery) *redis.GeoSearchLocationCmd
- func (r *Redis) GeoSearchStore(ctx context.Context, key string, store string, q *redis.GeoSearchStoreQuery) *redis.IntCmd
- func (r *Redis) Get(ctx context.Context, key string) *redis.StringCmd
- func (r *Redis) GetBit(ctx context.Context, key string, offset int64) *redis.IntCmd
- func (r *Redis) GetDel(ctx context.Context, key string) *redis.StringCmd
- func (r *Redis) GetEx(ctx context.Context, key string, expiration time.Duration) *redis.StringCmd
- func (r *Redis) GetRange(ctx context.Context, key string, start, end int64) *redis.StringCmd
- func (r *Redis) GetSet(ctx context.Context, key string, value interface{}) *redis.StringCmd
- func (r *Redis) HDel(ctx context.Context, key string, fields ...string) *redis.IntCmd
- func (r *Redis) HExists(ctx context.Context, key, field string) *redis.BoolCmd
- func (r *Redis) HGet(ctx context.Context, key, field string) *redis.StringCmd
- func (r *Redis) HGetAll(ctx context.Context, key string) *redis.MapStringStringCmd
- func (r *Redis) HIncrBy(ctx context.Context, key, field string, incr int64) *redis.IntCmd
- func (r *Redis) HIncrByFloat(ctx context.Context, key, field string, incr float64) *redis.FloatCmd
- func (r *Redis) HKeys(ctx context.Context, key string) *redis.StringSliceCmd
- func (r *Redis) HLen(ctx context.Context, key string) *redis.IntCmd
- func (r *Redis) HMGet(ctx context.Context, key string, fields ...string) *redis.SliceCmd
- func (r *Redis) HMSet(ctx context.Context, key string, values ...interface{}) *redis.BoolCmd
- func (r *Redis) HRandField(ctx context.Context, key string, count int) *redis.StringSliceCmd
- func (r *Redis) HRandFieldWithValues(ctx context.Context, key string, count int) *redis.KeyValueSliceCmd
- func (r *Redis) HScan(ctx context.Context, key string, cursor uint64, match string, count int64) *redis.ScanCmd
- func (r *Redis) HSet(ctx context.Context, key string, values ...interface{}) *redis.IntCmd
- func (r *Redis) HSetNX(ctx context.Context, key, field string, value interface{}) *redis.BoolCmd
- func (r *Redis) HVals(ctx context.Context, key string) *redis.StringSliceCmd
- func (r *Redis) Incr(ctx context.Context, key string) *redis.IntCmd
- func (r *Redis) IncrBy(ctx context.Context, key string, value int64) *redis.IntCmd
- func (r *Redis) IncrByFloat(ctx context.Context, key string, value float64) *redis.FloatCmd
- func (r *Redis) Info(ctx context.Context, section ...string) *redis.StringCmd
- func (r *Redis) Keys(ctx context.Context, pattern string) *redis.StringSliceCmd
- func (r *Redis) LCS(ctx context.Context, q *redis.LCSQuery) *redis.LCSCmd
- func (r *Redis) LIndex(ctx context.Context, key string, index int64) *redis.StringCmd
- func (r *Redis) LInsert(ctx context.Context, key, op string, pivot, value interface{}) *redis.IntCmd
- func (r *Redis) LInsertAfter(ctx context.Context, key string, pivot, value interface{}) *redis.IntCmd
- func (r *Redis) LInsertBefore(ctx context.Context, key string, pivot, value interface{}) *redis.IntCmd
- func (r *Redis) LLen(ctx context.Context, key string) *redis.IntCmd
- func (r *Redis) LMPop(ctx context.Context, direction string, count int64, keys ...string) *redis.KeyValuesCmd
- func (r *Redis) LMove(ctx context.Context, source string, destination string, srcpos string, ...) *redis.StringCmd
- func (r *Redis) LPop(ctx context.Context, key string) *redis.StringCmd
- func (r *Redis) LPopCount(ctx context.Context, key string, count int) *redis.StringSliceCmd
- func (r *Redis) LPos(ctx context.Context, key string, value string, args redis.LPosArgs) *redis.IntCmd
- func (r *Redis) LPosCount(ctx context.Context, key string, value string, count int64, ...) *redis.IntSliceCmd
- func (r *Redis) LPush(ctx context.Context, key string, values ...interface{}) *redis.IntCmd
- func (r *Redis) LPushX(ctx context.Context, key string, values ...interface{}) *redis.IntCmd
- func (r *Redis) LRange(ctx context.Context, key string, start, stop int64) *redis.StringSliceCmd
- func (r *Redis) LRem(ctx context.Context, key string, count int64, value interface{}) *redis.IntCmd
- func (r *Redis) LSet(ctx context.Context, key string, index int64, value interface{}) *redis.StatusCmd
- func (r *Redis) LTrim(ctx context.Context, key string, start, stop int64) *redis.StatusCmd
- func (r *Redis) LastSave(ctx context.Context) *redis.IntCmd
- func (r *Redis) MGet(ctx context.Context, keys ...string) *redis.SliceCmd
- func (r *Redis) MSet(ctx context.Context, pairs ...interface{}) *redis.StatusCmd
- func (r *Redis) MSetNX(ctx context.Context, pairs ...interface{}) *redis.BoolCmd
- func (r *Redis) MemoryUsage(ctx context.Context, key string, samples ...int) *redis.IntCmd
- func (r *Redis) Migrate(ctx context.Context, host, port, key string, db int, timeout time.Duration) *redis.StatusCmd
- func (r *Redis) ModuleLoadex(ctx context.Context, conf *redis.ModuleLoadexConfig) *redis.StringCmd
- func (r *Redis) Move(ctx context.Context, key string, db int) *redis.BoolCmd
- func (r *Redis) ObjectEncoding(ctx context.Context, key string) *redis.StringCmd
- func (r *Redis) ObjectIdleTime(ctx context.Context, key string) *redis.DurationCmd
- func (r *Redis) ObjectRefCount(ctx context.Context, key string) *redis.IntCmd
- func (r *Redis) PExpire(ctx context.Context, key string, expiration time.Duration) *redis.BoolCmd
- func (r *Redis) PExpireAt(ctx context.Context, key string, tm time.Time) *redis.BoolCmd
- func (r *Redis) PExpireTime(ctx context.Context, key string) *redis.DurationCmd
- func (r *Redis) PFAdd(ctx context.Context, key string, els ...interface{}) *redis.IntCmd
- func (r *Redis) PFCount(ctx context.Context, keys ...string) *redis.IntCmd
- func (r *Redis) PFMerge(ctx context.Context, dest string, keys ...string) *redis.StatusCmd
- func (r *Redis) PSubscribe(ctx context.Context, channels ...string) *redis.PubSub
- func (r *Redis) PTTL(ctx context.Context, key string) *redis.DurationCmd
- func (r *Redis) Persist(ctx context.Context, key string) *redis.BoolCmd
- func (r *Redis) Ping(ctx context.Context) *redis.StatusCmd
- func (r *Redis) Pipeline() redis.Pipeliner
- func (r *Redis) Pipelined(ctx context.Context, fn func(redis.Pipeliner) error) ([]redis.Cmder, error)
- func (r *Redis) PoolStats() *redis.PoolStats
- func (r *Redis) PubSubChannels(ctx context.Context, pattern string) *redis.StringSliceCmd
- func (r *Redis) PubSubNumPat(ctx context.Context) *redis.IntCmd
- func (r *Redis) PubSubNumSub(ctx context.Context, channels ...string) *redis.MapStringIntCmd
- func (r *Redis) PubSubShardChannels(ctx context.Context, pattern string) *redis.StringSliceCmd
- func (r *Redis) PubSubShardNumSub(ctx context.Context, channels ...string) *redis.MapStringIntCmd
- func (r *Redis) Publish(ctx context.Context, channel string, message interface{}) *redis.IntCmd
- func (r *Redis) Quit(ctx context.Context) *redis.StatusCmd
- func (r *Redis) RPop(ctx context.Context, key string) *redis.StringCmd
- func (r *Redis) RPopCount(ctx context.Context, key string, count int) *redis.StringSliceCmd
- func (r *Redis) RPopLPush(ctx context.Context, source, destination string) *redis.StringCmd
- func (r *Redis) RPush(ctx context.Context, key string, values ...interface{}) *redis.IntCmd
- func (r *Redis) RPushX(ctx context.Context, key string, values ...interface{}) *redis.IntCmd
- func (r *Redis) RandomKey(ctx context.Context) *redis.StringCmd
- func (r *Redis) ReadOnly(ctx context.Context) *redis.StatusCmd
- func (r *Redis) ReadWrite(ctx context.Context) *redis.StatusCmd
- func (r *Redis) Rename(ctx context.Context, key, newkey string) *redis.StatusCmd
- func (r *Redis) RenameNX(ctx context.Context, key, newkey string) *redis.BoolCmd
- func (r *Redis) Restore(ctx context.Context, key string, ttl time.Duration, value string) *redis.StatusCmd
- func (r *Redis) RestoreReplace(ctx context.Context, key string, ttl time.Duration, value string) *redis.StatusCmd
- func (r *Redis) SAdd(ctx context.Context, key string, members ...interface{}) *redis.IntCmd
- func (r *Redis) SCard(ctx context.Context, key string) *redis.IntCmd
- func (r *Redis) SDiff(ctx context.Context, keys ...string) *redis.StringSliceCmd
- func (r *Redis) SDiffStore(ctx context.Context, destination string, keys ...string) *redis.IntCmd
- func (r *Redis) SInter(ctx context.Context, keys ...string) *redis.StringSliceCmd
- func (r *Redis) SInterCard(ctx context.Context, limit int64, keys ...string) *redis.IntCmd
- func (r *Redis) SInterStore(ctx context.Context, destination string, keys ...string) *redis.IntCmd
- func (r *Redis) SIsMember(ctx context.Context, key string, member interface{}) *redis.BoolCmd
- func (r *Redis) SMIsMember(ctx context.Context, key string, members ...interface{}) *redis.BoolSliceCmd
- func (r *Redis) SMembers(ctx context.Context, key string) *redis.StringSliceCmd
- func (r *Redis) SMembersMap(ctx context.Context, key string) *redis.StringStructMapCmd
- func (r *Redis) SMove(ctx context.Context, source, destination string, member interface{}) *redis.BoolCmd
- func (r *Redis) SPop(ctx context.Context, key string) *redis.StringCmd
- func (r *Redis) SPopN(ctx context.Context, key string, count int64) *redis.StringSliceCmd
- func (r *Redis) SPublish(ctx context.Context, channel string, message interface{}) *redis.IntCmd
- func (r *Redis) SRandMember(ctx context.Context, key string) *redis.StringCmd
- func (r *Redis) SRandMemberN(ctx context.Context, key string, count int64) *redis.StringSliceCmd
- func (r *Redis) SRem(ctx context.Context, key string, members ...interface{}) *redis.IntCmd
- func (r *Redis) SScan(ctx context.Context, key string, cursor uint64, match string, count int64) *redis.ScanCmd
- func (r *Redis) SUnion(ctx context.Context, keys ...string) *redis.StringSliceCmd
- func (r *Redis) SUnionStore(ctx context.Context, destination string, keys ...string) *redis.IntCmd
- func (r *Redis) Save(ctx context.Context) *redis.StatusCmd
- func (r *Redis) Scan(ctx context.Context, cursor uint64, match string, count int64) *redis.ScanCmd
- func (r *Redis) ScanType(ctx context.Context, cursor uint64, match string, count int64, keyType string) *redis.ScanCmd
- func (r *Redis) ScriptExists(ctx context.Context, hashes ...string) *redis.BoolSliceCmd
- func (r *Redis) ScriptFlush(ctx context.Context) *redis.StatusCmd
- func (r *Redis) ScriptKill(ctx context.Context) *redis.StatusCmd
- func (r *Redis) ScriptLoad(ctx context.Context, script string) *redis.StringCmd
- func (r *Redis) Set(ctx context.Context, key string, value interface{}, expiration time.Duration) *redis.StatusCmd
- func (r *Redis) SetArgs(ctx context.Context, key string, value interface{}, a redis.SetArgs) *redis.StatusCmd
- func (r *Redis) SetBit(ctx context.Context, key string, offset int64, value int) *redis.IntCmd
- func (r *Redis) SetEx(ctx context.Context, key string, value interface{}, expiration time.Duration) *redis.StatusCmd
- func (r *Redis) SetNX(ctx context.Context, key string, value interface{}, expiration time.Duration) *redis.BoolCmd
- func (r *Redis) SetRange(ctx context.Context, key string, offset int64, value string) *redis.IntCmd
- func (r *Redis) SetXX(ctx context.Context, key string, value interface{}, expiration time.Duration) *redis.BoolCmd
- func (r *Redis) Shutdown(ctx context.Context) *redis.StatusCmd
- func (r *Redis) ShutdownNoSave(ctx context.Context) *redis.StatusCmd
- func (r *Redis) ShutdownSave(ctx context.Context) *redis.StatusCmd
- func (r *Redis) SlaveOf(ctx context.Context, host, port string) *redis.StatusCmd
- func (r *Redis) SlowLogGet(ctx context.Context, num int64) *redis.SlowLogCmd
- func (r *Redis) Sort(ctx context.Context, key string, sort *redis.Sort) *redis.StringSliceCmd
- func (r *Redis) SortInterfaces(ctx context.Context, key string, sort *redis.Sort) *redis.SliceCmd
- func (r *Redis) SortRO(ctx context.Context, key string, sort *redis.Sort) *redis.StringSliceCmd
- func (r *Redis) SortStore(ctx context.Context, key, store string, sort *redis.Sort) *redis.IntCmd
- func (r *Redis) StrLen(ctx context.Context, key string) *redis.IntCmd
- func (r *Redis) Subscribe(ctx context.Context, channels ...string) *redis.PubSub
- func (r *Redis) TDigestAdd(ctx context.Context, key string, elements ...float64) *redis.StatusCmd
- func (r *Redis) TDigestByRank(ctx context.Context, key string, rank ...uint64) *redis.FloatSliceCmd
- func (r *Redis) TDigestByRevRank(ctx context.Context, key string, rank ...uint64) *redis.FloatSliceCmd
- func (r *Redis) TDigestCDF(ctx context.Context, key string, elements ...float64) *redis.FloatSliceCmd
- func (r *Redis) TDigestCreate(ctx context.Context, key string) *redis.StatusCmd
- func (r *Redis) TDigestCreateWithCompression(ctx context.Context, key string, compression int64) *redis.StatusCmd
- func (r *Redis) TDigestInfo(ctx context.Context, key string) *redis.TDigestInfoCmd
- func (r *Redis) TDigestMax(ctx context.Context, key string) *redis.FloatCmd
- func (r *Redis) TDigestMerge(ctx context.Context, destKey string, options *redis.TDigestMergeOptions, ...) *redis.StatusCmd
- func (r *Redis) TDigestMin(ctx context.Context, key string) *redis.FloatCmd
- func (r *Redis) TDigestQuantile(ctx context.Context, key string, elements ...float64) *redis.FloatSliceCmd
- func (r *Redis) TDigestRank(ctx context.Context, key string, values ...float64) *redis.IntSliceCmd
- func (r *Redis) TDigestReset(ctx context.Context, key string) *redis.StatusCmd
- func (r *Redis) TDigestRevRank(ctx context.Context, key string, values ...float64) *redis.IntSliceCmd
- func (r *Redis) TDigestTrimmedMean(ctx context.Context, key string, lowCutQuantile float64, ...) *redis.FloatCmd
- func (r *Redis) TFCall(ctx context.Context, libName string, funcName string, numKeys int) *redis.Cmd
- func (r *Redis) TFCallASYNC(ctx context.Context, libName string, funcName string, numKeys int) *redis.Cmd
- func (r *Redis) TFCallASYNCArgs(ctx context.Context, libName string, funcName string, numKeys int, ...) *redis.Cmd
- func (r *Redis) TFCallArgs(ctx context.Context, libName string, funcName string, numKeys int, ...) *redis.Cmd
- func (r *Redis) TFunctionDelete(ctx context.Context, libName string) *redis.StatusCmd
- func (r *Redis) TFunctionList(ctx context.Context) *redis.MapStringInterfaceSliceCmd
- func (r *Redis) TFunctionListArgs(ctx context.Context, options *redis.TFunctionListOptions) *redis.MapStringInterfaceSliceCmd
- func (r *Redis) TFunctionLoad(ctx context.Context, lib string) *redis.StatusCmd
- func (r *Redis) TFunctionLoadArgs(ctx context.Context, lib string, options *redis.TFunctionLoadOptions) *redis.StatusCmd
- func (r *Redis) TTL(ctx context.Context, key string) *redis.DurationCmd
- func (r *Redis) Time(ctx context.Context) *redis.TimeCmd
- func (r *Redis) TopKAdd(ctx context.Context, key string, elements ...interface{}) *redis.StringSliceCmd
- func (r *Redis) TopKCount(ctx context.Context, key string, elements ...interface{}) *redis.IntSliceCmd
- func (r *Redis) TopKIncrBy(ctx context.Context, key string, elements ...interface{}) *redis.StringSliceCmd
- func (r *Redis) TopKInfo(ctx context.Context, key string) *redis.TopKInfoCmd
- func (r *Redis) TopKList(ctx context.Context, key string) *redis.StringSliceCmd
- func (r *Redis) TopKListWithCount(ctx context.Context, key string) *redis.MapStringIntCmd
- func (r *Redis) TopKQuery(ctx context.Context, key string, elements ...interface{}) *redis.BoolSliceCmd
- func (r *Redis) TopKReserve(ctx context.Context, key string, k int64) *redis.StatusCmd
- func (r *Redis) TopKReserveWithOptions(ctx context.Context, key string, k int64, width int64, depth int64, ...) *redis.StatusCmd
- func (r *Redis) Touch(ctx context.Context, keys ...string) *redis.IntCmd
- func (r *Redis) TxPipeline() redis.Pipeliner
- func (r *Redis) TxPipelined(ctx context.Context, fn func(redis.Pipeliner) error) ([]redis.Cmder, error)
- func (r *Redis) Type(ctx context.Context, key string) *redis.StatusCmd
- func (r *Redis) Unlink(ctx context.Context, keys ...string) *redis.IntCmd
- func (r *Redis) XAck(ctx context.Context, stream, group string, ids ...string) *redis.IntCmd
- func (r *Redis) XAdd(ctx context.Context, a *redis.XAddArgs) *redis.StringCmd
- func (r *Redis) XAutoClaim(ctx context.Context, a *redis.XAutoClaimArgs) *redis.XAutoClaimCmd
- func (r *Redis) XAutoClaimJustID(ctx context.Context, a *redis.XAutoClaimArgs) *redis.XAutoClaimJustIDCmd
- func (r *Redis) XClaim(ctx context.Context, a *redis.XClaimArgs) *redis.XMessageSliceCmd
- func (r *Redis) XClaimJustID(ctx context.Context, a *redis.XClaimArgs) *redis.StringSliceCmd
- func (r *Redis) XDel(ctx context.Context, stream string, ids ...string) *redis.IntCmd
- func (r *Redis) XGroupCreate(ctx context.Context, stream, group, start string) *redis.StatusCmd
- func (r *Redis) XGroupCreateConsumer(ctx context.Context, stream string, group string, consumer string) *redis.IntCmd
- func (r *Redis) XGroupCreateMkStream(ctx context.Context, stream, group, start string) *redis.StatusCmd
- func (r *Redis) XGroupDelConsumer(ctx context.Context, stream, group, consumer string) *redis.IntCmd
- func (r *Redis) XGroupDestroy(ctx context.Context, stream, group string) *redis.IntCmd
- func (r *Redis) XGroupSetID(ctx context.Context, stream, group, start string) *redis.StatusCmd
- func (r *Redis) XInfoConsumers(ctx context.Context, key string, group string) *redis.XInfoConsumersCmd
- func (r *Redis) XInfoGroups(ctx context.Context, key string) *redis.XInfoGroupsCmd
- func (r *Redis) XInfoStream(ctx context.Context, key string) *redis.XInfoStreamCmd
- func (r *Redis) XInfoStreamFull(ctx context.Context, key string, count int) *redis.XInfoStreamFullCmd
- func (r *Redis) XLen(ctx context.Context, stream string) *redis.IntCmd
- func (r *Redis) XPending(ctx context.Context, stream, group string) *redis.XPendingCmd
- func (r *Redis) XPendingExt(ctx context.Context, a *redis.XPendingExtArgs) *redis.XPendingExtCmd
- func (r *Redis) XRange(ctx context.Context, stream, start, stop string) *redis.XMessageSliceCmd
- func (r *Redis) XRangeN(ctx context.Context, stream, start, stop string, count int64) *redis.XMessageSliceCmd
- func (r *Redis) XRead(ctx context.Context, a *redis.XReadArgs) *redis.XStreamSliceCmd
- func (r *Redis) XReadGroup(ctx context.Context, a *redis.XReadGroupArgs) *redis.XStreamSliceCmd
- func (r *Redis) XReadStreams(ctx context.Context, streams ...string) *redis.XStreamSliceCmd
- func (r *Redis) XRevRange(ctx context.Context, stream string, start, stop string) *redis.XMessageSliceCmd
- func (r *Redis) XRevRangeN(ctx context.Context, stream string, start, stop string, count int64) *redis.XMessageSliceCmd
- func (r *Redis) XTrimMaxLen(ctx context.Context, key string, maxLen int64) *redis.IntCmd
- func (r *Redis) XTrimMaxLenApprox(ctx context.Context, key string, maxLen int64, limit int64) *redis.IntCmd
- func (r *Redis) XTrimMinID(ctx context.Context, key string, minID string) *redis.IntCmd
- func (r *Redis) XTrimMinIDApprox(ctx context.Context, key string, minID string, limit int64) *redis.IntCmd
- func (r *Redis) ZAdd(ctx context.Context, key string, members ...redis.Z) *redis.IntCmd
- func (r *Redis) ZAddArgs(ctx context.Context, key string, args redis.ZAddArgs) *redis.IntCmd
- func (r *Redis) ZAddArgsIncr(ctx context.Context, key string, args redis.ZAddArgs) *redis.FloatCmd
- func (r *Redis) ZAddGT(ctx context.Context, key string, members ...redis.Z) *redis.IntCmd
- func (r *Redis) ZAddLT(ctx context.Context, key string, members ...redis.Z) *redis.IntCmd
- func (r *Redis) ZAddNX(ctx context.Context, key string, members ...redis.Z) *redis.IntCmd
- func (r *Redis) ZAddXX(ctx context.Context, key string, members ...redis.Z) *redis.IntCmd
- func (r *Redis) ZCard(ctx context.Context, key string) *redis.IntCmd
- func (r *Redis) ZCount(ctx context.Context, key, min, max string) *redis.IntCmd
- func (r *Redis) ZDiff(ctx context.Context, keys ...string) *redis.StringSliceCmd
- func (r *Redis) ZDiffStore(ctx context.Context, destination string, keys ...string) *redis.IntCmd
- func (r *Redis) ZDiffWithScores(ctx context.Context, keys ...string) *redis.ZSliceCmd
- func (r *Redis) ZIncrBy(ctx context.Context, key string, increment float64, member string) *redis.FloatCmd
- func (r *Redis) ZInter(ctx context.Context, store *redis.ZStore) *redis.StringSliceCmd
- func (r *Redis) ZInterCard(ctx context.Context, limit int64, keys ...string) *redis.IntCmd
- func (r *Redis) ZInterStore(ctx context.Context, destination string, store *redis.ZStore) *redis.IntCmd
- func (r *Redis) ZInterWithScores(ctx context.Context, store *redis.ZStore) *redis.ZSliceCmd
- func (r *Redis) ZLexCount(ctx context.Context, key, min, max string) *redis.IntCmd
- func (r *Redis) ZMPop(ctx context.Context, order string, count int64, keys ...string) *redis.ZSliceWithKeyCmd
- func (r *Redis) ZMScore(ctx context.Context, key string, members ...string) *redis.FloatSliceCmd
- func (r *Redis) ZPopMax(ctx context.Context, key string, count ...int64) *redis.ZSliceCmd
- func (r *Redis) ZPopMin(ctx context.Context, key string, count ...int64) *redis.ZSliceCmd
- func (r *Redis) ZRandMember(ctx context.Context, key string, count int) *redis.StringSliceCmd
- func (r *Redis) ZRandMemberWithScores(ctx context.Context, key string, count int) *redis.ZSliceCmd
- func (r *Redis) ZRange(ctx context.Context, key string, start, stop int64) *redis.StringSliceCmd
- func (r *Redis) ZRangeArgs(ctx context.Context, z redis.ZRangeArgs) *redis.StringSliceCmd
- func (r *Redis) ZRangeArgsWithScores(ctx context.Context, z redis.ZRangeArgs) *redis.ZSliceCmd
- func (r *Redis) ZRangeByLex(ctx context.Context, key string, opt *redis.ZRangeBy) *redis.StringSliceCmd
- func (r *Redis) ZRangeByScore(ctx context.Context, key string, opt *redis.ZRangeBy) *redis.StringSliceCmd
- func (r *Redis) ZRangeByScoreWithScores(ctx context.Context, key string, opt *redis.ZRangeBy) *redis.ZSliceCmd
- func (r *Redis) ZRangeStore(ctx context.Context, dst string, z redis.ZRangeArgs) *redis.IntCmd
- func (r *Redis) ZRangeWithScores(ctx context.Context, key string, start, stop int64) *redis.ZSliceCmd
- func (r *Redis) ZRank(ctx context.Context, key, member string) *redis.IntCmd
- func (r *Redis) ZRankWithScore(ctx context.Context, key string, member string) *redis.RankWithScoreCmd
- func (r *Redis) ZRem(ctx context.Context, key string, members ...interface{}) *redis.IntCmd
- func (r *Redis) ZRemRangeByLex(ctx context.Context, key, min, max string) *redis.IntCmd
- func (r *Redis) ZRemRangeByRank(ctx context.Context, key string, start, stop int64) *redis.IntCmd
- func (r *Redis) ZRemRangeByScore(ctx context.Context, key, min, max string) *redis.IntCmd
- func (r *Redis) ZRevRange(ctx context.Context, key string, start, stop int64) *redis.StringSliceCmd
- func (r *Redis) ZRevRangeByLex(ctx context.Context, key string, opt *redis.ZRangeBy) *redis.StringSliceCmd
- func (r *Redis) ZRevRangeByScore(ctx context.Context, key string, opt *redis.ZRangeBy) *redis.StringSliceCmd
- func (r *Redis) ZRevRangeByScoreWithScores(ctx context.Context, key string, opt *redis.ZRangeBy) *redis.ZSliceCmd
- func (r *Redis) ZRevRangeWithScores(ctx context.Context, key string, start, stop int64) *redis.ZSliceCmd
- func (r *Redis) ZRevRank(ctx context.Context, key, member string) *redis.IntCmd
- func (r *Redis) ZRevRankWithScore(ctx context.Context, key string, member string) *redis.RankWithScoreCmd
- func (r *Redis) ZScan(ctx context.Context, key string, cursor uint64, match string, count int64) *redis.ScanCmd
- func (r *Redis) ZScore(ctx context.Context, key, member string) *redis.FloatCmd
- func (r *Redis) ZUnion(ctx context.Context, store redis.ZStore) *redis.StringSliceCmd
- func (r *Redis) ZUnionStore(ctx context.Context, dest string, store *redis.ZStore) *redis.IntCmd
- func (r *Redis) ZUnionWithScores(ctx context.Context, store redis.ZStore) *redis.ZSliceCmd
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Conf ¶
type Redis ¶
type Redis struct {
// contains filtered or unexported fields
}
func RedisSingleton ¶
func (*Redis) ACLDryRun ¶
func (r *Redis) ACLDryRun(ctx context.Context, username string, command ...interface{}) *redis.StringCmd
ACLDryRun implements redis.Cmdable
func (*Redis) ACLLogReset ¶
ACLLogReset implements redis.Cmdable.
func (*Redis) BFInfoCapacity ¶
BFInfoCapacity implements redis.Cmdable.
func (*Redis) BFInfoExpansion ¶
BFInfoExpansion implements redis.Cmdable.
func (*Redis) BFInfoFilters ¶
BFInfoFilters implements redis.Cmdable.
func (*Redis) BFInfoItems ¶
BFInfoItems implements redis.Cmdable.
func (*Redis) BFInfoSize ¶
BFInfoSize implements redis.Cmdable.
func (*Redis) BFInsert ¶
func (r *Redis) BFInsert(ctx context.Context, key string, options *redis.BFInsertOptions, elements ...interface{}) *redis.BoolSliceCmd
BFInsert implements redis.Cmdable.
func (*Redis) BFLoadChunk ¶
func (r *Redis) BFLoadChunk(ctx context.Context, key string, iterator int64, data interface{}) *redis.StatusCmd
BFLoadChunk implements redis.Cmdable.
func (*Redis) BFMAdd ¶
func (r *Redis) BFMAdd(ctx context.Context, key string, elements ...interface{}) *redis.BoolSliceCmd
BFMAdd implements redis.Cmdable.
func (*Redis) BFMExists ¶
func (r *Redis) BFMExists(ctx context.Context, key string, elements ...interface{}) *redis.BoolSliceCmd
BFMExists implements redis.Cmdable.
func (*Redis) BFReserve ¶
func (r *Redis) BFReserve(ctx context.Context, key string, errorRate float64, capacity int64) *redis.StatusCmd
BFReserve implements redis.Cmdable.
func (*Redis) BFReserveArgs ¶
func (r *Redis) BFReserveArgs(ctx context.Context, key string, options *redis.BFReserveOptions) *redis.StatusCmd
BFReserveArgs implements redis.Cmdable.
func (*Redis) BFReserveExpansion ¶
func (r *Redis) BFReserveExpansion(ctx context.Context, key string, errorRate float64, capacity int64, expansion int64) *redis.StatusCmd
BFReserveExpansion implements redis.Cmdable.
func (*Redis) BFReserveNonScaling ¶
func (r *Redis) BFReserveNonScaling(ctx context.Context, key string, errorRate float64, capacity int64) *redis.StatusCmd
BFReserveNonScaling implements redis.Cmdable.
func (*Redis) BFScanDump ¶
BFScanDump implements redis.Cmdable.
func (*Redis) BLMPop ¶
func (r *Redis) BLMPop(ctx context.Context, timeout time.Duration, direction string, count int64, keys ...string) *redis.KeyValuesCmd
BLMPop implements redis.Cmdable
func (*Redis) BLMove ¶
func (r *Redis) BLMove(ctx context.Context, source string, destination string, srcpos string, destpos string, timeout time.Duration) *redis.StringCmd
BLMove implements redis.Cmdable
func (*Redis) BRPopLPush ¶
func (*Redis) BZMPop ¶
func (r *Redis) BZMPop(ctx context.Context, timeout time.Duration, order string, count int64, keys ...string) *redis.ZSliceWithKeyCmd
BZMPop implements redis.Cmdable
func (*Redis) BitPosSpan ¶
func (r *Redis) BitPosSpan(ctx context.Context, key string, bit int8, start int64, end int64, span string) *redis.IntCmd
BitPosSpan implements redis.Cmdable
func (*Redis) CFInsert ¶
func (r *Redis) CFInsert(ctx context.Context, key string, options *redis.CFInsertOptions, elements ...interface{}) *redis.BoolSliceCmd
CFInsert implements redis.Cmdable.
func (*Redis) CFInsertNX ¶
func (r *Redis) CFInsertNX(ctx context.Context, key string, options *redis.CFInsertOptions, elements ...interface{}) *redis.IntSliceCmd
CFInsertNX implements redis.Cmdable.
func (*Redis) CFLoadChunk ¶
func (r *Redis) CFLoadChunk(ctx context.Context, key string, iterator int64, data interface{}) *redis.StatusCmd
CFLoadChunk implements redis.Cmdable.
func (*Redis) CFMExists ¶
func (r *Redis) CFMExists(ctx context.Context, key string, elements ...interface{}) *redis.BoolSliceCmd
CFMExists implements redis.Cmdable.
func (*Redis) CFReserveArgs ¶
func (r *Redis) CFReserveArgs(ctx context.Context, key string, options *redis.CFReserveOptions) *redis.StatusCmd
CFReserveArgs implements redis.Cmdable.
func (*Redis) CFReserveBucketSize ¶
func (r *Redis) CFReserveBucketSize(ctx context.Context, key string, capacity int64, bucketsize int64) *redis.StatusCmd
CFReserveBucketSize implements redis.Cmdable.
func (*Redis) CFReserveExpansion ¶
func (r *Redis) CFReserveExpansion(ctx context.Context, key string, capacity int64, expansion int64) *redis.StatusCmd
CFReserveExpansion implements redis.Cmdable.
func (*Redis) CFReserveMaxIterations ¶
func (r *Redis) CFReserveMaxIterations(ctx context.Context, key string, capacity int64, maxiterations int64) *redis.StatusCmd
CFReserveMaxIterations implements redis.Cmdable.
func (*Redis) CFScanDump ¶
CFScanDump implements redis.Cmdable.
func (*Redis) CMSIncrBy ¶
func (r *Redis) CMSIncrBy(ctx context.Context, key string, elements ...interface{}) *redis.IntSliceCmd
CMSIncrBy implements redis.Cmdable.
func (*Redis) CMSInitByDim ¶
func (r *Redis) CMSInitByDim(ctx context.Context, key string, width int64, height int64) *redis.StatusCmd
CMSInitByDim implements redis.Cmdable.
func (*Redis) CMSInitByProb ¶
func (r *Redis) CMSInitByProb(ctx context.Context, key string, errorRate float64, probability float64) *redis.StatusCmd
CMSInitByProb implements redis.Cmdable.
func (*Redis) CMSMerge ¶
func (r *Redis) CMSMerge(ctx context.Context, destKey string, sourceKeys ...string) *redis.StatusCmd
CMSMerge implements redis.Cmdable.
func (*Redis) CMSMergeWithWeight ¶
func (r *Redis) CMSMergeWithWeight(ctx context.Context, destKey string, sourceKeys map[string]int64) *redis.StatusCmd
CMSMergeWithWeight implements redis.Cmdable.
func (*Redis) CMSQuery ¶
func (r *Redis) CMSQuery(ctx context.Context, key string, elements ...interface{}) *redis.IntSliceCmd
CMSQuery implements redis.Cmdable.
func (*Redis) ClientInfo ¶
func (r *Redis) ClientInfo(ctx context.Context) *redis.ClientInfoCmd
ClientInfo implements redis.Cmdable
func (*Redis) ClientKill ¶
func (*Redis) ClientKillByFilter ¶
func (*Redis) ClientPause ¶
func (*Redis) ClientUnblock ¶
ClientUnblock implements redis.Cmdable
func (*Redis) ClientUnblockWithError ¶
ClientUnblockWithError implements redis.Cmdable
func (*Redis) ClientUnpause ¶
ClientUnpause implements redis.Cmdable
func (*Redis) ClusterAddSlots ¶
func (*Redis) ClusterAddSlotsRange ¶
func (*Redis) ClusterCountFailureReports ¶
func (*Redis) ClusterCountKeysInSlot ¶
func (*Redis) ClusterDelSlots ¶
func (*Redis) ClusterDelSlotsRange ¶
func (*Redis) ClusterFailover ¶
func (*Redis) ClusterForget ¶
func (*Redis) ClusterGetKeysInSlot ¶
func (*Redis) ClusterKeySlot ¶
func (*Redis) ClusterLinks ¶
func (r *Redis) ClusterLinks(ctx context.Context) *redis.ClusterLinksCmd
ClusterLinks implements redis.Cmdable
func (*Redis) ClusterMeet ¶
func (*Redis) ClusterMyShardID ¶
ClusterMyShardID implements redis.Cmdable
func (*Redis) ClusterReplicate ¶
func (*Redis) ClusterResetHard ¶
func (*Redis) ClusterResetSoft ¶
func (*Redis) ClusterSaveConfig ¶
func (*Redis) ClusterShards ¶
func (r *Redis) ClusterShards(ctx context.Context) *redis.ClusterShardsCmd
ClusterShards implements redis.Cmdable
func (*Redis) ClusterSlaves ¶
func (*Redis) ClusterSlots ¶
func (r *Redis) ClusterSlots(ctx context.Context) *redis.ClusterSlotsCmd
func (*Redis) CommandGetKeys ¶
func (r *Redis) CommandGetKeys(ctx context.Context, commands ...interface{}) *redis.StringSliceCmd
CommandGetKeys implements redis.Cmdable
func (*Redis) CommandGetKeysAndFlags ¶
func (r *Redis) CommandGetKeysAndFlags(ctx context.Context, commands ...interface{}) *redis.KeyFlagsCmd
CommandGetKeysAndFlags implements redis.Cmdable
func (*Redis) CommandList ¶
CommandList implements redis.Cmdable
func (*Redis) ConfigResetStat ¶
func (*Redis) Copy ¶
func (r *Redis) Copy(ctx context.Context, sourceKey string, destKey string, db int, replace bool) *redis.IntCmd
Copy implements redis.Cmdable
func (*Redis) DebugObject ¶
func (*Redis) EvalRO ¶
func (r *Redis) EvalRO(ctx context.Context, script string, keys []string, args ...interface{}) *redis.Cmd
EvalRO implements redis.Cmdable
func (*Redis) EvalShaRO ¶
func (r *Redis) EvalShaRO(ctx context.Context, sha1 string, keys []string, args ...interface{}) *redis.Cmd
EvalShaRO implements redis.Cmdable
func (*Redis) ExpireTime ¶
ExpireTime implements redis.Cmdable
func (*Redis) FCall ¶
func (r *Redis) FCall(ctx context.Context, function string, keys []string, args ...interface{}) *redis.Cmd
FCall implements redis.Cmdable
func (*Redis) FCallRO ¶
func (r *Redis) FCallRO(ctx context.Context, function string, keys []string, args ...interface{}) *redis.Cmd
FCallRO implements redis.Cmdable
func (*Redis) FCallRo ¶
func (r *Redis) FCallRo(ctx context.Context, function string, keys []string, args ...interface{}) *redis.Cmd
FCallRo implements redis.Cmdable
func (*Redis) FunctionDelete ¶
FunctionDelete implements redis.Cmdable
func (*Redis) FunctionDump ¶
FunctionDump implements redis.Cmdable
func (*Redis) FunctionFlush ¶
FunctionFlush implements redis.Cmdable
func (*Redis) FunctionFlushAsync ¶
FunctionFlushAsync implements redis.Cmdable
func (*Redis) FunctionKill ¶
FunctionKill implements redis.Cmdable
func (*Redis) FunctionList ¶
func (r *Redis) FunctionList(ctx context.Context, q redis.FunctionListQuery) *redis.FunctionListCmd
FunctionList implements redis.Cmdable
func (*Redis) FunctionLoad ¶
FunctionLoad implements redis.Cmdable
func (*Redis) FunctionLoadReplace ¶
FunctionLoadReplace implements redis.Cmdable
func (*Redis) FunctionRestore ¶
FunctionRestore implements redis.Cmdable
func (*Redis) FunctionStats ¶
func (r *Redis) FunctionStats(ctx context.Context) *redis.FunctionStatsCmd
FunctionStats implements redis.Cmdable
func (*Redis) GeoRadius ¶
func (r *Redis) GeoRadius(ctx context.Context, key string, longitude, latitude float64, query *redis.GeoRadiusQuery) *redis.GeoLocationCmd
func (*Redis) GeoRadiusByMember ¶
func (r *Redis) GeoRadiusByMember(ctx context.Context, key, member string, query *redis.GeoRadiusQuery) *redis.GeoLocationCmd
func (*Redis) GeoRadiusByMemberStore ¶
func (r *Redis) GeoRadiusByMemberStore(ctx context.Context, key string, member string, query *redis.GeoRadiusQuery) *redis.IntCmd
GeoRadiusByMemberStore implements redis.Cmdable
func (*Redis) GeoRadiusStore ¶
func (r *Redis) GeoRadiusStore(ctx context.Context, key string, longitude float64, latitude float64, query *redis.GeoRadiusQuery) *redis.IntCmd
GeoRadiusStore implements redis.Cmdable
func (*Redis) GeoSearch ¶
func (r *Redis) GeoSearch(ctx context.Context, key string, q *redis.GeoSearchQuery) *redis.StringSliceCmd
GeoSearch implements redis.Cmdable
func (*Redis) GeoSearchLocation ¶
func (r *Redis) GeoSearchLocation(ctx context.Context, key string, q *redis.GeoSearchLocationQuery) *redis.GeoSearchLocationCmd
GeoSearchLocation implements redis.Cmdable
func (*Redis) GeoSearchStore ¶
func (r *Redis) GeoSearchStore(ctx context.Context, key string, store string, q *redis.GeoSearchStoreQuery) *redis.IntCmd
GeoSearchStore implements redis.Cmdable
func (*Redis) HIncrByFloat ¶
func (*Redis) HRandField ¶
HRandField implements redis.Cmdable
func (*Redis) HRandFieldWithValues ¶
func (r *Redis) HRandFieldWithValues(ctx context.Context, key string, count int) *redis.KeyValueSliceCmd
HRandFieldWithValues implements redis.Cmdable
func (*Redis) IncrByFloat ¶
func (*Redis) LInsertAfter ¶
func (*Redis) LInsertBefore ¶
func (*Redis) LMPop ¶
func (r *Redis) LMPop(ctx context.Context, direction string, count int64, keys ...string) *redis.KeyValuesCmd
LMPop implements redis.Cmdable
func (*Redis) LMove ¶
func (r *Redis) LMove(ctx context.Context, source string, destination string, srcpos string, destpos string) *redis.StringCmd
LMove implements redis.Cmdable
func (*Redis) LPos ¶
func (r *Redis) LPos(ctx context.Context, key string, value string, args redis.LPosArgs) *redis.IntCmd
LPos implements redis.Cmdable
func (*Redis) LPosCount ¶
func (r *Redis) LPosCount(ctx context.Context, key string, value string, count int64, args redis.LPosArgs) *redis.IntSliceCmd
LPosCount implements redis.Cmdable
func (*Redis) MemoryUsage ¶
func (*Redis) ModuleLoadex ¶
ModuleLoadex implements redis.Cmdable
func (*Redis) ObjectEncoding ¶
func (*Redis) ObjectIdleTime ¶
func (*Redis) ObjectRefCount ¶
func (*Redis) PExpireTime ¶
PExpireTime implements redis.Cmdable
func (*Redis) PSubscribe ¶
PSubscribe subscribes the client to the given patterns. Patterns can be omitted to create empty subscription.
func (*Redis) PubSubChannels ¶
func (*Redis) PubSubNumSub ¶
func (*Redis) PubSubShardChannels ¶
PubSubShardChannels implements redis.Cmdable
func (*Redis) PubSubShardNumSub ¶
PubSubShardNumSub implements redis.Cmdable
func (*Redis) RestoreReplace ¶
func (*Redis) SDiffStore ¶
func (*Redis) SInterCard ¶
SInterCard implements redis.Cmdable
func (*Redis) SInterStore ¶
func (*Redis) SMIsMember ¶
func (r *Redis) SMIsMember(ctx context.Context, key string, members ...interface{}) *redis.BoolSliceCmd
SMIsMember implements redis.Cmdable
func (*Redis) SMembersMap ¶
func (*Redis) SRandMember ¶
func (*Redis) SRandMemberN ¶
func (*Redis) SUnionStore ¶
func (*Redis) ScanType ¶
func (r *Redis) ScanType(ctx context.Context, cursor uint64, match string, count int64, keyType string) *redis.ScanCmd
ScanType implements redis.Cmdable
func (*Redis) ScriptExists ¶
func (*Redis) ScriptLoad ¶
func (*Redis) SetArgs ¶
func (r *Redis) SetArgs(ctx context.Context, key string, value interface{}, a redis.SetArgs) *redis.StatusCmd
SetArgs implements redis.Cmdable
func (*Redis) SetEx ¶
func (r *Redis) SetEx(ctx context.Context, key string, value interface{}, expiration time.Duration) *redis.StatusCmd
SetEx implements redis.Cmdable
func (*Redis) SlowLogGet ¶
SlowLogGet implements redis.Cmdable
func (*Redis) SortInterfaces ¶
func (*Redis) Subscribe ¶
Subscribe subscribes the client to the specified channels. Channels can be omitted to create empty subscription. Note that this method does not wait on a response from Redis, so the subscription may not be active immediately. To force the connection to wait, you may call the Receive() method on the returned *PubSub like so:
sub := client.Subscribe(queryResp) iface, err := sub.Receive() if err != nil { // handle error } // Should be *Subscription, but others are possible if other actions have been // taken on sub since it was created. switch iface.(type) { case *Subscription: // subscribe succeeded case *Message: // received first message case *Pong: // pong received default: // handle error } ch := sub.Channel()
func (*Redis) TDigestAdd ¶
TDigestAdd implements redis.Cmdable.
func (*Redis) TDigestByRank ¶
TDigestByRank implements redis.Cmdable.
func (*Redis) TDigestByRevRank ¶
func (r *Redis) TDigestByRevRank(ctx context.Context, key string, rank ...uint64) *redis.FloatSliceCmd
TDigestByRevRank implements redis.Cmdable.
func (*Redis) TDigestCDF ¶
func (r *Redis) TDigestCDF(ctx context.Context, key string, elements ...float64) *redis.FloatSliceCmd
TDigestCDF implements redis.Cmdable.
func (*Redis) TDigestCreate ¶
TDigestCreate implements redis.Cmdable.
func (*Redis) TDigestCreateWithCompression ¶
func (r *Redis) TDigestCreateWithCompression(ctx context.Context, key string, compression int64) *redis.StatusCmd
TDigestCreateWithCompression implements redis.Cmdable.
func (*Redis) TDigestInfo ¶
TDigestInfo implements redis.Cmdable.
func (*Redis) TDigestMax ¶
TDigestMax implements redis.Cmdable.
func (*Redis) TDigestMerge ¶
func (r *Redis) TDigestMerge(ctx context.Context, destKey string, options *redis.TDigestMergeOptions, sourceKeys ...string) *redis.StatusCmd
TDigestMerge implements redis.Cmdable.
func (*Redis) TDigestMin ¶
TDigestMin implements redis.Cmdable.
func (*Redis) TDigestQuantile ¶
func (r *Redis) TDigestQuantile(ctx context.Context, key string, elements ...float64) *redis.FloatSliceCmd
TDigestQuantile implements redis.Cmdable.
func (*Redis) TDigestRank ¶
TDigestRank implements redis.Cmdable.
func (*Redis) TDigestReset ¶
TDigestReset implements redis.Cmdable.
func (*Redis) TDigestRevRank ¶
func (r *Redis) TDigestRevRank(ctx context.Context, key string, values ...float64) *redis.IntSliceCmd
TDigestRevRank implements redis.Cmdable.
func (*Redis) TDigestTrimmedMean ¶
func (r *Redis) TDigestTrimmedMean(ctx context.Context, key string, lowCutQuantile float64, highCutQuantile float64) *redis.FloatCmd
TDigestTrimmedMean implements redis.Cmdable.
func (*Redis) TFCall ¶
func (r *Redis) TFCall(ctx context.Context, libName string, funcName string, numKeys int) *redis.Cmd
TFCall implements redis.Cmdable.
func (*Redis) TFCallASYNC ¶
func (r *Redis) TFCallASYNC(ctx context.Context, libName string, funcName string, numKeys int) *redis.Cmd
TFCallASYNC implements redis.Cmdable.
func (*Redis) TFCallASYNCArgs ¶
func (r *Redis) TFCallASYNCArgs(ctx context.Context, libName string, funcName string, numKeys int, options *redis.TFCallOptions) *redis.Cmd
TFCallASYNCArgs implements redis.Cmdable.
func (*Redis) TFCallArgs ¶
func (r *Redis) TFCallArgs(ctx context.Context, libName string, funcName string, numKeys int, options *redis.TFCallOptions) *redis.Cmd
TFCallArgs implements redis.Cmdable.
func (*Redis) TFunctionDelete ¶
TFunctionDelete implements redis.Cmdable.
func (*Redis) TFunctionList ¶
func (r *Redis) TFunctionList(ctx context.Context) *redis.MapStringInterfaceSliceCmd
TFunctionList implements redis.Cmdable.
func (*Redis) TFunctionListArgs ¶
func (r *Redis) TFunctionListArgs(ctx context.Context, options *redis.TFunctionListOptions) *redis.MapStringInterfaceSliceCmd
TFunctionListArgs implements redis.Cmdable.
func (*Redis) TFunctionLoad ¶
TFunctionLoad implements redis.Cmdable.
func (*Redis) TFunctionLoadArgs ¶
func (r *Redis) TFunctionLoadArgs(ctx context.Context, lib string, options *redis.TFunctionLoadOptions) *redis.StatusCmd
TFunctionLoadArgs implements redis.Cmdable.
func (*Redis) TopKAdd ¶
func (r *Redis) TopKAdd(ctx context.Context, key string, elements ...interface{}) *redis.StringSliceCmd
TopKAdd implements redis.Cmdable.
func (*Redis) TopKCount ¶
func (r *Redis) TopKCount(ctx context.Context, key string, elements ...interface{}) *redis.IntSliceCmd
TopKCount implements redis.Cmdable.
func (*Redis) TopKIncrBy ¶
func (r *Redis) TopKIncrBy(ctx context.Context, key string, elements ...interface{}) *redis.StringSliceCmd
TopKIncrBy implements redis.Cmdable.
func (*Redis) TopKListWithCount ¶
TopKListWithCount implements redis.Cmdable.
func (*Redis) TopKQuery ¶
func (r *Redis) TopKQuery(ctx context.Context, key string, elements ...interface{}) *redis.BoolSliceCmd
TopKQuery implements redis.Cmdable.
func (*Redis) TopKReserve ¶
TopKReserve implements redis.Cmdable.
func (*Redis) TopKReserveWithOptions ¶
func (r *Redis) TopKReserveWithOptions(ctx context.Context, key string, k int64, width int64, depth int64, decay float64) *redis.StatusCmd
TopKReserveWithOptions implements redis.Cmdable.
func (*Redis) TxPipeline ¶
TxPipeline acts like Pipeline, but wraps queued commands with MULTI/EXEC.
func (*Redis) TxPipelined ¶
func (*Redis) XAutoClaim ¶
func (r *Redis) XAutoClaim(ctx context.Context, a *redis.XAutoClaimArgs) *redis.XAutoClaimCmd
XAutoClaim implements redis.Cmdable
func (*Redis) XAutoClaimJustID ¶
func (r *Redis) XAutoClaimJustID(ctx context.Context, a *redis.XAutoClaimArgs) *redis.XAutoClaimJustIDCmd
XAutoClaimJustID implements redis.Cmdable
func (*Redis) XClaim ¶
func (r *Redis) XClaim(ctx context.Context, a *redis.XClaimArgs) *redis.XMessageSliceCmd
func (*Redis) XClaimJustID ¶
func (r *Redis) XClaimJustID(ctx context.Context, a *redis.XClaimArgs) *redis.StringSliceCmd
func (*Redis) XGroupCreate ¶
func (*Redis) XGroupCreateConsumer ¶
func (r *Redis) XGroupCreateConsumer(ctx context.Context, stream string, group string, consumer string) *redis.IntCmd
XGroupCreateConsumer implements redis.Cmdable
func (*Redis) XGroupCreateMkStream ¶
func (*Redis) XGroupDelConsumer ¶
func (*Redis) XGroupDestroy ¶
func (*Redis) XGroupSetID ¶
func (*Redis) XInfoConsumers ¶
func (r *Redis) XInfoConsumers(ctx context.Context, key string, group string) *redis.XInfoConsumersCmd
XInfoConsumers implements redis.Cmdable
func (*Redis) XInfoGroups ¶
XInfoGroups implements redis.Cmdable
func (*Redis) XInfoStream ¶
XInfoStream implements redis.Cmdable
func (*Redis) XInfoStreamFull ¶
func (r *Redis) XInfoStreamFull(ctx context.Context, key string, count int) *redis.XInfoStreamFullCmd
XInfoStreamFull implements redis.Cmdable
func (*Redis) XPendingExt ¶
func (r *Redis) XPendingExt(ctx context.Context, a *redis.XPendingExtArgs) *redis.XPendingExtCmd
func (*Redis) XReadGroup ¶
func (r *Redis) XReadGroup(ctx context.Context, a *redis.XReadGroupArgs) *redis.XStreamSliceCmd
func (*Redis) XReadStreams ¶
func (*Redis) XRevRangeN ¶
func (*Redis) XTrimMaxLen ¶
XTrimMaxLen implements redis.Cmdable
func (*Redis) XTrimMaxLenApprox ¶
func (r *Redis) XTrimMaxLenApprox(ctx context.Context, key string, maxLen int64, limit int64) *redis.IntCmd
XTrimMaxLenApprox implements redis.Cmdable
func (*Redis) XTrimMinID ¶
XTrimMinID implements redis.Cmdable
func (*Redis) XTrimMinIDApprox ¶
func (r *Redis) XTrimMinIDApprox(ctx context.Context, key string, minID string, limit int64) *redis.IntCmd
XTrimMinIDApprox implements redis.Cmdable
func (*Redis) ZAddArgsIncr ¶
ZAddArgsIncr implements redis.Cmdable
func (*Redis) ZDiffStore ¶
ZDiffStore implements redis.Cmdable
func (*Redis) ZDiffWithScores ¶
ZDiffWithScores implements redis.Cmdable
func (*Redis) ZInterCard ¶
ZInterCard implements redis.Cmdable
func (*Redis) ZInterStore ¶
func (*Redis) ZInterWithScores ¶
ZInterWithScores implements redis.Cmdable
func (*Redis) ZMPop ¶
func (r *Redis) ZMPop(ctx context.Context, order string, count int64, keys ...string) *redis.ZSliceWithKeyCmd
ZMPop implements redis.Cmdable
func (*Redis) ZRandMember ¶
ZRandMember implements redis.Cmdable
func (*Redis) ZRandMemberWithScores ¶
ZRandMemberWithScores implements redis.Cmdable
func (*Redis) ZRangeArgs ¶
func (r *Redis) ZRangeArgs(ctx context.Context, z redis.ZRangeArgs) *redis.StringSliceCmd
ZRangeArgs implements redis.Cmdable
func (*Redis) ZRangeArgsWithScores ¶
ZRangeArgsWithScores implements redis.Cmdable
func (*Redis) ZRangeByLex ¶
func (*Redis) ZRangeByScore ¶
func (*Redis) ZRangeByScoreWithScores ¶
func (*Redis) ZRangeStore ¶
ZRangeStore implements redis.Cmdable
func (*Redis) ZRangeWithScores ¶
func (*Redis) ZRankWithScore ¶
func (r *Redis) ZRankWithScore(ctx context.Context, key string, member string) *redis.RankWithScoreCmd
ZRankWithScore implements redis.Cmdable
func (*Redis) ZRemRangeByLex ¶
func (*Redis) ZRemRangeByRank ¶
func (*Redis) ZRemRangeByScore ¶
func (*Redis) ZRevRangeByLex ¶
func (*Redis) ZRevRangeByScore ¶
func (*Redis) ZRevRangeByScoreWithScores ¶
func (*Redis) ZRevRangeWithScores ¶
func (*Redis) ZRevRankWithScore ¶
func (r *Redis) ZRevRankWithScore(ctx context.Context, key string, member string) *redis.RankWithScoreCmd
ZRevRankWithScore implements redis.Cmdable