ratelimit

package module
v0.1.7 Latest Latest
Warning

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

Go to latest
Published: Jul 21, 2023 License: MIT Imports: 12 Imported by: 2

README

Distributed rate-limit library based on Redis

golang-ci


Overview

The goal of this library is to be able to implement distributed rate limit functions simply and rudely. Similar to the usage of the ID generator, the client takes back the data from Redis - batch data (just a value here), as long as it Is not consumed.it doesn't exceed rate-limit.

Advantage
  • Less dependencies, only rely on Redis, no special services required
  • use Redis own clock, The clients no need to have the same clock
  • Thread (coroutine) security
  • Low system overhead and little pressure on redis

Notice

Different types of limiters may have different redis-key data types in redis. So different types of limiters cannot use same name redis-key.

For example

127.0.0.1:6379> type key:leaky
string
127.0.0.1:6379> type key:token
hash
127.0.0.1:6379> hgetall key:token

"token_count"
"0"
"updateTime"
"1613805726567122"
127.0.0.1:6379> get key:leaky
"1613807035353864"
How to get
go get github.com/vearne/ratelimit
Usage
1. create redis.Client

with "github.com/go-redis/redis"
Supports both redis master-slave mode and cluster mode

	client := redis.NewClient(&redis.Options{
		Addr:     "localhost:6379",
		Password: "xxx", // no password set
		DB:       0,  // use default DB
	})
	client := redis.NewClusterClient(&redis.ClusterOptions{
		Addrs:    []string{"127.0.0.1:6379"},
		Password: "xxxx",
	})
2. create RateLimiter
limiter, err := ratelimit.NewTokenBucketRateLimiter(ctx, client,                
        "push", time.Second, 200, 20, 5)

Indicates that 200 operations per second are allowed.

	limiter, err := ratelimit.NewTokenBucketRateLimiter(client, 
	        ctx, "push", time.Minute, 200, 20, 5)

Indicates that 200 operations per minute are allowed.

2.1 Counter algorithm
func NewCounterRateLimiter(ctx context.Context, client redis.Cmdable, key string, duration time.Duration,
	throughput int,
	batchSize int) (Limiter, error)
parameter Description
key Key in Redis
duration Indicates that the operation throughput is allowed in the duration time interval
throughput Indicates that the operation throughput is allowed in the duration time interval
batchSize The number of available operations each time retrieved from redis
2.2 Token bucket algorithm
func NewTokenBucketRateLimiter(ctx context.Context, client redis.Cmdable, key string, duration time.Duration,
	throughput int, maxCapacity int,
	batchSize int) (Limiter, error)
parameter Description
key Key in Redis
duration Indicates that the operation throughput is allowed in the duration time interval
throughput Indicates that the operation throughput is allowed in the duration time interval
maxCapacity The maximum number of tokens that can be stored in the token bucket
batchSize The number of available operations each time retrieved from redis
2.3 Leaky bucket algorithm
func NewLeakyBucketLimiter(ctx context.Context, client redis.Cmdable, key string, duration time.Duration,
	throughput int) (Limiter, error) 
parameter Description
key Key in Redis
duration Indicates that the operation throughput is allowed in the duration time interval
throughput Indicates that the operation throughput is allowed in the duration time interval
2.4 sliding time window
NewSlideTimeWindowLimiter(throught int, duration time.Duration, windowBuckets int) (Limiter, error)
parameter Description
duration Indicates that the operation throughput is allowed in the duration time interval
throughput Indicates that the operation throughput is allowed in the duration time interval
windowBuckets Indicates that windowBuckets buckets will be created for duration, and the time range represented by each bucket is duration/windowBuckets

Note: This limiter is based on memory and does not rely on Redis, so it may not be used in distributed frequency limiting scenarios.

example

more example

package main

import (
	"context"
	"fmt"
	"github.com/go-redis/redis/v8"
	"github.com/vearne/ratelimit"
	slog "github.com/vearne/simplelog"
	"sync"
	"time"
)

func consume(r ratelimit.Limiter, group *sync.WaitGroup,
	c *ratelimit.Counter, targetCount int) {
	defer group.Done()
	var ok bool
	for {
		ok = true
		err := r.Wait(context.Background())
		slog.Debug("r.Wait:%v", err)
		if err != nil {
			ok = false
			slog.Error("error:%v", err)
		}
		if ok {
			value := c.Incr()
			slog.Debug("---value--:%v", value)
			if value >= targetCount {
				break
			}
		}
	}
}

func main() {
	client := redis.NewClient(&redis.Options{
		Addr:     "localhost:6379",
		Password: "xxeQl*@nFE", // password set
		DB:       0,            // use default DB
	})

	limiter, err := ratelimit.NewTokenBucketRateLimiter(
		context.Background(),
		client,
		"key:token",
		time.Second,
		10,
		5,
		2)

	if err != nil {
		fmt.Println("error", err)
		return
	}

	var wg sync.WaitGroup
	total := 50
	counter := ratelimit.NewCounter()
	start := time.Now()
	for i := 0; i < 10; i++ {
		wg.Add(1)
		go consume(limiter, &wg, counter, total)
	}
	wg.Wait()
	cost := time.Since(start)
	fmt.Println("cost", time.Since(start), "rate", float64(total)/cost.Seconds())
}
Dependency

go-redis/redis

Thanks

The development of the module was inspired by the Reference 1.

Reference
  1. Performance million/s: Tencent lightweight global flow control program
Thanks

jetbrains

Documentation

Overview

Package mock_redis is a generated GoMock package.

Index

Constants

View Source
const (
	TokenBucketAlg = iota
	CounterAlg
	LeakyBucketAlg
)
View Source
const LeakyBucketScript = `` /* 473-byte string literal not displayed */
	key Type:  string

    // updateTime
	key -> {lastUpdateTime}* 1000000  +  {microsecond}
View Source
const TokenBucketScript = `` /* 959-byte string literal not displayed */

Variables

This section is empty.

Functions

This section is empty.

Types

type BaseRateLimiter added in v0.0.5

type BaseRateLimiter struct {
	sync.Mutex
	// contains filtered or unexported fields
}

nolint: govet

type Counter added in v0.0.6

type Counter struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewCounter added in v0.0.6

func NewCounter() *Counter

func (*Counter) Incr added in v0.1.0

func (c *Counter) Incr() int

type CounterLimiter added in v0.0.5

type CounterLimiter struct {
	BaseRateLimiter

	N int64

	/*
		If the traffic is too large, the limiter will request Redis frequently.
		To avoid this situation, the frequency of accessing Redis will be limited.
	*/
	AntiDDoS bool
	// contains filtered or unexported fields
}

func (*CounterLimiter) Take added in v0.0.5

func (r *CounterLimiter) Take(ctx context.Context) (bool, error)

func (*CounterLimiter) Wait added in v0.1.1

func (r *CounterLimiter) Wait(ctx context.Context) (err error)

wait until take a token or timeout

func (*CounterLimiter) WithAntiDDos added in v0.1.5

func (r *CounterLimiter) WithAntiDDos(antiDDoS bool)

just for test

type LeakyBucketLimiter added in v0.0.5

type LeakyBucketLimiter struct {
	BaseRateLimiter

	/*
		If the traffic is too large, the limiter will request Redis frequently.
		To avoid this situation, the frequency of accessing Redis will be limited.
	*/
	AntiDDoS bool
	// contains filtered or unexported fields
}

func (*LeakyBucketLimiter) Take added in v0.0.5

func (r *LeakyBucketLimiter) Take(ctx context.Context) (bool, error)

func (*LeakyBucketLimiter) Wait added in v0.1.1

func (r *LeakyBucketLimiter) Wait(ctx context.Context) (err error)

wait until take a token or timeout

func (*LeakyBucketLimiter) WithAntiDDos added in v0.1.5

func (r *LeakyBucketLimiter) WithAntiDDos(antiDDoS bool)

just for test

type Limiter added in v0.0.5

type Limiter interface {
	Take(ctx context.Context) (bool, error)
	Wait(ctx context.Context) (err error)
}

func NewCounterRateLimiter added in v0.0.5

func NewCounterRateLimiter(ctx context.Context, client redis.Cmdable, key string, duration time.Duration,
	throughput int,
	batchSize int) (Limiter, error)

func NewLeakyBucketLimiter added in v0.0.5

func NewLeakyBucketLimiter(ctx context.Context, client redis.Cmdable, key string, duration time.Duration,
	throughput int) (Limiter, error)

func NewSlideTimeWindowLimiter added in v0.0.6

func NewSlideTimeWindowLimiter(throughput int, duration time.Duration, windowBuckets int) (Limiter, error)

func NewTokenBucketRateLimiter added in v0.0.5

func NewTokenBucketRateLimiter(ctx context.Context, client redis.Cmdable, key string, duration time.Duration,
	throughput int, maxCapacity int,
	batchSize int, opts ...Option) (Limiter, error)

type MockCmdable added in v0.1.1

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

MockCmdable is a mock of Cmdable interface.

func NewMockCmdable added in v0.1.1

func NewMockCmdable(ctrl *gomock.Controller) *MockCmdable

NewMockCmdable creates a new mock instance.

func (*MockCmdable) Append added in v0.1.1

func (m *MockCmdable) Append(ctx context.Context, key, value string) *v8.IntCmd

Append mocks base method.

func (*MockCmdable) BLMove added in v0.1.1

func (m *MockCmdable) BLMove(ctx context.Context, source, destination, srcpos, destpos string, timeout time.Duration) *v8.StringCmd

BLMove mocks base method.

func (*MockCmdable) BLPop added in v0.1.1

func (m *MockCmdable) BLPop(ctx context.Context, timeout time.Duration, keys ...string) *v8.StringSliceCmd

BLPop mocks base method.

func (*MockCmdable) BRPop added in v0.1.1

func (m *MockCmdable) BRPop(ctx context.Context, timeout time.Duration, keys ...string) *v8.StringSliceCmd

BRPop mocks base method.

func (*MockCmdable) BRPopLPush added in v0.1.1

func (m *MockCmdable) BRPopLPush(ctx context.Context, source, destination string, timeout time.Duration) *v8.StringCmd

BRPopLPush mocks base method.

func (*MockCmdable) BZPopMax added in v0.1.1

func (m *MockCmdable) BZPopMax(ctx context.Context, timeout time.Duration, keys ...string) *v8.ZWithKeyCmd

BZPopMax mocks base method.

func (*MockCmdable) BZPopMin added in v0.1.1

func (m *MockCmdable) BZPopMin(ctx context.Context, timeout time.Duration, keys ...string) *v8.ZWithKeyCmd

BZPopMin mocks base method.

func (*MockCmdable) BgRewriteAOF added in v0.1.1

func (m *MockCmdable) BgRewriteAOF(ctx context.Context) *v8.StatusCmd

BgRewriteAOF mocks base method.

func (*MockCmdable) BgSave added in v0.1.1

func (m *MockCmdable) BgSave(ctx context.Context) *v8.StatusCmd

BgSave mocks base method.

func (*MockCmdable) BitCount added in v0.1.1

func (m *MockCmdable) BitCount(ctx context.Context, key string, bitCount *v8.BitCount) *v8.IntCmd

BitCount mocks base method.

func (*MockCmdable) BitField added in v0.1.1

func (m *MockCmdable) BitField(ctx context.Context, key string, args ...interface{}) *v8.IntSliceCmd

BitField mocks base method.

func (*MockCmdable) BitOpAnd added in v0.1.1

func (m *MockCmdable) BitOpAnd(ctx context.Context, destKey string, keys ...string) *v8.IntCmd

BitOpAnd mocks base method.

func (*MockCmdable) BitOpNot added in v0.1.1

func (m *MockCmdable) BitOpNot(ctx context.Context, destKey, key string) *v8.IntCmd

BitOpNot mocks base method.

func (*MockCmdable) BitOpOr added in v0.1.1

func (m *MockCmdable) BitOpOr(ctx context.Context, destKey string, keys ...string) *v8.IntCmd

BitOpOr mocks base method.

func (*MockCmdable) BitOpXor added in v0.1.1

func (m *MockCmdable) BitOpXor(ctx context.Context, destKey string, keys ...string) *v8.IntCmd

BitOpXor mocks base method.

func (*MockCmdable) BitPos added in v0.1.1

func (m *MockCmdable) BitPos(ctx context.Context, key string, bit int64, pos ...int64) *v8.IntCmd

BitPos mocks base method.

func (*MockCmdable) ClientGetName added in v0.1.1

func (m *MockCmdable) ClientGetName(ctx context.Context) *v8.StringCmd

ClientGetName mocks base method.

func (*MockCmdable) ClientID added in v0.1.1

func (m *MockCmdable) ClientID(ctx context.Context) *v8.IntCmd

ClientID mocks base method.

func (*MockCmdable) ClientKill added in v0.1.1

func (m *MockCmdable) ClientKill(ctx context.Context, ipPort string) *v8.StatusCmd

ClientKill mocks base method.

func (*MockCmdable) ClientKillByFilter added in v0.1.1

func (m *MockCmdable) ClientKillByFilter(ctx context.Context, keys ...string) *v8.IntCmd

ClientKillByFilter mocks base method.

func (*MockCmdable) ClientList added in v0.1.1

func (m *MockCmdable) ClientList(ctx context.Context) *v8.StringCmd

ClientList mocks base method.

func (*MockCmdable) ClientPause added in v0.1.1

func (m *MockCmdable) ClientPause(ctx context.Context, dur time.Duration) *v8.BoolCmd

ClientPause mocks base method.

func (*MockCmdable) ClusterAddSlots added in v0.1.1

func (m *MockCmdable) ClusterAddSlots(ctx context.Context, slots ...int) *v8.StatusCmd

ClusterAddSlots mocks base method.

func (*MockCmdable) ClusterAddSlotsRange added in v0.1.1

func (m *MockCmdable) ClusterAddSlotsRange(ctx context.Context, min, max int) *v8.StatusCmd

ClusterAddSlotsRange mocks base method.

func (*MockCmdable) ClusterCountFailureReports added in v0.1.1

func (m *MockCmdable) ClusterCountFailureReports(ctx context.Context, nodeID string) *v8.IntCmd

ClusterCountFailureReports mocks base method.

func (*MockCmdable) ClusterCountKeysInSlot added in v0.1.1

func (m *MockCmdable) ClusterCountKeysInSlot(ctx context.Context, slot int) *v8.IntCmd

ClusterCountKeysInSlot mocks base method.

func (*MockCmdable) ClusterDelSlots added in v0.1.1

func (m *MockCmdable) ClusterDelSlots(ctx context.Context, slots ...int) *v8.StatusCmd

ClusterDelSlots mocks base method.

func (*MockCmdable) ClusterDelSlotsRange added in v0.1.1

func (m *MockCmdable) ClusterDelSlotsRange(ctx context.Context, min, max int) *v8.StatusCmd

ClusterDelSlotsRange mocks base method.

func (*MockCmdable) ClusterFailover added in v0.1.1

func (m *MockCmdable) ClusterFailover(ctx context.Context) *v8.StatusCmd

ClusterFailover mocks base method.

func (*MockCmdable) ClusterForget added in v0.1.1

func (m *MockCmdable) ClusterForget(ctx context.Context, nodeID string) *v8.StatusCmd

ClusterForget mocks base method.

func (*MockCmdable) ClusterGetKeysInSlot added in v0.1.1

func (m *MockCmdable) ClusterGetKeysInSlot(ctx context.Context, slot, count int) *v8.StringSliceCmd

ClusterGetKeysInSlot mocks base method.

func (*MockCmdable) ClusterInfo added in v0.1.1

func (m *MockCmdable) ClusterInfo(ctx context.Context) *v8.StringCmd

ClusterInfo mocks base method.

func (*MockCmdable) ClusterKeySlot added in v0.1.1

func (m *MockCmdable) ClusterKeySlot(ctx context.Context, key string) *v8.IntCmd

ClusterKeySlot mocks base method.

func (*MockCmdable) ClusterMeet added in v0.1.1

func (m *MockCmdable) ClusterMeet(ctx context.Context, host, port string) *v8.StatusCmd

ClusterMeet mocks base method.

func (*MockCmdable) ClusterNodes added in v0.1.1

func (m *MockCmdable) ClusterNodes(ctx context.Context) *v8.StringCmd

ClusterNodes mocks base method.

func (*MockCmdable) ClusterReplicate added in v0.1.1

func (m *MockCmdable) ClusterReplicate(ctx context.Context, nodeID string) *v8.StatusCmd

ClusterReplicate mocks base method.

func (*MockCmdable) ClusterResetHard added in v0.1.1

func (m *MockCmdable) ClusterResetHard(ctx context.Context) *v8.StatusCmd

ClusterResetHard mocks base method.

func (*MockCmdable) ClusterResetSoft added in v0.1.1

func (m *MockCmdable) ClusterResetSoft(ctx context.Context) *v8.StatusCmd

ClusterResetSoft mocks base method.

func (*MockCmdable) ClusterSaveConfig added in v0.1.1

func (m *MockCmdable) ClusterSaveConfig(ctx context.Context) *v8.StatusCmd

ClusterSaveConfig mocks base method.

func (*MockCmdable) ClusterSlaves added in v0.1.1

func (m *MockCmdable) ClusterSlaves(ctx context.Context, nodeID string) *v8.StringSliceCmd

ClusterSlaves mocks base method.

func (*MockCmdable) ClusterSlots added in v0.1.1

func (m *MockCmdable) ClusterSlots(ctx context.Context) *v8.ClusterSlotsCmd

ClusterSlots mocks base method.

func (*MockCmdable) Command added in v0.1.1

func (m *MockCmdable) Command(ctx context.Context) *v8.CommandsInfoCmd

Command mocks base method.

func (*MockCmdable) ConfigGet added in v0.1.1

func (m *MockCmdable) ConfigGet(ctx context.Context, parameter string) *v8.SliceCmd

ConfigGet mocks base method.

func (*MockCmdable) ConfigResetStat added in v0.1.1

func (m *MockCmdable) ConfigResetStat(ctx context.Context) *v8.StatusCmd

ConfigResetStat mocks base method.

func (*MockCmdable) ConfigRewrite added in v0.1.1

func (m *MockCmdable) ConfigRewrite(ctx context.Context) *v8.StatusCmd

ConfigRewrite mocks base method.

func (*MockCmdable) ConfigSet added in v0.1.1

func (m *MockCmdable) ConfigSet(ctx context.Context, parameter, value string) *v8.StatusCmd

ConfigSet mocks base method.

func (*MockCmdable) Copy added in v0.1.1

func (m *MockCmdable) Copy(ctx context.Context, sourceKey, destKey string, db int, replace bool) *v8.IntCmd

Copy mocks base method.

func (*MockCmdable) DBSize added in v0.1.1

func (m *MockCmdable) DBSize(ctx context.Context) *v8.IntCmd

DBSize mocks base method.

func (*MockCmdable) DebugObject added in v0.1.1

func (m *MockCmdable) DebugObject(ctx context.Context, key string) *v8.StringCmd

DebugObject mocks base method.

func (*MockCmdable) Decr added in v0.1.1

func (m *MockCmdable) Decr(ctx context.Context, key string) *v8.IntCmd

Decr mocks base method.

func (*MockCmdable) DecrBy added in v0.1.1

func (m *MockCmdable) DecrBy(ctx context.Context, key string, decrement int64) *v8.IntCmd

DecrBy mocks base method.

func (*MockCmdable) Del added in v0.1.1

func (m *MockCmdable) Del(ctx context.Context, keys ...string) *v8.IntCmd

Del mocks base method.

func (*MockCmdable) Dump added in v0.1.1

func (m *MockCmdable) Dump(ctx context.Context, key string) *v8.StringCmd

Dump mocks base method.

func (*MockCmdable) EXPECT added in v0.1.1

func (m *MockCmdable) EXPECT() *MockCmdableMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockCmdable) Echo added in v0.1.1

func (m *MockCmdable) Echo(ctx context.Context, message interface{}) *v8.StringCmd

Echo mocks base method.

func (*MockCmdable) Eval added in v0.1.1

func (m *MockCmdable) Eval(ctx context.Context, script string, keys []string, args ...interface{}) *v8.Cmd

Eval mocks base method.

func (*MockCmdable) EvalSha added in v0.1.1

func (m *MockCmdable) EvalSha(ctx context.Context, sha1 string, keys []string, args ...interface{}) *v8.Cmd

EvalSha mocks base method.

func (*MockCmdable) Exists added in v0.1.1

func (m *MockCmdable) Exists(ctx context.Context, keys ...string) *v8.IntCmd

Exists mocks base method.

func (*MockCmdable) Expire added in v0.1.1

func (m *MockCmdable) Expire(ctx context.Context, key string, expiration time.Duration) *v8.BoolCmd

Expire mocks base method.

func (*MockCmdable) ExpireAt added in v0.1.1

func (m *MockCmdable) ExpireAt(ctx context.Context, key string, tm time.Time) *v8.BoolCmd

ExpireAt mocks base method.

func (*MockCmdable) ExpireGT added in v0.1.1

func (m *MockCmdable) ExpireGT(ctx context.Context, key string, expiration time.Duration) *v8.BoolCmd

ExpireGT mocks base method.

func (*MockCmdable) ExpireLT added in v0.1.1

func (m *MockCmdable) ExpireLT(ctx context.Context, key string, expiration time.Duration) *v8.BoolCmd

ExpireLT mocks base method.

func (*MockCmdable) ExpireNX added in v0.1.1

func (m *MockCmdable) ExpireNX(ctx context.Context, key string, expiration time.Duration) *v8.BoolCmd

ExpireNX mocks base method.

func (*MockCmdable) ExpireXX added in v0.1.1

func (m *MockCmdable) ExpireXX(ctx context.Context, key string, expiration time.Duration) *v8.BoolCmd

ExpireXX mocks base method.

func (*MockCmdable) FlushAll added in v0.1.1

func (m *MockCmdable) FlushAll(ctx context.Context) *v8.StatusCmd

FlushAll mocks base method.

func (*MockCmdable) FlushAllAsync added in v0.1.1

func (m *MockCmdable) FlushAllAsync(ctx context.Context) *v8.StatusCmd

FlushAllAsync mocks base method.

func (*MockCmdable) FlushDB added in v0.1.1

func (m *MockCmdable) FlushDB(ctx context.Context) *v8.StatusCmd

FlushDB mocks base method.

func (*MockCmdable) FlushDBAsync added in v0.1.1

func (m *MockCmdable) FlushDBAsync(ctx context.Context) *v8.StatusCmd

FlushDBAsync mocks base method.

func (*MockCmdable) GeoAdd added in v0.1.1

func (m *MockCmdable) GeoAdd(ctx context.Context, key string, geoLocation ...*v8.GeoLocation) *v8.IntCmd

GeoAdd mocks base method.

func (*MockCmdable) GeoDist added in v0.1.1

func (m *MockCmdable) GeoDist(ctx context.Context, key, member1, member2, unit string) *v8.FloatCmd

GeoDist mocks base method.

func (*MockCmdable) GeoHash added in v0.1.1

func (m *MockCmdable) GeoHash(ctx context.Context, key string, members ...string) *v8.StringSliceCmd

GeoHash mocks base method.

func (*MockCmdable) GeoPos added in v0.1.1

func (m *MockCmdable) GeoPos(ctx context.Context, key string, members ...string) *v8.GeoPosCmd

GeoPos mocks base method.

func (*MockCmdable) GeoRadius added in v0.1.1

func (m *MockCmdable) GeoRadius(ctx context.Context, key string, longitude, latitude float64, query *v8.GeoRadiusQuery) *v8.GeoLocationCmd

GeoRadius mocks base method.

func (*MockCmdable) GeoRadiusByMember added in v0.1.1

func (m *MockCmdable) GeoRadiusByMember(ctx context.Context, key, member string, query *v8.GeoRadiusQuery) *v8.GeoLocationCmd

GeoRadiusByMember mocks base method.

func (*MockCmdable) GeoRadiusByMemberStore added in v0.1.1

func (m *MockCmdable) GeoRadiusByMemberStore(ctx context.Context, key, member string, query *v8.GeoRadiusQuery) *v8.IntCmd

GeoRadiusByMemberStore mocks base method.

func (*MockCmdable) GeoRadiusStore added in v0.1.1

func (m *MockCmdable) GeoRadiusStore(ctx context.Context, key string, longitude, latitude float64, query *v8.GeoRadiusQuery) *v8.IntCmd

GeoRadiusStore mocks base method.

func (*MockCmdable) GeoSearch added in v0.1.1

func (m *MockCmdable) GeoSearch(ctx context.Context, key string, q *v8.GeoSearchQuery) *v8.StringSliceCmd

GeoSearch mocks base method.

func (*MockCmdable) GeoSearchLocation added in v0.1.1

func (m *MockCmdable) GeoSearchLocation(ctx context.Context, key string, q *v8.GeoSearchLocationQuery) *v8.GeoSearchLocationCmd

GeoSearchLocation mocks base method.

func (*MockCmdable) GeoSearchStore added in v0.1.1

func (m *MockCmdable) GeoSearchStore(ctx context.Context, key, store string, q *v8.GeoSearchStoreQuery) *v8.IntCmd

GeoSearchStore mocks base method.

func (*MockCmdable) Get added in v0.1.1

func (m *MockCmdable) Get(ctx context.Context, key string) *v8.StringCmd

Get mocks base method.

func (*MockCmdable) GetBit added in v0.1.1

func (m *MockCmdable) GetBit(ctx context.Context, key string, offset int64) *v8.IntCmd

GetBit mocks base method.

func (*MockCmdable) GetDel added in v0.1.1

func (m *MockCmdable) GetDel(ctx context.Context, key string) *v8.StringCmd

GetDel mocks base method.

func (*MockCmdable) GetEx added in v0.1.1

func (m *MockCmdable) GetEx(ctx context.Context, key string, expiration time.Duration) *v8.StringCmd

GetEx mocks base method.

func (*MockCmdable) GetRange added in v0.1.1

func (m *MockCmdable) GetRange(ctx context.Context, key string, start, end int64) *v8.StringCmd

GetRange mocks base method.

func (*MockCmdable) GetSet added in v0.1.1

func (m *MockCmdable) GetSet(ctx context.Context, key string, value interface{}) *v8.StringCmd

GetSet mocks base method.

func (*MockCmdable) HDel added in v0.1.1

func (m *MockCmdable) HDel(ctx context.Context, key string, fields ...string) *v8.IntCmd

HDel mocks base method.

func (*MockCmdable) HExists added in v0.1.1

func (m *MockCmdable) HExists(ctx context.Context, key, field string) *v8.BoolCmd

HExists mocks base method.

func (*MockCmdable) HGet added in v0.1.1

func (m *MockCmdable) HGet(ctx context.Context, key, field string) *v8.StringCmd

HGet mocks base method.

func (*MockCmdable) HGetAll added in v0.1.1

func (m *MockCmdable) HGetAll(ctx context.Context, key string) *v8.StringStringMapCmd

HGetAll mocks base method.

func (*MockCmdable) HIncrBy added in v0.1.1

func (m *MockCmdable) HIncrBy(ctx context.Context, key, field string, incr int64) *v8.IntCmd

HIncrBy mocks base method.

func (*MockCmdable) HIncrByFloat added in v0.1.1

func (m *MockCmdable) HIncrByFloat(ctx context.Context, key, field string, incr float64) *v8.FloatCmd

HIncrByFloat mocks base method.

func (*MockCmdable) HKeys added in v0.1.1

func (m *MockCmdable) HKeys(ctx context.Context, key string) *v8.StringSliceCmd

HKeys mocks base method.

func (*MockCmdable) HLen added in v0.1.1

func (m *MockCmdable) HLen(ctx context.Context, key string) *v8.IntCmd

HLen mocks base method.

func (*MockCmdable) HMGet added in v0.1.1

func (m *MockCmdable) HMGet(ctx context.Context, key string, fields ...string) *v8.SliceCmd

HMGet mocks base method.

func (*MockCmdable) HMSet added in v0.1.1

func (m *MockCmdable) HMSet(ctx context.Context, key string, values ...interface{}) *v8.BoolCmd

HMSet mocks base method.

func (*MockCmdable) HRandField added in v0.1.1

func (m *MockCmdable) HRandField(ctx context.Context, key string, count int, withValues bool) *v8.StringSliceCmd

HRandField mocks base method.

func (*MockCmdable) HScan added in v0.1.1

func (m *MockCmdable) HScan(ctx context.Context, key string, cursor uint64, match string, count int64) *v8.ScanCmd

HScan mocks base method.

func (*MockCmdable) HSet added in v0.1.1

func (m *MockCmdable) HSet(ctx context.Context, key string, values ...interface{}) *v8.IntCmd

HSet mocks base method.

func (*MockCmdable) HSetNX added in v0.1.1

func (m *MockCmdable) HSetNX(ctx context.Context, key, field string, value interface{}) *v8.BoolCmd

HSetNX mocks base method.

func (*MockCmdable) HVals added in v0.1.1

func (m *MockCmdable) HVals(ctx context.Context, key string) *v8.StringSliceCmd

HVals mocks base method.

func (*MockCmdable) Incr added in v0.1.1

func (m *MockCmdable) Incr(ctx context.Context, key string) *v8.IntCmd

Incr mocks base method.

func (*MockCmdable) IncrBy added in v0.1.1

func (m *MockCmdable) IncrBy(ctx context.Context, key string, value int64) *v8.IntCmd

IncrBy mocks base method.

func (*MockCmdable) IncrByFloat added in v0.1.1

func (m *MockCmdable) IncrByFloat(ctx context.Context, key string, value float64) *v8.FloatCmd

IncrByFloat mocks base method.

func (*MockCmdable) Info added in v0.1.1

func (m *MockCmdable) Info(ctx context.Context, section ...string) *v8.StringCmd

Info mocks base method.

func (*MockCmdable) Keys added in v0.1.1

func (m *MockCmdable) Keys(ctx context.Context, pattern string) *v8.StringSliceCmd

Keys mocks base method.

func (*MockCmdable) LIndex added in v0.1.1

func (m *MockCmdable) LIndex(ctx context.Context, key string, index int64) *v8.StringCmd

LIndex mocks base method.

func (*MockCmdable) LInsert added in v0.1.1

func (m *MockCmdable) LInsert(ctx context.Context, key, op string, pivot, value interface{}) *v8.IntCmd

LInsert mocks base method.

func (*MockCmdable) LInsertAfter added in v0.1.1

func (m *MockCmdable) LInsertAfter(ctx context.Context, key string, pivot, value interface{}) *v8.IntCmd

LInsertAfter mocks base method.

func (*MockCmdable) LInsertBefore added in v0.1.1

func (m *MockCmdable) LInsertBefore(ctx context.Context, key string, pivot, value interface{}) *v8.IntCmd

LInsertBefore mocks base method.

func (*MockCmdable) LLen added in v0.1.1

func (m *MockCmdable) LLen(ctx context.Context, key string) *v8.IntCmd

LLen mocks base method.

func (*MockCmdable) LMove added in v0.1.1

func (m *MockCmdable) LMove(ctx context.Context, source, destination, srcpos, destpos string) *v8.StringCmd

LMove mocks base method.

func (*MockCmdable) LPop added in v0.1.1

func (m *MockCmdable) LPop(ctx context.Context, key string) *v8.StringCmd

LPop mocks base method.

func (*MockCmdable) LPopCount added in v0.1.1

func (m *MockCmdable) LPopCount(ctx context.Context, key string, count int) *v8.StringSliceCmd

LPopCount mocks base method.

func (*MockCmdable) LPos added in v0.1.1

func (m *MockCmdable) LPos(ctx context.Context, key, value string, args v8.LPosArgs) *v8.IntCmd

LPos mocks base method.

func (*MockCmdable) LPosCount added in v0.1.1

func (m *MockCmdable) LPosCount(ctx context.Context, key, value string, count int64, args v8.LPosArgs) *v8.IntSliceCmd

