rueidiscompat

package
v1.0.10 Latest Latest
Warning

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

 Go to latest Published: Jun 25, 2023 License: Apache-2.0 Imports: 13 Imported by: 22

README

Go-redis like API Adapter

Though it is easier to know what command will be sent to redis at first glance if the command is constructed by the command builder, users may sometimes feel it too verbose to write.

For users who don't like the command builder, rueidiscompat.Adapter, contributed mainly by @418Coffee, is an alternative. It is a high level API which is close to go-redis's Cmdable interface.

Migrating from go-redis

You can also try adapting rueidis with existing go-redis code by replacing go-redis's UniversalClient with rueidiscompat.Adapter.

Client side caching

To use client side caching with rueidiscompat.Adapter, chain Cache(ttl) call in front of supported command.

package main

import (
	"context"
	"time"
	"github.com/redis/rueidis"
	"github.com/redis/rueidis/rueidiscompat"
)

func main() {
	ctx := context.Background()
	client, err := rueidis.NewClient(rueidis.ClientOption{InitAddress: []string{"127.0.0.1:6379"}})
	if err != nil {
		panic(err)
	}
	defer client.Close()

	compat := rueidiscompat.NewAdapter(client)
	ok, _ := compat.SetNX(ctx, "key", "val", time.Second).Result()

	// with client side caching
	res, _ := compat.Cache(time.Second).Get(ctx, "key").Result()
}

Documentation

Index

Constants

View Source 
const KeepTTL = -1

Variables

This section is empty.

Functions

This section is empty.

Types

type BitCount 

type BitCount struct {
	Start, End int64
}

type BitField 

type BitField struct {
	Get       *BitFieldArg
	Set       *BitFieldArg
	IncrBy    *BitFieldArg
	Overflow  string
	Increment int64
}

type BitFieldArg 

type BitFieldArg struct {
	Encoding string
	Offset   int64
}

type BoolCmd 

type BoolCmd struct {
	// contains filtered or unexported fields
}

func (*BoolCmd) Err 

func (cmd *BoolCmd) Err() error

func (*BoolCmd) Result 

func (cmd *BoolCmd) Result() (bool, error)

func (*BoolCmd) SetErr 

func (cmd *BoolCmd) SetErr(err error)

func (*BoolCmd) SetVal 

func (cmd *BoolCmd) SetVal(val bool)

func (*BoolCmd) Val 

func (cmd *BoolCmd) Val() bool

type BoolSliceCmd 

type BoolSliceCmd struct {
	// contains filtered or unexported fields
}

func (*BoolSliceCmd) Err 

func (cmd *BoolSliceCmd) Err() error

func (*BoolSliceCmd) Result 

func (cmd *BoolSliceCmd) Result() ([]bool, error)

func (*BoolSliceCmd) SetErr 

func (cmd *BoolSliceCmd) SetErr(err error)

func (*BoolSliceCmd) SetVal 

func (cmd *BoolSliceCmd) SetVal(val []bool)

func (*BoolSliceCmd) Val 

func (cmd *BoolSliceCmd) Val() []bool

type CacheCompat 

type CacheCompat struct {
	// contains filtered or unexported fields
}

func (CacheCompat) BitCount 

func (c CacheCompat) BitCount(ctx context.Context, key string, bitCount *BitCount) *IntCmd

func (CacheCompat) BitPos 

func (c CacheCompat) BitPos(ctx context.Context, key string, bit int64, pos ...int64) *IntCmd

func (CacheCompat) BitPosSpan 

func (c CacheCompat) BitPosSpan(ctx context.Context, key string, bit, start, end int64, span string) *IntCmd

func (CacheCompat) EvalRO added in v1.0.1 

func (c CacheCompat) EvalRO(ctx context.Context, script string, keys []string, args ...any) *Cmd

func (CacheCompat) EvalShaRO added in v1.0.1 

func (c CacheCompat) EvalShaRO(ctx context.Context, sha1 string, keys []string, args ...any) *Cmd

func (CacheCompat) FCallRO added in v1.0.1 

func (c CacheCompat) FCallRO(ctx context.Context, function string, keys []string, args ...any) *Cmd

func (CacheCompat) GeoDist 

func (c CacheCompat) GeoDist(ctx context.Context, key, member1, member2, unit string) *FloatCmd

func (CacheCompat) GeoHash 

func (c CacheCompat) GeoHash(ctx context.Context, key string, members ...string) *StringSliceCmd

func (CacheCompat) GeoPos 

func (c CacheCompat) GeoPos(ctx context.Context, key string, members ...string) *GeoPosCmd

func (CacheCompat) GeoRadius 

func (c CacheCompat) GeoRadius(ctx context.Context, key string, longitude, latitude float64, query GeoRadiusQuery) *GeoLocationCmd

GeoRadius is a read-only GEORADIUS_RO command.

func (CacheCompat) GeoRadiusByMember 

func (c CacheCompat) GeoRadiusByMember(ctx context.Context, key, member string, query GeoRadiusQuery) *GeoLocationCmd

GeoRadiusByMember is a read-only GEORADIUSBYMEMBER_RO command.

func (CacheCompat) GeoSearch 

func (c CacheCompat) GeoSearch(ctx context.Context, key string, q GeoSearchQuery) *StringSliceCmd

func (CacheCompat) Get 

func (c CacheCompat) Get(ctx context.Context, key string) *StringCmd

func (CacheCompat) GetBit 

func (c CacheCompat) GetBit(ctx context.Context, key string, offset int64) *IntCmd

func (CacheCompat) GetRange 

func (c CacheCompat) GetRange(ctx context.Context, key string, start, end int64) *StringCmd

func (CacheCompat) HExists 

func (c CacheCompat) HExists(ctx context.Context, key, field string) *BoolCmd

func (CacheCompat) HGet 

func (c CacheCompat) HGet(ctx context.Context, key, field string) *StringCmd

func (CacheCompat) HGetAll 

func (c CacheCompat) HGetAll(ctx context.Context, key string) *StringStringMapCmd

func (CacheCompat) HKeys 

func (c CacheCompat) HKeys(ctx context.Context, key string) *StringSliceCmd

func (CacheCompat) HLen 

func (c CacheCompat) HLen(ctx context.Context, key string) *IntCmd

func (CacheCompat) HMGet 

func (c CacheCompat) HMGet(ctx context.Context, key string, fields ...string) *SliceCmd

func (CacheCompat) HVals 

func (c CacheCompat) HVals(ctx context.Context, key string) *StringSliceCmd

func (CacheCompat) LIndex 

func (c CacheCompat) LIndex(ctx context.Context, key string, index int64) *StringCmd

func (CacheCompat) LLen 

func (c CacheCompat) LLen(ctx context.Context, key string) *IntCmd

func (CacheCompat) LPos 

func (c CacheCompat) LPos(ctx context.Context, key string, element string, a LPosArgs) *IntCmd

func (CacheCompat) LRange 

func (c CacheCompat) LRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd

func (CacheCompat) PTTL 

func (c CacheCompat) PTTL(ctx context.Context, key string) *DurationCmd

func (CacheCompat) SCard 

func (c CacheCompat) SCard(ctx context.Context, key string) *IntCmd

func (CacheCompat) SIsMember 

func (c CacheCompat) SIsMember(ctx context.Context, key string, member any) *BoolCmd

func (CacheCompat) SMIsMember 

func (c CacheCompat) SMIsMember(ctx context.Context, key string, members ...any) *BoolSliceCmd

func (CacheCompat) SMembers 

func (c CacheCompat) SMembers(ctx context.Context, key string) *StringSliceCmd

func (CacheCompat) SortRO 

func (c CacheCompat) SortRO(ctx context.Context, key string, sort Sort) *StringSliceCmd

func (CacheCompat) StrLen 

func (c CacheCompat) StrLen(ctx context.Context, key string) *IntCmd

func (CacheCompat) TTL 

func (c CacheCompat) TTL(ctx context.Context, key string) *DurationCmd

func (CacheCompat) Type 

func (c CacheCompat) Type(ctx context.Context, key string) *StatusCmd

func (CacheCompat) ZCard 

func (c CacheCompat) ZCard(ctx context.Context, key string) *IntCmd

func (CacheCompat) ZCount 

func (c CacheCompat) ZCount(ctx context.Context, key, min, max string) *IntCmd

func (CacheCompat) ZLexCount 

func (c CacheCompat) ZLexCount(ctx context.Context, key, min, max string) *IntCmd

func (CacheCompat) ZMScore 

func (c CacheCompat) ZMScore(ctx context.Context, key string, members ...string) *FloatSliceCmd

func (CacheCompat) ZRangeArgs 

func (c CacheCompat) ZRangeArgs(ctx context.Context, z ZRangeArgs) *StringSliceCmd

func (CacheCompat) ZRangeArgsWithScores 

func (c CacheCompat) ZRangeArgsWithScores(ctx context.Context, z ZRangeArgs) *ZSliceCmd

func (CacheCompat) ZRangeByLex 

func (c CacheCompat) ZRangeByLex(ctx context.Context, key string, opt ZRangeBy) *StringSliceCmd

func (CacheCompat) ZRangeByScore 

func (c CacheCompat) ZRangeByScore(ctx context.Context, key string, opt ZRangeBy) *StringSliceCmd

func (CacheCompat) ZRangeByScoreWithScores 

func (c CacheCompat) ZRangeByScoreWithScores(ctx context.Context, key string, opt ZRangeBy) *ZSliceCmd

func (CacheCompat) ZRangeWithScores 

func (c CacheCompat) ZRangeWithScores(ctx context.Context, key string, start, stop int64) *ZSliceCmd

func (CacheCompat) ZRank 

func (c CacheCompat) ZRank(ctx context.Context, key, member string) *IntCmd

func (CacheCompat) ZRankWithScore 

func (c CacheCompat) ZRankWithScore(ctx context.Context, key, member string) *RankWithScoreCmd

func (CacheCompat) ZRevRange 

func (c CacheCompat) ZRevRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd

func (CacheCompat) ZRevRangeByLex 

func (c CacheCompat) ZRevRangeByLex(ctx context.Context, key string, opt ZRangeBy) *StringSliceCmd

func (CacheCompat) ZRevRangeByScore 

func (c CacheCompat) ZRevRangeByScore(ctx context.Context, key string, opt ZRangeBy) *StringSliceCmd

func (CacheCompat) ZRevRangeByScoreWithScores 

func (c CacheCompat) ZRevRangeByScoreWithScores(ctx context.Context, key string, opt ZRangeBy) *ZSliceCmd

func (CacheCompat) ZRevRangeWithScores 

func (c CacheCompat) ZRevRangeWithScores(ctx context.Context, key string, start, stop int64) *ZSliceCmd

func (CacheCompat) ZRevRank 

func (c CacheCompat) ZRevRank(ctx context.Context, key, member string) *IntCmd

func (CacheCompat) ZRevRankWithScore 

func (c CacheCompat) ZRevRankWithScore(ctx context.Context, key, member string) *RankWithScoreCmd

func (CacheCompat) ZScore 

func (c CacheCompat) ZScore(ctx context.Context, key, member string) *FloatCmd

type ClusterNode 

type ClusterNode struct {
	ID   string
	Addr string
}

type ClusterSlot 

type ClusterSlot struct {
	Nodes []ClusterNode
	Start int64
	End   int64
}

type ClusterSlotsCmd 

type ClusterSlotsCmd struct {
	// contains filtered or unexported fields
}

func (*ClusterSlotsCmd) Err 

func (cmd *ClusterSlotsCmd) Err() error

func (*ClusterSlotsCmd) Result 

func (cmd *ClusterSlotsCmd) Result() ([]ClusterSlot, error)

func (*ClusterSlotsCmd) SetErr 

func (cmd *ClusterSlotsCmd) SetErr(err error)

func (*ClusterSlotsCmd) SetVal 

func (cmd *ClusterSlotsCmd) SetVal(val []ClusterSlot)

func (*ClusterSlotsCmd) Val 

func (cmd *ClusterSlotsCmd) Val() []ClusterSlot

type Cmd 

type Cmd struct {
	// contains filtered or unexported fields
}

func (*Cmd) Bool 

func (cmd *Cmd) Bool() (bool, error)

func (*Cmd) BoolSlice 

func (cmd *Cmd) BoolSlice() ([]bool, error)

func (*Cmd) Err 

func (cmd *Cmd) Err() error

func (*Cmd) Float32 

func (cmd *Cmd) Float32() (float32, error)

func (*Cmd) Float32Slice 

func (cmd *Cmd) Float32Slice() ([]float32, error)

func (*Cmd) Float64 

func (cmd *Cmd) Float64() (float64, error)

func (*Cmd) Float64Slice 

func (cmd *Cmd) Float64Slice() ([]float64, error)

func (*Cmd) Int 

func (cmd *Cmd) Int() (int, error)

func (*Cmd) Int64 

func (cmd *Cmd) Int64() (int64, error)

func (*Cmd) Int64Slice 

func (cmd *Cmd) Int64Slice() ([]int64, error)

func (*Cmd) Result 

func (cmd *Cmd) Result() (any, error)

func (*Cmd) SetErr 

func (cmd *Cmd) SetErr(err error)

func (*Cmd) SetVal 

func (cmd *Cmd) SetVal(val any)

func (*Cmd) Slice 

func (cmd *Cmd) Slice() ([]any, error)

func (*Cmd) StringSlice 

func (cmd *Cmd) StringSlice() ([]string, error)

func (*Cmd) Text 

func (cmd *Cmd) Text() (string, error)

func (*Cmd) Uint64 

func (cmd *Cmd) Uint64() (uint64, error)

func (*Cmd) Uint64Slice 

func (cmd *Cmd) Uint64Slice() ([]uint64, error)

func (*Cmd) Val 

func (cmd *Cmd) Val() any

type Cmdable 

type Cmdable interface {
	Cache(ttl time.Duration) CacheCompat

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

	GetBit(ctx context.Context, key string, offset int64) *IntCmd
	SetBit(ctx context.Context, key string, offset int64, value int64) *IntCmd
	BitCount(ctx context.Context, key string, bitCount *BitCount) *IntCmd
	BitOpAnd(ctx context.Context, destKey string, keys ...string) *IntCmd
	BitOpOr(ctx context.Context, destKey string, keys ...string) *IntCmd
	BitOpXor(ctx context.Context, destKey string, keys ...string) *IntCmd
	BitOpNot(ctx context.Context, destKey string, key string) *IntCmd
	BitPos(ctx context.Context, key string, bit int64, pos ...int64) *IntCmd
	BitPosSpan(ctx context.Context, key string, bit int64, start, end int64, span string) *IntCmd
	BitField(ctx context.Context, key string, args ...any) *IntSliceCmd

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

	HDel(ctx context.Context, key string, fields ...string) *IntCmd
	HExists(ctx context.Context, key, field string) *BoolCmd
	HGet(ctx context.Context, key, field string) *StringCmd
	HGetAll(ctx context.Context, key string) *StringStringMapCmd
	HIncrBy(ctx context.Context, key, field string, incr int64) *IntCmd
	HIncrByFloat(ctx context.Context, key, field string, incr float64) *FloatCmd
	HKeys(ctx context.Context, key string) *StringSliceCmd
	HLen(ctx context.Context, key string) *IntCmd
	HMGet(ctx context.Context, key string, fields ...string) *SliceCmd
	HSet(ctx context.Context, key string, values ...any) *IntCmd
	HMSet(ctx context.Context, key string, values ...any) *BoolCmd
	HSetNX(ctx context.Context, key, field string, value any) *BoolCmd
	HVals(ctx context.Context, key string) *StringSliceCmd
	HRandField(ctx context.Context, key string, count int64) *StringSliceCmd
	HRandFieldWithValues(ctx context.Context, key string, count int64) *KeyValueSliceCmd

	BLPop(ctx context.Context, timeout time.Duration, keys ...string) *StringSliceCmd
	BLMPop(ctx context.Context, timeout time.Duration, direction string, count int64, keys ...string) *KeyValuesCmd
	BRPop(ctx context.Context, timeout time.Duration, keys ...string) *StringSliceCmd
	BRPopLPush(ctx context.Context, source, destination string, timeout time.Duration) *StringCmd
	// TODO LCS(ctx context.Context, q *LCSQuery) *LCSCmd
	LIndex(ctx context.Context, key string, index int64) *StringCmd
	LInsert(ctx context.Context, key, op string, pivot, value any) *IntCmd
	LInsertBefore(ctx context.Context, key string, pivot, value any) *IntCmd
	LInsertAfter(ctx context.Context, key string, pivot, value any) *IntCmd
	LLen(ctx context.Context, key string) *IntCmd
	LMPop(ctx context.Context, direction string, count int64, keys ...string) *KeyValuesCmd
	LPop(ctx context.Context, key string) *StringCmd
	LPopCount(ctx context.Context, key string, count int64) *StringSliceCmd
	LPos(ctx context.Context, key string, value string, args LPosArgs) *IntCmd
	LPosCount(ctx context.Context, key string, value string, count int64, args LPosArgs) *IntSliceCmd
	LPush(ctx context.Context, key string, values ...any) *IntCmd
	LPushX(ctx context.Context, key string, values ...any) *IntCmd
	LRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd
	LRem(ctx context.Context, key string, count int64, value any) *IntCmd
	LSet(ctx context.Context, key string, index int64, value any) *StatusCmd
	LTrim(ctx context.Context, key string, start, stop int64) *StatusCmd
	RPop(ctx context.Context, key string) *StringCmd
	RPopCount(ctx context.Context, key string, count int64) *StringSliceCmd
	RPopLPush(ctx context.Context, source, destination string) *StringCmd
	RPush(ctx context.Context, key string, values ...any) *IntCmd
	RPushX(ctx context.Context, key string, values ...any) *IntCmd
	LMove(ctx context.Context, source, destination, srcpos, destpos string) *StringCmd
	BLMove(ctx context.Context, source, destination, srcpos, destpos string, timeout time.Duration) *StringCmd

	SAdd(ctx context.Context, key string, members ...any) *IntCmd
	SCard(ctx context.Context, key string) *IntCmd
	SDiff(ctx context.Context, keys ...string) *StringSliceCmd
	SDiffStore(ctx context.Context, destination string, keys ...string) *IntCmd
	SInter(ctx context.Context, keys ...string) *StringSliceCmd
	SInterCard(ctx context.Context, limit int64, keys ...string) *IntCmd
	SInterStore(ctx context.Context, destination string, keys ...string) *IntCmd
	SIsMember(ctx context.Context, key string, member any) *BoolCmd
	SMIsMember(ctx context.Context, key string, members ...any) *BoolSliceCmd
	SMembers(ctx context.Context, key string) *StringSliceCmd
	SMembersMap(ctx context.Context, key string) *StringStructMapCmd
	SMove(ctx context.Context, source, destination string, member any) *BoolCmd
	SPop(ctx context.Context, key string) *StringCmd
	SPopN(ctx context.Context, key string, count int64) *StringSliceCmd
	SRandMember(ctx context.Context, key string) *StringCmd
	SRandMemberN(ctx context.Context, key string, count int64) *StringSliceCmd
	SRem(ctx context.Context, key string, members ...any) *IntCmd
	SUnion(ctx context.Context, keys ...string) *StringSliceCmd
	SUnionStore(ctx context.Context, destination string, keys ...string) *IntCmd

	XAdd(ctx context.Context, a XAddArgs) *StringCmd
	XDel(ctx context.Context, stream string, ids ...string) *IntCmd
	XLen(ctx context.Context, stream string) *IntCmd
	XRange(ctx context.Context, stream, start, stop string) *XMessageSliceCmd
	XRangeN(ctx context.Context, stream, start, stop string, count int64) *XMessageSliceCmd
	XRevRange(ctx context.Context, stream string, start, stop string) *XMessageSliceCmd
	XRevRangeN(ctx context.Context, stream string, start, stop string, count int64) *XMessageSliceCmd
	XRead(ctx context.Context, a XReadArgs) *XStreamSliceCmd
	XReadStreams(ctx context.Context, streams ...string) *XStreamSliceCmd
	XGroupCreate(ctx context.Context, stream, group, start string) *StatusCmd
	XGroupCreateMkStream(ctx context.Context, stream, group, start string) *StatusCmd
	XGroupSetID(ctx context.Context, stream, group, start string) *StatusCmd
	XGroupDestroy(ctx context.Context, stream, group string) *IntCmd
	XGroupCreateConsumer(ctx context.Context, stream, group, consumer string) *IntCmd
	XGroupDelConsumer(ctx context.Context, stream, group, consumer string) *IntCmd
	XReadGroup(ctx context.Context, a XReadGroupArgs) *XStreamSliceCmd
	XAck(ctx context.Context, stream, group string, ids ...string) *IntCmd
	XPending(ctx context.Context, stream, group string) *XPendingCmd
	XPendingExt(ctx context.Context, a XPendingExtArgs) *XPendingExtCmd
	XClaim(ctx context.Context, a XClaimArgs) *XMessageSliceCmd
	XClaimJustID(ctx context.Context, a XClaimArgs) *StringSliceCmd
	XAutoClaim(ctx context.Context, a XAutoClaimArgs) *XAutoClaimCmd
	XAutoClaimJustID(ctx context.Context, a XAutoClaimArgs) *XAutoClaimJustIDCmd
	XTrimMaxLen(ctx context.Context, key string, maxLen int64) *IntCmd
	XTrimMaxLenApprox(ctx context.Context, key string, maxLen, limit int64) *IntCmd
	XTrimMinID(ctx context.Context, key string, minID string) *IntCmd
	XTrimMinIDApprox(ctx context.Context, key string, minID string, limit int64) *IntCmd
	XInfoGroups(ctx context.Context, key string) *XInfoGroupsCmd
	XInfoStream(ctx context.Context, key string) *XInfoStreamCmd
	XInfoStreamFull(ctx context.Context, key string, count int64) *XInfoStreamFullCmd
	XInfoConsumers(ctx context.Context, key string, group string) *XInfoConsumersCmd

	BZPopMax(ctx context.Context, timeout time.Duration, keys ...string) *ZWithKeyCmd
	BZPopMin(ctx context.Context, timeout time.Duration, keys ...string) *ZWithKeyCmd
	BZMPop(ctx context.Context, timeout time.Duration, order string, count int64, keys ...string) *ZSliceWithKeyCmd

	ZAdd(ctx context.Context, key string, members ...Z) *IntCmd
	ZAddLT(ctx context.Context, key string, members ...Z) *IntCmd
	ZAddGT(ctx context.Context, key string, members ...Z) *IntCmd
	ZAddNX(ctx context.Context, key string, members ...Z) *IntCmd
	ZAddXX(ctx context.Context, key string, members ...Z) *IntCmd
	ZAddArgs(ctx context.Context, key string, args ZAddArgs) *IntCmd
	ZAddArgsIncr(ctx context.Context, key string, args ZAddArgs) *FloatCmd
	ZCard(ctx context.Context, key string) *IntCmd
	ZCount(ctx context.Context, key, min, max string) *IntCmd
	ZLexCount(ctx context.Context, key, min, max string) *IntCmd
	ZIncrBy(ctx context.Context, key string, increment float64, member string) *FloatCmd
	ZInter(ctx context.Context, store ZStore) *StringSliceCmd
	ZInterWithScores(ctx context.Context, store ZStore) *ZSliceCmd
	ZInterCard(ctx context.Context, limit int64, keys ...string) *IntCmd
	ZInterStore(ctx context.Context, destination string, store ZStore) *IntCmd
	ZMPop(ctx context.Context, order string, count int64, keys ...string) *ZSliceWithKeyCmd
	ZMScore(ctx context.Context, key string, members ...string) *FloatSliceCmd
	ZPopMax(ctx context.Context, key string, count ...int64) *ZSliceCmd
	ZPopMin(ctx context.Context, key string, count ...int64) *ZSliceCmd
	ZRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd
	ZRangeWithScores(ctx context.Context, key string, start, stop int64) *ZSliceCmd
	ZRangeByScore(ctx context.Context, key string, opt ZRangeBy) *StringSliceCmd
	ZRangeByLex(ctx context.Context, key string, opt ZRangeBy) *StringSliceCmd
	ZRangeByScoreWithScores(ctx context.Context, key string, opt ZRangeBy) *ZSliceCmd
	ZRangeArgs(ctx context.Context, z ZRangeArgs) *StringSliceCmd
	ZRangeArgsWithScores(ctx context.Context, z ZRangeArgs) *ZSliceCmd
	ZRangeStore(ctx context.Context, dst string, z ZRangeArgs) *IntCmd
	ZRank(ctx context.Context, key, member string) *IntCmd
	ZRankWithScore(ctx context.Context, key, member string) *RankWithScoreCmd
	ZRem(ctx context.Context, key string, members ...any) *IntCmd
	ZRemRangeByRank(ctx context.Context, key string, start, stop int64) *IntCmd
	ZRemRangeByScore(ctx context.Context, key, min, max string) *IntCmd
	ZRemRangeByLex(ctx context.Context, key, min, max string) *IntCmd
	ZRevRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd
	ZRevRangeWithScores(ctx context.Context, key string, start, stop int64) *ZSliceCmd
	ZRevRangeByScore(ctx context.Context, key string, opt ZRangeBy) *StringSliceCmd
	ZRevRangeByLex(ctx context.Context, key string, opt ZRangeBy) *StringSliceCmd
	ZRevRangeByScoreWithScores(ctx context.Context, key string, opt ZRangeBy) *ZSliceCmd
	ZRevRank(ctx context.Context, key, member string) *IntCmd
	ZRevRankWithScore(ctx context.Context, key, member string) *RankWithScoreCmd
	ZScore(ctx context.Context, key, member string) *FloatCmd
	ZUnionStore(ctx context.Context, dest string, store ZStore) *IntCmd
	ZRandMember(ctx context.Context, key string, count int64) *StringSliceCmd
	ZRandMemberWithScores(ctx context.Context, key string, count int64) *ZSliceCmd
	ZUnion(ctx context.Context, store ZStore) *StringSliceCmd
	ZUnionWithScores(ctx context.Context, store ZStore) *ZSliceCmd
	ZDiff(ctx context.Context, keys ...string) *StringSliceCmd
	ZDiffWithScores(ctx context.Context, keys ...string) *ZSliceCmd
	ZDiffStore(ctx context.Context, destination string, keys ...string) *IntCmd

	PFAdd(ctx context.Context, key string, els ...any) *IntCmd
	PFCount(ctx context.Context, keys ...string) *IntCmd
	PFMerge(ctx context.Context, dest string, keys ...string) *StatusCmd

	BgRewriteAOF(ctx context.Context) *StatusCmd
	BgSave(ctx context.Context) *StatusCmd
	ClientKill(ctx context.Context, ipPort string) *StatusCmd
	ClientKillByFilter(ctx context.Context, keys ...string) *IntCmd
	ClientList(ctx context.Context) *StringCmd
	// TODO ClientInfo(ctx context.Context) *ClientInfoCmd
	ClientPause(ctx context.Context, dur time.Duration) *BoolCmd
	ClientUnpause(ctx context.Context) *BoolCmd
	ClientID(ctx context.Context) *IntCmd
	ClientUnblock(ctx context.Context, id int64) *IntCmd
	ClientUnblockWithError(ctx context.Context, id int64) *IntCmd
	ConfigGet(ctx context.Context, parameter string) *StringStringMapCmd
	ConfigResetStat(ctx context.Context) *StatusCmd
	ConfigSet(ctx context.Context, parameter, value string) *StatusCmd
	ConfigRewrite(ctx context.Context) *StatusCmd
	DBSize(ctx context.Context) *IntCmd
	FlushAll(ctx context.Context) *StatusCmd
	FlushAllAsync(ctx context.Context) *StatusCmd
	FlushDB(ctx context.Context) *StatusCmd
	FlushDBAsync(ctx context.Context) *StatusCmd
	Info(ctx context.Context, section ...string) *StringCmd
	LastSave(ctx context.Context) *IntCmd
	Save(ctx context.Context) *StatusCmd
	Shutdown(ctx context.Context) *StatusCmd
	ShutdownSave(ctx context.Context) *StatusCmd
	ShutdownNoSave(ctx context.Context) *StatusCmd
	// TODO SlaveOf(ctx context.Context, host, port string) *StatusCmd
	// TODO SlowLogGet(ctx context.Context, num int64) *SlowLogCmd
	Time(ctx context.Context) *TimeCmd
	DebugObject(ctx context.Context, key string) *StringCmd
	ReadOnly(ctx context.Context) *StatusCmd
	ReadWrite(ctx context.Context) *StatusCmd
	MemoryUsage(ctx context.Context, key string, samples ...int64) *IntCmd

	Eval(ctx context.Context, script string, keys []string, args ...any) *Cmd
	EvalSha(ctx context.Context, sha1 string, keys []string, args ...any) *Cmd
	EvalRO(ctx context.Context, script string, keys []string, args ...any) *Cmd
	EvalShaRO(ctx context.Context, sha1 string, keys []string, args ...any) *Cmd
	ScriptExists(ctx context.Context, hashes ...string) *BoolSliceCmd
	ScriptFlush(ctx context.Context) *StatusCmd
	ScriptKill(ctx context.Context) *StatusCmd
	ScriptLoad(ctx context.Context, script string) *StringCmd

	FunctionLoad(ctx context.Context, code string) *StringCmd
	FunctionLoadReplace(ctx context.Context, code string) *StringCmd
	FunctionDelete(ctx context.Context, libName string) *StringCmd
	FunctionFlush(ctx context.Context) *StringCmd
	FunctionKill(ctx context.Context) *StringCmd
	FunctionFlushAsync(ctx context.Context) *StringCmd
	FunctionList(ctx context.Context, q FunctionListQuery) *FunctionListCmd
	FunctionDump(ctx context.Context) *StringCmd
	FunctionRestore(ctx context.Context, libDump string) *StringCmd
	// TODO FunctionStats(ctx context.Context) *FunctionStatsCmd
	FCall(ctx context.Context, function string, keys []string, args ...any) *Cmd
	FCallRO(ctx context.Context, function string, keys []string, args ...any) *Cmd

	Publish(ctx context.Context, channel string, message any) *IntCmd
	SPublish(ctx context.Context, channel string, message any) *IntCmd
	PubSubChannels(ctx context.Context, pattern string) *StringSliceCmd
	PubSubNumSub(ctx context.Context, channels ...string) *StringIntMapCmd
	PubSubNumPat(ctx context.Context) *IntCmd
	PubSubShardChannels(ctx context.Context, pattern string) *StringSliceCmd
	PubSubShardNumSub(ctx context.Context, channels ...string) *StringIntMapCmd

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

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

	ACLDryRun(ctx context.Context, username string, command ...any) *StringCmd
}

