rueidiscompat

package
v1.0.25 Latest Latest
Warning

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

Go to latest
Published: Dec 22, 2023 License: Apache-2.0 Imports: 15 Imported by: 0

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/Datadog/rueidis"
	"github.com/Datadog/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 (
	Invalid = Aggregator(iota)
	Avg
	Sum
	Min
	Max
	Range
	Count
	First
	Last
	StdP
	StdS
	VarP
	VarS
	Twa
)
View Source
const KeepTTL = -1

Variables

This section is empty.

Functions

func Scan added in v1.0.25

func Scan(dst interface{}, keys []string, vals []interface{}) error

Scan scans the results from a key-value Redis map result set to a destination struct. The Redis keys are matched to the struct's field with the `redis` tag. NOTE: vals' element's underlying type should be string

Types

type Aggregator added in v1.0.25

type Aggregator int

func (Aggregator) String added in v1.0.25

func (a Aggregator) String() string

type BFInfo added in v1.0.25

type BFInfo struct {
	Capacity      int64 `redis:"Capacity"`
	Size          int64 `redis:"Size"`
	Filters       int64 `redis:"Number of filters"`
	ItemsInserted int64 `redis:"Number of items inserted"`
	ExpansionRate int64 `redis:"Expansion rate"`
}

type BFInfoCmd added in v1.0.25

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

func (*BFInfoCmd) Err added in v1.0.25

func (cmd *BFInfoCmd) Err() error

func (*BFInfoCmd) Result added in v1.0.25

func (cmd *BFInfoCmd) Result() (T, error)

func (*BFInfoCmd) SetVal added in v1.0.25

func (cmd *BFInfoCmd) SetVal(val T)

func (*BFInfoCmd) Val added in v1.0.25

func (cmd *BFInfoCmd) Val() T

type BFInsertOptions added in v1.0.25

type BFInsertOptions struct {
	Capacity   int64
	Error      float64
	Expansion  int64
	NonScaling bool
	NoCreate   bool
}

type BFReserveOptions added in v1.0.25

type BFReserveOptions struct {
	Capacity   int64
	Error      float64
	Expansion  int64
	NonScaling bool
}

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 CFInfo added in v1.0.25

type CFInfo struct {
	Size             int64 `redis:"Size"`
	NumBuckets       int64 `redis:"Number of buckets"`
	NumFilters       int64 `redis:"Number of filters"`
	NumItemsInserted int64 `redis:"Number of items inserted"`
	NumItemsDeleted  int64 `redis:"Number of items deleted"`
	BucketSize       int64 `redis:"Bucket size"`
	ExpansionRate    int64 `redis:"Expansion rate"`
	MaxIteration     int64 `redis:"Max iterations"`
}

type CFInfoCmd added in v1.0.25

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

func (*CFInfoCmd) Err added in v1.0.25

func (cmd *CFInfoCmd) Err() error

func (*CFInfoCmd) Result added in v1.0.25

func (cmd *CFInfoCmd) Result() (T, error)

func (*CFInfoCmd) SetVal added in v1.0.25

func (cmd *CFInfoCmd) SetVal(val T)

func (*CFInfoCmd) Val added in v1.0.25

func (cmd *CFInfoCmd) Val() T

type CFInsertOptions added in v1.0.25

type CFInsertOptions struct {
	Capacity int64
	NoCreate bool
}

type CFReserveOptions added in v1.0.25

type CFReserveOptions struct {
	Capacity      int64
	BucketSize    int64
	MaxIterations int64
	Expansion     int64
}

type CMSInfo added in v1.0.25

type CMSInfo struct {
	Width int64 `redis:"width"`
	Depth int64 `redis:"depth"`
	Count int64 `redis:"count"`
}

type CMSInfoCmd added in v1.0.25

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

func (*CMSInfoCmd) Err added in v1.0.25

func (cmd *CMSInfoCmd) Err() error

func (*CMSInfoCmd) Result added in v1.0.25

func (cmd *CMSInfoCmd) Result() (T, error)

func (*CMSInfoCmd) SetVal added in v1.0.25

func (cmd *CMSInfoCmd) SetVal(val T)

func (*CMSInfoCmd) Val added in v1.0.25

func (cmd *CMSInfoCmd) Val() T

type CacheCompat

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

CacheCompat implements commands that support client-side caching.

func (CacheCompat) BFExists added in v1.0.25

func (c CacheCompat) BFExists(ctx context.Context, key string, element interface{}) *BoolCmd

func (CacheCompat) BFInfo added in v1.0.25

func (c CacheCompat) BFInfo(ctx context.Context, key string) *BFInfoCmd

func (CacheCompat) BFInfoArg added in v1.0.25

func (c CacheCompat) BFInfoArg(ctx context.Context, key, option string) *BFInfoCmd

func (CacheCompat) BFInfoCapacity added in v1.0.25

func (c CacheCompat) BFInfoCapacity(ctx context.Context, key string) *BFInfoCmd

func (CacheCompat) BFInfoExpansion added in v1.0.25

func (c CacheCompat) BFInfoExpansion(ctx context.Context, key string) *BFInfoCmd

func (CacheCompat) BFInfoFilters added in v1.0.25

func (c CacheCompat) BFInfoFilters(ctx context.Context, key string) *BFInfoCmd

func (CacheCompat) BFInfoItems added in v1.0.25

func (c CacheCompat) BFInfoItems(ctx context.Context, key string) *BFInfoCmd

func (CacheCompat) BFInfoSize added in v1.0.25

func (c CacheCompat) BFInfoSize(ctx context.Context, key string) *BFInfoCmd

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) CFCount added in v1.0.25

func (c *CacheCompat) CFCount(ctx context.Context, key string, element interface{}) *IntCmd

func (*CacheCompat) CFExists added in v1.0.25

func (c *CacheCompat) CFExists(ctx context.Context, key string, element interface{}) *BoolCmd

func (*CacheCompat) CFInfo added in v1.0.25

func (c *CacheCompat) CFInfo(ctx context.Context, key string) *CFInfoCmd

func (*CacheCompat) CMSInfo added in v1.0.25

func (c *CacheCompat) CMSInfo(ctx context.Context, key string) *CMSInfoCmd

func (*CacheCompat) CMSQuery added in v1.0.25

func (c *CacheCompat) CMSQuery(ctx context.Context, key string, elements ...interface{}) *IntSliceCmd

func (CacheCompat) EvalRO

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

func (CacheCompat) EvalShaRO

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

func (CacheCompat) FCallRO

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) TopKInfo added in v1.0.25

func (c *CacheCompat) TopKInfo(ctx context.Context, key string) *TopKInfoCmd

func (*CacheCompat) TopKList added in v1.0.25

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

func (*CacheCompat) TopKQuery added in v1.0.25

func (c *CacheCompat) TopKQuery(ctx context.Context, key string, elements ...interface{}) *BoolSliceCmd

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 ClusterShard added in v1.0.25

type ClusterShard struct {
	Slots []SlotRange
	Nodes []Node
}

type ClusterShardsCmd added in v1.0.25

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

func (*ClusterShardsCmd) Err added in v1.0.25

func (cmd *ClusterShardsCmd) Err() error

func (*ClusterShardsCmd) Result added in v1.0.25

func (cmd *ClusterShardsCmd) Result() ([]ClusterShard, error)

func (*ClusterShardsCmd) SetErr added in v1.0.25

func (cmd *ClusterShardsCmd) SetErr(err error)

func (*ClusterShardsCmd) SetVal added in v1.0.25

func (cmd *ClusterShardsCmd) SetVal(val []ClusterShard)

func (*ClusterShardsCmd) Val added in v1.0.25

func (cmd *ClusterShardsCmd) Val() []ClusterShard

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
	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

	// TODO ModuleLoadex(ctx context.Context, conf *ModuleLoadexConfig) *StringCmd
	GearsCmdable
	ProbabilisticCmdable
	TimeseriesCmdable
}

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) BFAdd added in v1.0.25

func (c *Compat) BFAdd(ctx context.Context, key string, element interface{}) *BoolCmd

func (*Compat) BFCard added in v1.0.25

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

func (*Compat) BFExists added in v1.0.25

func (c *Compat) BFExists(ctx context.Context, key string, element interface{}) *BoolCmd

func (*Compat) BFInfo added in v1.0.25

func (c *Compat) BFInfo(ctx context.Context, key string) *BFInfoCmd

func (*Compat) BFInfoArg added in v1.0.25

func (c *Compat) BFInfoArg(ctx context.Context, key, option string) *BFInfoCmd

func (*Compat) BFInfoCapacity added in v1.0.25

func (c *Compat) BFInfoCapacity(ctx context.Context, key string) *BFInfoCmd

func (*Compat) BFInfoExpansion added in v1.0.25

func (c *Compat) BFInfoExpansion(ctx context.Context, key string) *BFInfoCmd

func (*Compat) BFInfoFilters added in v1.0.25

func (c *Compat) BFInfoFilters(ctx context.Context, key string) *BFInfoCmd

func (*Compat) BFInfoItems added in v1.0.25

func (c *Compat) BFInfoItems(ctx context.Context, key string) *BFInfoCmd

func (*Compat) BFInfoSize added in v1.0.25

func (c *Compat) BFInfoSize(ctx context.Context, key string) *BFInfoCmd

func (*Compat) BFInsert added in v1.0.25

func (c *Compat) BFInsert(ctx context.Context, key string, options *BFInsertOptions, elements ...interface{}) *BoolSliceCmd

func (*Compat) BFLoadChunk added in v1.0.25

func (c *Compat) BFLoadChunk(ctx context.Context, key string, iterator int64, data interface{}) *StatusCmd

func (*Compat) BFMAdd added in v1.0.25

func (c *Compat) BFMAdd(ctx context.Context, key string, elements ...interface{}) *BoolSliceCmd

func (*Compat) BFMExists added in v1.0.25

func (c *Compat) BFMExists(ctx context.Context, key string, elements ...interface{}) *BoolSliceCmd

func (*Compat) BFReserve added in v1.0.25

func (c *Compat) BFReserve(ctx context.Context, key string, errorRate float64, capacity int64) *StatusCmd

func (*Compat) BFReserveExpansion added in v1.0.25

func (c *Compat) BFReserveExpansion(ctx context.Context, key string, errorRate float64, capacity, expansion int64) *StatusCmd

func (*Compat) BFReserveNonScaling added in v1.0.25

func (c *Compat) BFReserveNonScaling(ctx context.Context, key string, errorRate float64, capacity int64) *StatusCmd

func (*Compat) BFReserveWithArgs added in v1.0.25

func (c *Compat) BFReserveWithArgs(ctx context.Context, key string, options *BFReserveOptions) *StatusCmd

func (*Compat) BFScanDump added in v1.0.25

func (c *Compat) BFScanDump(ctx context.Context, key string, iterator int64) *ScanDumpCmd

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) CFAdd added in v1.0.25

func (c *Compat) CFAdd(ctx context.Context, key string, element interface{}) *BoolCmd

func (*Compat) CFAddNX added in v1.0.25

func (c *Compat) CFAddNX(ctx context.Context, key string, element interface{}) *BoolCmd

func (*Compat) CFCount added in v1.0.25

func (c *Compat) CFCount(ctx context.Context, key string, element interface{}) *IntCmd

func (*Compat) CFDel added in v1.0.25

func (c *Compat) CFDel(ctx context.Context, key string, element interface{}) *BoolCmd

func (*Compat) CFExists added in v1.0.25

func (c *Compat) CFExists(ctx context.Context, key string, element interface{}) *BoolCmd

func (*Compat) CFInfo added in v1.0.25

func (c *Compat) CFInfo(ctx context.Context, key string) *CFInfoCmd

func (*Compat) CFInsert added in v1.0.25

func (c *Compat) CFInsert(ctx context.Context, key string, options *CFInsertOptions, elements ...interface{}) *BoolSliceCmd

func (*Compat) CFInsertNX added in v1.0.25

func (c *Compat) CFInsertNX(ctx context.Context, key string, options *CFInsertOptions, elements ...interface{}) *IntSliceCmd

func (*Compat) CFLoadChunk added in v1.0.25

func (c *Compat) CFLoadChunk(ctx context.Context, key string, iterator int64, data interface{}) *StatusCmd

func (*Compat) CFMExists added in v1.0.25

func (c *Compat) CFMExists(ctx context.Context, key string, elements ...interface{}) *BoolSliceCmd

func (*Compat) CFReserve added in v1.0.25

func (c *Compat) CFReserve(ctx context.Context, key string, capacity int64) *StatusCmd

func (*Compat) CFReserveBucketSize added in v1.0.25

func (c *Compat) CFReserveBucketSize(ctx context.Context, key string, capacity int64, bucketsize int64) *StatusCmd

func (*Compat) CFReserveExpansion added in v1.0.25

func (c *Compat) CFReserveExpansion(ctx context.Context, key string, capacity int64, expansion int64) *StatusCmd

func (*Compat) CFReserveMaxIterations added in v1.0.25

func (c *Compat) CFReserveMaxIterations(ctx context.Context, key string, capacity int64, maxiterations int64) *StatusCmd

func (*Compat) CFReserveWithArgs added in v1.0.25

func (c *Compat) CFReserveWithArgs(ctx context.Context, key string, options *CFReserveOptions) *StatusCmd

func (*Compat) CFScanDump added in v1.0.25

func (c *Compat) CFScanDump(ctx context.Context, key string, iterator int64) *ScanDumpCmd

func (*Compat) CMSIncrBy added in v1.0.25

func (c *Compat) CMSIncrBy(ctx context.Context, key string, elements ...interface{}) *IntSliceCmd

func (*Compat) CMSInfo added in v1.0.25

func (c *Compat) CMSInfo(ctx context.Context, key string) *CMSInfoCmd

func (*Compat) CMSInitByDim added in v1.0.25

func (c *Compat) CMSInitByDim(ctx context.Context, key string, width, height int64) *StatusCmd

func (*Compat) CMSInitByProb added in v1.0.25

func (c *Compat) CMSInitByProb(ctx context.Context, key string, errorRate, probability float64) *StatusCmd

func (*Compat) CMSMerge added in v1.0.25

func (c *Compat) CMSMerge(ctx context.Context, destKey string, sourceKeys ...string) *StatusCmd

func (*Compat) CMSMergeWithWeight added in v1.0.25

func (c *Compat) CMSMergeWithWeight(ctx context.Context, destKey string, sourceKeys map[string]int64) *StatusCmd

func (*Compat) CMSQuery added in v1.0.25

func (c *Compat) CMSQuery(ctx context.Context, key string, elements ...interface{}) *IntSliceCmd

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) ClusterShards added in v1.0.25

func (c *Compat) ClusterShards(ctx context.Context) *ClusterShardsCmd

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) TDigestAdd added in v1.0.25

func (c *Compat) TDigestAdd(ctx context.Context, key string, elements ...float64) *StatusCmd

func (*Compat) TDigestByRank added in v1.0.25

func (c *Compat) TDigestByRank(ctx context.Context, key string, rank ...uint64) *FloatSliceCmd

func (*Compat) TDigestByRevRank added in v1.0.25

func (c *Compat) TDigestByRevRank(ctx context.Context, key string, rank ...uint64) *FloatSliceCmd

func (*Compat) TDigestCDF added in v1.0.25

func (c *Compat) TDigestCDF(ctx context.Context, key string, elements ...float64) *FloatSliceCmd

func (*Compat) TDigestCreate added in v1.0.25

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

func (*Compat) TDigestCreateWithCompression added in v1.0.25

func (c *Compat) TDigestCreateWithCompression(ctx context.Context, key string, compression int64) *StatusCmd

func (*Compat) TDigestInfo added in v1.0.25

func (c *Compat) TDigestInfo(ctx context.Context, key string) *TDigestInfoCmd

func (*Compat) TDigestMax added in v1.0.25

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

func (*Compat) TDigestMerge added in v1.0.25

func (c *Compat) TDigestMerge(ctx context.Context, destKey string, options *TDigestMergeOptions, sourceKeys ...string) *StatusCmd

func (*Compat) TDigestMin added in v1.0.25

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

func (*Compat) TDigestQuantile added in v1.0.25

func (c *Compat) TDigestQuantile(ctx context.Context, key string, elements ...float64) *FloatSliceCmd

func (*Compat) TDigestRank added in v1.0.25

func (c *Compat) TDigestRank(ctx context.Context, key string, values ...float64) *IntSliceCmd

func (*Compat) TDigestReset added in v1.0.25

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

func (*Compat) TDigestRevRank added in v1.0.25

func (c *Compat) TDigestRevRank(ctx context.Context, key string, values ...float64) *IntSliceCmd

func (*Compat) TDigestTrimmedMean added in v1.0.25

func (c *Compat) TDigestTrimmedMean(ctx context.Context, key string, lowCutQuantile, highCutQuantile float64) *FloatCmd

