rdx

package
v0.0.0-...-43a62c1 Latest Latest
Warning

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

Go to latest
Published: Jan 28, 2023 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrNil          = errors.New("nil return")
	ErrWrongArgsNum = errors.New("args num error")
	ErrNegativeInt  = errors.New("redis cluster: unexpected value for Uint64")
)

Functions

func Append

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

func BLPop

func BLPop(timeout int, keys ...string) *redis.StringSliceCmd

func BRPop

func BRPop(timeout int, keys ...string) *redis.StringSliceCmd

func BRPopLPush

func BRPopLPush(source, destination string, timeout int) *redis.StringCmd

func BZPopMax

func BZPopMax(timeout int, keys ...string) *redis.ZWithKeyCmd

func BZPopMin

func BZPopMin(timeout int, keys ...string) *redis.ZWithKeyCmd

func BgRewriteAOF

func BgRewriteAOF() *redis.StatusCmd

func BgSave

func BgSave() *redis.StatusCmd

func BitCount

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

func BitField

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

func BitOpAnd

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

func BitOpNot

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

func BitOpOr

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

func BitOpXor

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

func BitPos

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

func Bool

func Bool(reply interface{}, err error) (bool, error)

func Bytes

func Bytes(reply interface{}, err error) ([]byte, error)

func ClientGetName

func ClientGetName() *redis.StringCmd

func ClientID

func ClientID() *redis.IntCmd

func ClientKill

func ClientKill(ipPort string) *redis.StatusCmd

func ClientKillByFilter

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

func ClientList

func ClientList() *redis.StringCmd

func ClientPause

func ClientPause(dur int) *redis.BoolCmd

func ClusterAddSlots

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

func ClusterAddSlotsRange

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

func ClusterCountFailureReports

func ClusterCountFailureReports(nodeID string) *redis.IntCmd

func ClusterCountKeysInSlot

func ClusterCountKeysInSlot(slot int) *redis.IntCmd

func ClusterDelSlots

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

func ClusterDelSlotsRange

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

func ClusterFailover

func ClusterFailover() *redis.StatusCmd

func ClusterForget

func ClusterForget(nodeID string) *redis.StatusCmd

func ClusterGetKeysInSlot

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

func ClusterInfo

func ClusterInfo() *redis.StringCmd

func ClusterKeySlot

func ClusterKeySlot(key string) *redis.IntCmd

func ClusterMeet

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

func ClusterNodes

func ClusterNodes() *redis.StringCmd

func ClusterReplicate

func ClusterReplicate(nodeID string) *redis.StatusCmd

func ClusterResetHard

func ClusterResetHard() *redis.StatusCmd

func ClusterResetSoft

func ClusterResetSoft() *redis.StatusCmd

func ClusterSaveConfig

func ClusterSaveConfig() *redis.StatusCmd

func ClusterSlaves

func ClusterSlaves(nodeID string) *redis.StringSliceCmd

func ClusterSlots

func ClusterSlots() *redis.ClusterSlotsCmd

func Command

func Command() *redis.CommandsInfoCmd

func ConfigGet

func ConfigGet(parameter string) *redis.SliceCmd

func ConfigResetStat

func ConfigResetStat() *redis.StatusCmd

func ConfigRewrite

func ConfigRewrite() *redis.StatusCmd

func ConfigSet

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

func DBSize

func DBSize() *redis.IntCmd

func DebugObject

func DebugObject(key string) *redis.StringCmd

func Decr

func Decr(key string) *redis.IntCmd

func DecrBy

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

func Del

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

func Dump

func Dump(key string) *redis.StringCmd

func Echo

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

func Eval

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

func EvalSha

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

func Exists

func Exists(keys ...string) int64

func Expire

func Expire(key string, expiration int) *redis.BoolCmd

func ExpireAt

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

func Float64

func Float64(reply interface{}, err error) (float64, error)

func FlushAll

func FlushAll() *redis.StatusCmd

func FlushAllAsync

func FlushAllAsync() *redis.StatusCmd

func FlushDB

func FlushDB() *redis.StatusCmd

func FlushDBAsync

func FlushDBAsync() *redis.StatusCmd

func GeoAdd

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