LPosCount mocks base method.

func (*MockCmdable) LPush added in v0.1.1

func (m *MockCmdable) LPush(ctx context.Context, key string, values ...interface{}) *v8.IntCmd

LPush mocks base method.

func (*MockCmdable) LPushX added in v0.1.1

func (m *MockCmdable) LPushX(ctx context.Context, key string, values ...interface{}) *v8.IntCmd

LPushX mocks base method.

func (*MockCmdable) LRange added in v0.1.1

func (m *MockCmdable) LRange(ctx context.Context, key string, start, stop int64) *v8.StringSliceCmd

LRange mocks base method.

func (*MockCmdable) LRem added in v0.1.1

func (m *MockCmdable) LRem(ctx context.Context, key string, count int64, value interface{}) *v8.IntCmd

LRem mocks base method.

func (*MockCmdable) LSet added in v0.1.1

func (m *MockCmdable) LSet(ctx context.Context, key string, index int64, value interface{}) *v8.StatusCmd

LSet mocks base method.

func (*MockCmdable) LTrim added in v0.1.1

func (m *MockCmdable) LTrim(ctx context.Context, key string, start, stop int64) *v8.StatusCmd

LTrim mocks base method.

func (*MockCmdable) LastSave added in v0.1.1

func (m *MockCmdable) LastSave(ctx context.Context) *v8.IntCmd

LastSave mocks base method.

func (*MockCmdable) MGet added in v0.1.1

func (m *MockCmdable) MGet(ctx context.Context, keys ...string) *v8.SliceCmd

MGet mocks base method.

func (*MockCmdable) MSet added in v0.1.1

func (m *MockCmdable) MSet(ctx context.Context, values ...interface{}) *v8.StatusCmd

MSet mocks base method.

func (*MockCmdable) MSetNX added in v0.1.1

func (m *MockCmdable) MSetNX(ctx context.Context, values ...interface{}) *v8.BoolCmd

MSetNX mocks base method.

func (*MockCmdable) MemoryUsage added in v0.1.1

func (m *MockCmdable) MemoryUsage(ctx context.Context, key string, samples ...int) *v8.IntCmd

MemoryUsage mocks base method.

func (*MockCmdable) Migrate added in v0.1.1

func (m *MockCmdable) Migrate(ctx context.Context, host, port, key string, db int, timeout time.Duration) *v8.StatusCmd

Migrate mocks base method.

func (*MockCmdable) Move added in v0.1.1

func (m *MockCmdable) Move(ctx context.Context, key string, db int) *v8.BoolCmd

Move mocks base method.

func (*MockCmdable) ObjectEncoding added in v0.1.1

func (m *MockCmdable) ObjectEncoding(ctx context.Context, key string) *v8.StringCmd

ObjectEncoding mocks base method.

func (*MockCmdable) ObjectIdleTime added in v0.1.1

func (m *MockCmdable) ObjectIdleTime(ctx context.Context, key string) *v8.DurationCmd

ObjectIdleTime mocks base method.

func (*MockCmdable) ObjectRefCount added in v0.1.1

func (m *MockCmdable) ObjectRefCount(ctx context.Context, key string) *v8.IntCmd

ObjectRefCount mocks base method.

func (*MockCmdable) PExpire added in v0.1.1

func (m *MockCmdable) PExpire(ctx context.Context, key string, expiration time.Duration) *v8.BoolCmd

PExpire mocks base method.

func (*MockCmdable) PExpireAt added in v0.1.1

func (m *MockCmdable) PExpireAt(ctx context.Context, key string, tm time.Time) *v8.BoolCmd

PExpireAt mocks base method.

func (*MockCmdable) PFAdd added in v0.1.1

func (m *MockCmdable) PFAdd(ctx context.Context, key string, els ...interface{}) *v8.IntCmd

PFAdd mocks base method.

func (*MockCmdable) PFCount added in v0.1.1

func (m *MockCmdable) PFCount(ctx context.Context, keys ...string) *v8.IntCmd

PFCount mocks base method.

func (*MockCmdable) PFMerge added in v0.1.1

func (m *MockCmdable) PFMerge(ctx context.Context, dest string, keys ...string) *v8.StatusCmd

PFMerge mocks base method.

func (*MockCmdable) PTTL added in v0.1.1

func (m *MockCmdable) PTTL(ctx context.Context, key string) *v8.DurationCmd

PTTL mocks base method.

func (*MockCmdable) Persist added in v0.1.1

func (m *MockCmdable) Persist(ctx context.Context, key string) *v8.BoolCmd

Persist mocks base method.

func (*MockCmdable) Ping added in v0.1.1

func (m *MockCmdable) Ping(ctx context.Context) *v8.StatusCmd

Ping mocks base method.

func (*MockCmdable) Pipeline added in v0.1.1

func (m *MockCmdable) Pipeline() v8.Pipeliner

Pipeline mocks base method.

func (*MockCmdable) Pipelined added in v0.1.1

func (m *MockCmdable) Pipelined(ctx context.Context, fn func(v8.Pipeliner) error) ([]v8.Cmder, error)

Pipelined mocks base method.

func (*MockCmdable) PubSubChannels added in v0.1.1

func (m *MockCmdable) PubSubChannels(ctx context.Context, pattern string) *v8.StringSliceCmd

PubSubChannels mocks base method.

func (*MockCmdable) PubSubNumPat added in v0.1.1

func (m *MockCmdable) PubSubNumPat(ctx context.Context) *v8.IntCmd

PubSubNumPat mocks base method.

func (*MockCmdable) PubSubNumSub added in v0.1.1

func (m *MockCmdable) PubSubNumSub(ctx context.Context, channels ...string) *v8.StringIntMapCmd

PubSubNumSub mocks base method.

func (*MockCmdable) Publish added in v0.1.1

func (m *MockCmdable) Publish(ctx context.Context, channel string, message interface{}) *v8.IntCmd

Publish mocks base method.

func (*MockCmdable) Quit added in v0.1.1

func (m *MockCmdable) Quit(ctx context.Context) *v8.StatusCmd

Quit mocks base method.

func (*MockCmdable) RPop added in v0.1.1

func (m *MockCmdable) RPop(ctx context.Context, key string) *v8.StringCmd

RPop mocks base method.

func (*MockCmdable) RPopCount added in v0.1.1

func (m *MockCmdable) RPopCount(ctx context.Context, key string, count int) *v8.StringSliceCmd

RPopCount mocks base method.

func (*MockCmdable) RPopLPush added in v0.1.1

func (m *MockCmdable) RPopLPush(ctx context.Context, source, destination string) *v8.StringCmd

RPopLPush mocks base method.

func (*MockCmdable) RPush added in v0.1.1

func (m *MockCmdable) RPush(ctx context.Context, key string, values ...interface{}) *v8.IntCmd

RPush mocks base method.

func (*MockCmdable) RPushX added in v0.1.1

func (m *MockCmdable) RPushX(ctx context.Context, key string, values ...interface{}) *v8.IntCmd

RPushX mocks base method.

func (*MockCmdable) RandomKey added in v0.1.1

func (m *MockCmdable) RandomKey(ctx context.Context) *v8.StringCmd

RandomKey mocks base method.

func (*MockCmdable) ReadOnly added in v0.1.1

func (m *MockCmdable) ReadOnly(ctx context.Context) *v8.StatusCmd

ReadOnly mocks base method.

func (*MockCmdable) ReadWrite added in v0.1.1

func (m *MockCmdable) ReadWrite(ctx context.Context) *v8.StatusCmd

ReadWrite mocks base method.

func (*MockCmdable) Rename added in v0.1.1

func (m *MockCmdable) Rename(ctx context.Context, key, newkey string) *v8.StatusCmd

Rename mocks base method.

func (*MockCmdable) RenameNX added in v0.1.1

func (m *MockCmdable) RenameNX(ctx context.Context, key, newkey string) *v8.BoolCmd

RenameNX mocks base method.

func (*MockCmdable) Restore added in v0.1.1

func (m *MockCmdable) Restore(ctx context.Context, key string, ttl time.Duration, value string) *v8.StatusCmd

Restore mocks base method.

func (*MockCmdable) RestoreReplace added in v0.1.1

func (m *MockCmdable) RestoreReplace(ctx context.Context, key string, ttl time.Duration, value string) *v8.StatusCmd

RestoreReplace mocks base method.

func (*MockCmdable) SAdd added in v0.1.1

func (m *MockCmdable) SAdd(ctx context.Context, key string, members ...interface{}) *v8.IntCmd

SAdd mocks base method.

func (*MockCmdable) SCard added in v0.1.1

func (m *MockCmdable) SCard(ctx context.Context, key string) *v8.IntCmd

SCard mocks base method.

func (*MockCmdable) SDiff added in v0.1.1

func (m *MockCmdable) SDiff(ctx context.Context, keys ...string) *v8.StringSliceCmd

SDiff mocks base method.

func (*MockCmdable) SDiffStore added in v0.1.1

func (m *MockCmdable) SDiffStore(ctx context.Context, destination string, keys ...string) *v8.IntCmd

SDiffStore mocks base method.

func (*MockCmdable) SInter added in v0.1.1

func (m *MockCmdable) SInter(ctx context.Context, keys ...string) *v8.StringSliceCmd

SInter mocks base method.

func (*MockCmdable) SInterStore added in v0.1.1

func (m *MockCmdable) SInterStore(ctx context.Context, destination string, keys ...string) *v8.IntCmd

SInterStore mocks base method.

func (*MockCmdable) SIsMember added in v0.1.1

func (m *MockCmdable) SIsMember(ctx context.Context, key string, member interface{}) *v8.BoolCmd

SIsMember mocks base method.

func (*MockCmdable) SMIsMember added in v0.1.1

func (m *MockCmdable) SMIsMember(ctx context.Context, key string, members ...interface{}) *v8.BoolSliceCmd

SMIsMember mocks base method.

func (*MockCmdable) SMembers added in v0.1.1

func (m *MockCmdable) SMembers(ctx context.Context, key string) *v8.StringSliceCmd

SMembers mocks base method.

func (*MockCmdable) SMembersMap added in v0.1.1

func (m *MockCmdable) SMembersMap(ctx context.Context, key string) *v8.StringStructMapCmd

SMembersMap mocks base method.

func (*MockCmdable) SMove added in v0.1.1

func (m *MockCmdable) SMove(ctx context.Context, source, destination string, member interface{}) *v8.BoolCmd

SMove mocks base method.

func (*MockCmdable) SPop added in v0.1.1

func (m *MockCmdable) SPop(ctx context.Context, key string) *v8.StringCmd

SPop mocks base method.

func (*MockCmdable) SPopN added in v0.1.1

func (m *MockCmdable) SPopN(ctx context.Context, key string, count int64) *v8.StringSliceCmd

SPopN mocks base method.

func (*MockCmdable) SRandMember added in v0.1.1

func (m *MockCmdable) SRandMember(ctx context.Context, key string) *v8.StringCmd

SRandMember mocks base method.

func (*MockCmdable) SRandMemberN added in v0.1.1

func (m *MockCmdable) SRandMemberN(ctx context.Context, key string, count int64) *v8.StringSliceCmd

SRandMemberN mocks base method.

func (*MockCmdable) SRem added in v0.1.1

func (m *MockCmdable) SRem(ctx context.Context, key string, members ...interface{}) *v8.IntCmd

SRem mocks base method.

func (*MockCmdable) SScan added in v0.1.1

func (m *MockCmdable) SScan(ctx context.Context, key string, cursor uint64, match string, count int64) *v8.ScanCmd

SScan mocks base method.

func (*MockCmdable) SUnion added in v0.1.1

func (m *MockCmdable) SUnion(ctx context.Context, keys ...string) *v8.StringSliceCmd

SUnion mocks base method.

func (*MockCmdable) SUnionStore added in v0.1.1

func (m *MockCmdable) SUnionStore(ctx context.Context, destination string, keys ...string) *v8.IntCmd

SUnionStore mocks base method.

func (*MockCmdable) Save added in v0.1.1

func (m *MockCmdable) Save(ctx context.Context) *v8.StatusCmd

Save mocks base method.

func (*MockCmdable) Scan added in v0.1.1

func (m *MockCmdable) Scan(ctx context.Context, cursor uint64, match string, count int64) *v8.ScanCmd

Scan mocks base method.

func (*MockCmdable) ScanType added in v0.1.1

func (m *MockCmdable) ScanType(ctx context.Context, cursor uint64, match string, count int64, keyType string) *v8.ScanCmd

ScanType mocks base method.

func (*MockCmdable) ScriptExists added in v0.1.1

func (m *MockCmdable) ScriptExists(ctx context.Context, hashes ...string) *v8.BoolSliceCmd

ScriptExists mocks base method.

func (*MockCmdable) ScriptFlush added in v0.1.1

func (m *MockCmdable) ScriptFlush(ctx context.Context) *v8.StatusCmd

ScriptFlush mocks base method.

func (*MockCmdable) ScriptKill added in v0.1.1

func (m *MockCmdable) ScriptKill(ctx context.Context) *v8.StatusCmd

ScriptKill mocks base method.

func (*MockCmdable) ScriptLoad added in v0.1.1

func (m *MockCmdable) ScriptLoad(ctx context.Context, script string) *v8.StringCmd

ScriptLoad mocks base method.

func (*MockCmdable) Set added in v0.1.1

func (m *MockCmdable) Set(ctx context.Context, key string, value interface{}, expiration time.Duration) *v8.StatusCmd

Set mocks base method.

func (*MockCmdable) SetArgs added in v0.1.1

func (m *MockCmdable) SetArgs(ctx context.Context, key string, value interface{}, a v8.SetArgs) *v8.StatusCmd

SetArgs mocks base method.

func (*MockCmdable) SetBit added in v0.1.1

func (m *MockCmdable) SetBit(ctx context.Context, key string, offset int64, value int) *v8.IntCmd

SetBit mocks base method.

func (*MockCmdable) SetEX added in v0.1.1

func (m *MockCmdable) SetEX(ctx context.Context, key string, value interface{}, expiration time.Duration) *v8.StatusCmd

SetEX mocks base method.

func (*MockCmdable) SetNX added in v0.1.1

func (m *MockCmdable) SetNX(ctx context.Context, key string, value interface{}, expiration time.Duration) *v8.BoolCmd

SetNX mocks base method.

func (*MockCmdable) SetRange added in v0.1.1

func (m *MockCmdable) SetRange(ctx context.Context, key string, offset int64, value string) *v8.IntCmd

SetRange mocks base method.

func (*MockCmdable) SetXX added in v0.1.1

func (m *MockCmdable) SetXX(ctx context.Context, key string, value interface{}, expiration time.Duration) *v8.BoolCmd

SetXX mocks base method.

func (*MockCmdable) Shutdown added in v0.1.1

func (m *MockCmdable) Shutdown(ctx context.Context) *v8.StatusCmd

Shutdown mocks base method.

func (*MockCmdable) ShutdownNoSave added in v0.1.1

func (m *MockCmdable) ShutdownNoSave(ctx context.Context) *v8.StatusCmd

ShutdownNoSave mocks base method.

func (*MockCmdable) ShutdownSave added in v0.1.1

func (m *MockCmdable) ShutdownSave(ctx context.Context) *v8.StatusCmd

ShutdownSave mocks base method.

func (*MockCmdable) SlaveOf added in v0.1.1

func (m *MockCmdable) SlaveOf(ctx context.Context, host, port string) *v8.StatusCmd

SlaveOf mocks base method.

func (*MockCmdable) Sort added in v0.1.1

func (m *MockCmdable) Sort(ctx context.Context, key string, sort *v8.Sort) *v8.StringSliceCmd

Sort mocks base method.

func (*MockCmdable) SortInterfaces added in v0.1.1

func (m *MockCmdable) SortInterfaces(ctx context.Context, key string, sort *v8.Sort) *v8.SliceCmd

SortInterfaces mocks base method.

func (*MockCmdable) SortStore added in v0.1.1

func (m *MockCmdable) SortStore(ctx context.Context, key, store string, sort *v8.Sort) *v8.IntCmd

SortStore mocks base method.

func (*MockCmdable) StrLen added in v0.1.1

func (m *MockCmdable) StrLen(ctx context.Context, key string) *v8.IntCmd

StrLen mocks base method.

func (*MockCmdable) TTL added in v0.1.1

func (m *MockCmdable) TTL(ctx context.Context, key string) *v8.DurationCmd

TTL mocks base method.

func (*MockCmdable) Time added in v0.1.1

func (m *MockCmdable) Time(ctx context.Context) *v8.TimeCmd

Time mocks base method.

func (*MockCmdable) Touch added in v0.1.1

func (m *MockCmdable) Touch(ctx context.Context, keys ...string) *v8.IntCmd

Touch mocks base method.

func (*MockCmdable) TxPipeline added in v0.1.1

func (m *MockCmdable) TxPipeline() v8.Pipeliner

TxPipeline mocks base method.

func (*MockCmdable) TxPipelined added in v0.1.1

func (m *MockCmdable) TxPipelined(ctx context.Context, fn func(v8.Pipeliner) error) ([]v8.Cmder, error)

TxPipelined mocks base method.

func (*MockCmdable) Type added in v0.1.1

func (m *MockCmdable) Type(ctx context.Context, key string) *v8.StatusCmd

Type mocks base method.

func (m *MockCmdable) Unlink(ctx context.Context, keys ...string) *v8.IntCmd

Unlink mocks base method.

func (*MockCmdable) XAck added in v0.1.1

func (m *MockCmdable) XAck(ctx context.Context, stream, group string, ids ...string) *v8.IntCmd

XAck mocks base method.

func (*MockCmdable) XAdd added in v0.1.1

func (m *MockCmdable) XAdd(ctx context.Context, a *v8.XAddArgs) *v8.StringCmd

XAdd mocks base method.

func (*MockCmdable) XAutoClaim added in v0.1.1

func (m *MockCmdable) XAutoClaim(ctx context.Context, a *v8.XAutoClaimArgs) *v8.XAutoClaimCmd

XAutoClaim mocks base method.

func (*MockCmdable) XAutoClaimJustID added in v0.1.1

func (m *MockCmdable) XAutoClaimJustID(ctx context.Context, a *v8.XAutoClaimArgs) *v8.XAutoClaimJustIDCmd

XAutoClaimJustID mocks base method.

func (*MockCmdable) XClaim added in v0.1.1

XClaim mocks base method.

func (*MockCmdable) XClaimJustID added in v0.1.1

func (m *MockCmdable) XClaimJustID(ctx context.Context, a *v8.XClaimArgs) *v8.StringSliceCmd

XClaimJustID mocks base method.

func (*MockCmdable) XDel added in v0.1.1

func (m *MockCmdable) XDel(ctx context.Context, stream string, ids ...string) *v8.IntCmd

XDel mocks base method.

func (*MockCmdable) XGroupCreate added in v0.1.1

func (m *MockCmdable) XGroupCreate(ctx context.Context, stream, group, start string) *v8.StatusCmd

XGroupCreate mocks base method.

func (*MockCmdable) XGroupCreateConsumer added in v0.1.1

func (m *MockCmdable) XGroupCreateConsumer(ctx context.Context, stream, group, consumer string) *v8.IntCmd

XGroupCreateConsumer mocks base method.

func (*MockCmdable) XGroupCreateMkStream added in v0.1.1

func (m *MockCmdable) XGroupCreateMkStream(ctx context.Context, stream, group, start string) *v8.StatusCmd

XGroupCreateMkStream mocks base method.

func (*MockCmdable) XGroupDelConsumer added in v0.1.1

func (m *MockCmdable) XGroupDelConsumer(ctx context.Context, stream, group, consumer string) *v8.IntCmd

XGroupDelConsumer mocks base method.

func (*MockCmdable) XGroupDestroy added in v0.1.1

func (m *MockCmdable) XGroupDestroy(ctx context.Context, stream, group string) *v8.IntCmd

XGroupDestroy mocks base method.

func (*MockCmdable) XGroupSetID added in v0.1.1

func (m *MockCmdable) XGroupSetID(ctx context.Context, stream, group, start string) *v8.StatusCmd

XGroupSetID mocks base method.

func (*MockCmdable) XInfoConsumers added in v0.1.1

func (m *MockCmdable) XInfoConsumers(ctx context.Context, key, group string) *v8.XInfoConsumersCmd

XInfoConsumers mocks base method.

func (*MockCmdable) XInfoGroups added in v0.1.1

func (m *MockCmdable) XInfoGroups(ctx context.Context, key string) *v8.XInfoGroupsCmd

XInfoGroups mocks base method.

func (*MockCmdable) XInfoStream added in v0.1.1

func (m *MockCmdable) XInfoStream(ctx context.Context, key string) *v8.XInfoStreamCmd

XInfoStream mocks base method.

func (*MockCmdable) XInfoStreamFull added in v0.1.1

func (m *MockCmdable) XInfoStreamFull(ctx context.Context, key string, count int) *v8.XInfoStreamFullCmd

XInfoStreamFull mocks base method.

func (*MockCmdable) XLen added in v0.1.1

func (m *MockCmdable) XLen(ctx context.Context, stream string) *v8.IntCmd

XLen mocks base method.

func (*MockCmdable) XPending added in v0.1.1

func (m *MockCmdable) XPending(ctx context.Context, stream, group string) *v8.XPendingCmd

XPending mocks base method.

func (*MockCmdable) XPendingExt added in v0.1.1

func (m *MockCmdable) XPendingExt(ctx context.Context, a *v8.XPendingExtArgs) *v8.XPendingExtCmd

XPendingExt mocks base method.

func (*MockCmdable) XRange added in v0.1.1

func (m *MockCmdable) XRange(ctx context.Context, stream, start, stop string) *v8.XMessageSliceCmd

XRange mocks base method.

func (*MockCmdable) XRangeN added in v0.1.1

func (m *MockCmdable) XRangeN(ctx context.Context, stream, start, stop string, count int64) *v8.XMessageSliceCmd

XRangeN mocks base method.

func (*MockCmdable) XRead added in v0.1.1

XRead mocks base method.

func (*MockCmdable) XReadGroup added in v0.1.1

func (m *MockCmdable) XReadGroup(ctx context.Context, a *v8.XReadGroupArgs) *v8.XStreamSliceCmd

XReadGroup mocks base method.

func (*MockCmdable) XReadStreams added in v0.1.1

func (m *MockCmdable) XReadStreams(ctx context.Context, streams ...string) *v8.XStreamSliceCmd

XReadStreams mocks base method.

func (*MockCmdable) XRevRange added in v0.1.1

func (m *MockCmdable) XRevRange(ctx context.Context, stream, start, stop string) *v8.XMessageSliceCmd

XRevRange mocks base method.

func (*MockCmdable) XRevRangeN added in v0.1.1

func (m *MockCmdable) XRevRangeN(ctx context.Context, stream, start, stop string, count int64) *v8.XMessageSliceCmd

XRevRangeN mocks base method.

func (*MockCmdable) XTrim added in v0.1.1

func (m *MockCmdable) XTrim(ctx context.Context, key string, maxLen int64) *v8.IntCmd

XTrim mocks base method.

func (*MockCmdable) XTrimApprox added in v0.1.1

func (m *MockCmdable) XTrimApprox(ctx context.Context, key string, maxLen int64) *v8.IntCmd

XTrimApprox mocks base method.

func (*MockCmdable) XTrimMaxLen added in v0.1.1

func (m *MockCmdable) XTrimMaxLen(ctx context.Context, key string, maxLen int64) *v8.IntCmd

XTrimMaxLen mocks base method.

func (*MockCmdable) XTrimMaxLenApprox added in v0.1.1

func (m *MockCmdable) XTrimMaxLenApprox(ctx context.Context, key string, maxLen, limit int64) *v8.IntCmd

XTrimMaxLenApprox mocks base method.

func (*MockCmdable) XTrimMinID added in v0.1.1

func (m *MockCmdable) XTrimMinID(ctx context.Context, key, minID string) *v8.IntCmd

XTrimMinID mocks base method.

func (*MockCmdable) XTrimMinIDApprox added in v0.1.1

func (m *MockCmdable) XTrimMinIDApprox(ctx context.Context, key, minID string, limit int64) *v8.IntCmd

XTrimMinIDApprox mocks base method.

func (*MockCmdable) ZAdd added in v0.1.1

func (m *MockCmdable) ZAdd(ctx context.Context, key string, members ...*v8.Z) *v8.IntCmd

ZAdd mocks base method.

func (*MockCmdable) ZAddArgs added in v0.1.1

func (m *MockCmdable) ZAddArgs(ctx context.Context, key string, args v8.ZAddArgs) *v8.IntCmd

ZAddArgs mocks base method.

func (*MockCmdable) ZAddArgsIncr added in v0.1.1

func (m *MockCmdable) ZAddArgsIncr(ctx context.Context, key string, args v8.ZAddArgs) *v8.FloatCmd

ZAddArgsIncr mocks base method.

func (*MockCmdable) ZAddCh added in v0.1.1

func (m *MockCmdable) ZAddCh(ctx context.Context, key string, members ...*v8.Z) *v8.IntCmd

ZAddCh mocks base method.

func (*MockCmdable) ZAddNX added in v0.1.1

func (m *MockCmdable) ZAddNX(ctx context.Context, key string, members ...*v8.Z) *v8.IntCmd

ZAddNX mocks base method.

func (*MockCmdable) ZAddNXCh added in v0.1.1

func (m *MockCmdable) ZAddNXCh(ctx context.Context, key string, members ...*v8.Z) *v8.IntCmd

ZAddNXCh mocks base method.

func (*MockCmdable) ZAddXX added in v0.1.1

func (m *MockCmdable) ZAddXX(ctx context.Context, key string, members ...*v8.Z) *v8.IntCmd

ZAddXX mocks base method.

func (*MockCmdable) ZAddXXCh added in v0.1.1

func (m *MockCmdable) ZAddXXCh(ctx context.Context, key string, members ...*v8.Z) *v8.IntCmd

ZAddXXCh mocks base method.

func (*MockCmdable) ZCard added in v0.1.1

func (m *MockCmdable) ZCard(ctx context.Context, key string) *v8.IntCmd

ZCard mocks base method.

func (*MockCmdable) ZCount added in v0.1.1

func (m *MockCmdable) ZCount(ctx context.Context, key, min, max string) *v8.IntCmd

ZCount mocks base method.

func (*MockCmdable) ZDiff added in v0.1.1

func (m *MockCmdable) ZDiff(ctx context.Context, keys ...string) *v8.StringSliceCmd

ZDiff mocks base method.

func (*MockCmdable) ZDiffStore added in v0.1.1

func (m *MockCmdable) ZDiffStore(ctx context.Context, destination string, keys ...string) *v8.IntCmd

ZDiffStore mocks base method.

func (*MockCmdable) ZDiffWithScores added in v0.1.1

func (m *MockCmdable) ZDiffWithScores(ctx context.Context, keys ...string) *v8.ZSliceCmd

ZDiffWithScores mocks base method.

func (*MockCmdable) ZIncr added in v0.1.1

func (m *MockCmdable) ZIncr(ctx context.Context, key string, member *v8.Z) *v8.FloatCmd

ZIncr mocks base method.

func (*MockCmdable) ZIncrBy added in v0.1.1

func (m *MockCmdable) ZIncrBy(ctx context.Context, key string, increment float64, member string) *v8.FloatCmd

ZIncrBy mocks base method.

func (*MockCmdable) ZIncrNX added in v0.1.1

func (m *MockCmdable) ZIncrNX(ctx context.Context, key string, member *v8.Z) *v8.FloatCmd

ZIncrNX mocks base method.

func (*MockCmdable) ZIncrXX added in v0.1.1

func (m *MockCmdable) ZIncrXX(ctx context.Context, key string, member *v8.Z) *v8.FloatCmd

ZIncrXX mocks base method.

func (*MockCmdable) ZInter added in v0.1.1

func (m *MockCmdable) ZInter(ctx context.Context, store *v8.ZStore) *v8.StringSliceCmd

ZInter mocks base method.

func (*MockCmdable) ZInterStore added in v0.1.1

func (m *MockCmdable) ZInterStore(ctx context.Context, destination string, store *v8.ZStore) *v8.IntCmd

ZInterStore mocks base method.

func (*MockCmdable) ZInterWithScores added in v0.1.1

func (m *MockCmdable) ZInterWithScores(ctx context.Context, store *v8.ZStore) *v8.ZSliceCmd

ZInterWithScores mocks base method.

func (*MockCmdable) ZLexCount added in v0.1.1

func (m *MockCmdable) ZLexCount(ctx context.Context, key, min, max string) *v8.IntCmd

ZLexCount mocks base method.

func (*MockCmdable) ZMScore added in v0.1.1

func (m *MockCmdable) ZMScore(ctx context.Context, key string, members ...string) *v8.FloatSliceCmd

ZMScore mocks base method.

func (*MockCmdable) ZPopMax added in v0.1.1

func (m *MockCmdable) ZPopMax(ctx context.Context, key string, count ...int64) *v8.ZSliceCmd

ZPopMax mocks base method.

func (*MockCmdable) ZPopMin added in v0.1.1

func (m *MockCmdable) ZPopMin(ctx context.Context, key string, count ...int64) *v8.ZSliceCmd

ZPopMin mocks base method.

func (*MockCmdable) ZRandMember added in v0.1.1

func (m *MockCmdable) ZRandMember(ctx context.Context, key string, count int, withScores bool) *v8.StringSliceCmd

ZRandMember mocks base method.

func (*MockCmdable) ZRange added in v0.1.1

func (m *MockCmdable) ZRange(ctx context.Context, key string, start, stop int64) *v8.StringSliceCmd

ZRange mocks base method.

func (*MockCmdable) ZRangeArgs added in v0.1.1

func (m *MockCmdable) ZRangeArgs(ctx context.Context, z v8.ZRangeArgs) *v8.StringSliceCmd

ZRangeArgs mocks base method.

func (*MockCmdable) ZRangeArgsWithScores added in v0.1.1

func (m *MockCmdable) ZRangeArgsWithScores(ctx context.Context, z v8.ZRangeArgs) *v8.ZSliceCmd

ZRangeArgsWithScores mocks base method.

func (*MockCmdable) ZRangeByLex added in v0.1.1

func (m *MockCmdable) ZRangeByLex(ctx context.Context, key string, opt *v8.ZRangeBy) *v8.StringSliceCmd

ZRangeByLex mocks base method.

func (*MockCmdable) ZRangeByScore added in v0.1.1

func (m *MockCmdable) ZRangeByScore(ctx context.Context, key string, opt *v8.ZRangeBy) *v8.StringSliceCmd

ZRangeByScore mocks base method.

func (*MockCmdable) ZRangeByScoreWithScores added in v0.1.1

func (m *MockCmdable) ZRangeByScoreWithScores(ctx context.Context, key string, opt *v8.ZRangeBy) *v8.ZSliceCmd

ZRangeByScoreWithScores mocks base method.

func (*MockCmdable) ZRangeStore added in v0.1.1

func (m *MockCmdable) ZRangeStore(ctx context.Context, dst string, z v8.ZRangeArgs) *v8.IntCmd

ZRangeStore mocks base method.

func (*MockCmdable) ZRangeWithScores added in v0.1.1

func (m *MockCmdable) ZRangeWithScores(ctx context.Context, key string, start, stop int64) *v8.ZSliceCmd

ZRangeWithScores mocks base method.

func (*MockCmdable) ZRank added in v0.1.1

func (m *MockCmdable) ZRank(ctx context.Context, key, member string) *v8.IntCmd

ZRank mocks base method.

func (*MockCmdable) ZRem added in v0.1.1

func (m *MockCmdable) ZRem(ctx context.Context, key string, members ...interface{}) *v8.IntCmd

ZRem mocks base method.

func (*MockCmdable) ZRemRangeByLex added in v0.1.1

func (m *MockCmdable) ZRemRangeByLex(ctx context.Context, key, min, max string) *v8.IntCmd

ZRemRangeByLex mocks base method.

func (*MockCmdable) ZRemRangeByRank added in v0.1.1

func (m *MockCmdable) ZRemRangeByRank(ctx context.Context, key string, start, stop int64) *v8.IntCmd

ZRemRangeByRank mocks base method.

func (*MockCmdable) ZRemRangeByScore added in v0.1.1

func (m *MockCmdable) ZRemRangeByScore(ctx context.Context, key, min, max string) *v8.IntCmd

ZRemRangeByScore mocks base method.

func (*MockCmdable) ZRevRange added in v0.1.1

func (m *MockCmdable) ZRevRange(ctx context.Context, key string, start, stop int64) *v8.StringSliceCmd

ZRevRange mocks base method.

func (*MockCmdable) ZRevRangeByLex added in v0.1.1

func (m *MockCmdable) ZRevRangeByLex(ctx context.Context, key string, opt *v8.ZRangeBy) *v8.StringSliceCmd

ZRevRangeByLex mocks base method.

func (*MockCmdable) ZRevRangeByScore added in v0.1.1

func (m *MockCmdable) ZRevRangeByScore(ctx context.Context, key string, opt *v8.ZRangeBy) *v8.StringSliceCmd

ZRevRangeByScore mocks base method.

func (*MockCmdable) ZRevRangeByScoreWithScores added in v0.1.1

func (m *MockCmdable) ZRevRangeByScoreWithScores(ctx context.Context, key string, opt *v8.ZRangeBy) *v8.ZSliceCmd

ZRevRangeByScoreWithScores mocks base method.

func (*MockCmdable) ZRevRangeWithScores added in v0.1.1

func (m *MockCmdable) ZRevRangeWithScores(ctx context.Context, key string, start, stop int64) *v8.ZSliceCmd

ZRevRangeWithScores mocks base method.

func (*MockCmdable) ZRevRank added in v0.1.1

func (m *MockCmdable) ZRevRank(ctx context.Context, key, member string) *v8.IntCmd

ZRevRank mocks base method.

func (*MockCmdable) ZScan added in v0.1.1

func (m *MockCmdable) ZScan(ctx context.Context, key string, cursor uint64, match string, count int64) *v8.ScanCmd

ZScan mocks base method.

func (*MockCmdable) ZScore added in v0.1.1

func (m *MockCmdable) ZScore(ctx context.Context, key, member string) *v8.FloatCmd

ZScore mocks base method.

func (*MockCmdable) ZUnion added in v0.1.1

func (m *MockCmdable) ZUnion(ctx context.Context, store v8.ZStore) *v8.StringSliceCmd

ZUnion mocks base method.

func (*MockCmdable) ZUnionStore added in v0.1.1

func (m *MockCmdable) ZUnionStore(ctx context.Context, dest string, store *v8.ZStore) *v8.IntCmd

ZUnionStore mocks base method.

func (*MockCmdable) ZUnionWithScores added in v0.1.1

func (m *MockCmdable) ZUnionWithScores(ctx context.Context, store v8.ZStore) *v8.ZSliceCmd

ZUnionWithScores mocks base method.

type MockCmdableMockRecorder added in v0.1.1

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

MockCmdableMockRecorder is the mock recorder for MockCmdable.

func (*MockCmdableMockRecorder) Append added in v0.1.1

func (mr *MockCmdableMockRecorder) Append(ctx, key, value interface{}) *gomock.Call

Append indicates an expected call of Append.

func (*MockCmdableMockRecorder) BLMove added in v0.1.1

func (mr *MockCmdableMockRecorder) BLMove(ctx, source, destination, srcpos, destpos, timeout interface{}) *gomock.Call

BLMove indicates an expected call of BLMove.

func (*MockCmdableMockRecorder) BLPop added in v0.1.1

func (mr *MockCmdableMockRecorder) BLPop(ctx, timeout interface{}, keys ...interface{}) *gomock.Call

BLPop indicates an expected call of BLPop.

func (*MockCmdableMockRecorder) BRPop added in v0.1.1

func (mr *MockCmdableMockRecorder) BRPop(ctx, timeout interface{}, keys ...interface{}) *gomock.Call

BRPop indicates an expected call of BRPop.

func (*MockCmdableMockRecorder) BRPopLPush added in v0.1.1

func (mr *MockCmdableMockRecorder) BRPopLPush(ctx, source, destination, timeout interface{}) *gomock.Call

BRPopLPush indicates an expected call of BRPopLPush.

func (*MockCmdableMockRecorder) BZPopMax added in v0.1.1

func (mr *MockCmdableMockRecorder) BZPopMax(ctx, timeout interface{}, keys ...interface{}) *gomock.Call

BZPopMax indicates an expected call of BZPopMax.

func (*MockCmdableMockRecorder) BZPopMin added in v0.1.1

func (mr *MockCmdableMockRecorder) BZPopMin(ctx, timeout interface{}, keys ...interface{}) *gomock.Call

BZPopMin indicates an expected call of BZPopMin.

func (*MockCmdableMockRecorder) BgRewriteAOF added in v0.1.1

func (mr *MockCmdableMockRecorder) BgRewriteAOF(ctx interface{}) *gomock.Call

BgRewriteAOF indicates an expected call of BgRewriteAOF.

func (*MockCmdableMockRecorder) BgSave added in v0.1.1

func (mr *MockCmdableMockRecorder) BgSave(ctx interface{}) *gomock.Call

BgSave indicates an expected call of BgSave.

func (*MockCmdableMockRecorder) BitCount added in v0.1.1

func (mr *MockCmdableMockRecorder) BitCount(ctx, key, bitCount interface{}) *gomock.Call

BitCount indicates an expected call of BitCount.

func (*MockCmdableMockRecorder) BitField added in v0.1.1

func (mr *MockCmdableMockRecorder) BitField(ctx, key interface{}, args ...interface{}) *gomock.Call

BitField indicates an expected call of BitField.

func (*MockCmdableMockRecorder) BitOpAnd added in v0.1.1

func (mr *MockCmdableMockRecorder) BitOpAnd(ctx, destKey interface{}, keys ...interface{}) *gomock.Call

BitOpAnd indicates an expected call of BitOpAnd.

func (*MockCmdableMockRecorder) BitOpNot added in v0.1.1

func (mr *MockCmdableMockRecorder) BitOpNot(ctx, destKey, key interface{}) *gomock.Call

BitOpNot indicates an expected call of BitOpNot.

func (*MockCmdableMockRecorder) BitOpOr added in v0.1.1

func (mr *MockCmdableMockRecorder) BitOpOr(ctx, destKey interface{}, keys ...interface{}) *gomock.Call

BitOpOr indicates an expected call of BitOpOr.

func (*MockCmdableMockRecorder) BitOpXor added in v0.1.1

func (mr *MockCmdableMockRecorder) BitOpXor(ctx, destKey interface{}, keys ...interface{}) *gomock.Call

BitOpXor indicates an expected call of BitOpXor.

func (*MockCmdableMockRecorder) BitPos added in v0.1.1

func (mr *MockCmdableMockRecorder) BitPos(ctx, key, bit interface{}, pos ...interface{}) *gomock.Call

BitPos indicates an expected call of BitPos.

func (*MockCmdableMockRecorder) ClientGetName added in v0.1.1

func (mr *MockCmdableMockRecorder) ClientGetName(ctx interface{}) *gomock.Call

ClientGetName indicates an expected call of ClientGetName.

func (*MockCmdableMockRecorder) ClientID added in v0.1.1

func (mr *MockCmdableMockRecorder) ClientID(ctx interface{}) *gomock.Call

ClientID indicates an expected call of ClientID.

func (*MockCmdableMockRecorder) ClientKill added in v0.1.1

func (mr *MockCmdableMockRecorder) ClientKill(ctx, ipPort interface{}) *gomock.Call

ClientKill indicates an expected call of ClientKill.

func (*MockCmdableMockRecorder) ClientKillByFilter added in v0.1.1

func (mr *MockCmdableMockRecorder) ClientKillByFilter(ctx interface{}, keys ...interface{}) *gomock.Call

ClientKillByFilter indicates an expected call of ClientKillByFilter.

func (*MockCmdableMockRecorder) ClientList added in v0.1.1

func (mr *MockCmdableMockRecorder) ClientList(ctx interface{}) *gomock.Call

ClientList indicates an expected call of ClientList.

func (*MockCmdableMockRecorder) ClientPause added in v0.1.1

func (mr *MockCmdableMockRecorder) ClientPause(ctx, dur interface{}) *gomock.Call

ClientPause indicates an expected call of ClientPause.

func (*MockCmdableMockRecorder) ClusterAddSlots added in v0.1.1

func (mr *MockCmdableMockRecorder) ClusterAddSlots(ctx interface{}, slots ...interface{}) *gomock.Call

ClusterAddSlots indicates an expected call of ClusterAddSlots.

func (*MockCmdableMockRecorder) ClusterAddSlotsRange added in v0.1.1

func (mr *MockCmdableMockRecorder) ClusterAddSlotsRange(ctx, min, max interface{}) *gomock.Call

ClusterAddSlotsRange indicates an expected call of ClusterAddSlotsRange.

func (*MockCmdableMockRecorder) ClusterCountFailureReports added in v0.1.1

func (mr *MockCmdableMockRecorder) ClusterCountFailureReports(ctx, nodeID interface{}) *gomock.Call

ClusterCountFailureReports indicates an expected call of ClusterCountFailureReports.

func (*MockCmdableMockRecorder) ClusterCountKeysInSlot added in v0.1.1

func (mr *MockCmdableMockRecorder) ClusterCountKeysInSlot(ctx, slot interface{}) *gomock.Call

ClusterCountKeysInSlot indicates an expected call of ClusterCountKeysInSlot.

func (*MockCmdableMockRecorder) ClusterDelSlots added in v0.1.1

func (mr *MockCmdableMockRecorder) ClusterDelSlots(ctx interface{}, slots ...interface{}) *gomock.Call

ClusterDelSlots indicates an expected call of ClusterDelSlots.

func (*MockCmdableMockRecorder) ClusterDelSlotsRange added in v0.1.1

func (mr *MockCmdableMockRecorder) ClusterDelSlotsRange(ctx, min, max interface{}) *gomock.Call

ClusterDelSlotsRange indicates an expected call of ClusterDelSlotsRange.

func (*MockCmdableMockRecorder) ClusterFailover added in v0.1.1

func (mr *MockCmdableMockRecorder) ClusterFailover(ctx interface{}) *gomock.Call

ClusterFailover indicates an expected call of ClusterFailover.

func (*MockCmdableMockRecorder) ClusterForget added in v0.1.1

func (mr *MockCmdableMockRecorder) ClusterForget(ctx, nodeID interface{}) *gomock.Call

ClusterForget indicates an expected call of ClusterForget.

func (*MockCmdableMockRecorder) ClusterGetKeysInSlot added in v0.1.1

func (mr *MockCmdableMockRecorder) ClusterGetKeysInSlot(ctx, slot, count interface{}) *gomock.Call

ClusterGetKeysInSlot indicates an expected call of ClusterGetKeysInSlot.

func (*MockCmdableMockRecorder) ClusterInfo added in v0.1.1

func (mr *MockCmdableMockRecorder) ClusterInfo(ctx interface{}) *gomock.Call

ClusterInfo indicates an expected call of ClusterInfo.

func (*MockCmdableMockRecorder) ClusterKeySlot added in v0.1.1

func (mr *MockCmdableMockRecorder) ClusterKeySlot(ctx, key interface{}) *gomock.Call

ClusterKeySlot indicates an expected call of ClusterKeySlot.

func (*MockCmdableMockRecorder) ClusterMeet added in v0.1.1

func (mr *MockCmdableMockRecorder) ClusterMeet(ctx, host, port interface{}) *gomock.Call

ClusterMeet indicates an expected call of ClusterMeet.

func (*MockCmdableMockRecorder) ClusterNodes added in v0.1.1

func (mr *MockCmdableMockRecorder) ClusterNodes(ctx interface{}) *gomock.Call

ClusterNodes indicates an expected call of ClusterNodes.

func (*MockCmdableMockRecorder) ClusterReplicate added in v0.1.1

func (mr *MockCmdableMockRecorder) ClusterReplicate(ctx, nodeID interface{}) *gomock.Call

ClusterReplicate indicates an expected call of ClusterReplicate.

func (*MockCmdableMockRecorder) ClusterResetHard added in v0.1.1

func (mr *MockCmdableMockRecorder) ClusterResetHard(ctx interface{}) *gomock.Call

ClusterResetHard indicates an expected call of ClusterResetHard.

func (*MockCmdableMockRecorder) ClusterResetSoft added in v0.1.1

func (mr *MockCmdableMockRecorder) ClusterResetSoft(ctx interface{}) *gomock.Call

ClusterResetSoft indicates an expected call of ClusterResetSoft.

func (*MockCmdableMockRecorder) ClusterSaveConfig added in v0.1.1

func (mr *MockCmdableMockRecorder) ClusterSaveConfig(ctx interface{}) *gomock.Call

ClusterSaveConfig indicates an expected call of ClusterSaveConfig.

func (*MockCmdableMockRecorder) ClusterSlaves added in v0.1.1

func (mr *MockCmdableMockRecorder) ClusterSlaves(ctx, nodeID interface{}) *gomock.Call

ClusterSlaves indicates an expected call of ClusterSlaves.

func (*MockCmdableMockRecorder) ClusterSlots added in v0.1.1

func (mr *MockCmdableMockRecorder) ClusterSlots(ctx interface{}) *gomock.Call

ClusterSlots indicates an expected call of ClusterSlots.

func (*MockCmdableMockRecorder) Command added in v0.1.1

func (mr *MockCmdableMockRecorder) Command(ctx interface{}) *gomock.Call

Command indicates an expected call of Command.

func (*MockCmdableMockRecorder) ConfigGet added in v0.1.1

func (mr *MockCmdableMockRecorder) ConfigGet(ctx, parameter interface{}) *gomock.Call

ConfigGet indicates an expected call of ConfigGet.

func (*MockCmdableMockRecorder) ConfigResetStat added in v0.1.1

func (mr *MockCmdableMockRecorder) ConfigResetStat(ctx interface{}) *gomock.Call

ConfigResetStat indicates an expected call of ConfigResetStat.

func (*MockCmdableMockRecorder) ConfigRewrite added in v0.1.1

func (mr *MockCmdableMockRecorder) ConfigRewrite(ctx interface{}) *gomock.Call

ConfigRewrite indicates an expected call of ConfigRewrite.

func (*MockCmdableMockRecorder) ConfigSet added in v0.1.1

func (mr *MockCmdableMockRecorder) ConfigSet(ctx, parameter, value interface{}) *gomock.Call

ConfigSet indicates an expected call of ConfigSet.

func (*MockCmdableMockRecorder) Copy added in v0.1.1

func (mr *MockCmdableMockRecorder) Copy(ctx, sourceKey, destKey, db, replace interface{}) *gomock.Call

Copy indicates an expected call of Copy.

func (*MockCmdableMockRecorder) DBSize added in v0.1.1

func (mr *MockCmdableMockRecorder) DBSize(ctx interface{}) *gomock.Call

DBSize indicates an expected call of DBSize.

func (*MockCmdableMockRecorder) DebugObject added in v0.1.1

func (mr *MockCmdableMockRecorder) DebugObject(ctx, key interface{}) *gomock.Call

DebugObject indicates an expected call of DebugObject.

func (*MockCmdableMockRecorder) Decr added in v0.1.1

func (mr *MockCmdableMockRecorder) Decr(ctx, key interface{}) *gomock.Call

Decr indicates an expected call of Decr.

func (*MockCmdableMockRecorder) DecrBy added in v0.1.1

func (mr *MockCmdableMockRecorder) DecrBy(ctx, key, decrement interface{}) *gomock.Call

DecrBy indicates an expected call of DecrBy.

func (*MockCmdableMockRecorder) Del added in v0.1.1

func (mr *MockCmdableMockRecorder) Del(ctx interface{}, keys ...interface{}) *gomock.Call

Del indicates an expected call of Del.

func (*MockCmdableMockRecorder) Dump added in v0.1.1

func (mr *MockCmdableMockRecorder) Dump(ctx, key interface{}) *gomock.Call

Dump indicates an expected call of Dump.

func (*MockCmdableMockRecorder) Echo added in v0.1.1

func (mr *MockCmdableMockRecorder) Echo(ctx, message interface{}) *gomock.Call

Echo indicates an expected call of Echo.

func (*MockCmdableMockRecorder) Eval added in v0.1.1

func (mr *MockCmdableMockRecorder) Eval(ctx, script, keys interface{}, args ...interface{}) *gomock.Call

Eval indicates an expected call of Eval.

func (*MockCmdableMockRecorder) EvalSha added in v0.1.1

func (mr *MockCmdableMockRecorder) EvalSha(ctx, sha1, keys interface{}, args ...interface{}) *gomock.Call

EvalSha indicates an expected call of EvalSha.

func (*MockCmdableMockRecorder) Exists added in v0.1.1

func (mr *MockCmdableMockRecorder) Exists(ctx interface{}, keys ...interface{}) *gomock.Call

Exists indicates an expected call of Exists.

func (*MockCmdableMockRecorder) Expire added in v0.1.1

func (mr *MockCmdableMockRecorder) Expire(ctx, key, expiration interface{}) *gomock.Call

Expire indicates an expected call of Expire.

func (*MockCmdableMockRecorder) ExpireAt added in v0.1.1

func (mr *MockCmdableMockRecorder) ExpireAt(ctx, key, tm interface{}) *gomock.Call

ExpireAt indicates an expected call of ExpireAt.

func (*MockCmdableMockRecorder) ExpireGT added in v0.1.1

func (mr *MockCmdableMockRecorder) ExpireGT(ctx, key, expiration interface{}) *gomock.Call

ExpireGT indicates an expected call of ExpireGT.

func (*MockCmdableMockRecorder) ExpireLT added in v0.1.1

func (mr *MockCmdableMockRecorder) ExpireLT(ctx, key, expiration interface{}) *gomock.Call

ExpireLT indicates an expected call of ExpireLT.

func (*MockCmdableMockRecorder) ExpireNX added in v0.1.1

func (mr *MockCmdableMockRecorder) ExpireNX(ctx, key, expiration interface{}) *gomock.Call

ExpireNX indicates an expected call of ExpireNX.

func (*MockCmdableMockRecorder) ExpireXX added in v0.1.1

func (mr *MockCmdableMockRecorder) ExpireXX(ctx, key, expiration interface{}) *gomock.Call

ExpireXX indicates an expected call of ExpireXX.

func (*MockCmdableMockRecorder) FlushAll added in v0.1.1

func (mr *MockCmdableMockRecorder) FlushAll(ctx interface{}) *gomock.Call

FlushAll indicates an expected call of FlushAll.

func (*MockCmdableMockRecorder) FlushAllAsync added in v0.1.1

func (mr *MockCmdableMockRecorder) FlushAllAsync(ctx interface{}) *gomock.Call

FlushAllAsync indicates an expected call of FlushAllAsync.

func (*MockCmdableMockRecorder) FlushDB added in v0.1.1

func (mr *MockCmdableMockRecorder) FlushDB(ctx interface{}) *gomock.Call

FlushDB indicates an expected call of FlushDB.

func (*MockCmdableMockRecorder) FlushDBAsync added in v0.1.1

func (mr *MockCmdableMockRecorder) FlushDBAsync(ctx interface{}) *gomock.Call

FlushDBAsync indicates an expected call of FlushDBAsync.

func (*MockCmdableMockRecorder) GeoAdd added in v0.1.1

func (mr *MockCmdableMockRecorder) GeoAdd(ctx, key interface{}, geoLocation ...interface{}) *gomock.Call

GeoAdd indicates an expected call of GeoAdd.

func (*MockCmdableMockRecorder) GeoDist added in v0.1.1

func (mr *MockCmdableMockRecorder) GeoDist(ctx, key, member1, member2, unit interface{}) *gomock.Call

GeoDist indicates an expected call of GeoDist.

func (*MockCmdableMockRecorder) GeoHash added in v0.1.1

func (mr *MockCmdableMockRecorder) GeoHash(ctx, key interface{}, members ...interface{}) *gomock.Call

GeoHash indicates an expected call of GeoHash.

func (*MockCmdableMockRecorder) GeoPos added in v0.1.1

func (mr *MockCmdableMockRecorder) GeoPos(ctx, key interface{}, members ...interface{}) *gomock.Call

GeoPos indicates an expected call of GeoPos.

func (*MockCmdableMockRecorder) GeoRadius added in v0.1.1

func (mr *MockCmdableMockRecorder) GeoRadius(ctx, key, longitude, latitude, query interface{}) *gomock.Call

GeoRadius indicates an expected call of GeoRadius.

func (*MockCmdableMockRecorder) GeoRadiusByMember added in v0.1.1

func (mr *MockCmdableMockRecorder) GeoRadiusByMember(ctx, key, member, query interface{}) *gomock.Call

GeoRadiusByMember indicates an expected call of GeoRadiusByMember.

func (*MockCmdableMockRecorder) GeoRadiusByMemberStore added in v0.1.1

func (mr *MockCmdableMockRecorder) GeoRadiusByMemberStore(ctx, key, member, query interface{}) *gomock.Call

GeoRadiusByMemberStore indicates an expected call of GeoRadiusByMemberStore.

func (*MockCmdableMockRecorder) GeoRadiusStore added in v0.1.1

func (mr *MockCmdableMockRecorder) GeoRadiusStore(ctx, key, longitude, latitude, query interface{}) *gomock.Call

GeoRadiusStore indicates an expected call of GeoRadiusStore.

func (*MockCmdableMockRecorder) GeoSearch added in v0.1.1

func (mr *MockCmdableMockRecorder) GeoSearch(ctx, key, q interface{}) *gomock.Call

GeoSearch indicates an expected call of GeoSearch.

func (*MockCmdableMockRecorder) GeoSearchLocation added in v0.1.1

func (mr *MockCmdableMockRecorder) GeoSearchLocation(ctx, key, q interface{}) *gomock.Call

GeoSearchLocation indicates an expected call of GeoSearchLocation.

func (*MockCmdableMockRecorder) GeoSearchStore added in v0.1.1

func (mr *MockCmdableMockRecorder) GeoSearchStore(ctx, key, store, q interface{}) *gomock.Call

GeoSearchStore indicates an expected call of GeoSearchStore.

func (*MockCmdableMockRecorder) Get added in v0.1.1

func (mr *MockCmdableMockRecorder) Get(ctx, key interface{}) *gomock.Call

Get indicates an expected call of Get.

func (*MockCmdableMockRecorder) GetBit added in v0.1.1

func (mr *MockCmdableMockRecorder) GetBit(ctx, key, offset interface{}) *gomock.Call

GetBit indicates an expected call of GetBit.

func (*MockCmdableMockRecorder) GetDel added in v0.1.1

func (mr *MockCmdableMockRecorder) GetDel(ctx, key interface{}) *gomock.Call

GetDel indicates an expected call of GetDel.

func (*MockCmdableMockRecorder) GetEx added in v0.1.1

func (mr *MockCmdableMockRecorder) GetEx(ctx, key, expiration interface{}) *gomock.Call

GetEx indicates an expected call of GetEx.

func (*MockCmdableMockRecorder) GetRange added in v0.1.1

func (mr *MockCmdableMockRecorder) GetRange(ctx, key, start, end interface{}) *gomock.Call

GetRange indicates an expected call of GetRange.

func (*MockCmdableMockRecorder) GetSet added in v0.1.1

func (mr *MockCmdableMockRecorder) GetSet(ctx, key, value interface{}) *gomock.Call

GetSet indicates an expected call of GetSet.

func (*MockCmdableMockRecorder) HDel added in v0.1.1

func (mr *MockCmdableMockRecorder) HDel(ctx, key interface{}, fields ...interface{}) *gomock.Call

HDel indicates an expected call of HDel.

func (*MockCmdableMockRecorder) HExists added in v0.1.1

func (mr *MockCmdableMockRecorder) HExists(ctx, key, field interface{}) *gomock.Call

HExists indicates an expected call of HExists.

func (*MockCmdableMockRecorder) HGet added in v0.1.1

func (mr *MockCmdableMockRecorder) HGet(ctx, key, field interface{}) *gomock.Call

HGet indicates an expected call of HGet.

func (*MockCmdableMockRecorder) HGetAll added in v0.1.1

func (mr *MockCmdableMockRecorder) HGetAll(ctx, key interface{}) *gomock.Call

HGetAll indicates an expected call of HGetAll.

func (*MockCmdableMockRecorder) HIncrBy added in v0.1.1

func (mr *MockCmdableMockRecorder) HIncrBy(ctx, key, field, incr interface{}) *gomock.Call

HIncrBy indicates an expected call of HIncrBy.

func (*MockCmdableMockRecorder) HIncrByFloat added in v0.1.1

func (mr *MockCmdableMockRecorder) HIncrByFloat(ctx, key, field, incr interface{}) *gomock.Call

HIncrByFloat indicates an expected call of HIncrByFloat.

func (*MockCmdableMockRecorder) HKeys added in v0.1.1

func (mr *MockCmdableMockRecorder) HKeys(ctx, key interface{}) *gomock.Call

HKeys indicates an expected call of HKeys.

func (*MockCmdableMockRecorder) HLen added in v0.1.1

func (mr *MockCmdableMockRecorder) HLen(ctx, key interface{}) *gomock.Call

HLen indicates an expected call of HLen.

func (*MockCmdableMockRecorder) HMGet added in v0.1.1

func (mr *MockCmdableMockRecorder) HMGet(ctx, key interface{}, fields ...interface{}) *gomock.Call

HMGet indicates an expected call of HMGet.

func (*MockCmdableMockRecorder) HMSet added in v0.1.1

func (mr *MockCmdableMockRecorder) HMSet(ctx, key interface{}, values ...interface{}) *gomock.Call

HMSet indicates an expected call of HMSet.

func (*MockCmdableMockRecorder) HRandField added in v0.1.1

func (mr *MockCmdableMockRecorder) HRandField(ctx, key, count, withValues interface{}) *gomock.Call

HRandField indicates an expected call of HRandField.

func (*MockCmdableMockRecorder) HScan added in v0.1.1

func (mr *MockCmdableMockRecorder) HScan(ctx, key, cursor, match, count interface{}) *gomock.Call

HScan indicates an expected call of HScan.

func (*MockCmdableMockRecorder) HSet added in v0.1.1

func (mr *MockCmdableMockRecorder) HSet(ctx, key interface{}, values ...interface{}) *gomock.Call

HSet indicates an expected call of HSet.

func (*MockCmdableMockRecorder) HSetNX added in v0.1.1

func (mr *MockCmdableMockRecorder) HSetNX(ctx, key, field, value interface{}) *gomock.Call

HSetNX indicates an expected call of HSetNX.

func (*MockCmdableMockRecorder) HVals added in v0.1.1

func (mr *MockCmdableMockRecorder) HVals(ctx, key interface{}) *gomock.Call

HVals indicates an expected call of HVals.

func (*MockCmdableMockRecorder) Incr added in v0.1.1

func (mr *MockCmdableMockRecorder) Incr(ctx, key interface{}) *gomock.Call

Incr indicates an expected call of Incr.

func (*MockCmdableMockRecorder) IncrBy added in v0.1.1

func (mr *MockCmdableMockRecorder) IncrBy(ctx, key, value interface{}) *gomock.Call

IncrBy indicates an expected call of IncrBy.

func (*MockCmdableMockRecorder) IncrByFloat added in v0.1.1

func (mr *MockCmdableMockRecorder) IncrByFloat(ctx, key, value interface{}) *gomock.Call

IncrByFloat indicates an expected call of IncrByFloat.

func (*MockCmdableMockRecorder) Info added in v0.1.1

func (mr *MockCmdableMockRecorder) Info(ctx interface{}, section ...interface{}) *gomock.Call

Info indicates an expected call of Info.

func (*MockCmdableMockRecorder) Keys added in v0.1.1

func (mr *MockCmdableMockRecorder) Keys(ctx, pattern interface{}) *gomock.Call

Keys indicates an expected call of Keys.

func (*MockCmdableMockRecorder) LIndex added in v0.1.1

func (mr *MockCmdableMockRecorder) LIndex(ctx, key, index interface{}) *gomock.Call

LIndex indicates an expected call of LIndex.

func (*MockCmdableMockRecorder) LInsert added in v0.1.1

func (mr *MockCmdableMockRecorder) LInsert(ctx, key, op, pivot, value interface{}) *gomock.Call

LInsert indicates an expected call of LInsert.

func (*MockCmdableMockRecorder) LInsertAfter added in v0.1.1

func (mr *MockCmdableMockRecorder) LInsertAfter(ctx, key, pivot, value interface{}) *gomock.Call

LInsertAfter indicates an expected call of LInsertAfter.

func (*MockCmdableMockRecorder) LInsertBefore added in v0.1.1

func (mr *MockCmdableMockRecorder) LInsertBefore(ctx, key, pivot, value interface{}) *gomock.Call

LInsertBefore indicates an expected call of LInsertBefore.

func (*MockCmdableMockRecorder) LLen added in v0.1.1

func (mr *MockCmdableMockRecorder) LLen(ctx, key interface{}) *gomock.Call

LLen indicates an expected call of LLen.

func (*MockCmdableMockRecorder) LMove added in v0.1.1

func (mr *MockCmdableMockRecorder) LMove(ctx, source, destination, srcpos, destpos interface{}) *gomock.Call

LMove indicates an expected call of LMove.

func (*MockCmdableMockRecorder) LPop added in v0.1.1

func (mr *MockCmdableMockRecorder) LPop(ctx, key interface{}) *gomock.Call

LPop indicates an expected call of LPop.

func (*MockCmdableMockRecorder) LPopCount added in v0.1.1

func (mr *MockCmdableMockRecorder) LPopCount(ctx, key, count interface{}) *gomock.Call

LPopCount indicates an expected call of LPopCount.

func (*MockCmdableMockRecorder) LPos added in v0.1.1

func (mr *MockCmdableMockRecorder) LPos(ctx, key, value, args interface{}) *gomock.Call

LPos indicates an expected call of LPos.

func (*MockCmdableMockRecorder) LPosCount added in v0.1.1

func (mr *MockCmdableMockRecorder) LPosCount(ctx, key, value, count, args interface{}) *gomock.Call

LPosCount indicates an expected call of LPosCount.

func (*MockCmdableMockRecorder) LPush added in v0.1.1

func (mr *MockCmdableMockRecorder) LPush(ctx, key interface{}, values ...interface{}) *gomock.Call

LPush indicates an expected call of LPush.

func (*MockCmdableMockRecorder) LPushX added in v0.1.1

func (mr *MockCmdableMockRecorder) LPushX(ctx, key interface{}, values ...interface{}) *gomock.Call

LPushX indicates an expected call of LPushX.

func (*MockCmdableMockRecorder) LRange added in v0.1.1

func (mr *MockCmdableMockRecorder) LRange(ctx, key, start, stop interface{}) *gomock.Call

LRange indicates an expected call of LRange.

func (*MockCmdableMockRecorder) LRem added in v0.1.1

func (mr *MockCmdableMockRecorder) LRem(ctx, key, count, value interface{}) *gomock.Call

LRem indicates an expected call of LRem.

func (*MockCmdableMockRecorder) LSet added in v0.1.1

func (mr *MockCmdableMockRecorder) LSet(ctx, key, index, value interface{}) *gomock.Call

LSet indicates an expected call of LSet.

func (*MockCmdableMockRecorder) LTrim added in v0.1.1

func (mr *MockCmdableMockRecorder) LTrim(ctx, key, start, stop interface{}) *gomock.Call

LTrim indicates an expected call of LTrim.

func (*MockCmdableMockRecorder) LastSave added in v0.1.1

func (mr *MockCmdableMockRecorder) LastSave(ctx interface{}) *gomock.Call

LastSave indicates an expected call of LastSave.

func (*MockCmdableMockRecorder) MGet added in v0.1.1

func (mr *MockCmdableMockRecorder) MGet(ctx interface{}, keys ...interface{}) *gomock.Call

MGet indicates an expected call of MGet.

func (*MockCmdableMockRecorder) MSet added in v0.1.1

func (mr *MockCmdableMockRecorder) MSet(ctx interface{}, values ...interface{}) *gomock.Call

MSet indicates an expected call of MSet.

func (*MockCmdableMockRecorder) MSetNX added in v0.1.1

func (mr *MockCmdableMockRecorder) MSetNX(ctx interface{}, values ...interface{}) *gomock.Call

MSetNX indicates an expected call of MSetNX.

func (*MockCmdableMockRecorder) MemoryUsage added in v0.1.1

func (mr *MockCmdableMockRecorder) MemoryUsage(ctx, key interface{}, samples ...interface{}) *gomock.Call

MemoryUsage indicates an expected call of MemoryUsage.

func (*MockCmdableMockRecorder) Migrate added in v0.1.1

func (mr *MockCmdableMockRecorder) Migrate(ctx, host, port, key, db, timeout interface{}) *gomock.Call

Migrate indicates an expected call of Migrate.

func (*MockCmdableMockRecorder) Move added in v0.1.1

func (mr *MockCmdableMockRecorder) Move(ctx, key, db interface{}) *gomock.Call

Move indicates an expected call of Move.

func (*MockCmdableMockRecorder) ObjectEncoding added in v0.1.1

func (mr *MockCmdableMockRecorder) ObjectEncoding(ctx, key interface{}) *gomock.Call

ObjectEncoding indicates an expected call of ObjectEncoding.

func (*MockCmdableMockRecorder) ObjectIdleTime added in v0.1.1

func (mr *MockCmdableMockRecorder) ObjectIdleTime(ctx, key interface{}) *gomock.Call

ObjectIdleTime indicates an expected call of ObjectIdleTime.

func (*MockCmdableMockRecorder) ObjectRefCount added in v0.1.1

func (mr *MockCmdableMockRecorder) ObjectRefCount(ctx, key interface{}) *gomock.Call

ObjectRefCount indicates an expected call of ObjectRefCount.

func (*MockCmdableMockRecorder) PExpire added in v0.1.1

func (mr *MockCmdableMockRecorder) PExpire(ctx, key, expiration interface{}) *gomock.Call

PExpire indicates an expected call of PExpire.

func (*MockCmdableMockRecorder) PExpireAt added in v0.1.1

func (mr *MockCmdableMockRecorder) PExpireAt(ctx, key, tm interface{}) *gomock.Call

PExpireAt indicates an expected call of PExpireAt.

func (*MockCmdableMockRecorder) PFAdd added in v0.1.1

func (mr *MockCmdableMockRecorder) PFAdd(ctx, key interface{}, els ...interface{}) *gomock.Call

PFAdd indicates an expected call of PFAdd.

func (*MockCmdableMockRecorder) PFCount added in v0.1.1

func (mr *MockCmdableMockRecorder) PFCount(ctx interface{}, keys ...interface{}) *gomock.Call

PFCount indicates an expected call of PFCount.

func (*MockCmdableMockRecorder) PFMerge added in v0.1.1

func (mr *MockCmdableMockRecorder) PFMerge(ctx, dest interface{}, keys ...interface{}) *gomock.Call

PFMerge indicates an expected call of PFMerge.

func (*MockCmdableMockRecorder) PTTL added in v0.1.1

func (mr *MockCmdableMockRecorder) PTTL(ctx, key interface{}) *gomock.Call

PTTL indicates an expected call of PTTL.

func (*MockCmdableMockRecorder) Persist added in v0.1.1

func (mr *MockCmdableMockRecorder) Persist(ctx, key interface{}) *gomock.Call

Persist indicates an expected call of Persist.

func (*MockCmdableMockRecorder) Ping added in v0.1.1

func (mr *MockCmdableMockRecorder) Ping(ctx interface{}) *gomock.Call

Ping indicates an expected call of Ping.

func (*MockCmdableMockRecorder) Pipeline added in v0.1.1

func (mr *MockCmdableMockRecorder) Pipeline() *gomock.Call

Pipeline indicates an expected call of Pipeline.

func (*MockCmdableMockRecorder) Pipelined added in v0.1.1

func (mr *MockCmdableMockRecorder) Pipelined(ctx, fn interface{}) *gomock.Call

Pipelined indicates an expected call of Pipelined.

func (*MockCmdableMockRecorder) PubSubChannels added in v0.1.1

func (mr *MockCmdableMockRecorder) PubSubChannels(ctx, pattern interface{}) *gomock.Call

PubSubChannels indicates an expected call of PubSubChannels.

func (*MockCmdableMockRecorder) PubSubNumPat added in v0.1.1

func (mr *MockCmdableMockRecorder) PubSubNumPat(ctx interface{}) *gomock.Call

PubSubNumPat indicates an expected call of PubSubNumPat.

func (*MockCmdableMockRecorder) PubSubNumSub added in v0.1.1

func (mr *MockCmdableMockRecorder) PubSubNumSub(ctx interface{}, channels ...interface{}) *gomock.Call

PubSubNumSub indicates an expected call of PubSubNumSub.

func (*MockCmdableMockRecorder) Publish added in v0.1.1

func (mr *MockCmdableMockRecorder) Publish(ctx, channel, message interface{}) *gomock.Call

Publish indicates an expected call of Publish.

func (*MockCmdableMockRecorder) Quit added in v0.1.1

func (mr *MockCmdableMockRecorder) Quit(ctx interface{}) *gomock.Call

Quit indicates an expected call of Quit.

func (*MockCmdableMockRecorder) RPop added in v0.1.1

func (mr *MockCmdableMockRecorder) RPop(ctx, key interface{}) *gomock.Call

RPop indicates an expected call of RPop.

func (*MockCmdableMockRecorder) RPopCount added in v0.1.1

func (mr *MockCmdableMockRecorder) RPopCount(ctx, key, count interface{}) *gomock.Call

RPopCount indicates an expected call of RPopCount.

func (*MockCmdableMockRecorder) RPopLPush added in v0.1.1

func (mr *MockCmdableMockRecorder) RPopLPush(ctx, source, destination interface{}) *gomock.Call

RPopLPush indicates an expected call of RPopLPush.

func (*MockCmdableMockRecorder) RPush added in v0.1.1

func (mr *MockCmdableMockRecorder) RPush(ctx, key interface{}, values ...interface{}) *gomock.Call

RPush indicates an expected call of RPush.

func (*MockCmdableMockRecorder) RPushX added in v0.1.1

func (mr *MockCmdableMockRecorder) RPushX(ctx, key interface{}, values ...interface{}) *gomock.Call

RPushX indicates an expected call of RPushX.

func (*MockCmdableMockRecorder) RandomKey added in v0.1.1

func (mr *MockCmdableMockRecorder) RandomKey(ctx interface{}) *gomock.Call

RandomKey indicates an expected call of RandomKey.

func (*MockCmdableMockRecorder) ReadOnly added in v0.1.1

func (mr *MockCmdableMockRecorder) ReadOnly(ctx interface{}) *gomock.Call

ReadOnly indicates an expected call of ReadOnly.

func (*MockCmdableMockRecorder) ReadWrite added in v0.1.1

func (mr *MockCmdableMockRecorder) ReadWrite(ctx interface{}) *gomock.Call

ReadWrite indicates an expected call of ReadWrite.

func (*MockCmdableMockRecorder) Rename added in v0.1.1

func (mr *MockCmdableMockRecorder) Rename(ctx, key, newkey interface{}) *gomock.Call

Rename indicates an expected call of Rename.

func (*MockCmdableMockRecorder) RenameNX added in v0.1.1

func (mr *MockCmdableMockRecorder) RenameNX(ctx, key, newkey interface{}) *gomock.Call

RenameNX indicates an expected call of RenameNX.

func (*MockCmdableMockRecorder) Restore added in v0.1.1

func (mr *MockCmdableMockRecorder) Restore(ctx, key, ttl, value interface{}) *gomock.Call

Restore indicates an expected call of Restore.

func (*MockCmdableMockRecorder) RestoreReplace added in v0.1.1

func (mr *MockCmdableMockRecorder) RestoreReplace(ctx, key, ttl, value interface{}) *gomock.Call

RestoreReplace indicates an expected call of RestoreReplace.

func (*MockCmdableMockRecorder) SAdd added in v0.1.1

func (mr *MockCmdableMockRecorder) SAdd(ctx, key interface{}, members ...interface{}) *gomock.Call

SAdd indicates an expected call of SAdd.

func (*MockCmdableMockRecorder) SCard added in v0.1.1

func (mr *MockCmdableMockRecorder) SCard(ctx, key interface{}) *gomock.Call

SCard indicates an expected call of SCard.

func (*MockCmdableMockRecorder) SDiff added in v0.1.1

func (mr *MockCmdableMockRecorder) SDiff(ctx interface{}, keys ...interface{}) *gomock.Call

SDiff indicates an expected call of SDiff.

func (*MockCmdableMockRecorder) SDiffStore added in v0.1.1

func (mr *MockCmdableMockRecorder) SDiffStore(ctx, destination interface{}, keys ...interface{}) *gomock.Call

SDiffStore indicates an expected call of SDiffStore.

func (*MockCmdableMockRecorder) SInter added in v0.1.1

func (mr *MockCmdableMockRecorder) SInter(ctx interface{}, keys ...interface{}) *gomock.Call

SInter indicates an expected call of SInter.

func (*MockCmdableMockRecorder) SInterStore added in v0.1.1

func (mr *MockCmdableMockRecorder) SInterStore(ctx, destination interface{}, keys ...interface{}) *gomock.Call

SInterStore indicates an expected call of SInterStore.

func (*MockCmdableMockRecorder) SIsMember added in v0.1.1

func (mr *MockCmdableMockRecorder) SIsMember(ctx, key, member interface{}) *gomock.Call

SIsMember indicates an expected call of SIsMember.

func (*MockCmdableMockRecorder) SMIsMember added in v0.1.1

func (mr *MockCmdableMockRecorder) SMIsMember(ctx, key interface{}, members ...interface{}) *gomock.Call

SMIsMember indicates an expected call of SMIsMember.

func (*MockCmdableMockRecorder) SMembers added in v0.1.1

func (mr *MockCmdableMockRecorder) SMembers(ctx, key interface{}) *gomock.Call

SMembers indicates an expected call of SMembers.

func (*MockCmdableMockRecorder) SMembersMap added in v0.1.1

func (mr *MockCmdableMockRecorder) SMembersMap(ctx, key interface{}) *gomock.Call

SMembersMap indicates an expected call of SMembersMap.

func (*MockCmdableMockRecorder) SMove added in v0.1.1

func (mr *MockCmdableMockRecorder) SMove(ctx, source, destination, member interface{}) *gomock.Call

SMove indicates an expected call of SMove.

func (*MockCmdableMockRecorder) SPop added in v0.1.1

func (mr *MockCmdableMockRecorder) SPop(ctx, key interface{}) *gomock.Call

SPop indicates an expected call of SPop.

func (*MockCmdableMockRecorder) SPopN added in v0.1.1

func (mr *MockCmdableMockRecorder) SPopN(ctx, key, count interface{}) *gomock.Call

SPopN indicates an expected call of SPopN.

func (*MockCmdableMockRecorder) SRandMember added in v0.1.1

func (mr *MockCmdableMockRecorder) SRandMember(ctx, key interface{}) *gomock.Call

SRandMember indicates an expected call of SRandMember.

func (*MockCmdableMockRecorder) SRandMemberN added in v0.1.1

func (mr *MockCmdableMockRecorder) SRandMemberN(ctx, key, count interface{}) *gomock.Call

SRandMemberN indicates an expected call of SRandMemberN.

func (*MockCmdableMockRecorder) SRem added in v0.1.1

func (mr *MockCmdableMockRecorder) SRem(ctx, key interface{}, members ...interface{}) *gomock.Call

SRem indicates an expected call of SRem.

func (*MockCmdableMockRecorder) SScan added in v0.1.1

func (mr *MockCmdableMockRecorder) SScan(ctx, key, cursor, match, count interface{}) *gomock.Call

SScan indicates an expected call of SScan.

func (*MockCmdableMockRecorder) SUnion added in v0.1.1

func (mr *MockCmdableMockRecorder) SUnion(ctx interface{}, keys ...interface{}) *gomock.Call

SUnion indicates an expected call of SUnion.

func (*MockCmdableMockRecorder) SUnionStore added in v0.1.1

func (mr *MockCmdableMockRecorder) SUnionStore(ctx, destination interface{}, keys ...interface{}) *gomock.Call

SUnionStore indicates an expected call of SUnionStore.

func (*MockCmdableMockRecorder) Save added in v0.1.1

func (mr *MockCmdableMockRecorder) Save(ctx interface{}) *gomock.Call

Save indicates an expected call of Save.

func (*MockCmdableMockRecorder) Scan added in v0.1.1

func (mr *MockCmdableMockRecorder) Scan(ctx, cursor, match, count interface{}) *gomock.Call

Scan indicates an expected call of Scan.

func (*MockCmdableMockRecorder) ScanType added in v0.1.1

func (mr *MockCmdableMockRecorder) ScanType(ctx, cursor, match, count, keyType interface{}) *gomock.Call

ScanType indicates an expected call of ScanType.

func (*MockCmdableMockRecorder) ScriptExists added in v0.1.1

func (mr *MockCmdableMockRecorder) ScriptExists(ctx interface{}, hashes ...interface{}) *gomock.Call

ScriptExists indicates an expected call of ScriptExists.

func (*MockCmdableMockRecorder) ScriptFlush added in v0.1.1

func (mr *MockCmdableMockRecorder) ScriptFlush(ctx interface{}) *gomock.Call

ScriptFlush indicates an expected call of ScriptFlush.

func (*MockCmdableMockRecorder) ScriptKill added in v0.1.1

func (mr *MockCmdableMockRecorder) ScriptKill(ctx interface{}) *gomock.Call

ScriptKill indicates an expected call of ScriptKill.

func (*MockCmdableMockRecorder) ScriptLoad added in v0.1.1

func (mr *MockCmdableMockRecorder) ScriptLoad(ctx, script interface{}) *gomock.Call

ScriptLoad indicates an expected call of ScriptLoad.

func (*MockCmdableMockRecorder) Set added in v0.1.1

func (mr *MockCmdableMockRecorder) Set(ctx, key, value, expiration interface{}) *gomock.Call

Set indicates an expected call of Set.

func (*MockCmdableMockRecorder) SetArgs added in v0.1.1

func (mr *MockCmdableMockRecorder) SetArgs(ctx, key, value, a interface{}) *gomock.Call

SetArgs indicates an expected call of SetArgs.

func (*MockCmdableMockRecorder) SetBit added in v0.1.1

func (mr *MockCmdableMockRecorder) SetBit(ctx, key, offset, value interface{}) *gomock.Call

SetBit indicates an expected call of SetBit.

func (*MockCmdableMockRecorder) SetEX added in v0.1.1

func (mr *MockCmdableMockRecorder) SetEX(ctx, key, value, expiration interface{}) *gomock.Call

SetEX indicates an expected call of SetEX.

func (*MockCmdableMockRecorder) SetNX added in v0.1.1

func (mr *MockCmdableMockRecorder) SetNX(ctx, key, value, expiration interface{}) *gomock.Call

SetNX indicates an expected call of SetNX.

func (*MockCmdableMockRecorder) SetRange added in v0.1.1

func (mr *MockCmdableMockRecorder) SetRange(ctx, key, offset, value interface{}) *gomock.Call

SetRange indicates an expected call of SetRange.

func (*MockCmdableMockRecorder) SetXX added in v0.1.1

func (mr *MockCmdableMockRecorder) SetXX(ctx, key, value, expiration interface{}) *gomock.Call

SetXX indicates an expected call of SetXX.

func (*MockCmdableMockRecorder) Shutdown added in v0.1.1

func (mr *MockCmdableMockRecorder) Shutdown(ctx interface{}) *gomock.Call

Shutdown indicates an expected call of Shutdown.

func (*MockCmdableMockRecorder) ShutdownNoSave added in v0.1.1

func (mr *MockCmdableMockRecorder) ShutdownNoSave(ctx interface{}) *gomock.Call

ShutdownNoSave indicates an expected call of ShutdownNoSave.

func (*MockCmdableMockRecorder) ShutdownSave added in v0.1.1

func (mr *MockCmdableMockRecorder) ShutdownSave(ctx interface{}) *gomock.Call

ShutdownSave indicates an expected call of ShutdownSave.

func (*MockCmdableMockRecorder) SlaveOf added in v0.1.1

func (mr *MockCmdableMockRecorder) SlaveOf(ctx, host, port interface{}) *gomock.Call

SlaveOf indicates an expected call of SlaveOf.

func (*MockCmdableMockRecorder) Sort added in v0.1.1

func (mr *MockCmdableMockRecorder) Sort(ctx, key, sort interface{}) *gomock.Call

Sort indicates an expected call of Sort.

func (*MockCmdableMockRecorder) SortInterfaces added in v0.1.1

func (mr *MockCmdableMockRecorder) SortInterfaces(ctx, key, sort interface{}) *gomock.Call

SortInterfaces indicates an expected call of SortInterfaces.

func (*MockCmdableMockRecorder) SortStore added in v0.1.1

func (mr *MockCmdableMockRecorder) SortStore(ctx, key, store, sort interface{}) *gomock.Call

SortStore indicates an expected call of SortStore.

func (*MockCmdableMockRecorder) StrLen added in v0.1.1

func (mr *MockCmdableMockRecorder) StrLen(ctx, key interface{}) *gomock.Call

StrLen indicates an expected call of StrLen.

func (*MockCmdableMockRecorder) TTL added in v0.1.1

func (mr *MockCmdableMockRecorder) TTL(ctx, key interface{}) *gomock.Call

TTL indicates an expected call of TTL.

func (*MockCmdableMockRecorder) Time added in v0.1.1

func (mr *MockCmdableMockRecorder) Time(ctx interface{}) *gomock.Call

Time indicates an expected call of Time.

func (*MockCmdableMockRecorder) Touch added in v0.1.1

func (mr *MockCmdableMockRecorder) Touch(ctx interface{}, keys ...interface{}) *gomock.Call

Touch indicates an expected call of Touch.

func (*MockCmdableMockRecorder) TxPipeline added in v0.1.1

func (mr *MockCmdableMockRecorder) TxPipeline() *gomock.Call

TxPipeline indicates an expected call of TxPipeline.

func (*MockCmdableMockRecorder) TxPipelined added in v0.1.1

func (mr *MockCmdableMockRecorder) TxPipelined(ctx, fn interface{}) *gomock.Call

TxPipelined indicates an expected call of TxPipelined.

func (*MockCmdableMockRecorder) Type added in v0.1.1

func (mr *MockCmdableMockRecorder) Type(ctx, key interface{}) *gomock.Call

Type indicates an expected call of Type.

func (mr *MockCmdableMockRecorder) Unlink(ctx interface{}, keys ...interface{}) *gomock.Call

Unlink indicates an expected call of Unlink.

func (*MockCmdableMockRecorder) XAck added in v0.1.1

func (mr *MockCmdableMockRecorder) XAck(ctx, stream, group interface{}, ids ...interface{}) *gomock.Call

XAck indicates an expected call of XAck.

func (*MockCmdableMockRecorder) XAdd added in v0.1.1

func (mr *MockCmdableMockRecorder) XAdd(ctx, a interface{}) *gomock.Call

XAdd indicates an expected call of XAdd.

func (*MockCmdableMockRecorder) XAutoClaim added in v0.1.1

func (mr *MockCmdableMockRecorder) XAutoClaim(ctx, a interface{}) *gomock.Call

XAutoClaim indicates an expected call of XAutoClaim.

func (*MockCmdableMockRecorder) XAutoClaimJustID added in v0.1.1

func (mr *MockCmdableMockRecorder) XAutoClaimJustID(ctx, a interface{}) *gomock.Call

XAutoClaimJustID indicates an expected call of XAutoClaimJustID.

func (*MockCmdableMockRecorder) XClaim added in v0.1.1

func (mr *MockCmdableMockRecorder) XClaim(ctx, a interface{}) *gomock.Call

XClaim indicates an expected call of XClaim.

func (*MockCmdableMockRecorder) XClaimJustID added in v0.1.1

func (mr *MockCmdableMockRecorder) XClaimJustID(ctx, a interface{}) *gomock.Call

XClaimJustID indicates an expected call of XClaimJustID.

func (*MockCmdableMockRecorder) XDel added in v0.1.1

func (mr *MockCmdableMockRecorder) XDel(ctx, stream interface{}, ids ...interface{}) *gomock.Call

XDel indicates an expected call of XDel.

func (*MockCmdableMockRecorder) XGroupCreate added in v0.1.1

func (mr *MockCmdableMockRecorder) XGroupCreate(ctx, stream, group, start interface{}) *gomock.Call

XGroupCreate indicates an expected call of XGroupCreate.

func (*MockCmdableMockRecorder) XGroupCreateConsumer added in v0.1.1

func (mr *MockCmdableMockRecorder) XGroupCreateConsumer(ctx, stream, group, consumer interface{}) *gomock.Call

XGroupCreateConsumer indicates an expected call of XGroupCreateConsumer.

func (*MockCmdableMockRecorder) XGroupCreateMkStream added in v0.1.1

func (mr *MockCmdableMockRecorder) XGroupCreateMkStream(ctx, stream, group, start interface{}) *gomock.Call

XGroupCreateMkStream indicates an expected call of XGroupCreateMkStream.

func (*MockCmdableMockRecorder) XGroupDelConsumer added in v0.1.1

func (mr *MockCmdableMockRecorder) XGroupDelConsumer(ctx, stream, group, consumer interface{}) *gomock.Call

XGroupDelConsumer indicates an expected call of XGroupDelConsumer.

func (*MockCmdableMockRecorder) XGroupDestroy added in v0.1.1

func (mr *MockCmdableMockRecorder) XGroupDestroy(ctx, stream, group interface{}) *gomock.Call

XGroupDestroy indicates an expected call of XGroupDestroy.

func (*MockCmdableMockRecorder) XGroupSetID added in v0.1.1

func (mr *MockCmdableMockRecorder) XGroupSetID(ctx, stream, group, start interface{}) *gomock.Call

XGroupSetID indicates an expected call of XGroupSetID.

func (*MockCmdableMockRecorder) XInfoConsumers added in v0.1.1

func (mr *MockCmdableMockRecorder) XInfoConsumers(ctx, key, group interface{}) *gomock.Call

XInfoConsumers indicates an expected call of XInfoConsumers.

func (*MockCmdableMockRecorder) XInfoGroups added in v0.1.1

func (mr *MockCmdableMockRecorder) XInfoGroups(ctx, key interface{}) *gomock.Call

XInfoGroups indicates an expected call of XInfoGroups.

func (*MockCmdableMockRecorder) XInfoStream added in v0.1.1

func (mr *MockCmdableMockRecorder) XInfoStream(ctx, key interface{}) *gomock.Call

XInfoStream indicates an expected call of XInfoStream.

func (*MockCmdableMockRecorder) XInfoStreamFull added in v0.1.1

func (mr *MockCmdableMockRecorder) XInfoStreamFull(ctx, key, count interface{}) *gomock.Call

XInfoStreamFull indicates an expected call of XInfoStreamFull.

func (*MockCmdableMockRecorder) XLen added in v0.1.1

func (mr *MockCmdableMockRecorder) XLen(ctx, stream interface{}) *gomock.Call

XLen indicates an expected call of XLen.

func (*MockCmdableMockRecorder) XPending added in v0.1.1

func (mr *MockCmdableMockRecorder) XPending(ctx, stream, group interface{}) *gomock.Call

XPending indicates an expected call of XPending.

func (*MockCmdableMockRecorder) XPendingExt added in v0.1.1

func (mr *MockCmdableMockRecorder) XPendingExt(ctx, a interface{}) *gomock.Call

XPendingExt indicates an expected call of XPendingExt.

func (*MockCmdableMockRecorder) XRange added in v0.1.1

func (mr *MockCmdableMockRecorder) XRange(ctx, stream, start, stop interface{}) *gomock.Call

XRange indicates an expected call of XRange.

func (*MockCmdableMockRecorder) XRangeN added in v0.1.1

func (mr *MockCmdableMockRecorder) XRangeN(ctx, stream, start, stop, count interface{}) *gomock.Call

XRangeN indicates an expected call of XRangeN.

func (*MockCmdableMockRecorder) XRead added in v0.1.1

func (mr *MockCmdableMockRecorder) XRead(ctx, a interface{}) *gomock.Call

XRead indicates an expected call of XRead.

func (*MockCmdableMockRecorder) XReadGroup added in v0.1.1

func (mr *MockCmdableMockRecorder) XReadGroup(ctx, a interface{}) *gomock.Call

XReadGroup indicates an expected call of XReadGroup.

func (*MockCmdableMockRecorder) XReadStreams added in v0.1.1

func (mr *MockCmdableMockRecorder) XReadStreams(ctx interface{}, streams ...interface{}) *gomock.Call

XReadStreams indicates an expected call of XReadStreams.

func (*MockCmdableMockRecorder) XRevRange added in v0.1.1

func (mr *MockCmdableMockRecorder) XRevRange(ctx, stream, start, stop interface{}) *gomock.Call

XRevRange indicates an expected call of XRevRange.

func (*MockCmdableMockRecorder) XRevRangeN added in v0.1.1

func (mr *MockCmdableMockRecorder) XRevRangeN(ctx, stream, start, stop, count interface{}) *gomock.Call

XRevRangeN indicates an expected call of XRevRangeN.

func (*MockCmdableMockRecorder) XTrim added in v0.1.1

func (mr *MockCmdableMockRecorder) XTrim(ctx, key, maxLen interface{}) *gomock.Call

XTrim indicates an expected call of XTrim.

func (*MockCmdableMockRecorder) XTrimApprox added in v0.1.1

func (mr *MockCmdableMockRecorder) XTrimApprox(ctx, key, maxLen interface{}) *gomock.Call

XTrimApprox indicates an expected call of XTrimApprox.

func (*MockCmdableMockRecorder) XTrimMaxLen added in v0.1.1

func (mr *MockCmdableMockRecorder) XTrimMaxLen(ctx, key, maxLen interface{}) *gomock.Call

XTrimMaxLen indicates an expected call of XTrimMaxLen.

func (*MockCmdableMockRecorder) XTrimMaxLenApprox added in v0.1.1

func (mr *MockCmdableMockRecorder) XTrimMaxLenApprox(ctx, key, maxLen, limit interface{}) *gomock.Call

XTrimMaxLenApprox indicates an expected call of XTrimMaxLenApprox.

func (*MockCmdableMockRecorder) XTrimMinID added in v0.1.1

func (mr *MockCmdableMockRecorder) XTrimMinID(ctx, key, minID interface{}) *gomock.Call

XTrimMinID indicates an expected call of XTrimMinID.

func (*MockCmdableMockRecorder) XTrimMinIDApprox added in v0.1.1

func (mr *MockCmdableMockRecorder) XTrimMinIDApprox(ctx, key, minID, limit interface{}) *gomock.Call

XTrimMinIDApprox indicates an expected call of XTrimMinIDApprox.

func (*MockCmdableMockRecorder) ZAdd added in v0.1.1

func (mr *MockCmdableMockRecorder) ZAdd(ctx, key interface{}, members ...interface{}) *gomock.Call

ZAdd indicates an expected call of ZAdd.

func (*MockCmdableMockRecorder) ZAddArgs added in v0.1.1

func (mr *MockCmdableMockRecorder) ZAddArgs(ctx, key, args interface{}) *gomock.Call

ZAddArgs indicates an expected call of ZAddArgs.

func (*MockCmdableMockRecorder) ZAddArgsIncr added in v0.1.1

func (mr *MockCmdableMockRecorder) ZAddArgsIncr(ctx, key, args interface{}) *gomock.Call

ZAddArgsIncr indicates an expected call of ZAddArgsIncr.

func (*MockCmdableMockRecorder) ZAddCh added in v0.1.1

func (mr *MockCmdableMockRecorder) ZAddCh(ctx, key interface{}, members ...interface{}) *gomock.Call

ZAddCh indicates an expected call of ZAddCh.

func (*MockCmdableMockRecorder) ZAddNX added in v0.1.1

func (mr *MockCmdableMockRecorder) ZAddNX(ctx, key interface{}, members ...interface{}) *gomock.Call

ZAddNX indicates an expected call of ZAddNX.

func (*MockCmdableMockRecorder) ZAddNXCh added in v0.1.1

func (mr *MockCmdableMockRecorder) ZAddNXCh(ctx, key interface{}, members ...interface{}) *gomock.Call

ZAddNXCh indicates an expected call of ZAddNXCh.

func (*MockCmdableMockRecorder) ZAddXX added in v0.1.1

func (mr *MockCmdableMockRecorder) ZAddXX(ctx, key interface{}, members ...interface{}) *gomock.Call

ZAddXX indicates an expected call of ZAddXX.

func (*MockCmdableMockRecorder) ZAddXXCh added in v0.1.1

func (mr *MockCmdableMockRecorder) ZAddXXCh(ctx, key interface{}, members ...interface{}) *gomock.Call

ZAddXXCh indicates an expected call of ZAddXXCh.

func (*MockCmdableMockRecorder) ZCard added in v0.1.1

func (mr *MockCmdableMockRecorder) ZCard(ctx, key interface{}) *gomock.Call

ZCard indicates an expected call of ZCard.

func (*MockCmdableMockRecorder) ZCount added in v0.1.1

func (mr *MockCmdableMockRecorder) ZCount(ctx, key, min, max interface{}) *gomock.Call

ZCount indicates an expected call of ZCount.

func (*MockCmdableMockRecorder) ZDiff added in v0.1.1

func (mr *MockCmdableMockRecorder) ZDiff(ctx interface{}, keys ...interface{}) *gomock.Call

ZDiff indicates an expected call of ZDiff.

func (*MockCmdableMockRecorder) ZDiffStore added in v0.1.1

func (mr *MockCmdableMockRecorder) ZDiffStore(ctx, destination interface{}, keys ...interface{}) *gomock.Call

ZDiffStore indicates an expected call of ZDiffStore.

func (*MockCmdableMockRecorder) ZDiffWithScores added in v0.1.1

func (mr *MockCmdableMockRecorder) ZDiffWithScores(ctx interface{}, keys ...interface{}) *gomock.Call

ZDiffWithScores indicates an expected call of ZDiffWithScores.

func (*MockCmdableMockRecorder) ZIncr added in v0.1.1

func (mr *MockCmdableMockRecorder) ZIncr(ctx, key, member interface{}) *gomock.Call

ZIncr indicates an expected call of ZIncr.

func (*MockCmdableMockRecorder) ZIncrBy added in v0.1.1

func (mr *MockCmdableMockRecorder) ZIncrBy(ctx, key, increment, member interface{}) *gomock.Call

ZIncrBy indicates an expected call of ZIncrBy.

func (*MockCmdableMockRecorder) ZIncrNX added in v0.1.1

func (mr *MockCmdableMockRecorder) ZIncrNX(ctx, key, member interface{}) *gomock.Call

ZIncrNX indicates an expected call of ZIncrNX.

func (*MockCmdableMockRecorder) ZIncrXX added in v0.1.1

func (mr *MockCmdableMockRecorder) ZIncrXX(ctx, key, member interface{}) *gomock.Call

ZIncrXX indicates an expected call of ZIncrXX.

func (*MockCmdableMockRecorder) ZInter added in v0.1.1

func (mr *MockCmdableMockRecorder) ZInter(ctx, store interface{}) *gomock.Call

ZInter indicates an expected call of ZInter.

func (*MockCmdableMockRecorder) ZInterStore added in v0.1.1

func (mr *MockCmdableMockRecorder) ZInterStore(ctx, destination, store interface{}) *gomock.Call

ZInterStore indicates an expected call of ZInterStore.

func (*MockCmdableMockRecorder) ZInterWithScores added in v0.1.1

func (mr *MockCmdableMockRecorder) ZInterWithScores(ctx, store interface{}) *gomock.Call

ZInterWithScores indicates an expected call of ZInterWithScores.

func (*MockCmdableMockRecorder) ZLexCount added in v0.1.1

func (mr *MockCmdableMockRecorder) ZLexCount(ctx, key, min, max interface{}) *gomock.Call

ZLexCount indicates an expected call of ZLexCount.

func (*MockCmdableMockRecorder) ZMScore added in v0.1.1

func (mr *MockCmdableMockRecorder) ZMScore(ctx, key interface{}, members ...interface{}) *gomock.Call

ZMScore indicates an expected call of ZMScore.

func (*MockCmdableMockRecorder) ZPopMax added in v0.1.1

func (mr *MockCmdableMockRecorder) ZPopMax(ctx, key interface{}, count ...interface{}) *gomock.Call

ZPopMax indicates an expected call of ZPopMax.

func (*MockCmdableMockRecorder) ZPopMin added in v0.1.1

func (mr *MockCmdableMockRecorder) ZPopMin(ctx, key interface{}, count ...interface{}) *gomock.Call

ZPopMin indicates an expected call of ZPopMin.

func (*MockCmdableMockRecorder) ZRandMember added in v0.1.1

func (mr *MockCmdableMockRecorder) ZRandMember(ctx, key, count, withScores interface{}) *gomock.Call

ZRandMember indicates an expected call of ZRandMember.

func (*MockCmdableMockRecorder) ZRange added in v0.1.1

func (mr *MockCmdableMockRecorder) ZRange(ctx, key, start, stop interface{}) *gomock.Call

ZRange indicates an expected call of ZRange.

func (*MockCmdableMockRecorder) ZRangeArgs added in v0.1.1

func (mr *MockCmdableMockRecorder) ZRangeArgs(ctx, z interface{}) *gomock.Call

ZRangeArgs indicates an expected call of ZRangeArgs.

func (*MockCmdableMockRecorder) ZRangeArgsWithScores added in v0.1.1

func (mr *MockCmdableMockRecorder) ZRangeArgsWithScores(ctx, z interface{}) *gomock.Call

ZRangeArgsWithScores indicates an expected call of ZRangeArgsWithScores.

func (*MockCmdableMockRecorder) ZRangeByLex added in v0.1.1

func (mr *MockCmdableMockRecorder) ZRangeByLex(ctx, key, opt interface{}) *gomock.Call

ZRangeByLex indicates an expected call of ZRangeByLex.

func (*MockCmdableMockRecorder) ZRangeByScore added in v0.1.1

func (mr *MockCmdableMockRecorder) ZRangeByScore(ctx, key, opt interface{}) *gomock.Call

ZRangeByScore indicates an expected call of ZRangeByScore.

func (*MockCmdableMockRecorder) ZRangeByScoreWithScores added in v0.1.1

func (mr *MockCmdableMockRecorder) ZRangeByScoreWithScores(ctx, key, opt interface{}) *gomock.Call

ZRangeByScoreWithScores indicates an expected call of ZRangeByScoreWithScores.

func (*MockCmdableMockRecorder) ZRangeStore added in v0.1.1

func (mr *MockCmdableMockRecorder) ZRangeStore(ctx, dst, z interface{}) *gomock.Call

ZRangeStore indicates an expected call of ZRangeStore.

func (*MockCmdableMockRecorder) ZRangeWithScores added in v0.1.1

func (mr *MockCmdableMockRecorder) ZRangeWithScores(ctx, key, start, stop interface{}) *gomock.Call

ZRangeWithScores indicates an expected call of ZRangeWithScores.

func (*MockCmdableMockRecorder) ZRank added in v0.1.1

func (mr *MockCmdableMockRecorder) ZRank(ctx, key, member interface{}) *gomock.Call

ZRank indicates an expected call of ZRank.

func (*MockCmdableMockRecorder) ZRem added in v0.1.1

func (mr *MockCmdableMockRecorder) ZRem(ctx, key interface{}, members ...interface{}) *gomock.Call

ZRem indicates an expected call of ZRem.

func (*MockCmdableMockRecorder) ZRemRangeByLex added in v0.1.1

func (mr *MockCmdableMockRecorder) ZRemRangeByLex(ctx, key, min, max interface{}) *gomock.Call

ZRemRangeByLex indicates an expected call of ZRemRangeByLex.

func (*MockCmdableMockRecorder) ZRemRangeByRank added in v0.1.1

func (mr *MockCmdableMockRecorder) ZRemRangeByRank(ctx, key, start, stop interface{}) *gomock.Call

ZRemRangeByRank indicates an expected call of ZRemRangeByRank.

func (*MockCmdableMockRecorder) ZRemRangeByScore added in v0.1.1

func (mr *MockCmdableMockRecorder) ZRemRangeByScore(ctx, key, min, max interface{}) *gomock.Call

ZRemRangeByScore indicates an expected call of ZRemRangeByScore.

func (*MockCmdableMockRecorder) ZRevRange added in v0.1.1

func (mr *MockCmdableMockRecorder) ZRevRange(ctx, key, start, stop interface{}) *gomock.Call

ZRevRange indicates an expected call of ZRevRange.

func (*MockCmdableMockRecorder) ZRevRangeByLex added in v0.1.1

func (mr *MockCmdableMockRecorder) ZRevRangeByLex(ctx, key, opt interface{}) *gomock.Call

ZRevRangeByLex indicates an expected call of ZRevRangeByLex.

func (*MockCmdableMockRecorder) ZRevRangeByScore added in v0.1.1

func (mr *MockCmdableMockRecorder) ZRevRangeByScore(ctx, key, opt interface{}) *gomock.Call

ZRevRangeByScore indicates an expected call of ZRevRangeByScore.

func (*MockCmdableMockRecorder) ZRevRangeByScoreWithScores added in v0.1.1

func (mr *MockCmdableMockRecorder) ZRevRangeByScoreWithScores(ctx, key, opt interface{}) *gomock.Call

ZRevRangeByScoreWithScores indicates an expected call of ZRevRangeByScoreWithScores.

func (*MockCmdableMockRecorder) ZRevRangeWithScores added in v0.1.1

func (mr *MockCmdableMockRecorder) ZRevRangeWithScores(ctx, key, start, stop interface{}) *gomock.Call

ZRevRangeWithScores indicates an expected call of ZRevRangeWithScores.

func (*MockCmdableMockRecorder) ZRevRank added in v0.1.1

func (mr *MockCmdableMockRecorder) ZRevRank(ctx, key, member interface{}) *gomock.Call

ZRevRank indicates an expected call of ZRevRank.

func (*MockCmdableMockRecorder) ZScan added in v0.1.1

func (mr *MockCmdableMockRecorder) ZScan(ctx, key, cursor, match, count interface{}) *gomock.Call

ZScan indicates an expected call of ZScan.

func (*MockCmdableMockRecorder) ZScore added in v0.1.1

func (mr *MockCmdableMockRecorder) ZScore(ctx, key, member interface{}) *gomock.Call

ZScore indicates an expected call of ZScore.

func (*MockCmdableMockRecorder) ZUnion added in v0.1.1

func (mr *MockCmdableMockRecorder) ZUnion(ctx, store interface{}) *gomock.Call

ZUnion indicates an expected call of ZUnion.

func (*MockCmdableMockRecorder) ZUnionStore added in v0.1.1

func (mr *MockCmdableMockRecorder) ZUnionStore(ctx, dest, store interface{}) *gomock.Call

ZUnionStore indicates an expected call of ZUnionStore.

func (*MockCmdableMockRecorder) ZUnionWithScores added in v0.1.1

func (mr *MockCmdableMockRecorder) ZUnionWithScores(ctx, store interface{}) *gomock.Call

ZUnionWithScores indicates an expected call of ZUnionWithScores.

type MockStatefulCmdable added in v0.1.1

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

MockStatefulCmdable is a mock of StatefulCmdable interface.

func NewMockStatefulCmdable added in v0.1.1

func NewMockStatefulCmdable(ctrl *gomock.Controller) *MockStatefulCmdable

NewMockStatefulCmdable creates a new mock instance.

func (*MockStatefulCmdable) Append added in v0.1.1

func (m *MockStatefulCmdable) Append(ctx context.Context, key, value string) *v8.IntCmd

Append mocks base method.

func (*MockStatefulCmdable) Auth added in v0.1.1

func (m *MockStatefulCmdable) Auth(ctx context.Context, password string) *v8.StatusCmd

Auth mocks base method.

func (*MockStatefulCmdable) AuthACL added in v0.1.1

func (m *MockStatefulCmdable) AuthACL(ctx context.Context, username, password string) *v8.StatusCmd

AuthACL mocks base method.

func (*MockStatefulCmdable) BLMove added in v0.1.1

func (m *MockStatefulCmdable) BLMove(ctx context.Context, source, destination, srcpos, destpos string, timeout time.Duration) *v8.StringCmd

BLMove mocks base method.

func (*MockStatefulCmdable) BLPop added in v0.1.1

func (m *MockStatefulCmdable) BLPop(ctx context.Context, timeout time.Duration, keys ...string) *v8.StringSliceCmd

BLPop mocks base method.

func (*MockStatefulCmdable) BRPop added in v0.1.1

func (m *MockStatefulCmdable) BRPop(ctx context.Context, timeout time.Duration, keys ...string) *v8.StringSliceCmd

BRPop mocks base method.

func (*MockStatefulCmdable) BRPopLPush added in v0.1.1

func (m *MockStatefulCmdable) BRPopLPush(ctx context.Context, source, destination string, timeout time.Duration) *v8.StringCmd

BRPopLPush mocks base method.

func (*MockStatefulCmdable) BZPopMax added in v0.1.1

func (m *MockStatefulCmdable) BZPopMax(ctx context.Context, timeout time.Duration, keys ...string) *v8.ZWithKeyCmd

BZPopMax mocks base method.

func (*MockStatefulCmdable) BZPopMin added in v0.1.1

func (m *MockStatefulCmdable) BZPopMin(ctx context.Context, timeout time.Duration, keys ...string) *v8.ZWithKeyCmd

BZPopMin mocks base method.

func (*MockStatefulCmdable) BgRewriteAOF added in v0.1.1

func (m *MockStatefulCmdable) BgRewriteAOF(ctx context.Context) *v8.StatusCmd

BgRewriteAOF mocks base method.

func (*MockStatefulCmdable) BgSave added in v0.1.1

BgSave mocks base method.

func (*MockStatefulCmdable) BitCount added in v0.1.1

func (m *MockStatefulCmdable) BitCount(ctx context.Context, key string, bitCount *v8.BitCount) *v8.IntCmd

BitCount mocks base method.

func (*MockStatefulCmdable) BitField added in v0.1.1

func (m *MockStatefulCmdable) BitField(ctx context.Context, key string, args ...interface{}) *v8.IntSliceCmd

BitField mocks base method.

func (*MockStatefulCmdable) BitOpAnd added in v0.1.1

func (m *MockStatefulCmdable) BitOpAnd(ctx context.Context, destKey string, keys ...string) *v8.IntCmd

BitOpAnd mocks base method.

func (*MockStatefulCmdable) BitOpNot added in v0.1.1

func (m *MockStatefulCmdable) BitOpNot(ctx context.Context, destKey, key string) *v8.IntCmd

BitOpNot mocks base method.

func (*MockStatefulCmdable) BitOpOr added in v0.1.1

func (m *MockStatefulCmdable) BitOpOr(ctx context.Context, destKey string, keys ...string) *v8.IntCmd

BitOpOr mocks base method.

func (*MockStatefulCmdable) BitOpXor added in v0.1.1

func (m *MockStatefulCmdable) BitOpXor(ctx context.Context, destKey string, keys ...string) *v8.IntCmd

BitOpXor mocks base method.

func (*MockStatefulCmdable) BitPos added in v0.1.1

func (m *MockStatefulCmdable) BitPos(ctx context.Context, key string, bit int64, pos ...int64) *v8.IntCmd

BitPos mocks base method.

func (*MockStatefulCmdable) ClientGetName added in v0.1.1

func (m *MockStatefulCmdable) ClientGetName(ctx context.Context) *v8.StringCmd

ClientGetName mocks base method.

func (*MockStatefulCmdable) ClientID added in v0.1.1

func (m *MockStatefulCmdable) ClientID(ctx context.Context) *v8.IntCmd

ClientID mocks base method.

func (*MockStatefulCmdable) ClientKill added in v0.1.1

func (m *MockStatefulCmdable) ClientKill(ctx context.Context, ipPort string) *v8.StatusCmd

ClientKill mocks base method.

func (*MockStatefulCmdable) ClientKillByFilter added in v0.1.1

func (m *MockStatefulCmdable) ClientKillByFilter(ctx context.Context, keys ...string) *v8.IntCmd

ClientKillByFilter mocks base method.

func (*MockStatefulCmdable) ClientList added in v0.1.1

func (m *MockStatefulCmdable) ClientList(ctx context.Context) *v8.StringCmd

ClientList mocks base method.

func (*MockStatefulCmdable) ClientPause added in v0.1.1

func (m *MockStatefulCmdable) ClientPause(ctx context.Context, dur time.Duration) *v8.BoolCmd

ClientPause mocks base method.

func (*MockStatefulCmdable) ClientSetName added in v0.1.1

func (m *MockStatefulCmdable) ClientSetName(ctx context.Context, name string) *v8.BoolCmd

ClientSetName mocks base method.

func (*MockStatefulCmdable) ClusterAddSlots added in v0.1.1

func (m *MockStatefulCmdable) ClusterAddSlots(ctx context.Context, slots ...int) *v8.StatusCmd

ClusterAddSlots mocks base method.

func (*MockStatefulCmdable) ClusterAddSlotsRange added in v0.1.1

func (m *MockStatefulCmdable) ClusterAddSlotsRange(ctx context.Context, min, max int) *v8.StatusCmd

ClusterAddSlotsRange mocks base method.

func (*MockStatefulCmdable) ClusterCountFailureReports added in v0.1.1

func (m *MockStatefulCmdable) ClusterCountFailureReports(ctx context.Context, nodeID string) *v8.IntCmd

ClusterCountFailureReports mocks base method.

func (*MockStatefulCmdable) ClusterCountKeysInSlot added in v0.1.1

func (m *MockStatefulCmdable) ClusterCountKeysInSlot(ctx context.Context, slot int) *v8.IntCmd

ClusterCountKeysInSlot mocks base method.

func (*MockStatefulCmdable) ClusterDelSlots added in v0.1.1

func (m *MockStatefulCmdable) ClusterDelSlots(ctx context.Context, slots ...int) *v8.StatusCmd

ClusterDelSlots mocks base method.

func (*MockStatefulCmdable) ClusterDelSlotsRange added in v0.1.1

func (m *MockStatefulCmdable) ClusterDelSlotsRange(ctx context.Context, min, max int) *v8.StatusCmd

ClusterDelSlotsRange mocks base method.

func (*MockStatefulCmdable) ClusterFailover added in v0.1.1

func (m *MockStatefulCmdable) ClusterFailover(ctx context.Context) *v8.StatusCmd

ClusterFailover mocks base method.

func (*MockStatefulCmdable) ClusterForget added in v0.1.1

func (m *MockStatefulCmdable) ClusterForget(ctx context.Context, nodeID string) *v8.StatusCmd

ClusterForget mocks base method.

func (*MockStatefulCmdable) ClusterGetKeysInSlot added in v0.1.1

func (m *MockStatefulCmdable) ClusterGetKeysInSlot(ctx context.Context, slot, count int) *v8.StringSliceCmd

ClusterGetKeysInSlot mocks base method.

func (*MockStatefulCmdable) ClusterInfo added in v0.1.1

func (m *MockStatefulCmdable) ClusterInfo(ctx context.Context) *v8.StringCmd

ClusterInfo mocks base method.

func (*MockStatefulCmdable) ClusterKeySlot added in v0.1.1

func (m *MockStatefulCmdable) ClusterKeySlot(ctx context.Context, key string) *v8.IntCmd

ClusterKeySlot mocks base method.

func (*MockStatefulCmdable) ClusterMeet added in v0.1.1

func (m *MockStatefulCmdable) ClusterMeet(ctx context.Context, host, port string) *v8.StatusCmd

ClusterMeet mocks base method.

func (*MockStatefulCmdable) ClusterNodes added in v0.1.1

func (m *MockStatefulCmdable) ClusterNodes(ctx context.Context) *v8.StringCmd

ClusterNodes mocks base method.

func (*MockStatefulCmdable) ClusterReplicate added in v0.1.1

func (m *MockStatefulCmdable) ClusterReplicate(ctx context.Context, nodeID string) *v8.StatusCmd

ClusterReplicate mocks base method.

func (*MockStatefulCmdable) ClusterResetHard added in v0.1.1

func (m *MockStatefulCmdable) ClusterResetHard(ctx context.Context) *v8.StatusCmd

ClusterResetHard mocks base method.

func (*MockStatefulCmdable) ClusterResetSoft added in v0.1.1

func (m *MockStatefulCmdable) ClusterResetSoft(ctx context.Context) *v8.StatusCmd

ClusterResetSoft mocks base method.

func (*MockStatefulCmdable) ClusterSaveConfig added in v0.1.1

func (m *MockStatefulCmdable) ClusterSaveConfig(ctx context.Context) *v8.StatusCmd

ClusterSaveConfig mocks base method.

func (*MockStatefulCmdable) ClusterSlaves added in v0.1.1

func (m *MockStatefulCmdable) ClusterSlaves(ctx context.Context, nodeID string) *v8.StringSliceCmd

ClusterSlaves mocks base method.

func (*MockStatefulCmdable) ClusterSlots added in v0.1.1

func (m *MockStatefulCmdable) ClusterSlots(ctx context.Context) *v8.ClusterSlotsCmd

ClusterSlots mocks base method.

func (*MockStatefulCmdable) Command added in v0.1.1

Command mocks base method.

func (*MockStatefulCmdable) ConfigGet added in v0.1.1

func (m *MockStatefulCmdable) ConfigGet(ctx context.Context, parameter string) *v8.SliceCmd

ConfigGet mocks base method.

func (*MockStatefulCmdable) ConfigResetStat added in v0.1.1

func (m *MockStatefulCmdable) ConfigResetStat(ctx context.Context) *v8.StatusCmd

ConfigResetStat mocks base method.

func (*MockStatefulCmdable) ConfigRewrite added in v0.1.1

func (m *MockStatefulCmdable) ConfigRewrite(ctx context.Context) *v8.StatusCmd

ConfigRewrite mocks base method.

func (*MockStatefulCmdable) ConfigSet added in v0.1.1

func (m *MockStatefulCmdable) ConfigSet(ctx context.Context, parameter, value string) *v8.StatusCmd

ConfigSet mocks base method.

func (*MockStatefulCmdable) Copy added in v0.1.1

func (m *MockStatefulCmdable) Copy(ctx context.Context, sourceKey, destKey string, db int, replace bool) *v8.IntCmd

Copy mocks base method.

func (*MockStatefulCmdable) DBSize added in v0.1.1

func (m *MockStatefulCmdable) DBSize(ctx context.Context) *v8.IntCmd

DBSize mocks base method.

func (*MockStatefulCmdable) DebugObject added in v0.1.1

func (m *MockStatefulCmdable) DebugObject(ctx context.Context, key string) *v8.StringCmd

DebugObject mocks base method.

func (*MockStatefulCmdable) Decr added in v0.1.1

func (m *MockStatefulCmdable) Decr(ctx context.Context, key string) *v8.IntCmd

Decr mocks base method.

func (*MockStatefulCmdable) DecrBy added in v0.1.1

func (m *MockStatefulCmdable) DecrBy(ctx context.Context, key string, decrement int64) *v8.IntCmd

DecrBy mocks base method.

func (*MockStatefulCmdable) Del added in v0.1.1

func (m *MockStatefulCmdable) Del(ctx context.Context, keys ...string) *v8.IntCmd

Del mocks base method.

func (*MockStatefulCmdable) Dump added in v0.1.1

Dump mocks base method.

func (*MockStatefulCmdable) EXPECT added in v0.1.1

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockStatefulCmdable) Echo added in v0.1.1

func (m *MockStatefulCmdable) Echo(ctx context.Context, message interface{}) *v8.StringCmd

Echo mocks base method.

func (*MockStatefulCmdable) Eval added in v0.1.1

func (m *MockStatefulCmdable) Eval(ctx context.Context, script string, keys []string, args ...interface{}) *v8.Cmd

Eval mocks base method.

func (*MockStatefulCmdable) EvalSha added in v0.1.1

func (m *MockStatefulCmdable) EvalSha(ctx context.Context, sha1 string, keys []string, args ...interface{}) *v8.Cmd

EvalSha mocks base method.

func (*MockStatefulCmdable) Exists added in v0.1.1

func (m *MockStatefulCmdable) Exists(ctx context.Context, keys ...string) *v8.IntCmd

Exists mocks base method.

func (*MockStatefulCmdable) Expire added in v0.1.1

func (m *MockStatefulCmdable) Expire(ctx context.Context, key string, expiration time.Duration) *v8.BoolCmd

Expire mocks base method.

func (*MockStatefulCmdable) ExpireAt added in v0.1.1

func (m *MockStatefulCmdable) ExpireAt(ctx context.Context, key string, tm time.Time) *v8.BoolCmd

ExpireAt mocks base method.

func (*MockStatefulCmdable) ExpireGT added in v0.1.1

func (m *MockStatefulCmdable) ExpireGT(ctx context.Context, key string, expiration time.Duration) *v8.BoolCmd

ExpireGT mocks base method.

func (*MockStatefulCmdable) ExpireLT added in v0.1.1

func (m *MockStatefulCmdable) ExpireLT(ctx context.Context, key string, expiration time.Duration) *v8.BoolCmd

ExpireLT mocks base method.

func (*MockStatefulCmdable) ExpireNX added in v0.1.1

func (m *MockStatefulCmdable) ExpireNX(ctx context.Context, key string, expiration time.Duration) *v8.BoolCmd

ExpireNX mocks base method.

func (*MockStatefulCmdable) ExpireXX added in v0.1.1

func (m *MockStatefulCmdable) ExpireXX(ctx context.Context, key string, expiration time.Duration) *v8.BoolCmd

ExpireXX mocks base method.

func (*MockStatefulCmdable) FlushAll added in v0.1.1

func (m *MockStatefulCmdable) FlushAll(ctx context.Context) *v8.StatusCmd

FlushAll mocks base method.

func (*MockStatefulCmdable) FlushAllAsync added in v0.1.1

func (m *MockStatefulCmdable) FlushAllAsync(ctx context.Context) *v8.StatusCmd

FlushAllAsync mocks base method.

func (*MockStatefulCmdable) FlushDB added in v0.1.1

func (m *MockStatefulCmdable) FlushDB(ctx context.Context) *v8.StatusCmd

FlushDB mocks base method.

func (*MockStatefulCmdable) FlushDBAsync added in v0.1.1

func (m *MockStatefulCmdable) FlushDBAsync(ctx context.Context) *v8.StatusCmd

FlushDBAsync mocks base method.

func (*MockStatefulCmdable) GeoAdd added in v0.1.1

func (m *MockStatefulCmdable) GeoAdd(ctx context.Context, key string, geoLocation ...*v8.GeoLocation) *v8.IntCmd

GeoAdd mocks base method.

func (*MockStatefulCmdable) GeoDist added in v0.1.1

func (m *MockStatefulCmdable) GeoDist(ctx context.Context, key, member1, member2, unit string) *v8.FloatCmd

GeoDist mocks base method.

func (*MockStatefulCmdable) GeoHash added in v0.1.1

func (m *MockStatefulCmdable) GeoHash(ctx context.Context, key string, members ...string) *v8.StringSliceCmd

GeoHash mocks base method.

func (*MockStatefulCmdable) GeoPos added in v0.1.1

func (m *MockStatefulCmdable) GeoPos(ctx context.Context, key string, members ...string) *v8.GeoPosCmd

GeoPos mocks base method.

func (*MockStatefulCmdable) GeoRadius added in v0.1.1

func (m *MockStatefulCmdable) GeoRadius(ctx context.Context, key string, longitude, latitude float64, query *v8.GeoRadiusQuery) *v8.GeoLocationCmd

GeoRadius mocks base method.

func (*MockStatefulCmdable) GeoRadiusByMember added in v0.1.1

func (m *MockStatefulCmdable) GeoRadiusByMember(ctx context.Context, key, member string, query *v8.GeoRadiusQuery) *v8.GeoLocationCmd

GeoRadiusByMember mocks base method.

func (*MockStatefulCmdable) GeoRadiusByMemberStore added in v0.1.1

func (m *MockStatefulCmdable) GeoRadiusByMemberStore(ctx context.Context, key, member string, query *v8.GeoRadiusQuery) *v8.IntCmd

GeoRadiusByMemberStore mocks base method.

func (*MockStatefulCmdable) GeoRadiusStore added in v0.1.1

func (m *MockStatefulCmdable) GeoRadiusStore(ctx context.Context, key string, longitude, latitude float64, query *v8.GeoRadiusQuery) *v8.IntCmd

GeoRadiusStore mocks base method.

func (*MockStatefulCmdable) GeoSearch added in v0.1.1

GeoSearch mocks base method.

func (*MockStatefulCmdable) GeoSearchLocation added in v0.1.1

GeoSearchLocation mocks base method.

func (*MockStatefulCmdable) GeoSearchStore added in v0.1.1

func (m *MockStatefulCmdable) GeoSearchStore(ctx context.Context, key, store string, q *v8.GeoSearchStoreQuery) *v8.IntCmd

GeoSearchStore mocks base method.

func (*MockStatefulCmdable) Get added in v0.1.1

Get mocks base method.

func (*MockStatefulCmdable) GetBit added in v0.1.1

func (m *MockStatefulCmdable) GetBit(ctx context.Context, key string, offset int64) *v8.IntCmd

GetBit mocks base method.

func (*MockStatefulCmdable) GetDel added in v0.1.1

func (m *MockStatefulCmdable) GetDel(ctx context.Context, key string) *v8.StringCmd

GetDel mocks base method.

func (*MockStatefulCmdable) GetEx added in v0.1.1

func (m *MockStatefulCmdable) GetEx(ctx context.Context, key string, expiration time.Duration) *v8.StringCmd

GetEx mocks base method.

func (*MockStatefulCmdable) GetRange added in v0.1.1

func (m *MockStatefulCmdable) GetRange(ctx context.Context, key string, start, end int64) *v8.StringCmd

GetRange mocks base method.

func (*MockStatefulCmdable) GetSet added in v0.1.1

func (m *MockStatefulCmdable) GetSet(ctx context.Context, key string, value interface{}) *v8.StringCmd

GetSet mocks base method.

func (*MockStatefulCmdable) HDel added in v0.1.1

func (m *MockStatefulCmdable) HDel(ctx context.Context, key string, fields ...string) *v8.IntCmd

HDel mocks base method.

func (*MockStatefulCmdable) HExists added in v0.1.1

func (m *MockStatefulCmdable) HExists(ctx context.Context, key, field string) *v8.BoolCmd

HExists mocks base method.

func (*MockStatefulCmdable) HGet added in v0.1.1

func (m *MockStatefulCmdable) HGet(ctx context.Context, key, field string) *v8.StringCmd

HGet mocks base method.

func (*MockStatefulCmdable) HGetAll added in v0.1.1

HGetAll mocks base method.

func (*MockStatefulCmdable) HIncrBy added in v0.1.1

func (m *MockStatefulCmdable) HIncrBy(ctx context.Context, key, field string, incr int64) *v8.IntCmd

HIncrBy mocks base method.

func (*MockStatefulCmdable) HIncrByFloat added in v0.1.1

func (m *MockStatefulCmdable) HIncrByFloat(ctx context.Context, key, field string, incr float64) *v8.FloatCmd

HIncrByFloat mocks base method.

func (*MockStatefulCmdable) HKeys added in v0.1.1

HKeys mocks base method.

func (*MockStatefulCmdable) HLen added in v0.1.1

func (m *MockStatefulCmdable) HLen(ctx context.Context, key string) *v8.IntCmd

HLen mocks base method.

func (*MockStatefulCmdable) HMGet added in v0.1.1

func (m *MockStatefulCmdable) HMGet(ctx context.Context, key string, fields ...string) *v8.SliceCmd

HMGet mocks base method.

func (*MockStatefulCmdable) HMSet added in v0.1.1

func (m *MockStatefulCmdable) HMSet(ctx context.Context, key string, values ...interface{}) *v8.BoolCmd

HMSet mocks base method.

func (*MockStatefulCmdable) HRandField added in v0.1.1

func (m *MockStatefulCmdable) HRandField(ctx context.Context, key string, count int, withValues bool) *v8.StringSliceCmd

HRandField mocks base method.

func (*MockStatefulCmdable) HScan added in v0.1.1

func (m *MockStatefulCmdable) HScan(ctx context.Context, key string, cursor uint64, match string, count int64) *v8.ScanCmd

HScan mocks base method.

func (*MockStatefulCmdable) HSet added in v0.1.1

func (m *MockStatefulCmdable) HSet(ctx context.Context, key string, values ...interface{}) *v8.IntCmd

HSet mocks base method.

func (*MockStatefulCmdable) HSetNX added in v0.1.1

func (m *MockStatefulCmdable) HSetNX(ctx context.Context, key, field string, value interface{}) *v8.BoolCmd

HSetNX mocks base method.

func (*MockStatefulCmdable) HVals added in v0.1.1

HVals mocks base method.

func (*MockStatefulCmdable) Incr added in v0.1.1

func (m *MockStatefulCmdable) Incr(ctx context.Context, key string) *v8.IntCmd

Incr mocks base method.

func (*MockStatefulCmdable) IncrBy added in v0.1.1

func (m *MockStatefulCmdable) IncrBy(ctx context.Context, key string, value int64) *v8.IntCmd

IncrBy mocks base method.

func (*MockStatefulCmdable) IncrByFloat added in v0.1.1

func (m *MockStatefulCmdable) IncrByFloat(ctx context.Context, key string, value float64) *v8.FloatCmd

IncrByFloat mocks base method.

func (*MockStatefulCmdable) Info added in v0.1.1

func (m *MockStatefulCmdable) Info(ctx context.Context, section ...string) *v8.StringCmd

Info mocks base method.

func (*MockStatefulCmdable) Keys added in v0.1.1

func (m *MockStatefulCmdable) Keys(ctx context.Context, pattern string) *v8.StringSliceCmd

Keys mocks base method.

func (*MockStatefulCmdable) LIndex added in v0.1.1

func (m *MockStatefulCmdable) LIndex(ctx context.Context, key string, index int64) *v8.StringCmd

LIndex mocks base method.

func (*MockStatefulCmdable) LInsert added in v0.1.1

func (m *MockStatefulCmdable) LInsert(ctx context.Context, key, op string, pivot, value interface{}) *v8.IntCmd

LInsert mocks base method.

func (*MockStatefulCmdable) LInsertAfter added in v0.1.1

func (m *MockStatefulCmdable) LInsertAfter(ctx context.Context, key string, pivot, value interface{}) *v8.IntCmd

LInsertAfter mocks base method.

func (*MockStatefulCmdable) LInsertBefore added in v0.1.1

func (m *MockStatefulCmdable) LInsertBefore(ctx context.Context, key string, pivot, value interface{}) *v8.IntCmd

LInsertBefore mocks base method.

func (*MockStatefulCmdable) LLen added in v0.1.1

func (m *MockStatefulCmdable) LLen(ctx context.Context, key string) *v8.IntCmd

LLen mocks base method.

func (*MockStatefulCmdable) LMove added in v0.1.1

func (m *MockStatefulCmdable) LMove(ctx context.Context, source, destination, srcpos, destpos string) *v8.StringCmd

LMove mocks base method.

func (*MockStatefulCmdable) LPop added in v0.1.1

LPop mocks base method.

func (*MockStatefulCmdable) LPopCount added in v0.1.1

func (m *MockStatefulCmdable) LPopCount(ctx context.Context, key string, count int) *v8.StringSliceCmd

LPopCount mocks base method.

func (*MockStatefulCmdable) LPos added in v0.1.1

func (m *MockStatefulCmdable) LPos(ctx context.Context, key, value string, args v8.LPosArgs) *v8.IntCmd

LPos mocks base method.

func (*MockStatefulCmdable) LPosCount added in v0.1.1

func (m *MockStatefulCmdable) LPosCount(ctx context.Context, key, value string, count int64, args v8.LPosArgs) *v8.IntSliceCmd

LPosCount mocks base method.

func (*MockStatefulCmdable) LPush added in v0.1.1

func (m *MockStatefulCmdable) LPush(ctx context.Context, key string, values ...interface{}) *v8.IntCmd

LPush mocks base method.

func (*MockStatefulCmdable) LPushX added in v0.1.1

func (m *MockStatefulCmdable) LPushX(ctx context.Context, key string, values ...interface{}) *v8.IntCmd

LPushX mocks base method.

func (*MockStatefulCmdable) LRange added in v0.1.1

func (m *MockStatefulCmdable) LRange(ctx context.Context, key string, start, stop int64) *v8.StringSliceCmd

LRange mocks base method.

func (*MockStatefulCmdable) LRem added in v0.1.1

func (m *MockStatefulCmdable) LRem(ctx context.Context, key string, count int64, value interface{}) *v8.IntCmd

LRem mocks base method.

func (*MockStatefulCmdable) LSet added in v0.1.1

func (m *MockStatefulCmdable) LSet(ctx context.Context, key string, index int64, value interface{}) *v8.StatusCmd

LSet mocks base method.

func (*MockStatefulCmdable) LTrim added in v0.1.1

func (m *MockStatefulCmdable) LTrim(ctx context.Context, key string, start, stop int64) *v8.StatusCmd

LTrim mocks base method.

func (*MockStatefulCmdable) LastSave added in v0.1.1

func (m *MockStatefulCmdable) LastSave(ctx context.Context) *v8.IntCmd

LastSave mocks base method.

func (*MockStatefulCmdable) MGet added in v0.1.1

func (m *MockStatefulCmdable) MGet(ctx context.Context, keys ...string) *v8.SliceCmd

MGet mocks base method.

func (*MockStatefulCmdable) MSet added in v0.1.1

func (m *MockStatefulCmdable) MSet(ctx context.Context, values ...interface{}) *v8.StatusCmd

MSet mocks base method.

func (*MockStatefulCmdable) MSetNX added in v0.1.1

func (m *MockStatefulCmdable) MSetNX(ctx context.Context, values ...interface{}) *v8.BoolCmd

MSetNX mocks base method.

func (*MockStatefulCmdable) MemoryUsage added in v0.1.1

func (m *MockStatefulCmdable) MemoryUsage(ctx context.Context, key string, samples ...int) *v8.IntCmd

MemoryUsage mocks base method.

func (*MockStatefulCmdable) Migrate added in v0.1.1

func (m *MockStatefulCmdable) Migrate(ctx context.Context, host, port, key string, db int, timeout time.Duration) *v8.StatusCmd

Migrate mocks base method.

func (*MockStatefulCmdable) Move added in v0.1.1

func (m *MockStatefulCmdable) Move(ctx context.Context, key string, db int) *v8.BoolCmd

Move mocks base method.

func (*MockStatefulCmdable) ObjectEncoding added in v0.1.1

func (m *MockStatefulCmdable) ObjectEncoding(ctx context.Context, key string) *v8.StringCmd

ObjectEncoding mocks base method.

func (*MockStatefulCmdable) ObjectIdleTime added in v0.1.1

func (m *MockStatefulCmdable) ObjectIdleTime(ctx context.Context, key string) *v8.DurationCmd

ObjectIdleTime mocks base method.

func (*MockStatefulCmdable) ObjectRefCount added in v0.1.1

func (m *MockStatefulCmdable) ObjectRefCount(ctx context.Context, key string) *v8.IntCmd

ObjectRefCount mocks base method.

func (*MockStatefulCmdable) PExpire added in v0.1.1

func (m *MockStatefulCmdable) PExpire(ctx context.Context, key string, expiration time.Duration) *v8.BoolCmd

PExpire mocks base method.

func (*MockStatefulCmdable) PExpireAt added in v0.1.1

func (m *MockStatefulCmdable) PExpireAt(ctx context.Context, key string, tm time.Time) *v8.BoolCmd

PExpireAt mocks base method.

func (*MockStatefulCmdable) PFAdd added in v0.1.1

func (m *MockStatefulCmdable) PFAdd(ctx context.Context, key string, els ...interface{}) *v8.IntCmd

PFAdd mocks base method.

func (*MockStatefulCmdable) PFCount added in v0.1.1

func (m *MockStatefulCmdable) PFCount(ctx context.Context, keys ...string) *v8.IntCmd

PFCount mocks base method.

func (*MockStatefulCmdable) PFMerge added in v0.1.1

func (m *MockStatefulCmdable) PFMerge(ctx context.Context, dest string, keys ...string) *v8.StatusCmd

PFMerge mocks base method.

func (*MockStatefulCmdable) PTTL added in v0.1.1

PTTL mocks base method.

func (*MockStatefulCmdable) Persist added in v0.1.1

func (m *MockStatefulCmdable) Persist(ctx context.Context, key string) *v8.BoolCmd

Persist mocks base method.

func (*MockStatefulCmdable) Ping added in v0.1.1

Ping mocks base method.

func (*MockStatefulCmdable) Pipeline added in v0.1.1

func (m *MockStatefulCmdable) Pipeline() v8.Pipeliner

Pipeline mocks base method.

func (*MockStatefulCmdable) Pipelined added in v0.1.1

func (m *MockStatefulCmdable) Pipelined(ctx context.Context, fn func(v8.Pipeliner) error) ([]v8.Cmder, error)

Pipelined mocks base method.

func (*MockStatefulCmdable) PubSubChannels added in v0.1.1

func (m *MockStatefulCmdable) PubSubChannels(ctx context.Context, pattern string) *v8.StringSliceCmd

PubSubChannels mocks base method.

func (*MockStatefulCmdable) PubSubNumPat added in v0.1.1

func (m *MockStatefulCmdable) PubSubNumPat(ctx context.Context) *v8.IntCmd

PubSubNumPat mocks base method.

func (*MockStatefulCmdable) PubSubNumSub added in v0.1.1

func (m *MockStatefulCmdable) PubSubNumSub(ctx context.Context, channels ...string) *v8.StringIntMapCmd

PubSubNumSub mocks base method.

func (*MockStatefulCmdable) Publish added in v0.1.1

func (m *MockStatefulCmdable) Publish(ctx context.Context, channel string, message interface{}) *v8.IntCmd

Publish mocks base method.

func (*MockStatefulCmdable) Quit added in v0.1.1

Quit mocks base method.

func (*MockStatefulCmdable) RPop added in v0.1.1

RPop mocks base method.

func (*MockStatefulCmdable) RPopCount added in v0.1.1

func (m *MockStatefulCmdable) RPopCount(ctx context.Context, key string, count int) *v8.StringSliceCmd

RPopCount mocks base method.

func (*MockStatefulCmdable) RPopLPush added in v0.1.1

func (m *MockStatefulCmdable) RPopLPush(ctx context.Context, source, destination string) *v8.StringCmd

RPopLPush mocks base method.

func (*MockStatefulCmdable) RPush added in v0.1.1

func (m *MockStatefulCmdable) RPush(ctx context.Context, key string, values ...interface{}) *v8.IntCmd

RPush mocks base method.

func (*MockStatefulCmdable) RPushX added in v0.1.1

func (m *MockStatefulCmdable) RPushX(ctx context.Context, key string, values ...interface{}) *v8.IntCmd

RPushX mocks base method.

func (*MockStatefulCmdable) RandomKey added in v0.1.1

func (m *MockStatefulCmdable) RandomKey(ctx context.Context) *v8.StringCmd

RandomKey mocks base method.

func (*MockStatefulCmdable) ReadOnly added in v0.1.1

func (m *MockStatefulCmdable) ReadOnly(ctx context.Context) *v8.StatusCmd

ReadOnly mocks base method.

func (*MockStatefulCmdable) ReadWrite added in v0.1.1

func (m *MockStatefulCmdable) ReadWrite(ctx context.Context) *v8.StatusCmd

ReadWrite mocks base method.

func (*MockStatefulCmdable) Rename added in v0.1.1

func (m *MockStatefulCmdable) Rename(ctx context.Context, key, newkey string) *v8.StatusCmd

Rename mocks base method.

func (*MockStatefulCmdable) RenameNX added in v0.1.1

func (m *MockStatefulCmdable) RenameNX(ctx context.Context, key, newkey string) *v8.BoolCmd

RenameNX mocks base method.

func (*MockStatefulCmdable) Restore added in v0.1.1

func (m *MockStatefulCmdable) Restore(ctx context.Context, key string, ttl time.Duration, value string) *v8.StatusCmd

Restore mocks base method.

func (*MockStatefulCmdable) RestoreReplace added in v0.1.1

func (m *MockStatefulCmdable) RestoreReplace(ctx context.Context, key string, ttl time.Duration, value string) *v8.StatusCmd

RestoreReplace mocks base method.

func (*MockStatefulCmdable) SAdd added in v0.1.1

func (m *MockStatefulCmdable) SAdd(ctx context.Context, key string, members ...interface{}) *v8.IntCmd

SAdd mocks base method.

func (*MockStatefulCmdable) SCard added in v0.1.1

func (m *MockStatefulCmdable) SCard(ctx context.Context, key string) *v8.IntCmd

SCard mocks base method.

func (*MockStatefulCmdable) SDiff added in v0.1.1

func (m *MockStatefulCmdable) SDiff(ctx context.Context, keys ...string) *v8.StringSliceCmd

SDiff mocks base method.

func (*MockStatefulCmdable) SDiffStore added in v0.1.1

func (m *MockStatefulCmdable) SDiffStore(ctx context.Context, destination string, keys ...string) *v8.IntCmd

SDiffStore mocks base method.

func (*MockStatefulCmdable) SInter added in v0.1.1

func (m *MockStatefulCmdable) SInter(ctx context.Context, keys ...string) *v8.StringSliceCmd

SInter mocks base method.

func (*MockStatefulCmdable) SInterStore added in v0.1.1

func (m *MockStatefulCmdable) SInterStore(ctx context.Context, destination string, keys ...string) *v8.IntCmd

SInterStore mocks base method.

func (*MockStatefulCmdable) SIsMember added in v0.1.1

func (m *MockStatefulCmdable) SIsMember(ctx context.Context, key string, member interface{}) *v8.BoolCmd

SIsMember mocks base method.

func (*MockStatefulCmdable) SMIsMember added in v0.1.1

func (m *MockStatefulCmdable) SMIsMember(ctx context.Context, key string, members ...interface{}) *v8.BoolSliceCmd

SMIsMember mocks base method.

func (*MockStatefulCmdable) SMembers added in v0.1.1

func (m *MockStatefulCmdable) SMembers(ctx context.Context, key string) *v8.StringSliceCmd

SMembers mocks base method.

func (*MockStatefulCmdable) SMembersMap added in v0.1.1

func (m *MockStatefulCmdable) SMembersMap(ctx context.Context, key string) *v8.StringStructMapCmd

SMembersMap mocks base method.

func (*MockStatefulCmdable) SMove added in v0.1.1

func (m *MockStatefulCmdable) SMove(ctx context.Context, source, destination string, member interface{}) *v8.BoolCmd

SMove mocks base method.

func (*MockStatefulCmdable) SPop added in v0.1.1

SPop mocks base method.

func (*MockStatefulCmdable) SPopN added in v0.1.1

func (m *MockStatefulCmdable) SPopN(ctx context.Context, key string, count int64) *v8.StringSliceCmd

SPopN mocks base method.

func (*MockStatefulCmdable) SRandMember added in v0.1.1

func (m *MockStatefulCmdable) SRandMember(ctx context.Context, key string) *v8.StringCmd

SRandMember mocks base method.

func (*MockStatefulCmdable) SRandMemberN added in v0.1.1

func (m *MockStatefulCmdable) SRandMemberN(ctx context.Context, key string, count int64) *v8.StringSliceCmd

SRandMemberN mocks base method.

func (*MockStatefulCmdable) SRem added in v0.1.1

func (m *MockStatefulCmdable) SRem(ctx context.Context, key string, members ...interface{}) *v8.IntCmd

SRem mocks base method.

func (*MockStatefulCmdable) SScan added in v0.1.1

func (m *MockStatefulCmdable) SScan(ctx context.Context, key string, cursor uint64, match string, count int64) *v8.ScanCmd

SScan mocks base method.

func (*MockStatefulCmdable) SUnion added in v0.1.1

func (m *MockStatefulCmdable) SUnion(ctx context.Context, keys ...string) *v8.StringSliceCmd

SUnion mocks base method.

func (*MockStatefulCmdable) SUnionStore added in v0.1.1

func (m *MockStatefulCmdable) SUnionStore(ctx context.Context, destination string, keys ...string) *v8.IntCmd

SUnionStore mocks base method.

func (*MockStatefulCmdable) Save added in v0.1.1

Save mocks base method.

func (*MockStatefulCmdable) Scan added in v0.1.1

func (m *MockStatefulCmdable) Scan(ctx context.Context, cursor uint64, match string, count int64) *v8.ScanCmd

Scan mocks base method.

func (*MockStatefulCmdable) ScanType added in v0.1.1

func (m *MockStatefulCmdable) ScanType(ctx context.Context, cursor uint64, match string, count int64, keyType string) *v8.ScanCmd

ScanType mocks base method.

func (*MockStatefulCmdable) ScriptExists added in v0.1.1

func (m *MockStatefulCmdable) ScriptExists(ctx context.Context, hashes ...string) *v8.BoolSliceCmd

ScriptExists mocks base method.

func (*MockStatefulCmdable) ScriptFlush added in v0.1.1

func (m *MockStatefulCmdable) ScriptFlush(ctx context.Context) *v8.StatusCmd

ScriptFlush mocks base method.

func (*MockStatefulCmdable) ScriptKill added in v0.1.1

func (m *MockStatefulCmdable) ScriptKill(ctx context.Context) *v8.StatusCmd

ScriptKill mocks base method.

func (*MockStatefulCmdable) ScriptLoad added in v0.1.1

func (m *MockStatefulCmdable) ScriptLoad(ctx context.Context, script string) *v8.StringCmd

ScriptLoad mocks base method.

func (*MockStatefulCmdable) Select added in v0.1.1

func (m *MockStatefulCmdable) Select(ctx context.Context, index int) *v8.StatusCmd

Select mocks base method.

func (*MockStatefulCmdable) Set added in v0.1.1

func (m *MockStatefulCmdable) Set(ctx context.Context, key string, value interface{}, expiration time.Duration) *v8.StatusCmd

Set mocks base method.

func (*MockStatefulCmdable) SetArgs added in v0.1.1

func (m *MockStatefulCmdable) SetArgs(ctx context.Context, key string, value interface{}, a v8.SetArgs) *v8.StatusCmd

SetArgs mocks base method.

func (*MockStatefulCmdable) SetBit added in v0.1.1

func (m *MockStatefulCmdable) SetBit(ctx context.Context, key string, offset int64, value int) *v8.IntCmd

SetBit mocks base method.

func (*MockStatefulCmdable) SetEX added in v0.1.1

func (m *MockStatefulCmdable) SetEX(ctx context.Context, key string, value interface{}, expiration time.Duration) *v8.StatusCmd

SetEX mocks base method.

func (*MockStatefulCmdable) SetNX added in v0.1.1

func (m *MockStatefulCmdable) SetNX(ctx context.Context, key string, value interface{}, expiration time.Duration) *v8.BoolCmd

SetNX mocks base method.

func (*MockStatefulCmdable) SetRange added in v0.1.1

func (m *MockStatefulCmdable) SetRange(ctx context.Context, key string, offset int64, value string) *v8.IntCmd

SetRange mocks base method.

func (*MockStatefulCmdable) SetXX added in v0.1.1

func (m *MockStatefulCmdable) SetXX(ctx context.Context, key string, value interface{}, expiration time.Duration) *v8.BoolCmd

SetXX mocks base method.

func (*MockStatefulCmdable) Shutdown added in v0.1.1

func (m *MockStatefulCmdable) Shutdown(ctx context.Context) *v8.StatusCmd

Shutdown mocks base method.

func (*MockStatefulCmdable) ShutdownNoSave added in v0.1.1

func (m *MockStatefulCmdable) ShutdownNoSave(ctx context.Context) *v8.StatusCmd

ShutdownNoSave mocks base method.

func (*MockStatefulCmdable) ShutdownSave added in v0.1.1

func (m *MockStatefulCmdable) ShutdownSave(ctx context.Context) *v8.StatusCmd

ShutdownSave mocks base method.

func (*MockStatefulCmdable) SlaveOf added in v0.1.1

func (m *MockStatefulCmdable) SlaveOf(ctx context.Context, host, port string) *v8.StatusCmd

SlaveOf mocks base method.

func (*MockStatefulCmdable) Sort added in v0.1.1

func (m *MockStatefulCmdable) Sort(ctx context.Context, key string, sort *v8.Sort) *v8.StringSliceCmd

Sort mocks base method.

func (*MockStatefulCmdable) SortInterfaces added in v0.1.1

func (m *MockStatefulCmdable) SortInterfaces(ctx context.Context, key string, sort *v8.Sort) *v8.SliceCmd

SortInterfaces mocks base method.

func (*MockStatefulCmdable) SortStore added in v0.1.1

func (m *MockStatefulCmdable) SortStore(ctx context.Context, key, store string, sort *v8.Sort) *v8.IntCmd

SortStore mocks base method.

func (*MockStatefulCmdable) StrLen added in v0.1.1

func (m *MockStatefulCmdable) StrLen(ctx context.Context, key string) *v8.IntCmd

StrLen mocks base method.

func (*MockStatefulCmdable) SwapDB added in v0.1.1

func (m *MockStatefulCmdable) SwapDB(ctx context.Context, index1, index2 int) *v8.StatusCmd

SwapDB mocks base method.

func (*MockStatefulCmdable) TTL added in v0.1.1

TTL mocks base method.

func (*MockStatefulCmdable) Time added in v0.1.1

Time mocks base method.

func (*MockStatefulCmdable) Touch added in v0.1.1

func (m *MockStatefulCmdable) Touch(ctx context.Context, keys ...string) *v8.IntCmd

Touch mocks base method.

func (*MockStatefulCmdable) TxPipeline added in v0.1.1

func (m *MockStatefulCmdable) TxPipeline() v8.Pipeliner

TxPipeline mocks base method.

func (*MockStatefulCmdable) TxPipelined added in v0.1.1

func (m *MockStatefulCmdable) TxPipelined(ctx context.Context, fn func(v8.Pipeliner) error) ([]v8.Cmder, error)

TxPipelined mocks base method.

func (*MockStatefulCmdable) Type added in v0.1.1

Type mocks base method.

func (m *MockStatefulCmdable) Unlink(ctx context.Context, keys ...string) *v8.IntCmd

Unlink mocks base method.

func (*MockStatefulCmdable) XAck added in v0.1.1

func (m *MockStatefulCmdable) XAck(ctx context.Context, stream, group string, ids ...string) *v8.IntCmd

XAck mocks base method.

func (*MockStatefulCmdable) XAdd added in v0.1.1

XAdd mocks base method.

func (*MockStatefulCmdable) XAutoClaim added in v0.1.1

XAutoClaim mocks base method.

func (*MockStatefulCmdable) XAutoClaimJustID added in v0.1.1

XAutoClaimJustID mocks base method.

func (*MockStatefulCmdable) XClaim added in v0.1.1

XClaim mocks base method.

func (*MockStatefulCmdable) XClaimJustID added in v0.1.1

func (m *MockStatefulCmdable) XClaimJustID(ctx context.Context, a *v8.XClaimArgs) *v8.StringSliceCmd

XClaimJustID mocks base method.

func (*MockStatefulCmdable) XDel added in v0.1.1

func (m *MockStatefulCmdable) XDel(ctx context.Context, stream string, ids ...string) *v8.IntCmd

XDel mocks base method.

func (*MockStatefulCmdable) XGroupCreate added in v0.1.1

func (m *MockStatefulCmdable) XGroupCreate(ctx context.Context, stream, group, start string) *v8.StatusCmd

XGroupCreate mocks base method.

func (*MockStatefulCmdable) XGroupCreateConsumer added in v0.1.1

func (m *MockStatefulCmdable) XGroupCreateConsumer(ctx context.Context, stream, group, consumer string) *v8.IntCmd

XGroupCreateConsumer mocks base method.

func (*MockStatefulCmdable) XGroupCreateMkStream added in v0.1.1

func (m *MockStatefulCmdable) XGroupCreateMkStream(ctx context.Context, stream, group, start string) *v8.StatusCmd

XGroupCreateMkStream mocks base method.

func (*MockStatefulCmdable) XGroupDelConsumer added in v0.1.1

func (m *MockStatefulCmdable) XGroupDelConsumer(ctx context.Context, stream, group, consumer string) *v8.IntCmd

XGroupDelConsumer mocks base method.

func (*MockStatefulCmdable) XGroupDestroy added in v0.1.1

func (m *MockStatefulCmdable) XGroupDestroy(ctx context.Context, stream, group string) *v8.IntCmd

XGroupDestroy mocks base method.

func (*MockStatefulCmdable) XGroupSetID added in v0.1.1

func (m *MockStatefulCmdable) XGroupSetID(ctx context.Context, stream, group, start string) *v8.StatusCmd

XGroupSetID mocks base method.

func (*MockStatefulCmdable) XInfoConsumers added in v0.1.1

func (m *MockStatefulCmdable) XInfoConsumers(ctx context.Context, key, group string) *v8.XInfoConsumersCmd

XInfoConsumers mocks base method.

func (*MockStatefulCmdable) XInfoGroups added in v0.1.1

func (m *MockStatefulCmdable) XInfoGroups(ctx context.Context, key string) *v8.XInfoGroupsCmd

XInfoGroups mocks base method.

func (*MockStatefulCmdable) XInfoStream added in v0.1.1

func (m *MockStatefulCmdable) XInfoStream(ctx context.Context, key string) *v8.XInfoStreamCmd

XInfoStream mocks base method.

func (*MockStatefulCmdable) XInfoStreamFull added in v0.1.1

func (m *MockStatefulCmdable) XInfoStreamFull(ctx context.Context, key string, count int) *v8.XInfoStreamFullCmd

XInfoStreamFull mocks base method.

func (*MockStatefulCmdable) XLen added in v0.1.1

func (m *MockStatefulCmdable) XLen(ctx context.Context, stream string) *v8.IntCmd

XLen mocks base method.

func (*MockStatefulCmdable) XPending added in v0.1.1

func (m *MockStatefulCmdable) XPending(ctx context.Context, stream, group string) *v8.XPendingCmd

XPending mocks base method.

func (*MockStatefulCmdable) XPendingExt added in v0.1.1

XPendingExt mocks base method.

func (*MockStatefulCmdable) XRange added in v0.1.1

func (m *MockStatefulCmdable) XRange(ctx context.Context, stream, start, stop string) *v8.XMessageSliceCmd

XRange mocks base method.

func (*MockStatefulCmdable) XRangeN added in v0.1.1

func (m *MockStatefulCmdable) XRangeN(ctx context.Context, stream, start, stop string, count int64) *v8.XMessageSliceCmd

XRangeN mocks base method.

func (*MockStatefulCmdable) XRead added in v0.1.1

XRead mocks base method.

func (*MockStatefulCmdable) XReadGroup added in v0.1.1

XReadGroup mocks base method.

func (*MockStatefulCmdable) XReadStreams added in v0.1.1

func (m *MockStatefulCmdable) XReadStreams(ctx context.Context, streams ...string) *v8.XStreamSliceCmd

XReadStreams mocks base method.

func (*MockStatefulCmdable) XRevRange added in v0.1.1

func (m *MockStatefulCmdable) XRevRange(ctx context.Context, stream, start, stop string) *v8.XMessageSliceCmd

XRevRange mocks base method.

func (*MockStatefulCmdable) XRevRangeN added in v0.1.1

func (m *MockStatefulCmdable) XRevRangeN(ctx context.Context, stream, start, stop string, count int64) *v8.XMessageSliceCmd

XRevRangeN mocks base method.

func (*MockStatefulCmdable) XTrim added in v0.1.1

func (m *MockStatefulCmdable) XTrim(ctx context.Context, key string, maxLen int64) *v8.IntCmd

XTrim mocks base method.

func (*MockStatefulCmdable) XTrimApprox added in v0.1.1

func (m *MockStatefulCmdable) XTrimApprox(ctx context.Context, key string, maxLen int64) *v8.IntCmd

XTrimApprox mocks base method.

func (*MockStatefulCmdable) XTrimMaxLen added in v0.1.1

func (m *MockStatefulCmdable) XTrimMaxLen(ctx context.Context, key string, maxLen int64) *v8.IntCmd

XTrimMaxLen mocks base method.

func (*MockStatefulCmdable) XTrimMaxLenApprox added in v0.1.1

func (m *MockStatefulCmdable) XTrimMaxLenApprox(ctx context.Context, key string, maxLen, limit int64) *v8.IntCmd

XTrimMaxLenApprox mocks base method.

func (*MockStatefulCmdable) XTrimMinID added in v0.1.1

func (m *MockStatefulCmdable) XTrimMinID(ctx context.Context, key, minID string) *v8.IntCmd

XTrimMinID mocks base method.

func (*MockStatefulCmdable) XTrimMinIDApprox added in v0.1.1

func (m *MockStatefulCmdable) XTrimMinIDApprox(ctx context.Context, key, minID string, limit int64) *v8.IntCmd

XTrimMinIDApprox mocks base method.

func (*MockStatefulCmdable) ZAdd added in v0.1.1

func (m *MockStatefulCmdable) ZAdd(ctx context.Context, key string, members ...*v8.Z) *v8.IntCmd

ZAdd mocks base method.

func (*MockStatefulCmdable) ZAddArgs added in v0.1.1

func (m *MockStatefulCmdable) ZAddArgs(ctx context.Context, key string, args v8.ZAddArgs) *v8.IntCmd

ZAddArgs mocks base method.

func (*MockStatefulCmdable) ZAddArgsIncr added in v0.1.1

func (m *MockStatefulCmdable) ZAddArgsIncr(ctx context.Context, key string, args v8.ZAddArgs) *v8.FloatCmd

ZAddArgsIncr mocks base method.

func (*MockStatefulCmdable) ZAddCh added in v0.1.1

func (m *MockStatefulCmdable) ZAddCh(ctx context.Context, key string, members ...*v8.Z) *v8.IntCmd

ZAddCh mocks base method.

func (*MockStatefulCmdable) ZAddNX added in v0.1.1

func (m *MockStatefulCmdable) ZAddNX(ctx context.Context, key string, members ...*v8.Z) *v8.IntCmd

ZAddNX mocks base method.

func (*MockStatefulCmdable) ZAddNXCh added in v0.1.1

func (m *MockStatefulCmdable) ZAddNXCh(ctx context.Context, key string, members ...*v8.Z) *v8.IntCmd

ZAddNXCh mocks base method.

func (*MockStatefulCmdable) ZAddXX added in v0.1.1

func (m *MockStatefulCmdable) ZAddXX(ctx context.Context, key string, members ...*v8.Z) *v8.IntCmd

ZAddXX mocks base method.

func (*MockStatefulCmdable) ZAddXXCh added in v0.1.1

func (m *MockStatefulCmdable) ZAddXXCh(ctx context.Context, key string, members ...*v8.Z) *v8.IntCmd

ZAddXXCh mocks base method.

func (*MockStatefulCmdable) ZCard added in v0.1.1

func (m *MockStatefulCmdable) ZCard(ctx context.Context, key string) *v8.IntCmd

ZCard mocks base method.

func (*MockStatefulCmdable) ZCount added in v0.1.1

func (m *MockStatefulCmdable) ZCount(ctx context.Context, key, min, max string) *v8.IntCmd

ZCount mocks base method.

func (*MockStatefulCmdable) ZDiff added in v0.1.1

func (m *MockStatefulCmdable) ZDiff(ctx context.Context, keys ...string) *v8.StringSliceCmd

ZDiff mocks base method.

func (*MockStatefulCmdable) ZDiffStore added in v0.1.1

func (m *MockStatefulCmdable) ZDiffStore(ctx context.Context, destination string, keys ...string) *v8.IntCmd

ZDiffStore mocks base method.

func (*MockStatefulCmdable) ZDiffWithScores added in v0.1.1

func (m *MockStatefulCmdable) ZDiffWithScores(ctx context.Context, keys ...string) *v8.ZSliceCmd

ZDiffWithScores mocks base method.

func (*MockStatefulCmdable) ZIncr added in v0.1.1

func (m *MockStatefulCmdable) ZIncr(ctx context.Context, key string, member *v8.Z) *v8.FloatCmd

ZIncr mocks base method.

func (*MockStatefulCmdable) ZIncrBy added in v0.1.1

func (m *MockStatefulCmdable) ZIncrBy(ctx context.Context, key string, increment float64, member string) *v8.FloatCmd

ZIncrBy mocks base method.

func (*MockStatefulCmdable) ZIncrNX added in v0.1.1

func (m *MockStatefulCmdable) ZIncrNX(ctx context.Context, key string, member *v8.Z) *v8.FloatCmd

ZIncrNX mocks base method.

func (*MockStatefulCmdable) ZIncrXX added in v0.1.1

func (m *MockStatefulCmdable) ZIncrXX(ctx context.Context, key string, member *v8.Z) *v8.FloatCmd

ZIncrXX mocks base method.

func (*MockStatefulCmdable) ZInter added in v0.1.1

func (m *MockStatefulCmdable) ZInter(ctx context.Context, store *v8.ZStore) *v8.StringSliceCmd

ZInter mocks base method.

func (*MockStatefulCmdable) ZInterStore added in v0.1.1

func (m *MockStatefulCmdable) ZInterStore(ctx context.Context, destination string, store *v8.ZStore) *v8.IntCmd

ZInterStore mocks base method.

func (*MockStatefulCmdable) ZInterWithScores added in v0.1.1

func (m *MockStatefulCmdable) ZInterWithScores(ctx context.Context, store *v8.ZStore) *v8.ZSliceCmd

ZInterWithScores mocks base method.

func (*MockStatefulCmdable) ZLexCount added in v0.1.1

func (m *MockStatefulCmdable) ZLexCount(ctx context.Context, key, min, max string) *v8.IntCmd

ZLexCount mocks base method.

func (*MockStatefulCmdable) ZMScore added in v0.1.1

func (m *MockStatefulCmdable) ZMScore(ctx context.Context, key string, members ...string) *v8.FloatSliceCmd

ZMScore mocks base method.

func (*MockStatefulCmdable) ZPopMax added in v0.1.1

func (m *MockStatefulCmdable) ZPopMax(ctx context.Context, key string, count ...int64) *v8.ZSliceCmd

ZPopMax mocks base method.

func (*MockStatefulCmdable) ZPopMin added in v0.1.1

func (m *MockStatefulCmdable) ZPopMin(ctx context.Context, key string, count ...int64) *v8.ZSliceCmd

ZPopMin mocks base method.

func (*MockStatefulCmdable) ZRandMember added in v0.1.1

func (m *MockStatefulCmdable) ZRandMember(ctx context.Context, key string, count int, withScores bool) *v8.StringSliceCmd

ZRandMember mocks base method.

func (*MockStatefulCmdable) ZRange added in v0.1.1

func (m *MockStatefulCmdable) ZRange(ctx context.Context, key string, start, stop int64) *v8.StringSliceCmd

ZRange mocks base method.

func (*MockStatefulCmdable) ZRangeArgs added in v0.1.1

ZRangeArgs mocks base method.

func (*MockStatefulCmdable) ZRangeArgsWithScores added in v0.1.1

func (m *MockStatefulCmdable) ZRangeArgsWithScores(ctx context.Context, z v8.ZRangeArgs) *v8.ZSliceCmd

ZRangeArgsWithScores mocks base method.

func (*MockStatefulCmdable) ZRangeByLex added in v0.1.1

func (m *MockStatefulCmdable) ZRangeByLex(ctx context.Context, key string, opt *v8.ZRangeBy) *v8.StringSliceCmd

ZRangeByLex mocks base method.

func (*MockStatefulCmdable) ZRangeByScore added in v0.1.1

func (m *MockStatefulCmdable) ZRangeByScore(ctx context.Context, key string, opt *v8.ZRangeBy) *v8.StringSliceCmd

ZRangeByScore mocks base method.

func (*MockStatefulCmdable) ZRangeByScoreWithScores added in v0.1.1

func (m *MockStatefulCmdable) ZRangeByScoreWithScores(ctx context.Context, key string, opt *v8.ZRangeBy) *v8.ZSliceCmd

ZRangeByScoreWithScores mocks base method.

func (*MockStatefulCmdable) ZRangeStore added in v0.1.1

func (m *MockStatefulCmdable) ZRangeStore(ctx context.Context, dst string, z v8.ZRangeArgs) *v8.IntCmd

ZRangeStore mocks base method.

func (*MockStatefulCmdable) ZRangeWithScores added in v0.1.1

func (m *MockStatefulCmdable) ZRangeWithScores(ctx context.Context, key string, start, stop int64) *v8.ZSliceCmd

ZRangeWithScores mocks base method.

func (*MockStatefulCmdable) ZRank added in v0.1.1

func (m *MockStatefulCmdable) ZRank(ctx context.Context, key, member string) *v8.IntCmd

ZRank mocks base method.

func (*MockStatefulCmdable) ZRem added in v0.1.1

func (m *MockStatefulCmdable) ZRem(ctx context.Context, key string, members ...interface{}) *v8.IntCmd

ZRem mocks base method.

func (*MockStatefulCmdable) ZRemRangeByLex added in v0.1.1

func (m *MockStatefulCmdable) ZRemRangeByLex(ctx context.Context, key, min, max string) *v8.IntCmd

ZRemRangeByLex mocks base method.

func (*MockStatefulCmdable) ZRemRangeByRank added in v0.1.1

func (m *MockStatefulCmdable) ZRemRangeByRank(ctx context.Context, key string, start, stop int64) *v8.IntCmd

ZRemRangeByRank mocks base method.

func (*MockStatefulCmdable) ZRemRangeByScore added in v0.1.1

func (m *MockStatefulCmdable) ZRemRangeByScore(ctx context.Context, key, min, max string) *v8.IntCmd

ZRemRangeByScore mocks base method.

func (*MockStatefulCmdable) ZRevRange added in v0.1.1

func (m *MockStatefulCmdable) ZRevRange(ctx context.Context, key string, start, stop int64) *v8.StringSliceCmd

ZRevRange mocks base method.

func (*MockStatefulCmdable) ZRevRangeByLex added in v0.1.1

func (m *MockStatefulCmdable) ZRevRangeByLex(ctx context.Context, key string, opt *v8.ZRangeBy) *v8.StringSliceCmd

ZRevRangeByLex mocks base method.

func (*MockStatefulCmdable) ZRevRangeByScore added in v0.1.1

func (m *MockStatefulCmdable) ZRevRangeByScore(ctx context.Context, key string, opt *v8.ZRangeBy) *v8.StringSliceCmd

ZRevRangeByScore mocks base method.

func (*MockStatefulCmdable) ZRevRangeByScoreWithScores added in v0.1.1

func (m *MockStatefulCmdable) ZRevRangeByScoreWithScores(ctx context.Context, key string, opt *v8.ZRangeBy) *v8.ZSliceCmd

ZRevRangeByScoreWithScores mocks base method.

func (*MockStatefulCmdable) ZRevRangeWithScores added in v0.1.1

func (m *MockStatefulCmdable) ZRevRangeWithScores(ctx context.Context, key string, start, stop int64) *v8.ZSliceCmd

ZRevRangeWithScores mocks base method.

func (*MockStatefulCmdable) ZRevRank added in v0.1.1

func (m *MockStatefulCmdable) ZRevRank(ctx context.Context, key, member string) *v8.IntCmd

ZRevRank mocks base method.

func (*MockStatefulCmdable) ZScan added in v0.1.1

func (m *MockStatefulCmdable) ZScan(ctx context.Context, key string, cursor uint64, match string, count int64) *v8.ScanCmd

ZScan mocks base method.

func (*MockStatefulCmdable) ZScore added in v0.1.1

func (m *MockStatefulCmdable) ZScore(ctx context.Context, key, member string) *v8.FloatCmd

ZScore mocks base method.

func (*MockStatefulCmdable) ZUnion added in v0.1.1

func (m *MockStatefulCmdable) ZUnion(ctx context.Context, store v8.ZStore) *v8.StringSliceCmd

ZUnion mocks base method.

func (*MockStatefulCmdable) ZUnionStore added in v0.1.1

func (m *MockStatefulCmdable) ZUnionStore(ctx context.Context, dest string, store *v8.ZStore) *v8.IntCmd

ZUnionStore mocks base method.

func (*MockStatefulCmdable) ZUnionWithScores added in v0.1.1

func (m *MockStatefulCmdable) ZUnionWithScores(ctx context.Context, store v8.ZStore) *v8.ZSliceCmd

ZUnionWithScores mocks base method.

type MockStatefulCmdableMockRecorder added in v0.1.1

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

MockStatefulCmdableMockRecorder is the mock recorder for MockStatefulCmdable.

func (*MockStatefulCmdableMockRecorder) Append added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) Append(ctx, key, value interface{}) *gomock.Call

Append indicates an expected call of Append.

func (*MockStatefulCmdableMockRecorder) Auth added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) Auth(ctx, password interface{}) *gomock.Call

Auth indicates an expected call of Auth.

func (*MockStatefulCmdableMockRecorder) AuthACL added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) AuthACL(ctx, username, password interface{}) *gomock.Call

AuthACL indicates an expected call of AuthACL.

func (*MockStatefulCmdableMockRecorder) BLMove added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) BLMove(ctx, source, destination, srcpos, destpos, timeout interface{}) *gomock.Call

BLMove indicates an expected call of BLMove.

func (*MockStatefulCmdableMockRecorder) BLPop added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) BLPop(ctx, timeout interface{}, keys ...interface{}) *gomock.Call

BLPop indicates an expected call of BLPop.

func (*MockStatefulCmdableMockRecorder) BRPop added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) BRPop(ctx, timeout interface{}, keys ...interface{}) *gomock.Call

BRPop indicates an expected call of BRPop.

func (*MockStatefulCmdableMockRecorder) BRPopLPush added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) BRPopLPush(ctx, source, destination, timeout interface{}) *gomock.Call

BRPopLPush indicates an expected call of BRPopLPush.

func (*MockStatefulCmdableMockRecorder) BZPopMax added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) BZPopMax(ctx, timeout interface{}, keys ...interface{}) *gomock.Call

BZPopMax indicates an expected call of BZPopMax.

func (*MockStatefulCmdableMockRecorder) BZPopMin added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) BZPopMin(ctx, timeout interface{}, keys ...interface{}) *gomock.Call

BZPopMin indicates an expected call of BZPopMin.

func (*MockStatefulCmdableMockRecorder) BgRewriteAOF added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) BgRewriteAOF(ctx interface{}) *gomock.Call

BgRewriteAOF indicates an expected call of BgRewriteAOF.

func (*MockStatefulCmdableMockRecorder) BgSave added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) BgSave(ctx interface{}) *gomock.Call

BgSave indicates an expected call of BgSave.

func (*MockStatefulCmdableMockRecorder) BitCount added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) BitCount(ctx, key, bitCount interface{}) *gomock.Call

BitCount indicates an expected call of BitCount.

func (*MockStatefulCmdableMockRecorder) BitField added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) BitField(ctx, key interface{}, args ...interface{}) *gomock.Call

BitField indicates an expected call of BitField.

func (*MockStatefulCmdableMockRecorder) BitOpAnd added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) BitOpAnd(ctx, destKey interface{}, keys ...interface{}) *gomock.Call

BitOpAnd indicates an expected call of BitOpAnd.

func (*MockStatefulCmdableMockRecorder) BitOpNot added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) BitOpNot(ctx, destKey, key interface{}) *gomock.Call

BitOpNot indicates an expected call of BitOpNot.

func (*MockStatefulCmdableMockRecorder) BitOpOr added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) BitOpOr(ctx, destKey interface{}, keys ...interface{}) *gomock.Call

BitOpOr indicates an expected call of BitOpOr.

func (*MockStatefulCmdableMockRecorder) BitOpXor added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) BitOpXor(ctx, destKey interface{}, keys ...interface{}) *gomock.Call

BitOpXor indicates an expected call of BitOpXor.

func (*MockStatefulCmdableMockRecorder) BitPos added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) BitPos(ctx, key, bit interface{}, pos ...interface{}) *gomock.Call

BitPos indicates an expected call of BitPos.

func (*MockStatefulCmdableMockRecorder) ClientGetName added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ClientGetName(ctx interface{}) *gomock.Call

ClientGetName indicates an expected call of ClientGetName.

func (*MockStatefulCmdableMockRecorder) ClientID added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ClientID(ctx interface{}) *gomock.Call

ClientID indicates an expected call of ClientID.

func (*MockStatefulCmdableMockRecorder) ClientKill added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ClientKill(ctx, ipPort interface{}) *gomock.Call

ClientKill indicates an expected call of ClientKill.

func (*MockStatefulCmdableMockRecorder) ClientKillByFilter added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ClientKillByFilter(ctx interface{}, keys ...interface{}) *gomock.Call

ClientKillByFilter indicates an expected call of ClientKillByFilter.

func (*MockStatefulCmdableMockRecorder) ClientList added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ClientList(ctx interface{}) *gomock.Call

ClientList indicates an expected call of ClientList.

func (*MockStatefulCmdableMockRecorder) ClientPause added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ClientPause(ctx, dur interface{}) *gomock.Call

ClientPause indicates an expected call of ClientPause.

func (*MockStatefulCmdableMockRecorder) ClientSetName added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ClientSetName(ctx, name interface{}) *gomock.Call

ClientSetName indicates an expected call of ClientSetName.

func (*MockStatefulCmdableMockRecorder) ClusterAddSlots added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ClusterAddSlots(ctx interface{}, slots ...interface{}) *gomock.Call

ClusterAddSlots indicates an expected call of ClusterAddSlots.

func (*MockStatefulCmdableMockRecorder) ClusterAddSlotsRange added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ClusterAddSlotsRange(ctx, min, max interface{}) *gomock.Call

ClusterAddSlotsRange indicates an expected call of ClusterAddSlotsRange.

func (*MockStatefulCmdableMockRecorder) ClusterCountFailureReports added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ClusterCountFailureReports(ctx, nodeID interface{}) *gomock.Call

ClusterCountFailureReports indicates an expected call of ClusterCountFailureReports.

func (*MockStatefulCmdableMockRecorder) ClusterCountKeysInSlot added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ClusterCountKeysInSlot(ctx, slot interface{}) *gomock.Call

ClusterCountKeysInSlot indicates an expected call of ClusterCountKeysInSlot.

func (*MockStatefulCmdableMockRecorder) ClusterDelSlots added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ClusterDelSlots(ctx interface{}, slots ...interface{}) *gomock.Call

ClusterDelSlots indicates an expected call of ClusterDelSlots.

func (*MockStatefulCmdableMockRecorder) ClusterDelSlotsRange added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ClusterDelSlotsRange(ctx, min, max interface{}) *gomock.Call

ClusterDelSlotsRange indicates an expected call of ClusterDelSlotsRange.

func (*MockStatefulCmdableMockRecorder) ClusterFailover added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ClusterFailover(ctx interface{}) *gomock.Call

ClusterFailover indicates an expected call of ClusterFailover.

func (*MockStatefulCmdableMockRecorder) ClusterForget added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ClusterForget(ctx, nodeID interface{}) *gomock.Call

ClusterForget indicates an expected call of ClusterForget.

func (*MockStatefulCmdableMockRecorder) ClusterGetKeysInSlot added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ClusterGetKeysInSlot(ctx, slot, count interface{}) *gomock.Call

ClusterGetKeysInSlot indicates an expected call of ClusterGetKeysInSlot.

func (*MockStatefulCmdableMockRecorder) ClusterInfo added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ClusterInfo(ctx interface{}) *gomock.Call

ClusterInfo indicates an expected call of ClusterInfo.

func (*MockStatefulCmdableMockRecorder) ClusterKeySlot added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ClusterKeySlot(ctx, key interface{}) *gomock.Call

ClusterKeySlot indicates an expected call of ClusterKeySlot.

func (*MockStatefulCmdableMockRecorder) ClusterMeet added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ClusterMeet(ctx, host, port interface{}) *gomock.Call

ClusterMeet indicates an expected call of ClusterMeet.

func (*MockStatefulCmdableMockRecorder) ClusterNodes added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ClusterNodes(ctx interface{}) *gomock.Call

ClusterNodes indicates an expected call of ClusterNodes.

func (*MockStatefulCmdableMockRecorder) ClusterReplicate added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ClusterReplicate(ctx, nodeID interface{}) *gomock.Call

ClusterReplicate indicates an expected call of ClusterReplicate.

func (*MockStatefulCmdableMockRecorder) ClusterResetHard added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ClusterResetHard(ctx interface{}) *gomock.Call

ClusterResetHard indicates an expected call of ClusterResetHard.

func (*MockStatefulCmdableMockRecorder) ClusterResetSoft added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ClusterResetSoft(ctx interface{}) *gomock.Call

ClusterResetSoft indicates an expected call of ClusterResetSoft.

func (*MockStatefulCmdableMockRecorder) ClusterSaveConfig added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ClusterSaveConfig(ctx interface{}) *gomock.Call

ClusterSaveConfig indicates an expected call of ClusterSaveConfig.

func (*MockStatefulCmdableMockRecorder) ClusterSlaves added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ClusterSlaves(ctx, nodeID interface{}) *gomock.Call

ClusterSlaves indicates an expected call of ClusterSlaves.

func (*MockStatefulCmdableMockRecorder) ClusterSlots added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ClusterSlots(ctx interface{}) *gomock.Call

ClusterSlots indicates an expected call of ClusterSlots.

func (*MockStatefulCmdableMockRecorder) Command added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) Command(ctx interface{}) *gomock.Call

Command indicates an expected call of Command.

func (*MockStatefulCmdableMockRecorder) ConfigGet added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ConfigGet(ctx, parameter interface{}) *gomock.Call

ConfigGet indicates an expected call of ConfigGet.

func (*MockStatefulCmdableMockRecorder) ConfigResetStat added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ConfigResetStat(ctx interface{}) *gomock.Call

ConfigResetStat indicates an expected call of ConfigResetStat.

func (*MockStatefulCmdableMockRecorder) ConfigRewrite added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ConfigRewrite(ctx interface{}) *gomock.Call

ConfigRewrite indicates an expected call of ConfigRewrite.

func (*MockStatefulCmdableMockRecorder) ConfigSet added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ConfigSet(ctx, parameter, value interface{}) *gomock.Call

ConfigSet indicates an expected call of ConfigSet.

func (*MockStatefulCmdableMockRecorder) Copy added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) Copy(ctx, sourceKey, destKey, db, replace interface{}) *gomock.Call

Copy indicates an expected call of Copy.

func (*MockStatefulCmdableMockRecorder) DBSize added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) DBSize(ctx interface{}) *gomock.Call

DBSize indicates an expected call of DBSize.

func (*MockStatefulCmdableMockRecorder) DebugObject added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) DebugObject(ctx, key interface{}) *gomock.Call

DebugObject indicates an expected call of DebugObject.

func (*MockStatefulCmdableMockRecorder) Decr added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) Decr(ctx, key interface{}) *gomock.Call

Decr indicates an expected call of Decr.

func (*MockStatefulCmdableMockRecorder) DecrBy added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) DecrBy(ctx, key, decrement interface{}) *gomock.Call

DecrBy indicates an expected call of DecrBy.

func (*MockStatefulCmdableMockRecorder) Del added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) Del(ctx interface{}, keys ...interface{}) *gomock.Call

Del indicates an expected call of Del.

func (*MockStatefulCmdableMockRecorder) Dump added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) Dump(ctx, key interface{}) *gomock.Call

Dump indicates an expected call of Dump.

func (*MockStatefulCmdableMockRecorder) Echo added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) Echo(ctx, message interface{}) *gomock.Call

Echo indicates an expected call of Echo.

func (*MockStatefulCmdableMockRecorder) Eval added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) Eval(ctx, script, keys interface{}, args ...interface{}) *gomock.Call

Eval indicates an expected call of Eval.

func (*MockStatefulCmdableMockRecorder) EvalSha added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) EvalSha(ctx, sha1, keys interface{}, args ...interface{}) *gomock.Call

EvalSha indicates an expected call of EvalSha.

func (*MockStatefulCmdableMockRecorder) Exists added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) Exists(ctx interface{}, keys ...interface{}) *gomock.Call

Exists indicates an expected call of Exists.

func (*MockStatefulCmdableMockRecorder) Expire added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) Expire(ctx, key, expiration interface{}) *gomock.Call

Expire indicates an expected call of Expire.

func (*MockStatefulCmdableMockRecorder) ExpireAt added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ExpireAt(ctx, key, tm interface{}) *gomock.Call

ExpireAt indicates an expected call of ExpireAt.

func (*MockStatefulCmdableMockRecorder) ExpireGT added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ExpireGT(ctx, key, expiration interface{}) *gomock.Call

ExpireGT indicates an expected call of ExpireGT.

func (*MockStatefulCmdableMockRecorder) ExpireLT added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ExpireLT(ctx, key, expiration interface{}) *gomock.Call

ExpireLT indicates an expected call of ExpireLT.

func (*MockStatefulCmdableMockRecorder) ExpireNX added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ExpireNX(ctx, key, expiration interface{}) *gomock.Call

ExpireNX indicates an expected call of ExpireNX.

func (*MockStatefulCmdableMockRecorder) ExpireXX added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ExpireXX(ctx, key, expiration interface{}) *gomock.Call

ExpireXX indicates an expected call of ExpireXX.

func (*MockStatefulCmdableMockRecorder) FlushAll added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) FlushAll(ctx interface{}) *gomock.Call

FlushAll indicates an expected call of FlushAll.

func (*MockStatefulCmdableMockRecorder) FlushAllAsync added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) FlushAllAsync(ctx interface{}) *gomock.Call

FlushAllAsync indicates an expected call of FlushAllAsync.

func (*MockStatefulCmdableMockRecorder) FlushDB added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) FlushDB(ctx interface{}) *gomock.Call

FlushDB indicates an expected call of FlushDB.

func (*MockStatefulCmdableMockRecorder) FlushDBAsync added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) FlushDBAsync(ctx interface{}) *gomock.Call

FlushDBAsync indicates an expected call of FlushDBAsync.

func (*MockStatefulCmdableMockRecorder) GeoAdd added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) GeoAdd(ctx, key interface{}, geoLocation ...interface{}) *gomock.Call

GeoAdd indicates an expected call of GeoAdd.

func (*MockStatefulCmdableMockRecorder) GeoDist added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) GeoDist(ctx, key, member1, member2, unit interface{}) *gomock.Call

GeoDist indicates an expected call of GeoDist.

func (*MockStatefulCmdableMockRecorder) GeoHash added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) GeoHash(ctx, key interface{}, members ...interface{}) *gomock.Call

GeoHash indicates an expected call of GeoHash.

func (*MockStatefulCmdableMockRecorder) GeoPos added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) GeoPos(ctx, key interface{}, members ...interface{}) *gomock.Call

GeoPos indicates an expected call of GeoPos.

func (*MockStatefulCmdableMockRecorder) GeoRadius added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) GeoRadius(ctx, key, longitude, latitude, query interface{}) *gomock.Call

GeoRadius indicates an expected call of GeoRadius.

func (*MockStatefulCmdableMockRecorder) GeoRadiusByMember added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) GeoRadiusByMember(ctx, key, member, query interface{}) *gomock.Call

GeoRadiusByMember indicates an expected call of GeoRadiusByMember.

func (*MockStatefulCmdableMockRecorder) GeoRadiusByMemberStore added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) GeoRadiusByMemberStore(ctx, key, member, query interface{}) *gomock.Call

GeoRadiusByMemberStore indicates an expected call of GeoRadiusByMemberStore.

func (*MockStatefulCmdableMockRecorder) GeoRadiusStore added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) GeoRadiusStore(ctx, key, longitude, latitude, query interface{}) *gomock.Call

GeoRadiusStore indicates an expected call of GeoRadiusStore.

func (*MockStatefulCmdableMockRecorder) GeoSearch added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) GeoSearch(ctx, key, q interface{}) *gomock.Call

GeoSearch indicates an expected call of GeoSearch.

func (*MockStatefulCmdableMockRecorder) GeoSearchLocation added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) GeoSearchLocation(ctx, key, q interface{}) *gomock.Call

GeoSearchLocation indicates an expected call of GeoSearchLocation.

func (*MockStatefulCmdableMockRecorder) GeoSearchStore added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) GeoSearchStore(ctx, key, store, q interface{}) *gomock.Call

GeoSearchStore indicates an expected call of GeoSearchStore.

func (*MockStatefulCmdableMockRecorder) Get added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) Get(ctx, key interface{}) *gomock.Call

Get indicates an expected call of Get.

func (*MockStatefulCmdableMockRecorder) GetBit added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) GetBit(ctx, key, offset interface{}) *gomock.Call

GetBit indicates an expected call of GetBit.

func (*MockStatefulCmdableMockRecorder) GetDel added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) GetDel(ctx, key interface{}) *gomock.Call

GetDel indicates an expected call of GetDel.

func (*MockStatefulCmdableMockRecorder) GetEx added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) GetEx(ctx, key, expiration interface{}) *gomock.Call

GetEx indicates an expected call of GetEx.

func (*MockStatefulCmdableMockRecorder) GetRange added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) GetRange(ctx, key, start, end interface{}) *gomock.Call

GetRange indicates an expected call of GetRange.

func (*MockStatefulCmdableMockRecorder) GetSet added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) GetSet(ctx, key, value interface{}) *gomock.Call

GetSet indicates an expected call of GetSet.

func (*MockStatefulCmdableMockRecorder) HDel added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) HDel(ctx, key interface{}, fields ...interface{}) *gomock.Call

HDel indicates an expected call of HDel.

func (*MockStatefulCmdableMockRecorder) HExists added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) HExists(ctx, key, field interface{}) *gomock.Call

HExists indicates an expected call of HExists.

func (*MockStatefulCmdableMockRecorder) HGet added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) HGet(ctx, key, field interface{}) *gomock.Call

HGet indicates an expected call of HGet.

func (*MockStatefulCmdableMockRecorder) HGetAll added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) HGetAll(ctx, key interface{}) *gomock.Call

HGetAll indicates an expected call of HGetAll.

func (*MockStatefulCmdableMockRecorder) HIncrBy added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) HIncrBy(ctx, key, field, incr interface{}) *gomock.Call

HIncrBy indicates an expected call of HIncrBy.

func (*MockStatefulCmdableMockRecorder) HIncrByFloat added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) HIncrByFloat(ctx, key, field, incr interface{}) *gomock.Call

HIncrByFloat indicates an expected call of HIncrByFloat.

func (*MockStatefulCmdableMockRecorder) HKeys added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) HKeys(ctx, key interface{}) *gomock.Call

HKeys indicates an expected call of HKeys.

func (*MockStatefulCmdableMockRecorder) HLen added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) HLen(ctx, key interface{}) *gomock.Call

HLen indicates an expected call of HLen.

func (*MockStatefulCmdableMockRecorder) HMGet added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) HMGet(ctx, key interface{}, fields ...interface{}) *gomock.Call

HMGet indicates an expected call of HMGet.

func (*MockStatefulCmdableMockRecorder) HMSet added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) HMSet(ctx, key interface{}, values ...interface{}) *gomock.Call

HMSet indicates an expected call of HMSet.

func (*MockStatefulCmdableMockRecorder) HRandField added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) HRandField(ctx, key, count, withValues interface{}) *gomock.Call

HRandField indicates an expected call of HRandField.

func (*MockStatefulCmdableMockRecorder) HScan added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) HScan(ctx, key, cursor, match, count interface{}) *gomock.Call

HScan indicates an expected call of HScan.

func (*MockStatefulCmdableMockRecorder) HSet added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) HSet(ctx, key interface{}, values ...interface{}) *gomock.Call

HSet indicates an expected call of HSet.

func (*MockStatefulCmdableMockRecorder) HSetNX added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) HSetNX(ctx, key, field, value interface{}) *gomock.Call

HSetNX indicates an expected call of HSetNX.

func (*MockStatefulCmdableMockRecorder) HVals added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) HVals(ctx, key interface{}) *gomock.Call

HVals indicates an expected call of HVals.

func (*MockStatefulCmdableMockRecorder) Incr added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) Incr(ctx, key interface{}) *gomock.Call

Incr indicates an expected call of Incr.

func (*MockStatefulCmdableMockRecorder) IncrBy added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) IncrBy(ctx, key, value interface{}) *gomock.Call

IncrBy indicates an expected call of IncrBy.

func (*MockStatefulCmdableMockRecorder) IncrByFloat added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) IncrByFloat(ctx, key, value interface{}) *gomock.Call

IncrByFloat indicates an expected call of IncrByFloat.

func (*MockStatefulCmdableMockRecorder) Info added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) Info(ctx interface{}, section ...interface{}) *gomock.Call

Info indicates an expected call of Info.

func (*MockStatefulCmdableMockRecorder) Keys added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) Keys(ctx, pattern interface{}) *gomock.Call

Keys indicates an expected call of Keys.

func (*MockStatefulCmdableMockRecorder) LIndex added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) LIndex(ctx, key, index interface{}) *gomock.Call

LIndex indicates an expected call of LIndex.

func (*MockStatefulCmdableMockRecorder) LInsert added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) LInsert(ctx, key, op, pivot, value interface{}) *gomock.Call

LInsert indicates an expected call of LInsert.

func (*MockStatefulCmdableMockRecorder) LInsertAfter added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) LInsertAfter(ctx, key, pivot, value interface{}) *gomock.Call

LInsertAfter indicates an expected call of LInsertAfter.

func (*MockStatefulCmdableMockRecorder) LInsertBefore added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) LInsertBefore(ctx, key, pivot, value interface{}) *gomock.Call

LInsertBefore indicates an expected call of LInsertBefore.

func (*MockStatefulCmdableMockRecorder) LLen added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) LLen(ctx, key interface{}) *gomock.Call

LLen indicates an expected call of LLen.

func (*MockStatefulCmdableMockRecorder) LMove added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) LMove(ctx, source, destination, srcpos, destpos interface{}) *gomock.Call

LMove indicates an expected call of LMove.

func (*MockStatefulCmdableMockRecorder) LPop added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) LPop(ctx, key interface{}) *gomock.Call

LPop indicates an expected call of LPop.

func (*MockStatefulCmdableMockRecorder) LPopCount added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) LPopCount(ctx, key, count interface{}) *gomock.Call

LPopCount indicates an expected call of LPopCount.

func (*MockStatefulCmdableMockRecorder) LPos added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) LPos(ctx, key, value, args interface{}) *gomock.Call

LPos indicates an expected call of LPos.

func (*MockStatefulCmdableMockRecorder) LPosCount added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) LPosCount(ctx, key, value, count, args interface{}) *gomock.Call

LPosCount indicates an expected call of LPosCount.

func (*MockStatefulCmdableMockRecorder) LPush added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) LPush(ctx, key interface{}, values ...interface{}) *gomock.Call

LPush indicates an expected call of LPush.

func (*MockStatefulCmdableMockRecorder) LPushX added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) LPushX(ctx, key interface{}, values ...interface{}) *gomock.Call

LPushX indicates an expected call of LPushX.

func (*MockStatefulCmdableMockRecorder) LRange added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) LRange(ctx, key, start, stop interface{}) *gomock.Call

LRange indicates an expected call of LRange.

func (*MockStatefulCmdableMockRecorder) LRem added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) LRem(ctx, key, count, value interface{}) *gomock.Call

LRem indicates an expected call of LRem.

func (*MockStatefulCmdableMockRecorder) LSet added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) LSet(ctx, key, index, value interface{}) *gomock.Call

LSet indicates an expected call of LSet.

func (*MockStatefulCmdableMockRecorder) LTrim added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) LTrim(ctx, key, start, stop interface{}) *gomock.Call

LTrim indicates an expected call of LTrim.

func (*MockStatefulCmdableMockRecorder) LastSave added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) LastSave(ctx interface{}) *gomock.Call

LastSave indicates an expected call of LastSave.

func (*MockStatefulCmdableMockRecorder) MGet added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) MGet(ctx interface{}, keys ...interface{}) *gomock.Call

MGet indicates an expected call of MGet.

func (*MockStatefulCmdableMockRecorder) MSet added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) MSet(ctx interface{}, values ...interface{}) *gomock.Call

MSet indicates an expected call of MSet.

func (*MockStatefulCmdableMockRecorder) MSetNX added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) MSetNX(ctx interface{}, values ...interface{}) *gomock.Call

MSetNX indicates an expected call of MSetNX.

func (*MockStatefulCmdableMockRecorder) MemoryUsage added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) MemoryUsage(ctx, key interface{}, samples ...interface{}) *gomock.Call

MemoryUsage indicates an expected call of MemoryUsage.

func (*MockStatefulCmdableMockRecorder) Migrate added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) Migrate(ctx, host, port, key, db, timeout interface{}) *gomock.Call

Migrate indicates an expected call of Migrate.

func (*MockStatefulCmdableMockRecorder) Move added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) Move(ctx, key, db interface{}) *gomock.Call

Move indicates an expected call of Move.

func (*MockStatefulCmdableMockRecorder) ObjectEncoding added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ObjectEncoding(ctx, key interface{}) *gomock.Call

ObjectEncoding indicates an expected call of ObjectEncoding.

func (*MockStatefulCmdableMockRecorder) ObjectIdleTime added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ObjectIdleTime(ctx, key interface{}) *gomock.Call

ObjectIdleTime indicates an expected call of ObjectIdleTime.

func (*MockStatefulCmdableMockRecorder) ObjectRefCount added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ObjectRefCount(ctx, key interface{}) *gomock.Call

ObjectRefCount indicates an expected call of ObjectRefCount.

func (*MockStatefulCmdableMockRecorder) PExpire added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) PExpire(ctx, key, expiration interface{}) *gomock.Call

PExpire indicates an expected call of PExpire.

func (*MockStatefulCmdableMockRecorder) PExpireAt added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) PExpireAt(ctx, key, tm interface{}) *gomock.Call

PExpireAt indicates an expected call of PExpireAt.

func (*MockStatefulCmdableMockRecorder) PFAdd added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) PFAdd(ctx, key interface{}, els ...interface{}) *gomock.Call

PFAdd indicates an expected call of PFAdd.

func (*MockStatefulCmdableMockRecorder) PFCount added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) PFCount(ctx interface{}, keys ...interface{}) *gomock.Call

PFCount indicates an expected call of PFCount.

func (*MockStatefulCmdableMockRecorder) PFMerge added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) PFMerge(ctx, dest interface{}, keys ...interface{}) *gomock.Call

PFMerge indicates an expected call of PFMerge.

func (*MockStatefulCmdableMockRecorder) PTTL added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) PTTL(ctx, key interface{}) *gomock.Call

PTTL indicates an expected call of PTTL.

func (*MockStatefulCmdableMockRecorder) Persist added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) Persist(ctx, key interface{}) *gomock.Call

Persist indicates an expected call of Persist.

func (*MockStatefulCmdableMockRecorder) Ping added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) Ping(ctx interface{}) *gomock.Call

Ping indicates an expected call of Ping.

func (*MockStatefulCmdableMockRecorder) Pipeline added in v0.1.1

Pipeline indicates an expected call of Pipeline.

func (*MockStatefulCmdableMockRecorder) Pipelined added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) Pipelined(ctx, fn interface{}) *gomock.Call

Pipelined indicates an expected call of Pipelined.

func (*MockStatefulCmdableMockRecorder) PubSubChannels added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) PubSubChannels(ctx, pattern interface{}) *gomock.Call

PubSubChannels indicates an expected call of PubSubChannels.

func (*MockStatefulCmdableMockRecorder) PubSubNumPat added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) PubSubNumPat(ctx interface{}) *gomock.Call

PubSubNumPat indicates an expected call of PubSubNumPat.

func (*MockStatefulCmdableMockRecorder) PubSubNumSub added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) PubSubNumSub(ctx interface{}, channels ...interface{}) *gomock.Call

PubSubNumSub indicates an expected call of PubSubNumSub.

func (*MockStatefulCmdableMockRecorder) Publish added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) Publish(ctx, channel, message interface{}) *gomock.Call

Publish indicates an expected call of Publish.

func (*MockStatefulCmdableMockRecorder) Quit added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) Quit(ctx interface{}) *gomock.Call

Quit indicates an expected call of Quit.

func (*MockStatefulCmdableMockRecorder) RPop added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) RPop(ctx, key interface{}) *gomock.Call

RPop indicates an expected call of RPop.

func (*MockStatefulCmdableMockRecorder) RPopCount added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) RPopCount(ctx, key, count interface{}) *gomock.Call

RPopCount indicates an expected call of RPopCount.

func (*MockStatefulCmdableMockRecorder) RPopLPush added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) RPopLPush(ctx, source, destination interface{}) *gomock.Call

RPopLPush indicates an expected call of RPopLPush.

func (*MockStatefulCmdableMockRecorder) RPush added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) RPush(ctx, key interface{}, values ...interface{}) *gomock.Call

RPush indicates an expected call of RPush.

func (*MockStatefulCmdableMockRecorder) RPushX added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) RPushX(ctx, key interface{}, values ...interface{}) *gomock.Call

RPushX indicates an expected call of RPushX.

func (*MockStatefulCmdableMockRecorder) RandomKey added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) RandomKey(ctx interface{}) *gomock.Call

RandomKey indicates an expected call of RandomKey.

func (*MockStatefulCmdableMockRecorder) ReadOnly added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ReadOnly(ctx interface{}) *gomock.Call

ReadOnly indicates an expected call of ReadOnly.

func (*MockStatefulCmdableMockRecorder) ReadWrite added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ReadWrite(ctx interface{}) *gomock.Call

ReadWrite indicates an expected call of ReadWrite.

func (*MockStatefulCmdableMockRecorder) Rename added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) Rename(ctx, key, newkey interface{}) *gomock.Call

Rename indicates an expected call of Rename.

func (*MockStatefulCmdableMockRecorder) RenameNX added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) RenameNX(ctx, key, newkey interface{}) *gomock.Call

RenameNX indicates an expected call of RenameNX.

func (*MockStatefulCmdableMockRecorder) Restore added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) Restore(ctx, key, ttl, value interface{}) *gomock.Call

Restore indicates an expected call of Restore.

func (*MockStatefulCmdableMockRecorder) RestoreReplace added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) RestoreReplace(ctx, key, ttl, value interface{}) *gomock.Call

RestoreReplace indicates an expected call of RestoreReplace.

func (*MockStatefulCmdableMockRecorder) SAdd added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) SAdd(ctx, key interface{}, members ...interface{}) *gomock.Call

SAdd indicates an expected call of SAdd.

func (*MockStatefulCmdableMockRecorder) SCard added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) SCard(ctx, key interface{}) *gomock.Call

SCard indicates an expected call of SCard.

func (*MockStatefulCmdableMockRecorder) SDiff added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) SDiff(ctx interface{}, keys ...interface{}) *gomock.Call

SDiff indicates an expected call of SDiff.

func (*MockStatefulCmdableMockRecorder) SDiffStore added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) SDiffStore(ctx, destination interface{}, keys ...interface{}) *gomock.Call

SDiffStore indicates an expected call of SDiffStore.

func (*MockStatefulCmdableMockRecorder) SInter added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) SInter(ctx interface{}, keys ...interface{}) *gomock.Call

SInter indicates an expected call of SInter.

func (*MockStatefulCmdableMockRecorder) SInterStore added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) SInterStore(ctx, destination interface{}, keys ...interface{}) *gomock.Call

SInterStore indicates an expected call of SInterStore.

func (*MockStatefulCmdableMockRecorder) SIsMember added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) SIsMember(ctx, key, member interface{}) *gomock.Call

SIsMember indicates an expected call of SIsMember.

func (*MockStatefulCmdableMockRecorder) SMIsMember added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) SMIsMember(ctx, key interface{}, members ...interface{}) *gomock.Call

SMIsMember indicates an expected call of SMIsMember.

func (*MockStatefulCmdableMockRecorder) SMembers added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) SMembers(ctx, key interface{}) *gomock.Call

SMembers indicates an expected call of SMembers.

func (*MockStatefulCmdableMockRecorder) SMembersMap added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) SMembersMap(ctx, key interface{}) *gomock.Call

SMembersMap indicates an expected call of SMembersMap.

func (*MockStatefulCmdableMockRecorder) SMove added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) SMove(ctx, source, destination, member interface{}) *gomock.Call

SMove indicates an expected call of SMove.

func (*MockStatefulCmdableMockRecorder) SPop added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) SPop(ctx, key interface{}) *gomock.Call

SPop indicates an expected call of SPop.

func (*MockStatefulCmdableMockRecorder) SPopN added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) SPopN(ctx, key, count interface{}) *gomock.Call

SPopN indicates an expected call of SPopN.

func (*MockStatefulCmdableMockRecorder) SRandMember added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) SRandMember(ctx, key interface{}) *gomock.Call

SRandMember indicates an expected call of SRandMember.

func (*MockStatefulCmdableMockRecorder) SRandMemberN added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) SRandMemberN(ctx, key, count interface{}) *gomock.Call

SRandMemberN indicates an expected call of SRandMemberN.

func (*MockStatefulCmdableMockRecorder) SRem added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) SRem(ctx, key interface{}, members ...interface{}) *gomock.Call

SRem indicates an expected call of SRem.

func (*MockStatefulCmdableMockRecorder) SScan added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) SScan(ctx, key, cursor, match, count interface{}) *gomock.Call

SScan indicates an expected call of SScan.

func (*MockStatefulCmdableMockRecorder) SUnion added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) SUnion(ctx interface{}, keys ...interface{}) *gomock.Call

SUnion indicates an expected call of SUnion.

func (*MockStatefulCmdableMockRecorder) SUnionStore added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) SUnionStore(ctx, destination interface{}, keys ...interface{}) *gomock.Call

SUnionStore indicates an expected call of SUnionStore.

func (*MockStatefulCmdableMockRecorder) Save added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) Save(ctx interface{}) *gomock.Call

Save indicates an expected call of Save.

func (*MockStatefulCmdableMockRecorder) Scan added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) Scan(ctx, cursor, match, count interface{}) *gomock.Call

Scan indicates an expected call of Scan.

func (*MockStatefulCmdableMockRecorder) ScanType added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ScanType(ctx, cursor, match, count, keyType interface{}) *gomock.Call

ScanType indicates an expected call of ScanType.

func (*MockStatefulCmdableMockRecorder) ScriptExists added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ScriptExists(ctx interface{}, hashes ...interface{}) *gomock.Call

ScriptExists indicates an expected call of ScriptExists.

func (*MockStatefulCmdableMockRecorder) ScriptFlush added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ScriptFlush(ctx interface{}) *gomock.Call

ScriptFlush indicates an expected call of ScriptFlush.

func (*MockStatefulCmdableMockRecorder) ScriptKill added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ScriptKill(ctx interface{}) *gomock.Call

ScriptKill indicates an expected call of ScriptKill.

func (*MockStatefulCmdableMockRecorder) ScriptLoad added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ScriptLoad(ctx, script interface{}) *gomock.Call

ScriptLoad indicates an expected call of ScriptLoad.

func (*MockStatefulCmdableMockRecorder) Select added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) Select(ctx, index interface{}) *gomock.Call

Select indicates an expected call of Select.

func (*MockStatefulCmdableMockRecorder) Set added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) Set(ctx, key, value, expiration interface{}) *gomock.Call

Set indicates an expected call of Set.

func (*MockStatefulCmdableMockRecorder) SetArgs added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) SetArgs(ctx, key, value, a interface{}) *gomock.Call

SetArgs indicates an expected call of SetArgs.

func (*MockStatefulCmdableMockRecorder) SetBit added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) SetBit(ctx, key, offset, value interface{}) *gomock.Call

SetBit indicates an expected call of SetBit.

func (*MockStatefulCmdableMockRecorder) SetEX added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) SetEX(ctx, key, value, expiration interface{}) *gomock.Call

SetEX indicates an expected call of SetEX.

func (*MockStatefulCmdableMockRecorder) SetNX added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) SetNX(ctx, key, value, expiration interface{}) *gomock.Call

SetNX indicates an expected call of SetNX.

func (*MockStatefulCmdableMockRecorder) SetRange added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) SetRange(ctx, key, offset, value interface{}) *gomock.Call

SetRange indicates an expected call of SetRange.

func (*MockStatefulCmdableMockRecorder) SetXX added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) SetXX(ctx, key, value, expiration interface{}) *gomock.Call

SetXX indicates an expected call of SetXX.

func (*MockStatefulCmdableMockRecorder) Shutdown added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) Shutdown(ctx interface{}) *gomock.Call

Shutdown indicates an expected call of Shutdown.

func (*MockStatefulCmdableMockRecorder) ShutdownNoSave added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ShutdownNoSave(ctx interface{}) *gomock.Call

ShutdownNoSave indicates an expected call of ShutdownNoSave.

func (*MockStatefulCmdableMockRecorder) ShutdownSave added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ShutdownSave(ctx interface{}) *gomock.Call

ShutdownSave indicates an expected call of ShutdownSave.

func (*MockStatefulCmdableMockRecorder) SlaveOf added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) SlaveOf(ctx, host, port interface{}) *gomock.Call

SlaveOf indicates an expected call of SlaveOf.

func (*MockStatefulCmdableMockRecorder) Sort added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) Sort(ctx, key, sort interface{}) *gomock.Call

Sort indicates an expected call of Sort.

func (*MockStatefulCmdableMockRecorder) SortInterfaces added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) SortInterfaces(ctx, key, sort interface{}) *gomock.Call

SortInterfaces indicates an expected call of SortInterfaces.

func (*MockStatefulCmdableMockRecorder) SortStore added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) SortStore(ctx, key, store, sort interface{}) *gomock.Call

SortStore indicates an expected call of SortStore.

func (*MockStatefulCmdableMockRecorder) StrLen added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) StrLen(ctx, key interface{}) *gomock.Call

StrLen indicates an expected call of StrLen.

func (*MockStatefulCmdableMockRecorder) SwapDB added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) SwapDB(ctx, index1, index2 interface{}) *gomock.Call

SwapDB indicates an expected call of SwapDB.

func (*MockStatefulCmdableMockRecorder) TTL added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) TTL(ctx, key interface{}) *gomock.Call

TTL indicates an expected call of TTL.

func (*MockStatefulCmdableMockRecorder) Time added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) Time(ctx interface{}) *gomock.Call

Time indicates an expected call of Time.

func (*MockStatefulCmdableMockRecorder) Touch added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) Touch(ctx interface{}, keys ...interface{}) *gomock.Call

Touch indicates an expected call of Touch.

func (*MockStatefulCmdableMockRecorder) TxPipeline added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) TxPipeline() *gomock.Call

TxPipeline indicates an expected call of TxPipeline.

func (*MockStatefulCmdableMockRecorder) TxPipelined added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) TxPipelined(ctx, fn interface{}) *gomock.Call

TxPipelined indicates an expected call of TxPipelined.

func (*MockStatefulCmdableMockRecorder) Type added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) Type(ctx, key interface{}) *gomock.Call

Type indicates an expected call of Type.

func (mr *MockStatefulCmdableMockRecorder) Unlink(ctx interface{}, keys ...interface{}) *gomock.Call

Unlink indicates an expected call of Unlink.

func (*MockStatefulCmdableMockRecorder) XAck added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) XAck(ctx, stream, group interface{}, ids ...interface{}) *gomock.Call

XAck indicates an expected call of XAck.

func (*MockStatefulCmdableMockRecorder) XAdd added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) XAdd(ctx, a interface{}) *gomock.Call

XAdd indicates an expected call of XAdd.

func (*MockStatefulCmdableMockRecorder) XAutoClaim added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) XAutoClaim(ctx, a interface{}) *gomock.Call

XAutoClaim indicates an expected call of XAutoClaim.

func (*MockStatefulCmdableMockRecorder) XAutoClaimJustID added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) XAutoClaimJustID(ctx, a interface{}) *gomock.Call

XAutoClaimJustID indicates an expected call of XAutoClaimJustID.

func (*MockStatefulCmdableMockRecorder) XClaim added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) XClaim(ctx, a interface{}) *gomock.Call

XClaim indicates an expected call of XClaim.

func (*MockStatefulCmdableMockRecorder) XClaimJustID added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) XClaimJustID(ctx, a interface{}) *gomock.Call

XClaimJustID indicates an expected call of XClaimJustID.

func (*MockStatefulCmdableMockRecorder) XDel added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) XDel(ctx, stream interface{}, ids ...interface{}) *gomock.Call

XDel indicates an expected call of XDel.

func (*MockStatefulCmdableMockRecorder) XGroupCreate added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) XGroupCreate(ctx, stream, group, start interface{}) *gomock.Call

XGroupCreate indicates an expected call of XGroupCreate.

func (*MockStatefulCmdableMockRecorder) XGroupCreateConsumer added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) XGroupCreateConsumer(ctx, stream, group, consumer interface{}) *gomock.Call

XGroupCreateConsumer indicates an expected call of XGroupCreateConsumer.

func (*MockStatefulCmdableMockRecorder) XGroupCreateMkStream added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) XGroupCreateMkStream(ctx, stream, group, start interface{}) *gomock.Call

XGroupCreateMkStream indicates an expected call of XGroupCreateMkStream.

func (*MockStatefulCmdableMockRecorder) XGroupDelConsumer added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) XGroupDelConsumer(ctx, stream, group, consumer interface{}) *gomock.Call

XGroupDelConsumer indicates an expected call of XGroupDelConsumer.

func (*MockStatefulCmdableMockRecorder) XGroupDestroy added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) XGroupDestroy(ctx, stream, group interface{}) *gomock.Call

XGroupDestroy indicates an expected call of XGroupDestroy.

func (*MockStatefulCmdableMockRecorder) XGroupSetID added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) XGroupSetID(ctx, stream, group, start interface{}) *gomock.Call

XGroupSetID indicates an expected call of XGroupSetID.

func (*MockStatefulCmdableMockRecorder) XInfoConsumers added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) XInfoConsumers(ctx, key, group interface{}) *gomock.Call

XInfoConsumers indicates an expected call of XInfoConsumers.

func (*MockStatefulCmdableMockRecorder) XInfoGroups added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) XInfoGroups(ctx, key interface{}) *gomock.Call

XInfoGroups indicates an expected call of XInfoGroups.

func (*MockStatefulCmdableMockRecorder) XInfoStream added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) XInfoStream(ctx, key interface{}) *gomock.Call

XInfoStream indicates an expected call of XInfoStream.

func (*MockStatefulCmdableMockRecorder) XInfoStreamFull added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) XInfoStreamFull(ctx, key, count interface{}) *gomock.Call

XInfoStreamFull indicates an expected call of XInfoStreamFull.

func (*MockStatefulCmdableMockRecorder) XLen added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) XLen(ctx, stream interface{}) *gomock.Call

XLen indicates an expected call of XLen.

func (*MockStatefulCmdableMockRecorder) XPending added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) XPending(ctx, stream, group interface{}) *gomock.Call

XPending indicates an expected call of XPending.

func (*MockStatefulCmdableMockRecorder) XPendingExt added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) XPendingExt(ctx, a interface{}) *gomock.Call

XPendingExt indicates an expected call of XPendingExt.

func (*MockStatefulCmdableMockRecorder) XRange added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) XRange(ctx, stream, start, stop interface{}) *gomock.Call

XRange indicates an expected call of XRange.

func (*MockStatefulCmdableMockRecorder) XRangeN added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) XRangeN(ctx, stream, start, stop, count interface{}) *gomock.Call

XRangeN indicates an expected call of XRangeN.

func (*MockStatefulCmdableMockRecorder) XRead added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) XRead(ctx, a interface{}) *gomock.Call

XRead indicates an expected call of XRead.

func (*MockStatefulCmdableMockRecorder) XReadGroup added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) XReadGroup(ctx, a interface{}) *gomock.Call

XReadGroup indicates an expected call of XReadGroup.

func (*MockStatefulCmdableMockRecorder) XReadStreams added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) XReadStreams(ctx interface{}, streams ...interface{}) *gomock.Call

XReadStreams indicates an expected call of XReadStreams.

func (*MockStatefulCmdableMockRecorder) XRevRange added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) XRevRange(ctx, stream, start, stop interface{}) *gomock.Call

XRevRange indicates an expected call of XRevRange.

func (*MockStatefulCmdableMockRecorder) XRevRangeN added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) XRevRangeN(ctx, stream, start, stop, count interface{}) *gomock.Call

XRevRangeN indicates an expected call of XRevRangeN.

func (*MockStatefulCmdableMockRecorder) XTrim added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) XTrim(ctx, key, maxLen interface{}) *gomock.Call

XTrim indicates an expected call of XTrim.

func (*MockStatefulCmdableMockRecorder) XTrimApprox added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) XTrimApprox(ctx, key, maxLen interface{}) *gomock.Call

XTrimApprox indicates an expected call of XTrimApprox.

func (*MockStatefulCmdableMockRecorder) XTrimMaxLen added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) XTrimMaxLen(ctx, key, maxLen interface{}) *gomock.Call

XTrimMaxLen indicates an expected call of XTrimMaxLen.

func (*MockStatefulCmdableMockRecorder) XTrimMaxLenApprox added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) XTrimMaxLenApprox(ctx, key, maxLen, limit interface{}) *gomock.Call

XTrimMaxLenApprox indicates an expected call of XTrimMaxLenApprox.

func (*MockStatefulCmdableMockRecorder) XTrimMinID added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) XTrimMinID(ctx, key, minID interface{}) *gomock.Call

XTrimMinID indicates an expected call of XTrimMinID.

func (*MockStatefulCmdableMockRecorder) XTrimMinIDApprox added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) XTrimMinIDApprox(ctx, key, minID, limit interface{}) *gomock.Call

XTrimMinIDApprox indicates an expected call of XTrimMinIDApprox.

func (*MockStatefulCmdableMockRecorder) ZAdd added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZAdd(ctx, key interface{}, members ...interface{}) *gomock.Call

ZAdd indicates an expected call of ZAdd.

func (*MockStatefulCmdableMockRecorder) ZAddArgs added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZAddArgs(ctx, key, args interface{}) *gomock.Call

ZAddArgs indicates an expected call of ZAddArgs.

func (*MockStatefulCmdableMockRecorder) ZAddArgsIncr added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZAddArgsIncr(ctx, key, args interface{}) *gomock.Call

ZAddArgsIncr indicates an expected call of ZAddArgsIncr.

func (*MockStatefulCmdableMockRecorder) ZAddCh added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZAddCh(ctx, key interface{}, members ...interface{}) *gomock.Call

ZAddCh indicates an expected call of ZAddCh.

func (*MockStatefulCmdableMockRecorder) ZAddNX added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZAddNX(ctx, key interface{}, members ...interface{}) *gomock.Call

ZAddNX indicates an expected call of ZAddNX.

func (*MockStatefulCmdableMockRecorder) ZAddNXCh added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZAddNXCh(ctx, key interface{}, members ...interface{}) *gomock.Call

ZAddNXCh indicates an expected call of ZAddNXCh.

func (*MockStatefulCmdableMockRecorder) ZAddXX added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZAddXX(ctx, key interface{}, members ...interface{}) *gomock.Call

ZAddXX indicates an expected call of ZAddXX.

func (*MockStatefulCmdableMockRecorder) ZAddXXCh added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZAddXXCh(ctx, key interface{}, members ...interface{}) *gomock.Call

ZAddXXCh indicates an expected call of ZAddXXCh.

func (*MockStatefulCmdableMockRecorder) ZCard added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZCard(ctx, key interface{}) *gomock.Call

ZCard indicates an expected call of ZCard.

func (*MockStatefulCmdableMockRecorder) ZCount added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZCount(ctx, key, min, max interface{}) *gomock.Call

ZCount indicates an expected call of ZCount.

func (*MockStatefulCmdableMockRecorder) ZDiff added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZDiff(ctx interface{}, keys ...interface{}) *gomock.Call

ZDiff indicates an expected call of ZDiff.

func (*MockStatefulCmdableMockRecorder) ZDiffStore added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZDiffStore(ctx, destination interface{}, keys ...interface{}) *gomock.Call

ZDiffStore indicates an expected call of ZDiffStore.

func (*MockStatefulCmdableMockRecorder) ZDiffWithScores added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZDiffWithScores(ctx interface{}, keys ...interface{}) *gomock.Call

ZDiffWithScores indicates an expected call of ZDiffWithScores.

func (*MockStatefulCmdableMockRecorder) ZIncr added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZIncr(ctx, key, member interface{}) *gomock.Call

ZIncr indicates an expected call of ZIncr.

func (*MockStatefulCmdableMockRecorder) ZIncrBy added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZIncrBy(ctx, key, increment, member interface{}) *gomock.Call

ZIncrBy indicates an expected call of ZIncrBy.

func (*MockStatefulCmdableMockRecorder) ZIncrNX added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZIncrNX(ctx, key, member interface{}) *gomock.Call

ZIncrNX indicates an expected call of ZIncrNX.

func (*MockStatefulCmdableMockRecorder) ZIncrXX added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZIncrXX(ctx, key, member interface{}) *gomock.Call

ZIncrXX indicates an expected call of ZIncrXX.

func (*MockStatefulCmdableMockRecorder) ZInter added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZInter(ctx, store interface{}) *gomock.Call

ZInter indicates an expected call of ZInter.

func (*MockStatefulCmdableMockRecorder) ZInterStore added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZInterStore(ctx, destination, store interface{}) *gomock.Call

ZInterStore indicates an expected call of ZInterStore.

func (*MockStatefulCmdableMockRecorder) ZInterWithScores added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZInterWithScores(ctx, store interface{}) *gomock.Call

ZInterWithScores indicates an expected call of ZInterWithScores.

func (*MockStatefulCmdableMockRecorder) ZLexCount added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZLexCount(ctx, key, min, max interface{}) *gomock.Call

ZLexCount indicates an expected call of ZLexCount.

func (*MockStatefulCmdableMockRecorder) ZMScore added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZMScore(ctx, key interface{}, members ...interface{}) *gomock.Call

ZMScore indicates an expected call of ZMScore.

func (*MockStatefulCmdableMockRecorder) ZPopMax added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZPopMax(ctx, key interface{}, count ...interface{}) *gomock.Call

ZPopMax indicates an expected call of ZPopMax.

func (*MockStatefulCmdableMockRecorder) ZPopMin added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZPopMin(ctx, key interface{}, count ...interface{}) *gomock.Call

ZPopMin indicates an expected call of ZPopMin.

func (*MockStatefulCmdableMockRecorder) ZRandMember added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZRandMember(ctx, key, count, withScores interface{}) *gomock.Call

ZRandMember indicates an expected call of ZRandMember.

func (*MockStatefulCmdableMockRecorder) ZRange added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZRange(ctx, key, start, stop interface{}) *gomock.Call

ZRange indicates an expected call of ZRange.

func (*MockStatefulCmdableMockRecorder) ZRangeArgs added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZRangeArgs(ctx, z interface{}) *gomock.Call

ZRangeArgs indicates an expected call of ZRangeArgs.

func (*MockStatefulCmdableMockRecorder) ZRangeArgsWithScores added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZRangeArgsWithScores(ctx, z interface{}) *gomock.Call

ZRangeArgsWithScores indicates an expected call of ZRangeArgsWithScores.

func (*MockStatefulCmdableMockRecorder) ZRangeByLex added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZRangeByLex(ctx, key, opt interface{}) *gomock.Call

ZRangeByLex indicates an expected call of ZRangeByLex.

func (*MockStatefulCmdableMockRecorder) ZRangeByScore added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZRangeByScore(ctx, key, opt interface{}) *gomock.Call

ZRangeByScore indicates an expected call of ZRangeByScore.

func (*MockStatefulCmdableMockRecorder) ZRangeByScoreWithScores added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZRangeByScoreWithScores(ctx, key, opt interface{}) *gomock.Call

ZRangeByScoreWithScores indicates an expected call of ZRangeByScoreWithScores.

func (*MockStatefulCmdableMockRecorder) ZRangeStore added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZRangeStore(ctx, dst, z interface{}) *gomock.Call

ZRangeStore indicates an expected call of ZRangeStore.

func (*MockStatefulCmdableMockRecorder) ZRangeWithScores added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZRangeWithScores(ctx, key, start, stop interface{}) *gomock.Call

ZRangeWithScores indicates an expected call of ZRangeWithScores.

func (*MockStatefulCmdableMockRecorder) ZRank added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZRank(ctx, key, member interface{}) *gomock.Call

ZRank indicates an expected call of ZRank.

func (*MockStatefulCmdableMockRecorder) ZRem added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZRem(ctx, key interface{}, members ...interface{}) *gomock.Call

ZRem indicates an expected call of ZRem.

func (*MockStatefulCmdableMockRecorder) ZRemRangeByLex added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZRemRangeByLex(ctx, key, min, max interface{}) *gomock.Call

ZRemRangeByLex indicates an expected call of ZRemRangeByLex.

func (*MockStatefulCmdableMockRecorder) ZRemRangeByRank added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZRemRangeByRank(ctx, key, start, stop interface{}) *gomock.Call

ZRemRangeByRank indicates an expected call of ZRemRangeByRank.

func (*MockStatefulCmdableMockRecorder) ZRemRangeByScore added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZRemRangeByScore(ctx, key, min, max interface{}) *gomock.Call

ZRemRangeByScore indicates an expected call of ZRemRangeByScore.

func (*MockStatefulCmdableMockRecorder) ZRevRange added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZRevRange(ctx, key, start, stop interface{}) *gomock.Call

ZRevRange indicates an expected call of ZRevRange.

func (*MockStatefulCmdableMockRecorder) ZRevRangeByLex added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZRevRangeByLex(ctx, key, opt interface{}) *gomock.Call

ZRevRangeByLex indicates an expected call of ZRevRangeByLex.

func (*MockStatefulCmdableMockRecorder) ZRevRangeByScore added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZRevRangeByScore(ctx, key, opt interface{}) *gomock.Call

ZRevRangeByScore indicates an expected call of ZRevRangeByScore.

func (*MockStatefulCmdableMockRecorder) ZRevRangeByScoreWithScores added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZRevRangeByScoreWithScores(ctx, key, opt interface{}) *gomock.Call

ZRevRangeByScoreWithScores indicates an expected call of ZRevRangeByScoreWithScores.

func (*MockStatefulCmdableMockRecorder) ZRevRangeWithScores added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZRevRangeWithScores(ctx, key, start, stop interface{}) *gomock.Call

ZRevRangeWithScores indicates an expected call of ZRevRangeWithScores.

func (*MockStatefulCmdableMockRecorder) ZRevRank added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZRevRank(ctx, key, member interface{}) *gomock.Call

ZRevRank indicates an expected call of ZRevRank.

func (*MockStatefulCmdableMockRecorder) ZScan added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZScan(ctx, key, cursor, match, count interface{}) *gomock.Call

ZScan indicates an expected call of ZScan.

func (*MockStatefulCmdableMockRecorder) ZScore added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZScore(ctx, key, member interface{}) *gomock.Call

ZScore indicates an expected call of ZScore.

func (*MockStatefulCmdableMockRecorder) ZUnion added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZUnion(ctx, store interface{}) *gomock.Call

ZUnion indicates an expected call of ZUnion.

func (*MockStatefulCmdableMockRecorder) ZUnionStore added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZUnionStore(ctx, dest, store interface{}) *gomock.Call

ZUnionStore indicates an expected call of ZUnionStore.

func (*MockStatefulCmdableMockRecorder) ZUnionWithScores added in v0.1.1

func (mr *MockStatefulCmdableMockRecorder) ZUnionWithScores(ctx, store interface{}) *gomock.Call

ZUnionWithScores indicates an expected call of ZUnionWithScores.

type Option added in v0.1.7

type Option func(*TokenBucketLimiter)

func WithAntiDDos added in v0.1.7

func WithAntiDDos(antiDDoS bool) Option

func WithEnablePreFetch added in v0.1.7

func WithEnablePreFetch(preFetch bool) Option

func WithPreFetchCount added in v0.1.7

func WithPreFetchCount(preFetchCount int64) Option

type SlideTimeWindowLimiter added in v0.0.6

type SlideTimeWindowLimiter struct {
	sync.Mutex
	// contains filtered or unexported fields
}

nolint: govet

func (*SlideTimeWindowLimiter) Count added in v0.0.6

func (s *SlideTimeWindowLimiter) Count() int

func (*SlideTimeWindowLimiter) Take added in v0.0.6

func (*SlideTimeWindowLimiter) Wait added in v0.1.1

func (r *SlideTimeWindowLimiter) Wait(ctx context.Context) (err error)

wait until take a token or timeout

type TokenBucketLimiter added in v0.0.5

type TokenBucketLimiter struct {
	BaseRateLimiter

	N int64

	/*
		If the traffic is too large, the limiter will request Redis frequently.
		To avoid this situation, the frequency of accessing Redis will be limited.
	*/
	AntiDDoS bool

	/*
		Get the token in advance before actually needing to use it
	*/
	EnablePreFetch bool
	PreFetchCount  int64
	// contains filtered or unexported fields
}

func (*TokenBucketLimiter) PreFetch added in v0.1.7

func (r *TokenBucketLimiter) PreFetch()

func (*TokenBucketLimiter) Take added in v0.0.5

func (r *TokenBucketLimiter) Take(ctx context.Context) (bool, error)

func (*TokenBucketLimiter) Wait added in v0.1.1

func (r *TokenBucketLimiter) Wait(ctx context.Context) (err error)

wait until take a token or timeout

Jump to

Keyboard shortcuts

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