func (*Compat) TFCall added in v1.0.25

func (c *Compat) TFCall(ctx context.Context, libName string, funcName string, numKeys int) *Cmd

func (*Compat) TFCallASYNC added in v1.0.25

func (c *Compat) TFCallASYNC(ctx context.Context, libName string, funcName string, numKeys int) *Cmd

func (*Compat) TFCallASYNCArgs added in v1.0.25

func (c *Compat) TFCallASYNCArgs(ctx context.Context, libName string, funcName string, numKeys int, options *TFCallOptions) *Cmd

func (*Compat) TFCallArgs added in v1.0.25

func (c *Compat) TFCallArgs(ctx context.Context, libName string, funcName string, numKeys int, options *TFCallOptions) *Cmd

func (*Compat) TFunctionDelete added in v1.0.25

func (c *Compat) TFunctionDelete(ctx context.Context, libName string) *StatusCmd

func (*Compat) TFunctionList added in v1.0.25

func (c *Compat) TFunctionList(ctx context.Context) *MapStringInterfaceSliceCmd

func (*Compat) TFunctionListArgs added in v1.0.25

func (c *Compat) TFunctionListArgs(ctx context.Context, options *TFunctionListOptions) *MapStringInterfaceSliceCmd

func (*Compat) TFunctionLoad added in v1.0.25

func (c *Compat) TFunctionLoad(ctx context.Context, lib string) *StatusCmd

func (*Compat) TFunctionLoadArgs added in v1.0.25

func (c *Compat) TFunctionLoadArgs(ctx context.Context, lib string, options *TFunctionLoadOptions) *StatusCmd

FIXME: should check nil of options

func (*Compat) TSAdd added in v1.0.25

func (c *Compat) TSAdd(ctx context.Context, key string, timestamp interface{}, value float64) *IntCmd

TSAdd - Adds one or more observations to a t-digest sketch. For more information - https://redis.io/commands/ts.add/

func (*Compat) TSAddWithArgs added in v1.0.25

func (c *Compat) TSAddWithArgs(ctx context.Context, key string, timestamp interface{}, value float64, options *TSOptions) *IntCmd

TSAddWithArgs - Adds one or more observations to a t-digest sketch. This function also allows for specifying additional options such as: Retention, ChunkSize, Encoding, DuplicatePolicy and Labels. For more information - https://redis.io/commands/ts.add/

func (*Compat) TSAlter added in v1.0.25

func (c *Compat) TSAlter(ctx context.Context, key string, options *TSAlterOptions) *StatusCmd

TSAlter - Alters an existing time-series key with additional options. This function allows for specifying additional options such as: Retention, ChunkSize and DuplicatePolicy. For more information - https://redis.io/commands/ts.alter/

func (*Compat) TSCreate added in v1.0.25

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

TSCreate - Creates a new time-series key. For more information - https://redis.io/commands/ts.create/

func (*Compat) TSCreateRule added in v1.0.25

func (c *Compat) TSCreateRule(ctx context.Context, sourceKey string, destKey string, aggregator Aggregator, bucketDuration int) *StatusCmd

TSCreateRule - Creates a compaction rule from sourceKey to destKey. For more information - https://redis.io/commands/ts.createrule/

func (*Compat) TSCreateRuleWithArgs added in v1.0.25

func (c *Compat) TSCreateRuleWithArgs(ctx context.Context, sourceKey string, destKey string, aggregator Aggregator, bucketDuration int, options *TSCreateRuleOptions) *StatusCmd

TSCreateRuleWithArgs - Creates a compaction rule from sourceKey to destKey with additional option. This function allows for specifying additional option such as: alignTimestamp. For more information - https://redis.io/commands/ts.createrule/

func (*Compat) TSCreateWithArgs added in v1.0.25

func (c *Compat) TSCreateWithArgs(ctx context.Context, key string, options *TSOptions) *StatusCmd

TSCreateWithArgs - Creates a new time-series key with additional options. This function allows for specifying additional options such as: Retention, ChunkSize, Encoding, DuplicatePolicy and Labels. For more information - https://redis.io/commands/ts.create/

func (*Compat) TSDecrBy added in v1.0.25

func (c *Compat) TSDecrBy(ctx context.Context, Key string, timestamp float64) *IntCmd