func GeoDist

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

func GeoHash

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

func GeoPos

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

func GeoRadius

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

func GeoRadiusByMember

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

func GeoRadiusByMemberStore

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

func GeoRadiusStore

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

func Get

func Get(key string) *redis.StringCmd

func GetBit

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

func GetDel

func GetDel(key string) *redis.StringCmd

func GetEx

func GetEx(key string, expiration int) *redis.StringCmd

func GetJson

func GetJson(key string, dst interface{}) error

func GetRange

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

func GetSet

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

func HDel

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

func HExists

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

func HGet

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

func HGetAll

func HGetAll(key string) *redis.StringStringMapCmd

func HIncrBy

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

func HIncrByFloat

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

func HKeys

func HKeys(key string) *redis.StringSliceCmd

func HLen

func HLen(key string) *redis.IntCmd

func HMGet

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

func HMSet

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

func HRandField

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

func HScan

func HScan(key string, cursor uint64, match string, count int64) *redis.ScanCmd

func HSet

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

func HSetNX

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

func HVals

func HVals(key string) *redis.StringSliceCmd

func Incr

func Incr(key string) *redis.IntCmd

func IncrBy

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

func IncrByFloat

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

func Info

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

func InitRdb

func InitRdb(addr, psw string, db int) error

func Int

func Int(reply interface{}, err error) (int, error)

func Int64

func Int64(reply interface{}, err error) (int64, error)

func Keys

func Keys(pattern string) *redis.StringSliceCmd

func LIndex

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

func LInsert

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

func LInsertAfter

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

func LInsertBefore

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

func LLen

func LLen(key string) *redis.IntCmd

func LMove

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

func LPop

func LPop(key string) *redis.StringCmd

func LPopCount

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

func LPos

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

func LPosCount

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

func LPush

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

func LPushX

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

func LRange

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

func LRem

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

func LSet

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

func LTrim

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

func LastSave

func LastSave() *redis.IntCmd

func MGet

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

func MSet

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

func MSetNX

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

func MemoryUsage

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

func Migrate

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

func Move

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

func NewRdb

func NewRdb(addr, psw string) *redis.Client

func ObjectEncoding

func ObjectEncoding(key string) *redis.StringCmd

func ObjectIdleTime

func ObjectIdleTime(key string) *redis.DurationCmd

func ObjectRefCount

func ObjectRefCount(key string) *redis.IntCmd

func PExpire

func PExpire(key string, expiration int) *redis.BoolCmd

func PExpireAt

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

func PFAdd

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

func PFCount

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

func PFMerge

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

func PTTL

func PTTL(key string) *redis.DurationCmd

func Persist

func Persist(key string) *redis.BoolCmd

func Ping

func Ping() *redis.StatusCmd

func Pipeline

func Pipeline() redis.Pipeliner

func Pipelined

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

func PubSubChannels

func PubSubChannels(pattern string) *redis.StringSliceCmd

func PubSubNumPat

func PubSubNumPat() *redis.IntCmd

func PubSubNumSub

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

func Publish

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

func Quit

func Quit() *redis.StatusCmd

func RPop

func RPop(key string) *redis.StringCmd

func RPopLPush

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

func RPush

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

func RPushX

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

func RandomKey

func RandomKey() *redis.StringCmd

func ReadOnly

func ReadOnly() *redis.StatusCmd

func ReadWrite

func ReadWrite() *redis.StatusCmd

func Rename

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

func RenameNX

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

func Restore

func Restore(key string, ttl int, value string) *redis.StatusCmd

func RestoreReplace

func RestoreReplace(key string, ttl int, value string) *redis.StatusCmd

func SAdd

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

func SCard

func SCard(key string) *redis.IntCmd

func SDiff

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

func SDiffStore

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

func SInter

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

func SInterStore

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

func SIsMember

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

func SMIsMember

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

func SMembers

func SMembers(key string) *redis.StringSliceCmd

func SMembersMap

func SMembersMap(key string) *redis.StringStructMapCmd

func SMove

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

func SPop

func SPop(key string) *redis.StringCmd

func SPopN

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

func SRandMember

func SRandMember(key string) *redis.StringCmd

func SRandMemberN

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

