redis

package
v0.5.42 Latest Latest
Warning

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

 Go to latest Published: Sep 30, 2025 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewCluster 

func NewCluster() interface{}

Types

type Client 

type Client struct {
	*redis.Client
	// contains filtered or unexported fields
}

func New 

func New(opts ...Option) *Client

func (*Client) Append 

func (cli *Client) Append(key, value string) *redis.IntCmd

func (*Client) BLMove 

func (cli *Client) BLMove(source, destination, srcpos, destpos string, timeout time.Duration) *redis.StringCmd

func (*Client) BLPop 

func (cli *Client) BLPop(timeout time.Duration, keys ...string) *redis.StringSliceCmd

func (*Client) BRPop 

func (cli *Client) BRPop(timeout time.Duration, keys ...string) *redis.StringSliceCmd

func (*Client) BRPopLPush 

func (cli *Client) BRPopLPush(source, destination string, timeout time.Duration) *redis.StringCmd

func (*Client) BZPopMax 

func (cli *Client) BZPopMax(timeout time.Duration, keys ...string) *redis.ZWithKeyCmd

func (*Client) BZPopMin 

func (cli *Client) BZPopMin(timeout time.Duration, keys ...string) *redis.ZWithKeyCmd

func (*Client) BitCount 

func (cli *Client) BitCount(key string, bitCount *redis.BitCount) *redis.IntCmd

func (*Client) BitField 

func (cli *Client) BitField(key string, args ...interface{}) *redis.IntSliceCmd

func (*Client) BitOpAnd 

func (cli *Client) BitOpAnd(destKey string, keys ...string) *redis.IntCmd

func (*Client) BitOpNot 

func (cli *Client) BitOpNot(destKey string, key string) *redis.IntCmd

func (*Client) BitOpOr 

func (cli *Client) BitOpOr(destKey string, keys ...string) *redis.IntCmd

func (*Client) BitOpXor 

func (cli *Client) BitOpXor(destKey string, keys ...string) *redis.IntCmd

func (*Client) BitPos 

func (cli *Client) BitPos(key string, bit int64, pos ...int64) *redis.IntCmd

func (*Client) ClientGetName 

func (cli *Client) ClientGetName() *redis.StringCmd

func (*Client) ClientKill 

func (cli *Client) ClientKill(ipPort string) *redis.StatusCmd

func (*Client) ClientKillByFilter 

func (cli *Client) ClientKillByFilter(keys ...string) *redis.IntCmd

func (*Client) ClientPause 

func (cli *Client) ClientPause(dur time.Duration) *redis.BoolCmd

func (*Client) ClusterAddSlots 

func (cli *Client) ClusterAddSlots(slots ...int) *redis.StatusCmd

func (*Client) ClusterAddSlotsRange 

func (cli *Client) ClusterAddSlotsRange(min, max int) *redis.StatusCmd

func (*Client) ClusterCountFailureReports 

func (cli *Client) ClusterCountFailureReports(nodeID string) *redis.IntCmd

func (*Client) ClusterCountKeysInSlot 

func (cli *Client) ClusterCountKeysInSlot(slot int) *redis.IntCmd

func (*Client) ClusterDelSlots 

func (cli *Client) ClusterDelSlots(slots ...int) *redis.StatusCmd

func (*Client) ClusterDelSlotsRange 

func (cli *Client) ClusterDelSlotsRange(min, max int) *redis.StatusCmd

func (*Client) ClusterForget 

func (cli *Client) ClusterForget(nodeID string) *redis.StatusCmd

func (*Client) ClusterGetKeysInSlot 

func (cli *Client) ClusterGetKeysInSlot(slot int, count int) *redis.StringSliceCmd

func (*Client) ClusterKeySlot 

func (cli *Client) ClusterKeySlot(key string) *redis.IntCmd

func (*Client) ClusterMeet 

func (cli *Client) ClusterMeet(host, port string) *redis.StatusCmd

func (*Client) ClusterReplicate 

func (cli *Client) ClusterReplicate(nodeID string) *redis.StatusCmd

func (*Client) ClusterSlaves 

func (cli *Client) ClusterSlaves(nodeID string) *redis.StringSliceCmd

func (*Client) Command 

func (cli *Client) Command() *redis.CommandsInfoCmd

func (*Client) ConfigGet 

func (cli *Client) ConfigGet(parameter string) *redis.SliceCmd

func (*Client) ConfigSet 

func (cli *Client) ConfigSet(parameter, value string) *redis.StatusCmd