TSDecrBy - Decrements the value of a time-series key by the specified timestamp. For more information - https://redis.io/commands/ts.decrby/ FIXME: timestamp should be subtrahend

func (*Compat) TSDecrByWithArgs added in v1.0.25

func (c *Compat) TSDecrByWithArgs(ctx context.Context, key string, timestamp float64, options *TSIncrDecrOptions) *IntCmd

TSDecrByWithArgs - Decrements the value of a time-series key by the specified timestamp with additional options. This function allows for specifying additional options such as: Timestamp, Retention, ChunkSize, Uncompressed and Labels. For more information - https://redis.io/commands/ts.decrby/

func (*Compat) TSDel added in v1.0.25

func (c *Compat) TSDel(ctx context.Context, Key string, fromTimestamp int, toTimestamp int) *IntCmd

TSDel - Deletes a range of samples from a time-series key. For more information - https://redis.io/commands/ts.del/

func (*Compat) TSDeleteRule added in v1.0.25

func (c *Compat) TSDeleteRule(ctx context.Context, sourceKey string, destKey string) *StatusCmd

TSDeleteRule - Deletes a compaction rule from sourceKey to destKey. For more information - https://redis.io/commands/ts.deleterule/

func (*Compat) TSGet added in v1.0.25

func (c *Compat) TSGet(ctx context.Context, key string) *TSTimestampValueCmd

TSGet - Gets the last sample of a time-series key. For more information - https://redis.io/commands/ts.get/

func (*Compat) TSGetWithArgs added in v1.0.25

func (c *Compat) TSGetWithArgs(ctx context.Context, key string, options *TSGetOptions) *TSTimestampValueCmd

TSGetWithArgs - Gets the last sample of a time-series key with additional option. This function allows for specifying additional option such as: Latest. For more information - https://redis.io/commands/ts.get/

func (*Compat) TSIncrBy added in v1.0.25

func (c *Compat) TSIncrBy(ctx context.Context, Key string, timestamp float64) *IntCmd

TSIncrBy - Increments the value of a time-series key by the specified timestamp. For more information - https://redis.io/commands/ts.incrby/ FIXME: timestamp should be addend

func (*Compat) TSIncrByWithArgs added in v1.0.25

func (c *Compat) TSIncrByWithArgs(ctx context.Context, key string, timestamp float64, options *TSIncrDecrOptions) *IntCmd

TSIncrByWithArgs - Increments the value of a time-series key by the specified timestamp with additional options. This function allows for specifying additional options such as: Timestamp, Retention, ChunkSize, Uncompressed and Labels. For more information - https://redis.io/commands/ts.incrby/ FIXME: timestamp should be addend

func (*Compat) TSInfo added in v1.0.25

func (c *Compat) TSInfo(ctx context.Context, key string) *MapStringInterfaceCmd

TSInfo - Returns information about a time-series key. For more information - https://redis.io/commands/ts.info/

func (*Compat) TSInfoWithArgs added in v1.0.25

func (c *Compat) TSInfoWithArgs(ctx context.Context, key string, options *TSInfoOptions) *MapStringInterfaceCmd

TSInfoWithArgs - Returns information about a time-series key with additional option. This function allows for specifying additional option such as: Debug. For more information - https://redis.io/commands/ts.info/

func (*Compat) TSMAdd added in v1.0.25

func (c *Compat) TSMAdd(ctx context.Context, ktvSlices [][]interface{}) *IntSliceCmd

TSMAdd - Adds multiple samples to multiple time-series keys. For more information - https://redis.io/commands/ts.madd/

func (*Compat) TSMGet added in v1.0.25

func (c *Compat) TSMGet(ctx context.Context, filters []string) *MapStringSliceInterfaceCmd

TSMGet - Returns the last sample of multiple time-series keys. For more information - https://redis.io/commands/ts.mget/

func (*Compat) TSMGetWithArgs added in v1.0.25

func (c *Compat) TSMGetWithArgs(ctx context.Context, filters []string, options *TSMGetOptions) *MapStringSliceInterfaceCmd

TSMGetWithArgs - Returns the last sample of multiple time-series keys with additional options. This function allows for specifying additional options such as: Latest, WithLabels and SelectedLabels. For more information - https://redis.io/commands/ts.mget/

func (*Compat) TSMRange added in v1.0.25

func (c *Compat) TSMRange(ctx context.Context, fromTimestamp int, toTimestamp int, filterExpr []string) *MapStringSliceInterfaceCmd

TSMRange - Returns a range of samples from multiple time-series keys. For more information - https://redis.io/commands/ts.mrange/

func (*Compat) TSMRangeWithArgs added in v1.0.25

func (c *Compat) TSMRangeWithArgs(ctx context.Context, fromTimestamp int, toTimestamp int, filterExpr []string, options *TSMRangeOptions) *MapStringSliceInterfaceCmd

TSMRangeWithArgs - Returns a range of samples from multiple time-series keys with additional options. This function allows for specifying additional options such as: Latest, FilterByTS, FilterByValue, WithLabels, SelectedLabels, Count, Align, Aggregator, BucketDuration, BucketTimestamp, Empty, GroupByLabel and Reducer. For more information - https://redis.io/commands/ts.mrange/

func (*Compat) TSMRevRange added in v1.0.25

func (c *Compat) TSMRevRange(ctx context.Context, fromTimestamp int, toTimestamp int, filterExpr []string) *MapStringSliceInterfaceCmd

TSMRevRange - Returns a range of samples from multiple time-series keys in reverse order. For more information - https://redis.io/commands/ts.mrevrange/

func (*Compat) TSMRevRangeWithArgs added in v1.0.25

func (c *Compat) TSMRevRangeWithArgs(ctx context.Context, fromTimestamp int, toTimestamp int, filterExpr []string, options *TSMRevRangeOptions) *MapStringSliceInterfaceCmd

TSMRevRangeWithArgs - Returns a range of samples from multiple time-series keys in reverse order with additional options. This function allows for specifying additional options such as: Latest, FilterByTS, FilterByValue, WithLabels, SelectedLabels, Count, Align, Aggregator, BucketDuration, BucketTimestamp, Empty, GroupByLabel and Reducer. For more information - https://redis.io/commands/ts.mrevrange/

func (*Compat) TSQueryIndex added in v1.0.25

func (c *Compat) TSQueryIndex(ctx context.Context, filterExpr []string) *StringSliceCmd

TSQueryIndex - Returns all the keys matching the filter expression. For more information - https://redis.io/commands/ts.queryindex/

func (*Compat) TSRange added in v1.0.25

func (c *Compat) TSRange(ctx context.Context, key string, fromTimestamp int, toTimestamp int) *TSTimestampValueSliceCmd

TSRange - Returns a range of samples from a time-series key. For more information - https://redis.io/commands/ts.range/

func (*Compat) TSRangeWithArgs added in v1.0.25

func (c *Compat) TSRangeWithArgs(ctx context.Context, key string, fromTimestamp int, toTimestamp int, options *TSRangeOptions) *TSTimestampValueSliceCmd

TSRangeWithArgs - Returns a range of samples from a time-series key with additional options. This function allows for specifying additional options such as: Latest, FilterByTS, FilterByValue, Count, Align, Aggregator, BucketDuration, BucketTimestamp and Empty. For more information - https://redis.io/commands/ts.range/

func (*Compat) TSRevRange added in v1.0.25

func (c *Compat) TSRevRange(ctx context.Context, key string, fromTimestamp int, toTimestamp int) *TSTimestampValueSliceCmd

TSRevRange - Returns a range of samples from a time-series key in reverse order. For more information - https://redis.io/commands/ts.revrange/

func (*Compat) TSRevRangeWithArgs added in v1.0.25

func (c *Compat) TSRevRangeWithArgs(ctx context.Context, key string, fromTimestamp int, toTimestamp int, options *TSRevRangeOptions) *TSTimestampValueSliceCmd

TSRevRangeWithArgs - Returns a range of samples from a time-series key in reverse order with additional options. This function allows for specifying additional options such as: Latest, FilterByTS, FilterByValue, Count, Align, Aggregator, BucketDuration, BucketTimestamp and Empty. For more information - https://redis.io/commands/ts.revrange/

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) TopKAdd added in v1.0.25

func (c *Compat) TopKAdd(ctx context.Context, key string, elements ...interface{}) *StringSliceCmd

func (*Compat) TopKCount added in v1.0.25

func (c *Compat) TopKCount(ctx context.Context, key string, elements ...interface{}) *IntSliceCmd

func (*Compat) TopKIncrBy added in v1.0.25

func (c *Compat) TopKIncrBy(ctx context.Context, key string, elements ...interface{}) *StringSliceCmd

func (*Compat) TopKInfo added in v1.0.25

func (c *Compat) TopKInfo(ctx context.Context, key string) *TopKInfoCmd

func (*Compat) TopKList added in v1.0.25

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

func (*Compat) TopKListWithCount added in v1.0.25

func (c *Compat) TopKListWithCount(ctx context.Context, key string) *MapStringIntCmd

func (*Compat) TopKQuery added in v1.0.25

func (c *Compat) TopKQuery(ctx context.Context, key string, elements ...interface{}) *BoolSliceCmd

func (*Compat) TopKReserve added in v1.0.25

func (c *Compat) TopKReserve(ctx context.Context, key string, k int64) *StatusCmd

func (*Compat) TopKReserveWithOptions added in v1.0.25

func (c *Compat) TopKReserveWithOptions(ctx context.Context, key string, k int64, width, depth int64, decay float64) *StatusCmd

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 GearsCmdable added in v1.0.25

type GearsCmdable interface {
	TFunctionLoad(ctx context.Context, lib string) *StatusCmd
	TFunctionLoadArgs(ctx context.Context, lib string, options *TFunctionLoadOptions) *StatusCmd
	TFunctionDelete(ctx context.Context, libName string) *StatusCmd
	TFunctionList(ctx context.Context) *MapStringInterfaceSliceCmd
	TFunctionListArgs(ctx context.Context, options *TFunctionListOptions) *MapStringInterfaceSliceCmd
	TFCall(ctx context.Context, libName string, funcName string, numKeys int) *Cmd
	TFCallArgs(ctx context.Context, libName string, funcName string, numKeys int, options *TFCallOptions) *Cmd
	TFCallASYNC(ctx context.Context, libName string, funcName string, numKeys int) *Cmd
	TFCallASYNCArgs(ctx context.Context, libName string, funcName string, numKeys int, options *TFCallOptions) *Cmd
}

Align with go-redis https://github.com/redis/go-redis/blob/f994ff1cd96299a5c8029ae3403af7b17ef06e8a/gears_commands.go#L9-L19

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
	Code      string
	Functions []Function
}

type MapStringIntCmd added in v1.0.25

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

func (*MapStringIntCmd) Err added in v1.0.25

func (cmd *MapStringIntCmd) Err() error

func (*MapStringIntCmd) Result added in v1.0.25

func (cmd *MapStringIntCmd) Result() (T, error)

func (*MapStringIntCmd) SetVal added in v1.0.25

func (cmd *MapStringIntCmd) SetVal(val T)

func (*MapStringIntCmd) Val added in v1.0.25

func (cmd *MapStringIntCmd) Val() T

type MapStringInterfaceCmd added in v1.0.25

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

func (*MapStringInterfaceCmd) Err added in v1.0.25

func (cmd *MapStringInterfaceCmd) Err() error

func (*MapStringInterfaceCmd) Result added in v1.0.25

func (cmd *MapStringInterfaceCmd) Result() (T, error)

func (*MapStringInterfaceCmd) SetVal added in v1.0.25

func (cmd *MapStringInterfaceCmd) SetVal(val T)

func (*MapStringInterfaceCmd) Val added in v1.0.25

func (cmd *MapStringInterfaceCmd) Val() T

type MapStringInterfaceSliceCmd added in v1.0.25

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

func (*MapStringInterfaceSliceCmd) Err added in v1.0.25

func (cmd *MapStringInterfaceSliceCmd) Err() error

func (*MapStringInterfaceSliceCmd) Result added in v1.0.25

func (cmd *MapStringInterfaceSliceCmd) Result() ([]map[string]interface{}, error)

func (*MapStringInterfaceSliceCmd) SetVal added in v1.0.25

func (cmd *MapStringInterfaceSliceCmd) SetVal(val []map[string]interface{})

func (*MapStringInterfaceSliceCmd) Val added in v1.0.25

func (cmd *MapStringInterfaceSliceCmd) Val() []map[string]interface{}

type MapStringSliceInterfaceCmd added in v1.0.25

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

func (*MapStringSliceInterfaceCmd) Err added in v1.0.25

func (cmd *MapStringSliceInterfaceCmd) Err() error

func (*MapStringSliceInterfaceCmd) Result