func SRem

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

func SScan

func SScan(key string, cursor uint64, match string, count int64) *redis.ScanCmd

func SUnion

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

func SUnionStore

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

func Save

func Save() *redis.StatusCmd

func Scan

func Scan(cursor uint64, match string, count int64) *redis.ScanCmd

func ScanType

func ScanType(cursor uint64, match string, count int64, keyType string) *redis.ScanCmd

func ScriptExists

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

func ScriptFlush

func ScriptFlush() *redis.StatusCmd

func ScriptKill

func ScriptKill() *redis.StatusCmd

func ScriptLoad

func ScriptLoad(script string) *redis.StringCmd

func Set

func Set(key string, value interface{}, expiration int) *redis.StatusCmd

func SetArgs

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

func SetBit

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

func SetEx

func SetEx(key string, value interface{}, expiration int) *redis.StatusCmd

func SetJson

func SetJson(key string, value interface{}, expiration int) error

func SetNX

func SetNX(key string, value interface{}, expiration int) *redis.BoolCmd

func SetRange

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

func SetXX

func SetXX(key string, value interface{}, expiration int) *redis.BoolCmd

func Shutdown

func Shutdown() *redis.StatusCmd

func ShutdownNoSave

func ShutdownNoSave() *redis.StatusCmd

func ShutdownSave

func ShutdownSave() *redis.StatusCmd

func SlaveOf

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

func Sort

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

func SortInterfaces

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

func SortStore

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

func StrLen

func StrLen(key string) *redis.IntCmd

func String

func String(reply interface{}, err error) (string, error)

func Strings

func Strings(reply interface{}, err error) ([]string, error)

func TTL

func TTL(key string) *redis.DurationCmd

func Time

func Time() *redis.TimeCmd

func Touch

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

func TxPipeline

func TxPipeline() redis.Pipeliner

func TxPipelined

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

func Type

func Type(key string) *redis.StatusCmd

func Uint64

func Uint64(reply interface{}, err error) (uint64, error)
func Unlink(keys ...string) *redis.IntCmd

func Values

func Values(reply interface{}, err error) ([]interface{}, error)

func XAck

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

func XAdd

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

func XClaim

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

func XClaimJustID

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

func XDel

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

func XGroupCreate

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

func XGroupCreateMkStream

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

func XGroupDelConsumer

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

func XGroupDestroy

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

func XGroupSetID

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

func XInfoConsumers

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

func XInfoGroups

func XInfoGroups(key string) *redis.XInfoGroupsCmd

func XInfoStream

func XInfoStream(key string) *redis.XInfoStreamCmd

func XLen

func XLen(stream string) *redis.IntCmd

func XPending

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

func XPendingExt

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

func XRange

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

func XRangeN

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

func XRead

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

func XReadGroup

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

func XReadStreams

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

func XRevRange

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

func XRevRangeN

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

func XTrim

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

func XTrimApprox

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

func ZAdd

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

func ZAddCh

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

func ZAddNX

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

func ZAddNXCh

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

func ZAddXX

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

func ZAddXXCh

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

func ZCard

func ZCard(key string) *redis.IntCmd

func ZCount

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

func ZDiff

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

func ZDiffStore

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

func ZDiffWithScores

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

func ZIncr

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

func ZIncrBy

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

func ZIncrNX

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

func ZIncrXX

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

func ZInter

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

func ZInterStore

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

func ZInterWithScores

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

func ZLexCount

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

func ZMScore

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

func ZPopMax

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

func ZPopMin

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

func ZRandMember

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

func ZRange

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

func ZRangeByLex

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

func ZRangeByScore

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

func ZRangeByScoreWithScores

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

func ZRangeWithScores

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

func ZRank

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

func ZRem

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

func ZRemRangeByLex

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

func ZRemRangeByRank

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

func ZRemRangeByScore

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

func ZRevRange

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

func ZRevRangeByLex

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

func ZRevRangeByScore

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

func ZRevRangeByScoreWithScores

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

func ZRevRangeWithScores

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

func ZRevRank

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

func ZScan

func ZScan(key string, cursor uint64, match string, count int64) *redis.ScanCmd

func ZScore

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

func ZUnionStore

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

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL