rueidiscompat

package module
v1.0.52 Latest Latest
Warning

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

 Go to latest Published: Dec 24, 2024 License: Apache-2.0 Imports: 20 Imported by: 21

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 example

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

package main

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

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

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

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

Pipeline example

package main

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

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

	rdb := rueidiscompat.NewAdapter(client)
	cmds, err := rdb.Pipelined(ctx, func(pipe rueidiscompat.Pipeliner) error {
		for i := 0; i < 100; i++ {
			pipe.Set(ctx, fmt.Sprintf("key%d", i), i, 0)
			pipe.Get(ctx, fmt.Sprintf("key%d", i))
		}
		return nil
	})
	if err != nil {
		panic(err)
	}
	for _, cmd := range cmds {
		fmt.Println(cmd.(*rueidiscompat.StringCmd).Val())
	}
}

Transaction example

package main

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

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

	key := "my_counter"
	rdb := rueidiscompat.NewAdapter(client)
	txf := func(tx rueidiscompat.Tx) error {
		n, err := tx.Get(ctx, key).Int()
		if err != nil && err != rueidiscompat.Nil {
			return err
		}
		// Operation is commited only if the watched keys remain unchanged.
		_, err = tx.TxPipelined(ctx, func(pipe rueidiscompat.Pipeliner) error {
			pipe.Set(ctx, key, n+1, 0)
			return nil
		})
		return err
	}
	for {
		err := rdb.Watch(ctx, txf, key)
		if err == nil {
			break
		} else if err == rueidiscompat.TxFailedErr {
			// Optimistic lock lost. Retry if the key has been changed.
			continue
		}
		panic(err)
	}
}

PubSub example

package main

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

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

	rdb := rueidiscompat.NewAdapter(client)
	pubsub := rdb.Subscribe(ctx, "mychannel1")
	defer pubsub.Close()

	go func() {
		for i := 0; ; i++ {
			if err := rdb.Publish(ctx, "mychannel1", strconv.Itoa(i)).Err(); err != nil {
				panic(err)
			}
		}
	}()
	for {
		msg, err := pubsub.ReceiveMessage(ctx)
		if err != nil {
			panic(err)
		}
		fmt.Println(msg.Channel, msg.Payload)
	}
}

Lua script example

package main

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

var incrBy = rueidiscompat.NewScript(`
local key = KEYS[1]
local change = ARGV[1]
local value = redis.call("GET", key)
if not value then
  value = 0
end
value = value + change
redis.call("SET", key, value)
return value
`)

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

	rdb := rueidiscompat.NewAdapter(client)
	keys := []string{"my_counter"}
	values := []interface{}{+1}
	fmt.Println(incrBy.Run(ctx, rdb, keys, values...).Int())
}

Methods not yet implemented in the adapter

  • HExpire, HPExpire, HTTL, and HPTTL related methods.
  • FTSearch, FTAggregate, FTCreate, and FTDropIndex related methods.

For more details, please refer to those TODO marks in the ./adapter.go

Documentation

Index

Examples

Constants

View Source 
const (
	KeepTTL           = -1
	BitCountIndexByte = "BYTE"
	BitCountIndexBit  = "BIT"
)
View Source 
const (
	Invalid = Aggregator(iota)
	Avg
	Sum
	Min
	Max
	Range
	Count
	First
	Last
	StdP
	StdS
	VarP
	VarS
	Twa
)
View Source 
const (
	TYP_STRING jsonCmdTyp = iota
	TYP_ARRAY
)
View Source 
const (
	SearchInvalid = SearchAggregator(iota)
	SearchAvg
	SearchSum
	SearchMin
	SearchMax
	SearchCount
	SearchCountDistinct
	SearchCountDistinctish
	SearchStdDev
	SearchQuantile
	SearchToList
	SearchFirstValue
	SearchRandomSample
)
View Source 
const (
	SearchFieldTypeInvalid = SearchFieldType(iota)
	SearchFieldTypeNumeric
	SearchFieldTypeTag
	SearchFieldTypeText
	SearchFieldTypeGeo
	SearchFieldTypeVector
	SearchFieldTypeGeoShape
)

Variables

View Source 
var Nil = rueidis.Nil
View Source 
var TxFailedErr = errors.New("redis: transaction failed")

Functions

func BytesToString added in v1.0.50 

func BytesToString(b []byte) string

func GetAddr added in v1.0.50 

func GetAddr(addr string) string

func ReplaceSpaces added in v1.0.50 

func ReplaceSpaces(s string) string

func Scan 

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

func StringToBytes added in v1.0.50 

func StringToBytes(s string) []byte

func ToFloat added in v1.0.50 

func ToFloat(val interface{}) float64

func ToInteger added in v1.0.50 

func ToInteger(val interface{}) int

func ToLower added in v1.0.50 

func ToLower(s string) string

func ToString added in v1.0.50 

func ToString(val interface{}) string

func ToStringSlice added in v1.0.50 

func ToStringSlice(val interface{}) []string

Types

type AggregateCmd added in v1.0.50 

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

func (*AggregateCmd) Err added in v1.0.50 

func (cmd *AggregateCmd) Err() error

func (*AggregateCmd) RawResult added in v1.0.50 

func (cmd *AggregateCmd) RawResult() (any, error)

func (*AggregateCmd) RawVal added in v1.0.50 

func (cmd *AggregateCmd) RawVal() any

func (*AggregateCmd) Result added in v1.0.50 

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

func (*AggregateCmd) SetErr added in v1.0.50 

func (cmd *AggregateCmd) SetErr(err error)

func (*AggregateCmd) SetRawVal added in v1.0.50 

func (cmd *AggregateCmd) SetRawVal(rawVal any)

func (*AggregateCmd) SetVal added in v1.0.50 

func (cmd *AggregateCmd) SetVal(val T)

func (*AggregateCmd) Val added in v1.0.50 

func (cmd *AggregateCmd) Val() T

type AggregateRow added in v1.0.50 

type AggregateRow struct {
	Fields map[string]any
}

type Aggregator 

type Aggregator int

func (Aggregator) String 

func (a Aggregator) String() string

type BFInfo 

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 

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

func (*BFInfoCmd) Err 

func (cmd *BFInfoCmd) Err() error

func (*BFInfoCmd) RawResult added in v1.0.50 

func (cmd *BFInfoCmd) RawResult() (any, error)

func (*BFInfoCmd) RawVal added in v1.0.50 

func (cmd *BFInfoCmd) RawVal() any

func (*BFInfoCmd) Result 

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

func (*BFInfoCmd) SetErr 

func (cmd *BFInfoCmd) SetErr(err error)

func (*BFInfoCmd) SetRawVal added in v1.0.50 

func (cmd *BFInfoCmd) SetRawVal(rawVal any)

func (*BFInfoCmd) SetVal 

func (cmd *BFInfoCmd) SetVal(val T)

func (*BFInfoCmd) Val 

func (cmd *BFInfoCmd) Val() T

type BFInsertOptions 

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

type BFReserveOptions 

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

type BitCount 

type BitCount struct {
	Start, End int64
	Unit       string // Stores BIT or BYTE
}

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) RawResult added in v1.0.50 

func (cmd *BoolCmd) RawResult() (any, error)

func (*BoolCmd) RawVal added in v1.0.50 

func (cmd *BoolCmd) RawVal() any

func (*BoolCmd) Result 

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

func (*BoolCmd) SetErr 

func (cmd *BoolCmd) SetErr(err error)

func (*BoolCmd) SetRawVal added in v1.0.50 

func (cmd *BoolCmd) SetRawVal(rawVal any)

func (*BoolCmd) SetVal 

func (cmd *BoolCmd) SetVal(val T)

func (*BoolCmd) Val 

func (cmd *BoolCmd) Val() T

type BoolSliceCmd 

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

func (*BoolSliceCmd) Err 

func (cmd *BoolSliceCmd) Err() error

func (*BoolSliceCmd) RawResult added in v1.0.50 

func (cmd *BoolSliceCmd) RawResult() (any, error)

func (*BoolSliceCmd) RawVal added in v1.0.50 

func (cmd *BoolSliceCmd) RawVal() any

func (*BoolSliceCmd) Result 

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

func (*BoolSliceCmd) SetErr 

func (cmd *BoolSliceCmd) SetErr(err error)

func (*BoolSliceCmd) SetRawVal added in v1.0.50 

func (cmd *BoolSliceCmd) SetRawVal(rawVal any)

func (*BoolSliceCmd) SetVal 

func (cmd *BoolSliceCmd) SetVal(val T)

func (*BoolSliceCmd) Val 

func (cmd *BoolSliceCmd) Val() T

type CFInfo 

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 

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

func (*CFInfoCmd) Err 

func (cmd *CFInfoCmd) Err() error

func (*CFInfoCmd) RawResult added in v1.0.50 

func (cmd *CFInfoCmd) RawResult() (any, error)

func (*CFInfoCmd) RawVal added in v1.0.50 

func (cmd *CFInfoCmd) RawVal() any

func (*CFInfoCmd) Result 

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

func (*CFInfoCmd) SetErr 

func (cmd *CFInfoCmd) SetErr(err error)

func (*CFInfoCmd) SetRawVal added in v1.0.50 

func (cmd *CFInfoCmd) SetRawVal(rawVal any)

func (*CFInfoCmd) SetVal 

func (cmd *CFInfoCmd) SetVal(val T)

func (*CFInfoCmd) Val 

func (cmd *CFInfoCmd) Val() T

type CFInsertOptions 

type CFInsertOptions struct {
	Capacity int64
	NoCreate bool
}

type CFReserveOptions 

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

type CMSInfo 

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

type CMSInfoCmd 

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

func (*CMSInfoCmd) Err 

func (cmd *CMSInfoCmd) Err() error

func (*CMSInfoCmd) RawResult added in v1.0.50 

func (cmd *CMSInfoCmd) RawResult() (any, error)

func (*CMSInfoCmd) RawVal added in v1.0.50 

func (cmd *CMSInfoCmd) RawVal() any

func (*CMSInfoCmd) Result 

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

func (*CMSInfoCmd) SetErr 

func (cmd *CMSInfoCmd) SetErr(err error)

func (*CMSInfoCmd) SetRawVal added in v1.0.50 

func (cmd *CMSInfoCmd) SetRawVal(rawVal any)

func (*CMSInfoCmd) SetVal 

func (cmd *CMSInfoCmd) SetVal(val T)

func (*CMSInfoCmd) Val 

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 

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

func (CacheCompat) BFInfo 

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

func (CacheCompat) BFInfoArg 

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

func (CacheCompat) BFInfoCapacity 

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

func (CacheCompat) BFInfoExpansion 

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

func (CacheCompat) BFInfoFilters 

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

func (CacheCompat) BFInfoItems 

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

func (CacheCompat) BFInfoSize 

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) BitFieldRO added in v1.0.52 

func (c CacheCompat) BitFieldRO(ctx context.Context, key string, args ...any) *IntSliceCmd

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 

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

func (*CacheCompat) CFExists 

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

func (*CacheCompat) CFInfo 

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

func (*CacheCompat) CMSInfo 

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

func (*CacheCompat) CMSQuery 

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

func (c *CacheCompat) JSONArrIndex(ctx context.Context, key, path string, value ...interface{}) *IntSliceCmd

func (*CacheCompat) JSONArrLen 

func (c *CacheCompat) JSONArrLen(ctx context.Context, key, path string) *IntSliceCmd

func (*CacheCompat) JSONGet 

func (c *CacheCompat) JSONGet(ctx context.Context, key string, paths ...string) *JSONCmd

func (*CacheCompat) JSONMGet 

func (c *CacheCompat) JSONMGet(ctx context.Context, path string, keys ...string) *JSONSliceCmd

func (*CacheCompat) JSONObjKeys 

func (c *CacheCompat) JSONObjKeys(ctx context.Context, key, path string) *SliceCmd

func (*CacheCompat) JSONObjLen 

func (c *CacheCompat) JSONObjLen(ctx context.Context, key, path string) *IntPointerSliceCmd

func (*CacheCompat) JSONStrLen 

func (c *CacheCompat) JSONStrLen(ctx context.Context, key, path string) *IntPointerSliceCmd

func (*CacheCompat) JSONType 

func (c *CacheCompat) JSONType(ctx context.Context, key, path string) *JSONSliceCmd

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 

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

func (*CacheCompat) TopKList 

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

func (*CacheCompat) TopKQuery 

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 ChannelOption added in v1.0.42 

type ChannelOption func(c *chopt)

func WithChannelHealthCheckInterval added in v1.0.42 

func WithChannelHealthCheckInterval(_ time.Duration) ChannelOption

WithChannelHealthCheckInterval is an empty ChannelOption to keep compatibility

func WithChannelSendTimeout added in v1.0.42 

func WithChannelSendTimeout(_ time.Duration) ChannelOption

WithChannelSendTimeout is an empty ChannelOption to keep compatibility

func WithChannelSize added in v1.0.42 

func WithChannelSize(size int) ChannelOption

WithChannelSize specifies the Go chan size that is used to buffer incoming messages. The default is 1000 messages.

type ClientFlags added in v1.0.52 

type ClientFlags uint64

ClientFlags is redis-server client flags, copy from redis/src/server.h (redis 7.0) 

const (
	ClientSlave            ClientFlags = 1 << 0  /* This client is a replica */
	ClientMaster           ClientFlags = 1 << 1  /* This client is a master */
	ClientMonitor          ClientFlags = 1 << 2  /* This client is a slave monitor, see MONITOR */
	ClientMulti            ClientFlags = 1 << 3  /* This client is in a MULTI context */
	ClientBlocked          ClientFlags = 1 << 4  /* The client is waiting in a blocking operation */
	ClientDirtyCAS         ClientFlags = 1 << 5  /* Watched keys modified. EXEC will fail. */
	ClientCloseAfterReply  ClientFlags = 1 << 6  /* Close after writing entire reply. */
	ClientUnBlocked        ClientFlags = 1 << 7  /* This client was unblocked and is stored in server.unblocked_clients */
	ClientScript           ClientFlags = 1 << 8  /* This is a non-connected client used by Lua */
	ClientAsking           ClientFlags = 1 << 9  /* Client issued the ASKING command */
	ClientCloseASAP        ClientFlags = 1 << 10 /* Close this client ASAP */
	ClientUnixSocket       ClientFlags = 1 << 11 /* Client connected via Unix domain socket */
	ClientDirtyExec        ClientFlags = 1 << 12 /* EXEC will fail for errors while queueing */
	ClientMasterForceReply ClientFlags = 1 << 13 /* Queue replies even if is master */
	ClientForceAOF         ClientFlags = 1 << 14 /* Force AOF propagation of current cmd. */
	ClientForceRepl        ClientFlags = 1 << 15 /* Force replication of current cmd. */
	ClientPrePSync         ClientFlags = 1 << 16 /* Instance don't understand PSYNC. */
	ClientReadOnly         ClientFlags = 1 << 17 /* Cluster client is in read-only state. */
	ClientPubSub           ClientFlags = 1 << 18 /* Client is in Pub/Sub mode. */
	ClientPreventAOFProp   ClientFlags = 1 << 19 /* Don't propagate to AOF. */
	ClientPreventReplProp  ClientFlags = 1 << 20 /* Don't propagate to slaves. */
	ClientPreventProp      ClientFlags = ClientPreventAOFProp | ClientPreventReplProp
	ClientPendingWrite     ClientFlags = 1 << 21 /* Client has output to send but a-write handler is yet not installed. */
	ClientReplyOff         ClientFlags = 1 << 22 /* Don't send replies to client. */
	ClientReplySkipNext    ClientFlags = 1 << 23 /* Set ClientREPLY_SKIP for next cmd */
	ClientReplySkip        ClientFlags = 1 << 24 /* Don't send just this reply. */
	ClientLuaDebug         ClientFlags = 1 << 25 /* Run EVAL in debug mode. */
	ClientLuaDebugSync     ClientFlags = 1 << 26 /* EVAL debugging without fork() */
	ClientModule           ClientFlags = 1 << 27 /* Non connected client used by some module. */
	ClientProtected        ClientFlags = 1 << 28 /* Client should not be freed for now. */
	ClientExecutingCommand ClientFlags = 1 << 29 /* Indicates that the client is currently in the process of handling
	   a command. usually this will be marked only during call()
	   however, blocked clients might have this flag kept until they
	   will try to reprocess the command. */
	ClientPendingCommand      ClientFlags = 1 << 30 /* Indicates the client has a fully * parsed command ready for execution. */
	ClientTracking            ClientFlags = 1 << 31 /* Client enabled keys tracking in order to perform client side caching. */
	ClientTrackingBrokenRedir ClientFlags = 1 << 32 /* Target client is invalid. */
	ClientTrackingBCAST       ClientFlags = 1 << 33 /* Tracking in BCAST mode. */
	ClientTrackingOptIn       ClientFlags = 1 << 34 /* Tracking in opt-in mode. */
	ClientTrackingOptOut      ClientFlags = 1 << 35 /* Tracking in opt-out mode. */
	ClientTrackingCaching     ClientFlags = 1 << 36 /* CACHING yes/no was given, depending on optin/optout mode. */
	ClientTrackingNoLoop      ClientFlags = 1 << 37 /* Don't send invalidation messages about writes performed by myself.*/
	ClientInTimeoutTable      ClientFlags = 1 << 38 /* This client is in the timeout table. */
	ClientProtocolError       ClientFlags = 1 << 39 /* Protocol error chatting with it. */
	ClientCloseAfterCommand   ClientFlags = 1 << 40 /* Close after executing commands * and writing entire reply. */
	ClientDenyBlocking        ClientFlags = 1 << 41 /* Indicate that the client should not be blocked. currently, turned on inside MULTI, Lua, RM_Call, and AOF client */
	ClientReplRDBOnly         ClientFlags = 1 << 42 /* This client is a replica that only wants RDB without replication buffer. */
	ClientNoEvict             ClientFlags = 1 << 43 /* This client is protected against client memory eviction. */
	ClientAllowOOM            ClientFlags = 1 << 44 /* Client used by RM_Call is allowed to fully execute scripts even when in OOM */
	ClientNoTouch             ClientFlags = 1 << 45 /* This client will not touch LFU/LRU stats. */
	ClientPushing             ClientFlags = 1 << 46 /* This client is pushing notifications. */
)

type ClientInfo added in v1.0.52 

type ClientInfo struct {
	ID                 int64         // redis version 2.8.12, a unique 64-bit client ID
	Addr               string        // address/port of the client
	LAddr              string        // address/port of local address client connected to (bind address)
	FD                 int64         // file descriptor corresponding to the socket
	Name               string        // the name set by the client with CLIENT SETNAME
	Age                time.Duration // total duration of the connection in seconds
	Idle               time.Duration // idle time of the connection in seconds
	Flags              ClientFlags   // client flags (see below)
	DB                 int           // current database ID
	Sub                int           // number of channel subscriptions
	PSub               int           // number of pattern matching subscriptions
	SSub               int           // redis version 7.0.3, number of shard channel subscriptions
	Multi              int           // number of commands in a MULTI/EXEC context
	Watch              int           // redis version 7.4 RC1, number of keys this client is currently watching.
	QueryBuf           int           // qbuf, query buffer length (0 means no query pending)
	QueryBufFree       int           // qbuf-free, free space of the query buffer (0 means the buffer is full)
	ArgvMem            int           // incomplete arguments for the next command (already extracted from query buffer)
	MultiMem           int           // redis version 7.0, memory is used up by buffered multi commands
	BufferSize         int           // rbs, usable size of buffer
	BufferPeak         int           // rbp, peak used size of buffer in last 5 sec interval
	OutputBufferLength int           // obl, output buffer length
	OutputListLength   int           // oll, output list length (replies are queued in this list when the buffer is full)
	OutputMemory       int           // omem, output buffer memory usage
	TotalMemory        int           // tot-mem, total memory consumed by this client in its various buffers
	Events             string        // file descriptor events (see below)
	LastCmd            string        // cmd, last command played
	User               string        // the authenticated username of the client
	Redir              int64         // client id of current client tracking redirection
	Resp               int           // redis version 7.0, client RESP protocol version
	LibName            string        // redis version 7.2, client library name
	LibVer             string        // redis version 7.2, client library version
}

ClientInfo is redis-server ClientInfo

type ClientInfoCmd added in v1.0.52 

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

func (*ClientInfoCmd) Err added in v1.0.52 

func (cmd *ClientInfoCmd) Err() error

func (*ClientInfoCmd) RawResult added in v1.0.52 

func (cmd *ClientInfoCmd) RawResult() (any, error)

func (*ClientInfoCmd) RawVal added in v1.0.52 

func (cmd *ClientInfoCmd) RawVal() any

func (*ClientInfoCmd) Result added in v1.0.52 

func (cmd *ClientInfoCmd) Result() (*ClientInfo, error)

func (*ClientInfoCmd) SetErr added in v1.0.52 

func (cmd *ClientInfoCmd) SetErr(err error)

func (*ClientInfoCmd) SetRawVal added in v1.0.52 

func (cmd *ClientInfoCmd) SetRawVal(rawVal any)

func (*ClientInfoCmd) SetVal added in v1.0.52 

func (cmd *ClientInfoCmd) SetVal(val *ClientInfo)

func (*ClientInfoCmd) Val added in v1.0.52 

func (cmd *ClientInfoCmd) Val() *ClientInfo

type ClusterNode 

type ClusterNode struct {
	ID   string
	Addr string
}

type ClusterShard 

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

type ClusterShardsCmd 

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

func (*ClusterShardsCmd) Err 

func (cmd *ClusterShardsCmd) Err() error

func (*ClusterShardsCmd) RawResult added in v1.0.50 

func (cmd *ClusterShardsCmd) RawResult() (any, error)

func (*ClusterShardsCmd) RawVal added in v1.0.50 

func (cmd *ClusterShardsCmd) RawVal() any

func (*ClusterShardsCmd) Result 

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

func (*ClusterShardsCmd) SetErr 

func (cmd *ClusterShardsCmd) SetErr(err error)

func (*ClusterShardsCmd) SetRawVal added in v1.0.50 

func (cmd *ClusterShardsCmd) SetRawVal(rawVal any)

func (*ClusterShardsCmd) SetVal 

func (cmd *ClusterShardsCmd) SetVal(val T)

func (*ClusterShardsCmd) Val 

func (cmd *ClusterShardsCmd) Val() T

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) RawResult added in v1.0.50 

func (cmd *ClusterSlotsCmd) RawResult() (any, error)

func (*ClusterSlotsCmd) RawVal added in v1.0.50 

func (cmd *ClusterSlotsCmd) RawVal() any

func (*ClusterSlotsCmd) Result 

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

func (*ClusterSlotsCmd) SetErr 

func (cmd *ClusterSlotsCmd) SetErr(err error)

func (*ClusterSlotsCmd) SetRawVal added in v1.0.50 

func (cmd *ClusterSlotsCmd) SetRawVal(rawVal any)

func (*ClusterSlotsCmd) SetVal 

func (cmd *ClusterSlotsCmd) SetVal(val T)

func (*ClusterSlotsCmd) Val 

func (cmd *ClusterSlotsCmd) Val() T

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) RawResult added in v1.0.50 

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

func (*Cmd) RawVal added in v1.0.50 

func (cmd *Cmd) RawVal() any

func (*Cmd) Result 

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

func (*Cmd) SetErr 

func (cmd *Cmd) SetErr(err error)

func (*Cmd) SetRawVal added in v1.0.50 

func (cmd *Cmd) SetRawVal(rawVal any)

func (*Cmd) SetVal 

func (cmd *Cmd) SetVal(val T)

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() T

type Cmdable 

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

	Subscribe(ctx context.Context, channels ...string) PubSub
	PSubscribe(ctx context.Context, patterns ...string) PubSub
	SSubscribe(ctx context.Context, channels ...string) PubSub

	Watch(ctx context.Context, fn func(Tx) error, keys ...string) error
}

func NewAdapter 

func NewAdapter(client rueidis.Client) Cmdable

type Cmder added in v1.0.44 

type Cmder interface {
	SetErr(error)
	Err() error
	// contains filtered or unexported methods
}

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) RawResult added in v1.0.50 

func (cmd *CommandsInfoCmd) RawResult() (any, error)

func (*CommandsInfoCmd) RawVal added in v1.0.50 

func (cmd *CommandsInfoCmd) RawVal() any

func (*CommandsInfoCmd) Result 

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

func (*CommandsInfoCmd) SetErr 

func (cmd *CommandsInfoCmd) SetErr(err error)

func (*CommandsInfoCmd) SetRawVal added in v1.0.50 

func (cmd *CommandsInfoCmd) SetRawVal(rawVal any)

func (*CommandsInfoCmd) SetVal 

func (cmd *CommandsInfoCmd) SetVal(val T)

func (*CommandsInfoCmd) Val 

func (cmd *CommandsInfoCmd) Val() T

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 

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

func (*Compat) BFCard 

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

func (*Compat) BFExists 

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

func (*Compat) BFInfo 

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

func (*Compat) BFInfoArg 

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

func (*Compat) BFInfoCapacity 

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

func (*Compat) BFInfoExpansion 

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

func (*Compat) BFInfoFilters 

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

func (*Compat) BFInfoItems 

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

func (*Compat) BFInfoSize 

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

func (*Compat) BFInsert 

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

func (*Compat) BFLoadChunk 

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

func (*Compat) BFMAdd 

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

func (*Compat) BFMExists 

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

func (*Compat) BFReserve 

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

func (*Compat) BFReserveExpansion 

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

func (*Compat) BFReserveNonScaling 

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

func (*Compat) BFReserveWithArgs 

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

func (*Compat) BFScanDump 

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) BitFieldRO added in v1.0.52 

func (c *Compat) BitFieldRO(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 

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

func (*Compat) CFAddNX 

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

func (*Compat) CFCount 

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

func (*Compat) CFDel 

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

func (*Compat) CFExists 

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

func (*Compat) CFInfo 

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

func (*Compat) CFInsert 

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

func (*Compat) CFInsertNX 

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

func (*Compat) CFLoadChunk 

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

func (*Compat) CFMExists 

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

func (*Compat) CFReserve 

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

func (*Compat) CFReserveBucketSize 

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

func (*Compat) CFReserveExpansion 

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

func (*Compat) CFReserveMaxIterations 

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

func (*Compat) CFReserveWithArgs 

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

func (*Compat) CFScanDump 

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

func (*Compat) CMSIncrBy 

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

func (*Compat) CMSInfo 

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

func (*Compat) CMSInitByDim 

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

func (*Compat) CMSInitByProb 

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

func (*Compat) CMSMerge 

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

func (*Compat) CMSMergeWithWeight 

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

func (*Compat) CMSQuery 

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) ClientInfo added in v1.0.52 

func (c *Compat) ClientInfo(ctx context.Context) *ClientInfoCmd

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) ClusterMyShardID added in v1.0.52 

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

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 

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) FTAggregate added in v1.0.50 

func (c *Compat) FTAggregate(ctx context.Context, index string, query string) *MapStringInterfaceCmd

FTAggregate - Performs a search query on an index and applies a series of aggregate transformations to the result. The 'index' parameter specifies the index to search, and the 'query' parameter specifies the search query. For more information, please refer to the Redis documentation: [FT.AGGREGATE]: (https://redis.io/commands/ft.aggregate/) see go-redis v9.7.0 https://github.com/redis/go-redis/blob/v9.7.0/search_commands.go#L473

func (*Compat) FTAggregateWithArgs added in v1.0.50 

func (c *Compat) FTAggregateWithArgs(ctx context.Context, index string, query string, options *FTAggregateOptions) *AggregateCmd

FTAggregateWithArgs - Performs a search query on an index and applies a series of aggregate transformations to the result. The 'index' parameter specifies the index to search, and the 'query' parameter specifies the search query. This function also allows for specifying additional options such as: Verbatim, LoadAll, Load, Timeout, GroupBy, SortBy, SortByMax, Apply, LimitOffset, Limit, Filter, WithCursor, Params, and DialectVersion. For more information, please refer to the Redis documentation: [FT.AGGREGATE]: (https://redis.io/commands/ft.aggregate/) see: go-redis v9.7.0: https://github.com/redis/go-redis/blob/v9.7.0/search_commands.go#L671

func (*Compat) FTAliasAdd added in v1.0.50 

func (c *Compat) FTAliasAdd(ctx context.Context, index string, alias string) *StatusCmd

FTAliasAdd - Adds an alias to an index. The 'index' parameter specifies the index to which the alias is added, and the 'alias' parameter specifies the alias. For more information, please refer to the Redis documentation: [FT.ALIASADD]: (https://redis.io/commands/ft.aliasadd/) see go-redis v9.7.0 https://github.com/redis/go-redis/blob/v9.7.0/search_commands.go#L782

func (*Compat) FTAliasDel added in v1.0.50 

func (c *Compat) FTAliasDel(ctx context.Context, alias string) *StatusCmd

FTAliasDel - Removes an alias from an index. The 'alias' parameter specifies the alias to be removed. For more information, please refer to the Redis documentation: [FT.ALIASDEL]: (https://redis.io/commands/ft.aliasdel/) see go-redis v9.7.0 https://github.com/redis/go-redis/blob/v9.7.0/search_commands.go#L793

func (*Compat) FTAliasUpdate added in v1.0.50 

func (c *Compat) FTAliasUpdate(ctx context.Context, index string, alias string) *StatusCmd

FTAliasUpdate - Updates an alias to an index. The 'index' parameter specifies the index to which the alias is updated, and the 'alias' parameter specifies the alias. If the alias already exists for a different index, it updates the alias to point to the specified index instead. For more information, please refer to the Redis documentation: [FT.ALIASUPDATE]: (https://redis.io/commands/ft.aliasupdate/) see go-redis v9.7.0 https://github.com/redis/go-redis/blob/v9.7.0/search_commands.go#L804

func (*Compat) FTAlter added in v1.0.50 

func (c *Compat) FTAlter(ctx context.Context, index string, skipInitalScan bool, definition []interface{}) *StatusCmd

FTAlter - Alters the definition of an existing index. The 'index' parameter specifies the index to alter, and the 'skipInitialScan' parameter specifies whether to skip the initial scan. The 'definition' parameter specifies the new definition for the index. For more information, please refer to the Redis documentation: [FT.ALTER]: (https://redis.io/commands/ft.alter/) see go-redis v9.7.0 https://github.com/redis/go-redis/blob/v9.7.0/search_commands.go#L815

func (*Compat) FTConfigGet added in v1.0.50 

func (c *Compat) FTConfigGet(ctx context.Context, option string) *MapMapStringInterfaceCmd

FTConfigGet - Retrieves the value of a RediSearch configuration parameter. The 'option' parameter specifies the configuration parameter to retrieve. For more information, please refer to the Redis documentation: [FT.CONFIG GET]: (https://redis.io/commands/ft.config-get/) see go-redis v9.7.0 https://github.com/redis/go-redis/blob/v9.7.0/search_commands.go#L831

func (*Compat) FTConfigSet added in v1.0.50 

func (c *Compat) FTConfigSet(ctx context.Context, option string, value interface{}) *StatusCmd

FTConfigSet - Sets the value of a RediSearch configuration parameter. The 'option' parameter specifies the configuration parameter to set, and the 'value' parameter specifies the new value. For more information, please refer to the Redis documentation: [FT.CONFIG SET]: (https://redis.io/commands/ft.config-set/) see go-redis v9.7.0 https://github.com/redis/go-redis/blob/v9.7.0/search_commands.go#L841

func (*Compat) FTCreate added in v1.0.50 

func (c *Compat) FTCreate(ctx context.Context, index string, options *FTCreateOptions, schema ...*FieldSchema) *StatusCmd

FTCreate - Creates a new index with the given options and schema. The 'index' parameter specifies the name of the index to create. The 'options' parameter specifies various options for the index, such as: whether to index hashes or JSONs, prefixes, filters, default language, score, score field, payload field, etc. The 'schema' parameter specifies the schema for the index, which includes the field name, field type, etc. For more information, please refer to the Redis documentation: [FT.CREATE]: (https://redis.io/commands/ft.create/) FTCreate aligns with go-redis v9.7.0. see go-redis v9.7.0 https://github.com/redis/go-redis/blob/v9.7.0/search_commands.go#L854

func (*Compat) FTCursorDel added in v1.0.50 

func (c *Compat) FTCursorDel(ctx context.Context, index string, cursorId int) *StatusCmd

FTCursorDel - Deletes a cursor from an existing index. The 'index' parameter specifies the index from which to delete the cursor, and the 'cursorId' parameter specifies the ID of the cursor to delete. For more information, please refer to the Redis documentation: [FT.CURSOR DEL]: (https://redis.io/commands/ft.cursor-del/) see go-redis v9.7.0 https://github.com/redis/go-redis/blob/v9.7.0/search_commands.go#L1032

func (*Compat) FTCursorRead added in v1.0.50 

func (c *Compat) FTCursorRead(ctx context.Context, index string, cursorId int, count int) *MapStringInterfaceCmd

FTCursorRead - Reads the next results from an existing cursor. The 'index' parameter specifies the index from which to read the cursor, the 'cursorId' parameter specifies the ID of the cursor to read, and the 'count' parameter specifies the number of results to read. For more information, please refer to the Redis documentation: [FT.CURSOR READ]: (https://redis.io/commands/ft.cursor-read/) see go-redis v9.7.0 https://github.com/redis/go-redis/blob/v9.7.0/search_commands.go#L1042

func (*Compat) FTDictAdd added in v1.0.50 

func (c *Compat) FTDictAdd(ctx context.Context, dict string, term ...interface{}) *IntCmd

FTDictAdd - Adds terms to a dictionary. The 'dict' parameter specifies the dictionary to which to add the terms, and the 'term' parameter specifies the terms to add. For more information, please refer to the Redis documentation: [FT.DICTADD]: (https://redis.io/commands/ft.dictadd/) see go-redis v9.7.0 https://github.com/redis/go-redis/blob/v9.7.0/search_commands.go#L1056

func (*Compat) FTDictDel added in v1.0.50 

func (c *Compat) FTDictDel(ctx context.Context, dict string, term ...interface{}) *IntCmd

FTDictDel - Deletes terms from a dictionary. The 'dict' parameter specifies the dictionary from which to delete the terms, and the 'term' parameter specifies the terms to delete. For more information, please refer to the Redis documentation: [FT.DICTDEL]: (https://redis.io/commands/ft.dictdel/) see go-redis v9.7.0 https://github.com/redis/go-redis/blob/v9.7.0/search_commands.go#L1068

func (*Compat) FTDictDump added in v1.0.50 

func (c *Compat) FTDictDump(ctx context.Context, dict string) *StringSliceCmd

FTDictDump - Returns all terms in the specified dictionary. The 'dict' parameter specifies the dictionary from which to return the terms. For more information, please refer to the Redis documentation: [FT.DICTDUMP]: (https://redis.io/commands/ft.dictdump/) see go-redis v9.7.0 https://github.com/redis/go-redis/blob/v9.7.0/search_commands.go#L1080

func (*Compat) FTDropIndex added in v1.0.50 

func (c *Compat) FTDropIndex(ctx context.Context, index string) *StatusCmd

FTDropIndex - Deletes an index. The 'index' parameter specifies the index to delete. For more information, please refer to the Redis documentation: [FT.DROPINDEX]: (https://redis.io/commands/ft.dropindex/) see go-redis v9.7.0 https://github.com/redis/go-redis/blob/v9.7.0/search_commands.go#L1090

func (*Compat) FTDropIndexWithArgs added in v1.0.50 

func (c *Compat) FTDropIndexWithArgs(ctx context.Context, index string, options *FTDropIndexOptions) *StatusCmd

FTDropIndexWithArgs - Deletes an index with options. The 'index' parameter specifies the index to delete, and the 'options' parameter specifies the DeleteDocs option for docs deletion. For more information, please refer to the Redis documentation: [FT.DROPINDEX]: (https://redis.io/commands/ft.dropindex/) see go-redis v9.7.0 https://github.com/redis/go-redis/blob/v9.7.0/search_commands.go#L1101

func (*Compat) FTExplain added in v1.0.50 

func (c *Compat) FTExplain(ctx context.Context, index string, query string) *StringCmd

FTExplain - Returns the execution plan for a complex query. The 'index' parameter specifies the index to query, and the 'query' parameter specifies the query string. For more information, please refer to the Redis documentation: [FT.EXPLAIN]: (https://redis.io/commands/ft.explain/) see go-redis v9.7.0 https://github.com/redis/go-redis/blob/v9.7.0/search_commands.go#L1117

func (*Compat) FTExplainWithArgs added in v1.0.50 

func (c *Compat) FTExplainWithArgs(ctx context.Context, index string, query string, options *FTExplainOptions) *StringCmd

FTExplainWithArgs - Returns the execution plan for a complex query with options. The 'index' parameter specifies the index to query, the 'query' parameter specifies the query string, and the 'options' parameter specifies the Dialect for the query. For more information, please refer to the Redis documentation: [FT.EXPLAIN]: (https://redis.io/commands/ft.explain/) see go-redis v9.7.0 https://github.com/redis/go-redis/blob/v9.7.0/search_commands.go#L1127

func (*Compat) FTInfo added in v1.0.50 

func (c *Compat) FTInfo(ctx context.Context, index string) *FTInfoCmd

FTInfo - Retrieves information about an index. The 'index' parameter specifies the index to retrieve information about. For more information, please refer to the Redis documentation: [FT.INFO]: (https://redis.io/commands/ft.info/) see go-redis v9.7.0 https://github.com/redis/go-redis/blob/v9.7.0/search_commands.go#L1393

func (*Compat) FTSearch added in v1.0.50 

func (c *Compat) FTSearch(ctx context.Context, index string, query string) *FTSearchCmd

FTSearch - Executes a search query on an index. The 'index' parameter specifies the index to search, and the 'query' parameter specifies the search query. For more information, please refer to the Redis documentation: [FT.SEARCH]: (https://redis.io/commands/ft.search/) see go-redis v9.7.0 https://github.com/redis/go-redis/blob/v9.7.0/search_commands.go#L1679

func (*Compat) FTSearchWithArgs added in v1.0.50 

func (c *Compat) FTSearchWithArgs(ctx context.Context, index string, query string, options *FTSearchOptions) *FTSearchCmd

FTSearchWithArgs - Executes a search query on an index with additional options. The 'index' parameter specifies the index to search, the 'query' parameter specifies the search query, and the 'options' parameter specifies additional options for the search. For more information, please refer to the Redis documentation: [FT.SEARCH]: (https://redis.io/commands/ft.search/) see go-redis v9.7.0 https://github.com/redis/go-redis/blob/v9.7.0/search_commands.go#L1802

func (*Compat) FTSpellCheck added in v1.0.50 

func (c *Compat) FTSpellCheck(ctx context.Context, index string, query string) *FTSpellCheckCmd

FTSpellCheck - Checks a query string for spelling errors. For more details about spellcheck query please follow: https://redis.io/docs/interact/search-and-query/advanced-concepts/spellcheck/ For more information, please refer to the Redis documentation: [FT.SPELLCHECK]: (https://redis.io/commands/ft.spellcheck/) see go-redis v9.7.0 https://github.com/redis/go-redis/blob/v9.7.0/search_commands.go#L1404

func (*Compat) FTSpellCheckWithArgs added in v1.0.50 

func (c *Compat) FTSpellCheckWithArgs(ctx context.Context, index string, query string, options *FTSpellCheckOptions) *FTSpellCheckCmd

FTSpellCheckWithArgs - Checks a query string for spelling errors with additional options. For more details about spellcheck query please follow: https://redis.io/docs/interact/search-and-query/advanced-concepts/spellcheck/ For more information, please refer to the Redis documentation: [FT.SPELLCHECK]: (https://redis.io/commands/ft.spellcheck/) see go-redis v9.7.0 https://github.com/redis/go-redis/blob/v9.7.0/search_commands.go#L1416

func (*Compat) FTSynDump added in v1.0.50 

func (c *Compat) FTSynDump(ctx context.Context, index string) *FTSynDumpCmd

FTSynDump - Dumps the contents of a synonym group. The 'index' parameter specifies the index to dump. For more information, please refer to the Redis documentation: [FT.SYNDUMP]: (https://redis.io/commands/ft.syndump/) see go-redis v9.7.0 https://github.com/redis/go-redis/blob/v9.7.0/search_commands.go#L1987

func (*Compat) FTSynUpdate added in v1.0.50 

func (c *Compat) FTSynUpdate(ctx context.Context, index string, synGroupId interface{}, terms []interface{}) *StatusCmd

FTSynUpdate - Creates or updates a synonym group with additional terms. The 'index' parameter specifies the index to update, the 'synGroupId' parameter specifies the synonym group id, and the 'terms' parameter specifies the additional terms. For more information, please refer to the Redis documentation: [FT.SYNUPDATE]: (https://redis.io/commands/ft.synupdate/) see go-redis v9.7.0 https://github.com/redis/go-redis/blob/v9.7.0/search_commands.go#L1997

func (*Compat) FTSynUpdateWithArgs added in v1.0.50 

func (c *Compat) FTSynUpdateWithArgs(ctx context.Context, index string, synGroupId interface{}, options *FTSynUpdateOptions, terms []interface{}) *StatusCmd

FTSynUpdateWithArgs - Creates or updates a synonym group with additional terms and options. The 'index' parameter specifies the index to update, the 'synGroupId' parameter specifies the synonym group id, the 'options' parameter specifies additional options for the update, and the 'terms' parameter specifies the additional terms. For more information, please refer to the Redis documentation: [FT.SYNUPDATE]: (https://redis.io/commands/ft.synupdate/) see go-redis v9.7.0 https://github.com/redis/go-redis/blob/v9.7.0/search_commands.go#L2009

func (*Compat) FTTagVals added in v1.0.50 

func (c *Compat) FTTagVals(ctx context.Context, index string, field string) *StringSliceCmd

FTTagVals - Returns all distinct values indexed in a tag field. The 'index' parameter specifies the index to check, and the 'field' parameter specifies the tag field to retrieve values from. For more information, please refer to the Redis documentation: [FT.TAGVALS]: (https://redis.io/commands/ft.tagvals/) see go-redis v9.7.0 https://github.com/redis/go-redis/blob/v9.7.0/search_commands.go#L2024

func (*Compat) FT_List added in v1.0.50 

func (c *Compat) FT_List(ctx context.Context) *StringSliceCmd

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) HExpire added in v1.0.45 

func (c *Compat) HExpire(ctx context.Context, key string, expiration time.Duration, fields ...string) *IntSliceCmd

func (*Compat) HExpireAt added in v1.0.45 

func (c *Compat) HExpireAt(ctx context.Context, key string, tm time.Time, fields ...string) *IntSliceCmd

func (*Compat) HExpireAtWithArgs added in v1.0.45 

func (c *Compat) HExpireAtWithArgs(ctx context.Context, key string, tm time.Time, expirationArgs HExpireArgs, fields ...string) *IntSliceCmd

func (*Compat) HExpireTime added in v1.0.45 

func (c *Compat) HExpireTime(ctx context.Context, key string, fields ...string) *IntSliceCmd

func (*Compat) HExpireWithArgs added in v1.0.45 

func (c *Compat) HExpireWithArgs(ctx context.Context, key string, expiration time.Duration, expirationArgs HExpireArgs, fields ...string) *IntSliceCmd

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) HPExpire added in v1.0.45 

func (c *Compat) HPExpire(ctx context.Context, key string, expiration time.Duration, fields ...string) *IntSliceCmd

func (*Compat) HPExpireAt added in v1.0.45 

func (c *Compat) HPExpireAt(ctx context.Context, key string, tm time.Time, fields ...string) *IntSliceCmd

func (*Compat) HPExpireAtWithArgs added in v1.0.45 

func (c *Compat) HPExpireAtWithArgs(ctx context.Context, key string, tm time.Time, expirationArgs HExpireArgs, fields ...string) *IntSliceCmd

func (*Compat) HPExpireTime added in v1.0.45 

func (c *Compat) HPExpireTime(ctx context.Context, key string, fields ...string) *IntSliceCmd

func (*Compat) HPExpireWithArgs added in v1.0.45 

func (c *Compat) HPExpireWithArgs(ctx context.Context, key string, expiration time.Duration, expirationArgs HExpireArgs, fields ...string) *IntSliceCmd

func (*Compat) HPTTL added in v1.0.45 

func (c *Compat) HPTTL(ctx context.Context, key string, fields ...string) *IntSliceCmd

func (*Compat) HPersist added in v1.0.45 

func (c *Compat) HPersist(ctx context.Context, key string, fields ...string) *IntSliceCmd

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) HScanNoValues added in v1.0.52 

func (c *Compat) HScanNoValues(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) HTTL added in v1.0.45 

func (c *Compat) HTTL(ctx context.Context, key string, fields ...string) *IntSliceCmd

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

func (c *Compat) JSONArrAppend(ctx context.Context, key, path string, values ...interface{}) *IntSliceCmd

JSONArrAppend adds the provided JSON values to the end of the array at the given path. For more information, see https://redis.io/commands/json.arrappend

func (*Compat) JSONArrIndex 

func (c *Compat) JSONArrIndex(ctx context.Context, key, path string, value ...interface{}) *IntSliceCmd

JSONArrIndex searches for the first occurrence of the provided JSON value in the array at the given path. For more information, see https://redis.io/commands/json.arrindex NOTE: value should have the format value start [stop]

func (*Compat) JSONArrIndexWithArgs 

func (c *Compat) JSONArrIndexWithArgs(ctx context.Context, key, path string, options *JSONArrIndexArgs, value ...interface{}) *IntSliceCmd

JSONArrIndex searches for the first occurrence of the provided JSON value in the array at the given path. For more information, see https://redis.io/commands/json.arrindex

func (*Compat) JSONArrInsert 

func (c *Compat) JSONArrInsert(ctx context.Context, key, path string, index int64, values ...interface{}) *IntSliceCmd

func (*Compat) JSONArrLen 

func (c *Compat) JSONArrLen(ctx context.Context, key, path string) *IntSliceCmd

func (*Compat) JSONArrPop 

func (c *Compat) JSONArrPop(ctx context.Context, key, path string, index int) *StringSliceCmd

func (*Compat) JSONArrTrim 

func (c *Compat) JSONArrTrim(ctx context.Context, key, path string) *IntSliceCmd

func (*Compat) JSONArrTrimWithArgs 

func (c *Compat) JSONArrTrimWithArgs(ctx context.Context, key, path string, options *JSONArrTrimArgs) *IntSliceCmd

func (*Compat) JSONClear 

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

func (*Compat) JSONDebugMemory 

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

func (*Compat) JSONDel 

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

func (*Compat) JSONForget 

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

func (*Compat) JSONGet 

func (c *Compat) JSONGet(ctx context.Context, key string, paths ...string) *JSONCmd

func (*Compat) JSONGetWithArgs 

func (c *Compat) JSONGetWithArgs(ctx context.Context, key string, options *JSONGetArgs, paths ...string) *JSONCmd

func (*Compat) JSONMGet 

func (c *Compat) JSONMGet(ctx context.Context, path string, keys ...string) *JSONSliceCmd

func (*Compat) JSONMSet 

func (c *Compat) JSONMSet(ctx context.Context, params ...interface{}) *StatusCmd

func (*Compat) JSONMSetArgs 

func (c *Compat) JSONMSetArgs(ctx context.Context, docs []JSONSetArgs) *StatusCmd

func (*Compat) JSONMerge 

func (c *Compat) JSONMerge(ctx context.Context, key, path string, value string) *StatusCmd

func (*Compat) JSONNumIncrBy 

func (c *Compat) JSONNumIncrBy(ctx context.Context, key, path string, value float64) *JSONCmd

func (*Compat) JSONObjKeys 

func (c *Compat) JSONObjKeys(ctx context.Context, key, path string) *SliceCmd

func (*Compat) JSONObjLen 

func (c *Compat) JSONObjLen(ctx context.Context, key, path string) *IntPointerSliceCmd

func (*Compat) JSONSet 

func (c *Compat) JSONSet(ctx context.Context, key, path string, value interface{}) *StatusCmd

func (*Compat) JSONSetMode 

func (c *Compat) JSONSetMode(ctx context.Context, key, path string, value interface{}, mode string) *StatusCmd

JSONSetMode sets the JSON value at the given path in the given key and allows the mode to be set (the mode value must be "XX" or "NX"). The value must be something that can be marshaled to JSON (using encoding/JSON) unless the argument is a string or []byte when we assume that it can be passed directly as JSON. For more information, see https://redis.io/commands/json.set

func (*Compat) JSONStrAppend 

func (c *Compat) JSONStrAppend(ctx context.Context, key, path, value string) *IntPointerSliceCmd

func (*Compat) JSONStrLen 

func (c *Compat) JSONStrLen(ctx context.Context, key, path string) *IntPointerSliceCmd

func (*Compat) JSONToggle 

func (c *Compat) JSONToggle(ctx context.Context, key, path string) *IntPointerSliceCmd

func (*Compat) JSONType 

func (c *Compat) JSONType(ctx context.Context, key, path string) *JSONSliceCmd

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) ModuleLoadex added in v1.0.52 

func (c *Compat) ModuleLoadex(ctx context.Context, conf *ModuleLoadexConfig) *StringCmd

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) PSubscribe added in v1.0.42 

func (c *Compat) PSubscribe(ctx context.Context, patterns ...string) PubSub

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) Pipeline added in v1.0.44 

func (c *Compat) Pipeline() Pipeliner

func (*Compat) Pipelined added in v1.0.44 

func (c *Compat) Pipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error)

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) SSubscribe added in v1.0.42 

func (c *Compat) SSubscribe(ctx context.Context, channels ...string) PubSub

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) SlaveOf added in v1.0.52 

func (c *Compat) SlaveOf(ctx context.Context, host, port string) *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) Subscribe added in v1.0.42 

func (c *Compat) Subscribe(ctx context.Context, channels ...string) PubSub

func (*Compat) TDigestAdd 

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

func (*Compat) TDigestByRank 

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

func (*Compat) TDigestByRevRank 

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

func (*Compat) TDigestCDF 

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

func (*Compat) TDigestCreate 

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

func (*Compat) TDigestCreateWithCompression 

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

func (*Compat) TDigestInfo 

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

func (*Compat) TDigestMax 

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

func (*Compat) TDigestMerge 

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

func (*Compat) TDigestMin 

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

func (*Compat) TDigestQuantile 

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

func (*Compat) TDigestRank 

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

func (*Compat) TDigestReset 

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

func (*Compat) TDigestRevRank 

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

func (*Compat) TDigestTrimmedMean 

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

func (*Compat) TFCall 

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

func (*Compat) TFCallASYNC 

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

func (*Compat) TFCallASYNCArgs 

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

func (*Compat) TFCallArgs 

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

func (*Compat) TFunctionDelete 

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

func (*Compat) TFunctionList 

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

func (*Compat) TFunctionListArgs 

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

func (*Compat) TFunctionLoad 

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

func (*Compat) TFunctionLoadArgs 

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

FIXME: should check nil of options

func (*Compat) TSAdd 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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

func (*Compat) TopKCount 

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

func (*Compat) TopKIncrBy 

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

func (*Compat) TopKInfo 

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

func (*Compat) TopKList 

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

func (*Compat) TopKListWithCount 

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

func (*Compat) TopKQuery 

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

func (*Compat) TopKReserve 

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

func (*Compat) TopKReserveWithOptions 

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) TxPipeline added in v1.0.44 

func (c *Compat) TxPipeline() Pipeliner

func (*Compat) TxPipelined added in v1.0.44 

func (c *Compat) TxPipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error)

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) Watch added in v1.0.44 

func (c *Compat) Watch(ctx context.Context, fn func(Tx) error, keys ...string) error

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 CoreCmdable added in v1.0.44 

type CoreCmdable interface {
	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
	BitFieldRO(ctx context.Context, key string, values ...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
	HScanNoValues(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
	HExpire(ctx context.Context, key string, expiration time.Duration, fields ...string) *IntSliceCmd
	HExpireWithArgs(ctx context.Context, key string, expiration time.Duration, expirationArgs HExpireArgs, fields ...string) *IntSliceCmd
	HPExpire(ctx context.Context, key string, expiration time.Duration, fields ...string) *IntSliceCmd
	HPExpireWithArgs(ctx context.Context, key string, expiration time.Duration, expirationArgs HExpireArgs, fields ...string) *IntSliceCmd
	HExpireAt(ctx context.Context, key string, tm time.Time, fields ...string) *IntSliceCmd
	HExpireAtWithArgs(ctx context.Context, key string, tm time.Time, expirationArgs HExpireArgs, fields ...string) *IntSliceCmd
	HPExpireAt(ctx context.Context, key string, tm time.Time, fields ...string) *IntSliceCmd
	HPExpireAtWithArgs(ctx context.Context, key string, tm time.Time, expirationArgs HExpireArgs, fields ...string) *IntSliceCmd
	HPersist(ctx context.Context, key string, fields ...string) *IntSliceCmd
	HExpireTime(ctx context.Context, key string, fields ...string) *IntSliceCmd
	HPExpireTime(ctx context.Context, key string, fields ...string) *IntSliceCmd
	HTTL(ctx context.Context, key string, fields ...string) *IntSliceCmd
	HPTTL(ctx context.Context, key string, fields ...string) *IntSliceCmd

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

	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

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

type CursorStats added in v1.0.50 

type CursorStats struct {
	GlobalIdle    int
	GlobalTotal   int
	IndexCapacity int
	IndexTotal    int
}

type Document added in v1.0.50 

type Document struct {
	ID      string
	Score   *float64
	Payload *string
	SortKey *string
	Fields  map[string]string
}

type DurationCmd 

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

func (*DurationCmd) Err 

func (cmd *DurationCmd) Err() error

func (*DurationCmd) RawResult added in v1.0.50 

func (cmd *DurationCmd) RawResult() (any, error)

func (*DurationCmd) RawVal added in v1.0.50 

func (cmd *DurationCmd) RawVal() any

func (*DurationCmd) Result 

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

func (*DurationCmd) SetErr 

func (cmd *DurationCmd) SetErr(err error)

func (*DurationCmd) SetRawVal added in v1.0.50 

func (cmd *DurationCmd) SetRawVal(rawVal any)

func (*DurationCmd) SetVal 

func (cmd *DurationCmd) SetVal(val T)

func (*DurationCmd) Val 

func (cmd *DurationCmd) Val() T

type FTAggregateApply added in v1.0.50 

type FTAggregateApply struct {
	Field string
	As    string
}

type FTAggregateGroupBy added in v1.0.50 

type FTAggregateGroupBy struct {
	Fields []interface{}
	Reduce []FTAggregateReducer
}

type FTAggregateLoad added in v1.0.50 

type FTAggregateLoad struct {
	Field string
	As    string
}

type FTAggregateOptions added in v1.0.50 

type FTAggregateOptions struct {
	Verbatim          bool
	LoadAll           bool
	Load              []FTAggregateLoad
	Timeout           int
	GroupBy           []FTAggregateGroupBy
	SortBy            []FTAggregateSortBy
	SortByMax         int
	Apply             []FTAggregateApply
	LimitOffset       int
	Limit             int
	Filter            string
	WithCursor        bool
	WithCursorOptions *FTAggregateWithCursor
	Params            map[string]interface{}
	DialectVersion    int
}

type FTAggregateReducer added in v1.0.50 

type FTAggregateReducer struct {
	Reducer SearchAggregator
	Args    []interface{}
	As      string
}

Each AggregateReducer have different args. Please follow https://redis.io/docs/interact/search-and-query/search/aggregations/#supported-groupby-reducers for more information.

type FTAggregateResult added in v1.0.50 

type FTAggregateResult struct {
	Total int
	Rows  []AggregateRow
}

type FTAggregateSortBy added in v1.0.50 

type FTAggregateSortBy struct {
	FieldName string
	Asc       bool
	Desc      bool
}

type FTAggregateWithCursor added in v1.0.50 

type FTAggregateWithCursor struct {
	Count   int
	MaxIdle int
}

type FTAttribute added in v1.0.50 

type FTAttribute struct {
	Identifier      string
	Attribute       string
	Type            string
	Weight          float64
	Sortable        bool
	NoStem          bool
	NoIndex         bool
	UNF             bool
	PhoneticMatcher string
	CaseSensitive   bool
	WithSuffixtrie  bool
}

type FTCreateOptions added in v1.0.50 

type FTCreateOptions struct {
	OnHash          bool
	OnJSON          bool
	Prefix          []any
	Filter          string
	DefaultLanguage string
	LanguageField   string
	Score           float64
	ScoreField      string
	PayloadField    string
	MaxTextFields   int
	NoOffsets       bool
	Temporary       int
	NoHL            bool
	NoFields        bool
	NoFreqs         bool
	StopWords       []any
	SkipInitialScan bool
}

type FTDropIndexOptions added in v1.0.50 

type FTDropIndexOptions struct {
	DeleteDocs bool
}

type FTExplainOptions added in v1.0.50 

type FTExplainOptions struct {
	Dialect string
}

type FTFlatOptions added in v1.0.50 

type FTFlatOptions struct {
	Type            string
	Dim             int
	DistanceMetric  string
	InitialCapacity int
	BlockSize       int
}

type FTHNSWOptions added in v1.0.50 

type FTHNSWOptions struct {
	Type                   string
	Dim                    int
	DistanceMetric         string
	InitialCapacity        int
	MaxEdgesPerNode        int
	MaxAllowedEdgesPerNode int
	EFRunTime              int
	Epsilon                float64
}

type FTInfoCmd added in v1.0.50 

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

func (*FTInfoCmd) Err added in v1.0.50 

func (cmd *FTInfoCmd) Err() error

func (*FTInfoCmd) RawResult added in v1.0.50 

func (cmd *FTInfoCmd) RawResult() (any, error)

func (*FTInfoCmd) RawVal added in v1.0.50 

func (cmd *FTInfoCmd) RawVal() any

func (*FTInfoCmd) Result added in v1.0.50 

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

func (*FTInfoCmd) SetErr added in v1.0.50 

func (cmd *FTInfoCmd) SetErr(err error)

func (*FTInfoCmd) SetRawVal added in v1.0.50 

func (cmd *FTInfoCmd) SetRawVal(rawVal any)

func (*FTInfoCmd) SetVal added in v1.0.50 

func (cmd *FTInfoCmd) SetVal(val T)

func (*FTInfoCmd) Val added in v1.0.50 

func (cmd *FTInfoCmd) Val() T

type FTInfoResult added in v1.0.50 

type FTInfoResult struct {
	IndexErrors              IndexErrors      `redis:"Index Errors"`
	Attributes               []FTAttribute    `redis:"attributes"`
	BytesPerRecordAvg        string           `redis:"bytes_per_record_avg"`
	Cleaning                 int              `redis:"cleaning"`
	CursorStats              CursorStats      `redis:"cursor_stats"`
	DialectStats             map[string]int   `redis:"dialect_stats"`
	DocTableSizeMB           float64          `redis:"doc_table_size_mb"`
	FieldStatistics          []FieldStatistic `redis:"field statistics"`
	GCStats                  GCStats          `redis:"gc_stats"`
	GeoshapesSzMB            float64          `redis:"geoshapes_sz_mb"`
	HashIndexingFailures     int              `redis:"hash_indexing_failures"`
	IndexDefinition          IndexDefinition  `redis:"index_definition"`
	IndexName                string           `redis:"index_name"`
	IndexOptions             []string         `redis:"index_options"`
	Indexing                 int              `redis:"indexing"`
	InvertedSzMB             float64          `redis:"inverted_sz_mb"`
	KeyTableSizeMB           float64          `redis:"key_table_size_mb"`
	MaxDocID                 int              `redis:"max_doc_id"`
	NumDocs                  int              `redis:"num_docs"`
	NumRecords               int              `redis:"num_records"`
	NumTerms                 int              `redis:"num_terms"`
	NumberOfUses             int              `redis:"number_of_uses"`
	OffsetBitsPerRecordAvg   string           `redis:"offset_bits_per_record_avg"`
	OffsetVectorsSzMB        float64          `redis:"offset_vectors_sz_mb"`
	OffsetsPerTermAvg        string           `redis:"offsets_per_term_avg"`
	PercentIndexed           float64          `redis:"percent_indexed"`
	RecordsPerDocAvg         string           `redis:"records_per_doc_avg"`
	SortableValuesSizeMB     float64          `redis:"sortable_values_size_mb"`
	TagOverheadSzMB          float64          `redis:"tag_overhead_sz_mb"`
	TextOverheadSzMB         float64          `redis:"text_overhead_sz_mb"`
	TotalIndexMemorySzMB     float64          `redis:"total_index_memory_sz_mb"`
	TotalIndexingTime        int              `redis:"total_indexing_time"`
	TotalInvertedIndexBlocks int              `redis:"total_inverted_index_blocks"`
	VectorIndexSzMB          float64          `redis:"vector_index_sz_mb"`
}

type FTSearchCmd added in v1.0.50 

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

func (*FTSearchCmd) Err added in v1.0.50 

func (cmd *FTSearchCmd) Err() error

func (*FTSearchCmd) RawResult added in v1.0.50 

func (cmd *FTSearchCmd) RawResult() (any, error)

func (*FTSearchCmd) RawVal added in v1.0.50 

func (cmd *FTSearchCmd) RawVal() any

func (*FTSearchCmd) Result added in v1.0.50 

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

func (*FTSearchCmd) SetErr added in v1.0.50 

func (cmd *FTSearchCmd) SetErr(err error)

func (*FTSearchCmd) SetRawVal added in v1.0.50 

func (cmd *FTSearchCmd) SetRawVal(rawVal any)

func (*FTSearchCmd) SetVal added in v1.0.50 

func (cmd *FTSearchCmd) SetVal(val T)

func (*FTSearchCmd) Val added in v1.0.50 

func (cmd *FTSearchCmd) Val() T

type FTSearchFilter added in v1.0.50 

type FTSearchFilter struct {
	FieldName any
	Min       any
	Max       any
}

type FTSearchGeoFilter added in v1.0.50 

type FTSearchGeoFilter struct {
	FieldName string
	Longitude float64
	Latitude  float64
	Radius    float64
	Unit      string
}

type FTSearchOptions added in v1.0.50 

type FTSearchOptions struct {
	NoContent       bool
	Verbatim        bool
	NoStopWords     bool
	WithScores      bool
	WithPayloads    bool
	WithSortKeys    bool
	Filters         []FTSearchFilter
	GeoFilter       []FTSearchGeoFilter
	InKeys          []interface{}
	InFields        []interface{}
	Return          []FTSearchReturn
	Slop            int
	Timeout         int
	InOrder         bool
	Language        string
	Expander        string
	Scorer          string
	ExplainScore    bool
	Payload         string
	SortBy          []FTSearchSortBy
	SortByWithCount bool
	LimitOffset     int
	Limit           int
	Params          map[string]interface{}
	DialectVersion  int
}

type FTSearchResult added in v1.0.50 

type FTSearchResult struct {
	Total int64
	Docs  []Document
}

type FTSearchReturn added in v1.0.50 

type FTSearchReturn struct {
	FieldName string
	As        string
}

type FTSearchSortBy added in v1.0.50 

type FTSearchSortBy struct {
	FieldName string
	Asc       bool
	Desc      bool
}

type FTSpellCheckCmd added in v1.0.50 

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

func (*FTSpellCheckCmd) Err added in v1.0.50 

func (cmd *FTSpellCheckCmd) Err() error

func (*FTSpellCheckCmd) RawResult added in v1.0.50 

func (cmd *FTSpellCheckCmd) RawResult() (any, error)

func (*FTSpellCheckCmd) RawVal added in v1.0.50 

func (cmd *FTSpellCheckCmd) RawVal() any

func (*FTSpellCheckCmd) Result added in v1.0.50 

func (cmd *FTSpellCheckCmd) Result() ([]SpellCheckResult, error)

func (*FTSpellCheckCmd) SetErr added in v1.0.50 

func (cmd *FTSpellCheckCmd) SetErr(err error)

func (*FTSpellCheckCmd) SetRawVal added in v1.0.50 

func (cmd *FTSpellCheckCmd) SetRawVal(rawVal any)

func (*FTSpellCheckCmd) SetVal added in v1.0.50 

func (cmd *FTSpellCheckCmd) SetVal(val T)

func (*FTSpellCheckCmd) Val added in v1.0.50 

func (cmd *FTSpellCheckCmd) Val() []SpellCheckResult

type FTSpellCheckOptions added in v1.0.50 

type FTSpellCheckOptions struct {
	Distance int
	Terms    *FTSpellCheckTerms
	Dialect  int
}

type FTSpellCheckTerms added in v1.0.50 

type FTSpellCheckTerms struct {
	Inclusion  string // Either "INCLUDE" or "EXCLUDE"
	Dictionary string
	Terms      []interface{}
}

type FTSynDumpCmd added in v1.0.50 

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

func (*FTSynDumpCmd) Err added in v1.0.50 

func (cmd *FTSynDumpCmd) Err() error

func (*FTSynDumpCmd) RawResult added in v1.0.50 

func (cmd *FTSynDumpCmd) RawResult() (any, error)

func (*FTSynDumpCmd) RawVal added in v1.0.50 

func (cmd *FTSynDumpCmd) RawVal() any

func (*FTSynDumpCmd) Result added in v1.0.50 

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

func (*FTSynDumpCmd) SetErr added in v1.0.50 

func (cmd *FTSynDumpCmd) SetErr(err error)

func (*FTSynDumpCmd) SetRawVal added in v1.0.50 

func (cmd *FTSynDumpCmd) SetRawVal(rawVal any)

func (*FTSynDumpCmd) SetVal added in v1.0.50 

func (cmd *FTSynDumpCmd) SetVal(val T)

func (*FTSynDumpCmd) Val added in v1.0.50 

func (cmd *FTSynDumpCmd) Val() T

type FTSynDumpResult added in v1.0.50 

type FTSynDumpResult struct {
	Term     string
	Synonyms []string
}

type FTSynUpdateOptions added in v1.0.50 

type FTSynUpdateOptions struct {
	SkipInitialScan bool
}

type FTVectorArgs added in v1.0.50 

type FTVectorArgs struct {
	FlatOptions *FTFlatOptions
	HNSWOptions *FTHNSWOptions
}

type FieldSchema added in v1.0.50 

type FieldSchema struct {
	FieldName         string
	As                string
	FieldType         SearchFieldType
	Sortable          bool
	UNF               bool
	NoStem            bool
	NoIndex           bool
	PhoneticMatcher   string
	Weight            float64
	Separator         string
	CaseSensitive     bool
	WithSuffixtrie    bool
	VectorArgs        *FTVectorArgs
	GeoShapeFieldType string
	IndexEmpty        bool
	IndexMissing      bool
}

type FieldStatistic added in v1.0.50 

type FieldStatistic struct {
	Identifier  string
	Attribute   string
	IndexErrors IndexErrors
}

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) RawResult added in v1.0.50 

func (cmd *FloatCmd) RawResult() (any, error)

func (*FloatCmd) RawVal added in v1.0.50 

func (cmd *FloatCmd) RawVal() any

func (*FloatCmd) Result 

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

func (*FloatCmd) SetErr 

func (cmd *FloatCmd) SetErr(err error)

func (*FloatCmd) SetRawVal added in v1.0.50 

func (cmd *FloatCmd) SetRawVal(rawVal any)

func (*FloatCmd) SetVal 

func (cmd *FloatCmd) SetVal(val T)

func (*FloatCmd) Val 

func (cmd *FloatCmd) Val() T

type FloatSliceCmd 

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

func (*FloatSliceCmd) Err 

func (cmd *FloatSliceCmd) Err() error

func (*FloatSliceCmd) RawResult added in v1.0.50 

func (cmd *FloatSliceCmd) RawResult() (any, error)

func (*FloatSliceCmd) RawVal added in v1.0.50 

func (cmd *FloatSliceCmd) RawVal() any

func (*FloatSliceCmd) Result 

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

func (*FloatSliceCmd) SetErr 

func (cmd *FloatSliceCmd) SetErr(err error)

func (*FloatSliceCmd) SetRawVal added in v1.0.50 

func (cmd *FloatSliceCmd) SetRawVal(rawVal any)

func (*FloatSliceCmd) SetVal 

func (cmd *FloatSliceCmd) SetVal(val T)

func (*FloatSliceCmd) Val 

func (cmd *FloatSliceCmd) Val() T

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) RawResult added in v1.0.50 

func (cmd *FunctionListCmd) RawResult() (any, error)

func (*FunctionListCmd) RawVal added in v1.0.50 

func (cmd *FunctionListCmd) RawVal() any

func (*FunctionListCmd) Result 

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

func (*FunctionListCmd) SetErr 

func (cmd *FunctionListCmd) SetErr(err error)

func (*FunctionListCmd) SetRawVal added in v1.0.50 

func (cmd *FunctionListCmd) SetRawVal(rawVal any)

func (*FunctionListCmd) SetVal 

func (cmd *FunctionListCmd) SetVal(val T)

func (*FunctionListCmd) Val 

func (cmd *FunctionListCmd) Val() T

type FunctionListQuery 

type FunctionListQuery struct {
	LibraryNamePattern string
	WithCode           bool
}

type GCStats added in v1.0.50 

type GCStats struct {
	BytesCollected       int    `redis:"bytes_collected"`
	TotalMsRun           int    `redis:"total_ms_run"`
	TotalCycles          int    `redis:"total_cycles"`
	AverageCycleTimeMs   string `redis:"average_cycle_time_ms"`
	LastRunTimeMs        int    `redis:"last_run_time_ms"`
	GCNumericTreesMissed int    `redis:"gc_numeric_trees_missed"`
	GCBlocksDenied       int    `redis:"gc_blocks_denied"`
}

type GearsCmdable 

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) RawResult added in v1.0.50 

func (cmd *GeoLocationCmd) RawResult() (any, error)

func (*GeoLocationCmd) RawVal added in v1.0.50 

func (cmd *GeoLocationCmd) RawVal() any

func (*GeoLocationCmd) Result 

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

func (*GeoLocationCmd) SetErr 

func (cmd *GeoLocationCmd) SetErr(err error)

func (*GeoLocationCmd) SetRawVal added in v1.0.50 

func (cmd *GeoLocationCmd) SetRawVal(rawVal any)

func (*GeoLocationCmd) SetVal 

func (cmd *GeoLocationCmd) SetVal(val T)

func (*GeoLocationCmd) Val 

func (cmd *GeoLocationCmd) Val() T

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) RawResult added in v1.0.50 

func (cmd *GeoPosCmd) RawResult() (any, error)

func (*GeoPosCmd) RawVal added in v1.0.50 

func (cmd *GeoPosCmd) RawVal() any

func (*GeoPosCmd) Result 

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

func (*GeoPosCmd) SetErr 

func (cmd *GeoPosCmd) SetErr(err error)

func (*GeoPosCmd) SetRawVal added in v1.0.50 

func (cmd *GeoPosCmd) SetRawVal(rawVal any)

func (*GeoPosCmd) SetVal 

func (cmd *GeoPosCmd) SetVal(val T)

func (*GeoPosCmd) Val 

func (cmd *GeoPosCmd) Val() T

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 HExpireArgs added in v1.0.45 

type HExpireArgs struct {
	NX bool
	XX bool
	GT bool
	LT bool
}

type IndexDefinition added in v1.0.50 

type IndexDefinition struct {
	KeyType      string
	Prefixes     []string
	DefaultScore float64
}

type IndexErrors added in v1.0.50 

type IndexErrors struct {
	IndexingFailures     int `redis:"indexing failures"`
	LastIndexingError    string
	LastIndexingErrorKey string
}

type IntCmd 

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

func (*IntCmd) Err 

func (cmd *IntCmd) Err() error

func (*IntCmd) RawResult added in v1.0.50 

func (cmd *IntCmd) RawResult() (any, error)

func (*IntCmd) RawVal added in v1.0.50 

func (cmd *IntCmd) RawVal() any

func (*IntCmd) Result 

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

func (*IntCmd) SetErr 

func (cmd *IntCmd) SetErr(err error)

func (*IntCmd) SetRawVal added in v1.0.50 

func (cmd *IntCmd) SetRawVal(rawVal any)

func (*IntCmd) SetVal 

func (cmd *IntCmd) SetVal(val T)

func (*IntCmd) Uint64 

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

func (*IntCmd) Val 

func (cmd *IntCmd) Val() T

type IntPointerSliceCmd 

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

func (*IntPointerSliceCmd) Err 

func (cmd *IntPointerSliceCmd) Err() error

func (*IntPointerSliceCmd) RawResult added in v1.0.50 

func (cmd *IntPointerSliceCmd) RawResult() (any, error)

func (*IntPointerSliceCmd) RawVal added in v1.0.50 

func (cmd *IntPointerSliceCmd) RawVal() any

func (*IntPointerSliceCmd) Result 

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

func (*IntPointerSliceCmd) SetErr 

func (cmd *IntPointerSliceCmd) SetErr(err error)

func (*IntPointerSliceCmd) SetRawVal added in v1.0.50 

func (cmd *IntPointerSliceCmd) SetRawVal(rawVal any)

func (*IntPointerSliceCmd) SetVal 

func (cmd *IntPointerSliceCmd) SetVal(val T)

func (*IntPointerSliceCmd) Val 

func (cmd *IntPointerSliceCmd) Val() T

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 JSONArrIndexArgs 

type JSONArrIndexArgs struct {
	Start int
	Stop  *int
}

type JSONArrTrimArgs 

type JSONArrTrimArgs struct {
	Start int
	Stop  *int
}

type JSONCmd 

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

func (*JSONCmd) Err 

func (cmd *JSONCmd) Err() error

func (*JSONCmd) Expanded 

func (cmd *JSONCmd) Expanded() (any, error)

https://github.com/redis/go-redis/blob/v9.3.0/json.go#L105

func (*JSONCmd) RawResult added in v1.0.50 

func (cmd *JSONCmd) RawResult() (any, error)

func (*JSONCmd) RawVal added in v1.0.50 

func (cmd *JSONCmd) RawVal() any

func (*JSONCmd) Result 

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

func (*JSONCmd) SetErr 

func (cmd *JSONCmd) SetErr(err error)

func (*JSONCmd) SetRawVal added in v1.0.50 

func (cmd *JSONCmd) SetRawVal(rawVal any)

func (*JSONCmd) SetVal 

func (cmd *JSONCmd) SetVal(val T)

func (*JSONCmd) Val 

func (cmd *JSONCmd) Val() string

https://github.com/redis/go-redis/blob/v9.3.0/json.go#L86

type JSONCmdable 

type JSONCmdable interface {
	JSONArrAppend(ctx context.Context, key, path string, values ...interface{}) *IntSliceCmd
	JSONArrIndex(ctx context.Context, key, path string, value ...interface{}) *IntSliceCmd
	JSONArrIndexWithArgs(ctx context.Context, key, path string, options *JSONArrIndexArgs, value ...interface{}) *IntSliceCmd
	JSONArrInsert(ctx context.Context, key, path string, index int64, values ...interface{}) *IntSliceCmd
	JSONArrLen(ctx context.Context, key, path string) *IntSliceCmd
	JSONArrPop(ctx context.Context, key, path string, index int) *StringSliceCmd
	JSONArrTrim(ctx context.Context, key, path string) *IntSliceCmd
	JSONArrTrimWithArgs(ctx context.Context, key, path string, options *JSONArrTrimArgs) *IntSliceCmd
	JSONClear(ctx context.Context, key, path string) *IntCmd
	JSONDebugMemory(ctx context.Context, key, path string) *IntCmd
	JSONDel(ctx context.Context, key, path string) *IntCmd
	JSONForget(ctx context.Context, key, path string) *IntCmd
	JSONGet(ctx context.Context, key string, paths ...string) *JSONCmd
	JSONGetWithArgs(ctx context.Context, key string, options *JSONGetArgs, paths ...string) *JSONCmd
	JSONMerge(ctx context.Context, key, path string, value string) *StatusCmd
	JSONMSetArgs(ctx context.Context, docs []JSONSetArgs) *StatusCmd
	JSONMSet(ctx context.Context, params ...interface{}) *StatusCmd
	JSONMGet(ctx context.Context, path string, keys ...string) *JSONSliceCmd
	JSONNumIncrBy(ctx context.Context, key, path string, value float64) *JSONCmd
	JSONObjKeys(ctx context.Context, key, path string) *SliceCmd
	JSONObjLen(ctx context.Context, key, path string) *IntPointerSliceCmd
	JSONSet(ctx context.Context, key, path string, value interface{}) *StatusCmd
	JSONSetMode(ctx context.Context, key, path string, value interface{}, mode string) *StatusCmd
	JSONStrAppend(ctx context.Context, key, path, value string) *IntPointerSliceCmd
	JSONStrLen(ctx context.Context, key, path string) *IntPointerSliceCmd
	JSONToggle(ctx context.Context, key, path string) *IntPointerSliceCmd
	JSONType(ctx context.Context, key, path string) *JSONSliceCmd
}

type JSONGetArgs 

type JSONGetArgs struct {
	Indent  string
	Newline string
	Space   string
}

type JSONSetArgs 

type JSONSetArgs struct {
	Key   string
	Path  string
	Value interface{}
}

type JSONSliceCmd 

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

func (*JSONSliceCmd) Err 

func (cmd *JSONSliceCmd) Err() error

func (*JSONSliceCmd) RawResult added in v1.0.50 

func (cmd *JSONSliceCmd) RawResult() (any, error)

func (*JSONSliceCmd) RawVal added in v1.0.50 

func (cmd *JSONSliceCmd) RawVal() any

func (*JSONSliceCmd) Result 

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

func (*JSONSliceCmd) SetErr 

func (cmd *JSONSliceCmd) SetErr(err error)

func (*JSONSliceCmd) SetRawVal added in v1.0.50 

func (cmd *JSONSliceCmd) SetRawVal(rawVal any)

func (*JSONSliceCmd) SetVal 

func (cmd *JSONSliceCmd) SetVal(val T)

func (*JSONSliceCmd) Val 

func (cmd *JSONSliceCmd) Val() T

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) RawResult added in v1.0.50 

func (cmd *KeyFlagsCmd) RawResult() (any, error)

func (*KeyFlagsCmd) RawVal added in v1.0.50 

func (cmd *KeyFlagsCmd) RawVal() any

func (*KeyFlagsCmd) Result 

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

func (*KeyFlagsCmd) SetErr 

func (cmd *KeyFlagsCmd) SetErr(err error)

func (*KeyFlagsCmd) SetRawVal added in v1.0.50 

func (cmd *KeyFlagsCmd) SetRawVal(rawVal any)

func (*KeyFlagsCmd) SetVal 

func (cmd *KeyFlagsCmd) SetVal(val T)

func (*KeyFlagsCmd) Val 

func (cmd *KeyFlagsCmd) Val() T

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) RawResult added in v1.0.50 

func (cmd *KeyValueSliceCmd) RawResult() (any, error)

func (*KeyValueSliceCmd) RawVal added in v1.0.50 

func (cmd *KeyValueSliceCmd) RawVal() any

func (*KeyValueSliceCmd) Result 

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

func (*KeyValueSliceCmd) SetErr 

func (cmd *KeyValueSliceCmd) SetErr(err error)

func (*KeyValueSliceCmd) SetRawVal added in v1.0.50 

func (cmd *KeyValueSliceCmd) SetRawVal(rawVal any)

func (*KeyValueSliceCmd) SetVal 

func (cmd *KeyValueSliceCmd) SetVal(val T)

func (*KeyValueSliceCmd) Val 

func (cmd *KeyValueSliceCmd) Val() T

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 MapMapStringInterfaceCmd added in v1.0.50 

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

func (*MapMapStringInterfaceCmd) Err added in v1.0.50 

func (cmd *MapMapStringInterfaceCmd) Err() error

func (*MapMapStringInterfaceCmd) RawResult added in v1.0.50 

func (cmd *MapMapStringInterfaceCmd) RawResult() (any, error)

func (*MapMapStringInterfaceCmd) RawVal added in v1.0.50 

func (cmd *MapMapStringInterfaceCmd) RawVal() any

func (*MapMapStringInterfaceCmd) Result added in v1.0.50 

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

func (*MapMapStringInterfaceCmd) SetErr added in v1.0.50 

func (cmd *MapMapStringInterfaceCmd) SetErr(err error)

func (*MapMapStringInterfaceCmd) SetRawVal added in v1.0.50 

func (cmd *MapMapStringInterfaceCmd) SetRawVal(rawVal any)

func (*MapMapStringInterfaceCmd) SetVal added in v1.0.50 

func (cmd *MapMapStringInterfaceCmd) SetVal(val T)

func (*MapMapStringInterfaceCmd) Val added in v1.0.50 

func (cmd *MapMapStringInterfaceCmd) Val() T

type MapStringIntCmd 

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

func (*MapStringIntCmd) Err 

func (cmd *MapStringIntCmd) Err() error

func (*MapStringIntCmd) RawResult added in v1.0.50 

func (cmd *MapStringIntCmd) RawResult() (any, error)

func (*MapStringIntCmd) RawVal added in v1.0.50 

func (cmd *MapStringIntCmd) RawVal() any

func (*MapStringIntCmd) Result 

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

func (*MapStringIntCmd) SetErr 

func (cmd *MapStringIntCmd) SetErr(err error)

func (*MapStringIntCmd) SetRawVal added in v1.0.50 

func (cmd *MapStringIntCmd) SetRawVal(rawVal any)

func (*MapStringIntCmd) SetVal 

func (cmd *MapStringIntCmd) SetVal(val T)

func (*MapStringIntCmd) Val 

func (cmd *MapStringIntCmd) Val() T

type MapStringInterfaceCmd 

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

func (*MapStringInterfaceCmd) Err 

func (cmd *MapStringInterfaceCmd) Err() error

func (*MapStringInterfaceCmd) RawResult added in v1.0.50 

func (cmd *MapStringInterfaceCmd) RawResult() (any, error)

func (*MapStringInterfaceCmd) RawVal added in v1.0.50 

func (cmd *MapStringInterfaceCmd) RawVal() any

func (*MapStringInterfaceCmd) Result 

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

func (*MapStringInterfaceCmd) SetErr 

func (cmd *MapStringInterfaceCmd) SetErr(err error)

func (*MapStringInterfaceCmd) SetRawVal added in v1.0.50 

func (cmd *MapStringInterfaceCmd) SetRawVal(rawVal any)

func (*MapStringInterfaceCmd) SetVal 

func (cmd *MapStringInterfaceCmd) SetVal(val T)

func (*MapStringInterfaceCmd) Val 

func (cmd *MapStringInterfaceCmd) Val() T

type MapStringInterfaceSliceCmd 

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

func (*MapStringInterfaceSliceCmd) Err 

func (cmd *MapStringInterfaceSliceCmd) Err() error

func (*MapStringInterfaceSliceCmd) RawResult added in v1.0.50 

func (cmd *MapStringInterfaceSliceCmd) RawResult() (any, error)

func (*MapStringInterfaceSliceCmd) RawVal added in v1.0.50 

func (cmd *MapStringInterfaceSliceCmd) RawVal() any

func (*MapStringInterfaceSliceCmd) Result 

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

func (*MapStringInterfaceSliceCmd) SetErr added in v1.0.32 

func (cmd *MapStringInterfaceSliceCmd) SetErr(err error)

func (*MapStringInterfaceSliceCmd) SetRawVal added in v1.0.50 

func (cmd *MapStringInterfaceSliceCmd) SetRawVal(rawVal any)

func (*MapStringInterfaceSliceCmd) SetVal 

func (cmd *MapStringInterfaceSliceCmd) SetVal(val T)

func (*MapStringInterfaceSliceCmd) Val 

func (cmd *MapStringInterfaceSliceCmd) Val() T

type MapStringSliceInterfaceCmd 

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

func (*MapStringSliceInterfaceCmd) Err 

func (cmd *MapStringSliceInterfaceCmd) Err() error

func (*MapStringSliceInterfaceCmd) RawResult added in v1.0.50 

func (cmd *MapStringSliceInterfaceCmd) RawResult() (any, error)

func (*MapStringSliceInterfaceCmd) RawVal added in v1.0.50 

func (cmd *MapStringSliceInterfaceCmd) RawVal() any

func (*MapStringSliceInterfaceCmd) Result 

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

func (*MapStringSliceInterfaceCmd) SetErr 

func (cmd *MapStringSliceInterfaceCmd) SetErr(err error)

func (*MapStringSliceInterfaceCmd) SetRawVal added in v1.0.50 

func (cmd *MapStringSliceInterfaceCmd) SetRawVal(rawVal any)

func (*MapStringSliceInterfaceCmd) SetVal 

func (cmd *MapStringSliceInterfaceCmd) SetVal(val T)

func (*MapStringSliceInterfaceCmd) Val 

func (cmd *MapStringSliceInterfaceCmd) Val() T

type Message added in v1.0.42 

type Message struct {
	Channel      string
	Pattern      string
	Payload      string
	PayloadSlice []string
}

Message received as result of a PUBLISH command issued by another client.

func (*Message) String added in v1.0.42 

func (m *Message) String() string

type ModuleLoadexConfig added in v1.0.52 

type ModuleLoadexConfig struct {
	Path string
	Conf map[string]interface{}
	Args []interface{}
}

ModuleLoadexConfig struct is used to specify the arguments for the MODULE LOADEX command of redis. `MODULE LOADEX path [CONFIG name value [CONFIG name value ...]] [ARGS args [args ...]]`

type Node 

type Node struct {
	ID                string
	Endpoint          string
	IP                string
	Hostname          string
	Role              string
	Health            string
	Port              int64
	TLSPort           int64
	ReplicationOffset int64
}

type Pipeline added in v1.0.44 

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

Pipeline implements pipelining as described in http://redis.io/topics/pipelining. Please note: it is not safe for concurrent use by multiple goroutines.

func (*Pipeline) ACLDryRun added in v1.0.44 

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

func (*Pipeline) Append added in v1.0.44 

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

func (*Pipeline) BFAdd added in v1.0.44 

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

func (*Pipeline) BFCard added in v1.0.44 

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

func (*Pipeline) BFExists added in v1.0.44 

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

func (*Pipeline) BFInfo added in v1.0.44 

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

func (*Pipeline) BFInfoArg added in v1.0.44 

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

func (*Pipeline) BFInfoCapacity added in v1.0.44 

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

func (*Pipeline) BFInfoExpansion added in v1.0.44 

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

func (*Pipeline) BFInfoFilters added in v1.0.44 

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

func (*Pipeline) BFInfoItems added in v1.0.44 

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

func (*Pipeline) BFInfoSize added in v1.0.44 

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

func (*Pipeline) BFInsert added in v1.0.44 

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

func (*Pipeline) BFLoadChunk added in v1.0.44 

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

func (*Pipeline) BFMAdd added in v1.0.44 

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

func (*Pipeline) BFMExists added in v1.0.44 

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

func (*Pipeline) BFReserve added in v1.0.44 

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

func (*Pipeline) BFReserveExpansion added in v1.0.44 

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

func (*Pipeline) BFReserveNonScaling added in v1.0.44 

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

func (*Pipeline) BFReserveWithArgs added in v1.0.44 

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

func (*Pipeline) BFScanDump added in v1.0.44 

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

func (*Pipeline) BLMPop added in v1.0.44 

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

func (*Pipeline) BLMove added in v1.0.44 

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

func (*Pipeline) BLPop added in v1.0.44 

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

func (*Pipeline) BRPop added in v1.0.44 

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

func (*Pipeline) BRPopLPush added in v1.0.44 

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

func (*Pipeline) BZMPop added in v1.0.44 

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

func (*Pipeline) BZPopMax added in v1.0.44 

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

func (*Pipeline) BZPopMin added in v1.0.44 

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

func (*Pipeline) BgRewriteAOF added in v1.0.44 

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

func (*Pipeline) BgSave added in v1.0.44 

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

func (*Pipeline) BitCount added in v1.0.44 

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

func (*Pipeline) BitField added in v1.0.44 

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

func (*Pipeline) BitFieldRO added in v1.0.52 

func (c *Pipeline) BitFieldRO(ctx context.Context, key string, args ...any) *IntSliceCmd

func (*Pipeline) BitOpAnd added in v1.0.44 

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

func (*Pipeline) BitOpNot added in v1.0.44 

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

func (*Pipeline) BitOpOr added in v1.0.44 

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

func (*Pipeline) BitOpXor added in v1.0.44 

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

func (*Pipeline) BitPos added in v1.0.44 

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

func (*Pipeline) BitPosSpan added in v1.0.44 

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

func (*Pipeline) CFAdd added in v1.0.44 

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

func (*Pipeline) CFAddNX added in v1.0.44 

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

func (*Pipeline) CFCount added in v1.0.44 

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

func (*Pipeline) CFDel added in v1.0.44 

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

func (*Pipeline) CFExists added in v1.0.44 

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

func (*Pipeline) CFInfo added in v1.0.44 

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

func (*Pipeline) CFInsert added in v1.0.44 

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

func (*Pipeline) CFInsertNX added in v1.0.44 

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

func (*Pipeline) CFLoadChunk added in v1.0.44 

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

func (*Pipeline) CFMExists added in v1.0.44 

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

func (*Pipeline) CFReserve added in v1.0.44 

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

func (*Pipeline) CFReserveBucketSize added in v1.0.44 

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

func (*Pipeline) CFReserveExpansion added in v1.0.44 

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

func (*Pipeline) CFReserveMaxIterations added in v1.0.44 

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

func (*Pipeline) CFReserveWithArgs added in v1.0.44 

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

func (*Pipeline) CFScanDump added in v1.0.44 

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

func (*Pipeline) CMSIncrBy added in v1.0.44 

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

func (*Pipeline) CMSInfo added in v1.0.44 

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

func (*Pipeline) CMSInitByDim added in v1.0.44 

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

func (*Pipeline) CMSInitByProb added in v1.0.44 

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

func (*Pipeline) CMSMerge added in v1.0.44 

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

func (*Pipeline) CMSMergeWithWeight added in v1.0.44 

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

func (*Pipeline) CMSQuery added in v1.0.44 

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

func (*Pipeline) ClientGetName added in v1.0.44 

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

func (*Pipeline) ClientID added in v1.0.44 

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

func (*Pipeline) ClientInfo added in v1.0.52 

func (c *Pipeline) ClientInfo(ctx context.Context) *ClientInfoCmd

func (*Pipeline) ClientKill added in v1.0.44 

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

func (*Pipeline) ClientKillByFilter added in v1.0.44 

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

func (*Pipeline) ClientList added in v1.0.44 

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

func (*Pipeline) ClientPause added in v1.0.44 

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

func (*Pipeline) ClientUnblock added in v1.0.44 

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

func (*Pipeline) ClientUnblockWithError added in v1.0.44 

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

func (*Pipeline) ClientUnpause added in v1.0.44 

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

func (*Pipeline) ClusterAddSlots added in v1.0.44 

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

func (*Pipeline) ClusterAddSlotsRange added in v1.0.44 

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

func (*Pipeline) ClusterCountFailureReports added in v1.0.44 

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

func (*Pipeline) ClusterCountKeysInSlot added in v1.0.44 

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

func (*Pipeline) ClusterDelSlots added in v1.0.44 

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

func (*Pipeline) ClusterDelSlotsRange added in v1.0.44 

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

func (*Pipeline) ClusterFailover added in v1.0.44 

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

func (*Pipeline) ClusterForget added in v1.0.44 

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

func (*Pipeline) ClusterGetKeysInSlot added in v1.0.44 

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

func (*Pipeline) ClusterInfo added in v1.0.44 

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

func (*Pipeline) ClusterKeySlot added in v1.0.44 

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

func (*Pipeline) ClusterMeet added in v1.0.44 

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

func (*Pipeline) ClusterMyShardID added in v1.0.52 

func (c *Pipeline) ClusterMyShardID(ctx context.Context) *StringCmd

func (*Pipeline) ClusterNodes added in v1.0.44 

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

func (*Pipeline) ClusterReplicate added in v1.0.44 

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

func (*Pipeline) ClusterResetHard added in v1.0.44 

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

func (*Pipeline) ClusterResetSoft added in v1.0.44 

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

func (*Pipeline) ClusterSaveConfig added in v1.0.44 

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

func (*Pipeline) ClusterShards added in v1.0.44 

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

func (*Pipeline) ClusterSlaves added in v1.0.44 

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

func (*Pipeline) ClusterSlots added in v1.0.44 

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

func (*Pipeline) Command added in v1.0.44 

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

func (*Pipeline) CommandGetKeys added in v1.0.44 

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

func (*Pipeline) CommandGetKeysAndFlags added in v1.0.44 

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

func (*Pipeline) CommandList added in v1.0.44 

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

func (*Pipeline) ConfigGet added in v1.0.44 

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

func (*Pipeline) ConfigResetStat added in v1.0.44 

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

func (*Pipeline) ConfigRewrite added in v1.0.44 

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

func (*Pipeline) ConfigSet added in v1.0.44 

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

func (*Pipeline) Copy added in v1.0.44 

func (c *Pipeline) Copy(ctx context.Context, sourceKey string, destKey string, db int64, replace bool) *IntCmd

func (*Pipeline) DBSize added in v1.0.44 

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

func (*Pipeline) DebugObject added in v1.0.44 

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

func (*Pipeline) Decr added in v1.0.44 

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

func (*Pipeline) DecrBy added in v1.0.44 

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

func (*Pipeline) Del added in v1.0.44 

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

func (*Pipeline) Discard added in v1.0.44 

func (c *Pipeline) Discard()

Discard resets the pipeline and discards queued commands.

func (*Pipeline) Do added in v1.0.44 

func (c *Pipeline) Do(_ context.Context, args ...interface{}) *Cmd

Do queues the custom command for later execution.

func (*Pipeline) Dump added in v1.0.44 

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

func (*Pipeline) Echo added in v1.0.44 

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

func (*Pipeline) Eval added in v1.0.44 

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

func (*Pipeline) EvalRO added in v1.0.44 

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

func (*Pipeline) EvalSha added in v1.0.44 

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

func (*Pipeline) EvalShaRO added in v1.0.44 

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

func (*Pipeline) Exec added in v1.0.44 

func (c *Pipeline) Exec(ctx context.Context) ([]Cmder, error)

Exec executes all previously queued commands using one client-server roundtrip.

Exec always returns list of commands and error of the first failed command if any.

func (*Pipeline) Exists added in v1.0.44 

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

func (*Pipeline) Expire added in v1.0.44 

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

func (*Pipeline) ExpireAt added in v1.0.44 

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

func (*Pipeline) ExpireGT added in v1.0.44 

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

func (*Pipeline) ExpireLT added in v1.0.44 

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

func (*Pipeline) ExpireNX added in v1.0.44 

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

func (*Pipeline) ExpireTime added in v1.0.44 

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

func (*Pipeline) ExpireXX added in v1.0.44 

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

func (*Pipeline) FCall added in v1.0.44 

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

func (*Pipeline) FCallRO added in v1.0.44 

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

func (*Pipeline) FTAggregate added in v1.0.50 

func (c *Pipeline) FTAggregate(ctx context.Context, index string, query string) *MapStringInterfaceCmd

func (*Pipeline) FTAggregateWithArgs added in v1.0.50 

func (c *Pipeline) FTAggregateWithArgs(ctx context.Context, index string, query string, options *FTAggregateOptions) *AggregateCmd

func (*Pipeline) FTAliasAdd added in v1.0.50 

func (c *Pipeline) FTAliasAdd(ctx context.Context, index string, alias string) *StatusCmd

func (*Pipeline) FTAliasDel added in v1.0.50 

func (c *Pipeline) FTAliasDel(ctx context.Context, alias string) *StatusCmd

func (*Pipeline) FTAliasUpdate added in v1.0.50 

func (c *Pipeline) FTAliasUpdate(ctx context.Context, index string, alias string) *StatusCmd

func (*Pipeline) FTAlter added in v1.0.50 

func (c *Pipeline) FTAlter(ctx context.Context, index string, skipInitalScan bool, definition []interface{}) *StatusCmd

func (*Pipeline) FTConfigGet added in v1.0.50 

func (c *Pipeline) FTConfigGet(ctx context.Context, option string) *MapMapStringInterfaceCmd

func (*Pipeline) FTConfigSet added in v1.0.50 

func (c *Pipeline) FTConfigSet(ctx context.Context, option string, value interface{}) *StatusCmd

func (*Pipeline) FTCreate added in v1.0.50 

func (c *Pipeline) FTCreate(ctx context.Context, index string, options *FTCreateOptions, schema ...*FieldSchema) *StatusCmd

func (*Pipeline) FTCursorDel added in v1.0.50 

func (c *Pipeline) FTCursorDel(ctx context.Context, index string, cursorId int) *StatusCmd

func (*Pipeline) FTCursorRead added in v1.0.50 

func (c *Pipeline) FTCursorRead(ctx context.Context, index string, cursorId int, count int) *MapStringInterfaceCmd

func (*Pipeline) FTDictAdd added in v1.0.50 

func (c *Pipeline) FTDictAdd(ctx context.Context, dict string, term ...interface{}) *IntCmd

func (*Pipeline) FTDictDel added in v1.0.50 

func (c *Pipeline) FTDictDel(ctx context.Context, dict string, term ...interface{}) *IntCmd

func (*Pipeline) FTDictDump added in v1.0.50 

func (c *Pipeline) FTDictDump(ctx context.Context, dict string) *StringSliceCmd

func (*Pipeline) FTDropIndex added in v1.0.50 

func (c *Pipeline) FTDropIndex(ctx context.Context, index string) *StatusCmd

func (*Pipeline) FTDropIndexWithArgs added in v1.0.50 

func (c *Pipeline) FTDropIndexWithArgs(ctx context.Context, index string, options *FTDropIndexOptions) *StatusCmd

func (*Pipeline) FTExplain added in v1.0.50 

func (c *Pipeline) FTExplain(ctx context.Context, index string, query string) *StringCmd

func (*Pipeline) FTExplainWithArgs added in v1.0.50 

func (c *Pipeline) FTExplainWithArgs(ctx context.Context, index string, query string, options *FTExplainOptions) *StringCmd

func (*Pipeline) FTInfo added in v1.0.50 

func (c *Pipeline) FTInfo(ctx context.Context, index string) *FTInfoCmd

func (*Pipeline) FTSearch added in v1.0.50 

func (c *Pipeline) FTSearch(ctx context.Context, index string, query string) *FTSearchCmd

func (*Pipeline) FTSearchWithArgs added in v1.0.50 

func (c *Pipeline) FTSearchWithArgs(ctx context.Context, index string, query string, options *FTSearchOptions) *FTSearchCmd

func (*Pipeline) FTSpellCheck added in v1.0.50 

func (c *Pipeline) FTSpellCheck(ctx context.Context, index string, query string) *FTSpellCheckCmd

func (*Pipeline) FTSpellCheckWithArgs added in v1.0.50 

func (c *Pipeline) FTSpellCheckWithArgs(ctx context.Context, index string, query string, options *FTSpellCheckOptions) *FTSpellCheckCmd

func (*Pipeline) FTSynDump added in v1.0.50 

func (c *Pipeline) FTSynDump(ctx context.Context, index string) *FTSynDumpCmd

func (*Pipeline) FTSynUpdate added in v1.0.50 

func (c *Pipeline) FTSynUpdate(ctx context.Context, index string, synGroupId interface{}, terms []interface{}) *StatusCmd

func (*Pipeline) FTSynUpdateWithArgs added in v1.0.50 

func (c *Pipeline) FTSynUpdateWithArgs(ctx context.Context, index string, synGroupId interface{}, options *FTSynUpdateOptions, terms []interface{}) *StatusCmd

func (*Pipeline) FTTagVals added in v1.0.50 

func (c *Pipeline) FTTagVals(ctx context.Context, index string, field string) *StringSliceCmd

func (*Pipeline) FT_List added in v1.0.50 

func (c *Pipeline) FT_List(ctx context.Context) *StringSliceCmd

func (*Pipeline) FlushAll added in v1.0.44 

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

func (*Pipeline) FlushAllAsync added in v1.0.44 

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

func (*Pipeline) FlushDB added in v1.0.44 

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

func (*Pipeline) FlushDBAsync added in v1.0.44 

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

func (*Pipeline) FunctionDelete added in v1.0.44 

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

func (*Pipeline) FunctionDump added in v1.0.44 

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

func (*Pipeline) FunctionFlush added in v1.0.44 

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

func (*Pipeline) FunctionFlushAsync added in v1.0.44 

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

func (*Pipeline) FunctionKill added in v1.0.44 

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

func (*Pipeline) FunctionList added in v1.0.44 

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

func (*Pipeline) FunctionLoad added in v1.0.44 

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

func (*Pipeline) FunctionLoadReplace added in v1.0.44 

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

func (*Pipeline) FunctionRestore added in v1.0.44 

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

func (*Pipeline) GeoAdd added in v1.0.44 

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

func (*Pipeline) GeoDist added in v1.0.44 

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

func (*Pipeline) GeoHash added in v1.0.44 

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

func (*Pipeline) GeoPos added in v1.0.44 

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

func (*Pipeline) GeoRadius added in v1.0.44 

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

func (*Pipeline) GeoRadiusByMember added in v1.0.44 

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

func (*Pipeline) GeoRadiusByMemberStore added in v1.0.44 

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

func (*Pipeline) GeoRadiusStore added in v1.0.44 

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

func (*Pipeline) GeoSearch added in v1.0.44 

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

func (*Pipeline) GeoSearchLocation added in v1.0.44 

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

func (*Pipeline) GeoSearchStore added in v1.0.44 

func (c *Pipeline) GeoSearchStore(ctx context.Context, key, store string, q GeoSearchStoreQuery) *IntCmd

func (*Pipeline) Get added in v1.0.44 

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

func (*Pipeline) GetBit added in v1.0.44 

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

func (*Pipeline) GetDel added in v1.0.44 

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

func (*Pipeline) GetEx added in v1.0.44 

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

func (*Pipeline) GetRange added in v1.0.44 

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

func (*Pipeline) GetSet added in v1.0.44 

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

func (*Pipeline) HDel added in v1.0.44 

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

func (*Pipeline) HExists added in v1.0.44 

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

func (*Pipeline) HExpire added in v1.0.45 

func (c *Pipeline) HExpire(ctx context.Context, key string, expiration time.Duration, fields ...string) *IntSliceCmd

func (*Pipeline) HExpireAt added in v1.0.45 

func (c *Pipeline) HExpireAt(ctx context.Context, key string, tm time.Time, fields ...string) *IntSliceCmd

func (*Pipeline) HExpireAtWithArgs added in v1.0.45 

func (c *Pipeline) HExpireAtWithArgs(ctx context.Context, key string, tm time.Time, expirationArgs HExpireArgs, fields ...string) *IntSliceCmd

func (*Pipeline) HExpireTime added in v1.0.45 

func (c *Pipeline) HExpireTime(ctx context.Context, key string, fields ...string) *IntSliceCmd

func (*Pipeline) HExpireWithArgs added in v1.0.45 

func (c *Pipeline) HExpireWithArgs(ctx context.Context, key string, expiration time.Duration, expirationArgs HExpireArgs, fields ...string) *IntSliceCmd

func (*Pipeline) HGet added in v1.0.44 

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

func (*Pipeline) HGetAll added in v1.0.44 

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

func (*Pipeline) HIncrBy added in v1.0.44 

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

func (*Pipeline) HIncrByFloat added in v1.0.44 

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

func (*Pipeline) HKeys added in v1.0.44 

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

func (*Pipeline) HLen added in v1.0.44 

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

func (*Pipeline) HMGet added in v1.0.44 

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

func (*Pipeline) HMSet added in v1.0.44 

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

func (*Pipeline) HPExpire added in v1.0.45 

func (c *Pipeline) HPExpire(ctx context.Context, key string, expiration time.Duration, fields ...string) *IntSliceCmd

func (*Pipeline) HPExpireAt added in v1.0.45 

func (c *Pipeline) HPExpireAt(ctx context.Context, key string, tm time.Time, fields ...string) *IntSliceCmd

func (*Pipeline) HPExpireAtWithArgs added in v1.0.45 

func (c *Pipeline) HPExpireAtWithArgs(ctx context.Context, key string, tm time.Time, expirationArgs HExpireArgs, fields ...string) *IntSliceCmd

func (*Pipeline) HPExpireTime added in v1.0.45 

func (c *Pipeline) HPExpireTime(ctx context.Context, key string, fields ...string) *IntSliceCmd

func (*Pipeline) HPExpireWithArgs added in v1.0.45 

func (c *Pipeline) HPExpireWithArgs(ctx context.Context, key string, expiration time.Duration, expirationArgs HExpireArgs, fields ...string) *IntSliceCmd

func (*Pipeline) HPTTL added in v1.0.45 

func (c *Pipeline) HPTTL(ctx context.Context, key string, fields ...string) *IntSliceCmd

func (*Pipeline) HPersist added in v1.0.45 

func (c *Pipeline) HPersist(ctx context.Context, key string, fields ...string) *IntSliceCmd

func (*Pipeline) HRandField added in v1.0.44 

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

func (*Pipeline) HRandFieldWithValues added in v1.0.44 

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

func (*Pipeline) HScan added in v1.0.44 

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

func (*Pipeline) HScanNoValues added in v1.0.52 

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

func (*Pipeline) HSet added in v1.0.44 

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

func (*Pipeline) HSetNX added in v1.0.44 

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

func (*Pipeline) HTTL added in v1.0.45 

func (c *Pipeline) HTTL(ctx context.Context, key string, fields ...string) *IntSliceCmd

func (*Pipeline) HVals added in v1.0.44 

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

func (*Pipeline) Incr added in v1.0.44 

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

func (*Pipeline) IncrBy added in v1.0.44 

func (c *Pipeline) IncrBy(ctx context.Context, key string, value int64) *IntCmd

func (*Pipeline) IncrByFloat added in v1.0.44 

func (c *Pipeline) IncrByFloat(ctx context.Context, key string, value float64) *FloatCmd

func (*Pipeline) Info added in v1.0.44 

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

func (*Pipeline) JSONArrAppend added in v1.0.44 

func (c *Pipeline) JSONArrAppend(ctx context.Context, key, path string, values ...interface{}) *IntSliceCmd

func (*Pipeline) JSONArrIndex added in v1.0.44 

func (c *Pipeline) JSONArrIndex(ctx context.Context, key, path string, value ...interface{}) *IntSliceCmd

func (*Pipeline) JSONArrIndexWithArgs added in v1.0.44 

func (c *Pipeline) JSONArrIndexWithArgs(ctx context.Context, key, path string, options *JSONArrIndexArgs, value ...interface{}) *IntSliceCmd

func (*Pipeline) JSONArrInsert added in v1.0.44 

func (c *Pipeline) JSONArrInsert(ctx context.Context, key, path string, index int64, values ...interface{}) *IntSliceCmd

func (*Pipeline) JSONArrLen added in v1.0.44 

func (c *Pipeline) JSONArrLen(ctx context.Context, key, path string) *IntSliceCmd

func (*Pipeline) JSONArrPop added in v1.0.44 

func (c *Pipeline) JSONArrPop(ctx context.Context, key, path string, index int) *StringSliceCmd

func (*Pipeline) JSONArrTrim added in v1.0.44 

func (c *Pipeline) JSONArrTrim(ctx context.Context, key, path string) *IntSliceCmd

func (*Pipeline) JSONArrTrimWithArgs added in v1.0.44 

func (c *Pipeline) JSONArrTrimWithArgs(ctx context.Context, key, path string, options *JSONArrTrimArgs) *IntSliceCmd

func (*Pipeline) JSONClear added in v1.0.44 

func (c *Pipeline) JSONClear(ctx context.Context, key, path string) *IntCmd

func (*Pipeline) JSONDebugMemory added in v1.0.44 

func (c *Pipeline) JSONDebugMemory(ctx context.Context, key, path string) *IntCmd

func (*Pipeline) JSONDel added in v1.0.44 

func (c *Pipeline) JSONDel(ctx context.Context, key, path string) *IntCmd

func (*Pipeline) JSONForget added in v1.0.44 

func (c *Pipeline) JSONForget(ctx context.Context, key, path string) *IntCmd

func (*Pipeline) JSONGet added in v1.0.44 

func (c *Pipeline) JSONGet(ctx context.Context, key string, paths ...string) *JSONCmd

func (*Pipeline) JSONGetWithArgs added in v1.0.44 

func (c *Pipeline) JSONGetWithArgs(ctx context.Context, key string, options *JSONGetArgs, paths ...string) *JSONCmd

func (*Pipeline) JSONMGet added in v1.0.44 

func (c *Pipeline) JSONMGet(ctx context.Context, path string, keys ...string) *JSONSliceCmd

func (*Pipeline) JSONMSet added in v1.0.44 

func (c *Pipeline) JSONMSet(ctx context.Context, params ...interface{}) *StatusCmd

func (*Pipeline) JSONMSetArgs added in v1.0.44 

func (c *Pipeline) JSONMSetArgs(ctx context.Context, docs []JSONSetArgs) *StatusCmd

func (*Pipeline) JSONMerge added in v1.0.44 

func (c *Pipeline) JSONMerge(ctx context.Context, key, path string, value string) *StatusCmd

func (*Pipeline) JSONNumIncrBy added in v1.0.44 

func (c *Pipeline) JSONNumIncrBy(ctx context.Context, key, path string, value float64) *JSONCmd

func (*Pipeline) JSONObjKeys added in v1.0.44 

func (c *Pipeline) JSONObjKeys(ctx context.Context, key, path string) *SliceCmd

func (*Pipeline) JSONObjLen added in v1.0.44 

func (c *Pipeline) JSONObjLen(ctx context.Context, key, path string) *IntPointerSliceCmd

func (*Pipeline) JSONSet added in v1.0.44 

func (c *Pipeline) JSONSet(ctx context.Context, key, path string, value interface{}) *StatusCmd

func (*Pipeline) JSONSetMode added in v1.0.44 

func (c *Pipeline) JSONSetMode(ctx context.Context, key, path string, value interface{}, mode string) *StatusCmd

func (*Pipeline) JSONStrAppend added in v1.0.44 

func (c *Pipeline) JSONStrAppend(ctx context.Context, key, path, value string) *IntPointerSliceCmd

func (*Pipeline) JSONStrLen added in v1.0.44 

func (c *Pipeline) JSONStrLen(ctx context.Context, key, path string) *IntPointerSliceCmd

func (*Pipeline) JSONToggle added in v1.0.44 

func (c *Pipeline) JSONToggle(ctx context.Context, key, path string) *IntPointerSliceCmd

func (*Pipeline) JSONType added in v1.0.44 

func (c *Pipeline) JSONType(ctx context.Context, key, path string) *JSONSliceCmd

func (*Pipeline) Keys added in v1.0.44 

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

func (*Pipeline) LIndex added in v1.0.44 

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

func (*Pipeline) LInsert added in v1.0.44 

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

func (*Pipeline) LInsertAfter added in v1.0.44 

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

func (*Pipeline) LInsertBefore added in v1.0.44 

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

func (*Pipeline) LLen added in v1.0.44 

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

func (*Pipeline) LMPop added in v1.0.44 

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

func (*Pipeline) LMove added in v1.0.44 

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

func (*Pipeline) LPop added in v1.0.44 

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

func (*Pipeline) LPopCount added in v1.0.44 

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

func (*Pipeline) LPos added in v1.0.44 

func (c *Pipeline) LPos(ctx context.Context, key string, value string, args LPosArgs) *IntCmd

func (*Pipeline) LPosCount added in v1.0.44 

func (c *Pipeline) LPosCount(ctx context.Context, key string, value string, count int64, args LPosArgs) *IntSliceCmd

func (*Pipeline) LPush added in v1.0.44 

func (c *Pipeline) LPush(ctx context.Context, key string, values ...any) *IntCmd

func (*Pipeline) LPushX added in v1.0.44 

func (c *Pipeline) LPushX(ctx context.Context, key string, values ...any) *IntCmd

func (*Pipeline) LRange added in v1.0.44 

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

func (*Pipeline) LRem added in v1.0.44 

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

func (*Pipeline) LSet added in v1.0.44 

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

func (*Pipeline) LTrim added in v1.0.44 

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

func (*Pipeline) LastSave added in v1.0.44 

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

func (*Pipeline) Len added in v1.0.44 

func (c *Pipeline) Len() int

Len returns the number of queued commands.

func (*Pipeline) MGet added in v1.0.44 

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

func (*Pipeline) MSet added in v1.0.44 

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

func (*Pipeline) MSetNX added in v1.0.44 

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

func (*Pipeline) MemoryUsage added in v1.0.44 

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

func (*Pipeline) Migrate added in v1.0.44 

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

func (*Pipeline) ModuleLoadex added in v1.0.52 

func (c *Pipeline) ModuleLoadex(ctx context.Context, conf *ModuleLoadexConfig) *StringCmd

func (*Pipeline) Move added in v1.0.44 

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

func (*Pipeline) ObjectEncoding added in v1.0.44 

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

func (*Pipeline) ObjectIdleTime added in v1.0.44 

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

func (*Pipeline) ObjectRefCount added in v1.0.44 

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

func (*Pipeline) PExpire added in v1.0.44 

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

func (*Pipeline) PExpireAt added in v1.0.44 

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

func (*Pipeline) PExpireTime added in v1.0.44 

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

func (*Pipeline) PFAdd added in v1.0.44 

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

func (*Pipeline) PFCount added in v1.0.44 

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

func (*Pipeline) PFMerge added in v1.0.44 

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

func (*Pipeline) PTTL added in v1.0.44 

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

func (*Pipeline) Persist added in v1.0.44 

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

func (*Pipeline) Ping added in v1.0.44 

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

func (*Pipeline) Pipeline added in v1.0.44 

func (c *Pipeline) Pipeline() Pipeliner

func (*Pipeline) Pipelined added in v1.0.44 

func (c *Pipeline) Pipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error)

func (*Pipeline) PubSubChannels added in v1.0.44 

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

func (*Pipeline) PubSubNumPat added in v1.0.44 

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

func (*Pipeline) PubSubNumSub added in v1.0.44 

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

func (*Pipeline) PubSubShardChannels added in v1.0.44 

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

func (*Pipeline) PubSubShardNumSub added in v1.0.44 

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

func (*Pipeline) Publish added in v1.0.44 

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

func (*Pipeline) Quit added in v1.0.44 

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

func (*Pipeline) RPop added in v1.0.44 

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

func (*Pipeline) RPopCount added in v1.0.44 

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

func (*Pipeline) RPopLPush added in v1.0.44 

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

func (*Pipeline) RPush added in v1.0.44 

func (c *Pipeline) RPush(ctx context.Context, key string, values ...any) *IntCmd

func (*Pipeline) RPushX added in v1.0.44 

func (c *Pipeline) RPushX(ctx context.Context, key string, values ...any) *IntCmd

func (*Pipeline) RandomKey added in v1.0.44 

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

func (*Pipeline) ReadOnly added in v1.0.44 

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

func (*Pipeline) ReadWrite added in v1.0.44 

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

func (*Pipeline) Rename added in v1.0.44 

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

func (*Pipeline) RenameNX added in v1.0.44 

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

func (*Pipeline) Restore added in v1.0.44 

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

func (*Pipeline) RestoreReplace added in v1.0.44 

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

func (*Pipeline) SAdd added in v1.0.44 

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

func (*Pipeline) SCard added in v1.0.44 

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

func (*Pipeline) SDiff added in v1.0.44 

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

func (*Pipeline) SDiffStore added in v1.0.44 

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

func (*Pipeline) SInter added in v1.0.44 

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

func (*Pipeline) SInterCard added in v1.0.44 

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

func (*Pipeline) SInterStore added in v1.0.44 

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

func (*Pipeline) SIsMember added in v1.0.44 

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

func (*Pipeline) SMIsMember added in v1.0.44 

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

func (*Pipeline) SMembers added in v1.0.44 

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

func (*Pipeline) SMembersMap added in v1.0.44 

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

func (*Pipeline) SMove added in v1.0.44 

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

func (*Pipeline) SPop added in v1.0.44 

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

func (*Pipeline) SPopN added in v1.0.44 

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

func (*Pipeline) SPublish added in v1.0.44 

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

func (*Pipeline) SRandMember added in v1.0.44 

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

func (*Pipeline) SRandMemberN added in v1.0.44 

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

func (*Pipeline) SRem added in v1.0.44 

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

func (*Pipeline) SScan added in v1.0.44 

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

func (*Pipeline) SUnion added in v1.0.44 

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

func (*Pipeline) SUnionStore added in v1.0.44 

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

func (*Pipeline) Save added in v1.0.44 

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

func (*Pipeline) Scan added in v1.0.44 

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

func (*Pipeline) ScanType added in v1.0.44 

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

func (*Pipeline) ScriptExists added in v1.0.44 

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

func (*Pipeline) ScriptFlush added in v1.0.44 

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

func (*Pipeline) ScriptKill added in v1.0.44 

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

func (*Pipeline) ScriptLoad added in v1.0.44 

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

func (*Pipeline) Set added in v1.0.44 

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

func (*Pipeline) SetArgs added in v1.0.44 

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

func (*Pipeline) SetBit added in v1.0.44 

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

func (*Pipeline) SetEX added in v1.0.44 

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

func (*Pipeline) SetNX added in v1.0.44 

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

func (*Pipeline) SetRange added in v1.0.44 

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

func (*Pipeline) SetXX added in v1.0.44 

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

func (*Pipeline) Shutdown added in v1.0.44 

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

func (*Pipeline) ShutdownNoSave added in v1.0.44 

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

func (*Pipeline) ShutdownSave added in v1.0.44 

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

func (*Pipeline) SlaveOf added in v1.0.52 

func (c *Pipeline) SlaveOf(ctx context.Context, host, port string) *StatusCmd

func (*Pipeline) Sort added in v1.0.44 

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

func (*Pipeline) SortInterfaces added in v1.0.44 

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

func (*Pipeline) SortRO added in v1.0.44 

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

func (*Pipeline) SortStore added in v1.0.44 

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

func (*Pipeline) StrLen added in v1.0.44 

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

func (*Pipeline) TDigestAdd added in v1.0.44 

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

func (*Pipeline) TDigestByRank added in v1.0.44 

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

func (*Pipeline) TDigestByRevRank added in v1.0.44 

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

func (*Pipeline) TDigestCDF added in v1.0.44 

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

func (*Pipeline) TDigestCreate added in v1.0.44 

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

func (*Pipeline) TDigestCreateWithCompression added in v1.0.44 

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

func (*Pipeline) TDigestInfo added in v1.0.44 

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

func (*Pipeline) TDigestMax added in v1.0.44 

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

func (*Pipeline) TDigestMerge added in v1.0.44 

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

func (*Pipeline) TDigestMin added in v1.0.44 

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

func (*Pipeline) TDigestQuantile added in v1.0.44 

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

func (*Pipeline) TDigestRank added in v1.0.44 

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

func (*Pipeline) TDigestReset added in v1.0.44 

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

func (*Pipeline) TDigestRevRank added in v1.0.44 

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

func (*Pipeline) TDigestTrimmedMean added in v1.0.44 

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

func (*Pipeline) TFCall added in v1.0.44 

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

func (*Pipeline) TFCallASYNC added in v1.0.44 

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

func (*Pipeline) TFCallASYNCArgs added in v1.0.44 

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

func (*Pipeline) TFCallArgs added in v1.0.44 

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

func (*Pipeline) TFunctionDelete added in v1.0.44 

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

func (*Pipeline) TFunctionList added in v1.0.44 

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

func (*Pipeline) TFunctionListArgs added in v1.0.44 

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

func (*Pipeline) TFunctionLoad added in v1.0.44 

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

func (*Pipeline) TFunctionLoadArgs added in v1.0.44 

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

func (*Pipeline) TSAdd added in v1.0.44 

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

func (*Pipeline) TSAddWithArgs added in v1.0.44 

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

func (*Pipeline) TSAlter added in v1.0.44 

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

func (*Pipeline) TSCreate added in v1.0.44 

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

func (*Pipeline) TSCreateRule added in v1.0.44 

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

func (*Pipeline) TSCreateRuleWithArgs added in v1.0.44 

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

func (*Pipeline) TSCreateWithArgs added in v1.0.44 

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

func (*Pipeline) TSDecrBy added in v1.0.44 

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

func (*Pipeline) TSDecrByWithArgs added in v1.0.44 

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

func (*Pipeline) TSDel added in v1.0.44 

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

func (*Pipeline) TSDeleteRule added in v1.0.44 

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

func (*Pipeline) TSGet added in v1.0.44 

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

func (*Pipeline) TSGetWithArgs added in v1.0.44 

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

func (*Pipeline) TSIncrBy added in v1.0.44 

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

func (*Pipeline) TSIncrByWithArgs added in v1.0.44 

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

func (*Pipeline) TSInfo added in v1.0.44 

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

func (*Pipeline) TSInfoWithArgs added in v1.0.44 

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

func (*Pipeline) TSMAdd added in v1.0.44 

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

func (*Pipeline) TSMGet added in v1.0.44 

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

func (*Pipeline) TSMGetWithArgs added in v1.0.44 

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

func (*Pipeline) TSMRange added in v1.0.44 

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

func (*Pipeline) TSMRangeWithArgs added in v1.0.44 

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

func (*Pipeline) TSMRevRange added in v1.0.44 

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

func (*Pipeline) TSMRevRangeWithArgs added in v1.0.44 

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

func (*Pipeline) TSQueryIndex added in v1.0.44 

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

func (*Pipeline) TSRange added in v1.0.44 

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

func (*Pipeline) TSRangeWithArgs added in v1.0.44 

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

func (*Pipeline) TSRevRange added in v1.0.44 

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

func (*Pipeline) TSRevRangeWithArgs added in v1.0.44 

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

func (*Pipeline) TTL added in v1.0.44 

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

func (*Pipeline) Time added in v1.0.44 

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

func (*Pipeline) TopKAdd added in v1.0.44 

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

func (*Pipeline) TopKCount added in v1.0.44 

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

func (*Pipeline) TopKIncrBy added in v1.0.44 

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

func (*Pipeline) TopKInfo added in v1.0.44 

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

func (*Pipeline) TopKList added in v1.0.44 

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

func (*Pipeline) TopKListWithCount added in v1.0.44 

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

func (*Pipeline) TopKQuery added in v1.0.44 

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

func (*Pipeline) TopKReserve added in v1.0.44 

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

func (*Pipeline) TopKReserveWithOptions added in v1.0.44 

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

func (*Pipeline) Touch added in v1.0.44 

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

func (*Pipeline) TxPipeline added in v1.0.44 

func (c *Pipeline) TxPipeline() Pipeliner

func (*Pipeline) TxPipelined added in v1.0.44 

func (c *Pipeline) TxPipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error)

func (*Pipeline) Type added in v1.0.44 

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

func (*Pipeline) XAck added in v1.0.44 

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

func (*Pipeline) XAdd added in v1.0.44 

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

func (*Pipeline) XAutoClaim added in v1.0.44 

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

func (*Pipeline) XAutoClaimJustID added in v1.0.44 

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

func (*Pipeline) XClaim added in v1.0.44 

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

func (*Pipeline) XClaimJustID added in v1.0.44 

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

func (*Pipeline) XDel added in v1.0.44 

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

func (*Pipeline) XGroupCreate added in v1.0.44 

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

func (*Pipeline) XGroupCreateConsumer added in v1.0.44 

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

func (*Pipeline) XGroupCreateMkStream added in v1.0.44 

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

func (*Pipeline) XGroupDelConsumer added in v1.0.44 

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

func (*Pipeline) XGroupDestroy added in v1.0.44 

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

func (*Pipeline) XGroupSetID added in v1.0.44 

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

func (*Pipeline) XInfoConsumers added in v1.0.44 

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

func (*Pipeline) XInfoGroups added in v1.0.44 

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

func (*Pipeline) XInfoStream added in v1.0.44 

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

func (*Pipeline) XInfoStreamFull added in v1.0.44 

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

func (*Pipeline) XLen added in v1.0.44 

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

func (*Pipeline) XPending added in v1.0.44 

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

func (*Pipeline) XPendingExt added in v1.0.44 

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

func (*Pipeline) XRange added in v1.0.44 

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

func (*Pipeline) XRangeN added in v1.0.44 

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

func (*Pipeline) XRead added in v1.0.44 

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

func (*Pipeline) XReadGroup added in v1.0.44 

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

func (*Pipeline) XReadStreams added in v1.0.44 

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

func (*Pipeline) XRevRange added in v1.0.44 

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

func (*Pipeline) XRevRangeN added in v1.0.44 

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

func (*Pipeline) XTrimMaxLen added in v1.0.44 

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

func (*Pipeline) XTrimMaxLenApprox added in v1.0.44 

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

func (*Pipeline) XTrimMinID added in v1.0.44 

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

func (*Pipeline) XTrimMinIDApprox added in v1.0.44 

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

func (*Pipeline) ZAdd added in v1.0.44 

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

func (*Pipeline) ZAddArgs added in v1.0.44 

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

func (*Pipeline) ZAddArgsIncr added in v1.0.44 

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

func (*Pipeline) ZAddGT added in v1.0.44 

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

func (*Pipeline) ZAddLT added in v1.0.44 

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

func (*Pipeline) ZAddNX added in v1.0.44 

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

func (*Pipeline) ZAddXX added in v1.0.44 

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

func (*Pipeline) ZCard added in v1.0.44 

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

func (*Pipeline) ZCount added in v1.0.44 

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

func (*Pipeline) ZDiff added in v1.0.44 

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

func (*Pipeline) ZDiffStore added in v1.0.44 

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

func (*Pipeline) ZDiffWithScores added in v1.0.44 

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

func (*Pipeline) ZIncrBy added in v1.0.44 

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

func (*Pipeline) ZInter added in v1.0.44 

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

func (*Pipeline) ZInterCard added in v1.0.44 

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

func (*Pipeline) ZInterStore added in v1.0.44 

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

func (*Pipeline) ZInterWithScores added in v1.0.44 

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

func (*Pipeline) ZLexCount added in v1.0.44 

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

func (*Pipeline) ZMPop added in v1.0.44 

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

func (*Pipeline) ZMScore added in v1.0.44 

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

func (*Pipeline) ZPopMax added in v1.0.44 

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

func (*Pipeline) ZPopMin added in v1.0.44 

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

func (*Pipeline) ZRandMember added in v1.0.44 

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

func (*Pipeline) ZRandMemberWithScores added in v1.0.44 

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

func (*Pipeline) ZRange added in v1.0.44 

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

func (*Pipeline) ZRangeArgs added in v1.0.44 

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

func (*Pipeline) ZRangeArgsWithScores added in v1.0.44 

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

func (*Pipeline) ZRangeByLex added in v1.0.44 

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

func (*Pipeline) ZRangeByScore added in v1.0.44 

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

func (*Pipeline) ZRangeByScoreWithScores added in v1.0.44 

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

func (*Pipeline) ZRangeStore added in v1.0.44 

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

func (*Pipeline) ZRangeWithScores added in v1.0.44 

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

func (*Pipeline) ZRank added in v1.0.44 

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

func (*Pipeline) ZRankWithScore added in v1.0.44 

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

func (*Pipeline) ZRem added in v1.0.44 

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

func (*Pipeline) ZRemRangeByLex added in v1.0.44 

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

func (*Pipeline) ZRemRangeByRank added in v1.0.44 

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

func (*Pipeline) ZRemRangeByScore added in v1.0.44 

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

func (*Pipeline) ZRevRange added in v1.0.44 

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

func (*Pipeline) ZRevRangeByLex added in v1.0.44 

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

func (*Pipeline) ZRevRangeByScore added in v1.0.44 

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

func (*Pipeline) ZRevRangeByScoreWithScores added in v1.0.44 

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

func (*Pipeline) ZRevRangeWithScores added in v1.0.44 

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

func (*Pipeline) ZRevRank added in v1.0.44 

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

func (*Pipeline) ZRevRankWithScore added in v1.0.44 

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

func (*Pipeline) ZScan added in v1.0.44 

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

func (*Pipeline) ZScore added in v1.0.44 

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

func (*Pipeline) ZUnion added in v1.0.44 

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

func (*Pipeline) ZUnionStore added in v1.0.44 

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

func (*Pipeline) ZUnionWithScores added in v1.0.44 

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

type Pipeliner added in v1.0.44 

type Pipeliner interface {
	CoreCmdable

	// Len is to obtain the number of commands in the pipeline that have not yet been executed.
	Len() int

	// Do is an API for executing any command.
	// If a certain Redis command is not yet supported, you can use Do to execute it.
	Do(ctx context.Context, args ...interface{}) *Cmd

	// Discard is to discard all commands in the cache that have not yet been executed.
	Discard()

	// Exec is to send all the commands buffered in the pipeline to the redis-server.
	Exec(ctx context.Context) ([]Cmder, error)
}

Pipeliner is a mechanism to realise Redis Pipeline technique.

Pipelining is a technique to extremely speed up processing by packing operations to batches, send them at once to Redis and read a replies in a single step. See https://redis.io/topics/pipelining

Pay attention, that Pipeline is not a transaction, so you can get unexpected results in case of big pipelines and small read/write timeouts. Redis client has retransmission logic in case of timeouts, pipeline can be retransmitted and commands can be executed more then once. To avoid this: it is good idea to use reasonable bigger read/write timeouts depends on your batch size and/or use TxPipeline.

type ProbabilisticCmdable 

type ProbabilisticCmdable interface {
	BFAdd(ctx context.Context, key string, element interface{}) *BoolCmd
	BFCard(ctx context.Context, key string) *IntCmd
	BFExists(ctx context.Context, key string, element interface{}) *BoolCmd
	BFInfo(ctx context.Context, key string) *BFInfoCmd
	BFInfoArg(ctx context.Context, key, option string) *BFInfoCmd
	BFInfoCapacity(ctx context.Context, key string) *BFInfoCmd
	BFInfoSize(ctx context.Context, key string) *BFInfoCmd
	BFInfoFilters(ctx context.Context, key string) *BFInfoCmd
	BFInfoItems(ctx context.Context, key string) *BFInfoCmd
	BFInfoExpansion(ctx context.Context, key string) *BFInfoCmd
	BFInsert(ctx context.Context, key string, options *BFInsertOptions, elements ...interface{}) *BoolSliceCmd
	BFMAdd(ctx context.Context, key string, elements ...interface{}) *BoolSliceCmd
	BFMExists(ctx context.Context, key string, elements ...interface{}) *BoolSliceCmd
	BFReserve(ctx context.Context, key string, errorRate float64, capacity int64) *StatusCmd
	BFReserveExpansion(ctx context.Context, key string, errorRate float64, capacity, expansion int64) *StatusCmd
	BFReserveNonScaling(ctx context.Context, key string, errorRate float64, capacity int64) *StatusCmd
	BFReserveWithArgs(ctx context.Context, key string, options *BFReserveOptions) *StatusCmd
	BFScanDump(ctx context.Context, key string, iterator int64) *ScanDumpCmd
	BFLoadChunk(ctx context.Context, key string, iterator int64, data interface{}) *StatusCmd

	CFAdd(ctx context.Context, key string, element interface{}) *BoolCmd
	CFAddNX(ctx context.Context, key string, element interface{}) *BoolCmd
	CFCount(ctx context.Context, key string, element interface{}) *IntCmd
	CFDel(ctx context.Context, key string, element interface{}) *BoolCmd
	CFExists(ctx context.Context, key string, element interface{}) *BoolCmd
	CFInfo(ctx context.Context, key string) *CFInfoCmd
	CFInsert(ctx context.Context, key string, options *CFInsertOptions, elements ...interface{}) *BoolSliceCmd
	CFInsertNX(ctx context.Context, key string, options *CFInsertOptions, elements ...interface{}) *IntSliceCmd
	CFMExists(ctx context.Context, key string, elements ...interface{}) *BoolSliceCmd
	CFReserve(ctx context.Context, key string, capacity int64) *StatusCmd
	CFReserveWithArgs(ctx context.Context, key string, options *CFReserveOptions) *StatusCmd
	CFReserveExpansion(ctx context.Context, key string, capacity int64, expansion int64) *StatusCmd
	CFReserveBucketSize(ctx context.Context, key string, capacity int64, bucketsize int64) *StatusCmd
	CFReserveMaxIterations(ctx context.Context, key string, capacity int64, maxiterations int64) *StatusCmd
	CFScanDump(ctx context.Context, key string, iterator int64) *ScanDumpCmd
	CFLoadChunk(ctx context.Context, key string, iterator int64, data interface{}) *StatusCmd

	CMSIncrBy(ctx context.Context, key string, elements ...interface{}) *IntSliceCmd
	CMSInfo(ctx context.Context, key string) *CMSInfoCmd
	CMSInitByDim(ctx context.Context, key string, width, height int64) *StatusCmd
	CMSInitByProb(ctx context.Context, key string, errorRate, probability float64) *StatusCmd
	CMSMerge(ctx context.Context, destKey string, sourceKeys ...string) *StatusCmd
	CMSMergeWithWeight(ctx context.Context, destKey string, sourceKeys map[string]int64) *StatusCmd
	CMSQuery(ctx context.Context, key string, elements ...interface{}) *IntSliceCmd

	TopKAdd(ctx context.Context, key string, elements ...interface{}) *StringSliceCmd
	TopKCount(ctx context.Context, key string, elements ...interface{}) *IntSliceCmd
	TopKIncrBy(ctx context.Context, key string, elements ...interface{}) *StringSliceCmd
	TopKInfo(ctx context.Context, key string) *TopKInfoCmd
	TopKList(ctx context.Context, key string) *StringSliceCmd
	TopKListWithCount(ctx context.Context, key string) *MapStringIntCmd
	TopKQuery(ctx context.Context, key string, elements ...interface{}) *BoolSliceCmd
	TopKReserve(ctx context.Context, key string, k int64) *StatusCmd
	TopKReserveWithOptions(ctx context.Context, key string, k int64, width, depth int64, decay float64) *StatusCmd

	TDigestAdd(ctx context.Context, key string, elements ...float64) *StatusCmd
	TDigestByRank(ctx context.Context, key string, rank ...uint64) *FloatSliceCmd
	TDigestByRevRank(ctx context.Context, key string, rank ...uint64) *FloatSliceCmd
	TDigestCDF(ctx context.Context, key string, elements ...float64) *FloatSliceCmd
	TDigestCreate(ctx context.Context, key string) *StatusCmd
	TDigestCreateWithCompression(ctx context.Context, key string, compression int64) *StatusCmd
	TDigestInfo(ctx context.Context, key string) *TDigestInfoCmd
	TDigestMax(ctx context.Context, key string) *FloatCmd
	TDigestMin(ctx context.Context, key string) *FloatCmd
	TDigestMerge(ctx context.Context, destKey string, options *TDigestMergeOptions, sourceKeys ...string) *StatusCmd
	TDigestQuantile(ctx context.Context, key string, elements ...float64) *FloatSliceCmd
	TDigestRank(ctx context.Context, key string, values ...float64) *IntSliceCmd
	TDigestReset(ctx context.Context, key string) *StatusCmd
	TDigestRevRank(ctx context.Context, key string, values ...float64) *IntSliceCmd
	TDigestTrimmedMean(ctx context.Context, key string, lowCutQuantile, highCutQuantile float64) *FloatCmd

	Pipeline() Pipeliner
	Pipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error)

	TxPipeline() Pipeliner
	TxPipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error)
}

https://github.com/redis/go-redis/blob/af4872cbd0de349855ce3f0978929c2f56eb995f/probabilistic.go#L10

type PubSub added in v1.0.42 

type PubSub interface {
	Close() error
	Subscribe(ctx context.Context, channels ...string) error
	PSubscribe(ctx context.Context, patterns ...string) error
	SSubscribe(ctx context.Context, channels ...string) error
	Unsubscribe(ctx context.Context, channels ...string) error
	PUnsubscribe(ctx context.Context, patterns ...string) error
	SUnsubscribe(ctx context.Context, channels ...string) error
	Ping(ctx context.Context, payload ...string) error
	ReceiveTimeout(ctx context.Context, timeout time.Duration) (any, error)
	Receive(ctx context.Context) (any, error)
	ReceiveMessage(ctx context.Context) (*Message, error)
	Channel(opts ...ChannelOption) <-chan *Message
	ChannelWithSubscriptions(opts ...ChannelOption) <-chan any
	String() string
}

type RankScore 

type RankScore struct {
	Rank  int64
	Score float64
}

type RankWithScoreCmd 

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

func (*RankWithScoreCmd) Err 

func (cmd *RankWithScoreCmd) Err() error

func (*RankWithScoreCmd) RawResult added in v1.0.50 

func (cmd *RankWithScoreCmd) RawResult() (any, error)

func (*RankWithScoreCmd) RawVal added in v1.0.50 

func (cmd *RankWithScoreCmd) RawVal() any

func (*RankWithScoreCmd) Result 

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

func (*RankWithScoreCmd) SetErr 

func (cmd *RankWithScoreCmd) SetErr(err error)

func (*RankWithScoreCmd) SetRawVal added in v1.0.50 

func (cmd *RankWithScoreCmd) SetRawVal(rawVal any)

func (*RankWithScoreCmd) SetVal 

func (cmd *RankWithScoreCmd) SetVal(val T)

func (*RankWithScoreCmd) Val 

func (cmd *RankWithScoreCmd) Val() T

type ScanCmd 

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

func (*ScanCmd) Err 

func (cmd *ScanCmd) Err() error

func (*ScanCmd) Result 

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

func (*ScanCmd) SetErr added in v1.0.44 

func (cmd *ScanCmd) SetErr(err error)

func (*ScanCmd) SetVal 

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

func (*ScanCmd) Val 

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

type ScanDump 

type ScanDump struct {
	Data string
	Iter int64
}

type ScanDumpCmd 

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

func (*ScanDumpCmd) Err 

func (cmd *ScanDumpCmd) Err() error

func (*ScanDumpCmd) RawResult added in v1.0.50 

func (cmd *ScanDumpCmd) RawResult() (any, error)

func (*ScanDumpCmd) RawVal added in v1.0.50 

func (cmd *ScanDumpCmd) RawVal() any

func (*ScanDumpCmd) Result 

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

func (*ScanDumpCmd) SetErr 

func (cmd *ScanDumpCmd) SetErr(err error)

func (*ScanDumpCmd) SetRawVal added in v1.0.50 

func (cmd *ScanDumpCmd) SetRawVal(rawVal any)

func (*ScanDumpCmd) SetVal 

func (cmd *ScanDumpCmd) SetVal(val T)

func (*ScanDumpCmd) Val 

func (cmd *ScanDumpCmd) Val() T

type Scanner 

type Scanner interface {
	ScanRedis(s string) error
}

Scanner is the interface implemented by themselves, which will override the decoding behavior of decoderFunc.

type Script added in v1.0.44 

type Script struct {
	// contains filtered or unexported fields
}
Example 
ctx = context.Background()
IncrByXX := NewScript(`
		if redis.call("GET", KEYS[1]) ~= false then
			return redis.call("INCRBY", KEYS[1], ARGV[1])
		end
		return false
	`)
client, err := rueidis.NewClient(rueidis.ClientOption{InitAddress: []string{"127.0.0.1:6379"}})
if err != nil {
	panic(err)
}
defer client.Close()
rdb := NewAdapter(client)
n, err := IncrByXX.Run(ctx, rdb, []string{"xx_counter"}, 2).Result()
fmt.Println(n, err)

err = rdb.Set(ctx, "xx_counter", "40", 0).Err()
if err != nil {
	panic(err)
}

n, err = IncrByXX.Run(ctx, rdb, []string{"xx_counter"}, 2).Result()
fmt.Println(n, err)

Output:

func NewScript added in v1.0.44 

func NewScript(src string) *Script

func (*Script) Eval added in v1.0.44 

func (s *Script) Eval(ctx context.Context, c Scripter, keys []string, args ...interface{}) *Cmd

func (*Script) EvalRO added in v1.0.44 

func (s *Script) EvalRO(ctx context.Context, c Scripter, keys []string, args ...interface{}) *Cmd

func (*Script) EvalSha added in v1.0.44 

func (s *Script) EvalSha(ctx context.Context, c Scripter, keys []string, args ...interface{}) *Cmd

func (*Script) EvalShaRO added in v1.0.44 

func (s *Script) EvalShaRO(ctx context.Context, c Scripter, keys []string, args ...interface{}) *Cmd

func (*Script) Exists added in v1.0.44 

func (s *Script) Exists(ctx context.Context, c Scripter) *BoolSliceCmd

func (*Script) Hash added in v1.0.44 

func (s *Script) Hash() string

func (*Script) Load added in v1.0.44 

func (s *Script) Load(ctx context.Context, c Scripter) *StringCmd

func (*Script) Run added in v1.0.44 

func (s *Script) Run(ctx context.Context, c Scripter, keys []string, args ...interface{}) *Cmd

Run optimistically uses EVALSHA to run the script. If script does not exist it is retried using EVAL.

func (*Script) RunRO added in v1.0.44 

func (s *Script) RunRO(ctx context.Context, c Scripter, keys []string, args ...interface{}) *Cmd

RunRO optimistically uses EVALSHA_RO to run the script. If script does not exist it is retried using EVAL_RO.

type Scripter added in v1.0.44 

type Scripter interface {
	Eval(ctx context.Context, script string, keys []string, args ...interface{}) *Cmd
	EvalSha(ctx context.Context, sha1 string, keys []string, args ...interface{}) *Cmd
	EvalRO(ctx context.Context, script string, keys []string, args ...interface{}) *Cmd
	EvalShaRO(ctx context.Context, sha1 string, keys []string, args ...interface{}) *Cmd
	ScriptExists(ctx context.Context, hashes ...string) *BoolSliceCmd
	ScriptLoad(ctx context.Context, script string) *StringCmd
}

type SearchAggregator added in v1.0.50 

type SearchAggregator int

func (SearchAggregator) String added in v1.0.50 

func (a SearchAggregator) String() string

type SearchCmdable added in v1.0.50 

type SearchCmdable interface {
	FT_List(ctx context.Context) *StringSliceCmd
	FTAggregate(ctx context.Context, index string, query string) *MapStringInterfaceCmd
	FTAggregateWithArgs(ctx context.Context, index string, query string, options *FTAggregateOptions) *AggregateCmd
	FTAliasAdd(ctx context.Context, index string, alias string) *StatusCmd
	FTAliasDel(ctx context.Context, alias string) *StatusCmd
	FTAliasUpdate(ctx context.Context, index string, alias string) *StatusCmd
	FTAlter(ctx context.Context, index string, skipInitalScan bool, definition []interface{}) *StatusCmd
	FTConfigGet(ctx context.Context, option string) *MapMapStringInterfaceCmd
	FTConfigSet(ctx context.Context, option string, value interface{}) *StatusCmd
	FTCreate(ctx context.Context, index string, options *FTCreateOptions, schema ...*FieldSchema) *StatusCmd
	FTCursorDel(ctx context.Context, index string, cursorId int) *StatusCmd
	FTCursorRead(ctx context.Context, index string, cursorId int, count int) *MapStringInterfaceCmd
	FTDictAdd(ctx context.Context, dict string, term ...interface{}) *IntCmd
	FTDictDel(ctx context.Context, dict string, term ...interface{}) *IntCmd
	FTDictDump(ctx context.Context, dict string) *StringSliceCmd
	FTDropIndex(ctx context.Context, index string) *StatusCmd
	FTDropIndexWithArgs(ctx context.Context, index string, options *FTDropIndexOptions) *StatusCmd
	FTExplain(ctx context.Context, index string, query string) *StringCmd
	FTExplainWithArgs(ctx context.Context, index string, query string, options *FTExplainOptions) *StringCmd
	FTInfo(ctx context.Context, index string) *FTInfoCmd
	FTSpellCheck(ctx context.Context, index string, query string) *FTSpellCheckCmd
	FTSpellCheckWithArgs(ctx context.Context, index string, query string, options *FTSpellCheckOptions) *FTSpellCheckCmd
	FTSearch(ctx context.Context, index string, query string) *FTSearchCmd
	FTSearchWithArgs(ctx context.Context, index string, query string, options *FTSearchOptions) *FTSearchCmd
	FTSynDump(ctx context.Context, index string) *FTSynDumpCmd
	FTSynUpdate(ctx context.Context, index string, synGroupId interface{}, terms []interface{}) *StatusCmd
	FTSynUpdateWithArgs(ctx context.Context, index string, synGroupId interface{}, options *FTSynUpdateOptions, terms []interface{}) *StatusCmd
	FTTagVals(ctx context.Context, index string, field string) *StringSliceCmd
}

type SearchFieldType added in v1.0.50 

type SearchFieldType int

func (SearchFieldType) String added in v1.0.50 

func (t SearchFieldType) String() string

type SetArgs 

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

SetArgs provides arguments for the SetArgs function.

type SliceCmd 

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

func (*SliceCmd) Err 

func (cmd *SliceCmd) Err() error

func (*SliceCmd) RawResult added in v1.0.50 

func (cmd *SliceCmd) RawResult() (any, error)

func (*SliceCmd) RawVal added in v1.0.50 

func (cmd *SliceCmd) RawVal() any

func (*SliceCmd) Result 

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

func (*SliceCmd) Scan 

func (cmd *SliceCmd) Scan(dst any) error

Scan scans the results from the map into a destination struct. The map keys are matched in the Redis struct fields by the `redis:"field"` tag. NOTE: result from JSON.ObjKeys should not call this.

func (*SliceCmd) SetErr 

func (cmd *SliceCmd) SetErr(err error)

func (*SliceCmd) SetRawVal added in v1.0.50 

func (cmd *SliceCmd) SetRawVal(rawVal any)

func (*SliceCmd) SetVal 

func (cmd *SliceCmd) SetVal(val T)

func (*SliceCmd) Val 

func (cmd *SliceCmd) Val() T

type SlotRange 

type SlotRange struct {
	Start int64
	End   int64
}

type Sort 

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

type SpellCheckResult added in v1.0.50 

type SpellCheckResult struct {
	Term        string
	Suggestions []SpellCheckSuggestion
}

type SpellCheckSuggestion added in v1.0.50 

type SpellCheckSuggestion struct {
	Score      float64
	Suggestion string
}

type SpellCheckTerms added in v1.0.50 

type SpellCheckTerms struct {
	Include    bool
	Exclude    bool
	Dictionary string
}

type StatusCmd 

type StatusCmd = StringCmd

type StringCmd 

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

func (*StringCmd) Bool 

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

func (*StringCmd) Bytes 

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

func (*StringCmd) Err 

func (cmd *StringCmd) Err() error

func (*StringCmd) Float32 

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

func (*StringCmd) Float64 

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

func (*StringCmd) Int 

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

func (*StringCmd) Int64 

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

func (*StringCmd) RawResult added in v1.0.50 

func (cmd *StringCmd) RawResult() (any, error)

func (*StringCmd) RawVal added in v1.0.50 

func (cmd *StringCmd) RawVal() any

func (*StringCmd) Result 

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

func (*StringCmd) SetErr 

func (cmd *StringCmd) SetErr(err error)

func (*StringCmd) SetRawVal added in v1.0.50 

func (cmd *StringCmd) SetRawVal(rawVal any)

func (*StringCmd) SetVal 

func (cmd *StringCmd) SetVal(val T)

func (*StringCmd) String 

func (cmd *StringCmd) String() string

func (*StringCmd) Time 

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

func (*StringCmd) Uint64 

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

func (*StringCmd) Val 

func (cmd *StringCmd) Val() T

type StringIntMapCmd 

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

func (*StringIntMapCmd) Err 

func (cmd *StringIntMapCmd) Err() error

func (*StringIntMapCmd) RawResult added in v1.0.50 

func (cmd *StringIntMapCmd) RawResult() (any, error)

func (*StringIntMapCmd) RawVal added in v1.0.50 

func (cmd *StringIntMapCmd) RawVal() any

func (*StringIntMapCmd) Result 

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

func (*StringIntMapCmd) SetErr 

func (cmd *StringIntMapCmd) SetErr(err error)

func (*StringIntMapCmd) SetRawVal added in v1.0.50 

func (cmd *StringIntMapCmd) SetRawVal(rawVal any)

func (*StringIntMapCmd) SetVal 

func (cmd *StringIntMapCmd) SetVal(val T)

func (*StringIntMapCmd) Val 

func (cmd *StringIntMapCmd) Val() T

type StringSliceCmd 

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

func (*StringSliceCmd) Err 

func (cmd *StringSliceCmd) Err() error

func (*StringSliceCmd) RawResult added in v1.0.50 

func (cmd *StringSliceCmd) RawResult() (any, error)

func (*StringSliceCmd) RawVal added in v1.0.50 

func (cmd *StringSliceCmd) RawVal() any

func (*StringSliceCmd) Result 

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

func (*StringSliceCmd) SetErr 

func (cmd *StringSliceCmd) SetErr(err error)

func (*StringSliceCmd) SetRawVal added in v1.0.50 

func (cmd *StringSliceCmd) SetRawVal(rawVal any)

func (*StringSliceCmd) SetVal 

func (cmd *StringSliceCmd) SetVal(val T)

func (*StringSliceCmd) Val 

func (cmd *StringSliceCmd) Val() T

type StringStringMapCmd 

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

func (*StringStringMapCmd) Err 

func (cmd *StringStringMapCmd) Err() error

func (*StringStringMapCmd) RawResult added in v1.0.50 

func (cmd *StringStringMapCmd) RawResult() (any, error)

func (*StringStringMapCmd) RawVal added in v1.0.50 

func (cmd *StringStringMapCmd) RawVal() any

func (*StringStringMapCmd) Result 

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

func (*StringStringMapCmd) Scan 

func (cmd *StringStringMapCmd) Scan(dest interface{}) error

Scan scans the results from the map into a destination struct. The map keys are matched in the Redis struct fields by the `redis:"field"` tag.

func (*StringStringMapCmd) SetErr 

func (cmd *StringStringMapCmd) SetErr(err error)

func (*StringStringMapCmd) SetRawVal added in v1.0.50 

func (cmd *StringStringMapCmd) SetRawVal(rawVal any)

func (*StringStringMapCmd) SetVal 

func (cmd *StringStringMapCmd) SetVal(val T)

func (*StringStringMapCmd) Val 

func (cmd *StringStringMapCmd) Val() T

type StringStructMapCmd 

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

func (*StringStructMapCmd) Err 

func (cmd *StringStructMapCmd) Err() error

func (*StringStructMapCmd) RawResult added in v1.0.50 

func (cmd *StringStructMapCmd) RawResult() (any, error)

func (*StringStructMapCmd) RawVal added in v1.0.50 

func (cmd *StringStructMapCmd) RawVal() any

func (*StringStructMapCmd) Result 

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

func (*StringStructMapCmd) SetErr 

func (cmd *StringStructMapCmd) SetErr(err error)

func (*StringStructMapCmd) SetRawVal added in v1.0.50 

func (cmd *StringStructMapCmd) SetRawVal(rawVal any)

func (*StringStructMapCmd) SetVal 

func (cmd *StringStructMapCmd) SetVal(val T)

func (*StringStructMapCmd) Val 

func (cmd *StringStructMapCmd) Val() T

type StructValue 

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

func Struct 

func Struct(dst interface{}) (StructValue, error)

func (StructValue) Scan 

func (s StructValue) Scan(key string, value string) error

type Subscription added in v1.0.42 

type Subscription struct {
	// Can be "subscribe", "unsubscribe", "psubscribe" or "punsubscribe".
	Kind string
	// Channel name we have subscribed to.
	Channel string
	// Number of channels we are currently subscribed to.
	Count int
}

Subscription received after a successful subscription to channel.

func (*Subscription) String added in v1.0.42 

func (m *Subscription) String() string

type TDigestInfo 

type TDigestInfo struct {
	Compression       int64 `redis:"Compression"`
	Capacity          int64 `redis:"Capacity"`
	MergedNodes       int64 `redis:"Merged nodes"`
	UnmergedNodes     int64 `redis:"UnmergedNodes"`
	MergedWeight      int64 `redis:"MergedWeight"`
	UnmergedWeight    int64 `redis:"Unmerged weight"`
	Observations      int64 `redis:"Observations"`
	TotalCompressions int64 `redis:"Total compressions"`
	MemoryUsage       int64 `redis:"Memory usage"`
}

Ref: https://redis.io/commands/tdigest.info/

type TDigestInfoCmd 

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

func (*TDigestInfoCmd) Err 

func (cmd *TDigestInfoCmd) Err() error

func (*TDigestInfoCmd) RawResult added in v1.0.50 

func (cmd *TDigestInfoCmd) RawResult() (any, error)

func (*TDigestInfoCmd) RawVal added in v1.0.50 

func (cmd *TDigestInfoCmd) RawVal() any

func (*TDigestInfoCmd) Result 

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

func (*TDigestInfoCmd) SetErr 

func (cmd *TDigestInfoCmd) SetErr(err error)

func (*TDigestInfoCmd) SetRawVal added in v1.0.50 

func (cmd *TDigestInfoCmd) SetRawVal(rawVal any)

func (*TDigestInfoCmd) SetVal 

func (cmd *TDigestInfoCmd) SetVal(val T)

func (*TDigestInfoCmd) Val 

func (cmd *TDigestInfoCmd) Val() T

type TDigestMergeOptions 

type TDigestMergeOptions struct {
	Compression int64
	Override    bool
}

type TFCallOptions 

type TFCallOptions struct {
	Keys      []string
	Arguments []string
}

type TFunctionListOptions 

type TFunctionListOptions struct {
	Library  string
	Verbose  int
	Withcode bool
}

type TFunctionLoadOptions 

type TFunctionLoadOptions struct {
	Config  string
	Replace bool
}

https://github.com/redis/go-redis/blob/f994ff1cd96299a5c8029ae3403af7b17ef06e8a/gears_commands.go#L21C1-L35C2

type TSAlterOptions 

type TSAlterOptions struct {
	Retention       int
	ChunkSize       int
	DuplicatePolicy string
	Labels          map[string]string
}

type TSCreateRuleOptions 

type TSCreateRuleOptions struct {
	AlignTimestamp int64
}

type TSGetOptions 

type TSGetOptions struct {
	Latest bool
}

type TSIncrDecrOptions 

type TSIncrDecrOptions struct {
	Timestamp    int64
	Retention    int
	ChunkSize    int
	Uncompressed bool
	Labels       map[string]string
}

type TSInfoOptions 

type TSInfoOptions struct {
	Debug bool
}

type TSMGetOptions 

type TSMGetOptions struct {
	Latest         bool
	WithLabels     bool
	SelectedLabels []interface{}
}

type TSMRangeOptions 

type TSMRangeOptions struct {
	Latest          bool
	FilterByTS      []int
	FilterByValue   []int
	WithLabels      bool
	SelectedLabels  []interface{}
	Count           int
	Align           interface{}
	Aggregator      Aggregator
	BucketDuration  int
	BucketTimestamp interface{}
	Empty           bool
	GroupByLabel    interface{}
	Reducer         interface{}
}

type TSMRevRangeOptions 

type TSMRevRangeOptions struct {
	Latest          bool
	FilterByTS      []int
	FilterByValue   []int
	WithLabels      bool
	SelectedLabels  []interface{}
	Count           int
	Align           interface{}
	Aggregator      Aggregator
	BucketDuration  int
	BucketTimestamp interface{}
	Empty           bool
	GroupByLabel    interface{}
	Reducer         interface{}
}

type TSOptions 

type TSOptions struct {
	Retention       int
	ChunkSize       int
	Encoding        string
	DuplicatePolicy string
	Labels          map[string]string
}

type TSRangeOptions 

type TSRangeOptions struct {
	Latest          bool
	FilterByTS      []int
	FilterByValue   []int
	Count           int
	Align           interface{}
	Aggregator      Aggregator
	BucketDuration  int
	BucketTimestamp interface{}
	Empty           bool
}

type TSRevRangeOptions 

type TSRevRangeOptions struct {
	Latest          bool
	FilterByTS      []int
	FilterByValue   []int
	Count           int
	Align           interface{}
	Aggregator      Aggregator
	BucketDuration  int
	BucketTimestamp interface{}
	Empty           bool
}

type TSTimestampValue 

type TSTimestampValue struct {
	Timestamp int64
	Value     float64
}

type TSTimestampValueCmd 

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

func (*TSTimestampValueCmd) Err 

func (cmd *TSTimestampValueCmd) Err() error

func (*TSTimestampValueCmd) RawResult added in v1.0.50 

func (cmd *TSTimestampValueCmd) RawResult() (any, error)

func (*TSTimestampValueCmd) RawVal added in v1.0.50 

func (cmd *TSTimestampValueCmd) RawVal() any

func (*TSTimestampValueCmd) Result 

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

func (*TSTimestampValueCmd) SetErr 

func (cmd *TSTimestampValueCmd) SetErr(err error)

func (*TSTimestampValueCmd) SetRawVal added in v1.0.50 

func (cmd *TSTimestampValueCmd) SetRawVal(rawVal any)

func (*TSTimestampValueCmd) SetVal 

func (cmd *TSTimestampValueCmd) SetVal(val T)

func (*TSTimestampValueCmd) Val 

func (cmd *TSTimestampValueCmd) Val() T

type TSTimestampValueSliceCmd 

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

func (*TSTimestampValueSliceCmd) Err 

func (cmd *TSTimestampValueSliceCmd) Err() error

func (*TSTimestampValueSliceCmd) RawResult added in v1.0.50 

func (cmd *TSTimestampValueSliceCmd) RawResult() (any, error)

func (*TSTimestampValueSliceCmd) RawVal added in v1.0.50 

func (cmd *TSTimestampValueSliceCmd) RawVal() any

func (*TSTimestampValueSliceCmd) Result 

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

func (*TSTimestampValueSliceCmd) SetErr 

func (cmd *TSTimestampValueSliceCmd) SetErr(err error)

func (*TSTimestampValueSliceCmd) SetRawVal added in v1.0.50 

func (cmd *TSTimestampValueSliceCmd) SetRawVal(rawVal any)

func (*TSTimestampValueSliceCmd) SetVal 

func (cmd *TSTimestampValueSliceCmd) SetVal(val T)

func (*TSTimestampValueSliceCmd) Val 

func (cmd *TSTimestampValueSliceCmd) Val() T

type TimeCmd 

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

func (*TimeCmd) Err 

func (cmd *TimeCmd) Err() error

func (*TimeCmd) RawResult added in v1.0.50 

func (cmd *TimeCmd) RawResult() (any, error)

func (*TimeCmd) RawVal added in v1.0.50 

func (cmd *TimeCmd) RawVal() any

func (*TimeCmd) Result 

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

func (*TimeCmd) SetErr 

func (cmd *TimeCmd) SetErr(err error)

func (*TimeCmd) SetRawVal added in v1.0.50 

func (cmd *TimeCmd) SetRawVal(rawVal any)

func (*TimeCmd) SetVal 

func (cmd *TimeCmd) SetVal(val T)

func (*TimeCmd) Val 

func (cmd *TimeCmd) Val() T

type TimeseriesCmdable 

type TimeseriesCmdable interface {
	TSAdd(ctx context.Context, key string, timestamp interface{}, value float64) *IntCmd
	TSAddWithArgs(ctx context.Context, key string, timestamp interface{}, value float64, options *TSOptions) *IntCmd
	TSCreate(ctx context.Context, key string) *StatusCmd
	TSCreateWithArgs(ctx context.Context, key string, options *TSOptions) *StatusCmd
	TSAlter(ctx context.Context, key string, options *TSAlterOptions) *StatusCmd
	TSCreateRule(ctx context.Context, sourceKey string, destKey string, aggregator Aggregator, bucketDuration int) *StatusCmd
	TSCreateRuleWithArgs(ctx context.Context, sourceKey string, destKey string, aggregator Aggregator, bucketDuration int, options *TSCreateRuleOptions) *StatusCmd
	TSIncrBy(ctx context.Context, Key string, timestamp float64) *IntCmd
	TSIncrByWithArgs(ctx context.Context, key string, timestamp float64, options *TSIncrDecrOptions) *IntCmd
	TSDecrBy(ctx context.Context, Key string, timestamp float64) *IntCmd
	TSDecrByWithArgs(ctx context.Context, key string, timestamp float64, options *TSIncrDecrOptions) *IntCmd
	TSDel(ctx context.Context, Key string, fromTimestamp int, toTimestamp int) *IntCmd
	TSDeleteRule(ctx context.Context, sourceKey string, destKey string) *StatusCmd
	TSGet(ctx context.Context, key string) *TSTimestampValueCmd
	TSGetWithArgs(ctx context.Context, key string, options *TSGetOptions) *TSTimestampValueCmd
	TSInfo(ctx context.Context, key string) *MapStringInterfaceCmd
	TSInfoWithArgs(ctx context.Context, key string, options *TSInfoOptions) *MapStringInterfaceCmd
	TSMAdd(ctx context.Context, ktvSlices [][]interface{}) *IntSliceCmd
	TSQueryIndex(ctx context.Context, filterExpr []string) *StringSliceCmd
	TSRevRange(ctx context.Context, key string, fromTimestamp int, toTimestamp int) *TSTimestampValueSliceCmd
	TSRevRangeWithArgs(ctx context.Context, key string, fromTimestamp int, toTimestamp int, options *TSRevRangeOptions) *TSTimestampValueSliceCmd
	TSRange(ctx context.Context, key string, fromTimestamp int, toTimestamp int) *TSTimestampValueSliceCmd
	TSRangeWithArgs(ctx context.Context, key string, fromTimestamp int, toTimestamp int, options *TSRangeOptions) *TSTimestampValueSliceCmd
	TSMRange(ctx context.Context, fromTimestamp int, toTimestamp int, filterExpr []string) *MapStringSliceInterfaceCmd
	TSMRangeWithArgs(ctx context.Context, fromTimestamp int, toTimestamp int, filterExpr []string, options *TSMRangeOptions) *MapStringSliceInterfaceCmd
	TSMRevRange(ctx context.Context, fromTimestamp int, toTimestamp int, filterExpr []string) *MapStringSliceInterfaceCmd
	TSMRevRangeWithArgs(ctx context.Context, fromTimestamp int, toTimestamp int, filterExpr []string, options *TSMRevRangeOptions) *MapStringSliceInterfaceCmd
	TSMGet(ctx context.Context, filters []string) *MapStringSliceInterfaceCmd
	TSMGetWithArgs(ctx context.Context, filters []string, options *TSMGetOptions) *MapStringSliceInterfaceCmd
}

type TopKInfo 

type TopKInfo struct {
	K     int64   `redis:"k"`
	Width int64   `redis:"width"`
	Depth int64   `redis:"depth"`
	Decay float64 `redis:"decay"`
}

type TopKInfoCmd 

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

func (*TopKInfoCmd) Err 

func (cmd *TopKInfoCmd) Err() error

func (*TopKInfoCmd) RawResult added in v1.0.50 

func (cmd *TopKInfoCmd) RawResult() (any, error)

func (*TopKInfoCmd) RawVal added in v1.0.50 

func (cmd *TopKInfoCmd) RawVal() any

func (*TopKInfoCmd) Result 

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

func (*TopKInfoCmd) SetErr 

func (cmd *TopKInfoCmd) SetErr(err error)

func (*TopKInfoCmd) SetRawVal added in v1.0.50 

func (cmd *TopKInfoCmd) SetRawVal(rawVal any)

func (*TopKInfoCmd) SetVal 

func (cmd *TopKInfoCmd) SetVal(val T)

func (*TopKInfoCmd) Val 

func (cmd *TopKInfoCmd) Val() T

type Tx added in v1.0.44 

type Tx interface {
	CoreCmdable
	Watch(ctx context.Context, keys ...string) *StatusCmd
	Unwatch(ctx context.Context, keys ...string) *StatusCmd
	Close(ctx context.Context) error
}

type TxPipeline added in v1.0.44 

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

func (*TxPipeline) Exec added in v1.0.44 

func (c *TxPipeline) Exec(ctx context.Context) ([]Cmder, error)

func (*TxPipeline) Pipeline added in v1.0.44 

func (c *TxPipeline) Pipeline() Pipeliner

func (*TxPipeline) Pipelined added in v1.0.44 

func (c *TxPipeline) Pipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error)

func (*TxPipeline) TxPipeline added in v1.0.44 

func (c *TxPipeline) TxPipeline() Pipeliner

func (*TxPipeline) TxPipelined added in v1.0.44 

func (c *TxPipeline) TxPipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error)

type XAddArgs 

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

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

type XAutoClaimArgs 

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

type XAutoClaimCmd 

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

func (*XAutoClaimCmd) Err 

func (cmd *XAutoClaimCmd) Err() error

func (*XAutoClaimCmd) Result 

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

func (*XAutoClaimCmd) SetErr 

func (cmd *XAutoClaimCmd) SetErr(err error)

func (*XAutoClaimCmd) SetVal 

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

func (*XAutoClaimCmd) Val 

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

type XAutoClaimJustIDCmd 

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

func (*XAutoClaimJustIDCmd) Err 

func (cmd *XAutoClaimJustIDCmd) Err() error

func (*XAutoClaimJustIDCmd) Result 

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

func (*XAutoClaimJustIDCmd) SetErr 

func (cmd *XAutoClaimJustIDCmd) SetErr(err error)

func (*XAutoClaimJustIDCmd) SetVal 

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

func (*XAutoClaimJustIDCmd) Val 

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

type XClaimArgs 

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

type XInfoConsumer 

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

type XInfoConsumersCmd 

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

func (*XInfoConsumersCmd) Err 

func (cmd *XInfoConsumersCmd) Err() error

func (*XInfoConsumersCmd) RawResult added in v1.0.50 

func (cmd *XInfoConsumersCmd) RawResult() (any, error)

func (*XInfoConsumersCmd) RawVal added in v1.0.50 

func (cmd *XInfoConsumersCmd) RawVal() any

func (*XInfoConsumersCmd) Result 

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

func (*XInfoConsumersCmd) SetErr 

func (cmd *XInfoConsumersCmd) SetErr(err error)

func (*XInfoConsumersCmd) SetRawVal added in v1.0.50 

func (cmd *XInfoConsumersCmd) SetRawVal(rawVal any)

func (*XInfoConsumersCmd) SetVal 

func (cmd *XInfoConsumersCmd) SetVal(val T)

func (*XInfoConsumersCmd) Val 

func (cmd *XInfoConsumersCmd) Val() T

type XInfoGroup 

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

type XInfoGroupsCmd 

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

func (*XInfoGroupsCmd) Err 

func (cmd *XInfoGroupsCmd) Err() error

func (*XInfoGroupsCmd) RawResult added in v1.0.50 

func (cmd *XInfoGroupsCmd) RawResult() (any, error)

func (*XInfoGroupsCmd) RawVal added in v1.0.50 

func (cmd *XInfoGroupsCmd) RawVal() any

func (*XInfoGroupsCmd) Result 

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

func (*XInfoGroupsCmd) SetErr 

func (cmd *XInfoGroupsCmd) SetErr(err error)

func (*XInfoGroupsCmd) SetRawVal added in v1.0.50 

func (cmd *XInfoGroupsCmd) SetRawVal(rawVal any)

func (*XInfoGroupsCmd) SetVal 

func (cmd *XInfoGroupsCmd) SetVal(val T)

func (*XInfoGroupsCmd) Val 

func (cmd *XInfoGroupsCmd) Val() T

type XInfoStream 

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

type XInfoStreamCmd 

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

func (*XInfoStreamCmd) Err 

func (cmd *XInfoStreamCmd) Err() error

func (*XInfoStreamCmd) RawResult added in v1.0.50 

func (cmd *XInfoStreamCmd) RawResult() (any, error)

func (*XInfoStreamCmd) RawVal added in v1.0.50 

func (cmd *XInfoStreamCmd) RawVal() any

func (*XInfoStreamCmd) Result 

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

func (*XInfoStreamCmd) SetErr 

func (cmd *XInfoStreamCmd) SetErr(err error)

func (*XInfoStreamCmd) SetRawVal added in v1.0.50 

func (cmd *XInfoStreamCmd) SetRawVal(rawVal any)

func (*XInfoStreamCmd) SetVal 

func (cmd *XInfoStreamCmd) SetVal(val T)

func (*XInfoStreamCmd) Val 

func (cmd *XInfoStreamCmd) Val() T

type XInfoStreamConsumer 

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

type XInfoStreamConsumerPending 

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

type XInfoStreamFull 

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

type XInfoStreamFullCmd 

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

func (*XInfoStreamFullCmd) Err 

func (cmd *XInfoStreamFullCmd) Err() error

func (*XInfoStreamFullCmd) RawResult added in v1.0.50 

func (cmd *XInfoStreamFullCmd) RawResult() (any, error)

func (*XInfoStreamFullCmd) RawVal added in v1.0.50 

func (cmd *XInfoStreamFullCmd) RawVal() any

func (*XInfoStreamFullCmd) Result 

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

func (*XInfoStreamFullCmd) SetErr 

func (cmd *XInfoStreamFullCmd) SetErr(err error)

func (*XInfoStreamFullCmd) SetRawVal added in v1.0.50 

func (cmd *XInfoStreamFullCmd) SetRawVal(rawVal any)

func (*XInfoStreamFullCmd) SetVal 

func (cmd *XInfoStreamFullCmd) SetVal(val T)

func (*XInfoStreamFullCmd) Val 

func (cmd *XInfoStreamFullCmd) Val() T

type XInfoStreamGroup 

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

type XInfoStreamGroupPending 

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

type XMessage 

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

type XMessageSliceCmd 

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

func (*XMessageSliceCmd) Err 

func (cmd *XMessageSliceCmd) Err() error

func (*XMessageSliceCmd) RawResult added in v1.0.50 

func (cmd *XMessageSliceCmd) RawResult() (any, error)

func (*XMessageSliceCmd) RawVal added in v1.0.50 

func (cmd *XMessageSliceCmd) RawVal() any

func (*XMessageSliceCmd) Result 

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

func (*XMessageSliceCmd) SetErr 

func (cmd *XMessageSliceCmd) SetErr(err error)

func (*XMessageSliceCmd) SetRawVal added in v1.0.50 

func (cmd *XMessageSliceCmd) SetRawVal(rawVal any)

func (*XMessageSliceCmd) SetVal 

func (cmd *XMessageSliceCmd) SetVal(val T)

func (*XMessageSliceCmd) Val 

func (cmd *XMessageSliceCmd) Val() T

type XPending 

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

type XPendingCmd 

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

func (*XPendingCmd) Err 

func (cmd *XPendingCmd) Err() error

func (*XPendingCmd) RawResult added in v1.0.50 

func (cmd *XPendingCmd) RawResult() (any, error)

func (*XPendingCmd) RawVal added in v1.0.50 

func (cmd *XPendingCmd) RawVal() any

func (*XPendingCmd) Result 

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

func (*XPendingCmd) SetErr 

func (cmd *XPendingCmd) SetErr(err error)

func (*XPendingCmd) SetRawVal added in v1.0.50 

func (cmd *XPendingCmd) SetRawVal(rawVal any)

func (*XPendingCmd) SetVal 

func (cmd *XPendingCmd) SetVal(val T)

func (*XPendingCmd) Val 

func (cmd *XPendingCmd) Val() T

type XPendingExt 

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

type XPendingExtArgs 

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

type XPendingExtCmd 

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

func (*XPendingExtCmd) Err 

func (cmd *XPendingExtCmd) Err() error

func (*XPendingExtCmd) RawResult added in v1.0.50 

func (cmd *XPendingExtCmd) RawResult() (any, error)

func (*XPendingExtCmd) RawVal added in v1.0.50 

func (cmd *XPendingExtCmd) RawVal() any

func (*XPendingExtCmd) Result 

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

func (*XPendingExtCmd) SetErr 

func (cmd *XPendingExtCmd) SetErr(err error)

func (*XPendingExtCmd) SetRawVal added in v1.0.50 

func (cmd *XPendingExtCmd) SetRawVal(rawVal any)

func (*XPendingExtCmd) SetVal 

func (cmd *XPendingExtCmd) SetVal(val T)

func (*XPendingExtCmd) Val 

func (cmd *XPendingExtCmd) Val() T

type XReadArgs 

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

type XReadGroupArgs 

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

type XStream 

type XStream struct {
	Stream   string
	Messages []XMessage
}

type XStreamSliceCmd 

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

func (*XStreamSliceCmd) Err 

func (cmd *XStreamSliceCmd) Err() error

func (*XStreamSliceCmd) RawResult added in v1.0.50 

func (cmd *XStreamSliceCmd) RawResult() (any, error)

func (*XStreamSliceCmd) RawVal added in v1.0.50 

func (cmd *XStreamSliceCmd) RawVal() any

func (*XStreamSliceCmd) Result 

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

func (*XStreamSliceCmd) SetErr 

func (cmd *XStreamSliceCmd) SetErr(err error)

func (*XStreamSliceCmd) SetRawVal added in v1.0.50 

func (cmd *XStreamSliceCmd) SetRawVal(rawVal any)

func (*XStreamSliceCmd) SetVal 

func (cmd *XStreamSliceCmd) SetVal(val T)

func (*XStreamSliceCmd) Val 

func (cmd *XStreamSliceCmd) Val() T

type Z 

type Z struct {
	Member string
	Score  float64
}

Z represents sorted set member.

type ZAddArgs 

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

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

type ZRangeArgs 

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

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

ZREVRANGE,
ZRANGEBYSCORE,
ZREVRANGEBYSCORE,
ZRANGEBYLEX,
ZREVRANGEBYLEX.

Please pay attention to your redis-server version.

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

type ZRangeBy 

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

type ZSliceCmd 

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

func (*ZSliceCmd) Err 

func (cmd *ZSliceCmd) Err() error

func (*ZSliceCmd) RawResult added in v1.0.50 

func (cmd *ZSliceCmd) RawResult() (any, error)

func (*ZSliceCmd) RawVal added in v1.0.50 

func (cmd *ZSliceCmd) RawVal() any

func (*ZSliceCmd) Result 

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

func (*ZSliceCmd) SetErr 

func (cmd *ZSliceCmd) SetErr(err error)

func (*ZSliceCmd) SetRawVal added in v1.0.50 

func (cmd *ZSliceCmd) SetRawVal(rawVal any)

func (*ZSliceCmd) SetVal 

func (cmd *ZSliceCmd) SetVal(val T)

func (*ZSliceCmd) Val 

func (cmd *ZSliceCmd) Val() T

type ZSliceWithKeyCmd 

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

func (*ZSliceWithKeyCmd) Err 

func (cmd *ZSliceWithKeyCmd) Err() error

func (*ZSliceWithKeyCmd) Result 

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

func (*ZSliceWithKeyCmd) SetErr 

func (cmd *ZSliceWithKeyCmd) SetErr(err error)

func (*ZSliceWithKeyCmd) SetVal 

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

func (*ZSliceWithKeyCmd) Val 

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

type ZStore 

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

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

type ZWithKey 

type ZWithKey struct {
	Z
	Key string
}

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

type ZWithKeyCmd 

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

func (*ZWithKeyCmd) Err 

func (cmd *ZWithKeyCmd) Err() error

func (*ZWithKeyCmd) RawResult added in v1.0.50 

func (cmd *ZWithKeyCmd) RawResult() (any, error)

func (*ZWithKeyCmd) RawVal added in v1.0.50 

func (cmd *ZWithKeyCmd) RawVal() any

func (*ZWithKeyCmd) Result 

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

func (*ZWithKeyCmd) SetErr 

func (cmd *ZWithKeyCmd) SetErr(err error)

func (*ZWithKeyCmd) SetRawVal added in v1.0.50 

func (cmd *ZWithKeyCmd) SetRawVal(rawVal any)

func (*ZWithKeyCmd) SetVal 

func (cmd *ZWithKeyCmd) SetVal(val T)

func (*ZWithKeyCmd) Val 

func (cmd *ZWithKeyCmd) Val() T

Source Files

View all Source files

Jump to

Keyboard shortcuts

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