func (*Client) Copy 

func (cli *Client) Copy(sourceKey string, destKey string, db int, replace bool) *redis.IntCmd

func (*Client) DebugObject 

func (cli *Client) DebugObject(key string) *redis.StringCmd

func (*Client) Decr 

func (cli *Client) Decr(key string) *redis.IntCmd

func (*Client) DecrBy 

func (cli *Client) DecrBy(key string, decrement int64) *redis.IntCmd

func (*Client) Del 

func (cli *Client) Del(keys ...string) *redis.IntCmd

func (*Client) Dump 

func (cli *Client) Dump(key string) *redis.StringCmd

func (*Client) Echo 

func (cli *Client) Echo(message interface{}) *redis.StringCmd

func (*Client) Eval 

func (cli *Client) Eval(script string, keys []string, args ...interface{}) *redis.Cmd

func (*Client) EvalSha 

func (cli *Client) EvalSha(sha1 string, keys []string, args ...interface{}) *redis.Cmd

func (*Client) Exists 

func (cli *Client) Exists(keys ...string) *redis.IntCmd

func (*Client) Expire 

func (cli *Client) Expire(key string, expiration time.Duration) *redis.BoolCmd

func (*Client) ExpireAt 

func (cli *Client) ExpireAt(key string, tm time.Time) *redis.BoolCmd

func (*Client) ExpireGT 

func (cli *Client) ExpireGT(key string, expiration time.Duration) *redis.BoolCmd

func (*Client) ExpireLT 

func (cli *Client) ExpireLT(key string, expiration time.Duration) *redis.BoolCmd

func (*Client) ExpireNX 

func (cli *Client) ExpireNX(key string, expiration time.Duration) *redis.BoolCmd

func (*Client) ExpireXX 

func (cli *Client) ExpireXX(key string, expiration time.Duration) *redis.BoolCmd

func (*Client) GeoAdd 

func (cli *Client) GeoAdd(key string, geoLocation ...*redis.GeoLocation) *redis.IntCmd

func (*Client) GeoDist 

func (cli *Client) GeoDist(key string, member1, member2, unit string) *redis.FloatCmd

func (*Client) GeoHash 

func (cli *Client) GeoHash(key string, members ...string) *redis.StringSliceCmd

func (*Client) GeoPos 

func (cli *Client) GeoPos(key string, members ...string) *redis.GeoPosCmd

func (*Client) GeoRadius 

func (cli *Client) GeoRadius(key string, longitude, latitude float64, query *redis.GeoRadiusQuery) *redis.GeoLocationCmd

func (*Client) GeoRadiusByMember 

func (cli *Client) GeoRadiusByMember(key, member string, query *redis.GeoRadiusQuery) *redis.GeoLocationCmd

func (*Client) GeoRadiusByMemberStore 

func (cli *Client) GeoRadiusByMemberStore(key, member string, query *redis.GeoRadiusQuery) *redis.IntCmd

func (*Client) GeoRadiusStore 

func (cli *Client) GeoRadiusStore(key string, longitude, latitude float64, query *redis.GeoRadiusQuery) *redis.IntCmd

func (*Client) GeoSearch 

func (cli *Client) GeoSearch(key string, q *redis.GeoSearchQuery) *redis.StringSliceCmd

func (*Client) GeoSearchLocation 

func (cli *Client) GeoSearchLocation(key string, q *redis.GeoSearchLocationQuery) *redis.GeoSearchLocationCmd

func (*Client) GeoSearchStore 

func (cli *Client) GeoSearchStore(key, store string, q *redis.GeoSearchStoreQuery) *redis.IntCmd

func (*Client) Get 

func (cli *Client) Get(key string) *redis.StringCmd

func (*Client) GetBit 

func (cli *Client) GetBit(key string, offset int64) *redis.IntCmd

func (*Client) GetDel 

func (cli *Client) GetDel(key string) *redis.StringCmd

func (*Client) GetEx 

func (cli *Client) GetEx(key string, expiration time.Duration) *redis.StringCmd

func (*Client) GetRange 

func (cli *Client) GetRange(key string, start, end int64) *redis.StringCmd

func (*Client) GetSet 

func (cli *Client) GetSet(key string, value interface{}) *redis.StringCmd

func (*Client) HDel 

func (cli *Client) HDel(key string, fields ...string) *redis.IntCmd

func (*Client) HExists 

func (cli *Client) HExists(key, field string) *redis.BoolCmd

func (*Client) HGet 

func (cli *Client) HGet(key, field string) *redis.StringCmd

func (*Client) HGetAll 

func (cli *Client) HGetAll(key string) *redis.StringStringMapCmd

func (*Client) HIncrBy 

func (cli *Client) HIncrBy(key, field string, incr int64) *redis.IntCmd

func (*Client) HIncrByFloat 

func (cli *Client) HIncrByFloat(key, field string, incr float64) *redis.FloatCmd

func (*Client) HKeys 

func (cli *Client) HKeys(key string) *redis.StringSliceCmd

func (*Client) HLen 

func (cli *Client) HLen(key string) *redis.IntCmd

func (*Client) HMGet 

func (cli *Client) HMGet(key string, fields ...string) *redis.SliceCmd

func (*Client) HMSet 

func (cli *Client) HMSet(key string, values ...interface{}) *redis.BoolCmd

func (*Client) HRandField 

func (cli *Client) HRandField(key string, count int, withValues bool) *redis.StringSliceCmd

func (*Client) HScan 

func (cli *Client) HScan(ctx context.Context, key string, cursor uint64, match string, count int64) *redis.ScanCmd

func (*Client) HSet 

func (cli *Client) HSet(key string, values ...interface{}) *redis.IntCmd

func (*Client) HSetNX 

func (cli *Client) HSetNX(key, field string, value interface{}) *redis.BoolCmd

func (*Client) HVals 

func (cli *Client) HVals(key string) *redis.StringSliceCmd

func (*Client) Incr 

func (cli *Client) Incr(key string) *redis.IntCmd

func (*Client) IncrBy 

func (cli *Client) IncrBy(key string, value int64) *redis.IntCmd

func (*Client) IncrByFloat 

func (cli *Client) IncrByFloat(key string, value float64) *redis.FloatCmd

func (*Client) Info 

func (cli *Client) Info(section ...string) *redis.StringCmd

func (*Client) Keys 

func (cli *Client) Keys(pattern string) *redis.StringSliceCmd

func (*Client) LIndex 

func (cli *Client) LIndex(key string, index int64) *redis.StringCmd

func (*Client) LInsert 

func (cli *Client) LInsert(key, op string, pivot, value interface{}) *redis.IntCmd

func (*Client) LInsertAfter 

func (cli *Client) LInsertAfter(key string, pivot, value interface{}) *redis.IntCmd

func (*Client) LInsertBefore 

func (cli *Client) LInsertBefore(key string, pivot, value interface{}) *redis.IntCmd

func (*Client) LLen 

func (cli *Client) LLen(key string) *redis.IntCmd

func (*Client) LMove 

func (cli *Client) LMove(source, destination, srcpos, destpos string) *redis.StringCmd

func (*Client) LPop 

func (cli *Client) LPop(key string) *redis.StringCmd

func (*Client) LPopCount 

func (cli *Client) LPopCount(key string, count int) *redis.StringSliceCmd

func (*Client) LPos 

func (cli *Client) LPos(key string, value string, args redis.LPosArgs) *redis.IntCmd

func (*Client) LPosCount 

func (cli *Client) LPosCount(key string, value string, count int64, args redis.LPosArgs) *redis.IntSliceCmd

func (*Client) LPush 

func (cli *Client) LPush(key string, values ...interface{}) *redis.IntCmd

func (*Client) LPushX 

func (cli *Client) LPushX(key string, values ...interface{}) *redis.IntCmd

func (*Client) LRange 

func (cli *Client) LRange(key string, start, stop int64) *redis.StringSliceCmd

func (*Client) LRem 

func (cli *Client) LRem(key string, count int64, value interface{}) *redis.IntCmd

func (*Client) LSet 

func (cli *Client) LSet(key string, index int64, value interface{}) *redis.StatusCmd

func (*Client) LTrim 

func (cli *Client) LTrim(key string, start, stop int64) *redis.StatusCmd

func (*Client) MGet 

func (cli *Client) MGet(keys ...string) *redis.SliceCmd

func (*Client) MSet 

func (cli *Client) MSet(values ...interface{}) *redis.StatusCmd

func (*Client) MSetNX 

func (cli *Client) MSetNX(values ...interface{}) *redis.BoolCmd

func (*Client) MemoryUsage 

func (cli *Client) MemoryUsage(key string, samples ...int) *redis.IntCmd

func (*Client) Migrate 

func (cli *Client) Migrate(host, port, key string, db int, timeout time.Duration) *redis.StatusCmd

func (*Client) Move 

func (cli *Client) Move(key string, db int) *redis.BoolCmd

func (*Client) ObjectEncoding 

func (cli *Client) ObjectEncoding(key string) *redis.StringCmd

func (*Client) ObjectIdleTime 

func (cli *Client) ObjectIdleTime(key string) *redis.DurationCmd

func (*Client) ObjectRefCount 

func (cli *Client) ObjectRefCount(key string) *redis.IntCmd

func (*Client) PExpire 

func (cli *Client) PExpire(key string, expiration time.Duration) *redis.BoolCmd

func (*Client) PExpireAt 

func (cli *Client) PExpireAt(key string, tm time.Time) *redis.BoolCmd

func (*Client) PFAdd 

func (cli *Client) PFAdd(key string, els ...interface{}) *redis.IntCmd

func (*Client) PFCount 

func (cli *Client) PFCount(keys ...string) *redis.IntCmd

func (*Client) PFMerge 

func (cli *Client) PFMerge(dest string, keys ...string) *redis.StatusCmd

func (*Client) PTTL 

func (cli *Client) PTTL(key string) *redis.DurationCmd

func (*Client) Persist 

func (cli *Client) Persist(key string) *redis.BoolCmd

func (*Client) Ping 

func (cli *Client) Ping() *redis.StatusCmd

func (*Client) Pipelined 

func (cli *Client) Pipelined(fn func(redis.Pipeliner) error) ([]redis.Cmder, error)

func (*Client) Provide 

func (cli *Client) Provide(ctx context.Context) interface{}

func (*Client) PubSubChannels 

func (cli *Client) PubSubChannels(pattern string) *redis.StringSliceCmd

func (*Client) PubSubNumSub 

func (cli *Client) PubSubNumSub(channels ...string) *redis.StringIntMapCmd

func (*Client) Publish 

func (cli *Client) Publish(channel string, message interface{}) *redis.IntCmd

func (*Client) Quit 

func (cli *Client) Quit() *redis.StatusCmd

func (*Client) RPop 

func (cli *Client) RPop(key string) *redis.StringCmd

func (*Client) RPopCount 

func (cli *Client) RPopCount(key string, count int) *redis.StringSliceCmd

func (*Client) RPopLPush 

func (cli *Client) RPopLPush(source, destination string) *redis.StringCmd

func (*Client) RPush 

func (cli *Client) RPush(key string, values ...interface{}) *redis.IntCmd

func (*Client) RPushX 

func (cli *Client) RPushX(key string, values ...interface{}) *redis.IntCmd

func (*Client) Rename 

func (cli *Client) Rename(key, newkey string) *redis.StatusCmd

func (*Client) RenameNX 

func (cli *Client) RenameNX(key, newkey string) *redis.BoolCmd

func (*Client) Restore 

func (cli *Client) Restore(key string, ttl time.Duration, value string) *redis.StatusCmd

func (*Client) RestoreReplace 

func (cli *Client) RestoreReplace(key string, ttl time.Duration, value string) *redis.StatusCmd

func (*Client) SAdd 

func (cli *Client) SAdd(key string, members ...interface{}) *redis.IntCmd

func (*Client) SCard 

func (cli *Client) SCard(key string) *redis.IntCmd

func (*Client) SDiff 

func (cli *Client) SDiff(keys ...string) *redis.StringSliceCmd

func (*Client) SDiffStore 

func (cli *Client) SDiffStore(destination string, keys ...string) *redis.IntCmd

func (*Client) SInter 

func (cli *Client) SInter(keys ...string) *redis.StringSliceCmd

func (*Client) SInterStore 

func (cli *Client) SInterStore(destination string, keys ...string) *redis.IntCmd

func (*Client) SIsMember 

func (cli *Client) SIsMember(key string, member interface{}) *redis.BoolCmd

func (*Client) SMIsMember 

func (cli *Client) SMIsMember(key string, members ...interface{}) *redis.BoolSliceCmd

func (*Client) SMembers 

func (cli *Client) SMembers(key string) *redis.StringSliceCmd

func (*Client) SMembersMap 

func (cli *Client) SMembersMap(key string) *redis.StringStructMapCmd

func (*Client) SMove 

func (cli *Client) SMove(source, destination string, member interface{}) *redis.BoolCmd

func (*Client) SPop 

func (cli *Client) SPop(key string) *redis.StringCmd

func (*Client) SPopN 

func (cli *Client) SPopN(key string, count int64) *redis.StringSliceCmd

func (*Client) SRandMember 

func (cli *Client) SRandMember(key string) *redis.StringCmd

func (*Client) SRandMemberN 

func (cli *Client) SRandMemberN(key string, count int64) *redis.StringSliceCmd

func (*Client) SRem 

func (cli *Client) SRem(key string, members ...interface{}) *redis.IntCmd

func (*Client) SScan 

func (cli *Client) SScan(ctx context.Context, key string, cursor uint64, match string, count int64) *redis.ScanCmd

func (*Client) SUnion 

func (cli *Client) SUnion(keys ...string) *redis.StringSliceCmd

func (*Client) SUnionStore 

func (cli *Client) SUnionStore(destination string, keys ...string) *redis.IntCmd

func (*Client) Scan 

func (cli *Client) Scan(ctx context.Context, cursor uint64, match string, count int64) *redis.ScanCmd

func (*Client) ScanType 

func (cli *Client) ScanType(ctx context.Context, cursor uint64, match string, count int64, keyType string) *redis.ScanCmd

func (*Client) ScriptExists 

func (cli *Client) ScriptExists(hashes ...string) *redis.BoolSliceCmd

func (*Client) ScriptLoad 

func (cli *Client) ScriptLoad(script string) *redis.StringCmd

func (*Client) Set 

func (cli *Client) Set(key string, value interface{}, expiration time.Duration) *redis.StatusCmd

func (*Client) SetArgs 

func (cli *Client) SetArgs(key string, value interface{}, a redis.SetArgs) *redis.StatusCmd

func (*Client) SetBit 

func (cli *Client) SetBit(key string, offset int64, value int) *redis.IntCmd

func (*Client) SetEX 

func (cli *Client) SetEX(key string, value interface{}, expiration time.Duration) *redis.StatusCmd

func (*Client) SetNX 

func (cli *Client) SetNX(key string, value interface{}, expiration time.Duration) *redis.BoolCmd

func (*Client) SetRange 

func (cli *Client) SetRange(key string, offset int64, value string) *redis.IntCmd

func (*Client) SetXX 

func (cli *Client) SetXX(key string, value interface{}, expiration time.Duration) *redis.BoolCmd

func (*Client) SlaveOf 

func (cli *Client) SlaveOf(host, port string) *redis.StatusCmd

func (*Client) Sort 

func (cli *Client) Sort(key string, sort *redis.Sort) *redis.StringSliceCmd

func (*Client) SortInterfaces 

func (cli *Client) SortInterfaces(key string, sort *redis.Sort) *redis.SliceCmd

func (*Client) SortStore 

func (cli *Client) SortStore(key, store string, sort *redis.Sort) *redis.IntCmd

func (*Client) StrLen 

func (cli *Client) StrLen(key string) *redis.IntCmd

func (*Client) TTL 

func (cli *Client) TTL(key string) *redis.DurationCmd

func (*Client) Touch 

func (cli *Client) Touch(keys ...string) *redis.IntCmd

func (*Client) TxPipelined 

func (cli *Client) TxPipelined(fn func(redis.Pipeliner) error) ([]redis.Cmder, error)

func (*Client) Type 

func (cli *Client) Type(key string) *redis.StatusCmd
func (cli *Client) Unlink(keys ...string) *redis.IntCmd

func (*Client) XAck 

func (cli *Client) XAck(stream, group string, ids ...string) *redis.IntCmd

func (*Client) XAdd 

func (cli *Client) XAdd(a *redis.XAddArgs) *redis.StringCmd

func (*Client) XAutoClaim 

func (cli *Client) XAutoClaim(a *redis.XAutoClaimArgs) *redis.XAutoClaimCmd

func (*Client) XAutoClaimJustID 

func (cli *Client) XAutoClaimJustID(a *redis.XAutoClaimArgs) *redis.XAutoClaimJustIDCmd

func (*Client) XClaim 

func (cli *Client) XClaim(a *redis.XClaimArgs) *redis.XMessageSliceCmd

func (*Client) XClaimJustID 

func (cli *Client) XClaimJustID(a *redis.XClaimArgs) *redis.StringSliceCmd

func (*Client) XDel 

func (cli *Client) XDel(stream string, ids ...string) *redis.IntCmd

func (*Client) XGroupCreate 

func (cli *Client) XGroupCreate(stream, group, start string) *redis.StatusCmd

func (*Client) XGroupCreateConsumer 

func (cli *Client) XGroupCreateConsumer(stream, group, consumer string) *redis.IntCmd

func (*Client) XGroupCreateMkStream 