func NewAdapter 

func NewAdapter(client rueidis.Client) Cmdable

type CommandInfo 

type CommandInfo struct {
	Name        string
	Flags       []string
	ACLFlags    []string
	Arity       int64
	FirstKeyPos int64
	LastKeyPos  int64
	StepCount   int64
	ReadOnly    bool
}

type CommandsInfoCmd 

type CommandsInfoCmd struct {
	// contains filtered or unexported fields
}

func (*CommandsInfoCmd) Err 

func (cmd *CommandsInfoCmd) Err() error

func (*CommandsInfoCmd) Result 

func (cmd *CommandsInfoCmd) Result() (map[string]CommandInfo, error)

func (*CommandsInfoCmd) SetErr 

func (cmd *CommandsInfoCmd) SetErr(err error)

func (*CommandsInfoCmd) SetVal 

func (cmd *CommandsInfoCmd) SetVal(val map[string]CommandInfo)

func (*CommandsInfoCmd) Val 

func (cmd *CommandsInfoCmd) Val() map[string]CommandInfo

type Compat 

type Compat struct {
	// contains filtered or unexported fields
}

func (*Compat) ACLDryRun 

func (c *Compat) ACLDryRun(ctx context.Context, username string, command ...any) *StringCmd

func (*Compat) Append 

func (c *Compat) Append(ctx context.Context, key, value string) *IntCmd

func (*Compat) BLMPop 

func (c *Compat) BLMPop(ctx context.Context, timeout time.Duration, direction string, count int64, keys ...string) *KeyValuesCmd

func (*Compat) BLMove 

func (c *Compat) BLMove(ctx context.Context, source, destination, srcpos, destpos string, timeout time.Duration) *StringCmd

func (*Compat) BLPop 

func (c *Compat) BLPop(ctx context.Context, timeout time.Duration, keys ...string) *StringSliceCmd

func (*Compat) BRPop 

func (c *Compat) BRPop(ctx context.Context, timeout time.Duration, keys ...string) *StringSliceCmd

func (*Compat) BRPopLPush 

func (c *Compat) BRPopLPush(ctx context.Context, source, destination string, timeout time.Duration) *StringCmd

func (*Compat) BZMPop 

func (c *Compat) BZMPop(ctx context.Context, timeout time.Duration, order string, count int64, keys ...string) *ZSliceWithKeyCmd

func (*Compat) BZPopMax 

func (c *Compat) BZPopMax(ctx context.Context, timeout time.Duration, keys ...string) *ZWithKeyCmd

BZPopMax Redis `BZPOPMAX key [key ...] timeout` command.

func (*Compat) BZPopMin 

func (c *Compat) BZPopMin(ctx context.Context, timeout time.Duration, keys ...string) *ZWithKeyCmd

BZPopMin Redis `BZPOPMIN key [key ...] timeout` command.

func (*Compat) BgRewriteAOF 

func (c *Compat) BgRewriteAOF(ctx context.Context) *StatusCmd

func (*Compat) BgSave 

func (c *Compat) BgSave(ctx context.Context) *StatusCmd

func (*Compat) BitCount 

func (c *Compat) BitCount(ctx context.Context, key string, bitCount *BitCount) *IntCmd

func (*Compat) BitField 

func (c *Compat) BitField(ctx context.Context, key string, args ...any) *IntSliceCmd

func (*Compat) BitOpAnd 

func (c *Compat) BitOpAnd(ctx context.Context, destKey string, keys ...string) *IntCmd

func (*Compat) BitOpNot 

func (c *Compat) BitOpNot(ctx context.Context, destKey string, key string) *IntCmd

func (*Compat) BitOpOr 

func (c *Compat) BitOpOr(ctx context.Context, destKey string, keys ...string) *IntCmd

func (*Compat) BitOpXor 

func (c *Compat) BitOpXor(ctx context.Context, destKey string, keys ...string) *IntCmd

func (*Compat) BitPos 

func (c *Compat) BitPos(ctx context.Context, key string, bit int64, pos ...int64) *IntCmd

func (*Compat) BitPosSpan 

func (c *Compat) BitPosSpan(ctx context.Context, key string, bit, start, end int64, span string) *IntCmd

func (*Compat) Cache 

func (c *Compat) Cache(ttl time.Duration) CacheCompat

func (*Compat) ClientGetName 

func (c *Compat) ClientGetName(ctx context.Context) *StringCmd

func (*Compat) ClientID 

func (c *Compat) ClientID(ctx context.Context) *IntCmd

func (*Compat) ClientKill 

func (c *Compat) ClientKill(ctx context.Context, ipPort string) *StatusCmd

func (*Compat) ClientKillByFilter 

func (c *Compat) ClientKillByFilter(ctx context.Context, keys ...string) *IntCmd

func (*Compat) ClientList 

func (c *Compat) ClientList(ctx context.Context) *StringCmd

func (*Compat) ClientPause 

func (c *Compat) ClientPause(ctx context.Context, dur time.Duration) *BoolCmd

func (*Compat) ClientUnblock 

func (c *Compat) ClientUnblock(ctx context.Context, id int64) *IntCmd

func (*Compat) ClientUnblockWithError 

func (c *Compat) ClientUnblockWithError(ctx context.Context, id int64) *IntCmd

func (*Compat) ClientUnpause 

func (c *Compat) ClientUnpause(ctx context.Context) *BoolCmd

func (*Compat) ClusterAddSlots 

func (c *Compat) ClusterAddSlots(ctx context.Context, slots ...int64) *StatusCmd

func (*Compat) ClusterAddSlotsRange 

func (c *Compat) ClusterAddSlotsRange(ctx context.Context, min, max int64) *StatusCmd

func (*Compat) ClusterCountFailureReports 

func (c *Compat) ClusterCountFailureReports(ctx context.Context, nodeID string) *IntCmd

func (*Compat) ClusterCountKeysInSlot 

func (c *Compat) ClusterCountKeysInSlot(ctx context.Context, slot int64) *IntCmd

func (*Compat) ClusterDelSlots 

func (c *Compat) ClusterDelSlots(ctx context.Context, slots ...int64) *StatusCmd

func (*Compat) ClusterDelSlotsRange 

func (c *Compat) ClusterDelSlotsRange(ctx context.Context, min, max int64) *StatusCmd

func (*Compat) ClusterFailover 

func (c *Compat) ClusterFailover(ctx context.Context) *StatusCmd

func (*Compat) ClusterForget 

func (c *Compat) ClusterForget(ctx context.Context, nodeID string) *StatusCmd

func (*Compat) ClusterGetKeysInSlot 

func (c *Compat) ClusterGetKeysInSlot(ctx context.Context, slot int64, count int64) *StringSliceCmd

func (*Compat) ClusterInfo 

func (c *Compat) ClusterInfo(ctx context.Context) *StringCmd

func (*Compat) ClusterKeySlot 

func (c *Compat) ClusterKeySlot(ctx context.Context, key string) *IntCmd

func (*Compat) ClusterMeet 

func (c *Compat) ClusterMeet(ctx context.Context, host string, port int64) *StatusCmd

func (*Compat) ClusterNodes 

func (c *Compat) ClusterNodes(ctx context.Context) *StringCmd

func (*Compat) ClusterReplicate 

func (c *Compat) ClusterReplicate(ctx context.Context, nodeID string) *StatusCmd

func (*Compat) ClusterResetHard 

func (c *Compat) ClusterResetHard(ctx context.Context) *StatusCmd

func (*Compat) ClusterResetSoft 

func (c *Compat) ClusterResetSoft(ctx context.Context) *StatusCmd

func (*Compat) ClusterSaveConfig 

func (c *Compat) ClusterSaveConfig(ctx context.Context) *StatusCmd

func (*Compat) ClusterSlaves 

func (c *Compat) ClusterSlaves(ctx context.Context, nodeID string) *StringSliceCmd

func (*Compat) ClusterSlots 

func (c *Compat) ClusterSlots(ctx context.Context) *ClusterSlotsCmd

func (*Compat) Command 

func (c *Compat) Command(ctx context.Context) *CommandsInfoCmd

func (*Compat) CommandGetKeys 

func (c *Compat) CommandGetKeys(ctx context.Context, commands ...any) *StringSliceCmd

func (*Compat) CommandGetKeysAndFlags 

func (c *Compat) CommandGetKeysAndFlags(ctx context.Context, commands ...any) *KeyFlagsCmd

func (*Compat) CommandList 

func (c *Compat) CommandList(ctx context.Context, filter FilterBy) *StringSliceCmd

func (*Compat) ConfigGet 

func (c *Compat) ConfigGet(ctx context.Context, parameter string) *StringStringMapCmd

func (*Compat) ConfigResetStat 

func (c *Compat) ConfigResetStat(ctx context.Context) *StatusCmd

func (*Compat) ConfigRewrite 

func (c *Compat) ConfigRewrite(ctx context.Context) *StatusCmd

func (*Compat) ConfigSet 

func (c *Compat) ConfigSet(ctx context.Context, parameter, value string) *StatusCmd

func (*Compat) Copy 

func (c *Compat) Copy(ctx context.Context, source string, destination string, db int64, replace bool) *IntCmd

func (*Compat) DBSize 

func (c *Compat) DBSize(ctx context.Context) *IntCmd

func (*Compat) DebugObject 

func (c *Compat) DebugObject(ctx context.Context, key string) *StringCmd

func (*Compat) Decr 

func (c *Compat) Decr(ctx context.Context, key string) *IntCmd

func (*Compat) DecrBy 

func (c *Compat) DecrBy(ctx context.Context, key string, decrement int64) *IntCmd

func (*Compat) Del 

func (c *Compat) Del(ctx context.Context, keys ...string) *IntCmd

func (*Compat) Dump 

func (c *Compat) Dump(ctx context.Context, key string) *StringCmd

func (*Compat) Echo 

func (c *Compat) Echo(ctx context.Context, message any) *StringCmd

func (*Compat) Eval 

func (c *Compat) Eval(ctx context.Context, script string, keys []string, args ...any) *Cmd

func (*Compat) EvalRO 

func (c *Compat) EvalRO(ctx context.Context, script string, keys []string, args ...any) *Cmd

func (*Compat) EvalSha 

func (c *Compat) EvalSha(ctx context.Context, sha1 string, keys []string, args ...any) *Cmd

func (*Compat) EvalShaRO 

func (c *Compat) EvalShaRO(ctx context.Context, sha1 string, keys []string, args ...any) *Cmd

func (*Compat) Exists 

func (c *Compat) Exists(ctx context.Context, keys ...string) *IntCmd

func (*Compat) Expire 

func (c *Compat) Expire(ctx context.Context, key string, seconds time.Duration) *BoolCmd

func (*Compat) ExpireAt 

func (c *Compat) ExpireAt(ctx context.Context, key string, timestamp time.Time) *BoolCmd

func (*Compat) ExpireGT 

func (c *Compat) ExpireGT(ctx context.Context, key string, seconds time.Duration) *BoolCmd

func (*Compat) ExpireLT 

func (c *Compat) ExpireLT(ctx context.Context, key string, seconds time.Duration) *BoolCmd

func (*Compat) ExpireNX 

func (c *Compat) ExpireNX(ctx context.Context, key string, seconds time.Duration) *BoolCmd

func (*Compat) ExpireTime 

func (c *Compat) ExpireTime(ctx context.Context, key string) *DurationCmd

func (*Compat) ExpireXX 

func (c *Compat) ExpireXX(ctx context.Context, key string, seconds time.Duration) *BoolCmd

func (*Compat) FCall 

func (c *Compat) FCall(ctx context.Context, function string, keys []string, args ...any) *Cmd

func (*Compat) FCallRO 

func (c *Compat) FCallRO(ctx context.Context, function string, keys []string, args ...any) *Cmd

func (*Compat) FlushAll 

func (c *Compat) FlushAll(ctx context.Context) *StatusCmd

func (*Compat) FlushAllAsync 

func (c *Compat) FlushAllAsync(ctx context.Context) *StatusCmd

func (*Compat) FlushDB 

func (c *Compat) FlushDB(ctx context.Context) *StatusCmd

func (*Compat) FlushDBAsync 

func (c *Compat) FlushDBAsync(ctx context.Context) *StatusCmd

func (*Compat) FunctionDelete 

func (c *Compat) FunctionDelete(ctx context.Context, libName string) *StringCmd

func (*Compat) FunctionDump 

func (c *Compat) FunctionDump(ctx context.Context) *StringCmd

func (*Compat) FunctionFlush 

func (c *Compat) FunctionFlush(ctx context.Context) *StringCmd

func (*Compat) FunctionFlushAsync 

func (c *Compat) FunctionFlushAsync(ctx context.Context) *StringCmd

func (*Compat) FunctionKill 

func (c *Compat) FunctionKill(ctx context.Context) *StringCmd

func (*Compat) FunctionList 

func (c *Compat) FunctionList(ctx context.Context, q FunctionListQuery) *FunctionListCmd

func (*Compat) FunctionLoad 

func (c *Compat) FunctionLoad(ctx context.Context, code string) *StringCmd

func (*Compat) FunctionLoadReplace 

func (c *Compat) FunctionLoadReplace(ctx context.Context, code string) *StringCmd

func (*Compat) FunctionRestore 

func (c *Compat) FunctionRestore(ctx context.Context, libDump string) *StringCmd

func (*Compat) GeoAdd 

func (c *Compat) GeoAdd(ctx context.Context, key string, geoLocation ...GeoLocation) *IntCmd

func (*Compat) GeoDist 

func (c *Compat) GeoDist(ctx context.Context, key, member1, member2, unit string) *FloatCmd

func (*Compat) GeoHash 

func (c *Compat) GeoHash(ctx context.Context, key string, members ...string) *StringSliceCmd

func (*Compat) GeoPos 

func (c *Compat) GeoPos(ctx context.Context, key string, members ...string) *GeoPosCmd

func (*Compat) GeoRadius 

func (c *Compat) GeoRadius(ctx context.Context, key string, longitude, latitude float64, query GeoRadiusQuery) *GeoLocationCmd

GeoRadius is a read-only GEORADIUS_RO command.

func (*Compat) GeoRadiusByMember 

func (c *Compat) GeoRadiusByMember(ctx context.Context, key, member string, query GeoRadiusQuery) *GeoLocationCmd

GeoRadiusByMember is a read-only GEORADIUSBYMEMBER_RO command.

func (*Compat) GeoRadiusByMemberStore 

func (c *Compat) GeoRadiusByMemberStore(ctx context.Context, key, member string, query GeoRadiusQuery) *IntCmd

GeoRadiusByMemberStore is a writing GEORADIUSBYMEMBER command.

func (*Compat) GeoRadiusStore 

func (c *Compat) GeoRadiusStore(ctx context.Context, key string, longitude, latitude float64, query GeoRadiusQuery) *IntCmd

GeoRadiusStore is a writing GEORADIUS command.

func (*Compat) GeoSearch 

func (c *Compat) GeoSearch(ctx context.Context, key string, q GeoSearchQuery) *StringSliceCmd

func (*Compat) GeoSearchLocation 

func (c *Compat) GeoSearchLocation(ctx context.Context, key string, q GeoSearchLocationQuery) *GeoLocationCmd

func (*Compat) GeoSearchStore 

func (c *Compat) GeoSearchStore(ctx context.Context, src, dest string, q GeoSearchStoreQuery) *IntCmd

func (*Compat) Get 

func (c *Compat) Get(ctx context.Context, key string) *StringCmd

func (*Compat) GetBit 

func (c *Compat) GetBit(ctx context.Context, key string, offset int64) *IntCmd

func (*Compat) GetDel 

func (c *Compat) GetDel(ctx context.Context, key string) *StringCmd

func (*Compat) GetEx 

func (c *Compat) GetEx(ctx context.Context, key string, expiration time.Duration) *StringCmd

GetEx An expiration of zero removes the TTL associated with the key (i.e. GETEX key persist). Requires Redis >= 6.2.0.

func (*Compat) GetRange 

func (c *Compat) GetRange(ctx context.Context, key string, start, end int64) *StringCmd

func (*Compat) GetSet 

func (c *Compat) GetSet(ctx context.Context, key string, value any) *StringCmd

func (*Compat) HDel 

func (c *Compat) HDel(ctx context.Context, key string, fields ...string) *IntCmd

func (*Compat) HExists 

func (c *Compat) HExists(ctx context.Context, key, field string) *BoolCmd

func (*Compat) HGet 

func (c *Compat) HGet(ctx context.Context, key, field string) *StringCmd

func (*Compat) HGetAll 

func (c *Compat) HGetAll(ctx context.Context, key string) *StringStringMapCmd

func (*Compat) HIncrBy 

func (c *Compat) HIncrBy(ctx context.Context, key, field string, incr int64) *IntCmd

func (*Compat) HIncrByFloat 

func (c *Compat) HIncrByFloat(ctx context.Context, key, field string, incr float64) *FloatCmd

func (*Compat) HKeys 

func (c *Compat) HKeys(ctx context.Context, key string) *StringSliceCmd

func (*Compat) HLen 

func (c *Compat) HLen(ctx context.Context, key string) *IntCmd

func (*Compat) HMGet 

func (c *Compat) HMGet(ctx context.Context, key string, fields ...string) *SliceCmd

func (*Compat) HMSet 

func (c *Compat) HMSet(ctx context.Context, key string, values ...any) *BoolCmd

HMSet is a deprecated version of HSet left for compatibility with Redis 3.

func (*Compat) HRandField 

func (c *Compat) HRandField(ctx context.Context, key string, count int64) *StringSliceCmd

func (*Compat) HRandFieldWithValues 

func (c *Compat) HRandFieldWithValues(ctx context.Context, key string, count int64) *KeyValueSliceCmd

func (*Compat) HScan 

func (c *Compat) HScan(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd

func (*Compat) HSet 

func (c *Compat) HSet(ctx context.Context, key string, values ...any) *IntCmd

HSet requires Redis v4 for multiple field/value pairs support.

func (*Compat) HSetNX 

func (c *Compat) HSetNX(ctx context.Context, key, field string, value any) *BoolCmd

func (*Compat) HVals 

func (c *Compat) HVals(ctx context.Context, key string) *StringSliceCmd

func (*Compat) Incr 

func (c *Compat) Incr(ctx context.Context, key string) *IntCmd

func (*Compat) IncrBy 

func (c *Compat) IncrBy(ctx context.Context, key string, increment int64) *IntCmd

func (*Compat) IncrByFloat 

func (c *Compat) IncrByFloat(ctx context.Context, key string, increment float64) *FloatCmd

func (*Compat) Info 

func (c *Compat) Info(ctx context.Context, section ...string) *StringCmd

func (*Compat) Keys 

func (c *Compat) Keys(ctx context.Context, pattern string) *StringSliceCmd

func (*Compat) LIndex 

func (c *Compat) LIndex(ctx context.Context, key string, index int64) *StringCmd

func (*Compat) LInsert 

func (c *Compat) LInsert(ctx context.Context, key, op string, pivot, element any) *IntCmd

func (*Compat) LInsertAfter 

func (c *Compat) LInsertAfter(ctx context.Context, key string, pivot, element any) *IntCmd

func (*Compat) LInsertBefore 

func (c *Compat) LInsertBefore(ctx context.Context, key string, pivot, element any) *IntCmd

func (*Compat) LLen 

func (c *Compat) LLen(ctx context.Context, key string) *IntCmd

func (*Compat) LMPop 

func (c *Compat) LMPop(ctx context.Context, direction string, count int64, keys ...string) *KeyValuesCmd

func (*Compat) LMove 

func (c *Compat) LMove(ctx context.Context, source, destination, srcpos, destpos string) *StringCmd

func (*Compat) LPop 

func (c *Compat) LPop(ctx context.Context, key string) *StringCmd

func (*Compat) LPopCount 

func (c *Compat) LPopCount(ctx context.Context, key string, count int64) *StringSliceCmd

func (*Compat) LPos 

func (c *Compat) LPos(ctx context.Context, key string, element string, a LPosArgs) *IntCmd

func (*Compat) LPosCount 

func (c *Compat) LPosCount(ctx context.Context, key string, element string, count int64, a LPosArgs) *IntSliceCmd

func (*Compat) LPush 

func (c *Compat) LPush(ctx context.Context, key string, elements ...any) *IntCmd

func (*Compat) LPushX 

func (c *Compat) LPushX(ctx context.Context, key string, elements ...any) *IntCmd

func (*Compat) LRange 

func (c *Compat) LRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd

func (*Compat) LRem 

func (c *Compat) LRem(ctx context.Context, key string, count int64, element any) *IntCmd

func (*Compat) LSet 

func (c *Compat) LSet(ctx context.Context, key string, index int64, element any) *StatusCmd

func (*Compat) LTrim 

func (c *Compat) LTrim(ctx context.Context, key string, start, stop int64) *StatusCmd

func (*Compat) LastSave 

func (c *Compat) LastSave(ctx context.Context) *IntCmd

func (*Compat) MGet 

func (c *Compat) MGet(ctx context.Context, keys ...string) *SliceCmd

func (*Compat) MSet 

func (c *Compat) MSet(ctx context.Context, values ...any) *StatusCmd

func (*Compat) MSetNX 

func (c *Compat) MSetNX(ctx context.Context, values ...any) *BoolCmd

func (*Compat) MemoryUsage 

func (c *Compat) MemoryUsage(ctx context.Context, key string, samples ...int64) *IntCmd

func (*Compat) Migrate 

func (c *Compat) Migrate(ctx context.Context, host string, port int64, key string, db int64, timeout time.Duration) *StatusCmd

func (*Compat) Move 

func (c *Compat) Move(ctx context.Context, key string, db int64) *BoolCmd

func (*Compat) ObjectEncoding 

func (c *Compat) ObjectEncoding(ctx context.Context, key string) *StringCmd

func (*Compat) ObjectIdleTime 

func (c *Compat) ObjectIdleTime(ctx context.Context, key string) *DurationCmd

func (*Compat) ObjectRefCount 

func (c *Compat) ObjectRefCount(ctx context.Context, key string) *IntCmd

func (*Compat) PExpire 

func (c *Compat) PExpire(ctx context.Context, key string, milliseconds time.Duration) *BoolCmd

func (*Compat) PExpireAt 

func (c *Compat) PExpireAt(ctx context.Context, key string, millisecondsTimestamp time.Time) *BoolCmd

func (*Compat) PExpireTime 

func (c *Compat) PExpireTime(ctx context.Context, key string) *DurationCmd

func (*Compat) PFAdd 

func (c *Compat) PFAdd(ctx context.Context, key string, els ...any) *IntCmd

func (*Compat) PFCount 

func (c *Compat) PFCount(ctx context.Context, keys ...string) *IntCmd

func (*Compat) PFMerge 

func (c *Compat) PFMerge(ctx context.Context, dest string, keys ...string) *StatusCmd

func (*Compat) PTTL 

func (c *Compat) PTTL(ctx context.Context, key string) *DurationCmd

func (*Compat) Persist 

func (c *Compat) Persist(ctx context.Context, key string) *BoolCmd

func (*Compat) Ping 

func (c *Compat) Ping(ctx context.Context) *StatusCmd

func (*Compat) PubSubChannels 

func (c *Compat) PubSubChannels(ctx context.Context, pattern string) *StringSliceCmd

func (*Compat) PubSubNumPat 

func (c *Compat) PubSubNumPat(ctx context.Context) *IntCmd

func (*Compat) PubSubNumSub 

func (c *Compat) PubSubNumSub(ctx context.Context, channels ...string) *StringIntMapCmd

func (*Compat) PubSubShardChannels 

func (c *Compat) PubSubShardChannels(ctx context.Context, pattern string) *StringSliceCmd

func (*Compat) PubSubShardNumSub 

func (c *Compat) PubSubShardNumSub(ctx context.Context, channels ...string) *StringIntMapCmd

func (*Compat) Publish 

func (c *Compat) Publish(ctx context.Context, channel string, message any) *IntCmd

func (*Compat) Quit 

func (c *Compat) Quit(ctx context.Context) *StatusCmd

func (*Compat) RPop 

func (c *Compat) RPop(ctx context.Context, key string) *StringCmd

func (*Compat) RPopCount 

func (c *Compat) RPopCount(ctx context.Context, key string, count int64) *StringSliceCmd

func (*Compat) RPopLPush 

func (c *Compat) RPopLPush(ctx context.Context, source, destination string) *StringCmd

func (*Compat) RPush 

func (c *Compat) RPush(ctx context.Context, key string, elements ...any) *IntCmd

func (*Compat) RPushX 

func (c *Compat) RPushX(ctx context.Context, key string, elements ...any) *IntCmd

func (*Compat) RandomKey 

func (c *Compat) RandomKey(ctx context.Context) *StringCmd

func (*Compat) ReadOnly 

func (c *Compat) ReadOnly(ctx context.Context) *StatusCmd

func (*Compat) ReadWrite 

func (c *Compat) ReadWrite(ctx context.Context) *StatusCmd

func (*Compat) Rename 

func (c *Compat) Rename(ctx context.Context, key, newkey string) *StatusCmd

func (*Compat) RenameNX 

func (c *Compat) RenameNX(ctx context.Context, key, newkey string) *BoolCmd

func (*Compat) Restore 

func (c *Compat) Restore(ctx context.Context, key string, ttl time.Duration, serializedValue string) *StatusCmd

func (*Compat) RestoreReplace 

func (c *Compat) RestoreReplace(ctx context.Context, key string, ttl time.Duration, serializedValue string) *StatusCmd

func (*Compat) SAdd 

func (c *Compat) SAdd(ctx context.Context, key string, members ...any) *IntCmd

func (*Compat) SCard 

func (c *Compat) SCard(ctx context.Context, key string) *IntCmd

func (*Compat) SDiff 

func (c *Compat) SDiff(ctx context.Context, keys ...string) *StringSliceCmd

func (*Compat) SDiffStore 

func (c *Compat) SDiffStore(ctx context.Context, destination string, keys ...string) *IntCmd

func (*Compat) SInter 

func (c *Compat) SInter(ctx context.Context, keys ...string) *StringSliceCmd

func (*Compat) SInterCard 

func (c *Compat) SInterCard(ctx context.Context, limit int64, keys ...string) *IntCmd

func (*Compat) SInterStore 

func (c *Compat) SInterStore(ctx context.Context, destination string, keys ...string) *IntCmd

func (*Compat) SIsMember 

func (c *Compat) SIsMember(ctx context.Context, key string, member any) *BoolCmd

func (*Compat) SMIsMember 

func (c *Compat) SMIsMember(ctx context.Context, key string, members ...any) *BoolSliceCmd

func (*Compat) SMembers 

func (c *Compat) SMembers(ctx context.Context, key string) *StringSliceCmd

func (*Compat) SMembersMap 

func (c *Compat) SMembersMap(ctx context.Context, key string) *StringStructMapCmd

func (*Compat) SMove 

func (c *Compat) SMove(ctx context.Context, source, destination string, member any) *BoolCmd

func (*Compat) SPop 

func (c *Compat) SPop(ctx context.Context, key string) *StringCmd

func (*Compat) SPopN 

func (c *Compat) SPopN(ctx context.Context, key string, count int64) *StringSliceCmd

func (*Compat) SPublish 

func (c *Compat) SPublish(ctx context.Context, channel string, message any) *IntCmd

func (*Compat) SRandMember 

func (c *Compat) SRandMember(ctx context.Context, key string) *StringCmd

func (*Compat) SRandMemberN 

func (c *Compat) SRandMemberN(ctx context.Context, key string, count int64) *StringSliceCmd

func (*Compat) SRem 

func (c *Compat) SRem(ctx context.Context, key string, members ...any) *IntCmd

func (*Compat) SScan 

func (c *Compat) SScan(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd

func (*Compat) SUnion 

func (c *Compat) SUnion(ctx context.Context, keys ...string) *StringSliceCmd

func (*Compat) SUnionStore 

func (c *Compat) SUnionStore(ctx context.Context, destination string, keys ...string) *IntCmd

func (*Compat) Save 

func (c *Compat) Save(ctx context.Context) *StatusCmd

func (*Compat) Scan 

func (c *Compat) Scan(ctx context.Context, cursor uint64, match string, count int64) *ScanCmd

func (*Compat) ScanType 

func (c *Compat) ScanType(ctx context.Context, cursor uint64, match string, count int64, keyType string) *ScanCmd

func (*Compat) ScriptExists 

func (c *Compat) ScriptExists(ctx context.Context, hashes ...string) *BoolSliceCmd

func (*Compat) ScriptFlush 

func (c *Compat) ScriptFlush(ctx context.Context) *StatusCmd

func (*Compat) ScriptKill 

func (c *Compat) ScriptKill(ctx context.Context) *StatusCmd

func (*Compat) ScriptLoad 

func (c *Compat) ScriptLoad(ctx context.Context, script string) *StringCmd

func (*Compat) Set 

func (c *Compat) Set(ctx context.Context, key string, value any, expiration time.Duration) *StatusCmd

Set key value [expiration]

For no expiration use 0.

For KEEPTTL use -1.

For more options, use SetArgs.

func (*Compat) SetArgs 

func (c *Compat) SetArgs(ctx context.Context, key string, value any, a SetArgs) *StatusCmd

func (*Compat) SetBit 

func (c *Compat) SetBit(ctx context.Context, key string, offset int64, value int64) *IntCmd

func (*Compat) SetEX 

func (c *Compat) SetEX(ctx context.Context, key string, value any, expiration time.Duration) *StatusCmd

func (*Compat) SetNX 

func (c *Compat) SetNX(ctx context.Context, key string, value any, expiration time.Duration) *BoolCmd

func (*Compat) SetRange 

func (c *Compat) SetRange(ctx context.Context, key string, offset int64, value string) *IntCmd

func (*Compat) SetXX 

func (c *Compat) SetXX(ctx context.Context, key string, value any, expiration time.Duration) *BoolCmd

func (*Compat) Shutdown 

func (c *Compat) Shutdown(ctx context.Context) *StatusCmd

func (*Compat) ShutdownNoSave 

func (c *Compat) ShutdownNoSave(ctx context.Context) *StatusCmd

func (*Compat) ShutdownSave 

func (c *Compat) ShutdownSave(ctx context.Context) *StatusCmd

func (*Compat) Sort 

func (c *Compat) Sort(ctx context.Context, key string, sort Sort) *StringSliceCmd

func (*Compat) SortInterfaces 

func (c *Compat) SortInterfaces(ctx context.Context, key string, sort Sort) *SliceCmd

func (*Compat) SortRO 

func (c *Compat) SortRO(ctx context.Context, key string, sort Sort) *StringSliceCmd

func (*Compat) SortStore 

func (c *Compat) SortStore(ctx context.Context, key, store string, sort Sort) *IntCmd

func (*Compat) StrLen 

func (c *Compat) StrLen(ctx context.Context, key string) *IntCmd

func (*Compat) TTL 

func (c *Compat) TTL(ctx context.Context, key string) *DurationCmd

func (*Compat) Time 

func (c *Compat) Time(ctx context.Context) *TimeCmd

func (*Compat) Touch 

func (c *Compat) Touch(ctx context.Context, keys ...string) *IntCmd

func (*Compat) Type 

func (c *Compat) Type(ctx context.Context, key string) *StatusCmd
func (c *Compat) Unlink(ctx context.Context, keys ...string) *IntCmd

func (*Compat) XAck 

func (c *Compat) XAck(ctx context.Context, stream, group string, ids ...string) *IntCmd

func (*Compat) XAdd 

func (c *Compat) XAdd(ctx context.Context, a XAddArgs) *StringCmd

func (*Compat) XAutoClaim 

func (c *Compat) XAutoClaim(ctx context.Context, a XAutoClaimArgs) *XAutoClaimCmd

func (*Compat) XAutoClaimJustID 

func (c *Compat) XAutoClaimJustID(ctx context.Context, a XAutoClaimArgs) *XAutoClaimJustIDCmd

func (*Compat) XClaim 

func (c *Compat) XClaim(ctx context.Context, a XClaimArgs) *XMessageSliceCmd

func (*Compat) XClaimJustID 

func (c *Compat) XClaimJustID(ctx context.Context, a XClaimArgs) *StringSliceCmd

func (*Compat) XDel 

func (c *Compat) XDel(ctx context.Context, stream string, ids ...string) *IntCmd

func (*Compat) XGroupCreate 

func (c *Compat) XGroupCreate(ctx context.Context, stream, group, start string) *StatusCmd

func (*Compat) XGroupCreateConsumer 

func (c *Compat) XGroupCreateConsumer(ctx context.Context, stream, group, consumer string) *IntCmd

func (*Compat) XGroupCreateMkStream 

func (c *Compat) XGroupCreateMkStream(ctx context.Context, stream, group, start string) *StatusCmd

func (*Compat) XGroupDelConsumer 

func (c *Compat) XGroupDelConsumer(ctx context.Context, stream, group, consumer string) *IntCmd

func (*Compat) XGroupDestroy 

func (c *Compat) XGroupDestroy(ctx context.Context, stream, group string) *IntCmd

func (*Compat) XGroupSetID 

func (c *Compat) XGroupSetID(ctx context.Context, stream, group, start string) *StatusCmd

func (*Compat) XInfoConsumers 

func (c *Compat) XInfoConsumers(ctx context.Context, key, group string) *XInfoConsumersCmd

func (*Compat) XInfoGroups 

func (c *Compat) XInfoGroups(ctx context.Context, key string) *XInfoGroupsCmd

func (*Compat) XInfoStream 

func (c *Compat) XInfoStream(ctx context.Context, key string) *XInfoStreamCmd

func (*Compat) XInfoStreamFull 

func (c *Compat) XInfoStreamFull(ctx context.Context, key string, count int64) *XInfoStreamFullCmd

func (*Compat) XLen 

func (c *Compat) XLen(ctx context.Context, stream string) *IntCmd

func (*Compat) XPending 

func (c *Compat) XPending(ctx context.Context, stream, group string) *XPendingCmd

func (*Compat) XPendingExt 

func (c *Compat) XPendingExt(ctx context.Context, a XPendingExtArgs) *XPendingExtCmd

func (*Compat) XRange 

func (c *Compat) XRange(ctx context.Context, stream, start, stop string) *XMessageSliceCmd

func (*Compat) XRangeN 

func (c *Compat) XRangeN(ctx context.Context, stream, start, stop string, count int64) *XMessageSliceCmd

func (*Compat) XRead 

func (c *Compat) XRead(ctx context.Context, a XReadArgs) *XStreamSliceCmd

func (*Compat) XReadGroup 

func (c *Compat) XReadGroup(ctx context.Context, a XReadGroupArgs) *XStreamSliceCmd

func (*Compat) XReadStreams 

func (c *Compat) XReadStreams(ctx context.Context, streams ...string) *XStreamSliceCmd

func (*Compat) XRevRange 

func (c *Compat) XRevRange(ctx context.Context, stream, stop, start string) *XMessageSliceCmd

func (*Compat) XRevRangeN 

func (c *Compat) XRevRangeN(ctx context.Context, stream, stop, start string, count int64) *XMessageSliceCmd

func (*Compat) XTrimMaxLen 

func (c *Compat) XTrimMaxLen(ctx context.Context, key string, maxLen int64) *IntCmd

XTrimMaxLen No `~` rules are used, `limit` cannot be used. cmd: XTRIM key MAXLEN maxLen

func (*Compat) XTrimMaxLenApprox 

func (c *Compat) XTrimMaxLenApprox(ctx context.Context, key string, maxLen, limit int64) *IntCmd

XTrimMaxLenApprox LIMIT has a bug, please confirm it and use it. issue: https://github.com/redis/redis/issues/9046 cmd: XTRIM key MAXLEN ~ maxLen LIMIT limit

func (*Compat) XTrimMinID 

func (c *Compat) XTrimMinID(ctx context.Context, key string, minID string) *IntCmd

XTrimMinID No `~` rules are used, `limit` cannot be used. cmd: XTRIM key MINID minID

func (*Compat) XTrimMinIDApprox 

func (c *Compat) XTrimMinIDApprox(ctx context.Context, key string, minID string, limit int64) *IntCmd

XTrimMinIDApprox LIMIT has a bug, please confirm it and use it. issue: https://github.com/redis/redis/issues/9046 cmd: XTRIM key MINID ~ minID LIMIT limit

func (*Compat) ZAdd 

func (c *Compat) ZAdd(ctx context.Context, key string, members ...Z) *IntCmd

ZAdd Redis `ZADD key score member [score member ...]` command.

func (*Compat) ZAddArgs 

func (c *Compat) ZAddArgs(ctx context.Context, key string, args ZAddArgs) *IntCmd

func (*Compat) ZAddArgsIncr 

func (c *Compat) ZAddArgsIncr(ctx context.Context, key string, args ZAddArgs) *FloatCmd

func (*Compat) ZAddGT 

func (c *Compat) ZAddGT(ctx context.Context, key string, members ...Z) *IntCmd

func (*Compat) ZAddLT 

func (c *Compat) ZAddLT(ctx context.Context, key string, members ...Z) *IntCmd

func (*Compat) ZAddNX 

func (c *Compat) ZAddNX(ctx context.Context, key string, members ...Z) *IntCmd

ZAddNX Redis `ZADD key NX score member [score member ...]` command.

func (*Compat) ZAddXX 

func (c *Compat) ZAddXX(ctx context.Context, key string, members ...Z) *IntCmd

ZAddXX Redis `ZADD key XX score member [score member ...]` command.

func (*Compat) ZCard 

func (c *Compat) ZCard(ctx context.Context, key string) *IntCmd

func (*Compat) ZCount 

func (c *Compat) ZCount(ctx context.Context, key, min, max string) *IntCmd

func (*Compat) ZDiff 

func (c *Compat) ZDiff(ctx context.Context, keys ...string) *StringSliceCmd

func (*Compat) ZDiffStore 

func (c *Compat) ZDiffStore(ctx context.Context, destination string, keys ...string) *IntCmd

func (*Compat) ZDiffWithScores 

func (c *Compat) ZDiffWithScores(ctx context.Context, keys ...string) *ZSliceCmd

func (*Compat) ZIncrBy 

func (c *Compat) ZIncrBy(ctx context.Context, key string, increment float64, member string) *FloatCmd

func (*Compat) ZInter 

func (c *Compat) ZInter(ctx context.Context, store ZStore) *StringSliceCmd

func (*Compat) ZInterCard 

func (c *Compat) ZInterCard(ctx context.Context, limit int64, keys ...string) *IntCmd

func (*Compat) ZInterStore 

func (c *Compat) ZInterStore(ctx context.Context, destination string, store ZStore) *IntCmd

func (*Compat) ZInterWithScores 

func (c *Compat) ZInterWithScores(ctx context.Context, store ZStore) *ZSliceCmd

func (*Compat) ZLexCount 

func (c *Compat) ZLexCount(ctx context.Context, key, min, max string) *IntCmd

func (*Compat) ZMPop 

func (c *Compat) ZMPop(ctx context.Context, order string, count int64, keys ...string) *ZSliceWithKeyCmd

func (*Compat) ZMScore 

func (c *Compat) ZMScore(ctx context.Context, key string, members ...string) *FloatSliceCmd

func (*Compat) ZPopMax 

func (c *Compat) ZPopMax(ctx context.Context, key string, count ...int64) *ZSliceCmd

func (*Compat) ZPopMin 

func (c *Compat) ZPopMin(ctx context.Context, key string, count ...int64) *ZSliceCmd

func (*Compat) ZRandMember 

func (c *Compat) ZRandMember(ctx context.Context, key string, count int64) *StringSliceCmd

func (*Compat) ZRandMemberWithScores 

func (c *Compat) ZRandMemberWithScores(ctx context.Context, key string, count int64) *ZSliceCmd

func (*Compat) ZRange 

func (c *Compat) ZRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd

func (*Compat) ZRangeArgs 

func (c *Compat) ZRangeArgs(ctx context.Context, z ZRangeArgs) *StringSliceCmd

func (*Compat) ZRangeArgsWithScores 

func (c *Compat) ZRangeArgsWithScores(ctx context.Context, z ZRangeArgs) *ZSliceCmd

func (*Compat) ZRangeByLex 

func (c *Compat) ZRangeByLex(ctx context.Context, key string, opt ZRangeBy) *StringSliceCmd

func (*Compat) ZRangeByScore 

func (c *Compat) ZRangeByScore(ctx context.Context, key string, opt ZRangeBy) *StringSliceCmd

func (*Compat) ZRangeByScoreWithScores 

func (c *Compat) ZRangeByScoreWithScores(ctx context.Context, key string, opt ZRangeBy) *ZSliceCmd

func (*Compat) ZRangeStore 

func (c *Compat) ZRangeStore(ctx context.Context, dst string, z ZRangeArgs) *IntCmd

func (*Compat) ZRangeWithScores 

func (c *Compat) ZRangeWithScores(ctx context.Context, key string, start, stop int64) *ZSliceCmd

func (*Compat) ZRank 

func (c *Compat) ZRank(ctx context.Context, key, member string) *IntCmd

func (*Compat) ZRankWithScore 

func (c *Compat) ZRankWithScore(ctx context.Context, key, member string) *RankWithScoreCmd

func (*Compat) ZRem 

func (c *Compat) ZRem(ctx context.Context, key string, members ...any) *IntCmd

func (*Compat) ZRemRangeByLex 

func (c *Compat) ZRemRangeByLex(ctx context.Context, key string, min, max string) *IntCmd

func (*Compat) ZRemRangeByRank 

func (c *Compat) ZRemRangeByRank(ctx context.Context, key string, start, stop int64) *IntCmd

func (*Compat) ZRemRangeByScore 

func (c *Compat) ZRemRangeByScore(ctx context.Context, key, min, max string) *IntCmd

func (*Compat) ZRevRange 

func (c *Compat) ZRevRange(ctx context.Context, key string, start, stop int64) *StringSliceCmd

func (*Compat) ZRevRangeByLex 

func (c *Compat) ZRevRangeByLex(ctx context.Context, key string, opt ZRangeBy) *StringSliceCmd

func (*Compat) ZRevRangeByScore 

func (c *Compat) ZRevRangeByScore(ctx context.Context, key string, opt ZRangeBy) *StringSliceCmd

func (*Compat) ZRevRangeByScoreWithScores 

func (c *Compat) ZRevRangeByScoreWithScores(ctx context.Context, key string, opt ZRangeBy) *ZSliceCmd

func (*Compat) ZRevRangeWithScores 

func (c *Compat) ZRevRangeWithScores(ctx context.Context, key string, start, stop int64) *ZSliceCmd

func (*Compat) ZRevRank 

func (c *Compat) ZRevRank(ctx context.Context, key, member string) *IntCmd

func (*Compat) ZRevRankWithScore 

func (c *Compat) ZRevRankWithScore(ctx context.Context, key, member string) *RankWithScoreCmd

func (*Compat) ZScan 

func (c *Compat) ZScan(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd

func (*Compat) ZScore 

func (c *Compat) ZScore(ctx context.Context, key, member string) *FloatCmd

func (*Compat) ZUnion 

func (c *Compat) ZUnion(ctx context.Context, store ZStore) *StringSliceCmd

func (*Compat) ZUnionStore 

func (c *Compat) ZUnionStore(ctx context.Context, dest string, store ZStore) *IntCmd

func (*Compat) ZUnionWithScores 

func (c *Compat) ZUnionWithScores(ctx context.Context, store ZStore) *ZSliceCmd

type DurationCmd 

type DurationCmd struct {
	// contains filtered or unexported fields
}

func (*DurationCmd) Err 

func (cmd *DurationCmd) Err() error

func (*DurationCmd) Result 

func (cmd *DurationCmd) Result() (time.Duration, error)

func (*DurationCmd) SetErr 

func (cmd *DurationCmd) SetErr(err error)

func (*DurationCmd) SetVal 

func (cmd *DurationCmd) SetVal(val time.Duration)

func (*DurationCmd) Val 

func (cmd *DurationCmd) Val() time.Duration

type FilterBy 

type FilterBy struct {
	Module  string
	ACLCat  string
	Pattern string
}

type FloatCmd 

type FloatCmd struct {
	// contains filtered or unexported fields
}

func (*FloatCmd) Err 

func (cmd *FloatCmd) Err() error

func (*FloatCmd) Result 

func (cmd *FloatCmd) Result() (float64, error)

func (*FloatCmd) SetErr 

func (cmd *FloatCmd) SetErr(err error)

func (*FloatCmd) SetVal 

func (cmd *FloatCmd) SetVal(val float64)

func (*FloatCmd) Val 

func (cmd *FloatCmd) Val() float64

type FloatSliceCmd 

type FloatSliceCmd struct {
	// contains filtered or unexported fields
}

func (*FloatSliceCmd) Err 

func (cmd *FloatSliceCmd) Err() error

func (*FloatSliceCmd) Result 

func (cmd *FloatSliceCmd) Result() ([]float64, error)

func (*FloatSliceCmd) SetErr 

func (cmd *FloatSliceCmd) SetErr(err error)

func (*FloatSliceCmd) SetVal 

func (cmd *FloatSliceCmd) SetVal(val []float64)

func (*FloatSliceCmd) Val 

func (cmd *FloatSliceCmd) Val() []float64

type Function 

type Function struct {
	Name        string
	Description string
	Flags       []string
}

type FunctionListCmd 

type FunctionListCmd struct {
	// contains filtered or unexported fields
}

func (*FunctionListCmd) Err 

func (cmd *FunctionListCmd) Err() error

func (*FunctionListCmd) First 

func (cmd *FunctionListCmd) First() (*Library, error)

func (*FunctionListCmd) Result 

func (cmd *FunctionListCmd) Result() ([]Library, error)

func (*FunctionListCmd) SetErr 

func (cmd *FunctionListCmd) SetErr(err error)

func (*FunctionListCmd) SetVal 

func (cmd *FunctionListCmd) SetVal(val []Library)

func (*FunctionListCmd) Val 

func (cmd *FunctionListCmd) Val() []Library

type FunctionListQuery 

type FunctionListQuery struct {
	LibraryNamePattern string
	WithCode           bool
}

type GeoLocation 

type GeoLocation = rueidis.GeoLocation

type GeoLocationCmd 

type GeoLocationCmd struct {
	// contains filtered or unexported fields
}

func (*GeoLocationCmd) Err 

func (cmd *GeoLocationCmd) Err() error

func (*GeoLocationCmd) Result 

func (cmd *GeoLocationCmd) Result() ([]rueidis.GeoLocation, error)

func (*GeoLocationCmd) SetErr 

func (cmd *GeoLocationCmd) SetErr(err error)

func (*GeoLocationCmd) SetVal 

func (cmd *GeoLocationCmd) SetVal(val []GeoLocation)

func (*GeoLocationCmd) Val 

func (cmd *GeoLocationCmd) Val() []rueidis.GeoLocation

type GeoPos 

type GeoPos struct {
	Longitude, Latitude float64
}

type GeoPosCmd 

type GeoPosCmd struct {
	// contains filtered or unexported fields
}

func (*GeoPosCmd) Err 

func (cmd *GeoPosCmd) Err() error

func (*GeoPosCmd) Result 

func (cmd *GeoPosCmd) Result() ([]*GeoPos, error)

func (*GeoPosCmd) SetErr 

func (cmd *GeoPosCmd) SetErr(err error)

func (*GeoPosCmd) SetVal 

func (cmd *GeoPosCmd) SetVal(val []*GeoPos)

func (*GeoPosCmd) Val 

func (cmd *GeoPosCmd) Val() []*GeoPos

type GeoRadiusQuery 

type GeoRadiusQuery struct {
	Unit        string
	Sort        string
	Store       string
	StoreDist   string
	Radius      float64
	Count       int64
	WithCoord   bool
	WithDist    bool
	WithGeoHash bool
}

GeoRadiusQuery is used with GeoRadius to query geospatial index.

type GeoSearchLocationQuery 

type GeoSearchLocationQuery struct {
	GeoSearchQuery

	WithCoord bool
	WithDist  bool
	WithHash  bool
}

type GeoSearchQuery 

type GeoSearchQuery struct {
	Member     string
	RadiusUnit string
	BoxUnit    string
	Sort       string
	Longitude  float64
	Latitude   float64
	Radius     float64
	BoxWidth   float64
	BoxHeight  float64
	Count      int64
	CountAny   bool
}

GeoSearchQuery is used for GEOSearch/GEOSearchStore command query.

type GeoSearchStoreQuery 

type GeoSearchStoreQuery struct {
	GeoSearchQuery

	// When using the StoreDist option, the command stores the items in a
	// sorted set populated with their distance from the center of the circle or box,
	// as a floating-point number, in the same unit specified for that shape.
	StoreDist bool
}

type IntCmd 

type IntCmd struct {
	// contains filtered or unexported fields
}

func (*IntCmd) Err 

func (cmd *IntCmd) Err() error

func (*IntCmd) Result 

func (cmd *IntCmd) Result() (int64, error)

func (*IntCmd) SetErr 

func (cmd *IntCmd) SetErr(err error)

func (*IntCmd) SetVal 

func (cmd *IntCmd) SetVal(val int64)

func (*IntCmd) Uint64 

func (cmd *IntCmd) Uint64() (uint64, error)

func (*IntCmd) Val 

func (cmd *IntCmd) Val() int64

type IntSliceCmd 

type IntSliceCmd struct {
	// contains filtered or unexported fields
}

func (*IntSliceCmd) Err 

func (cmd *IntSliceCmd) Err() error

func (*IntSliceCmd) Result 

func (cmd *IntSliceCmd) Result() ([]int64, error)

func (*IntSliceCmd) SetErr 

func (cmd *IntSliceCmd) SetErr(err error)

func (*IntSliceCmd) SetVal 

func (cmd *IntSliceCmd) SetVal(val []int64)

func (*IntSliceCmd) Val 

func (cmd *IntSliceCmd) Val() []int64

type KeyFlags 

type KeyFlags struct {
	Key   string
	Flags []string
}

type KeyFlagsCmd 

type KeyFlagsCmd struct {
	// contains filtered or unexported fields
}

func (*KeyFlagsCmd) Err 

func (cmd *KeyFlagsCmd) Err() error

func (*KeyFlagsCmd) Result 

func (cmd *KeyFlagsCmd) Result() ([]KeyFlags, error)

func (*KeyFlagsCmd) SetErr 

func (cmd *KeyFlagsCmd) SetErr(err error)

func (*KeyFlagsCmd) SetVal 

func (cmd *KeyFlagsCmd) SetVal(val []KeyFlags)

func (*KeyFlagsCmd) Val 

func (cmd *KeyFlagsCmd) Val() (val []KeyFlags)

type KeyValue 

type KeyValue struct {
	Key   string
	Value string
}

type KeyValueSliceCmd 

type KeyValueSliceCmd struct {
	// contains filtered or unexported fields
}

func (*KeyValueSliceCmd) Err 

func (cmd *KeyValueSliceCmd) Err() error

func (*KeyValueSliceCmd) Result 

func (cmd *KeyValueSliceCmd) Result() ([]KeyValue, error)

func (*KeyValueSliceCmd) SetErr 

func (cmd *KeyValueSliceCmd) SetErr(err error)

func (*KeyValueSliceCmd) SetVal 

func (cmd *KeyValueSliceCmd) SetVal(val []KeyValue)

func (*KeyValueSliceCmd) Val 

func (cmd *KeyValueSliceCmd) Val() []KeyValue

type KeyValuesCmd 

type KeyValuesCmd struct {
	// contains filtered or unexported fields
}

func (*KeyValuesCmd) Err 

func (cmd *KeyValuesCmd) Err() error

func (*KeyValuesCmd) Result 

func (cmd *KeyValuesCmd) Result() (string, []string, error)

func (*KeyValuesCmd) SetErr 

func (cmd *KeyValuesCmd) SetErr(err error)

func (*KeyValuesCmd) SetVal 

func (cmd *KeyValuesCmd) SetVal(key string, val []string)

func (*KeyValuesCmd) Val 

func (cmd *KeyValuesCmd) Val() (string, []string)

type LPosArgs 

type LPosArgs struct {
	Rank, MaxLen int64
}

type Library 

type Library struct {
	Name      string
	Engine    string
	Functions []Function
	Code      string
}

type RankScore 

type RankScore struct {
	Rank  int64
	Score float64
}

type RankWithScoreCmd 

type RankWithScoreCmd struct {
	// contains filtered or unexported fields
}

func (*RankWithScoreCmd) Err 

func (cmd *RankWithScoreCmd) Err() error

func (*RankWithScoreCmd) Result 

func (cmd *RankWithScoreCmd) Result() (RankScore, error)

func (*RankWithScoreCmd) SetErr 

func (cmd *RankWithScoreCmd) SetErr(err error)

func (*RankWithScoreCmd) SetVal 

func (cmd *RankWithScoreCmd) SetVal(val RankScore)

func (*RankWithScoreCmd) Val 

func (cmd *RankWithScoreCmd) Val() RankScore

type ScanCmd 

type ScanCmd struct {
	// contains filtered or unexported fields
}

func (*ScanCmd) Err 

func (cmd *ScanCmd) Err() error

func (*ScanCmd) Result 

func (cmd *ScanCmd) Result() (keys []string, cursor uint64, err error)

func (*ScanCmd) SetVal 

func (cmd *ScanCmd) SetVal(keys []string, cursor uint64)

func (*ScanCmd) Val 

func (cmd *ScanCmd) Val() (keys []string, cursor uint64)

type SetArgs 

type SetArgs struct {
	ExpireAt time.Time
	Mode     string
	TTL      time.Duration
	Get      bool
	KeepTTL  bool
}

SetArgs provides arguments for the SetArgs function.

type SliceCmd 

type SliceCmd struct {
	// contains filtered or unexported fields
}

func (*SliceCmd) Err 

func (cmd *SliceCmd) Err() error

func (*SliceCmd) Result 

func (cmd *SliceCmd) Result() ([]any, error)

func (*SliceCmd) SetErr 

func (cmd *SliceCmd) SetErr(err error)

func (*SliceCmd) SetVal 

func (cmd *SliceCmd) SetVal(val []any)

func (*SliceCmd) Val 

func (cmd *SliceCmd) Val() []any

type Sort 

type Sort struct {
	By     string
	Order  string
	Get    []string
	Offset int64
	Count  int64
	Alpha  bool
}

type StatusCmd 

type StatusCmd = StringCmd

type StringCmd 

type StringCmd struct {
	// contains filtered or unexported fields
}

func (*StringCmd) Bool 

func (cmd *StringCmd) Bool() (bool, error)

func (*StringCmd) Bytes 

func (cmd *StringCmd) Bytes() ([]byte, error)

func (*StringCmd) Err 

func (cmd *StringCmd) Err() error

func (*StringCmd) Float32 

func (cmd *StringCmd) Float32() (float32, error)

func (*StringCmd) Float64 

func (cmd *StringCmd) Float64() (float64, error)

func (*StringCmd) Int 

func (cmd *StringCmd) Int() (int, error)

func (*StringCmd) Int64 

func (cmd *StringCmd) Int64() (int64, error)

func (*StringCmd) Result 

func (cmd *StringCmd) Result() (string, error)

func (*StringCmd) SetErr 

func (cmd *StringCmd) SetErr(err error)

func (*StringCmd) SetVal 

func (cmd *StringCmd) SetVal(val string)

func (*StringCmd) String 

func (cmd *StringCmd) String() string

func (*StringCmd) Time 

func (cmd *StringCmd) Time() (time.Time, error)

func (*StringCmd) Uint64 

func (cmd *StringCmd) Uint64() (uint64, error)

func (*StringCmd) Val 

func (cmd *StringCmd) Val() string

type StringIntMapCmd 

type StringIntMapCmd struct {
	// contains filtered or unexported fields
}

func (*StringIntMapCmd) Err 

func (cmd *StringIntMapCmd) Err() error

func (*StringIntMapCmd) Result 

func (cmd *StringIntMapCmd) Result() (map[string]int64, error)

func (*StringIntMapCmd) SetErr 

func (cmd *StringIntMapCmd) SetErr(err error)

func (*StringIntMapCmd) SetVal 

func (cmd *StringIntMapCmd) SetVal(val map[string]int64)

func (*StringIntMapCmd) Val 

func (cmd *StringIntMapCmd) Val() map[string]int64

type StringSliceCmd 

type StringSliceCmd struct {
	// contains filtered or unexported fields
}

func (*StringSliceCmd) Err 

func (cmd *StringSliceCmd) Err() error

func (*StringSliceCmd) Result 

func (cmd *StringSliceCmd) Result() ([]string, error)

func (*StringSliceCmd) SetErr 

func (cmd *StringSliceCmd) SetErr(err error)

func (*StringSliceCmd) SetVal 

func (cmd *StringSliceCmd) SetVal(val []string)

func (*StringSliceCmd) Val 

func (cmd *StringSliceCmd) Val() []string

type StringStringMapCmd 

type StringStringMapCmd struct {
	// contains filtered or unexported fields
}

func (*StringStringMapCmd) Err 

func (cmd *StringStringMapCmd) Err() error

func (*StringStringMapCmd) Result 

func (cmd *StringStringMapCmd) Result() (map[string]string, error)

func (*StringStringMapCmd) SetErr 

func (cmd *StringStringMapCmd) SetErr(err error)

func (*StringStringMapCmd) SetVal 

func (cmd *StringStringMapCmd) SetVal(val map[string]string)

func (*StringStringMapCmd) Val 

func (cmd *StringStringMapCmd) Val() map[string]string

type StringStructMapCmd 

type StringStructMapCmd struct {
	// contains filtered or unexported fields
}

func (*StringStructMapCmd) Err 

func (cmd *StringStructMapCmd) Err() error

func (*StringStructMapCmd) Result 

func (cmd *StringStructMapCmd) Result() (map[string]struct{}, error)

func (*StringStructMapCmd) SetErr 

func (cmd *StringStructMapCmd) SetErr(err error)

func (*StringStructMapCmd) SetVal 

func (cmd *StringStructMapCmd) SetVal(val map[string]struct{})

func (*StringStructMapCmd) Val 

func (cmd *StringStructMapCmd) Val() map[string]struct{}

type TimeCmd 

type TimeCmd struct {
	// contains filtered or unexported fields
}

func (*TimeCmd) Err 

func (cmd *TimeCmd) Err() error

func (*TimeCmd) Result 

func (cmd *TimeCmd) Result() (time.Time, error)

func (*TimeCmd) SetErr 

func (cmd *TimeCmd) SetErr(err error)

func (*TimeCmd) SetVal 

func (cmd *TimeCmd) SetVal(val time.Time)

func (*TimeCmd) Val 

func (cmd *TimeCmd) Val() time.Time

type XAddArgs 

type XAddArgs struct {
	Values     any
	Stream     string
	MinID      string
	ID         string
	MaxLen     int64
	Limit      int64
	NoMkStream bool
	Approx     bool
}

Note: MaxLen/MaxLenApprox and MinID are in conflict, only one of them can be used.

type XAutoClaimArgs 

type XAutoClaimArgs struct {
	Stream   string
	Group    string
	Start    string
	Consumer string
	MinIdle  time.Duration
	Count    int64
}

type XAutoClaimCmd 

type XAutoClaimCmd struct {
	// contains filtered or unexported fields
}

func (*XAutoClaimCmd) Err 

func (cmd *XAutoClaimCmd) Err() error

func (*XAutoClaimCmd) Result 

func (cmd *XAutoClaimCmd) Result() (messages []XMessage, start string, err error)

func (*XAutoClaimCmd) SetErr 

func (cmd *XAutoClaimCmd) SetErr(err error)

func (*XAutoClaimCmd) SetVal 

func (cmd *XAutoClaimCmd) SetVal(val []XMessage, start string)

func (*XAutoClaimCmd) Val 

func (cmd *XAutoClaimCmd) Val() (messages []XMessage, start string)

type XAutoClaimJustIDCmd 

type XAutoClaimJustIDCmd struct {
	// contains filtered or unexported fields
}

func (*XAutoClaimJustIDCmd) Err 

func (cmd *XAutoClaimJustIDCmd) Err() error

func (*XAutoClaimJustIDCmd) Result 

func (cmd *XAutoClaimJustIDCmd) Result() (ids []string, start string, err error)

func (*XAutoClaimJustIDCmd) SetErr 

func (cmd *XAutoClaimJustIDCmd) SetErr(err error)

func (*XAutoClaimJustIDCmd) SetVal 

func (cmd *XAutoClaimJustIDCmd) SetVal(val []string, start string)

func (*XAutoClaimJustIDCmd) Val 

func (cmd *XAutoClaimJustIDCmd) Val() (ids []string, start string)

type XClaimArgs 

type XClaimArgs struct {
	Stream   string
	Group    string
	Consumer string
	Messages []string
	MinIdle  time.Duration
}

type XInfoConsumer 

type XInfoConsumer struct {
	Name    string
	Pending int64
	Idle    time.Duration
}

type XInfoConsumersCmd 

type XInfoConsumersCmd struct {
	// contains filtered or unexported fields
}

func (*XInfoConsumersCmd) Err 

func (cmd *XInfoConsumersCmd) Err() error

func (*XInfoConsumersCmd) Result 

func (cmd *XInfoConsumersCmd) Result() ([]XInfoConsumer, error)

func (*XInfoConsumersCmd) SetErr 

func (cmd *XInfoConsumersCmd) SetErr(err error)

func (*XInfoConsumersCmd) SetVal 

func (cmd *XInfoConsumersCmd) SetVal(val []XInfoConsumer)

func (*XInfoConsumersCmd) Val 

func (cmd *XInfoConsumersCmd) Val() []XInfoConsumer

type XInfoGroup 

type XInfoGroup struct {
	Name            string
	LastDeliveredID string
	Consumers       int64
	Pending         int64
	EntriesRead     int64
	Lag             int64
}

type XInfoGroupsCmd 

type XInfoGroupsCmd struct {
	// contains filtered or unexported fields
}

func (*XInfoGroupsCmd) Err 

func (cmd *XInfoGroupsCmd) Err() error

func (*XInfoGroupsCmd) Result 

func (cmd *XInfoGroupsCmd) Result() ([]XInfoGroup, error)

func (*XInfoGroupsCmd) SetErr 

func (cmd *XInfoGroupsCmd) SetErr(err error)

func (*XInfoGroupsCmd) SetVal 

func (cmd *XInfoGroupsCmd) SetVal(val []XInfoGroup)

func (*XInfoGroupsCmd) Val 

func (cmd *XInfoGroupsCmd) Val() []XInfoGroup

type XInfoStream 

type XInfoStream struct {
	FirstEntry           XMessage
	LastEntry            XMessage
	LastGeneratedID      string
	MaxDeletedEntryID    string
	RecordedFirstEntryID string
	Length               int64
	RadixTreeKeys        int64
	RadixTreeNodes       int64
	Groups               int64
	EntriesAdded         int64
}

type XInfoStreamCmd 

type XInfoStreamCmd struct {
	// contains filtered or unexported fields
}

func (*XInfoStreamCmd) Err 

func (cmd *XInfoStreamCmd) Err() error

func (*XInfoStreamCmd) Result 

func (cmd *XInfoStreamCmd) Result() (XInfoStream, error)

func (*XInfoStreamCmd) SetErr 

func (cmd *XInfoStreamCmd) SetErr(err error)

func (*XInfoStreamCmd) SetVal 

func (cmd *XInfoStreamCmd) SetVal(val XInfoStream)

func (*XInfoStreamCmd) Val 

func (cmd *XInfoStreamCmd) Val() XInfoStream

type XInfoStreamConsumer 

type XInfoStreamConsumer struct {
	SeenTime time.Time
	Name     string
	Pending  []XInfoStreamConsumerPending
	PelCount int64
}

type XInfoStreamConsumerPending 

type XInfoStreamConsumerPending struct {
	DeliveryTime  time.Time
	ID            string
	DeliveryCount int64
}

type XInfoStreamFull 

type XInfoStreamFull struct {
	LastGeneratedID      string
	MaxDeletedEntryID    string
	RecordedFirstEntryID string
	Entries              []XMessage
	Groups               []XInfoStreamGroup
	Length               int64
	RadixTreeKeys        int64
	RadixTreeNodes       int64
	EntriesAdded         int64
}

type XInfoStreamFullCmd 

type XInfoStreamFullCmd struct {
	// contains filtered or unexported fields
}

func (*XInfoStreamFullCmd) Err 

func (cmd *XInfoStreamFullCmd) Err() error

func (*XInfoStreamFullCmd) Result 

func (cmd *XInfoStreamFullCmd) Result() (XInfoStreamFull, error)

func (*XInfoStreamFullCmd) SetErr 

func (cmd *XInfoStreamFullCmd) SetErr(err error)

func (*XInfoStreamFullCmd) SetVal 

func (cmd *XInfoStreamFullCmd) SetVal(val XInfoStreamFull)

func (*XInfoStreamFullCmd) Val 

func (cmd *XInfoStreamFullCmd) Val() XInfoStreamFull

type XInfoStreamGroup 

type XInfoStreamGroup struct {
	Name            string
	LastDeliveredID string
	Pending         []XInfoStreamGroupPending
	Consumers       []XInfoStreamConsumer
	EntriesRead     int64
	Lag             int64
	PelCount        int64
}

type XInfoStreamGroupPending 

type XInfoStreamGroupPending struct {
	DeliveryTime  time.Time
	ID            string
	Consumer      string
	DeliveryCount int64
}

type XMessage 

type XMessage struct {
	Values map[string]any
	ID     string
}

type XMessageSliceCmd 

type XMessageSliceCmd struct {
	// contains filtered or unexported fields
}

func (*XMessageSliceCmd) Err 

func (cmd *XMessageSliceCmd) Err() error

func (*XMessageSliceCmd) Result 

func (cmd *XMessageSliceCmd) Result() ([]XMessage, error)

func (*XMessageSliceCmd) SetErr 

func (cmd *XMessageSliceCmd) SetErr(err error)

func (*XMessageSliceCmd) SetVal 

func (cmd *XMessageSliceCmd) SetVal(val []XMessage)

func (*XMessageSliceCmd) Val 

func (cmd *XMessageSliceCmd) Val() []XMessage

type XPending 

type XPending struct {
	Consumers map[string]int64
	Lower     string
	Higher    string
	Count     int64
}

type XPendingCmd 

type XPendingCmd struct {
	// contains filtered or unexported fields
}

func (*XPendingCmd) Err 

func (cmd *XPendingCmd) Err() error

func (*XPendingCmd) Result 

func (cmd *XPendingCmd) Result() (XPending, error)

func (*XPendingCmd) SetErr 

func (cmd *XPendingCmd) SetErr(err error)

func (*XPendingCmd) SetVal 

func (cmd *XPendingCmd) SetVal(val XPending)

func (*XPendingCmd) Val 

func (cmd *XPendingCmd) Val() XPending

type XPendingExt 

type XPendingExt struct {
	ID         string
	Consumer   string
	Idle       time.Duration
	RetryCount int64
}

type XPendingExtArgs 

type XPendingExtArgs struct {
	Stream   string
	Group    string
	Start    string
	End      string
	Consumer string
	Idle     time.Duration
	Count    int64
}

type XPendingExtCmd 

type XPendingExtCmd struct {
	// contains filtered or unexported fields
}

func (*XPendingExtCmd) Err 

func (cmd *XPendingExtCmd) Err() error

func (*XPendingExtCmd) Result 

func (cmd *XPendingExtCmd) Result() ([]XPendingExt, error)

func (*XPendingExtCmd) SetErr 

func (cmd *XPendingExtCmd) SetErr(err error)

func (*XPendingExtCmd) SetVal 

func (cmd *XPendingExtCmd) SetVal(val []XPendingExt)

func (*XPendingExtCmd) Val 

func (cmd *XPendingExtCmd) Val() []XPendingExt

type XReadArgs 

type XReadArgs struct {
	Streams []string // list of streams
	Count   int64
	Block   time.Duration
}

type XReadGroupArgs 

type XReadGroupArgs struct {
	Group    string
	Consumer string
	Streams  []string // list of streams
	Count    int64
	Block    time.Duration
	NoAck    bool
}

type XStream 

type XStream struct {
	Stream   string
	Messages []XMessage
}

type XStreamSliceCmd 

type XStreamSliceCmd struct {
	// contains filtered or unexported fields
}

func (*XStreamSliceCmd) Err 

func (cmd *XStreamSliceCmd) Err() error

func (*XStreamSliceCmd) Result 

func (cmd *XStreamSliceCmd) Result() ([]XStream, error)

func (*XStreamSliceCmd) SetErr 

func (cmd *XStreamSliceCmd) SetErr(err error)

func (*XStreamSliceCmd) SetVal 

func (cmd *XStreamSliceCmd) SetVal(val []XStream)

func (*XStreamSliceCmd) Val 

func (cmd *XStreamSliceCmd) Val() []XStream

type Z 

type Z struct {
	Member any
	Score  float64
}

Z represents sorted set member.

type ZAddArgs 

type ZAddArgs struct {
	Members []Z
	NX      bool
	XX      bool
	LT      bool
	GT      bool
	Ch      bool
}

Note: The GT, LT and NX options are mutually exclusive.

type ZRangeArgs 

type ZRangeArgs struct {
	Start   any
	Stop    any
	Key     string
	Offset  int64
	Count   int64
	ByScore bool
	ByLex   bool
	Rev     bool
}

ZRangeArgs is all the options of the ZRange command. In version> 6.2.0, you can replace the(cmd): 

ZREVRANGE,
ZRANGEBYSCORE,
ZREVRANGEBYSCORE,
ZRANGEBYLEX,
ZREVRANGEBYLEX.

Please pay attention to your redis-server version.

Rev, ByScore, ByLex and Offset+Count options require redis-server 6.2.0 and higher.

type ZRangeBy 

type ZRangeBy struct {
	Min, Max      string
	Offset, Count int64
}

type ZSliceCmd 

type ZSliceCmd struct {
	// contains filtered or unexported fields
}

func (*ZSliceCmd) Err 

func (cmd *ZSliceCmd) Err() error

func (*ZSliceCmd) Result 

func (cmd *ZSliceCmd) Result() ([]Z, error)

func (*ZSliceCmd) SetErr 

func (cmd *ZSliceCmd) SetErr(err error)

func (*ZSliceCmd) SetVal 

func (cmd *ZSliceCmd) SetVal(val []Z)

func (*ZSliceCmd) Val 

func (cmd *ZSliceCmd) Val() []Z

type ZSliceWithKeyCmd 

type ZSliceWithKeyCmd struct {
	// contains filtered or unexported fields
}

func (*ZSliceWithKeyCmd) Err 

func (cmd *ZSliceWithKeyCmd) Err() error

func (*ZSliceWithKeyCmd) Result 

func (cmd *ZSliceWithKeyCmd) Result() (string, []Z, error)

func (*ZSliceWithKeyCmd) SetErr 

func (cmd *ZSliceWithKeyCmd) SetErr(err error)

func (*ZSliceWithKeyCmd) SetVal 

func (cmd *ZSliceWithKeyCmd) SetVal(key string, val []Z)

func (*ZSliceWithKeyCmd) Val 

func (cmd *ZSliceWithKeyCmd) Val() (string, []Z)

type ZStore 

type ZStore struct {
	Aggregate string
	Keys      []string
	Weights   []int64
}

ZStore is used as an arg to ZInter/ZInterStore and ZUnion/ZUnionStore.

type ZWithKey 

type ZWithKey struct {
	Z
	Key string
}

ZWithKey represents sorted set member including the name of the key where it was popped.

type ZWithKeyCmd 

type ZWithKeyCmd struct {
	// contains filtered or unexported fields
}

func (*ZWithKeyCmd) Err 

func (cmd *ZWithKeyCmd) Err() error

func (*ZWithKeyCmd) Result 

func (cmd *ZWithKeyCmd) Result() (ZWithKey, error)

func (*ZWithKeyCmd) SetErr 

func (cmd *ZWithKeyCmd) SetErr(err error)

func (*ZWithKeyCmd) SetVal 

func (cmd *ZWithKeyCmd) SetVal(val ZWithKey)

func (*ZWithKeyCmd) Val 

func (cmd *ZWithKeyCmd) Val() ZWithKey

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.