func (cli *Client) XGroupCreateMkStream(stream, group, start string) *redis.StatusCmd

func (*Client) XGroupDelConsumer 

func (cli *Client) XGroupDelConsumer(stream, group, consumer string) *redis.IntCmd

func (*Client) XGroupDestroy 

func (cli *Client) XGroupDestroy(stream, group string) *redis.IntCmd

func (*Client) XGroupSetID 

func (cli *Client) XGroupSetID(stream, group, start string) *redis.StatusCmd

func (*Client) XInfoConsumers 

func (cli *Client) XInfoConsumers(key string, group string) *redis.XInfoConsumersCmd

func (*Client) XInfoGroups 

func (cli *Client) XInfoGroups(key string) *redis.XInfoGroupsCmd

func (*Client) XInfoStream 

func (cli *Client) XInfoStream(key string) *redis.XInfoStreamCmd

func (*Client) XInfoStreamFull 

func (cli *Client) XInfoStreamFull(key string, count int) *redis.XInfoStreamFullCmd

func (*Client) XLen 

func (cli *Client) XLen(stream string) *redis.IntCmd

func (*Client) XPending 

func (cli *Client) XPending(stream, group string) *redis.XPendingCmd

func (*Client) XPendingExt 

func (cli *Client) XPendingExt(a *redis.XPendingExtArgs) *redis.XPendingExtCmd

func (*Client) XRange 

func (cli *Client) XRange(stream, start, stop string) *redis.XMessageSliceCmd

func (*Client) XRangeN 

func (cli *Client) XRangeN(stream, start, stop string, count int64) *redis.XMessageSliceCmd

func (*Client) XRead 

func (cli *Client) XRead(a *redis.XReadArgs) *redis.XStreamSliceCmd

func (*Client) XReadGroup 

func (cli *Client) XReadGroup(a *redis.XReadGroupArgs) *redis.XStreamSliceCmd

func (*Client) XReadStreams 

func (cli *Client) XReadStreams(streams ...string) *redis.XStreamSliceCmd

func (*Client) XRevRange 

func (cli *Client) XRevRange(stream string, start, stop string) *redis.XMessageSliceCmd

func (*Client) XRevRangeN 

func (cli *Client) XRevRangeN(stream string, start, stop string, count int64) *redis.XMessageSliceCmd

func (*Client) XTrim 

func (cli *Client) XTrim(key string, maxLen int64) *redis.IntCmd

func (*Client) XTrimApprox 

func (cli *Client) XTrimApprox(key string, maxLen int64) *redis.IntCmd

func (*Client) XTrimMaxLen 

func (cli *Client) XTrimMaxLen(key string, maxLen int64) *redis.IntCmd

func (*Client) XTrimMaxLenApprox 

func (cli *Client) XTrimMaxLenApprox(key string, maxLen, limit int64) *redis.IntCmd

func (*Client) XTrimMinID 

func (cli *Client) XTrimMinID(key string, minID string) *redis.IntCmd

func (*Client) XTrimMinIDApprox 

func (cli *Client) XTrimMinIDApprox(key string, minID string, limit int64) *redis.IntCmd

func (*Client) ZAdd 

func (cli *Client) ZAdd(key string, members ...*redis.Z) *redis.IntCmd

func (*Client) ZAddArgs 

func (cli *Client) ZAddArgs(key string, args redis.ZAddArgs) *redis.IntCmd

func (*Client) ZAddArgsIncr 

func (cli *Client) ZAddArgsIncr(key string, args redis.ZAddArgs) *redis.FloatCmd

func (*Client) ZAddCh 

func (cli *Client) ZAddCh(key string, members ...*redis.Z) *redis.IntCmd

func (*Client) ZAddNX 

func (cli *Client) ZAddNX(key string, members ...*redis.Z) *redis.IntCmd

func (*Client) ZAddNXCh 

func (cli *Client) ZAddNXCh(key string, members ...*redis.Z) *redis.IntCmd

func (*Client) ZAddXX 

func (cli *Client) ZAddXX(key string, members ...*redis.Z) *redis.IntCmd

func (*Client) ZAddXXCh 

func (cli *Client) ZAddXXCh(key string, members ...*redis.Z) *redis.IntCmd

func (*Client) ZCard 

func (cli *Client) ZCard(key string) *redis.IntCmd

func (*Client) ZCount 

func (cli *Client) ZCount(key, min, max string) *redis.IntCmd

func (*Client) ZDiff 

func (cli *Client) ZDiff(keys ...string) *redis.StringSliceCmd

func (*Client) ZDiffStore 

func (cli *Client) ZDiffStore(destination string, keys ...string) *redis.IntCmd

func (*Client) ZDiffWithScores 

func (cli *Client) ZDiffWithScores(keys ...string) *redis.ZSliceCmd

func (*Client) ZIncr 

func (cli *Client) ZIncr(key string, member *redis.Z) *redis.FloatCmd

func (*Client) ZIncrBy 

func (cli *Client) ZIncrBy(key string, increment float64, member string) *redis.FloatCmd

func (*Client) ZIncrNX 

func (cli *Client) ZIncrNX(key string, member *redis.Z) *redis.FloatCmd

func (*Client) ZIncrXX 

func (cli *Client) ZIncrXX(key string, member *redis.Z) *redis.FloatCmd

func (*Client) ZInter 

func (cli *Client) ZInter(store *redis.ZStore) *redis.StringSliceCmd

func (*Client) ZInterStore 

func (cli *Client) ZInterStore(destination string, store *redis.ZStore) *redis.IntCmd

func (*Client) ZInterWithScores 

func (cli *Client) ZInterWithScores(store *redis.ZStore) *redis.ZSliceCmd

func (*Client) ZLexCount 

func (cli *Client) ZLexCount(key, min, max string) *redis.IntCmd

func (*Client) ZMScore 

func (cli *Client) ZMScore(key string, members ...string) *redis.FloatSliceCmd

func (*Client) ZPopMax 

func (cli *Client) ZPopMax(key string, count ...int64) *redis.ZSliceCmd

func (*Client) ZPopMin 

func (cli *Client) ZPopMin(key string, count ...int64) *redis.ZSliceCmd

func (*Client) ZRandMember 

func (cli *Client) ZRandMember(key string, count int, withScores bool) *redis.StringSliceCmd

func (*Client) ZRange 

func (cli *Client) ZRange(key string, start, stop int64) *redis.StringSliceCmd

func (*Client) ZRangeArgs 

func (cli *Client) ZRangeArgs(z redis.ZRangeArgs) *redis.StringSliceCmd

func (*Client) ZRangeArgsWithScores 

func (cli *Client) ZRangeArgsWithScores(z redis.ZRangeArgs) *redis.ZSliceCmd

func (*Client) ZRangeByLex 

func (cli *Client) ZRangeByLex(key string, opt *redis.ZRangeBy) *redis.StringSliceCmd

func (*Client) ZRangeByScore 

func (cli *Client) ZRangeByScore(key string, opt *redis.ZRangeBy) *redis.StringSliceCmd

func (*Client) ZRangeByScoreWithScores 

func (cli *Client) ZRangeByScoreWithScores(key string, opt *redis.ZRangeBy) *redis.ZSliceCmd

func (*Client) ZRangeStore 

func (cli *Client) ZRangeStore(dst string, z redis.ZRangeArgs) *redis.IntCmd

func (*Client) ZRangeWithScores 

func (cli *Client) ZRangeWithScores(key string, start, stop int64) *redis.ZSliceCmd

func (*Client) ZRank 

func (cli *Client) ZRank(key, member string) *redis.IntCmd

func (*Client) ZRem 

func (cli *Client) ZRem(key string, members ...interface{}) *redis.IntCmd

func (*Client) ZRemRangeByLex 

func (cli *Client) ZRemRangeByLex(key, min, max string) *redis.IntCmd

func (*Client) ZRemRangeByRank 

func (cli *Client) ZRemRangeByRank(key string, start, stop int64) *redis.IntCmd

func (*Client) ZRemRangeByScore 

func (cli *Client) ZRemRangeByScore(key, min, max string) *redis.IntCmd

func (*Client) ZRevRange 

func (cli *Client) ZRevRange(key string, start, stop int64) *redis.StringSliceCmd

func (*Client) ZRevRangeByLex 

func (cli *Client) ZRevRangeByLex(key string, opt *redis.ZRangeBy) *redis.StringSliceCmd

func (*Client) ZRevRangeByScore 

func (cli *Client) ZRevRangeByScore(key string, opt *redis.ZRangeBy) *redis.StringSliceCmd

func (*Client) ZRevRangeByScoreWithScores 

func (cli *Client) ZRevRangeByScoreWithScores(key string, opt *redis.ZRangeBy) *redis.ZSliceCmd

func (*Client) ZRevRangeWithScores 

func (cli *Client) ZRevRangeWithScores(key string, start, stop int64) *redis.ZSliceCmd

func (*Client) ZRevRank 

func (cli *Client) ZRevRank(key, member string) *redis.IntCmd

func (*Client) ZScan 

func (cli *Client) ZScan(ctx context.Context, key string, cursor uint64, match string, count int64) *redis.ScanCmd

func (*Client) ZScore 

func (cli *Client) ZScore(key, member string) *redis.FloatCmd

func (*Client) ZUnion 

func (cli *Client) ZUnion(store redis.ZStore) *redis.StringSliceCmd

func (*Client) ZUnionStore 

func (cli *Client) ZUnionStore(dest string, store *redis.ZStore) *redis.IntCmd

func (*Client) ZUnionWithScores 

func (cli *Client) ZUnionWithScores(store redis.ZStore) *redis.ZSliceCmd

type ClusterClient 

type ClusterClient struct {
	*redis.ClusterClient
}

func (*ClusterClient) Provide 

func (cli *ClusterClient) Provide(ctx context.Context) interface{}

type Conn 

type Conn interface {
	Pipeline() redis.Pipeliner
	Pipelined(fn func(redis.Pipeliner) error) ([]redis.Cmder, error)

	TxPipelined(fn func(redis.Pipeliner) error) ([]redis.Cmder, error)
	TxPipeline() redis.Pipeliner

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

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

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

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

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

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

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

	XTrim(key string, maxLen int64) *redis.IntCmd
	XTrimApprox(key string, maxLen int64) *redis.IntCmd
	XTrimMaxLen(key string, maxLen int64) *redis.IntCmd
	XTrimMaxLenApprox(key string, maxLen, limit int64) *redis.IntCmd
	XTrimMinID(key string, minID string) *redis.IntCmd
	XTrimMinIDApprox(key string, minID string, limit int64) *redis.IntCmd
	XInfoGroups(key string) *redis.XInfoGroupsCmd
	XInfoStream(key string) *redis.XInfoStreamCmd
	XInfoStreamFull(key string, count int) *redis.XInfoStreamFullCmd
	XInfoConsumers(key string, group string) *redis.XInfoConsumersCmd

	BZPopMax(timeout time.Duration, keys ...string) *redis.ZWithKeyCmd
	BZPopMin(timeout time.Duration, keys ...string) *redis.ZWithKeyCmd

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

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

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

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

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

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

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

type Option 

type Option func(*Options)

func WithAddr 

func WithAddr(addr string) Option

func WithCtxTimeout 

func WithCtxTimeout(ctxTimeout time.Duration) Option

func WithDb 

func WithDb(dbNum int) Option

func WithDialTimeout 

func WithDialTimeout(dial time.Duration) Option

func WithIdleTimeout 

func WithIdleTimeout(idle time.Duration) Option

func WithMaxConnAge 

func WithMaxConnAge(maxConnAge time.Duration) Option

func WithMinIdle 

func WithMinIdle(minIdle int) Option

func WithPassword 

func WithPassword(password string) Option

func WithPoolSize 

func WithPoolSize(poolSize int) Option

func WithPoolTimeout 

func WithPoolTimeout(pool time.Duration) Option

func WithReadTimeout 

func WithReadTimeout(read time.Duration) Option

func WithTLS 

func WithTLS(tls bool) Option

func WithWriteTimeout 

func WithWriteTimeout(write time.Duration) Option

type Options 

type Options struct {
	Addr         string
	DbNum        int
	Password     string
	DialTimeout  time.Duration
	ReadTimeout  time.Duration
	WriteTimeout time.Duration
	MaxConnAge   time.Duration
	PoolTimeout  time.Duration
	IdleTimeout  time.Duration
	CtxTimeout   time.Duration
	PoolSize     int
	MinIdleConn  int
	TLS          bool
}

type RedisRepository 

type RedisRepository struct {
	RDB *Client `inject:""`
}

func (*RedisRepository) Del 

func (repo *RedisRepository) Del(keys ...string) error

func (*RedisRepository) Exists 

func (repo *RedisRepository) Exists(key string) (bool, error)

func (*RedisRepository) Expire 

func (repo *RedisRepository) Expire(key string, expire int64) error

func (*RedisRepository) Get 

func (repo *RedisRepository) Get(key string) (string, error)

func (*RedisRepository) Provide 

func (repo *RedisRepository) Provide(context.Context) any

func (*RedisRepository) Set 

func (repo *RedisRepository) Set(key string, value interface{}, expire int64) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

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