container

package
v1.18.0 Latest Latest
Warning

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

 Go to latest Published: Aug 26, 2024 License: Apache-2.0 Imports: 29 Imported by: 3

Documentation

Overview

Package container is a generated GoMock package.

Package container is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewMockContainer added in v1.3.0 

func NewMockContainer(t *testing.T) (*Container, Mocks)

Types

type Cassandra added in v1.12.0 

type Cassandra interface {
	// Query executes the query and binds the result into dest parameter.
	// Returns error if any error occurs while binding the result.
	// Can be used to single as well as multiple rows.
	// Accepts pointer to struct or slice as dest parameter for single and multiple rows retrieval respectively.
	//
	// Example:
	//
	//	// Get multiple rows with only one column
	//	   ids := make([]int, 0)
	//	   err := c.Query(&ids, "SELECT id FROM users")
	//
	//	// Get a single object from database
	//	   type user struct {
	//	   	ID    int
	//	   	Name string
	//	   }
	//	   u := user{}
	//	   err := c.Query(&u, "SELECT * FROM users WHERE id=?", 1)
	//
	//	// Get array of objects from multiple rows
	//	   type user struct {
	//	   	ID    int
	//	   	Name string `db:"name"`
	//	   }
	//	   users := []user{}
	//	   err := c.Query(&users, "SELECT * FROM users")
	Query(dest any, stmt string, values ...any) error

	// Exec executes the query without returning any rows.
	// Return error if any error occurs while executing the query.
	// Can be used to execute UPDATE or INSERT.
	//
	// Example:
	//
	//	// Without values
	//	   err := c.Exec("INSERT INTO users VALUES(1, 'John Doe')")
	//
	//	// With Values
	//	   id := 1
	//	   name := "John Doe"
	//	   err := c.Exec("INSERT INTO users VALUES(?, ?)", id, name)
	Exec(stmt string, values ...any) error

	// ExecCAS executes a lightweight transaction (i.e. an UPDATE or INSERT statement containing an IF clause).
	// If the transaction fails because the existing values did not match, the previous values will be stored in dest.
	// Returns true if the query is applied otherwise false.
	// Returns false and error if any error occur while executing the query.
	// Accepts only pointer to struct and built-in types as the dest parameter.
	//
	// Example:
	//
	//	type user struct {
	//		ID    int
	//		Name string
	//	}
	//	u := user{}
	//	applied, err := c.ExecCAS(&user, "INSERT INTO users VALUES(1, 'John Doe') IF NOT EXISTS")
	ExecCAS(dest any, stmt string, values ...any) (bool, error)

	// NewBatch creates a new Cassandra batch with the specified name and batch type.
	//
	// This method initializes a new Cassandra batch operation. It sets up the batch
	// with the given name and type, allowing you to execute multiple queries in
	// a single batch operation. The `batchType` determines the type of batch operation
	// and can be one of `LoggedBatch`, `UnloggedBatch`, or `CounterBatch`.
	// These constants have been defined in gofr.dev/pkg/gofr/datasource/cassandra
	//
	// Example:
	//	err := client.NewBatch("myBatch", cassandra.LoggedBatch)
	NewBatch(name string, batchType int) error

	CassandraBatch

	HealthChecker
}

type CassandraBatch added in v1.17.0 

type CassandraBatch interface {
	// BatchQuery adds the query to the batch operation
	//
	// Example:
	//
	//	// Without values
	//	   c.BatchQuery("INSERT INTO users VALUES(1, 'John Doe')")
	//	   c.BatchQuery("INSERT INTO users VALUES(2, 'Jane Smith')")
	//
	//	// With Values
	//	   id1 := 1
	//	   name1 := "John Doe"
	//	   id2 := 2
	//	   name2 := "Jane Smith"
	//	   c.BatchQuery("INSERT INTO users VALUES(?, ?)", id1, name1)
	//	   c.BatchQuery("INSERT INTO users VALUES(?, ?)", id2, name2)
	BatchQuery(name, stmt string, values ...any) error

	// ExecuteBatch executes a batch operation and returns nil if successful otherwise an error is returned describing the failure.
	//
	// Example:
	//
	//	err := c.ExecuteBatch("myBatch")
	ExecuteBatch(name string) error

	// ExecuteBatchCAS executes a batch operation and returns true if successful.
	// Returns true if the query is applied otherwise false.
	// Returns false and error if any error occur while executing the query.
	// Accepts only pointer to struct and built-in types as the dest parameter.
	//
	// Example:
	//
	//  applied, err := c.ExecuteBatchCAS("myBatch");
	ExecuteBatchCAS(name string, dest ...any) (bool, error)
}

type CassandraProvider added in v1.12.0 

type CassandraProvider interface {
	Cassandra
	// contains filtered or unexported methods
}

type Clickhouse added in v1.12.0 

type Clickhouse interface {
	Exec(ctx context.Context, query string, args ...any) error
	Select(ctx context.Context, dest any, query string, args ...any) error
	AsyncInsert(ctx context.Context, query string, wait bool, args ...any) error

	HealthChecker
}

type ClickhouseProvider added in v1.12.0 

type ClickhouseProvider interface {
	Clickhouse
	// contains filtered or unexported methods
}

type Container 

type Container struct {
	logging.Logger

	Services map[string]service.HTTP

	PubSub pubsub.Client

	Redis Redis
	SQL   DB

	Cassandra  Cassandra
	Clickhouse Clickhouse
	Mongo      Mongo

	KVStore KVStore

	File file.FileSystem
	// contains filtered or unexported fields
}

Container is a collection of all common application level concerns. Things like Logger, Connection Pool for Redis etc. which is shared across is placed here.

func NewContainer 

func NewContainer(conf config.Config) *Container

func (*Container) Close added in v1.16.0 

func (c *Container) Close() error

func (*Container) Create added in v1.1.1 

func (c *Container) Create(conf config.Config)

func (*Container) GetAppName added in v0.2.0 

func (c *Container) GetAppName() string

func (*Container) GetAppVersion added in v0.2.0 

func (c *Container) GetAppVersion() string

func (*Container) GetConnectionFromContext added in v1.17.0 

func (*Container) GetConnectionFromContext(ctx context.Context) *websocket.Connection

func (*Container) GetHTTPService 

func (c *Container) GetHTTPService(serviceName string) service.HTTP

GetHTTPService returns registered HTTP services. HTTP services are registered from AddHTTPService method of GoFr object.

func (*Container) GetPublisher added in v1.1.1 

func (c *Container) GetPublisher() pubsub.Publisher

func (*Container) GetSubscriber added in v1.1.1 

func (c *Container) GetSubscriber() pubsub.Subscriber

func (*Container) Health 

func (c *Container) Health(ctx context.Context) interface{}

func (*Container) Metrics added in v0.2.0 

func (c *Container) Metrics() metrics.Manager

type DB added in v1.3.0 

type DB interface {
	Query(query string, args ...interface{}) (*sql.Rows, error)
	QueryRow(query string, args ...interface{}) *sql.Row
	QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)
	QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row
	Exec(query string, args ...interface{}) (sql.Result, error)
	ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
	Prepare(query string) (*sql.Stmt, error)
	Begin() (*gofrSQL.Tx, error)
	Select(ctx context.Context, data interface{}, query string, args ...interface{})
	HealthCheck() *datasource.Health
	Dialect() string
	Close() error
}

type HealthChecker 

type HealthChecker interface {
	// HealthCheck returns an interface rather than a struct as externalDB's are part of different module.
	// It is done to avoid adding packages which are not being used.
	HealthCheck(context.Context) (any, error)
}

type KVStore added in v1.15.0 

type KVStore interface {
	Get(ctx context.Context, key string) (string, error)
	Set(ctx context.Context, key, value string) error
	Delete(ctx context.Context, key string) error

	HealthChecker
}

type KVStoreProvider added in v1.15.0 

type KVStoreProvider interface {
	KVStore
	// contains filtered or unexported methods
}

type Metrics added in v1.11.0 

type Metrics interface {
	NewCounter(name, desc string)
	NewUpDownCounter(name, desc string)
	NewHistogram(name, desc string, buckets ...float64)
	NewGauge(name, desc string)

	IncrementCounter(ctx context.Context, name string, labels ...string)
	DeltaUpDownCounter(ctx context.Context, name string, value float64, labels ...string)
	RecordHistogram(ctx context.Context, name string, value float64, labels ...string)
	SetGauge(name string, value float64, labels ...string)
}

type MockCassandra added in v1.12.0 

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

MockCassandra is a mock of Cassandra interface.

func NewMockCassandra added in v1.12.0 

func NewMockCassandra(ctrl *gomock.Controller) *MockCassandra

NewMockCassandra creates a new mock instance.

func (*MockCassandra) BatchQuery added in v1.17.0 

func (m *MockCassandra) BatchQuery(name, stmt string, values ...any) error

BatchQuery mocks base method.

func (*MockCassandra) EXPECT added in v1.12.0 

func (m *MockCassandra) EXPECT() *MockCassandraMockRecorder

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

func (*MockCassandra) Exec added in v1.12.0 

func (m *MockCassandra) Exec(stmt string, values ...any) error

Exec mocks base method.

func (*MockCassandra) ExecCAS added in v1.12.0 

func (m *MockCassandra) ExecCAS(dest any, stmt string, values ...any) (bool, error)

ExecCAS mocks base method.

func (*MockCassandra) ExecuteBatch added in v1.17.0 

func (m *MockCassandra) ExecuteBatch(name string) error

ExecuteBatch mocks base method.

func (*MockCassandra) ExecuteBatchCAS added in v1.17.0 

func (m *MockCassandra) ExecuteBatchCAS(name string, dest ...any) (bool, error)

ExecuteBatchCAS mocks base method.

func (*MockCassandra) HealthCheck added in v1.13.0 

func (m *MockCassandra) HealthCheck(arg0 context.Context) (any, error)

HealthCheck mocks base method.

func (*MockCassandra) NewBatch added in v1.17.0 

func (m *MockCassandra) NewBatch(name string, batchType int) error

NewBatch mocks base method.

func (*MockCassandra) Query added in v1.12.0 

func (m *MockCassandra) Query(dest any, stmt string, values ...any) error

Query mocks base method.

type MockCassandraBatch added in v1.17.0 

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

MockCassandraBatch is a mock of CassandraBatch interface.

func NewMockCassandraBatch added in v1.17.0 

func NewMockCassandraBatch(ctrl *gomock.Controller) *MockCassandraBatch

NewMockCassandraBatch creates a new mock instance.

func (*MockCassandraBatch) BatchQuery added in v1.17.0 

func (m *MockCassandraBatch) BatchQuery(name, stmt string, values ...any) error

BatchQuery mocks base method.

func (*MockCassandraBatch) EXPECT added in v1.17.0 

func (m *MockCassandraBatch) EXPECT() *MockCassandraBatchMockRecorder

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

func (*MockCassandraBatch) ExecuteBatch added in v1.17.0 

func (m *MockCassandraBatch) ExecuteBatch(name string) error

ExecuteBatch mocks base method.

func (*MockCassandraBatch) ExecuteBatchCAS added in v1.17.0 

func (m *MockCassandraBatch) ExecuteBatchCAS(name string, dest ...any) (bool, error)

ExecuteBatchCAS mocks base method.

type MockCassandraBatchMockRecorder added in v1.17.0 

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

MockCassandraBatchMockRecorder is the mock recorder for MockCassandraBatch.

func (*MockCassandraBatchMockRecorder) BatchQuery added in v1.17.0 

func (mr *MockCassandraBatchMockRecorder) BatchQuery(name, stmt any, values ...any) *gomock.Call

BatchQuery indicates an expected call of BatchQuery.

func (*MockCassandraBatchMockRecorder) ExecuteBatch added in v1.17.0 

func (mr *MockCassandraBatchMockRecorder) ExecuteBatch(name any) *gomock.Call

ExecuteBatch indicates an expected call of ExecuteBatch.

func (*MockCassandraBatchMockRecorder) ExecuteBatchCAS added in v1.17.0 

func (mr *MockCassandraBatchMockRecorder) ExecuteBatchCAS(name any, dest ...any) *gomock.Call

ExecuteBatchCAS indicates an expected call of ExecuteBatchCAS.

type MockCassandraMockRecorder added in v1.12.0 

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

MockCassandraMockRecorder is the mock recorder for MockCassandra.

func (*MockCassandraMockRecorder) BatchQuery added in v1.17.0 

func (mr *MockCassandraMockRecorder) BatchQuery(name, stmt any, values ...any) *gomock.Call

BatchQuery indicates an expected call of BatchQuery.

func (*MockCassandraMockRecorder) Exec added in v1.12.0 

func (mr *MockCassandraMockRecorder) Exec(stmt any, values ...any) *gomock.Call

Exec indicates an expected call of Exec.

func (*MockCassandraMockRecorder) ExecCAS added in v1.12.0 

func (mr *MockCassandraMockRecorder) ExecCAS(dest, stmt any, values ...any) *gomock.Call

ExecCAS indicates an expected call of ExecCAS.

func (*MockCassandraMockRecorder) ExecuteBatch added in v1.17.0 

func (mr *MockCassandraMockRecorder) ExecuteBatch(name any) *gomock.Call

ExecuteBatch indicates an expected call of ExecuteBatch.

func (*MockCassandraMockRecorder) ExecuteBatchCAS added in v1.17.0 

func (mr *MockCassandraMockRecorder) ExecuteBatchCAS(name any, dest ...any) *gomock.Call

ExecuteBatchCAS indicates an expected call of ExecuteBatchCAS.

func (*MockCassandraMockRecorder) HealthCheck added in v1.13.0 

func (mr *MockCassandraMockRecorder) HealthCheck(arg0 any) *gomock.Call

HealthCheck indicates an expected call of HealthCheck.

func (*MockCassandraMockRecorder) NewBatch added in v1.17.0 

func (mr *MockCassandraMockRecorder) NewBatch(name, batchType any) *gomock.Call

NewBatch indicates an expected call of NewBatch.

func (*MockCassandraMockRecorder) Query added in v1.12.0 

func (mr *MockCassandraMockRecorder) Query(dest, stmt any, values ...any) *gomock.Call

Query indicates an expected call of Query.

type MockCassandraProvider added in v1.12.0 

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

MockCassandraProvider is a mock of CassandraProvider interface.

func NewMockCassandraProvider added in v1.12.0 

func NewMockCassandraProvider(ctrl *gomock.Controller) *MockCassandraProvider

NewMockCassandraProvider creates a new mock instance.

func (*MockCassandraProvider) BatchQuery added in v1.17.0 

func (m *MockCassandraProvider) BatchQuery(name, stmt string, values ...any) error

BatchQuery mocks base method.

func (*MockCassandraProvider) Connect added in v1.12.0 

func (m *MockCassandraProvider) Connect()

Connect mocks base method.

func (*MockCassandraProvider) EXPECT added in v1.12.0 

func (m *MockCassandraProvider) EXPECT() *MockCassandraProviderMockRecorder

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

func (*MockCassandraProvider) Exec added in v1.12.0 

func (m *MockCassandraProvider) Exec(stmt string, values ...any) error

Exec mocks base method.

func (*MockCassandraProvider) ExecCAS added in v1.12.0 

func (m *MockCassandraProvider) ExecCAS(dest any, stmt string, values ...any) (bool, error)

ExecCAS mocks base method.

func (*MockCassandraProvider) ExecuteBatch added in v1.17.0 

func (m *MockCassandraProvider) ExecuteBatch(name string) error

ExecuteBatch mocks base method.

func (*MockCassandraProvider) ExecuteBatchCAS added in v1.17.0 

func (m *MockCassandraProvider) ExecuteBatchCAS(name string, dest ...any) (bool, error)

ExecuteBatchCAS mocks base method.

func (*MockCassandraProvider) HealthCheck added in v1.13.0 

func (m *MockCassandraProvider) HealthCheck(arg0 context.Context) (any, error)

HealthCheck mocks base method.

func (*MockCassandraProvider) NewBatch added in v1.17.0 

func (m *MockCassandraProvider) NewBatch(name string, batchType int) error

NewBatch mocks base method.

func (*MockCassandraProvider) Query added in v1.12.0 

func (m *MockCassandraProvider) Query(dest any, stmt string, values ...any) error

Query mocks base method.

func (*MockCassandraProvider) UseLogger added in v1.12.0 

func (m *MockCassandraProvider) UseLogger(logger any)

UseLogger mocks base method.

func (*MockCassandraProvider) UseMetrics added in v1.12.0 

func (m *MockCassandraProvider) UseMetrics(metrics any)

UseMetrics mocks base method.

type MockCassandraProviderMockRecorder added in v1.12.0 

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

MockCassandraProviderMockRecorder is the mock recorder for MockCassandraProvider.

func (*MockCassandraProviderMockRecorder) BatchQuery added in v1.17.0 

func (mr *MockCassandraProviderMockRecorder) BatchQuery(name, stmt any, values ...any) *gomock.Call

BatchQuery indicates an expected call of BatchQuery.

func (*MockCassandraProviderMockRecorder) Connect added in v1.12.0 

func (mr *MockCassandraProviderMockRecorder) Connect() *gomock.Call

Connect indicates an expected call of Connect.

func (*MockCassandraProviderMockRecorder) Exec added in v1.12.0 

func (mr *MockCassandraProviderMockRecorder) Exec(stmt any, values ...any) *gomock.Call

Exec indicates an expected call of Exec.

func (*MockCassandraProviderMockRecorder) ExecCAS added in v1.12.0 

func (mr *MockCassandraProviderMockRecorder) ExecCAS(dest, stmt any, values ...any) *gomock.Call

ExecCAS indicates an expected call of ExecCAS.

func (*MockCassandraProviderMockRecorder) ExecuteBatch added in v1.17.0 

func (mr *MockCassandraProviderMockRecorder) ExecuteBatch(name any) *gomock.Call

ExecuteBatch indicates an expected call of ExecuteBatch.

func (*MockCassandraProviderMockRecorder) ExecuteBatchCAS added in v1.17.0 

func (mr *MockCassandraProviderMockRecorder) ExecuteBatchCAS(name any, dest ...any) *gomock.Call

ExecuteBatchCAS indicates an expected call of ExecuteBatchCAS.

func (*MockCassandraProviderMockRecorder) HealthCheck added in v1.13.0 

func (mr *MockCassandraProviderMockRecorder) HealthCheck(arg0 any) *gomock.Call

HealthCheck indicates an expected call of HealthCheck.

func (*MockCassandraProviderMockRecorder) NewBatch added in v1.17.0 

func (mr *MockCassandraProviderMockRecorder) NewBatch(name, batchType any) *gomock.Call

NewBatch indicates an expected call of NewBatch.

func (*MockCassandraProviderMockRecorder) Query added in v1.12.0 

func (mr *MockCassandraProviderMockRecorder) Query(dest, stmt any, values ...any) *gomock.Call

Query indicates an expected call of Query.

func (*MockCassandraProviderMockRecorder) UseLogger added in v1.12.0 

func (mr *MockCassandraProviderMockRecorder) UseLogger(logger any) *gomock.Call

UseLogger indicates an expected call of UseLogger.

func (*MockCassandraProviderMockRecorder) UseMetrics added in v1.12.0 

func (mr *MockCassandraProviderMockRecorder) UseMetrics(metrics any) *gomock.Call

UseMetrics indicates an expected call of UseMetrics.

type MockClickhouse added in v1.12.0 

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

MockClickhouse is a mock of Clickhouse interface.

func NewMockClickhouse added in v1.12.0 

func NewMockClickhouse(ctrl *gomock.Controller) *MockClickhouse

NewMockClickhouse creates a new mock instance.

func (*MockClickhouse) AsyncInsert added in v1.12.0 

func (m *MockClickhouse) AsyncInsert(ctx context.Context, query string, wait bool, args ...any) error

AsyncInsert mocks base method.

func (*MockClickhouse) EXPECT added in v1.12.0 

func (m *MockClickhouse) EXPECT() *MockClickhouseMockRecorder

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

func (*MockClickhouse) Exec added in v1.12.0 

func (m *MockClickhouse) Exec(ctx context.Context, query string, args ...any) error

Exec mocks base method.

func (*MockClickhouse) HealthCheck added in v1.13.0 

func (m *MockClickhouse) HealthCheck(arg0 context.Context) (any, error)

HealthCheck mocks base method.

func (*MockClickhouse) Select added in v1.12.0 

func (m *MockClickhouse) Select(ctx context.Context, dest any, query string, args ...any) error

Select mocks base method.

type MockClickhouseMockRecorder added in v1.12.0 

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

MockClickhouseMockRecorder is the mock recorder for MockClickhouse.

func (*MockClickhouseMockRecorder) AsyncInsert added in v1.12.0 

func (mr *MockClickhouseMockRecorder) AsyncInsert(ctx, query, wait any, args ...any) *gomock.Call

AsyncInsert indicates an expected call of AsyncInsert.

func (*MockClickhouseMockRecorder) Exec added in v1.12.0 

func (mr *MockClickhouseMockRecorder) Exec(ctx, query any, args ...any) *gomock.Call

Exec indicates an expected call of Exec.

func (*MockClickhouseMockRecorder) HealthCheck added in v1.13.0 

func (mr *MockClickhouseMockRecorder) HealthCheck(arg0 any) *gomock.Call

HealthCheck indicates an expected call of HealthCheck.

func (*MockClickhouseMockRecorder) Select added in v1.12.0 

func (mr *MockClickhouseMockRecorder) Select(ctx, dest, query any, args ...any) *gomock.Call

Select indicates an expected call of Select.

type MockClickhouseProvider added in v1.12.0 

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

MockClickhouseProvider is a mock of ClickhouseProvider interface.

func NewMockClickhouseProvider added in v1.12.0 

func NewMockClickhouseProvider(ctrl *gomock.Controller) *MockClickhouseProvider

NewMockClickhouseProvider creates a new mock instance.

func (*MockClickhouseProvider) AsyncInsert added in v1.12.0 

func (m *MockClickhouseProvider) AsyncInsert(ctx context.Context, query string, wait bool, args ...any) error

AsyncInsert mocks base method.

func (*MockClickhouseProvider) Connect added in v1.12.0 

func (m *MockClickhouseProvider) Connect()

Connect mocks base method.

func (*MockClickhouseProvider) EXPECT added in v1.12.0 

func (m *MockClickhouseProvider) EXPECT() *MockClickhouseProviderMockRecorder

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

func (*MockClickhouseProvider) Exec added in v1.12.0 

func (m *MockClickhouseProvider) Exec(ctx context.Context, query string, args ...any) error

Exec mocks base method.

func (*MockClickhouseProvider) HealthCheck added in v1.13.0 

func (m *MockClickhouseProvider) HealthCheck(arg0 context.Context) (any, error)

HealthCheck mocks base method.

func (*MockClickhouseProvider) Select added in v1.12.0 

func (m *MockClickhouseProvider) Select(ctx context.Context, dest any, query string, args ...any) error

Select mocks base method.

func (*MockClickhouseProvider) UseLogger added in v1.12.0 

func (m *MockClickhouseProvider) UseLogger(logger any)

UseLogger mocks base method.

func (*MockClickhouseProvider) UseMetrics added in v1.12.0 

func (m *MockClickhouseProvider) UseMetrics(metrics any)

UseMetrics mocks base method.

type MockClickhouseProviderMockRecorder added in v1.12.0 

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

MockClickhouseProviderMockRecorder is the mock recorder for MockClickhouseProvider.

func (*MockClickhouseProviderMockRecorder) AsyncInsert added in v1.12.0 

func (mr *MockClickhouseProviderMockRecorder) AsyncInsert(ctx, query, wait any, args ...any) *gomock.Call

AsyncInsert indicates an expected call of AsyncInsert.

func (*MockClickhouseProviderMockRecorder) Connect added in v1.12.0 

func (mr *MockClickhouseProviderMockRecorder) Connect() *gomock.Call

Connect indicates an expected call of Connect.

func (*MockClickhouseProviderMockRecorder) Exec added in v1.12.0 

func (mr *MockClickhouseProviderMockRecorder) Exec(ctx, query any, args ...any) *gomock.Call

Exec indicates an expected call of Exec.

func (*MockClickhouseProviderMockRecorder) HealthCheck added in v1.13.0 

func (mr *MockClickhouseProviderMockRecorder) HealthCheck(arg0 any) *gomock.Call

HealthCheck indicates an expected call of HealthCheck.

func (*MockClickhouseProviderMockRecorder) Select added in v1.12.0 

func (mr *MockClickhouseProviderMockRecorder) Select(ctx, dest, query any, args ...any) *gomock.Call

Select indicates an expected call of Select.

func (*MockClickhouseProviderMockRecorder) UseLogger added in v1.12.0 

func (mr *MockClickhouseProviderMockRecorder) UseLogger(logger any) *gomock.Call

UseLogger indicates an expected call of UseLogger.

func (*MockClickhouseProviderMockRecorder) UseMetrics added in v1.12.0 

func (mr *MockClickhouseProviderMockRecorder) UseMetrics(metrics any) *gomock.Call

UseMetrics indicates an expected call of UseMetrics.

type MockDB added in v1.3.0 

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

MockDB is a mock of DB interface.

func NewMockDB added in v1.3.0 

func NewMockDB(ctrl *gomock.Controller) *MockDB

NewMockDB creates a new mock instance.

func (*MockDB) Begin added in v1.3.0 

func (m *MockDB) Begin() (*sql0.Tx, error)

Begin mocks base method.

func (*MockDB) Close added in v1.16.0 

func (m *MockDB) Close() error

Close mocks base method.

func (*MockDB) Dialect added in v1.4.1 

func (m *MockDB) Dialect() string

Dialect mocks base method.

func (*MockDB) EXPECT added in v1.3.0 

func (m *MockDB) EXPECT() *MockDBMockRecorder

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

func (*MockDB) Exec added in v1.3.0 

func (m *MockDB) Exec(query string, args ...any) (sql.Result, error)

Exec mocks base method.

func (*MockDB) ExecContext added in v1.3.0 

func (m *MockDB) ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)

ExecContext mocks base method.

func (*MockDB) HealthCheck added in v1.3.0 

func (m *MockDB) HealthCheck() *datasource.Health

HealthCheck mocks base method.

func (*MockDB) Prepare added in v1.3.0 

func (m *MockDB) Prepare(query string) (*sql.Stmt, error)

Prepare mocks base method.

func (*MockDB) Query added in v1.3.0 

func (m *MockDB) Query(query string, args ...any) (*sql.Rows, error)

Query mocks base method.

func (*MockDB) QueryContext added in v1.3.0 

func (m *MockDB) QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)

QueryContext mocks base method.

func (*MockDB) QueryRow added in v1.3.0 

func (m *MockDB) QueryRow(query string, args ...any) *sql.Row

QueryRow mocks base method.

func (*MockDB) QueryRowContext added in v1.3.0 

func (m *MockDB) QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row

QueryRowContext mocks base method.

func (*MockDB) Select added in v1.3.0 

func (m *MockDB) Select(ctx context.Context, data any, query string, args ...any)

Select mocks base method.

type MockDBMockRecorder added in v1.3.0 

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

MockDBMockRecorder is the mock recorder for MockDB.

func (*MockDBMockRecorder) Begin added in v1.3.0 

func (mr *MockDBMockRecorder) Begin() *gomock.Call

Begin indicates an expected call of Begin.

func (*MockDBMockRecorder) Close added in v1.16.0 

func (mr *MockDBMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockDBMockRecorder) Dialect added in v1.4.1 

func (mr *MockDBMockRecorder) Dialect() *gomock.Call

Dialect indicates an expected call of Dialect.

func (*MockDBMockRecorder) Exec added in v1.3.0 

func (mr *MockDBMockRecorder) Exec(query any, args ...any) *gomock.Call

Exec indicates an expected call of Exec.

func (*MockDBMockRecorder) ExecContext added in v1.3.0 

func (mr *MockDBMockRecorder) ExecContext(ctx, query any, args ...any) *gomock.Call

ExecContext indicates an expected call of ExecContext.

func (*MockDBMockRecorder) HealthCheck added in v1.3.0 

func (mr *MockDBMockRecorder) HealthCheck() *gomock.Call

HealthCheck indicates an expected call of HealthCheck.

func (*MockDBMockRecorder) Prepare added in v1.3.0 

func (mr *MockDBMockRecorder) Prepare(query any) *gomock.Call

Prepare indicates an expected call of Prepare.

func (*MockDBMockRecorder) Query added in v1.3.0 

func (mr *MockDBMockRecorder) Query(query any, args ...any) *gomock.Call

Query indicates an expected call of Query.

func (*MockDBMockRecorder) QueryContext added in v1.3.0 

func (mr *MockDBMockRecorder) QueryContext(ctx, query any, args ...any) *gomock.Call

QueryContext indicates an expected call of QueryContext.

func (*MockDBMockRecorder) QueryRow added in v1.3.0 

func (mr *MockDBMockRecorder) QueryRow(query any, args ...any) *gomock.Call

QueryRow indicates an expected call of QueryRow.

func (*MockDBMockRecorder) QueryRowContext added in v1.3.0 

func (mr *MockDBMockRecorder) QueryRowContext(ctx, query any, args ...any) *gomock.Call

QueryRowContext indicates an expected call of QueryRowContext.

func (*MockDBMockRecorder) Select added in v1.3.0 

func (mr *MockDBMockRecorder) Select(ctx, data, query any, args ...any) *gomock.Call

Select indicates an expected call of Select.

type MockHealthChecker added in v1.13.0 

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

MockHealthChecker is a mock of HealthChecker interface.

func NewMockHealthChecker added in v1.13.0 

func NewMockHealthChecker(ctrl *gomock.Controller) *MockHealthChecker

NewMockHealthChecker creates a new mock instance.

func (*MockHealthChecker) EXPECT added in v1.13.0 

func (m *MockHealthChecker) EXPECT() *MockHealthCheckerMockRecorder

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

func (*MockHealthChecker) HealthCheck added in v1.13.0 

func (m *MockHealthChecker) HealthCheck(arg0 context.Context) (any, error)

HealthCheck mocks base method.

type MockHealthCheckerMockRecorder added in v1.13.0 

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

MockHealthCheckerMockRecorder is the mock recorder for MockHealthChecker.

func (*MockHealthCheckerMockRecorder) HealthCheck added in v1.13.0 

func (mr *MockHealthCheckerMockRecorder) HealthCheck(arg0 any) *gomock.Call

HealthCheck indicates an expected call of HealthCheck.

type MockKVStore added in v1.15.0 

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

MockKVStore is a mock of KVStore interface.

func NewMockKVStore added in v1.15.0 

func NewMockKVStore(ctrl *gomock.Controller) *MockKVStore

NewMockKVStore creates a new mock instance.

func (*MockKVStore) Delete added in v1.15.0 

func (m *MockKVStore) Delete(ctx context.Context, key string) error

Delete mocks base method.

func (*MockKVStore) EXPECT added in v1.15.0 

func (m *MockKVStore) EXPECT() *MockKVStoreMockRecorder

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

func (*MockKVStore) Get added in v1.15.0 

func (m *MockKVStore) Get(ctx context.Context, key string) (string, error)

Get mocks base method.

func (*MockKVStore) HealthCheck added in v1.15.0 

func (m *MockKVStore) HealthCheck(arg0 context.Context) (any, error)

HealthCheck mocks base method.

func (*MockKVStore) Set added in v1.15.0 

func (m *MockKVStore) Set(ctx context.Context, key, value string) error

Set mocks base method.

type MockKVStoreMockRecorder added in v1.15.0 

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

MockKVStoreMockRecorder is the mock recorder for MockKVStore.

func (*MockKVStoreMockRecorder) Delete added in v1.15.0 

func (mr *MockKVStoreMockRecorder) Delete(ctx, key any) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockKVStoreMockRecorder) Get added in v1.15.0 

func (mr *MockKVStoreMockRecorder) Get(ctx, key any) *gomock.Call

Get indicates an expected call of Get.

func (*MockKVStoreMockRecorder) HealthCheck added in v1.15.0 

func (mr *MockKVStoreMockRecorder) HealthCheck(arg0 any) *gomock.Call

HealthCheck indicates an expected call of HealthCheck.

func (*MockKVStoreMockRecorder) Set added in v1.15.0 

func (mr *MockKVStoreMockRecorder) Set(ctx, key, value any) *gomock.Call

Set indicates an expected call of Set.

type MockKVStoreProvider added in v1.15.0 

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

MockKVStoreProvider is a mock of KVStoreProvider interface.

func NewMockKVStoreProvider added in v1.15.0 

func NewMockKVStoreProvider(ctrl *gomock.Controller) *MockKVStoreProvider

NewMockKVStoreProvider creates a new mock instance.

func (*MockKVStoreProvider) Connect added in v1.15.0 

func (m *MockKVStoreProvider) Connect()

Connect mocks base method.

func (*MockKVStoreProvider) Delete added in v1.15.0 

func (m *MockKVStoreProvider) Delete(ctx context.Context, key string) error

Delete mocks base method.

func (*MockKVStoreProvider) EXPECT added in v1.15.0 

func (m *MockKVStoreProvider) EXPECT() *MockKVStoreProviderMockRecorder

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

func (*MockKVStoreProvider) Get added in v1.15.0 

func (m *MockKVStoreProvider) Get(ctx context.Context, key string) (string, error)

Get mocks base method.

func (*MockKVStoreProvider) HealthCheck added in v1.15.0 

func (m *MockKVStoreProvider) HealthCheck(arg0 context.Context) (any, error)

HealthCheck mocks base method.

func (*MockKVStoreProvider) Set added in v1.15.0 

func (m *MockKVStoreProvider) Set(ctx context.Context, key, value string) error

Set mocks base method.

func (*MockKVStoreProvider) UseLogger added in v1.15.0 

func (m *MockKVStoreProvider) UseLogger(logger any)

UseLogger mocks base method.

func (*MockKVStoreProvider) UseMetrics added in v1.15.0 

func (m *MockKVStoreProvider) UseMetrics(metrics any)

UseMetrics mocks base method.

type MockKVStoreProviderMockRecorder added in v1.15.0 

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

MockKVStoreProviderMockRecorder is the mock recorder for MockKVStoreProvider.

func (*MockKVStoreProviderMockRecorder) Connect added in v1.15.0 

func (mr *MockKVStoreProviderMockRecorder) Connect() *gomock.Call

Connect indicates an expected call of Connect.

func (*MockKVStoreProviderMockRecorder) Delete added in v1.15.0 

func (mr *MockKVStoreProviderMockRecorder) Delete(ctx, key any) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockKVStoreProviderMockRecorder) Get added in v1.15.0 

func (mr *MockKVStoreProviderMockRecorder) Get(ctx, key any) *gomock.Call

Get indicates an expected call of Get.

func (*MockKVStoreProviderMockRecorder) HealthCheck added in v1.15.0 

func (mr *MockKVStoreProviderMockRecorder) HealthCheck(arg0 any) *gomock.Call

HealthCheck indicates an expected call of HealthCheck.

func (*MockKVStoreProviderMockRecorder) Set added in v1.15.0 

func (mr *MockKVStoreProviderMockRecorder) Set(ctx, key, value any) *gomock.Call

Set indicates an expected call of Set.

func (*MockKVStoreProviderMockRecorder) UseLogger added in v1.15.0 

func (mr *MockKVStoreProviderMockRecorder) UseLogger(logger any) *gomock.Call

UseLogger indicates an expected call of UseLogger.

func (*MockKVStoreProviderMockRecorder) UseMetrics added in v1.15.0 

func (mr *MockKVStoreProviderMockRecorder) UseMetrics(metrics any) *gomock.Call

UseMetrics indicates an expected call of UseMetrics.

type MockMetrics added in v1.11.0 

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

MockMetrics is a mock of Metrics interface.

func NewMockMetrics added in v1.11.0 

func NewMockMetrics(ctrl *gomock.Controller) *MockMetrics

NewMockMetrics creates a new mock instance.

func (*MockMetrics) DeltaUpDownCounter added in v1.11.0 

func (m *MockMetrics) DeltaUpDownCounter(ctx context.Context, name string, value float64, labels ...string)

DeltaUpDownCounter mocks base method.

func (*MockMetrics) EXPECT added in v1.11.0 

func (m *MockMetrics) EXPECT() *MockMetricsMockRecorder

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

func (*MockMetrics) IncrementCounter added in v1.11.0 

func (m *MockMetrics) IncrementCounter(ctx context.Context, name string, labels ...string)

IncrementCounter mocks base method.

func (*MockMetrics) NewCounter added in v1.11.0 

func (m *MockMetrics) NewCounter(name, desc string)

NewCounter mocks base method.

func (*MockMetrics) NewGauge added in v1.11.0 

func (m *MockMetrics) NewGauge(name, desc string)

NewGauge mocks base method.

func (*MockMetrics) NewHistogram added in v1.11.0 

func (m *MockMetrics) NewHistogram(name, desc string, buckets ...float64)

NewHistogram mocks base method.

func (*MockMetrics) NewUpDownCounter added in v1.11.0 

func (m *MockMetrics) NewUpDownCounter(name, desc string)

NewUpDownCounter mocks base method.

func (*MockMetrics) RecordHistogram added in v1.11.0 

func (m *MockMetrics) RecordHistogram(ctx context.Context, name string, value float64, labels ...string)

RecordHistogram mocks base method.

func (*MockMetrics) SetGauge added in v1.11.0 

func (m *MockMetrics) SetGauge(name string, value float64, labels ...string)

SetGauge mocks base method.

type MockMetricsMockRecorder added in v1.11.0 

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

MockMetricsMockRecorder is the mock recorder for MockMetrics.

func (*MockMetricsMockRecorder) DeltaUpDownCounter added in v1.11.0 

func (mr *MockMetricsMockRecorder) DeltaUpDownCounter(ctx, name, value any, labels ...any) *gomock.Call

DeltaUpDownCounter indicates an expected call of DeltaUpDownCounter.

func (*MockMetricsMockRecorder) IncrementCounter added in v1.11.0 

func (mr *MockMetricsMockRecorder) IncrementCounter(ctx, name any, labels ...any) *gomock.Call

IncrementCounter indicates an expected call of IncrementCounter.

func (*MockMetricsMockRecorder) NewCounter added in v1.11.0 

func (mr *MockMetricsMockRecorder) NewCounter(name, desc any) *gomock.Call

NewCounter indicates an expected call of NewCounter.

func (*MockMetricsMockRecorder) NewGauge added in v1.11.0 

func (mr *MockMetricsMockRecorder) NewGauge(name, desc any) *gomock.Call

NewGauge indicates an expected call of NewGauge.

func (*MockMetricsMockRecorder) NewHistogram added in v1.11.0 

func (mr *MockMetricsMockRecorder) NewHistogram(name, desc any, buckets ...any) *gomock.Call

NewHistogram indicates an expected call of NewHistogram.

func (*MockMetricsMockRecorder) NewUpDownCounter added in v1.11.0 

func (mr *MockMetricsMockRecorder) NewUpDownCounter(name, desc any) *gomock.Call

NewUpDownCounter indicates an expected call of NewUpDownCounter.

func (*MockMetricsMockRecorder) RecordHistogram added in v1.11.0 

func (mr *MockMetricsMockRecorder) RecordHistogram(ctx, name, value any, labels ...any) *gomock.Call

RecordHistogram indicates an expected call of RecordHistogram.

func (*MockMetricsMockRecorder) SetGauge added in v1.11.0 

func (mr *MockMetricsMockRecorder) SetGauge(name, value any, labels ...any) *gomock.Call

SetGauge indicates an expected call of SetGauge.

type MockMongo added in v1.12.0 

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

MockMongo is a mock of Mongo interface.

func NewMockMongo added in v1.12.0 

func NewMockMongo(ctrl *gomock.Controller) *MockMongo

NewMockMongo creates a new mock instance.

func (*MockMongo) CountDocuments added in v1.12.0 

func (m *MockMongo) CountDocuments(ctx context.Context, collection string, filter any) (int64, error)

CountDocuments mocks base method.

func (*MockMongo) CreateCollection added in v1.13.0 

func (m *MockMongo) CreateCollection(ctx context.Context, name string) error

CreateCollection mocks base method.

func (*MockMongo) DeleteMany added in v1.12.0 

func (m *MockMongo) DeleteMany(ctx context.Context, collection string, filter any) (int64, error)

DeleteMany mocks base method.

func (*MockMongo) DeleteOne added in v1.12.0 

func (m *MockMongo) DeleteOne(ctx context.Context, collection string, filter any) (int64, error)

DeleteOne mocks base method.

func (*MockMongo) Drop added in v1.12.0 

func (m *MockMongo) Drop(ctx context.Context, collection string) error

Drop mocks base method.

func (*MockMongo) EXPECT added in v1.12.0 

func (m *MockMongo) EXPECT() *MockMongoMockRecorder

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

func (*MockMongo) Find added in v1.12.0 

func (m *MockMongo) Find(ctx context.Context, collection string, filter, results any) error

Find mocks base method.

func (*MockMongo) FindOne added in v1.12.0 

func (m *MockMongo) FindOne(ctx context.Context, collection string, filter, result any) error

FindOne mocks base method.

func (*MockMongo) HealthCheck added in v1.13.0 

func (m *MockMongo) HealthCheck(arg0 context.Context) (any, error)

HealthCheck mocks base method.

func (*MockMongo) InsertMany added in v1.12.0 

func (m *MockMongo) InsertMany(ctx context.Context, collection string, documents []any) ([]any, error)

InsertMany mocks base method.

func (*MockMongo) InsertOne added in v1.12.0 

func (m *MockMongo) InsertOne(ctx context.Context, collection string, document any) (any, error)

InsertOne mocks base method.

func (*MockMongo) StartSession added in v1.13.0 

func (m *MockMongo) StartSession() (any, error)

StartSession mocks base method.

func (*MockMongo) UpdateByID added in v1.12.0 

func (m *MockMongo) UpdateByID(ctx context.Context, collection string, id, update any) (int64, error)

UpdateByID mocks base method.

func (*MockMongo) UpdateMany added in v1.12.0 

func (m *MockMongo) UpdateMany(ctx context.Context, collection string, filter, update any) (int64, error)

UpdateMany mocks base method.

func (*MockMongo) UpdateOne added in v1.12.0 

func (m *MockMongo) UpdateOne(ctx context.Context, collection string, filter, update any) error

UpdateOne mocks base method.

type MockMongoMockRecorder added in v1.12.0 

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

MockMongoMockRecorder is the mock recorder for MockMongo.

func (*MockMongoMockRecorder) CountDocuments added in v1.12.0 

func (mr *MockMongoMockRecorder) CountDocuments(ctx, collection, filter any) *gomock.Call

CountDocuments indicates an expected call of CountDocuments.

func (*MockMongoMockRecorder) CreateCollection added in v1.13.0 

func (mr *MockMongoMockRecorder) CreateCollection(ctx, name any) *gomock.Call

CreateCollection indicates an expected call of CreateCollection.

func (*MockMongoMockRecorder) DeleteMany added in v1.12.0 

func (mr *MockMongoMockRecorder) DeleteMany(ctx, collection, filter any) *gomock.Call

DeleteMany indicates an expected call of DeleteMany.

func (*MockMongoMockRecorder) DeleteOne added in v1.12.0 

func (mr *MockMongoMockRecorder) DeleteOne(ctx, collection, filter any) *gomock.Call

DeleteOne indicates an expected call of DeleteOne.

func (*MockMongoMockRecorder) Drop added in v1.12.0 

func (mr *MockMongoMockRecorder) Drop(ctx, collection any) *gomock.Call

Drop indicates an expected call of Drop.

func (*MockMongoMockRecorder) Find added in v1.12.0 

func (mr *MockMongoMockRecorder) Find(ctx, collection, filter, results any) *gomock.Call

Find indicates an expected call of Find.

func (*MockMongoMockRecorder) FindOne added in v1.12.0 

func (mr *MockMongoMockRecorder) FindOne(ctx, collection, filter, result any) *gomock.Call

FindOne indicates an expected call of FindOne.

func (*MockMongoMockRecorder) HealthCheck added in v1.13.0 

func (mr *MockMongoMockRecorder) HealthCheck(arg0 any) *gomock.Call

HealthCheck indicates an expected call of HealthCheck.

func (*MockMongoMockRecorder) InsertMany added in v1.12.0 

func (mr *MockMongoMockRecorder) InsertMany(ctx, collection, documents any) *gomock.Call

InsertMany indicates an expected call of InsertMany.

func (*MockMongoMockRecorder) InsertOne added in v1.12.0 

func (mr *MockMongoMockRecorder) InsertOne(ctx, collection, document any) *gomock.Call

InsertOne indicates an expected call of InsertOne.

func (*MockMongoMockRecorder) StartSession added in v1.13.0 

func (mr *MockMongoMockRecorder) StartSession() *gomock.Call

StartSession indicates an expected call of StartSession.

func (*MockMongoMockRecorder) UpdateByID added in v1.12.0 

func (mr *MockMongoMockRecorder) UpdateByID(ctx, collection, id, update any) *gomock.Call

UpdateByID indicates an expected call of UpdateByID.

func (*MockMongoMockRecorder) UpdateMany added in v1.12.0 

func (mr *MockMongoMockRecorder) UpdateMany(ctx, collection, filter, update any) *gomock.Call

UpdateMany indicates an expected call of UpdateMany.

func (*MockMongoMockRecorder) UpdateOne added in v1.12.0 

func (mr *MockMongoMockRecorder) UpdateOne(ctx, collection, filter, update any) *gomock.Call

UpdateOne indicates an expected call of UpdateOne.

type MockMongoProvider added in v1.12.0 

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

MockMongoProvider is a mock of MongoProvider interface.

func NewMockMongoProvider added in v1.12.0 

func NewMockMongoProvider(ctrl *gomock.Controller) *MockMongoProvider

NewMockMongoProvider creates a new mock instance.

func (*MockMongoProvider) Connect added in v1.12.0 

func (m *MockMongoProvider) Connect()

Connect mocks base method.

func (*MockMongoProvider) CountDocuments added in v1.12.0 

func (m *MockMongoProvider) CountDocuments(ctx context.Context, collection string, filter any) (int64, error)

CountDocuments mocks base method.

func (*MockMongoProvider) CreateCollection added in v1.13.0 

func (m *MockMongoProvider) CreateCollection(ctx context.Context, name string) error

CreateCollection mocks base method.

func (*MockMongoProvider) DeleteMany added in v1.12.0 

func (m *MockMongoProvider) DeleteMany(ctx context.Context, collection string, filter any) (int64, error)

DeleteMany mocks base method.

func (*MockMongoProvider) DeleteOne added in v1.12.0 

func (m *MockMongoProvider) DeleteOne(ctx context.Context, collection string, filter any) (int64, error)

DeleteOne mocks base method.

func (*MockMongoProvider) Drop added in v1.12.0 

func (m *MockMongoProvider) Drop(ctx context.Context, collection string) error

Drop mocks base method.

func (*MockMongoProvider) EXPECT added in v1.12.0 

func (m *MockMongoProvider) EXPECT() *MockMongoProviderMockRecorder

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

func (*MockMongoProvider) Find added in v1.12.0 

func (m *MockMongoProvider) Find(ctx context.Context, collection string, filter, results any) error

Find mocks base method.

func (*MockMongoProvider) FindOne added in v1.12.0 

func (m *MockMongoProvider) FindOne(ctx context.Context, collection string, filter, result any) error

FindOne mocks base method.

func (*MockMongoProvider) HealthCheck added in v1.13.0 

func (m *MockMongoProvider) HealthCheck(arg0 context.Context) (any, error)

HealthCheck mocks base method.

func (*MockMongoProvider) InsertMany added in v1.12.0 

func (m *MockMongoProvider) InsertMany(ctx context.Context, collection string, documents []any) ([]any, error)

InsertMany mocks base method.

func (*MockMongoProvider) InsertOne added in v1.12.0 

func (m *MockMongoProvider) InsertOne(ctx context.Context, collection string, document any) (any, error)

InsertOne mocks base method.

func (*MockMongoProvider) StartSession added in v1.13.0 

func (m *MockMongoProvider) StartSession() (any, error)

StartSession mocks base method.

func (*MockMongoProvider) UpdateByID added in v1.12.0 

func (m *MockMongoProvider) UpdateByID(ctx context.Context, collection string, id, update any) (int64, error)

UpdateByID mocks base method.

func (*MockMongoProvider) UpdateMany added in v1.12.0 

func (m *MockMongoProvider) UpdateMany(ctx context.Context, collection string, filter, update any) (int64, error)

UpdateMany mocks base method.

func (*MockMongoProvider) UpdateOne added in v1.12.0 

func (m *MockMongoProvider) UpdateOne(ctx context.Context, collection string, filter, update any) error

UpdateOne mocks base method.

func (*MockMongoProvider) UseLogger added in v1.12.0 

func (m *MockMongoProvider) UseLogger(logger any)

UseLogger mocks base method.

func (*MockMongoProvider) UseMetrics added in v1.12.0 

func (m *MockMongoProvider) UseMetrics(metrics any)

UseMetrics mocks base method.

type MockMongoProviderMockRecorder added in v1.12.0 

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

MockMongoProviderMockRecorder is the mock recorder for MockMongoProvider.

func (*MockMongoProviderMockRecorder) Connect added in v1.12.0 

func (mr *MockMongoProviderMockRecorder) Connect() *gomock.Call

Connect indicates an expected call of Connect.

func (*MockMongoProviderMockRecorder) CountDocuments added in v1.12.0 

func (mr *MockMongoProviderMockRecorder) CountDocuments(ctx, collection, filter any) *gomock.Call

CountDocuments indicates an expected call of CountDocuments.

func (*MockMongoProviderMockRecorder) CreateCollection added in v1.13.0 

func (mr *MockMongoProviderMockRecorder) CreateCollection(ctx, name any) *gomock.Call

CreateCollection indicates an expected call of CreateCollection.

func (*MockMongoProviderMockRecorder) DeleteMany added in v1.12.0 

func (mr *MockMongoProviderMockRecorder) DeleteMany(ctx, collection, filter any) *gomock.Call

DeleteMany indicates an expected call of DeleteMany.

func (*MockMongoProviderMockRecorder) DeleteOne added in v1.12.0 

func (mr *MockMongoProviderMockRecorder) DeleteOne(ctx, collection, filter any) *gomock.Call

DeleteOne indicates an expected call of DeleteOne.

func (*MockMongoProviderMockRecorder) Drop added in v1.12.0 

func (mr *MockMongoProviderMockRecorder) Drop(ctx, collection any) *gomock.Call

Drop indicates an expected call of Drop.

func (*MockMongoProviderMockRecorder) Find added in v1.12.0 

func (mr *MockMongoProviderMockRecorder) Find(ctx, collection, filter, results any) *gomock.Call

Find indicates an expected call of Find.

func (*MockMongoProviderMockRecorder) FindOne added in v1.12.0 

func (mr *MockMongoProviderMockRecorder) FindOne(ctx, collection, filter, result any) *gomock.Call

FindOne indicates an expected call of FindOne.

func (*MockMongoProviderMockRecorder) HealthCheck added in v1.13.0 

func (mr *MockMongoProviderMockRecorder) HealthCheck(arg0 any) *gomock.Call

HealthCheck indicates an expected call of HealthCheck.

func (*MockMongoProviderMockRecorder) InsertMany added in v1.12.0 

func (mr *MockMongoProviderMockRecorder) InsertMany(ctx, collection, documents any) *gomock.Call

InsertMany indicates an expected call of InsertMany.

func (*MockMongoProviderMockRecorder) InsertOne added in v1.12.0 

func (mr *MockMongoProviderMockRecorder) InsertOne(ctx, collection, document any) *gomock.Call

InsertOne indicates an expected call of InsertOne.

func (*MockMongoProviderMockRecorder) StartSession added in v1.13.0 

func (mr *MockMongoProviderMockRecorder) StartSession() *gomock.Call

StartSession indicates an expected call of StartSession.

func (*MockMongoProviderMockRecorder) UpdateByID added in v1.12.0 

func (mr *MockMongoProviderMockRecorder) UpdateByID(ctx, collection, id, update any) *gomock.Call

UpdateByID indicates an expected call of UpdateByID.

func (*MockMongoProviderMockRecorder) UpdateMany added in v1.12.0 

func (mr *MockMongoProviderMockRecorder) UpdateMany(ctx, collection, filter, update any) *gomock.Call

UpdateMany indicates an expected call of UpdateMany.

func (*MockMongoProviderMockRecorder) UpdateOne added in v1.12.0 

func (mr *MockMongoProviderMockRecorder) UpdateOne(ctx, collection, filter, update any) *gomock.Call

UpdateOne indicates an expected call of UpdateOne.

func (*MockMongoProviderMockRecorder) UseLogger added in v1.12.0 

func (mr *MockMongoProviderMockRecorder) UseLogger(logger any) *gomock.Call

UseLogger indicates an expected call of UseLogger.

func (*MockMongoProviderMockRecorder) UseMetrics added in v1.12.0 

func (mr *MockMongoProviderMockRecorder) UseMetrics(metrics any) *gomock.Call

UseMetrics indicates an expected call of UseMetrics.

type MockPubSub added in v1.4.1 

type MockPubSub struct {
}

func (*MockPubSub) Close added in v1.16.0 

func (*MockPubSub) Close() error

func (*MockPubSub) CreateTopic added in v1.4.1 

func (*MockPubSub) CreateTopic(_ context.Context, _ string) error

func (*MockPubSub) DeleteTopic added in v1.4.1 

func (*MockPubSub) DeleteTopic(_ context.Context, _ string) error

func (*MockPubSub) Health added in v1.4.1 

func (*MockPubSub) Health() datasource.Health

func (*MockPubSub) Publish added in v1.4.1 

func (*MockPubSub) Publish(_ context.Context, _ string, _ []byte) error

func (*MockPubSub) Subscribe added in v1.4.1 

func (*MockPubSub) Subscribe(_ context.Context, _ string) (*pubsub.Message, error)

type MockRedis added in v1.3.0 

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

MockRedis is a mock of Redis interface.

func NewMockRedis added in v1.3.0 

func NewMockRedis(ctrl *gomock.Controller) *MockRedis

NewMockRedis creates a new mock instance.

func (*MockRedis) ACLDryRun added in v1.3.0 

func (m *MockRedis) ACLDryRun(ctx context.Context, username string, command ...any) *redis.StringCmd

ACLDryRun mocks base method.

func (*MockRedis) ACLLog added in v1.3.0 

func (m *MockRedis) ACLLog(ctx context.Context, count int64) *redis.ACLLogCmd

ACLLog mocks base method.

func (*MockRedis) ACLLogReset added in v1.3.0 

func (m *MockRedis) ACLLogReset(ctx context.Context) *redis.StatusCmd

ACLLogReset mocks base method.

func (*MockRedis) Append added in v1.3.0 

func (m *MockRedis) Append(ctx context.Context, key, value string) *redis.IntCmd

Append mocks base method.

func (*MockRedis) BFAdd added in v1.3.0 

func (m *MockRedis) BFAdd(ctx context.Context, key string, element any) *redis.BoolCmd

BFAdd mocks base method.

func (*MockRedis) BFCard added in v1.3.0 

func (m *MockRedis) BFCard(ctx context.Context, key string) *redis.IntCmd

BFCard mocks base method.

func (*MockRedis) BFExists added in v1.3.0 

func (m *MockRedis) BFExists(ctx context.Context, key string, element any) *redis.BoolCmd

BFExists mocks base method.

func (*MockRedis) BFInfo added in v1.3.0 

func (m *MockRedis) BFInfo(ctx context.Context, key string) *redis.BFInfoCmd

BFInfo mocks base method.

func (*MockRedis) BFInfoArg added in v1.3.0 

func (m *MockRedis) BFInfoArg(ctx context.Context, key, option string) *redis.BFInfoCmd

BFInfoArg mocks base method.

func (*MockRedis) BFInfoCapacity added in v1.3.0 

func (m *MockRedis) BFInfoCapacity(ctx context.Context, key string) *redis.BFInfoCmd

BFInfoCapacity mocks base method.

func (*MockRedis) BFInfoExpansion added in v1.3.0 

func (m *MockRedis) BFInfoExpansion(ctx context.Context, key string) *redis.BFInfoCmd

BFInfoExpansion mocks base method.

func (*MockRedis) BFInfoFilters added in v1.3.0 

func (m *MockRedis) BFInfoFilters(ctx context.Context, key string) *redis.BFInfoCmd

BFInfoFilters mocks base method.

func (*MockRedis) BFInfoItems added in v1.3.0 

func (m *MockRedis) BFInfoItems(ctx context.Context, key string) *redis.BFInfoCmd

BFInfoItems mocks base method.

func (*MockRedis) BFInfoSize added in v1.3.0 

func (m *MockRedis) BFInfoSize(ctx context.Context, key string) *redis.BFInfoCmd

BFInfoSize mocks base method.

func (*MockRedis) BFInsert added in v1.3.0 

func (m *MockRedis) BFInsert(ctx context.Context, key string, options *redis.BFInsertOptions, elements ...any) *redis.BoolSliceCmd

BFInsert mocks base method.

func (*MockRedis) BFLoadChunk added in v1.3.0 

func (m *MockRedis) BFLoadChunk(ctx context.Context, key string, iterator int64, data any) *redis.StatusCmd

BFLoadChunk mocks base method.

func (*MockRedis) BFMAdd added in v1.3.0 

func (m *MockRedis) BFMAdd(ctx context.Context, key string, elements ...any) *redis.BoolSliceCmd

BFMAdd mocks base method.

func (*MockRedis) BFMExists added in v1.3.0 

func (m *MockRedis) BFMExists(ctx context.Context, key string, elements ...any) *redis.BoolSliceCmd

BFMExists mocks base method.

func (*MockRedis) BFReserve added in v1.3.0 

func (m *MockRedis) BFReserve(ctx context.Context, key string, errorRate float64, capacity int64) *redis.StatusCmd

BFReserve mocks base method.

func (*MockRedis) BFReserveExpansion added in v1.3.0 

func (m *MockRedis) BFReserveExpansion(ctx context.Context, key string, errorRate float64, capacity, expansion int64) *redis.StatusCmd

BFReserveExpansion mocks base method.

func (*MockRedis) BFReserveNonScaling added in v1.3.0 

func (m *MockRedis) BFReserveNonScaling(ctx context.Context, key string, errorRate float64, capacity int64) *redis.StatusCmd

BFReserveNonScaling mocks base method.

func (*MockRedis) BFReserveWithArgs added in v1.3.0 

func (m *MockRedis) BFReserveWithArgs(ctx context.Context, key string, options *redis.BFReserveOptions) *redis.StatusCmd

BFReserveWithArgs mocks base method.

func (*MockRedis) BFScanDump added in v1.3.0 

func (m *MockRedis) BFScanDump(ctx context.Context, key string, iterator int64) *redis.ScanDumpCmd

BFScanDump mocks base method.

func (*MockRedis) BLMPop added in v1.3.0 

func (m *MockRedis) BLMPop(ctx context.Context, timeout time.Duration, direction string, count int64, keys ...string) *redis.KeyValuesCmd

BLMPop mocks base method.

func (*MockRedis) BLMove added in v1.3.0 

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

BLMove mocks base method.

func (*MockRedis) BLPop added in v1.3.0 

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

BLPop mocks base method.

func (*MockRedis) BRPop added in v1.3.0 

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

BRPop mocks base method.

func (*MockRedis) BRPopLPush added in v1.3.0 

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

BRPopLPush mocks base method.

func (*MockRedis) BZMPop added in v1.3.0 

func (m *MockRedis) BZMPop(ctx context.Context, timeout time.Duration, order string, count int64, keys ...string) *redis.ZSliceWithKeyCmd

BZMPop mocks base method.

func (*MockRedis) BZPopMax added in v1.3.0 

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

BZPopMax mocks base method.

func (*MockRedis) BZPopMin added in v1.3.0 

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

BZPopMin mocks base method.

func (*MockRedis) BgRewriteAOF added in v1.3.0 

func (m *MockRedis) BgRewriteAOF(ctx context.Context) *redis.StatusCmd

BgRewriteAOF mocks base method.

func (*MockRedis) BgSave added in v1.3.0 

func (m *MockRedis) BgSave(ctx context.Context) *redis.StatusCmd

BgSave mocks base method.

func (*MockRedis) BitCount added in v1.3.0 

func (m *MockRedis) BitCount(ctx context.Context, key string, bitCount *redis.BitCount) *redis.IntCmd

BitCount mocks base method.

func (*MockRedis) BitField added in v1.3.0 

func (m *MockRedis) BitField(ctx context.Context, key string, values ...any) *redis.IntSliceCmd

BitField mocks base method.

func (*MockRedis) BitFieldRO added in v1.15.0 

func (m *MockRedis) BitFieldRO(ctx context.Context, key string, values ...any) *redis.IntSliceCmd

BitFieldRO mocks base method.

func (*MockRedis) BitOpAnd added in v1.3.0 

func (m *MockRedis) BitOpAnd(ctx context.Context, destKey string, keys ...string) *redis.IntCmd

BitOpAnd mocks base method.

func (*MockRedis) BitOpNot added in v1.3.0 

func (m *MockRedis) BitOpNot(ctx context.Context, destKey, key string) *redis.IntCmd

BitOpNot mocks base method.

func (*MockRedis) BitOpOr added in v1.3.0 

func (m *MockRedis) BitOpOr(ctx context.Context, destKey string, keys ...string) *redis.IntCmd

BitOpOr mocks base method.

func (*MockRedis) BitOpXor added in v1.3.0 

func (m *MockRedis) BitOpXor(ctx context.Context, destKey string, keys ...string) *redis.IntCmd

BitOpXor mocks base method.

func (*MockRedis) BitPos added in v1.3.0 

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

BitPos mocks base method.

func (*MockRedis) BitPosSpan added in v1.3.0 

func (m *MockRedis) BitPosSpan(ctx context.Context, key string, bit int8, start, end int64, span string) *redis.IntCmd

BitPosSpan mocks base method.

func (*MockRedis) CFAdd added in v1.3.0 

func (m *MockRedis) CFAdd(ctx context.Context, key string, element any) *redis.BoolCmd

CFAdd mocks base method.

func (*MockRedis) CFAddNX added in v1.3.0 

func (m *MockRedis) CFAddNX(ctx context.Context, key string, element any) *redis.BoolCmd

CFAddNX mocks base method.

func (*MockRedis) CFCount added in v1.3.0 

func (m *MockRedis) CFCount(ctx context.Context, key string, element any) *redis.IntCmd

CFCount mocks base method.

func (*MockRedis) CFDel added in v1.3.0 

func (m *MockRedis) CFDel(ctx context.Context, key string, element any) *redis.BoolCmd

CFDel mocks base method.

func (*MockRedis) CFExists added in v1.3.0 

func (m *MockRedis) CFExists(ctx context.Context, key string, element any) *redis.BoolCmd

CFExists mocks base method.

func (*MockRedis) CFInfo added in v1.3.0 

func (m *MockRedis) CFInfo(ctx context.Context, key string) *redis.CFInfoCmd

CFInfo mocks base method.

func (*MockRedis) CFInsert added in v1.3.0 

func (m *MockRedis) CFInsert(ctx context.Context, key string, options *redis.CFInsertOptions, elements ...any) *redis.BoolSliceCmd

CFInsert mocks base method.

func (*MockRedis) CFInsertNX added in v1.3.0 

func (m *MockRedis) CFInsertNX(ctx context.Context, key string, options *redis.CFInsertOptions, elements ...any) *redis.IntSliceCmd

CFInsertNX mocks base method.

func (*MockRedis) CFLoadChunk added in v1.3.0 

func (m *MockRedis) CFLoadChunk(ctx context.Context, key string, iterator int64, data any) *redis.StatusCmd

CFLoadChunk mocks base method.

func (*MockRedis) CFMExists added in v1.3.0 

func (m *MockRedis) CFMExists(ctx context.Context, key string, elements ...any) *redis.BoolSliceCmd

CFMExists mocks base method.

func (*MockRedis) CFReserve added in v1.3.0 

func (m *MockRedis) CFReserve(ctx context.Context, key string, capacity int64) *redis.StatusCmd

CFReserve mocks base method.

func (*MockRedis) CFReserveBucketSize added in v1.3.0 

func (m *MockRedis) CFReserveBucketSize(ctx context.Context, key string, capacity, bucketsize int64) *redis.StatusCmd

CFReserveBucketSize mocks base method.

func (*MockRedis) CFReserveExpansion added in v1.3.0 

func (m *MockRedis) CFReserveExpansion(ctx context.Context, key string, capacity, expansion int64) *redis.StatusCmd

CFReserveExpansion mocks base method.

func (*MockRedis) CFReserveMaxIterations added in v1.3.0 

func (m *MockRedis) CFReserveMaxIterations(ctx context.Context, key string, capacity, maxiterations int64) *redis.StatusCmd

CFReserveMaxIterations mocks base method.

func (*MockRedis) CFReserveWithArgs added in v1.3.0 

func (m *MockRedis) CFReserveWithArgs(ctx context.Context, key string, options *redis.CFReserveOptions) *redis.StatusCmd

CFReserveWithArgs mocks base method.

func (*MockRedis) CFScanDump added in v1.3.0 

func (m *MockRedis) CFScanDump(ctx context.Context, key string, iterator int64) *redis.ScanDumpCmd

CFScanDump mocks base method.

func (*MockRedis) CMSIncrBy added in v1.3.0 

func (m *MockRedis) CMSIncrBy(ctx context.Context, key string, elements ...any) *redis.IntSliceCmd

CMSIncrBy mocks base method.

func (*MockRedis) CMSInfo added in v1.3.0 

func (m *MockRedis) CMSInfo(ctx context.Context, key string) *redis.CMSInfoCmd

CMSInfo mocks base method.

func (*MockRedis) CMSInitByDim added in v1.3.0 

func (m *MockRedis) CMSInitByDim(ctx context.Context, key string, width, height int64) *redis.StatusCmd

CMSInitByDim mocks base method.

func (*MockRedis) CMSInitByProb added in v1.3.0 

func (m *MockRedis) CMSInitByProb(ctx context.Context, key string, errorRate, probability float64) *redis.StatusCmd

CMSInitByProb mocks base method.

func (*MockRedis) CMSMerge added in v1.3.0 

func (m *MockRedis) CMSMerge(ctx context.Context, destKey string, sourceKeys ...string) *redis.StatusCmd

CMSMerge mocks base method.

func (*MockRedis) CMSMergeWithWeight added in v1.3.0 

func (m *MockRedis) CMSMergeWithWeight(ctx context.Context, destKey string, sourceKeys map[string]int64) *redis.StatusCmd

CMSMergeWithWeight mocks base method.

func (*MockRedis) CMSQuery added in v1.3.0 

func (m *MockRedis) CMSQuery(ctx context.Context, key string, elements ...any) *redis.IntSliceCmd

CMSQuery mocks base method.

func (*MockRedis) ClientGetName added in v1.3.0 

func (m *MockRedis) ClientGetName(ctx context.Context) *redis.StringCmd

ClientGetName mocks base method.

func (*MockRedis) ClientID added in v1.3.0 

func (m *MockRedis) ClientID(ctx context.Context) *redis.IntCmd

ClientID mocks base method.

func (*MockRedis) ClientInfo added in v1.3.0 

func (m *MockRedis) ClientInfo(ctx context.Context) *redis.ClientInfoCmd

ClientInfo mocks base method.

func (*MockRedis) ClientKill added in v1.3.0 

func (m *MockRedis) ClientKill(ctx context.Context, ipPort string) *redis.StatusCmd

ClientKill mocks base method.

func (*MockRedis) ClientKillByFilter added in v1.3.0 

func (m *MockRedis) ClientKillByFilter(ctx context.Context, keys ...string) *redis.IntCmd

ClientKillByFilter mocks base method.

func (*MockRedis) ClientList added in v1.3.0 

func (m *MockRedis) ClientList(ctx context.Context) *redis.StringCmd

ClientList mocks base method.

func (*MockRedis) ClientPause added in v1.3.0 

func (m *MockRedis) ClientPause(ctx context.Context, dur time.Duration) *redis.BoolCmd

ClientPause mocks base method.

func (*MockRedis) ClientUnblock added in v1.3.0 

func (m *MockRedis) ClientUnblock(ctx context.Context, id int64) *redis.IntCmd

ClientUnblock mocks base method.

func (*MockRedis) ClientUnblockWithError added in v1.3.0 

func (m *MockRedis) ClientUnblockWithError(ctx context.Context, id int64) *redis.IntCmd

ClientUnblockWithError mocks base method.

func (*MockRedis) ClientUnpause added in v1.3.0 

func (m *MockRedis) ClientUnpause(ctx context.Context) *redis.BoolCmd

ClientUnpause mocks base method.

func (*MockRedis) Close added in v1.16.0 

func (m *MockRedis) Close() error

Close mocks base method.

func (*MockRedis) ClusterAddSlots added in v1.3.0 

func (m *MockRedis) ClusterAddSlots(ctx context.Context, slots ...int) *redis.StatusCmd

ClusterAddSlots mocks base method.

func (*MockRedis) ClusterAddSlotsRange added in v1.3.0 

func (m *MockRedis) ClusterAddSlotsRange(ctx context.Context, min, max int) *redis.StatusCmd

ClusterAddSlotsRange mocks base method.

func (*MockRedis) ClusterCountFailureReports added in v1.3.0 

func (m *MockRedis) ClusterCountFailureReports(ctx context.Context, nodeID string) *redis.IntCmd

ClusterCountFailureReports mocks base method.

func (*MockRedis) ClusterCountKeysInSlot added in v1.3.0 

func (m *MockRedis) ClusterCountKeysInSlot(ctx context.Context, slot int) *redis.IntCmd

ClusterCountKeysInSlot mocks base method.

func (*MockRedis) ClusterDelSlots added in v1.3.0 

func (m *MockRedis) ClusterDelSlots(ctx context.Context, slots ...int) *redis.StatusCmd

ClusterDelSlots mocks base method.

func (*MockRedis) ClusterDelSlotsRange added in v1.3.0 

func (m *MockRedis) ClusterDelSlotsRange(ctx context.Context, min, max int) *redis.StatusCmd

ClusterDelSlotsRange mocks base method.

func (*MockRedis) ClusterFailover added in v1.3.0 

func (m *MockRedis) ClusterFailover(ctx context.Context) *redis.StatusCmd

ClusterFailover mocks base method.

func (*MockRedis) ClusterForget added in v1.3.0 

func (m *MockRedis) ClusterForget(ctx context.Context, nodeID string) *redis.StatusCmd

ClusterForget mocks base method.

func (*MockRedis) ClusterGetKeysInSlot added in v1.3.0 

func (m *MockRedis) ClusterGetKeysInSlot(ctx context.Context, slot, count int) *redis.StringSliceCmd

ClusterGetKeysInSlot mocks base method.

func (*MockRedis) ClusterInfo added in v1.3.0 

func (m *MockRedis) ClusterInfo(ctx context.Context) *redis.StringCmd

ClusterInfo mocks base method.

func (*MockRedis) ClusterKeySlot added in v1.3.0 

func (m *MockRedis) ClusterKeySlot(ctx context.Context, key string) *redis.IntCmd

ClusterKeySlot mocks base method. 

func (m *MockRedis) ClusterLinks(ctx context.Context) *redis.ClusterLinksCmd

ClusterLinks mocks base method.

func (*MockRedis) ClusterMeet added in v1.3.0 

func (m *MockRedis) ClusterMeet(ctx context.Context, host, port string) *redis.StatusCmd

ClusterMeet mocks base method.

func (*MockRedis) ClusterMyShardID added in v1.3.0 

func (m *MockRedis) ClusterMyShardID(ctx context.Context) *redis.StringCmd

ClusterMyShardID mocks base method.

func (*MockRedis) ClusterNodes added in v1.3.0 

func (m *MockRedis) ClusterNodes(ctx context.Context) *redis.StringCmd

ClusterNodes mocks base method.

func (*MockRedis) ClusterReplicate added in v1.3.0 

func (m *MockRedis) ClusterReplicate(ctx context.Context, nodeID string) *redis.StatusCmd

ClusterReplicate mocks base method.

func (*MockRedis) ClusterResetHard added in v1.3.0 

func (m *MockRedis) ClusterResetHard(ctx context.Context) *redis.StatusCmd

ClusterResetHard mocks base method.

func (*MockRedis) ClusterResetSoft added in v1.3.0 

func (m *MockRedis) ClusterResetSoft(ctx context.Context) *redis.StatusCmd

ClusterResetSoft mocks base method.

func (*MockRedis) ClusterSaveConfig added in v1.3.0 

func (m *MockRedis) ClusterSaveConfig(ctx context.Context) *redis.StatusCmd

ClusterSaveConfig mocks base method.

func (*MockRedis) ClusterShards added in v1.3.0 

func (m *MockRedis) ClusterShards(ctx context.Context) *redis.ClusterShardsCmd

ClusterShards mocks base method.

func (*MockRedis) ClusterSlaves added in v1.3.0 

func (m *MockRedis) ClusterSlaves(ctx context.Context, nodeID string) *redis.StringSliceCmd

ClusterSlaves mocks base method.

func (*MockRedis) ClusterSlots added in v1.3.0 

func (m *MockRedis) ClusterSlots(ctx context.Context) *redis.ClusterSlotsCmd

ClusterSlots mocks base method.

func (*MockRedis) Command added in v1.3.0 

func (m *MockRedis) Command(ctx context.Context) *redis.CommandsInfoCmd

Command mocks base method.

func (*MockRedis) CommandGetKeys added in v1.3.0 

func (m *MockRedis) CommandGetKeys(ctx context.Context, commands ...any) *redis.StringSliceCmd

CommandGetKeys mocks base method.

func (*MockRedis) CommandGetKeysAndFlags added in v1.3.0 

func (m *MockRedis) CommandGetKeysAndFlags(ctx context.Context, commands ...any) *redis.KeyFlagsCmd

CommandGetKeysAndFlags mocks base method.

func (*MockRedis) CommandList added in v1.3.0 

func (m *MockRedis) CommandList(ctx context.Context, filter *redis.FilterBy) *redis.StringSliceCmd

CommandList mocks base method.

func (*MockRedis) ConfigGet added in v1.3.0 

func (m *MockRedis) ConfigGet(ctx context.Context, parameter string) *redis.MapStringStringCmd

ConfigGet mocks base method.

func (*MockRedis) ConfigResetStat added in v1.3.0 

func (m *MockRedis) ConfigResetStat(ctx context.Context) *redis.StatusCmd

ConfigResetStat mocks base method.

func (*MockRedis) ConfigRewrite added in v1.3.0 

func (m *MockRedis) ConfigRewrite(ctx context.Context) *redis.StatusCmd

ConfigRewrite mocks base method.

func (*MockRedis) ConfigSet added in v1.3.0 

func (m *MockRedis) ConfigSet(ctx context.Context, parameter, value string) *redis.StatusCmd

ConfigSet mocks base method.

func (*MockRedis) Copy added in v1.3.0 

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

Copy mocks base method.

func (*MockRedis) DBSize added in v1.3.0 

func (m *MockRedis) DBSize(ctx context.Context) *redis.IntCmd

DBSize mocks base method.

func (*MockRedis) DebugObject added in v1.3.0 

func (m *MockRedis) DebugObject(ctx context.Context, key string) *redis.StringCmd

DebugObject mocks base method.

func (*MockRedis) Decr added in v1.3.0 

func (m *MockRedis) Decr(ctx context.Context, key string) *redis.IntCmd

Decr mocks base method.

func (*MockRedis) DecrBy added in v1.3.0 

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

DecrBy mocks base method.

func (*MockRedis) Del added in v1.3.0 

func (m *MockRedis) Del(ctx context.Context, keys ...string) *redis.IntCmd

Del mocks base method.

func (*MockRedis) Dump added in v1.3.0 

func (m *MockRedis) Dump(ctx context.Context, key string) *redis.StringCmd

Dump mocks base method.

func (*MockRedis) EXPECT added in v1.3.0 

func (m *MockRedis) EXPECT() *MockRedisMockRecorder

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

func (*MockRedis) Echo added in v1.3.0 

func (m *MockRedis) Echo(ctx context.Context, message any) *redis.StringCmd

Echo mocks base method.

func (*MockRedis) Eval added in v1.3.0 

func (m *MockRedis) Eval(ctx context.Context, script string, keys []string, args ...any) *redis.Cmd

Eval mocks base method.

func (*MockRedis) EvalRO added in v1.3.0 

func (m *MockRedis) EvalRO(ctx context.Context, script string, keys []string, args ...any) *redis.Cmd

EvalRO mocks base method.

func (*MockRedis) EvalSha added in v1.3.0 

func (m *MockRedis) EvalSha(ctx context.Context, sha1 string, keys []string, args ...any) *redis.Cmd

EvalSha mocks base method.

func (*MockRedis) EvalShaRO added in v1.3.0 

func (m *MockRedis) EvalShaRO(ctx context.Context, sha1 string, keys []string, args ...any) *redis.Cmd

EvalShaRO mocks base method.

func (*MockRedis) Exists added in v1.3.0 

func (m *MockRedis) Exists(ctx context.Context, keys ...string) *redis.IntCmd

Exists mocks base method.

func (*MockRedis) Expire added in v1.3.0 

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

Expire mocks base method.

func (*MockRedis) ExpireAt added in v1.3.0 

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

ExpireAt mocks base method.

func (*MockRedis) ExpireGT added in v1.3.0 

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

ExpireGT mocks base method.

func (*MockRedis) ExpireLT added in v1.3.0 

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

ExpireLT mocks base method.

func (*MockRedis) ExpireNX added in v1.3.0 

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

ExpireNX mocks base method.

func (*MockRedis) ExpireTime added in v1.3.0 

func (m *MockRedis) ExpireTime(ctx context.Context, key string) *redis.DurationCmd

ExpireTime mocks base method.

func (*MockRedis) ExpireXX added in v1.3.0 

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

ExpireXX mocks base method.

func (*MockRedis) FCall added in v1.3.0 

func (m *MockRedis) FCall(ctx context.Context, function string, keys []string, args ...any) *redis.Cmd

FCall mocks base method.

func (*MockRedis) FCallRO added in v1.3.0 

func (m *MockRedis) FCallRO(ctx context.Context, function string, keys []string, args ...any) *redis.Cmd

FCallRO mocks base method.

func (*MockRedis) FCallRo added in v1.3.0 

func (m *MockRedis) FCallRo(ctx context.Context, function string, keys []string, args ...any) *redis.Cmd

FCallRo mocks base method.

func (*MockRedis) FlushAll added in v1.3.0 

func (m *MockRedis) FlushAll(ctx context.Context) *redis.StatusCmd

FlushAll mocks base method.

func (*MockRedis) FlushAllAsync added in v1.3.0 

func (m *MockRedis) FlushAllAsync(ctx context.Context) *redis.StatusCmd

FlushAllAsync mocks base method.

func (*MockRedis) FlushDB added in v1.3.0 

func (m *MockRedis) FlushDB(ctx context.Context) *redis.StatusCmd

FlushDB mocks base method.

func (*MockRedis) FlushDBAsync added in v1.3.0 

func (m *MockRedis) FlushDBAsync(ctx context.Context) *redis.StatusCmd

FlushDBAsync mocks base method.

func (*MockRedis) FunctionDelete added in v1.3.0 

func (m *MockRedis) FunctionDelete(ctx context.Context, libName string) *redis.StringCmd

FunctionDelete mocks base method.

func (*MockRedis) FunctionDump added in v1.3.0 

func (m *MockRedis) FunctionDump(ctx context.Context) *redis.StringCmd

FunctionDump mocks base method.

func (*MockRedis) FunctionFlush added in v1.3.0 

func (m *MockRedis) FunctionFlush(ctx context.Context) *redis.StringCmd

FunctionFlush mocks base method.

func (*MockRedis) FunctionFlushAsync added in v1.3.0 

func (m *MockRedis) FunctionFlushAsync(ctx context.Context) *redis.StringCmd

FunctionFlushAsync mocks base method.

func (*MockRedis) FunctionKill added in v1.3.0 

func (m *MockRedis) FunctionKill(ctx context.Context) *redis.StringCmd

FunctionKill mocks base method.

func (*MockRedis) FunctionList added in v1.3.0 

func (m *MockRedis) FunctionList(ctx context.Context, q redis.FunctionListQuery) *redis.FunctionListCmd

FunctionList mocks base method.

func (*MockRedis) FunctionLoad added in v1.3.0 

func (m *MockRedis) FunctionLoad(ctx context.Context, code string) *redis.StringCmd

FunctionLoad mocks base method.

func (*MockRedis) FunctionLoadReplace added in v1.3.0 

func (m *MockRedis) FunctionLoadReplace(ctx context.Context, code string) *redis.StringCmd

FunctionLoadReplace mocks base method.

func (*MockRedis) FunctionRestore added in v1.3.0 

func (m *MockRedis) FunctionRestore(ctx context.Context, libDump string) *redis.StringCmd

FunctionRestore mocks base method.

func (*MockRedis) FunctionStats added in v1.3.0 

func (m *MockRedis) FunctionStats(ctx context.Context) *redis.FunctionStatsCmd

FunctionStats mocks base method.

func (*MockRedis) GeoAdd added in v1.3.0 

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

GeoAdd mocks base method.

func (*MockRedis) GeoDist added in v1.3.0 

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

GeoDist mocks base method.

func (*MockRedis) GeoHash added in v1.3.0 

func (m *MockRedis) GeoHash(ctx context.Context, key string, members ...string) *redis.StringSliceCmd

GeoHash mocks base method.

func (*MockRedis) GeoPos added in v1.3.0 

func (m *MockRedis) GeoPos(ctx context.Context, key string, members ...string) *redis.GeoPosCmd

GeoPos mocks base method.

func (*MockRedis) GeoRadius added in v1.3.0 

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

GeoRadius mocks base method.

func (*MockRedis) GeoRadiusByMember added in v1.3.0 

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

GeoRadiusByMember mocks base method.

func (*MockRedis) GeoRadiusByMemberStore added in v1.3.0 

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

GeoRadiusByMemberStore mocks base method.

func (*MockRedis) GeoRadiusStore added in v1.3.0 

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

GeoRadiusStore mocks base method.

func (*MockRedis) GeoSearch added in v1.3.0 

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

GeoSearch mocks base method.

func (*MockRedis) GeoSearchLocation added in v1.3.0 

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

GeoSearchLocation mocks base method.

func (*MockRedis) GeoSearchStore added in v1.3.0 

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

GeoSearchStore mocks base method.

func (*MockRedis) Get added in v1.3.0 

func (m *MockRedis) Get(ctx context.Context, key string) *redis.StringCmd

Get mocks base method.

func (*MockRedis) GetBit added in v1.3.0 

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

GetBit mocks base method.

func (*MockRedis) GetDel added in v1.3.0 

func (m *MockRedis) GetDel(ctx context.Context, key string) *redis.StringCmd

GetDel mocks base method.

func (*MockRedis) GetEx added in v1.3.0 

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

GetEx mocks base method.

func (*MockRedis) GetRange added in v1.3.0 

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

GetRange mocks base method.

func (*MockRedis) GetSet added in v1.3.0 

func (m *MockRedis) GetSet(ctx context.Context, key string, value any) *redis.StringCmd

GetSet mocks base method.

func (*MockRedis) HDel added in v1.3.0 

func (m *MockRedis) HDel(ctx context.Context, key string, fields ...string) *redis.IntCmd

HDel mocks base method.

func (*MockRedis) HExists added in v1.3.0 

func (m *MockRedis) HExists(ctx context.Context, key, field string) *redis.BoolCmd

HExists mocks base method.

func (*MockRedis) HExpire added in v1.15.0 

func (m *MockRedis) HExpire(ctx context.Context, key string, expiration time.Duration, fields ...string) *redis.IntSliceCmd

HExpire mocks base method.

func (*MockRedis) HExpireAt added in v1.15.0 

func (m *MockRedis) HExpireAt(ctx context.Context, key string, tm time.Time, fields ...string) *redis.IntSliceCmd

HExpireAt mocks base method.

func (*MockRedis) HExpireAtWithArgs added in v1.15.0 

func (m *MockRedis) HExpireAtWithArgs(ctx context.Context, key string, tm time.Time, expirationArgs redis.HExpireArgs, fields ...string) *redis.IntSliceCmd

HExpireAtWithArgs mocks base method.

func (*MockRedis) HExpireTime added in v1.15.0 

func (m *MockRedis) HExpireTime(ctx context.Context, key string, fields ...string) *redis.IntSliceCmd

HExpireTime mocks base method.

func (*MockRedis) HExpireWithArgs added in v1.15.0 

func (m *MockRedis) HExpireWithArgs(ctx context.Context, key string, expiration time.Duration, expirationArgs redis.HExpireArgs, fields ...string) *redis.IntSliceCmd

HExpireWithArgs mocks base method.

func (*MockRedis) HGet added in v1.3.0 

func (m *MockRedis) HGet(ctx context.Context, key, field string) *redis.StringCmd

HGet mocks base method.

func (*MockRedis) HGetAll added in v1.3.0 

func (m *MockRedis) HGetAll(ctx context.Context, key string) *redis.MapStringStringCmd

HGetAll mocks base method.

func (*MockRedis) HIncrBy added in v1.3.0 

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

HIncrBy mocks base method.

func (*MockRedis) HIncrByFloat added in v1.3.0 

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

HIncrByFloat mocks base method.

func (*MockRedis) HKeys added in v1.3.0 

func (m *MockRedis) HKeys(ctx context.Context, key string) *redis.StringSliceCmd

HKeys mocks base method.

func (*MockRedis) HLen added in v1.3.0 

func (m *MockRedis) HLen(ctx context.Context, key string) *redis.IntCmd

HLen mocks base method.

func (*MockRedis) HMGet added in v1.3.0 

func (m *MockRedis) HMGet(ctx context.Context, key string, fields ...string) *redis.SliceCmd

HMGet mocks base method.

func (*MockRedis) HMSet added in v1.3.0 

func (m *MockRedis) HMSet(ctx context.Context, key string, values ...any) *redis.BoolCmd

HMSet mocks base method.

func (*MockRedis) HPExpire added in v1.15.0 

func (m *MockRedis) HPExpire(ctx context.Context, key string, expiration time.Duration, fields ...string) *redis.IntSliceCmd

HPExpire mocks base method.

func (*MockRedis) HPExpireAt added in v1.15.0 

func (m *MockRedis) HPExpireAt(ctx context.Context, key string, tm time.Time, fields ...string) *redis.IntSliceCmd

HPExpireAt mocks base method.

func (*MockRedis) HPExpireAtWithArgs added in v1.15.0 

func (m *MockRedis) HPExpireAtWithArgs(ctx context.Context, key string, tm time.Time, expirationArgs redis.HExpireArgs, fields ...string) *redis.IntSliceCmd

HPExpireAtWithArgs mocks base method.

func (*MockRedis) HPExpireTime added in v1.15.0 

func (m *MockRedis) HPExpireTime(ctx context.Context, key string, fields ...string) *redis.IntSliceCmd

HPExpireTime mocks base method.

func (*MockRedis) HPExpireWithArgs added in v1.15.0 

func (m *MockRedis) HPExpireWithArgs(ctx context.Context, key string, expiration time.Duration, expirationArgs redis.HExpireArgs, fields ...string) *redis.IntSliceCmd

HPExpireWithArgs mocks base method.

func (*MockRedis) HPTTL added in v1.15.0 

func (m *MockRedis) HPTTL(ctx context.Context, key string, fields ...string) *redis.IntSliceCmd

HPTTL mocks base method.

func (*MockRedis) HPersist added in v1.15.0 

func (m *MockRedis) HPersist(ctx context.Context, key string, fields ...string) *redis.IntSliceCmd

HPersist mocks base method.

func (*MockRedis) HRandField added in v1.3.0 

func (m *MockRedis) HRandField(ctx context.Context, key string, count int) *redis.StringSliceCmd

HRandField mocks base method.

func (*MockRedis) HRandFieldWithValues added in v1.3.0 

func (m *MockRedis) HRandFieldWithValues(ctx context.Context, key string, count int) *redis.KeyValueSliceCmd

HRandFieldWithValues mocks base method.

func (*MockRedis) HScan added in v1.3.0 

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

HScan mocks base method.

func (*MockRedis) HScanNoValues added in v1.15.0 

func (m *MockRedis) HScanNoValues(ctx context.Context, key string, cursor uint64, match string, count int64) *redis.ScanCmd

HScanNoValues mocks base method.

func (*MockRedis) HSet added in v1.3.0 

func (m *MockRedis) HSet(ctx context.Context, key string, values ...any) *redis.IntCmd

HSet mocks base method.

func (*MockRedis) HSetNX added in v1.3.0 

func (m *MockRedis) HSetNX(ctx context.Context, key, field string, value any) *redis.BoolCmd

HSetNX mocks base method.

func (*MockRedis) HTTL added in v1.15.0 

func (m *MockRedis) HTTL(ctx context.Context, key string, fields ...string) *redis.IntSliceCmd

HTTL mocks base method.

func (*MockRedis) HVals added in v1.3.0 

func (m *MockRedis) HVals(ctx context.Context, key string) *redis.StringSliceCmd

HVals mocks base method.

func (*MockRedis) HealthCheck added in v1.3.0 

func (m *MockRedis) HealthCheck() datasource.Health

HealthCheck mocks base method.

func (*MockRedis) Incr added in v1.3.0 

func (m *MockRedis) Incr(ctx context.Context, key string) *redis.IntCmd

Incr mocks base method.

func (*MockRedis) IncrBy added in v1.3.0 

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

IncrBy mocks base method.

func (*MockRedis) IncrByFloat added in v1.3.0 

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

IncrByFloat mocks base method.

func (*MockRedis) Info added in v1.3.0 

func (m *MockRedis) Info(ctx context.Context, section ...string) *redis.StringCmd

Info mocks base method.

func (*MockRedis) JSONArrAppend added in v1.3.0 

func (m *MockRedis) JSONArrAppend(ctx context.Context, key, path string, values ...any) *redis.IntSliceCmd

JSONArrAppend mocks base method.

func (*MockRedis) JSONArrIndex added in v1.3.0 

func (m *MockRedis) JSONArrIndex(ctx context.Context, key, path string, value ...any) *redis.IntSliceCmd

JSONArrIndex mocks base method.

func (*MockRedis) JSONArrIndexWithArgs added in v1.3.0 

func (m *MockRedis) JSONArrIndexWithArgs(ctx context.Context, key, path string, options *redis.JSONArrIndexArgs, value ...any) *redis.IntSliceCmd

JSONArrIndexWithArgs mocks base method.

func (*MockRedis) JSONArrInsert added in v1.3.0 

func (m *MockRedis) JSONArrInsert(ctx context.Context, key, path string, index int64, values ...any) *redis.IntSliceCmd

JSONArrInsert mocks base method.

func (*MockRedis) JSONArrLen added in v1.3.0 

func (m *MockRedis) JSONArrLen(ctx context.Context, key, path string) *redis.IntSliceCmd

JSONArrLen mocks base method.

func (*MockRedis) JSONArrPop added in v1.3.0 

func (m *MockRedis) JSONArrPop(ctx context.Context, key, path string, index int) *redis.StringSliceCmd

JSONArrPop mocks base method.

func (*MockRedis) JSONArrTrim added in v1.3.0 

func (m *MockRedis) JSONArrTrim(ctx context.Context, key, path string) *redis.IntSliceCmd

JSONArrTrim mocks base method.

func (*MockRedis) JSONArrTrimWithArgs added in v1.3.0 

func (m *MockRedis) JSONArrTrimWithArgs(ctx context.Context, key, path string, options *redis.JSONArrTrimArgs) *redis.IntSliceCmd

JSONArrTrimWithArgs mocks base method.

func (*MockRedis) JSONClear added in v1.3.0 

func (m *MockRedis) JSONClear(ctx context.Context, key, path string) *redis.IntCmd

JSONClear mocks base method.

func (*MockRedis) JSONDebugMemory added in v1.3.0 

func (m *MockRedis) JSONDebugMemory(ctx context.Context, key, path string) *redis.IntCmd

JSONDebugMemory mocks base method.

func (*MockRedis) JSONDel added in v1.3.0 

func (m *MockRedis) JSONDel(ctx context.Context, key, path string) *redis.IntCmd

JSONDel mocks base method.

func (*MockRedis) JSONForget added in v1.3.0 

func (m *MockRedis) JSONForget(ctx context.Context, key, path string) *redis.IntCmd

JSONForget mocks base method.

func (*MockRedis) JSONGet added in v1.3.0 

func (m *MockRedis) JSONGet(ctx context.Context, key string, paths ...string) *redis.JSONCmd

JSONGet mocks base method.

func (*MockRedis) JSONGetWithArgs added in v1.3.0 

func (m *MockRedis) JSONGetWithArgs(ctx context.Context, key string, options *redis.JSONGetArgs, paths ...string) *redis.JSONCmd

JSONGetWithArgs mocks base method.

func (*MockRedis) JSONMGet added in v1.3.0 

func (m *MockRedis) JSONMGet(ctx context.Context, path string, keys ...string) *redis.JSONSliceCmd

JSONMGet mocks base method.

func (*MockRedis) JSONMSet added in v1.3.0 

func (m *MockRedis) JSONMSet(ctx context.Context, params ...any) *redis.StatusCmd

JSONMSet mocks base method.

func (*MockRedis) JSONMSetArgs added in v1.3.0 

func (m *MockRedis) JSONMSetArgs(ctx context.Context, docs []redis.JSONSetArgs) *redis.StatusCmd

JSONMSetArgs mocks base method.

func (*MockRedis) JSONMerge added in v1.3.0 

func (m *MockRedis) JSONMerge(ctx context.Context, key, path, value string) *redis.StatusCmd

JSONMerge mocks base method.

func (*MockRedis) JSONNumIncrBy added in v1.3.0 

func (m *MockRedis) JSONNumIncrBy(ctx context.Context, key, path string, value float64) *redis.JSONCmd

JSONNumIncrBy mocks base method.

func (*MockRedis) JSONObjKeys added in v1.3.0 

func (m *MockRedis) JSONObjKeys(ctx context.Context, key, path string) *redis.SliceCmd

JSONObjKeys mocks base method.

func (*MockRedis) JSONObjLen added in v1.3.0 

func (m *MockRedis) JSONObjLen(ctx context.Context, key, path string) *redis.IntPointerSliceCmd

JSONObjLen mocks base method.

func (*MockRedis) JSONSet added in v1.3.0 

func (m *MockRedis) JSONSet(ctx context.Context, key, path string, value any) *redis.StatusCmd

JSONSet mocks base method.

func (*MockRedis) JSONSetMode added in v1.3.0 

func (m *MockRedis) JSONSetMode(ctx context.Context, key, path string, value any, mode string) *redis.StatusCmd

JSONSetMode mocks base method.

func (*MockRedis) JSONStrAppend added in v1.3.0 

func (m *MockRedis) JSONStrAppend(ctx context.Context, key, path, value string) *redis.IntPointerSliceCmd

JSONStrAppend mocks base method.

func (*MockRedis) JSONStrLen added in v1.3.0 

func (m *MockRedis) JSONStrLen(ctx context.Context, key, path string) *redis.IntPointerSliceCmd

JSONStrLen mocks base method.

func (*MockRedis) JSONToggle added in v1.3.0 

func (m *MockRedis) JSONToggle(ctx context.Context, key, path string) *redis.IntPointerSliceCmd

JSONToggle mocks base method.

func (*MockRedis) JSONType added in v1.3.0 

func (m *MockRedis) JSONType(ctx context.Context, key, path string) *redis.JSONSliceCmd

JSONType mocks base method.

func (*MockRedis) Keys added in v1.3.0 

func (m *MockRedis) Keys(ctx context.Context, pattern string) *redis.StringSliceCmd

Keys mocks base method.

func (*MockRedis) LCS added in v1.3.0 

func (m *MockRedis) LCS(ctx context.Context, q *redis.LCSQuery) *redis.LCSCmd

LCS mocks base method.

func (*MockRedis) LIndex added in v1.3.0 

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

LIndex mocks base method.

func (*MockRedis) LInsert added in v1.3.0 

func (m *MockRedis) LInsert(ctx context.Context, key, op string, pivot, value any) *redis.IntCmd

LInsert mocks base method.

func (*MockRedis) LInsertAfter added in v1.3.0 

func (m *MockRedis) LInsertAfter(ctx context.Context, key string, pivot, value any) *redis.IntCmd

LInsertAfter mocks base method.

func (*MockRedis) LInsertBefore added in v1.3.0 

func (m *MockRedis) LInsertBefore(ctx context.Context, key string, pivot, value any) *redis.IntCmd

LInsertBefore mocks base method.

func (*MockRedis) LLen added in v1.3.0 

func (m *MockRedis) LLen(ctx context.Context, key string) *redis.IntCmd

LLen mocks base method.

func (*MockRedis) LMPop added in v1.3.0 

func (m *MockRedis) LMPop(ctx context.Context, direction string, count int64, keys ...string) *redis.KeyValuesCmd

LMPop mocks base method.

func (*MockRedis) LMove added in v1.3.0 

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

LMove mocks base method.

func (*MockRedis) LPop added in v1.3.0 

func (m *MockRedis) LPop(ctx context.Context, key string) *redis.StringCmd

LPop mocks base method.

func (*MockRedis) LPopCount added in v1.3.0 

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

LPopCount mocks base method.

func (*MockRedis) LPos added in v1.3.0 

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

LPos mocks base method.

func (*MockRedis) LPosCount added in v1.3.0 

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

LPosCount mocks base method.

func (*MockRedis) LPush added in v1.3.0 

func (m *MockRedis) LPush(ctx context.Context, key string, values ...any) *redis.IntCmd

LPush mocks base method.

func (*MockRedis) LPushX added in v1.3.0 

func (m *MockRedis) LPushX(ctx context.Context, key string, values ...any) *redis.IntCmd

LPushX mocks base method.

func (*MockRedis) LRange added in v1.3.0 

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

LRange mocks base method.

func (*MockRedis) LRem added in v1.3.0 

func (m *MockRedis) LRem(ctx context.Context, key string, count int64, value any) *redis.IntCmd

LRem mocks base method.

func (*MockRedis) LSet added in v1.3.0 

func (m *MockRedis) LSet(ctx context.Context, key string, index int64, value any) *redis.StatusCmd

LSet mocks base method.

func (*MockRedis) LTrim added in v1.3.0 

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

LTrim mocks base method.

func (*MockRedis) LastSave added in v1.3.0 

func (m *MockRedis) LastSave(ctx context.Context) *redis.IntCmd

LastSave mocks base method.

func (*MockRedis) MGet added in v1.3.0 

func (m *MockRedis) MGet(ctx context.Context, keys ...string) *redis.SliceCmd

MGet mocks base method.

func (*MockRedis) MSet added in v1.3.0 

func (m *MockRedis) MSet(ctx context.Context, values ...any) *redis.StatusCmd

MSet mocks base method.

func (*MockRedis) MSetNX added in v1.3.0 

func (m *MockRedis) MSetNX(ctx context.Context, values ...any) *redis.BoolCmd

MSetNX mocks base method.

func (*MockRedis) MemoryUsage added in v1.3.0 

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

MemoryUsage mocks base method.

func (*MockRedis) Migrate added in v1.3.0 

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

Migrate mocks base method.

func (*MockRedis) ModuleLoadex added in v1.3.0 

func (m *MockRedis) ModuleLoadex(ctx context.Context, conf *redis.ModuleLoadexConfig) *redis.StringCmd

ModuleLoadex mocks base method.

func (*MockRedis) Move added in v1.3.0 

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

Move mocks base method.

func (*MockRedis) ObjectEncoding added in v1.3.0 

func (m *MockRedis) ObjectEncoding(ctx context.Context, key string) *redis.StringCmd

ObjectEncoding mocks base method.

func (*MockRedis) ObjectFreq added in v1.3.0 

func (m *MockRedis) ObjectFreq(ctx context.Context, key string) *redis.IntCmd

ObjectFreq mocks base method.

func (*MockRedis) ObjectIdleTime added in v1.3.0 

func (m *MockRedis) ObjectIdleTime(ctx context.Context, key string) *redis.DurationCmd

ObjectIdleTime mocks base method.

func (*MockRedis) ObjectRefCount added in v1.3.0 

func (m *MockRedis) ObjectRefCount(ctx context.Context, key string) *redis.IntCmd

ObjectRefCount mocks base method.

func (*MockRedis) PExpire added in v1.3.0 

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

PExpire mocks base method.

func (*MockRedis) PExpireAt added in v1.3.0 

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

PExpireAt mocks base method.

func (*MockRedis) PExpireTime added in v1.3.0 

func (m *MockRedis) PExpireTime(ctx context.Context, key string) *redis.DurationCmd

PExpireTime mocks base method.

func (*MockRedis) PFAdd added in v1.3.0 

func (m *MockRedis) PFAdd(ctx context.Context, key string, els ...any) *redis.IntCmd

PFAdd mocks base method.

func (*MockRedis) PFCount added in v1.3.0 

func (m *MockRedis) PFCount(ctx context.Context, keys ...string) *redis.IntCmd

PFCount mocks base method.

func (*MockRedis) PFMerge added in v1.3.0 

func (m *MockRedis) PFMerge(ctx context.Context, dest string, keys ...string) *redis.StatusCmd

PFMerge mocks base method.

func (*MockRedis) PTTL added in v1.3.0 

func (m *MockRedis) PTTL(ctx context.Context, key string) *redis.DurationCmd

PTTL mocks base method.

func (*MockRedis) Persist added in v1.3.0 

func (m *MockRedis) Persist(ctx context.Context, key string) *redis.BoolCmd

Persist mocks base method.

func (*MockRedis) Ping added in v1.3.0 

func (m *MockRedis) Ping(ctx context.Context) *redis.StatusCmd

Ping mocks base method.

func (*MockRedis) Pipeline added in v1.3.0 

func (m *MockRedis) Pipeline() redis.Pipeliner

Pipeline mocks base method.

func (*MockRedis) Pipelined added in v1.3.0 

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

Pipelined mocks base method.

func (*MockRedis) PubSubChannels added in v1.3.0 

func (m *MockRedis) PubSubChannels(ctx context.Context, pattern string) *redis.StringSliceCmd

PubSubChannels mocks base method.

func (*MockRedis) PubSubNumPat added in v1.3.0 

func (m *MockRedis) PubSubNumPat(ctx context.Context) *redis.IntCmd

PubSubNumPat mocks base method.

func (*MockRedis) PubSubNumSub added in v1.3.0 

func (m *MockRedis) PubSubNumSub(ctx context.Context, channels ...string) *redis.MapStringIntCmd

PubSubNumSub mocks base method.

func (*MockRedis) PubSubShardChannels added in v1.3.0 

func (m *MockRedis) PubSubShardChannels(ctx context.Context, pattern string) *redis.StringSliceCmd

PubSubShardChannels mocks base method.

func (*MockRedis) PubSubShardNumSub added in v1.3.0 

func (m *MockRedis) PubSubShardNumSub(ctx context.Context, channels ...string) *redis.MapStringIntCmd

PubSubShardNumSub mocks base method.

func (*MockRedis) Publish added in v1.3.0 

func (m *MockRedis) Publish(ctx context.Context, channel string, message any) *redis.IntCmd

Publish mocks base method.

func (*MockRedis) Quit added in v1.3.0 

func (m *MockRedis) Quit(ctx context.Context) *redis.StatusCmd

Quit mocks base method.

func (*MockRedis) RPop added in v1.3.0 

func (m *MockRedis) RPop(ctx context.Context, key string) *redis.StringCmd

RPop mocks base method.

func (*MockRedis) RPopCount added in v1.3.0 

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

RPopCount mocks base method.

func (*MockRedis) RPopLPush added in v1.3.0 

func (m *MockRedis) RPopLPush(ctx context.Context, source, destination string) *redis.StringCmd

RPopLPush mocks base method.

func (*MockRedis) RPush added in v1.3.0 

func (m *MockRedis) RPush(ctx context.Context, key string, values ...any) *redis.IntCmd

RPush mocks base method.

func (*MockRedis) RPushX added in v1.3.0 

func (m *MockRedis) RPushX(ctx context.Context, key string, values ...any) *redis.IntCmd

RPushX mocks base method.

func (*MockRedis) RandomKey added in v1.3.0 

func (m *MockRedis) RandomKey(ctx context.Context) *redis.StringCmd

RandomKey mocks base method.

func (*MockRedis) ReadOnly added in v1.3.0 

func (m *MockRedis) ReadOnly(ctx context.Context) *redis.StatusCmd

ReadOnly mocks base method.

func (*MockRedis) ReadWrite added in v1.3.0 

func (m *MockRedis) ReadWrite(ctx context.Context) *redis.StatusCmd

ReadWrite mocks base method.

func (*MockRedis) Rename added in v1.3.0 

func (m *MockRedis) Rename(ctx context.Context, key, newkey string) *redis.StatusCmd

Rename mocks base method.

func (*MockRedis) RenameNX added in v1.3.0 

func (m *MockRedis) RenameNX(ctx context.Context, key, newkey string) *redis.BoolCmd

RenameNX mocks base method.

func (*MockRedis) Restore added in v1.3.0 

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

Restore mocks base method.

func (*MockRedis) RestoreReplace added in v1.3.0 

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

RestoreReplace mocks base method.

func (*MockRedis) SAdd added in v1.3.0 

func (m *MockRedis) SAdd(ctx context.Context, key string, members ...any) *redis.IntCmd

SAdd mocks base method.

func (*MockRedis) SCard added in v1.3.0 

func (m *MockRedis) SCard(ctx context.Context, key string) *redis.IntCmd

SCard mocks base method.

func (*MockRedis) SDiff added in v1.3.0 

func (m *MockRedis) SDiff(ctx context.Context, keys ...string) *redis.StringSliceCmd

SDiff mocks base method.

func (*MockRedis) SDiffStore added in v1.3.0 

func (m *MockRedis) SDiffStore(ctx context.Context, destination string, keys ...string) *redis.IntCmd

SDiffStore mocks base method.

func (*MockRedis) SInter added in v1.3.0 

func (m *MockRedis) SInter(ctx context.Context, keys ...string) *redis.StringSliceCmd

SInter mocks base method.

func (*MockRedis) SInterCard added in v1.3.0 

func (m *MockRedis) SInterCard(ctx context.Context, limit int64, keys ...string) *redis.IntCmd

SInterCard mocks base method.

func (*MockRedis) SInterStore added in v1.3.0 

func (m *MockRedis) SInterStore(ctx context.Context, destination string, keys ...string) *redis.IntCmd

SInterStore mocks base method.

func (*MockRedis) SIsMember added in v1.3.0 

func (m *MockRedis) SIsMember(ctx context.Context, key string, member any) *redis.BoolCmd

SIsMember mocks base method.

func (*MockRedis) SMIsMember added in v1.3.0 

func (m *MockRedis) SMIsMember(ctx context.Context, key string, members ...any) *redis.BoolSliceCmd

SMIsMember mocks base method.

func (*MockRedis) SMembers added in v1.3.0 

func (m *MockRedis) SMembers(ctx context.Context, key string) *redis.StringSliceCmd

SMembers mocks base method.

func (*MockRedis) SMembersMap added in v1.3.0 

func (m *MockRedis) SMembersMap(ctx context.Context, key string) *redis.StringStructMapCmd

SMembersMap mocks base method.

func (*MockRedis) SMove added in v1.3.0 

func (m *MockRedis) SMove(ctx context.Context, source, destination string, member any) *redis.BoolCmd

SMove mocks base method.

func (*MockRedis) SPop added in v1.3.0 

func (m *MockRedis) SPop(ctx context.Context, key string) *redis.StringCmd

SPop mocks base method.

func (*MockRedis) SPopN added in v1.3.0 

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

SPopN mocks base method.

func (*MockRedis) SPublish added in v1.3.0 

func (m *MockRedis) SPublish(ctx context.Context, channel string, message any) *redis.IntCmd

SPublish mocks base method.

func (*MockRedis) SRandMember added in v1.3.0 

func (m *MockRedis) SRandMember(ctx context.Context, key string) *redis.StringCmd

SRandMember mocks base method.

func (*MockRedis) SRandMemberN added in v1.3.0 

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

SRandMemberN mocks base method.

func (*MockRedis) SRem added in v1.3.0 

func (m *MockRedis) SRem(ctx context.Context, key string, members ...any) *redis.IntCmd

SRem mocks base method.

func (*MockRedis) SScan added in v1.3.0 

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

SScan mocks base method.

func (*MockRedis) SUnion added in v1.3.0 

func (m *MockRedis) SUnion(ctx context.Context, keys ...string) *redis.StringSliceCmd

SUnion mocks base method.

func (*MockRedis) SUnionStore added in v1.3.0 

func (m *MockRedis) SUnionStore(ctx context.Context, destination string, keys ...string) *redis.IntCmd

SUnionStore mocks base method.

func (*MockRedis) Save added in v1.3.0 

func (m *MockRedis) Save(ctx context.Context) *redis.StatusCmd

Save mocks base method.

func (*MockRedis) Scan added in v1.3.0 

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

Scan mocks base method.

func (*MockRedis) ScanType added in v1.3.0 

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

ScanType mocks base method.

func (*MockRedis) ScriptExists added in v1.3.0 

func (m *MockRedis) ScriptExists(ctx context.Context, hashes ...string) *redis.BoolSliceCmd

ScriptExists mocks base method.

func (*MockRedis) ScriptFlush added in v1.3.0 

func (m *MockRedis) ScriptFlush(ctx context.Context) *redis.StatusCmd

ScriptFlush mocks base method.

func (*MockRedis) ScriptKill added in v1.3.0 

func (m *MockRedis) ScriptKill(ctx context.Context) *redis.StatusCmd

ScriptKill mocks base method.

func (*MockRedis) ScriptLoad added in v1.3.0 

func (m *MockRedis) ScriptLoad(ctx context.Context, script string) *redis.StringCmd

ScriptLoad mocks base method.

func (*MockRedis) Set added in v1.3.0 

func (m *MockRedis) Set(ctx context.Context, key string, value any, expiration time.Duration) *redis.StatusCmd

Set mocks base method.

func (*MockRedis) SetArgs added in v1.3.0 

func (m *MockRedis) SetArgs(ctx context.Context, key string, value any, a redis.SetArgs) *redis.StatusCmd

SetArgs mocks base method.

func (*MockRedis) SetBit added in v1.3.0 

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

SetBit mocks base method.

func (*MockRedis) SetEx added in v1.3.0 

func (m *MockRedis) SetEx(ctx context.Context, key string, value any, expiration time.Duration) *redis.StatusCmd

SetEx mocks base method.

func (*MockRedis) SetNX added in v1.3.0 

func (m *MockRedis) SetNX(ctx context.Context, key string, value any, expiration time.Duration) *redis.BoolCmd

SetNX mocks base method.

func (*MockRedis) SetRange added in v1.3.0 

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

SetRange mocks base method.

func (*MockRedis) SetXX added in v1.3.0 

func (m *MockRedis) SetXX(ctx context.Context, key string, value any, expiration time.Duration) *redis.BoolCmd

SetXX mocks base method.

func (*MockRedis) Shutdown added in v1.3.0 

func (m *MockRedis) Shutdown(ctx context.Context) *redis.StatusCmd

Shutdown mocks base method.

func (*MockRedis) ShutdownNoSave added in v1.3.0 

func (m *MockRedis) ShutdownNoSave(ctx context.Context) *redis.StatusCmd

ShutdownNoSave mocks base method.

func (*MockRedis) ShutdownSave added in v1.3.0 

func (m *MockRedis) ShutdownSave(ctx context.Context) *redis.StatusCmd

ShutdownSave mocks base method.

func (*MockRedis) SlaveOf added in v1.3.0 

func (m *MockRedis) SlaveOf(ctx context.Context, host, port string) *redis.StatusCmd

SlaveOf mocks base method.

func (*MockRedis) SlowLogGet added in v1.3.0 

func (m *MockRedis) SlowLogGet(ctx context.Context, num int64) *redis.SlowLogCmd

SlowLogGet mocks base method.

func (*MockRedis) Sort added in v1.3.0 

func (m *MockRedis) Sort(ctx context.Context, key string, sort *redis.Sort) *redis.StringSliceCmd

Sort mocks base method.

func (*MockRedis) SortInterfaces added in v1.3.0 

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

SortInterfaces mocks base method.

func (*MockRedis) SortRO added in v1.3.0 

func (m *MockRedis) SortRO(ctx context.Context, key string, sort *redis.Sort) *redis.StringSliceCmd

SortRO mocks base method.

func (*MockRedis) SortStore added in v1.3.0 

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

SortStore mocks base method.

func (*MockRedis) StrLen added in v1.3.0 

func (m *MockRedis) StrLen(ctx context.Context, key string) *redis.IntCmd

StrLen mocks base method.

func (*MockRedis) TDigestAdd added in v1.3.0 

func (m *MockRedis) TDigestAdd(ctx context.Context, key string, elements ...float64) *redis.StatusCmd

TDigestAdd mocks base method.

func (*MockRedis) TDigestByRank added in v1.3.0 

func (m *MockRedis) TDigestByRank(ctx context.Context, key string, rank ...uint64) *redis.FloatSliceCmd

TDigestByRank mocks base method.

func (*MockRedis) TDigestByRevRank added in v1.3.0 

func (m *MockRedis) TDigestByRevRank(ctx context.Context, key string, rank ...uint64) *redis.FloatSliceCmd

TDigestByRevRank mocks base method.

func (*MockRedis) TDigestCDF added in v1.3.0 

func (m *MockRedis) TDigestCDF(ctx context.Context, key string, elements ...float64) *redis.FloatSliceCmd

TDigestCDF mocks base method.

func (*MockRedis) TDigestCreate added in v1.3.0 

func (m *MockRedis) TDigestCreate(ctx context.Context, key string) *redis.StatusCmd

TDigestCreate mocks base method.

func (*MockRedis) TDigestCreateWithCompression added in v1.3.0 

func (m *MockRedis) TDigestCreateWithCompression(ctx context.Context, key string, compression int64) *redis.StatusCmd

TDigestCreateWithCompression mocks base method.

func (*MockRedis) TDigestInfo added in v1.3.0 

func (m *MockRedis) TDigestInfo(ctx context.Context, key string) *redis.TDigestInfoCmd

TDigestInfo mocks base method.

func (*MockRedis) TDigestMax added in v1.3.0 

func (m *MockRedis) TDigestMax(ctx context.Context, key string) *redis.FloatCmd

TDigestMax mocks base method.

func (*MockRedis) TDigestMerge added in v1.3.0 

func (m *MockRedis) TDigestMerge(ctx context.Context, destKey string, options *redis.TDigestMergeOptions, sourceKeys ...string) *redis.StatusCmd

TDigestMerge mocks base method.

func (*MockRedis) TDigestMin added in v1.3.0 

func (m *MockRedis) TDigestMin(ctx context.Context, key string) *redis.FloatCmd

TDigestMin mocks base method.

func (*MockRedis) TDigestQuantile added in v1.3.0 

func (m *MockRedis) TDigestQuantile(ctx context.Context, key string, elements ...float64) *redis.FloatSliceCmd

TDigestQuantile mocks base method.

func (*MockRedis) TDigestRank added in v1.3.0 

func (m *MockRedis) TDigestRank(ctx context.Context, key string, values ...float64) *redis.IntSliceCmd

TDigestRank mocks base method.

func (*MockRedis) TDigestReset added in v1.3.0 

func (m *MockRedis) TDigestReset(ctx context.Context, key string) *redis.StatusCmd

TDigestReset mocks base method.

func (*MockRedis) TDigestRevRank added in v1.3.0 

func (m *MockRedis) TDigestRevRank(ctx context.Context, key string, values ...float64) *redis.IntSliceCmd

TDigestRevRank mocks base method.

func (*MockRedis) TDigestTrimmedMean added in v1.3.0 

func (m *MockRedis) TDigestTrimmedMean(ctx context.Context, key string, lowCutQuantile, highCutQuantile float64) *redis.FloatCmd

TDigestTrimmedMean mocks base method.

func (*MockRedis) TFCall added in v1.3.0 

func (m *MockRedis) TFCall(ctx context.Context, libName, funcName string, numKeys int) *redis.Cmd

TFCall mocks base method.

func (*MockRedis) TFCallASYNC added in v1.3.0 

func (m *MockRedis) TFCallASYNC(ctx context.Context, libName, funcName string, numKeys int) *redis.Cmd

TFCallASYNC mocks base method.

func (*MockRedis) TFCallASYNCArgs added in v1.3.0 

func (m *MockRedis) TFCallASYNCArgs(ctx context.Context, libName, funcName string, numKeys int, options *redis.TFCallOptions) *redis.Cmd

TFCallASYNCArgs mocks base method.

func (*MockRedis) TFCallArgs added in v1.3.0 

func (m *MockRedis) TFCallArgs(ctx context.Context, libName, funcName string, numKeys int, options *redis.TFCallOptions) *redis.Cmd

TFCallArgs mocks base method.

func (*MockRedis) TFunctionDelete added in v1.3.0 

func (m *MockRedis) TFunctionDelete(ctx context.Context, libName string) *redis.StatusCmd

TFunctionDelete mocks base method.

func (*MockRedis) TFunctionList added in v1.3.0 

func (m *MockRedis) TFunctionList(ctx context.Context) *redis.MapStringInterfaceSliceCmd

TFunctionList mocks base method.

func (*MockRedis) TFunctionListArgs added in v1.3.0 

func (m *MockRedis) TFunctionListArgs(ctx context.Context, options *redis.TFunctionListOptions) *redis.MapStringInterfaceSliceCmd

TFunctionListArgs mocks base method.

func (*MockRedis) TFunctionLoad added in v1.3.0 

func (m *MockRedis) TFunctionLoad(ctx context.Context, lib string) *redis.StatusCmd

TFunctionLoad mocks base method.

func (*MockRedis) TFunctionLoadArgs added in v1.3.0 

func (m *MockRedis) TFunctionLoadArgs(ctx context.Context, lib string, options *redis.TFunctionLoadOptions) *redis.StatusCmd

TFunctionLoadArgs mocks base method.

func (*MockRedis) TSAdd added in v1.3.0 

func (m *MockRedis) TSAdd(ctx context.Context, key string, timestamp any, value float64) *redis.IntCmd

TSAdd mocks base method.

func (*MockRedis) TSAddWithArgs added in v1.3.0 

func (m *MockRedis) TSAddWithArgs(ctx context.Context, key string, timestamp any, value float64, options *redis.TSOptions) *redis.IntCmd

TSAddWithArgs mocks base method.

func (*MockRedis) TSAlter added in v1.3.0 

func (m *MockRedis) TSAlter(ctx context.Context, key string, options *redis.TSAlterOptions) *redis.StatusCmd

TSAlter mocks base method.

func (*MockRedis) TSCreate added in v1.3.0 

func (m *MockRedis) TSCreate(ctx context.Context, key string) *redis.StatusCmd

TSCreate mocks base method.

func (*MockRedis) TSCreateRule added in v1.3.0 

func (m *MockRedis) TSCreateRule(ctx context.Context, sourceKey, destKey string, aggregator redis.Aggregator, bucketDuration int) *redis.StatusCmd

TSCreateRule mocks base method.

func (*MockRedis) TSCreateRuleWithArgs added in v1.3.0 

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

TSCreateRuleWithArgs mocks base method.

func (*MockRedis) TSCreateWithArgs added in v1.3.0 

func (m *MockRedis) TSCreateWithArgs(ctx context.Context, key string, options *redis.TSOptions) *redis.StatusCmd

TSCreateWithArgs mocks base method.

func (*MockRedis) TSDecrBy added in v1.3.0 

func (m *MockRedis) TSDecrBy(ctx context.Context, Key string, timestamp float64) *redis.IntCmd

TSDecrBy mocks base method.

func (*MockRedis) TSDecrByWithArgs added in v1.3.0 

func (m *MockRedis) TSDecrByWithArgs(ctx context.Context, key string, timestamp float64, options *redis.TSIncrDecrOptions) *redis.IntCmd

TSDecrByWithArgs mocks base method.

func (*MockRedis) TSDel added in v1.3.0 

func (m *MockRedis) TSDel(ctx context.Context, Key string, fromTimestamp, toTimestamp int) *redis.IntCmd

TSDel mocks base method.

func (*MockRedis) TSDeleteRule added in v1.3.0 

func (m *MockRedis) TSDeleteRule(ctx context.Context, sourceKey, destKey string) *redis.StatusCmd

TSDeleteRule mocks base method.

func (*MockRedis) TSGet added in v1.3.0 

func (m *MockRedis) TSGet(ctx context.Context, key string) *redis.TSTimestampValueCmd

TSGet mocks base method.

func (*MockRedis) TSGetWithArgs added in v1.3.0 

func (m *MockRedis) TSGetWithArgs(ctx context.Context, key string, options *redis.TSGetOptions) *redis.TSTimestampValueCmd

TSGetWithArgs mocks base method.

func (*MockRedis) TSIncrBy added in v1.3.0 

func (m *MockRedis) TSIncrBy(ctx context.Context, Key string, timestamp float64) *redis.IntCmd

TSIncrBy mocks base method.

func (*MockRedis) TSIncrByWithArgs added in v1.3.0 

func (m *MockRedis) TSIncrByWithArgs(ctx context.Context, key string, timestamp float64, options *redis.TSIncrDecrOptions) *redis.IntCmd

TSIncrByWithArgs mocks base method.

func (*MockRedis) TSInfo added in v1.3.0 

func (m *MockRedis) TSInfo(ctx context.Context, key string) *redis.MapStringInterfaceCmd

TSInfo mocks base method.

func (*MockRedis) TSInfoWithArgs added in v1.3.0 

func (m *MockRedis) TSInfoWithArgs(ctx context.Context, key string, options *redis.TSInfoOptions) *redis.MapStringInterfaceCmd

TSInfoWithArgs mocks base method.

func (*MockRedis) TSMAdd added in v1.3.0 

func (m *MockRedis) TSMAdd(ctx context.Context, ktvSlices [][]any) *redis.IntSliceCmd

TSMAdd mocks base method.

func (*MockRedis) TSMGet added in v1.3.0 

func (m *MockRedis) TSMGet(ctx context.Context, filters []string) *redis.MapStringSliceInterfaceCmd

TSMGet mocks base method.

func (*MockRedis) TSMGetWithArgs added in v1.3.0 

func (m *MockRedis) TSMGetWithArgs(ctx context.Context, filters []string, options *redis.TSMGetOptions) *redis.MapStringSliceInterfaceCmd

TSMGetWithArgs mocks base method.

func (*MockRedis) TSMRange added in v1.3.0 

func (m *MockRedis) TSMRange(ctx context.Context, fromTimestamp, toTimestamp int, filterExpr []string) *redis.MapStringSliceInterfaceCmd

TSMRange mocks base method.

func (*MockRedis) TSMRangeWithArgs added in v1.3.0 

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

TSMRangeWithArgs mocks base method.

func (*MockRedis) TSMRevRange added in v1.3.0 

func (m *MockRedis) TSMRevRange(ctx context.Context, fromTimestamp, toTimestamp int, filterExpr []string) *redis.MapStringSliceInterfaceCmd

TSMRevRange mocks base method.

func (*MockRedis) TSMRevRangeWithArgs added in v1.3.0 

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

TSMRevRangeWithArgs mocks base method.

func (*MockRedis) TSQueryIndex added in v1.3.0 

func (m *MockRedis) TSQueryIndex(ctx context.Context, filterExpr []string) *redis.StringSliceCmd

TSQueryIndex mocks base method.

func (*MockRedis) TSRange added in v1.3.0 

func (m *MockRedis) TSRange(ctx context.Context, key string, fromTimestamp, toTimestamp int) *redis.TSTimestampValueSliceCmd

TSRange mocks base method.

func (*MockRedis) TSRangeWithArgs added in v1.3.0 

func (m *MockRedis) TSRangeWithArgs(ctx context.Context, key string, fromTimestamp, toTimestamp int, options *redis.TSRangeOptions) *redis.TSTimestampValueSliceCmd

TSRangeWithArgs mocks base method.

func (*MockRedis) TSRevRange added in v1.3.0 

func (m *MockRedis) TSRevRange(ctx context.Context, key string, fromTimestamp, toTimestamp int) *redis.TSTimestampValueSliceCmd

TSRevRange mocks base method.

func (*MockRedis) TSRevRangeWithArgs added in v1.3.0 

func (m *MockRedis) TSRevRangeWithArgs(ctx context.Context, key string, fromTimestamp, toTimestamp int, options *redis.TSRevRangeOptions) *redis.TSTimestampValueSliceCmd

TSRevRangeWithArgs mocks base method.

func (*MockRedis) TTL added in v1.3.0 

func (m *MockRedis) TTL(ctx context.Context, key string) *redis.DurationCmd

TTL mocks base method.

func (*MockRedis) Time added in v1.3.0 

func (m *MockRedis) Time(ctx context.Context) *redis.TimeCmd

Time mocks base method.

func (*MockRedis) TopKAdd added in v1.3.0 

func (m *MockRedis) TopKAdd(ctx context.Context, key string, elements ...any) *redis.StringSliceCmd

TopKAdd mocks base method.

func (*MockRedis) TopKCount added in v1.3.0 

func (m *MockRedis) TopKCount(ctx context.Context, key string, elements ...any) *redis.IntSliceCmd

TopKCount mocks base method.

func (*MockRedis) TopKIncrBy added in v1.3.0 

func (m *MockRedis) TopKIncrBy(ctx context.Context, key string, elements ...any) *redis.StringSliceCmd

TopKIncrBy mocks base method.

func (*MockRedis) TopKInfo added in v1.3.0 

func (m *MockRedis) TopKInfo(ctx context.Context, key string) *redis.TopKInfoCmd

TopKInfo mocks base method.

func (*MockRedis) TopKList added in v1.3.0 

func (m *MockRedis) TopKList(ctx context.Context, key string) *redis.StringSliceCmd

TopKList mocks base method.

func (*MockRedis) TopKListWithCount added in v1.3.0 

func (m *MockRedis) TopKListWithCount(ctx context.Context, key string) *redis.MapStringIntCmd

TopKListWithCount mocks base method.

func (*MockRedis) TopKQuery added in v1.3.0 

func (m *MockRedis) TopKQuery(ctx context.Context, key string, elements ...any) *redis.BoolSliceCmd

TopKQuery mocks base method.

func (*MockRedis) TopKReserve added in v1.3.0 

func (m *MockRedis) TopKReserve(ctx context.Context, key string, k int64) *redis.StatusCmd

TopKReserve mocks base method.

func (*MockRedis) TopKReserveWithOptions added in v1.3.0 

func (m *MockRedis) TopKReserveWithOptions(ctx context.Context, key string, k, width, depth int64, decay float64) *redis.StatusCmd

TopKReserveWithOptions mocks base method.

func (*MockRedis) Touch added in v1.3.0 

func (m *MockRedis) Touch(ctx context.Context, keys ...string) *redis.IntCmd

Touch mocks base method.

func (*MockRedis) TxPipeline added in v1.3.0 

func (m *MockRedis) TxPipeline() redis.Pipeliner

TxPipeline mocks base method.

func (*MockRedis) TxPipelined added in v1.3.0 

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

TxPipelined mocks base method.

func (*MockRedis) Type added in v1.3.0 

func (m *MockRedis) Type(ctx context.Context, key string) *redis.StatusCmd

Type mocks base method. 

func (m *MockRedis) Unlink(ctx context.Context, keys ...string) *redis.IntCmd

Unlink mocks base method.

func (*MockRedis) XAck added in v1.3.0 

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

XAck mocks base method.

func (*MockRedis) XAdd added in v1.3.0 

func (m *MockRedis) XAdd(ctx context.Context, a *redis.XAddArgs) *redis.StringCmd

XAdd mocks base method.

func (*MockRedis) XAutoClaim added in v1.3.0 

func (m *MockRedis) XAutoClaim(ctx context.Context, a *redis.XAutoClaimArgs) *redis.XAutoClaimCmd

XAutoClaim mocks base method.

func (*MockRedis) XAutoClaimJustID added in v1.3.0 

func (m *MockRedis) XAutoClaimJustID(ctx context.Context, a *redis.XAutoClaimArgs) *redis.XAutoClaimJustIDCmd

XAutoClaimJustID mocks base method.

func (*MockRedis) XClaim added in v1.3.0 

func (m *MockRedis) XClaim(ctx context.Context, a *redis.XClaimArgs) *redis.XMessageSliceCmd

XClaim mocks base method.

func (*MockRedis) XClaimJustID added in v1.3.0 

func (m *MockRedis) XClaimJustID(ctx context.Context, a *redis.XClaimArgs) *redis.StringSliceCmd

XClaimJustID mocks base method.

func (*MockRedis) XDel added in v1.3.0 

func (m *MockRedis) XDel(ctx context.Context, stream string, ids ...string) *redis.IntCmd

XDel mocks base method.

func (*MockRedis) XGroupCreate added in v1.3.0 

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

XGroupCreate mocks base method.

func (*MockRedis) XGroupCreateConsumer added in v1.3.0 

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

XGroupCreateConsumer mocks base method.

func (*MockRedis) XGroupCreateMkStream added in v1.3.0 

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

XGroupCreateMkStream mocks base method.

func (*MockRedis) XGroupDelConsumer added in v1.3.0 

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

XGroupDelConsumer mocks base method.

func (*MockRedis) XGroupDestroy added in v1.3.0 

func (m *MockRedis) XGroupDestroy(ctx context.Context, stream, group string) *redis.IntCmd

XGroupDestroy mocks base method.

func (*MockRedis) XGroupSetID added in v1.3.0 

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

XGroupSetID mocks base method.

func (*MockRedis) XInfoConsumers added in v1.3.0 

func (m *MockRedis) XInfoConsumers(ctx context.Context, key, group string) *redis.XInfoConsumersCmd

XInfoConsumers mocks base method.

func (*MockRedis) XInfoGroups added in v1.3.0 

func (m *MockRedis) XInfoGroups(ctx context.Context, key string) *redis.XInfoGroupsCmd

XInfoGroups mocks base method.

func (*MockRedis) XInfoStream added in v1.3.0 

func (m *MockRedis) XInfoStream(ctx context.Context, key string) *redis.XInfoStreamCmd

XInfoStream mocks base method.

func (*MockRedis) XInfoStreamFull added in v1.3.0 

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

XInfoStreamFull mocks base method.

func (*MockRedis) XLen added in v1.3.0 

func (m *MockRedis) XLen(ctx context.Context, stream string) *redis.IntCmd

XLen mocks base method.

func (*MockRedis) XPending added in v1.3.0 

func (m *MockRedis) XPending(ctx context.Context, stream, group string) *redis.XPendingCmd

XPending mocks base method.

func (*MockRedis) XPendingExt added in v1.3.0 

func (m *MockRedis) XPendingExt(ctx context.Context, a *redis.XPendingExtArgs) *redis.XPendingExtCmd

XPendingExt mocks base method.

func (*MockRedis) XRange added in v1.3.0 

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

XRange mocks base method.

func (*MockRedis) XRangeN added in v1.3.0 

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

XRangeN mocks base method.

func (*MockRedis) XRead added in v1.3.0 

func (m *MockRedis) XRead(ctx context.Context, a *redis.XReadArgs) *redis.XStreamSliceCmd

XRead mocks base method.

func (*MockRedis) XReadGroup added in v1.3.0 

func (m *MockRedis) XReadGroup(ctx context.Context, a *redis.XReadGroupArgs) *redis.XStreamSliceCmd

XReadGroup mocks base method.

func (*MockRedis) XReadStreams added in v1.3.0 

func (m *MockRedis) XReadStreams(ctx context.Context, streams ...string) *redis.XStreamSliceCmd

XReadStreams mocks base method.

func (*MockRedis) XRevRange added in v1.3.0 

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

XRevRange mocks base method.

func (*MockRedis) XRevRangeN added in v1.3.0 

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

XRevRangeN mocks base method.

func (*MockRedis) XTrimMaxLen added in v1.3.0 

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

XTrimMaxLen mocks base method.

func (*MockRedis) XTrimMaxLenApprox added in v1.3.0 

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

XTrimMaxLenApprox mocks base method.

func (*MockRedis) XTrimMinID added in v1.3.0 

func (m *MockRedis) XTrimMinID(ctx context.Context, key, minID string) *redis.IntCmd

XTrimMinID mocks base method.

func (*MockRedis) XTrimMinIDApprox added in v1.3.0 

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

XTrimMinIDApprox mocks base method.

func (*MockRedis) ZAdd added in v1.3.0 

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

ZAdd mocks base method.

func (*MockRedis) ZAddArgs added in v1.3.0 

func (m *MockRedis) ZAddArgs(ctx context.Context, key string, args redis.ZAddArgs) *redis.IntCmd

ZAddArgs mocks base method.

func (*MockRedis) ZAddArgsIncr added in v1.3.0 

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

ZAddArgsIncr mocks base method.

func (*MockRedis) ZAddGT added in v1.3.0 

func (m *MockRedis) ZAddGT(ctx context.Context, key string, members ...redis.Z) *redis.IntCmd

ZAddGT mocks base method.

func (*MockRedis) ZAddLT added in v1.3.0 

func (m *MockRedis) ZAddLT(ctx context.Context, key string, members ...redis.Z) *redis.IntCmd

ZAddLT mocks base method.

func (*MockRedis) ZAddNX added in v1.3.0 

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

ZAddNX mocks base method.

func (*MockRedis) ZAddXX added in v1.3.0 

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

ZAddXX mocks base method.

func (*MockRedis) ZCard added in v1.3.0 

func (m *MockRedis) ZCard(ctx context.Context, key string) *redis.IntCmd

ZCard mocks base method.

func (*MockRedis) ZCount added in v1.3.0 

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

ZCount mocks base method.

func (*MockRedis) ZDiff added in v1.3.0 

func (m *MockRedis) ZDiff(ctx context.Context, keys ...string) *redis.StringSliceCmd

ZDiff mocks base method.

func (*MockRedis) ZDiffStore added in v1.3.0 

func (m *MockRedis) ZDiffStore(ctx context.Context, destination string, keys ...string) *redis.IntCmd

ZDiffStore mocks base method.

func (*MockRedis) ZDiffWithScores added in v1.3.0 

func (m *MockRedis) ZDiffWithScores(ctx context.Context, keys ...string) *redis.ZSliceCmd

ZDiffWithScores mocks base method.

func (*MockRedis) ZIncrBy added in v1.3.0 

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

ZIncrBy mocks base method.

func (*MockRedis) ZInter added in v1.3.0 

func (m *MockRedis) ZInter(ctx context.Context, store *redis.ZStore) *redis.StringSliceCmd

ZInter mocks base method.

func (*MockRedis) ZInterCard added in v1.3.0 

func (m *MockRedis) ZInterCard(ctx context.Context, limit int64, keys ...string) *redis.IntCmd

ZInterCard mocks base method.

func (*MockRedis) ZInterStore added in v1.3.0 

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

ZInterStore mocks base method.

func (*MockRedis) ZInterWithScores added in v1.3.0 

func (m *MockRedis) ZInterWithScores(ctx context.Context, store *redis.ZStore) *redis.ZSliceCmd

ZInterWithScores mocks base method.

func (*MockRedis) ZLexCount added in v1.3.0 

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

ZLexCount mocks base method.

func (*MockRedis) ZMPop added in v1.3.0 

func (m *MockRedis) ZMPop(ctx context.Context, order string, count int64, keys ...string) *redis.ZSliceWithKeyCmd

ZMPop mocks base method.

func (*MockRedis) ZMScore added in v1.3.0 

func (m *MockRedis) ZMScore(ctx context.Context, key string, members ...string) *redis.FloatSliceCmd

ZMScore mocks base method.

func (*MockRedis) ZPopMax added in v1.3.0 

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

ZPopMax mocks base method.

func (*MockRedis) ZPopMin added in v1.3.0 

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

ZPopMin mocks base method.

func (*MockRedis) ZRandMember added in v1.3.0 

func (m *MockRedis) ZRandMember(ctx context.Context, key string, count int) *redis.StringSliceCmd

ZRandMember mocks base method.

func (*MockRedis) ZRandMemberWithScores added in v1.3.0 

func (m *MockRedis) ZRandMemberWithScores(ctx context.Context, key string, count int) *redis.ZSliceCmd

ZRandMemberWithScores mocks base method.

func (*MockRedis) ZRange added in v1.3.0 

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

ZRange mocks base method.

func (*MockRedis) ZRangeArgs added in v1.3.0 

func (m *MockRedis) ZRangeArgs(ctx context.Context, z redis.ZRangeArgs) *redis.StringSliceCmd

ZRangeArgs mocks base method.

func (*MockRedis) ZRangeArgsWithScores added in v1.3.0 

func (m *MockRedis) ZRangeArgsWithScores(ctx context.Context, z redis.ZRangeArgs) *redis.ZSliceCmd

ZRangeArgsWithScores mocks base method.

func (*MockRedis) ZRangeByLex added in v1.3.0 

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

ZRangeByLex mocks base method.

func (*MockRedis) ZRangeByScore added in v1.3.0 

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

ZRangeByScore mocks base method.

func (*MockRedis) ZRangeByScoreWithScores added in v1.3.0 

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

ZRangeByScoreWithScores mocks base method.

func (*MockRedis) ZRangeStore added in v1.3.0 

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

ZRangeStore mocks base method.

func (*MockRedis) ZRangeWithScores added in v1.3.0 

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

ZRangeWithScores mocks base method.

func (*MockRedis) ZRank added in v1.3.0 

func (m *MockRedis) ZRank(ctx context.Context, key, member string) *redis.IntCmd

ZRank mocks base method.

func (*MockRedis) ZRankWithScore added in v1.3.0 

func (m *MockRedis) ZRankWithScore(ctx context.Context, key, member string) *redis.RankWithScoreCmd

ZRankWithScore mocks base method.

func (*MockRedis) ZRem added in v1.3.0 

func (m *MockRedis) ZRem(ctx context.Context, key string, members ...any) *redis.IntCmd

ZRem mocks base method.

func (*MockRedis) ZRemRangeByLex added in v1.3.0 

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

ZRemRangeByLex mocks base method.

func (*MockRedis) ZRemRangeByRank added in v1.3.0 

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

ZRemRangeByRank mocks base method.

func (*MockRedis) ZRemRangeByScore added in v1.3.0 

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

ZRemRangeByScore mocks base method.

func (*MockRedis) ZRevRange added in v1.3.0 

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

ZRevRange mocks base method.

func (*MockRedis) ZRevRangeByLex added in v1.3.0 

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

ZRevRangeByLex mocks base method.

func (*MockRedis) ZRevRangeByScore added in v1.3.0 

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

ZRevRangeByScore mocks base method.

func (*MockRedis) ZRevRangeByScoreWithScores added in v1.3.0 

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

ZRevRangeByScoreWithScores mocks base method.

func (*MockRedis) ZRevRangeWithScores added in v1.3.0 

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

ZRevRangeWithScores mocks base method.

func (*MockRedis) ZRevRank added in v1.3.0 

func (m *MockRedis) ZRevRank(ctx context.Context, key, member string) *redis.IntCmd

ZRevRank mocks base method.

func (*MockRedis) ZRevRankWithScore added in v1.3.0 

func (m *MockRedis) ZRevRankWithScore(ctx context.Context, key, member string) *redis.RankWithScoreCmd

ZRevRankWithScore mocks base method.

func (*MockRedis) ZScan added in v1.3.0 

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

ZScan mocks base method.

func (*MockRedis) ZScore added in v1.3.0 

func (m *MockRedis) ZScore(ctx context.Context, key, member string) *redis.FloatCmd

ZScore mocks base method.

func (*MockRedis) ZUnion added in v1.3.0 

func (m *MockRedis) ZUnion(ctx context.Context, store redis.ZStore) *redis.StringSliceCmd

ZUnion mocks base method.

func (*MockRedis) ZUnionStore added in v1.3.0 

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

ZUnionStore mocks base method.

func (*MockRedis) ZUnionWithScores added in v1.3.0 

func (m *MockRedis) ZUnionWithScores(ctx context.Context, store redis.ZStore) *redis.ZSliceCmd

ZUnionWithScores mocks base method.

type MockRedisMockRecorder added in v1.3.0 

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

MockRedisMockRecorder is the mock recorder for MockRedis.

func (*MockRedisMockRecorder) ACLDryRun added in v1.3.0 

func (mr *MockRedisMockRecorder) ACLDryRun(ctx, username any, command ...any) *gomock.Call

ACLDryRun indicates an expected call of ACLDryRun.

func (*MockRedisMockRecorder) ACLLog added in v1.3.0 

func (mr *MockRedisMockRecorder) ACLLog(ctx, count any) *gomock.Call

ACLLog indicates an expected call of ACLLog.

func (*MockRedisMockRecorder) ACLLogReset added in v1.3.0 

func (mr *MockRedisMockRecorder) ACLLogReset(ctx any) *gomock.Call

ACLLogReset indicates an expected call of ACLLogReset.

func (*MockRedisMockRecorder) Append added in v1.3.0 

func (mr *MockRedisMockRecorder) Append(ctx, key, value any) *gomock.Call

Append indicates an expected call of Append.

func (*MockRedisMockRecorder) BFAdd added in v1.3.0 

func (mr *MockRedisMockRecorder) BFAdd(ctx, key, element any) *gomock.Call

BFAdd indicates an expected call of BFAdd.

func (*MockRedisMockRecorder) BFCard added in v1.3.0 

func (mr *MockRedisMockRecorder) BFCard(ctx, key any) *gomock.Call

BFCard indicates an expected call of BFCard.

func (*MockRedisMockRecorder) BFExists added in v1.3.0 

func (mr *MockRedisMockRecorder) BFExists(ctx, key, element any) *gomock.Call

BFExists indicates an expected call of BFExists.

func (*MockRedisMockRecorder) BFInfo added in v1.3.0 

func (mr *MockRedisMockRecorder) BFInfo(ctx, key any) *gomock.Call

BFInfo indicates an expected call of BFInfo.

func (*MockRedisMockRecorder) BFInfoArg added in v1.3.0 

func (mr *MockRedisMockRecorder) BFInfoArg(ctx, key, option any) *gomock.Call

BFInfoArg indicates an expected call of BFInfoArg.

func (*MockRedisMockRecorder) BFInfoCapacity added in v1.3.0 

func (mr *MockRedisMockRecorder) BFInfoCapacity(ctx, key any) *gomock.Call

BFInfoCapacity indicates an expected call of BFInfoCapacity.

func (*MockRedisMockRecorder) BFInfoExpansion added in v1.3.0 

func (mr *MockRedisMockRecorder) BFInfoExpansion(ctx, key any) *gomock.Call

BFInfoExpansion indicates an expected call of BFInfoExpansion.

func (*MockRedisMockRecorder) BFInfoFilters added in v1.3.0 

func (mr *MockRedisMockRecorder) BFInfoFilters(ctx, key any) *gomock.Call

BFInfoFilters indicates an expected call of BFInfoFilters.

func (*MockRedisMockRecorder) BFInfoItems added in v1.3.0 

func (mr *MockRedisMockRecorder) BFInfoItems(ctx, key any) *gomock.Call

BFInfoItems indicates an expected call of BFInfoItems.

func (*MockRedisMockRecorder) BFInfoSize added in v1.3.0 

func (mr *MockRedisMockRecorder) BFInfoSize(ctx, key any) *gomock.Call

BFInfoSize indicates an expected call of BFInfoSize.

func (*MockRedisMockRecorder) BFInsert added in v1.3.0 

func (mr *MockRedisMockRecorder) BFInsert(ctx, key, options any, elements ...any) *gomock.Call

BFInsert indicates an expected call of BFInsert.

func (*MockRedisMockRecorder) BFLoadChunk added in v1.3.0 

func (mr *MockRedisMockRecorder) BFLoadChunk(ctx, key, iterator, data any) *gomock.Call

BFLoadChunk indicates an expected call of BFLoadChunk.

func (*MockRedisMockRecorder) BFMAdd added in v1.3.0 

func (mr *MockRedisMockRecorder) BFMAdd(ctx, key any, elements ...any) *gomock.Call

BFMAdd indicates an expected call of BFMAdd.

func (*MockRedisMockRecorder) BFMExists added in v1.3.0 

func (mr *MockRedisMockRecorder) BFMExists(ctx, key any, elements ...any) *gomock.Call

BFMExists indicates an expected call of BFMExists.

func (*MockRedisMockRecorder) BFReserve added in v1.3.0 

func (mr *MockRedisMockRecorder) BFReserve(ctx, key, errorRate, capacity any) *gomock.Call

BFReserve indicates an expected call of BFReserve.

func (*MockRedisMockRecorder) BFReserveExpansion added in v1.3.0 

func (mr *MockRedisMockRecorder) BFReserveExpansion(ctx, key, errorRate, capacity, expansion any) *gomock.Call

BFReserveExpansion indicates an expected call of BFReserveExpansion.

func (*MockRedisMockRecorder) BFReserveNonScaling added in v1.3.0 

func (mr *MockRedisMockRecorder) BFReserveNonScaling(ctx, key, errorRate, capacity any) *gomock.Call

BFReserveNonScaling indicates an expected call of BFReserveNonScaling.

func (*MockRedisMockRecorder) BFReserveWithArgs added in v1.3.0 

func (mr *MockRedisMockRecorder) BFReserveWithArgs(ctx, key, options any) *gomock.Call

BFReserveWithArgs indicates an expected call of BFReserveWithArgs.

func (*MockRedisMockRecorder) BFScanDump added in v1.3.0 

func (mr *MockRedisMockRecorder) BFScanDump(ctx, key, iterator any) *gomock.Call

BFScanDump indicates an expected call of BFScanDump.

func (*MockRedisMockRecorder) BLMPop added in v1.3.0 

func (mr *MockRedisMockRecorder) BLMPop(ctx, timeout, direction, count any, keys ...any) *gomock.Call

BLMPop indicates an expected call of BLMPop.

func (*MockRedisMockRecorder) BLMove added in v1.3.0 

func (mr *MockRedisMockRecorder) BLMove(ctx, source, destination, srcpos, destpos, timeout any) *gomock.Call

BLMove indicates an expected call of BLMove.

func (*MockRedisMockRecorder) BLPop added in v1.3.0 

func (mr *MockRedisMockRecorder) BLPop(ctx, timeout any, keys ...any) *gomock.Call

BLPop indicates an expected call of BLPop.

func (*MockRedisMockRecorder) BRPop added in v1.3.0 

func (mr *MockRedisMockRecorder) BRPop(ctx, timeout any, keys ...any) *gomock.Call

BRPop indicates an expected call of BRPop.

func (*MockRedisMockRecorder) BRPopLPush added in v1.3.0 

func (mr *MockRedisMockRecorder) BRPopLPush(ctx, source, destination, timeout any) *gomock.Call

BRPopLPush indicates an expected call of BRPopLPush.

func (*MockRedisMockRecorder) BZMPop added in v1.3.0 

func (mr *MockRedisMockRecorder) BZMPop(ctx, timeout, order, count any, keys ...any) *gomock.Call

BZMPop indicates an expected call of BZMPop.

func (*MockRedisMockRecorder) BZPopMax added in v1.3.0 

func (mr *MockRedisMockRecorder) BZPopMax(ctx, timeout any, keys ...any) *gomock.Call

BZPopMax indicates an expected call of BZPopMax.

func (*MockRedisMockRecorder) BZPopMin added in v1.3.0 

func (mr *MockRedisMockRecorder) BZPopMin(ctx, timeout any, keys ...any) *gomock.Call

BZPopMin indicates an expected call of BZPopMin.

func (*MockRedisMockRecorder) BgRewriteAOF added in v1.3.0 

func (mr *MockRedisMockRecorder) BgRewriteAOF(ctx any) *gomock.Call

BgRewriteAOF indicates an expected call of BgRewriteAOF.

func (*MockRedisMockRecorder) BgSave added in v1.3.0 

func (mr *MockRedisMockRecorder) BgSave(ctx any) *gomock.Call

BgSave indicates an expected call of BgSave.

func (*MockRedisMockRecorder) BitCount added in v1.3.0 

func (mr *MockRedisMockRecorder) BitCount(ctx, key, bitCount any) *gomock.Call

BitCount indicates an expected call of BitCount.

func (*MockRedisMockRecorder) BitField added in v1.3.0 

func (mr *MockRedisMockRecorder) BitField(ctx, key any, values ...any) *gomock.Call

BitField indicates an expected call of BitField.

func (*MockRedisMockRecorder) BitFieldRO added in v1.15.0 

func (mr *MockRedisMockRecorder) BitFieldRO(ctx, key any, values ...any) *gomock.Call

BitFieldRO indicates an expected call of BitFieldRO.

func (*MockRedisMockRecorder) BitOpAnd added in v1.3.0 

func (mr *MockRedisMockRecorder) BitOpAnd(ctx, destKey any, keys ...any) *gomock.Call

BitOpAnd indicates an expected call of BitOpAnd.

func (*MockRedisMockRecorder) BitOpNot added in v1.3.0 

func (mr *MockRedisMockRecorder) BitOpNot(ctx, destKey, key any) *gomock.Call

BitOpNot indicates an expected call of BitOpNot.

func (*MockRedisMockRecorder) BitOpOr added in v1.3.0 

func (mr *MockRedisMockRecorder) BitOpOr(ctx, destKey any, keys ...any) *gomock.Call

BitOpOr indicates an expected call of BitOpOr.

func (*MockRedisMockRecorder) BitOpXor added in v1.3.0 

func (mr *MockRedisMockRecorder) BitOpXor(ctx, destKey any, keys ...any) *gomock.Call

BitOpXor indicates an expected call of BitOpXor.

func (*MockRedisMockRecorder) BitPos added in v1.3.0 

func (mr *MockRedisMockRecorder) BitPos(ctx, key, bit any, pos ...any) *gomock.Call

BitPos indicates an expected call of BitPos.

func (*MockRedisMockRecorder) BitPosSpan added in v1.3.0 

func (mr *MockRedisMockRecorder) BitPosSpan(ctx, key, bit, start, end, span any) *gomock.Call

BitPosSpan indicates an expected call of BitPosSpan.

func (*MockRedisMockRecorder) CFAdd added in v1.3.0 

func (mr *MockRedisMockRecorder) CFAdd(ctx, key, element any) *gomock.Call

CFAdd indicates an expected call of CFAdd.

func (*MockRedisMockRecorder) CFAddNX added in v1.3.0 

func (mr *MockRedisMockRecorder) CFAddNX(ctx, key, element any) *gomock.Call

CFAddNX indicates an expected call of CFAddNX.

func (*MockRedisMockRecorder) CFCount added in v1.3.0 

func (mr *MockRedisMockRecorder) CFCount(ctx, key, element any) *gomock.Call

CFCount indicates an expected call of CFCount.

func (*MockRedisMockRecorder) CFDel added in v1.3.0 

func (mr *MockRedisMockRecorder) CFDel(ctx, key, element any) *gomock.Call

CFDel indicates an expected call of CFDel.

func (*MockRedisMockRecorder) CFExists added in v1.3.0 

func (mr *MockRedisMockRecorder) CFExists(ctx, key, element any) *gomock.Call

CFExists indicates an expected call of CFExists.

func (*MockRedisMockRecorder) CFInfo added in v1.3.0 

func (mr *MockRedisMockRecorder) CFInfo(ctx, key any) *gomock.Call

CFInfo indicates an expected call of CFInfo.

func (*MockRedisMockRecorder) CFInsert added in v1.3.0 

func (mr *MockRedisMockRecorder) CFInsert(ctx, key, options any, elements ...any) *gomock.Call

CFInsert indicates an expected call of CFInsert.

func (*MockRedisMockRecorder) CFInsertNX added in v1.3.0 

func (mr *MockRedisMockRecorder) CFInsertNX(ctx, key, options any, elements ...any) *gomock.Call

CFInsertNX indicates an expected call of CFInsertNX.

func (*MockRedisMockRecorder) CFLoadChunk added in v1.3.0 

func (mr *MockRedisMockRecorder) CFLoadChunk(ctx, key, iterator, data any) *gomock.Call

CFLoadChunk indicates an expected call of CFLoadChunk.

func (*MockRedisMockRecorder) CFMExists added in v1.3.0 

func (mr *MockRedisMockRecorder) CFMExists(ctx, key any, elements ...any) *gomock.Call

CFMExists indicates an expected call of CFMExists.

func (*MockRedisMockRecorder) CFReserve added in v1.3.0 

func (mr *MockRedisMockRecorder) CFReserve(ctx, key, capacity any) *gomock.Call

CFReserve indicates an expected call of CFReserve.

func (*MockRedisMockRecorder) CFReserveBucketSize added in v1.3.0 

func (mr *MockRedisMockRecorder) CFReserveBucketSize(ctx, key, capacity, bucketsize any) *gomock.Call

CFReserveBucketSize indicates an expected call of CFReserveBucketSize.

func (*MockRedisMockRecorder) CFReserveExpansion added in v1.3.0 

func (mr *MockRedisMockRecorder) CFReserveExpansion(ctx, key, capacity, expansion any) *gomock.Call

CFReserveExpansion indicates an expected call of CFReserveExpansion.

func (*MockRedisMockRecorder) CFReserveMaxIterations added in v1.3.0 

func (mr *MockRedisMockRecorder) CFReserveMaxIterations(ctx, key, capacity, maxiterations any) *gomock.Call

CFReserveMaxIterations indicates an expected call of CFReserveMaxIterations.

func (*MockRedisMockRecorder) CFReserveWithArgs added in v1.3.0 

func (mr *MockRedisMockRecorder) CFReserveWithArgs(ctx, key, options any) *gomock.Call

CFReserveWithArgs indicates an expected call of CFReserveWithArgs.

func (*MockRedisMockRecorder) CFScanDump added in v1.3.0 

func (mr *MockRedisMockRecorder) CFScanDump(ctx, key, iterator any) *gomock.Call

CFScanDump indicates an expected call of CFScanDump.

func (*MockRedisMockRecorder) CMSIncrBy added in v1.3.0 

func (mr *MockRedisMockRecorder) CMSIncrBy(ctx, key any, elements ...any) *gomock.Call

CMSIncrBy indicates an expected call of CMSIncrBy.

func (*MockRedisMockRecorder) CMSInfo added in v1.3.0 

func (mr *MockRedisMockRecorder) CMSInfo(ctx, key any) *gomock.Call

CMSInfo indicates an expected call of CMSInfo.

func (*MockRedisMockRecorder) CMSInitByDim added in v1.3.0 

func (mr *MockRedisMockRecorder) CMSInitByDim(ctx, key, width, height any) *gomock.Call

CMSInitByDim indicates an expected call of CMSInitByDim.

func (*MockRedisMockRecorder) CMSInitByProb added in v1.3.0 

func (mr *MockRedisMockRecorder) CMSInitByProb(ctx, key, errorRate, probability any) *gomock.Call

CMSInitByProb indicates an expected call of CMSInitByProb.

func (*MockRedisMockRecorder) CMSMerge added in v1.3.0 

func (mr *MockRedisMockRecorder) CMSMerge(ctx, destKey any, sourceKeys ...any) *gomock.Call

CMSMerge indicates an expected call of CMSMerge.

func (*MockRedisMockRecorder) CMSMergeWithWeight added in v1.3.0 

func (mr *MockRedisMockRecorder) CMSMergeWithWeight(ctx, destKey, sourceKeys any) *gomock.Call

CMSMergeWithWeight indicates an expected call of CMSMergeWithWeight.

func (*MockRedisMockRecorder) CMSQuery added in v1.3.0 

func (mr *MockRedisMockRecorder) CMSQuery(ctx, key any, elements ...any) *gomock.Call

CMSQuery indicates an expected call of CMSQuery.

func (*MockRedisMockRecorder) ClientGetName added in v1.3.0 

func (mr *MockRedisMockRecorder) ClientGetName(ctx any) *gomock.Call

ClientGetName indicates an expected call of ClientGetName.

func (*MockRedisMockRecorder) ClientID added in v1.3.0 

func (mr *MockRedisMockRecorder) ClientID(ctx any) *gomock.Call

ClientID indicates an expected call of ClientID.

func (*MockRedisMockRecorder) ClientInfo added in v1.3.0 

func (mr *MockRedisMockRecorder) ClientInfo(ctx any) *gomock.Call

ClientInfo indicates an expected call of ClientInfo.

func (*MockRedisMockRecorder) ClientKill added in v1.3.0 

func (mr *MockRedisMockRecorder) ClientKill(ctx, ipPort any) *gomock.Call

ClientKill indicates an expected call of ClientKill.

func (*MockRedisMockRecorder) ClientKillByFilter added in v1.3.0 

func (mr *MockRedisMockRecorder) ClientKillByFilter(ctx any, keys ...any) *gomock.Call

ClientKillByFilter indicates an expected call of ClientKillByFilter.

func (*MockRedisMockRecorder) ClientList added in v1.3.0 

func (mr *MockRedisMockRecorder) ClientList(ctx any) *gomock.Call

ClientList indicates an expected call of ClientList.

func (*MockRedisMockRecorder) ClientPause added in v1.3.0 

func (mr *MockRedisMockRecorder) ClientPause(ctx, dur any) *gomock.Call

ClientPause indicates an expected call of ClientPause.

func (*MockRedisMockRecorder) ClientUnblock added in v1.3.0 

func (mr *MockRedisMockRecorder) ClientUnblock(ctx, id any) *gomock.Call

ClientUnblock indicates an expected call of ClientUnblock.

func (*MockRedisMockRecorder) ClientUnblockWithError added in v1.3.0 

func (mr *MockRedisMockRecorder) ClientUnblockWithError(ctx, id any) *gomock.Call

ClientUnblockWithError indicates an expected call of ClientUnblockWithError.

func (*MockRedisMockRecorder) ClientUnpause added in v1.3.0 

func (mr *MockRedisMockRecorder) ClientUnpause(ctx any) *gomock.Call

ClientUnpause indicates an expected call of ClientUnpause.

func (*MockRedisMockRecorder) Close added in v1.16.0 

func (mr *MockRedisMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockRedisMockRecorder) ClusterAddSlots added in v1.3.0 

func (mr *MockRedisMockRecorder) ClusterAddSlots(ctx any, slots ...any) *gomock.Call

ClusterAddSlots indicates an expected call of ClusterAddSlots.

func (*MockRedisMockRecorder) ClusterAddSlotsRange added in v1.3.0 

func (mr *MockRedisMockRecorder) ClusterAddSlotsRange(ctx, min, max any) *gomock.Call

ClusterAddSlotsRange indicates an expected call of ClusterAddSlotsRange.

func (*MockRedisMockRecorder) ClusterCountFailureReports added in v1.3.0 

func (mr *MockRedisMockRecorder) ClusterCountFailureReports(ctx, nodeID any) *gomock.Call

ClusterCountFailureReports indicates an expected call of ClusterCountFailureReports.

func (*MockRedisMockRecorder) ClusterCountKeysInSlot added in v1.3.0 

func (mr *MockRedisMockRecorder) ClusterCountKeysInSlot(ctx, slot any) *gomock.Call

ClusterCountKeysInSlot indicates an expected call of ClusterCountKeysInSlot.

func (*MockRedisMockRecorder) ClusterDelSlots added in v1.3.0 

func (mr *MockRedisMockRecorder) ClusterDelSlots(ctx any, slots ...any) *gomock.Call

ClusterDelSlots indicates an expected call of ClusterDelSlots.

func (*MockRedisMockRecorder) ClusterDelSlotsRange added in v1.3.0 

func (mr *MockRedisMockRecorder) ClusterDelSlotsRange(ctx, min, max any) *gomock.Call

ClusterDelSlotsRange indicates an expected call of ClusterDelSlotsRange.

func (*MockRedisMockRecorder) ClusterFailover added in v1.3.0 

func (mr *MockRedisMockRecorder) ClusterFailover(ctx any) *gomock.Call

ClusterFailover indicates an expected call of ClusterFailover.

func (*MockRedisMockRecorder) ClusterForget added in v1.3.0 

func (mr *MockRedisMockRecorder) ClusterForget(ctx, nodeID any) *gomock.Call

ClusterForget indicates an expected call of ClusterForget.

func (*MockRedisMockRecorder) ClusterGetKeysInSlot added in v1.3.0 

func (mr *MockRedisMockRecorder) ClusterGetKeysInSlot(ctx, slot, count any) *gomock.Call

ClusterGetKeysInSlot indicates an expected call of ClusterGetKeysInSlot.

func (*MockRedisMockRecorder) ClusterInfo added in v1.3.0 

func (mr *MockRedisMockRecorder) ClusterInfo(ctx any) *gomock.Call

ClusterInfo indicates an expected call of ClusterInfo.

func (*MockRedisMockRecorder) ClusterKeySlot added in v1.3.0 

func (mr *MockRedisMockRecorder) ClusterKeySlot(ctx, key any) *gomock.Call

ClusterKeySlot indicates an expected call of ClusterKeySlot. 

func (mr *MockRedisMockRecorder) ClusterLinks(ctx any) *gomock.Call

ClusterLinks indicates an expected call of ClusterLinks.

func (*MockRedisMockRecorder) ClusterMeet added in v1.3.0 

func (mr *MockRedisMockRecorder) ClusterMeet(ctx, host, port any) *gomock.Call

ClusterMeet indicates an expected call of ClusterMeet.

func (*MockRedisMockRecorder) ClusterMyShardID added in v1.3.0 

func (mr *MockRedisMockRecorder) ClusterMyShardID(ctx any) *gomock.Call

ClusterMyShardID indicates an expected call of ClusterMyShardID.

func (*MockRedisMockRecorder) ClusterNodes added in v1.3.0 

func (mr *MockRedisMockRecorder) ClusterNodes(ctx any) *gomock.Call

ClusterNodes indicates an expected call of ClusterNodes.

func (*MockRedisMockRecorder) ClusterReplicate added in v1.3.0 

func (mr *MockRedisMockRecorder) ClusterReplicate(ctx, nodeID any) *gomock.Call

ClusterReplicate indicates an expected call of ClusterReplicate.

func (*MockRedisMockRecorder) ClusterResetHard added in v1.3.0 

func (mr *MockRedisMockRecorder) ClusterResetHard(ctx any) *gomock.Call

ClusterResetHard indicates an expected call of ClusterResetHard.

func (*MockRedisMockRecorder) ClusterResetSoft added in v1.3.0 

func (mr *MockRedisMockRecorder) ClusterResetSoft(ctx any) *gomock.Call

ClusterResetSoft indicates an expected call of ClusterResetSoft.

func (*MockRedisMockRecorder) ClusterSaveConfig added in v1.3.0 

func (mr *MockRedisMockRecorder) ClusterSaveConfig(ctx any) *gomock.Call

ClusterSaveConfig indicates an expected call of ClusterSaveConfig.

func (*MockRedisMockRecorder) ClusterShards added in v1.3.0 

func (mr *MockRedisMockRecorder) ClusterShards(ctx any) *gomock.Call

ClusterShards indicates an expected call of ClusterShards.

func (*MockRedisMockRecorder) ClusterSlaves added in v1.3.0 

func (mr *MockRedisMockRecorder) ClusterSlaves(ctx, nodeID any) *gomock.Call

ClusterSlaves indicates an expected call of ClusterSlaves.

func (*MockRedisMockRecorder) ClusterSlots added in v1.3.0 

func (mr *MockRedisMockRecorder) ClusterSlots(ctx any) *gomock.Call

ClusterSlots indicates an expected call of ClusterSlots.

func (*MockRedisMockRecorder) Command added in v1.3.0 

func (mr *MockRedisMockRecorder) Command(ctx any) *gomock.Call

Command indicates an expected call of Command.

func (*MockRedisMockRecorder) CommandGetKeys added in v1.3.0 

func (mr *MockRedisMockRecorder) CommandGetKeys(ctx any, commands ...any) *gomock.Call

CommandGetKeys indicates an expected call of CommandGetKeys.

func (*MockRedisMockRecorder) CommandGetKeysAndFlags added in v1.3.0 

func (mr *MockRedisMockRecorder) CommandGetKeysAndFlags(ctx any, commands ...any) *gomock.Call

CommandGetKeysAndFlags indicates an expected call of CommandGetKeysAndFlags.

func (*MockRedisMockRecorder) CommandList added in v1.3.0 

func (mr *MockRedisMockRecorder) CommandList(ctx, filter any) *gomock.Call

CommandList indicates an expected call of CommandList.

func (*MockRedisMockRecorder) ConfigGet added in v1.3.0 

func (mr *MockRedisMockRecorder) ConfigGet(ctx, parameter any) *gomock.Call

ConfigGet indicates an expected call of ConfigGet.

func (*MockRedisMockRecorder) ConfigResetStat added in v1.3.0 

func (mr *MockRedisMockRecorder) ConfigResetStat(ctx any) *gomock.Call

ConfigResetStat indicates an expected call of ConfigResetStat.

func (*MockRedisMockRecorder) ConfigRewrite added in v1.3.0 

func (mr *MockRedisMockRecorder) ConfigRewrite(ctx any) *gomock.Call

ConfigRewrite indicates an expected call of ConfigRewrite.

func (*MockRedisMockRecorder) ConfigSet added in v1.3.0 

func (mr *MockRedisMockRecorder) ConfigSet(ctx, parameter, value any) *gomock.Call

ConfigSet indicates an expected call of ConfigSet.

func (*MockRedisMockRecorder) Copy added in v1.3.0 

func (mr *MockRedisMockRecorder) Copy(ctx, sourceKey, destKey, db, replace any) *gomock.Call

Copy indicates an expected call of Copy.

func (*MockRedisMockRecorder) DBSize added in v1.3.0 

func (mr *MockRedisMockRecorder) DBSize(ctx any) *gomock.Call

DBSize indicates an expected call of DBSize.

func (*MockRedisMockRecorder) DebugObject added in v1.3.0 

func (mr *MockRedisMockRecorder) DebugObject(ctx, key any) *gomock.Call

DebugObject indicates an expected call of DebugObject.

func (*MockRedisMockRecorder) Decr added in v1.3.0 

func (mr *MockRedisMockRecorder) Decr(ctx, key any) *gomock.Call

Decr indicates an expected call of Decr.

func (*MockRedisMockRecorder) DecrBy added in v1.3.0 

func (mr *MockRedisMockRecorder) DecrBy(ctx, key, decrement any) *gomock.Call

DecrBy indicates an expected call of DecrBy.

func (*MockRedisMockRecorder) Del added in v1.3.0 

func (mr *MockRedisMockRecorder) Del(ctx any, keys ...any) *gomock.Call

Del indicates an expected call of Del.

func (*MockRedisMockRecorder) Dump added in v1.3.0 

func (mr *MockRedisMockRecorder) Dump(ctx, key any) *gomock.Call

Dump indicates an expected call of Dump.

func (*MockRedisMockRecorder) Echo added in v1.3.0 

func (mr *MockRedisMockRecorder) Echo(ctx, message any) *gomock.Call

Echo indicates an expected call of Echo.

func (*MockRedisMockRecorder) Eval added in v1.3.0 

func (mr *MockRedisMockRecorder) Eval(ctx, script, keys any, args ...any) *gomock.Call

Eval indicates an expected call of Eval.

func (*MockRedisMockRecorder) EvalRO added in v1.3.0 

func (mr *MockRedisMockRecorder) EvalRO(ctx, script, keys any, args ...any) *gomock.Call

EvalRO indicates an expected call of EvalRO.

func (*MockRedisMockRecorder) EvalSha added in v1.3.0 

func (mr *MockRedisMockRecorder) EvalSha(ctx, sha1, keys any, args ...any) *gomock.Call

EvalSha indicates an expected call of EvalSha.

func (*MockRedisMockRecorder) EvalShaRO added in v1.3.0 

func (mr *MockRedisMockRecorder) EvalShaRO(ctx, sha1, keys any, args ...any) *gomock.Call

EvalShaRO indicates an expected call of EvalShaRO.

func (*MockRedisMockRecorder) Exists added in v1.3.0 

func (mr *MockRedisMockRecorder) Exists(ctx any, keys ...any) *gomock.Call

Exists indicates an expected call of Exists.

func (*MockRedisMockRecorder) Expire added in v1.3.0 

func (mr *MockRedisMockRecorder) Expire(ctx, key, expiration any) *gomock.Call

Expire indicates an expected call of Expire.

func (*MockRedisMockRecorder) ExpireAt added in v1.3.0 

func (mr *MockRedisMockRecorder) ExpireAt(ctx, key, tm any) *gomock.Call

ExpireAt indicates an expected call of ExpireAt.

func (*MockRedisMockRecorder) ExpireGT added in v1.3.0 

func (mr *MockRedisMockRecorder) ExpireGT(ctx, key, expiration any) *gomock.Call

ExpireGT indicates an expected call of ExpireGT.

func (*MockRedisMockRecorder) ExpireLT added in v1.3.0 

func (mr *MockRedisMockRecorder) ExpireLT(ctx, key, expiration any) *gomock.Call

ExpireLT indicates an expected call of ExpireLT.

func (*MockRedisMockRecorder) ExpireNX added in v1.3.0 

func (mr *MockRedisMockRecorder) ExpireNX(ctx, key, expiration any) *gomock.Call

ExpireNX indicates an expected call of ExpireNX.

func (*MockRedisMockRecorder) ExpireTime added in v1.3.0 

func (mr *MockRedisMockRecorder) ExpireTime(ctx, key any) *gomock.Call

ExpireTime indicates an expected call of ExpireTime.

func (*MockRedisMockRecorder) ExpireXX added in v1.3.0 

func (mr *MockRedisMockRecorder) ExpireXX(ctx, key, expiration any) *gomock.Call

ExpireXX indicates an expected call of ExpireXX.

func (*MockRedisMockRecorder) FCall added in v1.3.0 

func (mr *MockRedisMockRecorder) FCall(ctx, function, keys any, args ...any) *gomock.Call

FCall indicates an expected call of FCall.

func (*MockRedisMockRecorder) FCallRO added in v1.3.0 

func (mr *MockRedisMockRecorder) FCallRO(ctx, function, keys any, args ...any) *gomock.Call

FCallRO indicates an expected call of FCallRO.

func (*MockRedisMockRecorder) FCallRo added in v1.3.0 

func (mr *MockRedisMockRecorder) FCallRo(ctx, function, keys any, args ...any) *gomock.Call

FCallRo indicates an expected call of FCallRo.

func (*MockRedisMockRecorder) FlushAll added in v1.3.0 

func (mr *MockRedisMockRecorder) FlushAll(ctx any) *gomock.Call

FlushAll indicates an expected call of FlushAll.

func (*MockRedisMockRecorder) FlushAllAsync added in v1.3.0 

func (mr *MockRedisMockRecorder) FlushAllAsync(ctx any) *gomock.Call

FlushAllAsync indicates an expected call of FlushAllAsync.

func (*MockRedisMockRecorder) FlushDB added in v1.3.0 

func (mr *MockRedisMockRecorder) FlushDB(ctx any) *gomock.Call

FlushDB indicates an expected call of FlushDB.

func (*MockRedisMockRecorder) FlushDBAsync added in v1.3.0 

func (mr *MockRedisMockRecorder) FlushDBAsync(ctx any) *gomock.Call

FlushDBAsync indicates an expected call of FlushDBAsync.

func (*MockRedisMockRecorder) FunctionDelete added in v1.3.0 

func (mr *MockRedisMockRecorder) FunctionDelete(ctx, libName any) *gomock.Call

FunctionDelete indicates an expected call of FunctionDelete.

func (*MockRedisMockRecorder) FunctionDump added in v1.3.0 

func (mr *MockRedisMockRecorder) FunctionDump(ctx any) *gomock.Call

FunctionDump indicates an expected call of FunctionDump.

func (*MockRedisMockRecorder) FunctionFlush added in v1.3.0 

func (mr *MockRedisMockRecorder) FunctionFlush(ctx any) *gomock.Call

FunctionFlush indicates an expected call of FunctionFlush.

func (*MockRedisMockRecorder) FunctionFlushAsync added in v1.3.0 

func (mr *MockRedisMockRecorder) FunctionFlushAsync(ctx any) *gomock.Call

FunctionFlushAsync indicates an expected call of FunctionFlushAsync.

func (*MockRedisMockRecorder) FunctionKill added in v1.3.0 

func (mr *MockRedisMockRecorder) FunctionKill(ctx any) *gomock.Call

FunctionKill indicates an expected call of FunctionKill.

func (*MockRedisMockRecorder) FunctionList added in v1.3.0 

func (mr *MockRedisMockRecorder) FunctionList(ctx, q any) *gomock.Call

FunctionList indicates an expected call of FunctionList.

func (*MockRedisMockRecorder) FunctionLoad added in v1.3.0 

func (mr *MockRedisMockRecorder) FunctionLoad(ctx, code any) *gomock.Call

FunctionLoad indicates an expected call of FunctionLoad.

func (*MockRedisMockRecorder) FunctionLoadReplace added in v1.3.0 

func (mr *MockRedisMockRecorder) FunctionLoadReplace(ctx, code any) *gomock.Call

FunctionLoadReplace indicates an expected call of FunctionLoadReplace.

func (*MockRedisMockRecorder) FunctionRestore added in v1.3.0 

func (mr *MockRedisMockRecorder) FunctionRestore(ctx, libDump any) *gomock.Call

FunctionRestore indicates an expected call of FunctionRestore.

func (*MockRedisMockRecorder) FunctionStats added in v1.3.0 

func (mr *MockRedisMockRecorder) FunctionStats(ctx any) *gomock.Call

FunctionStats indicates an expected call of FunctionStats.

func (*MockRedisMockRecorder) GeoAdd added in v1.3.0 

func (mr *MockRedisMockRecorder) GeoAdd(ctx, key any, geoLocation ...any) *gomock.Call

GeoAdd indicates an expected call of GeoAdd.

func (*MockRedisMockRecorder) GeoDist added in v1.3.0 

func (mr *MockRedisMockRecorder) GeoDist(ctx, key, member1, member2, unit any) *gomock.Call

GeoDist indicates an expected call of GeoDist.

func (*MockRedisMockRecorder) GeoHash added in v1.3.0 

func (mr *MockRedisMockRecorder) GeoHash(ctx, key any, members ...any) *gomock.Call

GeoHash indicates an expected call of GeoHash.

func (*MockRedisMockRecorder) GeoPos added in v1.3.0 

func (mr *MockRedisMockRecorder) GeoPos(ctx, key any, members ...any) *gomock.Call

GeoPos indicates an expected call of GeoPos.

func (*MockRedisMockRecorder) GeoRadius added in v1.3.0 

func (mr *MockRedisMockRecorder) GeoRadius(ctx, key, longitude, latitude, query any) *gomock.Call

GeoRadius indicates an expected call of GeoRadius.

func (*MockRedisMockRecorder) GeoRadiusByMember added in v1.3.0 

func (mr *MockRedisMockRecorder) GeoRadiusByMember(ctx, key, member, query any) *gomock.Call

GeoRadiusByMember indicates an expected call of GeoRadiusByMember.

func (*MockRedisMockRecorder) GeoRadiusByMemberStore added in v1.3.0 

func (mr *MockRedisMockRecorder) GeoRadiusByMemberStore(ctx, key, member, query any) *gomock.Call

GeoRadiusByMemberStore indicates an expected call of GeoRadiusByMemberStore.

func (*MockRedisMockRecorder) GeoRadiusStore added in v1.3.0 

func (mr *MockRedisMockRecorder) GeoRadiusStore(ctx, key, longitude, latitude, query any) *gomock.Call

GeoRadiusStore indicates an expected call of GeoRadiusStore.

func (*MockRedisMockRecorder) GeoSearch added in v1.3.0 

func (mr *MockRedisMockRecorder) GeoSearch(ctx, key, q any) *gomock.Call

GeoSearch indicates an expected call of GeoSearch.

func (*MockRedisMockRecorder) GeoSearchLocation added in v1.3.0 

func (mr *MockRedisMockRecorder) GeoSearchLocation(ctx, key, q any) *gomock.Call

GeoSearchLocation indicates an expected call of GeoSearchLocation.

func (*MockRedisMockRecorder) GeoSearchStore added in v1.3.0 

func (mr *MockRedisMockRecorder) GeoSearchStore(ctx, key, store, q any) *gomock.Call

GeoSearchStore indicates an expected call of GeoSearchStore.

func (*MockRedisMockRecorder) Get added in v1.3.0 

func (mr *MockRedisMockRecorder) Get(ctx, key any) *gomock.Call

Get indicates an expected call of Get.

func (*MockRedisMockRecorder) GetBit added in v1.3.0 

func (mr *MockRedisMockRecorder) GetBit(ctx, key, offset any) *gomock.Call

GetBit indicates an expected call of GetBit.

func (*MockRedisMockRecorder) GetDel added in v1.3.0 

func (mr *MockRedisMockRecorder) GetDel(ctx, key any) *gomock.Call

GetDel indicates an expected call of GetDel.

func (*MockRedisMockRecorder) GetEx added in v1.3.0 

func (mr *MockRedisMockRecorder) GetEx(ctx, key, expiration any) *gomock.Call

GetEx indicates an expected call of GetEx.

func (*MockRedisMockRecorder) GetRange added in v1.3.0 

func (mr *MockRedisMockRecorder) GetRange(ctx, key, start, end any) *gomock.Call

GetRange indicates an expected call of GetRange.

func (*MockRedisMockRecorder) GetSet added in v1.3.0 

func (mr *MockRedisMockRecorder) GetSet(ctx, key, value any) *gomock.Call

GetSet indicates an expected call of GetSet.

func (*MockRedisMockRecorder) HDel added in v1.3.0 

func (mr *MockRedisMockRecorder) HDel(ctx, key any, fields ...any) *gomock.Call

HDel indicates an expected call of HDel.

func (*MockRedisMockRecorder) HExists added in v1.3.0 

func (mr *MockRedisMockRecorder) HExists(ctx, key, field any) *gomock.Call

HExists indicates an expected call of HExists.

func (*MockRedisMockRecorder) HExpire added in v1.15.0 

func (mr *MockRedisMockRecorder) HExpire(ctx, key, expiration any, fields ...any) *gomock.Call

HExpire indicates an expected call of HExpire.

func (*MockRedisMockRecorder) HExpireAt added in v1.15.0 

func (mr *MockRedisMockRecorder) HExpireAt(ctx, key, tm any, fields ...any) *gomock.Call

HExpireAt indicates an expected call of HExpireAt.

func (*MockRedisMockRecorder) HExpireAtWithArgs added in v1.15.0 

func (mr *MockRedisMockRecorder) HExpireAtWithArgs(ctx, key, tm, expirationArgs any, fields ...any) *gomock.Call

HExpireAtWithArgs indicates an expected call of HExpireAtWithArgs.

func (*MockRedisMockRecorder) HExpireTime added in v1.15.0 

func (mr *MockRedisMockRecorder) HExpireTime(ctx, key any, fields ...any) *gomock.Call

HExpireTime indicates an expected call of HExpireTime.

func (*MockRedisMockRecorder) HExpireWithArgs added in v1.15.0 

func (mr *MockRedisMockRecorder) HExpireWithArgs(ctx, key, expiration, expirationArgs any, fields ...any) *gomock.Call

HExpireWithArgs indicates an expected call of HExpireWithArgs.

func (*MockRedisMockRecorder) HGet added in v1.3.0 

func (mr *MockRedisMockRecorder) HGet(ctx, key, field any) *gomock.Call

HGet indicates an expected call of HGet.

func (*MockRedisMockRecorder) HGetAll added in v1.3.0 

func (mr *MockRedisMockRecorder) HGetAll(ctx, key any) *gomock.Call

HGetAll indicates an expected call of HGetAll.

func (*MockRedisMockRecorder) HIncrBy added in v1.3.0 

func (mr *MockRedisMockRecorder) HIncrBy(ctx, key, field, incr any) *gomock.Call

HIncrBy indicates an expected call of HIncrBy.

func (*MockRedisMockRecorder) HIncrByFloat added in v1.3.0 

func (mr *MockRedisMockRecorder) HIncrByFloat(ctx, key, field, incr any) *gomock.Call

HIncrByFloat indicates an expected call of HIncrByFloat.

func (*MockRedisMockRecorder) HKeys added in v1.3.0 

func (mr *MockRedisMockRecorder) HKeys(ctx, key any) *gomock.Call

HKeys indicates an expected call of HKeys.

func (*MockRedisMockRecorder) HLen added in v1.3.0 

func (mr *MockRedisMockRecorder) HLen(ctx, key any) *gomock.Call

HLen indicates an expected call of HLen.

func (*MockRedisMockRecorder) HMGet added in v1.3.0 

func (mr *MockRedisMockRecorder) HMGet(ctx, key any, fields ...any) *gomock.Call

HMGet indicates an expected call of HMGet.

func (*MockRedisMockRecorder) HMSet added in v1.3.0 

func (mr *MockRedisMockRecorder) HMSet(ctx, key any, values ...any) *gomock.Call

HMSet indicates an expected call of HMSet.

func (*MockRedisMockRecorder) HPExpire added in v1.15.0 

func (mr *MockRedisMockRecorder) HPExpire(ctx, key, expiration any, fields ...any) *gomock.Call

HPExpire indicates an expected call of HPExpire.

func (*MockRedisMockRecorder) HPExpireAt added in v1.15.0 

func (mr *MockRedisMockRecorder) HPExpireAt(ctx, key, tm any, fields ...any) *gomock.Call

HPExpireAt indicates an expected call of HPExpireAt.

func (*MockRedisMockRecorder) HPExpireAtWithArgs added in v1.15.0 

func (mr *MockRedisMockRecorder) HPExpireAtWithArgs(ctx, key, tm, expirationArgs any, fields ...any) *gomock.Call

HPExpireAtWithArgs indicates an expected call of HPExpireAtWithArgs.

func (*MockRedisMockRecorder) HPExpireTime added in v1.15.0 

func (mr *MockRedisMockRecorder) HPExpireTime(ctx, key any, fields ...any) *gomock.Call

HPExpireTime indicates an expected call of HPExpireTime.

func (*MockRedisMockRecorder) HPExpireWithArgs added in v1.15.0 

func (mr *MockRedisMockRecorder) HPExpireWithArgs(ctx, key, expiration, expirationArgs any, fields ...any) *gomock.Call

HPExpireWithArgs indicates an expected call of HPExpireWithArgs.

func (*MockRedisMockRecorder) HPTTL added in v1.15.0 

func (mr *MockRedisMockRecorder) HPTTL(ctx, key any, fields ...any) *gomock.Call

HPTTL indicates an expected call of HPTTL.

func (*MockRedisMockRecorder) HPersist added in v1.15.0 

func (mr *MockRedisMockRecorder) HPersist(ctx, key any, fields ...any) *gomock.Call

HPersist indicates an expected call of HPersist.

func (*MockRedisMockRecorder) HRandField added in v1.3.0 

func (mr *MockRedisMockRecorder) HRandField(ctx, key, count any) *gomock.Call

HRandField indicates an expected call of HRandField.

func (*MockRedisMockRecorder) HRandFieldWithValues added in v1.3.0 

func (mr *MockRedisMockRecorder) HRandFieldWithValues(ctx, key, count any) *gomock.Call

HRandFieldWithValues indicates an expected call of HRandFieldWithValues.

func (*MockRedisMockRecorder) HScan added in v1.3.0 

func (mr *MockRedisMockRecorder) HScan(ctx, key, cursor, match, count any) *gomock.Call

HScan indicates an expected call of HScan.

func (*MockRedisMockRecorder) HScanNoValues added in v1.15.0 

func (mr *MockRedisMockRecorder) HScanNoValues(ctx, key, cursor, match, count any) *gomock.Call

HScanNoValues indicates an expected call of HScanNoValues.

func (*MockRedisMockRecorder) HSet added in v1.3.0 

func (mr *MockRedisMockRecorder) HSet(ctx, key any, values ...any) *gomock.Call

HSet indicates an expected call of HSet.

func (*MockRedisMockRecorder) HSetNX added in v1.3.0 

func (mr *MockRedisMockRecorder) HSetNX(ctx, key, field, value any) *gomock.Call

HSetNX indicates an expected call of HSetNX.

func (*MockRedisMockRecorder) HTTL added in v1.15.0 

func (mr *MockRedisMockRecorder) HTTL(ctx, key any, fields ...any) *gomock.Call

HTTL indicates an expected call of HTTL.

func (*MockRedisMockRecorder) HVals added in v1.3.0 

func (mr *MockRedisMockRecorder) HVals(ctx, key any) *gomock.Call

HVals indicates an expected call of HVals.

func (*MockRedisMockRecorder) HealthCheck added in v1.3.0 

func (mr *MockRedisMockRecorder) HealthCheck() *gomock.Call

HealthCheck indicates an expected call of HealthCheck.

func (*MockRedisMockRecorder) Incr added in v1.3.0 

func (mr *MockRedisMockRecorder) Incr(ctx, key any) *gomock.Call

Incr indicates an expected call of Incr.

func (*MockRedisMockRecorder) IncrBy added in v1.3.0 

func (mr *MockRedisMockRecorder) IncrBy(ctx, key, value any) *gomock.Call

IncrBy indicates an expected call of IncrBy.

func (*MockRedisMockRecorder) IncrByFloat added in v1.3.0 

func (mr *MockRedisMockRecorder) IncrByFloat(ctx, key, value any) *gomock.Call

IncrByFloat indicates an expected call of IncrByFloat.

func (*MockRedisMockRecorder) Info added in v1.3.0 

func (mr *MockRedisMockRecorder) Info(ctx any, section ...any) *gomock.Call

Info indicates an expected call of Info.

func (*MockRedisMockRecorder) JSONArrAppend added in v1.3.0 

func (mr *MockRedisMockRecorder) JSONArrAppend(ctx, key, path any, values ...any) *gomock.Call

JSONArrAppend indicates an expected call of JSONArrAppend.

func (*MockRedisMockRecorder) JSONArrIndex added in v1.3.0 

func (mr *MockRedisMockRecorder) JSONArrIndex(ctx, key, path any, value ...any) *gomock.Call

JSONArrIndex indicates an expected call of JSONArrIndex.

func (*MockRedisMockRecorder) JSONArrIndexWithArgs added in v1.3.0 

func (mr *MockRedisMockRecorder) JSONArrIndexWithArgs(ctx, key, path, options any, value ...any) *gomock.Call

JSONArrIndexWithArgs indicates an expected call of JSONArrIndexWithArgs.

func (*MockRedisMockRecorder) JSONArrInsert added in v1.3.0 

func (mr *MockRedisMockRecorder) JSONArrInsert(ctx, key, path, index any, values ...any) *gomock.Call

JSONArrInsert indicates an expected call of JSONArrInsert.

func (*MockRedisMockRecorder) JSONArrLen added in v1.3.0 

func (mr *MockRedisMockRecorder) JSONArrLen(ctx, key, path any) *gomock.Call

JSONArrLen indicates an expected call of JSONArrLen.

func (*MockRedisMockRecorder) JSONArrPop added in v1.3.0 

func (mr *MockRedisMockRecorder) JSONArrPop(ctx, key, path, index any) *gomock.Call

JSONArrPop indicates an expected call of JSONArrPop.

func (*MockRedisMockRecorder) JSONArrTrim added in v1.3.0 

func (mr *MockRedisMockRecorder) JSONArrTrim(ctx, key, path any) *gomock.Call

JSONArrTrim indicates an expected call of JSONArrTrim.

func (*MockRedisMockRecorder) JSONArrTrimWithArgs added in v1.3.0 

func (mr *MockRedisMockRecorder) JSONArrTrimWithArgs(ctx, key, path, options any) *gomock.Call

JSONArrTrimWithArgs indicates an expected call of JSONArrTrimWithArgs.

func (*MockRedisMockRecorder) JSONClear added in v1.3.0 

func (mr *MockRedisMockRecorder) JSONClear(ctx, key, path any) *gomock.Call

JSONClear indicates an expected call of JSONClear.

func (*MockRedisMockRecorder) JSONDebugMemory added in v1.3.0 

func (mr *MockRedisMockRecorder) JSONDebugMemory(ctx, key, path any) *gomock.Call

JSONDebugMemory indicates an expected call of JSONDebugMemory.

func (*MockRedisMockRecorder) JSONDel added in v1.3.0 

func (mr *MockRedisMockRecorder) JSONDel(ctx, key, path any) *gomock.Call

JSONDel indicates an expected call of JSONDel.

func (*MockRedisMockRecorder) JSONForget added in v1.3.0 

func (mr *MockRedisMockRecorder) JSONForget(ctx, key, path any) *gomock.Call

JSONForget indicates an expected call of JSONForget.

func (*MockRedisMockRecorder) JSONGet added in v1.3.0 

func (mr *MockRedisMockRecorder) JSONGet(ctx, key any, paths ...any) *gomock.Call

JSONGet indicates an expected call of JSONGet.

func (*MockRedisMockRecorder) JSONGetWithArgs added in v1.3.0 

func (mr *MockRedisMockRecorder) JSONGetWithArgs(ctx, key, options any, paths ...any) *gomock.Call

JSONGetWithArgs indicates an expected call of JSONGetWithArgs.

func (*MockRedisMockRecorder) JSONMGet added in v1.3.0 

func (mr *MockRedisMockRecorder) JSONMGet(ctx, path any, keys ...any) *gomock.Call

JSONMGet indicates an expected call of JSONMGet.

func (*MockRedisMockRecorder) JSONMSet added in v1.3.0 

func (mr *MockRedisMockRecorder) JSONMSet(ctx any, params ...any) *gomock.Call

JSONMSet indicates an expected call of JSONMSet.

func (*MockRedisMockRecorder) JSONMSetArgs added in v1.3.0 

func (mr *MockRedisMockRecorder) JSONMSetArgs(ctx, docs any) *gomock.Call

JSONMSetArgs indicates an expected call of JSONMSetArgs.

func (*MockRedisMockRecorder) JSONMerge added in v1.3.0 

func (mr *MockRedisMockRecorder) JSONMerge(ctx, key, path, value any) *gomock.Call

JSONMerge indicates an expected call of JSONMerge.

func (*MockRedisMockRecorder) JSONNumIncrBy added in v1.3.0 

func (mr *MockRedisMockRecorder) JSONNumIncrBy(ctx, key, path, value any) *gomock.Call

JSONNumIncrBy indicates an expected call of JSONNumIncrBy.

func (*MockRedisMockRecorder) JSONObjKeys added in v1.3.0 

func (mr *MockRedisMockRecorder) JSONObjKeys(ctx, key, path any) *gomock.Call

JSONObjKeys indicates an expected call of JSONObjKeys.

func (*MockRedisMockRecorder) JSONObjLen added in v1.3.0 

func (mr *MockRedisMockRecorder) JSONObjLen(ctx, key, path any) *gomock.Call

JSONObjLen indicates an expected call of JSONObjLen.

func (*MockRedisMockRecorder) JSONSet added in v1.3.0 

func (mr *MockRedisMockRecorder) JSONSet(ctx, key, path, value any) *gomock.Call

JSONSet indicates an expected call of JSONSet.

func (*MockRedisMockRecorder) JSONSetMode added in v1.3.0 

func (mr *MockRedisMockRecorder) JSONSetMode(ctx, key, path, value, mode any) *gomock.Call

JSONSetMode indicates an expected call of JSONSetMode.

func (*MockRedisMockRecorder) JSONStrAppend added in v1.3.0 

func (mr *MockRedisMockRecorder) JSONStrAppend(ctx, key, path, value any) *gomock.Call

JSONStrAppend indicates an expected call of JSONStrAppend.

func (*MockRedisMockRecorder) JSONStrLen added in v1.3.0 

func (mr *MockRedisMockRecorder) JSONStrLen(ctx, key, path any) *gomock.Call

JSONStrLen indicates an expected call of JSONStrLen.

func (*MockRedisMockRecorder) JSONToggle added in v1.3.0 

func (mr *MockRedisMockRecorder) JSONToggle(ctx, key, path any) *gomock.Call

JSONToggle indicates an expected call of JSONToggle.

func (*MockRedisMockRecorder) JSONType added in v1.3.0 

func (mr *MockRedisMockRecorder) JSONType(ctx, key, path any) *gomock.Call

JSONType indicates an expected call of JSONType.

func (*MockRedisMockRecorder) Keys added in v1.3.0 

func (mr *MockRedisMockRecorder) Keys(ctx, pattern any) *gomock.Call

Keys indicates an expected call of Keys.

func (*MockRedisMockRecorder) LCS added in v1.3.0 

func (mr *MockRedisMockRecorder) LCS(ctx, q any) *gomock.Call

LCS indicates an expected call of LCS.

func (*MockRedisMockRecorder) LIndex added in v1.3.0 

func (mr *MockRedisMockRecorder) LIndex(ctx, key, index any) *gomock.Call

LIndex indicates an expected call of LIndex.

func (*MockRedisMockRecorder) LInsert added in v1.3.0 

func (mr *MockRedisMockRecorder) LInsert(ctx, key, op, pivot, value any) *gomock.Call

LInsert indicates an expected call of LInsert.

func (*MockRedisMockRecorder) LInsertAfter added in v1.3.0 

func (mr *MockRedisMockRecorder) LInsertAfter(ctx, key, pivot, value any) *gomock.Call

LInsertAfter indicates an expected call of LInsertAfter.

func (*MockRedisMockRecorder) LInsertBefore added in v1.3.0 

func (mr *MockRedisMockRecorder) LInsertBefore(ctx, key, pivot, value any) *gomock.Call

LInsertBefore indicates an expected call of LInsertBefore.

func (*MockRedisMockRecorder) LLen added in v1.3.0 

func (mr *MockRedisMockRecorder) LLen(ctx, key any) *gomock.Call

LLen indicates an expected call of LLen.

func (*MockRedisMockRecorder) LMPop added in v1.3.0 

func (mr *MockRedisMockRecorder) LMPop(ctx, direction, count any, keys ...any) *gomock.Call

LMPop indicates an expected call of LMPop.

func (*MockRedisMockRecorder) LMove added in v1.3.0 

func (mr *MockRedisMockRecorder) LMove(ctx, source, destination, srcpos, destpos any) *gomock.Call

LMove indicates an expected call of LMove.

func (*MockRedisMockRecorder) LPop added in v1.3.0 

func (mr *MockRedisMockRecorder) LPop(ctx, key any) *gomock.Call

LPop indicates an expected call of LPop.

func (*MockRedisMockRecorder) LPopCount added in v1.3.0 

func (mr *MockRedisMockRecorder) LPopCount(ctx, key, count any) *gomock.Call

LPopCount indicates an expected call of LPopCount.

func (*MockRedisMockRecorder) LPos added in v1.3.0 

func (mr *MockRedisMockRecorder) LPos(ctx, key, value, args any) *gomock.Call

LPos indicates an expected call of LPos.

func (*MockRedisMockRecorder) LPosCount added in v1.3.0 

func (mr *MockRedisMockRecorder) LPosCount(ctx, key, value, count, args any) *gomock.Call

LPosCount indicates an expected call of LPosCount.

func (*MockRedisMockRecorder) LPush added in v1.3.0 

func (mr *MockRedisMockRecorder) LPush(ctx, key any, values ...any) *gomock.Call

LPush indicates an expected call of LPush.

func (*MockRedisMockRecorder) LPushX added in v1.3.0 

func (mr *MockRedisMockRecorder) LPushX(ctx, key any, values ...any) *gomock.Call

LPushX indicates an expected call of LPushX.

func (*MockRedisMockRecorder) LRange added in v1.3.0 

func (mr *MockRedisMockRecorder) LRange(ctx, key, start, stop any) *gomock.Call

LRange indicates an expected call of LRange.

func (*MockRedisMockRecorder) LRem added in v1.3.0 

func (mr *MockRedisMockRecorder) LRem(ctx, key, count, value any) *gomock.Call

LRem indicates an expected call of LRem.

func (*MockRedisMockRecorder) LSet added in v1.3.0 

func (mr *MockRedisMockRecorder) LSet(ctx, key, index, value any) *gomock.Call

LSet indicates an expected call of LSet.

func (*MockRedisMockRecorder) LTrim added in v1.3.0 

func (mr *MockRedisMockRecorder) LTrim(ctx, key, start, stop any) *gomock.Call

LTrim indicates an expected call of LTrim.

func (*MockRedisMockRecorder) LastSave added in v1.3.0 

func (mr *MockRedisMockRecorder) LastSave(ctx any) *gomock.Call

LastSave indicates an expected call of LastSave.

func (*MockRedisMockRecorder) MGet added in v1.3.0 

func (mr *MockRedisMockRecorder) MGet(ctx any, keys ...any) *gomock.Call

MGet indicates an expected call of MGet.

func (*MockRedisMockRecorder) MSet added in v1.3.0 

func (mr *MockRedisMockRecorder) MSet(ctx any, values ...any) *gomock.Call

MSet indicates an expected call of MSet.

func (*MockRedisMockRecorder) MSetNX added in v1.3.0 

func (mr *MockRedisMockRecorder) MSetNX(ctx any, values ...any) *gomock.Call

MSetNX indicates an expected call of MSetNX.

func (*MockRedisMockRecorder) MemoryUsage added in v1.3.0 

func (mr *MockRedisMockRecorder) MemoryUsage(ctx, key any, samples ...any) *gomock.Call

MemoryUsage indicates an expected call of MemoryUsage.

func (*MockRedisMockRecorder) Migrate added in v1.3.0 

func (mr *MockRedisMockRecorder) Migrate(ctx, host, port, key, db, timeout any) *gomock.Call

Migrate indicates an expected call of Migrate.

func (*MockRedisMockRecorder) ModuleLoadex added in v1.3.0 

func (mr *MockRedisMockRecorder) ModuleLoadex(ctx, conf any) *gomock.Call

ModuleLoadex indicates an expected call of ModuleLoadex.

func (*MockRedisMockRecorder) Move added in v1.3.0 

func (mr *MockRedisMockRecorder) Move(ctx, key, db any) *gomock.Call

Move indicates an expected call of Move.

func (*MockRedisMockRecorder) ObjectEncoding added in v1.3.0 

func (mr *MockRedisMockRecorder) ObjectEncoding(ctx, key any) *gomock.Call

ObjectEncoding indicates an expected call of ObjectEncoding.

func (*MockRedisMockRecorder) ObjectFreq added in v1.3.0 

func (mr *MockRedisMockRecorder) ObjectFreq(ctx, key any) *gomock.Call

ObjectFreq indicates an expected call of ObjectFreq.

func (*MockRedisMockRecorder) ObjectIdleTime added in v1.3.0 

func (mr *MockRedisMockRecorder) ObjectIdleTime(ctx, key any) *gomock.Call

ObjectIdleTime indicates an expected call of ObjectIdleTime.

func (*MockRedisMockRecorder) ObjectRefCount added in v1.3.0 

func (mr *MockRedisMockRecorder) ObjectRefCount(ctx, key any) *gomock.Call

ObjectRefCount indicates an expected call of ObjectRefCount.

func (*MockRedisMockRecorder) PExpire added in v1.3.0 

func (mr *MockRedisMockRecorder) PExpire(ctx, key, expiration any) *gomock.Call

PExpire indicates an expected call of PExpire.

func (*MockRedisMockRecorder) PExpireAt added in v1.3.0 

func (mr *MockRedisMockRecorder) PExpireAt(ctx, key, tm any) *gomock.Call

PExpireAt indicates an expected call of PExpireAt.

func (*MockRedisMockRecorder) PExpireTime added in v1.3.0 

func (mr *MockRedisMockRecorder) PExpireTime(ctx, key any) *gomock.Call

PExpireTime indicates an expected call of PExpireTime.

func (*MockRedisMockRecorder) PFAdd added in v1.3.0 

func (mr *MockRedisMockRecorder) PFAdd(ctx, key any, els ...any) *gomock.Call

PFAdd indicates an expected call of PFAdd.

func (*MockRedisMockRecorder) PFCount added in v1.3.0 

func (mr *MockRedisMockRecorder) PFCount(ctx any, keys ...any) *gomock.Call

PFCount indicates an expected call of PFCount.

func (*MockRedisMockRecorder) PFMerge added in v1.3.0 

func (mr *MockRedisMockRecorder) PFMerge(ctx, dest any, keys ...any) *gomock.Call

PFMerge indicates an expected call of PFMerge.

func (*MockRedisMockRecorder) PTTL added in v1.3.0 

func (mr *MockRedisMockRecorder) PTTL(ctx, key any) *gomock.Call

PTTL indicates an expected call of PTTL.

func (*MockRedisMockRecorder) Persist added in v1.3.0 

func (mr *MockRedisMockRecorder) Persist(ctx, key any) *gomock.Call

Persist indicates an expected call of Persist.

func (*MockRedisMockRecorder) Ping added in v1.3.0 

func (mr *MockRedisMockRecorder) Ping(ctx any) *gomock.Call

Ping indicates an expected call of Ping.

func (*MockRedisMockRecorder) Pipeline added in v1.3.0 

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

Pipeline indicates an expected call of Pipeline.

func (*MockRedisMockRecorder) Pipelined added in v1.3.0 

func (mr *MockRedisMockRecorder) Pipelined(ctx, fn any) *gomock.Call

Pipelined indicates an expected call of Pipelined.

func (*MockRedisMockRecorder) PubSubChannels added in v1.3.0 

func (mr *MockRedisMockRecorder) PubSubChannels(ctx, pattern any) *gomock.Call

PubSubChannels indicates an expected call of PubSubChannels.

func (*MockRedisMockRecorder) PubSubNumPat added in v1.3.0 

func (mr *MockRedisMockRecorder) PubSubNumPat(ctx any) *gomock.Call

PubSubNumPat indicates an expected call of PubSubNumPat.

func (*MockRedisMockRecorder) PubSubNumSub added in v1.3.0 

func (mr *MockRedisMockRecorder) PubSubNumSub(ctx any, channels ...any) *gomock.Call

PubSubNumSub indicates an expected call of PubSubNumSub.

func (*MockRedisMockRecorder) PubSubShardChannels added in v1.3.0 

func (mr *MockRedisMockRecorder) PubSubShardChannels(ctx, pattern any) *gomock.Call

PubSubShardChannels indicates an expected call of PubSubShardChannels.

func (*MockRedisMockRecorder) PubSubShardNumSub added in v1.3.0 

func (mr *MockRedisMockRecorder) PubSubShardNumSub(ctx any, channels ...any) *gomock.Call

PubSubShardNumSub indicates an expected call of PubSubShardNumSub.

func (*MockRedisMockRecorder) Publish added in v1.3.0 

func (mr *MockRedisMockRecorder) Publish(ctx, channel, message any) *gomock.Call

Publish indicates an expected call of Publish.

func (*MockRedisMockRecorder) Quit added in v1.3.0 

func (mr *MockRedisMockRecorder) Quit(ctx any) *gomock.Call

Quit indicates an expected call of Quit.

func (*MockRedisMockRecorder) RPop added in v1.3.0 

func (mr *MockRedisMockRecorder) RPop(ctx, key any) *gomock.Call

RPop indicates an expected call of RPop.

func (*MockRedisMockRecorder) RPopCount added in v1.3.0 

func (mr *MockRedisMockRecorder) RPopCount(ctx, key, count any) *gomock.Call

RPopCount indicates an expected call of RPopCount.

func (*MockRedisMockRecorder) RPopLPush added in v1.3.0 

func (mr *MockRedisMockRecorder) RPopLPush(ctx, source, destination any) *gomock.Call

RPopLPush indicates an expected call of RPopLPush.

func (*MockRedisMockRecorder) RPush added in v1.3.0 

func (mr *MockRedisMockRecorder) RPush(ctx, key any, values ...any) *gomock.Call

RPush indicates an expected call of RPush.

func (*MockRedisMockRecorder) RPushX added in v1.3.0 

func (mr *MockRedisMockRecorder) RPushX(ctx, key any, values ...any) *gomock.Call

RPushX indicates an expected call of RPushX.

func (*MockRedisMockRecorder) RandomKey added in v1.3.0 

func (mr *MockRedisMockRecorder) RandomKey(ctx any) *gomock.Call

RandomKey indicates an expected call of RandomKey.

func (*MockRedisMockRecorder) ReadOnly added in v1.3.0 

func (mr *MockRedisMockRecorder) ReadOnly(ctx any) *gomock.Call

ReadOnly indicates an expected call of ReadOnly.

func (*MockRedisMockRecorder) ReadWrite added in v1.3.0 

func (mr *MockRedisMockRecorder) ReadWrite(ctx any) *gomock.Call

ReadWrite indicates an expected call of ReadWrite.

func (*MockRedisMockRecorder) Rename added in v1.3.0 

func (mr *MockRedisMockRecorder) Rename(ctx, key, newkey any) *gomock.Call

Rename indicates an expected call of Rename.

func (*MockRedisMockRecorder) RenameNX added in v1.3.0 

func (mr *MockRedisMockRecorder) RenameNX(ctx, key, newkey any) *gomock.Call

RenameNX indicates an expected call of RenameNX.

func (*MockRedisMockRecorder) Restore added in v1.3.0 

func (mr *MockRedisMockRecorder) Restore(ctx, key, ttl, value any) *gomock.Call

Restore indicates an expected call of Restore.

func (*MockRedisMockRecorder) RestoreReplace added in v1.3.0 

func (mr *MockRedisMockRecorder) RestoreReplace(ctx, key, ttl, value any) *gomock.Call

RestoreReplace indicates an expected call of RestoreReplace.

func (*MockRedisMockRecorder) SAdd added in v1.3.0 

func (mr *MockRedisMockRecorder) SAdd(ctx, key any, members ...any) *gomock.Call

SAdd indicates an expected call of SAdd.

func (*MockRedisMockRecorder) SCard added in v1.3.0 

func (mr *MockRedisMockRecorder) SCard(ctx, key any) *gomock.Call

SCard indicates an expected call of SCard.

func (*MockRedisMockRecorder) SDiff added in v1.3.0 

func (mr *MockRedisMockRecorder) SDiff(ctx any, keys ...any) *gomock.Call

SDiff indicates an expected call of SDiff.

func (*MockRedisMockRecorder) SDiffStore added in v1.3.0 

func (mr *MockRedisMockRecorder) SDiffStore(ctx, destination any, keys ...any) *gomock.Call

SDiffStore indicates an expected call of SDiffStore.

func (*MockRedisMockRecorder) SInter added in v1.3.0 

func (mr *MockRedisMockRecorder) SInter(ctx any, keys ...any) *gomock.Call

SInter indicates an expected call of SInter.

func (*MockRedisMockRecorder) SInterCard added in v1.3.0 

func (mr *MockRedisMockRecorder) SInterCard(ctx, limit any, keys ...any) *gomock.Call

SInterCard indicates an expected call of SInterCard.

func (*MockRedisMockRecorder) SInterStore added in v1.3.0 

func (mr *MockRedisMockRecorder) SInterStore(ctx, destination any, keys ...any) *gomock.Call

SInterStore indicates an expected call of SInterStore.

func (*MockRedisMockRecorder) SIsMember added in v1.3.0 

func (mr *MockRedisMockRecorder) SIsMember(ctx, key, member any) *gomock.Call

SIsMember indicates an expected call of SIsMember.

func (*MockRedisMockRecorder) SMIsMember added in v1.3.0 

func (mr *MockRedisMockRecorder) SMIsMember(ctx, key any, members ...any) *gomock.Call

SMIsMember indicates an expected call of SMIsMember.

func (*MockRedisMockRecorder) SMembers added in v1.3.0 

func (mr *MockRedisMockRecorder) SMembers(ctx, key any) *gomock.Call

SMembers indicates an expected call of SMembers.

func (*MockRedisMockRecorder) SMembersMap added in v1.3.0 

func (mr *MockRedisMockRecorder) SMembersMap(ctx, key any) *gomock.Call

SMembersMap indicates an expected call of SMembersMap.

func (*MockRedisMockRecorder) SMove added in v1.3.0 

func (mr *MockRedisMockRecorder) SMove(ctx, source, destination, member any) *gomock.Call

SMove indicates an expected call of SMove.

func (*MockRedisMockRecorder) SPop added in v1.3.0 

func (mr *MockRedisMockRecorder) SPop(ctx, key any) *gomock.Call

SPop indicates an expected call of SPop.

func (*MockRedisMockRecorder) SPopN added in v1.3.0 

func (mr *MockRedisMockRecorder) SPopN(ctx, key, count any) *gomock.Call

SPopN indicates an expected call of SPopN.

func (*MockRedisMockRecorder) SPublish added in v1.3.0 

func (mr *MockRedisMockRecorder) SPublish(ctx, channel, message any) *gomock.Call

SPublish indicates an expected call of SPublish.

func (*MockRedisMockRecorder) SRandMember added in v1.3.0 

func (mr *MockRedisMockRecorder) SRandMember(ctx, key any) *gomock.Call

SRandMember indicates an expected call of SRandMember.

func (*MockRedisMockRecorder) SRandMemberN added in v1.3.0 

func (mr *MockRedisMockRecorder) SRandMemberN(ctx, key, count any) *gomock.Call

SRandMemberN indicates an expected call of SRandMemberN.

func (*MockRedisMockRecorder) SRem added in v1.3.0 

func (mr *MockRedisMockRecorder) SRem(ctx, key any, members ...any) *gomock.Call

SRem indicates an expected call of SRem.

func (*MockRedisMockRecorder) SScan added in v1.3.0 

func (mr *MockRedisMockRecorder) SScan(ctx, key, cursor, match, count any) *gomock.Call

SScan indicates an expected call of SScan.

func (*MockRedisMockRecorder) SUnion added in v1.3.0 

func (mr *MockRedisMockRecorder) SUnion(ctx any, keys ...any) *gomock.Call

SUnion indicates an expected call of SUnion.

func (*MockRedisMockRecorder) SUnionStore added in v1.3.0 

func (mr *MockRedisMockRecorder) SUnionStore(ctx, destination any, keys ...any) *gomock.Call

SUnionStore indicates an expected call of SUnionStore.

func (*MockRedisMockRecorder) Save added in v1.3.0 

func (mr *MockRedisMockRecorder) Save(ctx any) *gomock.Call

Save indicates an expected call of Save.

func (*MockRedisMockRecorder) Scan added in v1.3.0 

func (mr *MockRedisMockRecorder) Scan(ctx, cursor, match, count any) *gomock.Call

Scan indicates an expected call of Scan.

func (*MockRedisMockRecorder) ScanType added in v1.3.0 

func (mr *MockRedisMockRecorder) ScanType(ctx, cursor, match, count, keyType any) *gomock.Call

ScanType indicates an expected call of ScanType.

func (*MockRedisMockRecorder) ScriptExists added in v1.3.0 

func (mr *MockRedisMockRecorder) ScriptExists(ctx any, hashes ...any) *gomock.Call

ScriptExists indicates an expected call of ScriptExists.

func (*MockRedisMockRecorder) ScriptFlush added in v1.3.0 

func (mr *MockRedisMockRecorder) ScriptFlush(ctx any) *gomock.Call

ScriptFlush indicates an expected call of ScriptFlush.

func (*MockRedisMockRecorder) ScriptKill added in v1.3.0 

func (mr *MockRedisMockRecorder) ScriptKill(ctx any) *gomock.Call

ScriptKill indicates an expected call of ScriptKill.

func (*MockRedisMockRecorder) ScriptLoad added in v1.3.0 

func (mr *MockRedisMockRecorder) ScriptLoad(ctx, script any) *gomock.Call

ScriptLoad indicates an expected call of ScriptLoad.

func (*MockRedisMockRecorder) Set added in v1.3.0 

func (mr *MockRedisMockRecorder) Set(ctx, key, value, expiration any) *gomock.Call

Set indicates an expected call of Set.

func (*MockRedisMockRecorder) SetArgs added in v1.3.0 

func (mr *MockRedisMockRecorder) SetArgs(ctx, key, value, a any) *gomock.Call

SetArgs indicates an expected call of SetArgs.

func (*MockRedisMockRecorder) SetBit added in v1.3.0 

func (mr *MockRedisMockRecorder) SetBit(ctx, key, offset, value any) *gomock.Call

SetBit indicates an expected call of SetBit.

func (*MockRedisMockRecorder) SetEx added in v1.3.0 

func (mr *MockRedisMockRecorder) SetEx(ctx, key, value, expiration any) *gomock.Call

SetEx indicates an expected call of SetEx.

func (*MockRedisMockRecorder) SetNX added in v1.3.0 

func (mr *MockRedisMockRecorder) SetNX(ctx, key, value, expiration any) *gomock.Call

SetNX indicates an expected call of SetNX.

func (*MockRedisMockRecorder) SetRange added in v1.3.0 

func (mr *MockRedisMockRecorder) SetRange(ctx, key, offset, value any) *gomock.Call

SetRange indicates an expected call of SetRange.

func (*MockRedisMockRecorder) SetXX added in v1.3.0 

func (mr *MockRedisMockRecorder) SetXX(ctx, key, value, expiration any) *gomock.Call

SetXX indicates an expected call of SetXX.

func (*MockRedisMockRecorder) Shutdown added in v1.3.0 

func (mr *MockRedisMockRecorder) Shutdown(ctx any) *gomock.Call

Shutdown indicates an expected call of Shutdown.

func (*MockRedisMockRecorder) ShutdownNoSave added in v1.3.0 

func (mr *MockRedisMockRecorder) ShutdownNoSave(ctx any) *gomock.Call

ShutdownNoSave indicates an expected call of ShutdownNoSave.

func (*MockRedisMockRecorder) ShutdownSave added in v1.3.0 

func (mr *MockRedisMockRecorder) ShutdownSave(ctx any) *gomock.Call

ShutdownSave indicates an expected call of ShutdownSave.

func (*MockRedisMockRecorder) SlaveOf added in v1.3.0 

func (mr *MockRedisMockRecorder) SlaveOf(ctx, host, port any) *gomock.Call

SlaveOf indicates an expected call of SlaveOf.

func (*MockRedisMockRecorder) SlowLogGet added in v1.3.0 

func (mr *MockRedisMockRecorder) SlowLogGet(ctx, num any) *gomock.Call

SlowLogGet indicates an expected call of SlowLogGet.

func (*MockRedisMockRecorder) Sort added in v1.3.0 

func (mr *MockRedisMockRecorder) Sort(ctx, key, sort any) *gomock.Call

Sort indicates an expected call of Sort.

func (*MockRedisMockRecorder) SortInterfaces added in v1.3.0 

func (mr *MockRedisMockRecorder) SortInterfaces(ctx, key, sort any) *gomock.Call

SortInterfaces indicates an expected call of SortInterfaces.

func (*MockRedisMockRecorder) SortRO added in v1.3.0 

func (mr *MockRedisMockRecorder) SortRO(ctx, key, sort any) *gomock.Call

SortRO indicates an expected call of SortRO.

func (*MockRedisMockRecorder) SortStore added in v1.3.0 

func (mr *MockRedisMockRecorder) SortStore(ctx, key, store, sort any) *gomock.Call

SortStore indicates an expected call of SortStore.

func (*MockRedisMockRecorder) StrLen added in v1.3.0 

func (mr *MockRedisMockRecorder) StrLen(ctx, key any) *gomock.Call

StrLen indicates an expected call of StrLen.

func (*MockRedisMockRecorder) TDigestAdd added in v1.3.0 

func (mr *MockRedisMockRecorder) TDigestAdd(ctx, key any, elements ...any) *gomock.Call

TDigestAdd indicates an expected call of TDigestAdd.

func (*MockRedisMockRecorder) TDigestByRank added in v1.3.0 

func (mr *MockRedisMockRecorder) TDigestByRank(ctx, key any, rank ...any) *gomock.Call

TDigestByRank indicates an expected call of TDigestByRank.

func (*MockRedisMockRecorder) TDigestByRevRank added in v1.3.0 

func (mr *MockRedisMockRecorder) TDigestByRevRank(ctx, key any, rank ...any) *gomock.Call

TDigestByRevRank indicates an expected call of TDigestByRevRank.

func (*MockRedisMockRecorder) TDigestCDF added in v1.3.0 

func (mr *MockRedisMockRecorder) TDigestCDF(ctx, key any, elements ...any) *gomock.Call

TDigestCDF indicates an expected call of TDigestCDF.

func (*MockRedisMockRecorder) TDigestCreate added in v1.3.0 

func (mr *MockRedisMockRecorder) TDigestCreate(ctx, key any) *gomock.Call

TDigestCreate indicates an expected call of TDigestCreate.

func (*MockRedisMockRecorder) TDigestCreateWithCompression added in v1.3.0 

func (mr *MockRedisMockRecorder) TDigestCreateWithCompression(ctx, key, compression any) *gomock.Call

TDigestCreateWithCompression indicates an expected call of TDigestCreateWithCompression.

func (*MockRedisMockRecorder) TDigestInfo added in v1.3.0 

func (mr *MockRedisMockRecorder) TDigestInfo(ctx, key any) *gomock.Call

TDigestInfo indicates an expected call of TDigestInfo.

func (*MockRedisMockRecorder) TDigestMax added in v1.3.0 

func (mr *MockRedisMockRecorder) TDigestMax(ctx, key any) *gomock.Call

TDigestMax indicates an expected call of TDigestMax.

func (*MockRedisMockRecorder) TDigestMerge added in v1.3.0 

func (mr *MockRedisMockRecorder) TDigestMerge(ctx, destKey, options any, sourceKeys ...any) *gomock.Call

TDigestMerge indicates an expected call of TDigestMerge.

func (*MockRedisMockRecorder) TDigestMin added in v1.3.0 

func (mr *MockRedisMockRecorder) TDigestMin(ctx, key any) *gomock.Call

TDigestMin indicates an expected call of TDigestMin.

func (*MockRedisMockRecorder) TDigestQuantile added in v1.3.0 

func (mr *MockRedisMockRecorder) TDigestQuantile(ctx, key any, elements ...any) *gomock.Call

TDigestQuantile indicates an expected call of TDigestQuantile.

func (*MockRedisMockRecorder) TDigestRank added in v1.3.0 

func (mr *MockRedisMockRecorder) TDigestRank(ctx, key any, values ...any) *gomock.Call

TDigestRank indicates an expected call of TDigestRank.

func (*MockRedisMockRecorder) TDigestReset added in v1.3.0 

func (mr *MockRedisMockRecorder) TDigestReset(ctx, key any) *gomock.Call

TDigestReset indicates an expected call of TDigestReset.

func (*MockRedisMockRecorder) TDigestRevRank added in v1.3.0 

func (mr *MockRedisMockRecorder) TDigestRevRank(ctx, key any, values ...any) *gomock.Call

TDigestRevRank indicates an expected call of TDigestRevRank.

func (*MockRedisMockRecorder) TDigestTrimmedMean added in v1.3.0 

func (mr *MockRedisMockRecorder) TDigestTrimmedMean(ctx, key, lowCutQuantile, highCutQuantile any) *gomock.Call

TDigestTrimmedMean indicates an expected call of TDigestTrimmedMean.

func (*MockRedisMockRecorder) TFCall added in v1.3.0 

func (mr *MockRedisMockRecorder) TFCall(ctx, libName, funcName, numKeys any) *gomock.Call

TFCall indicates an expected call of TFCall.

func (*MockRedisMockRecorder) TFCallASYNC added in v1.3.0 

func (mr *MockRedisMockRecorder) TFCallASYNC(ctx, libName, funcName, numKeys any) *gomock.Call

TFCallASYNC indicates an expected call of TFCallASYNC.

func (*MockRedisMockRecorder) TFCallASYNCArgs added in v1.3.0 

func (mr *MockRedisMockRecorder) TFCallASYNCArgs(ctx, libName, funcName, numKeys, options any) *gomock.Call

TFCallASYNCArgs indicates an expected call of TFCallASYNCArgs.

func (*MockRedisMockRecorder) TFCallArgs added in v1.3.0 

func (mr *MockRedisMockRecorder) TFCallArgs(ctx, libName, funcName, numKeys, options any) *gomock.Call

TFCallArgs indicates an expected call of TFCallArgs.

func (*MockRedisMockRecorder) TFunctionDelete added in v1.3.0 

func (mr *MockRedisMockRecorder) TFunctionDelete(ctx, libName any) *gomock.Call

TFunctionDelete indicates an expected call of TFunctionDelete.

func (*MockRedisMockRecorder) TFunctionList added in v1.3.0 

func (mr *MockRedisMockRecorder) TFunctionList(ctx any) *gomock.Call

TFunctionList indicates an expected call of TFunctionList.

func (*MockRedisMockRecorder) TFunctionListArgs added in v1.3.0 

func (mr *MockRedisMockRecorder) TFunctionListArgs(ctx, options any) *gomock.Call

TFunctionListArgs indicates an expected call of TFunctionListArgs.

func (*MockRedisMockRecorder) TFunctionLoad added in v1.3.0 

func (mr *MockRedisMockRecorder) TFunctionLoad(ctx, lib any) *gomock.Call

TFunctionLoad indicates an expected call of TFunctionLoad.

func (*MockRedisMockRecorder) TFunctionLoadArgs added in v1.3.0 

func (mr *MockRedisMockRecorder) TFunctionLoadArgs(ctx, lib, options any) *gomock.Call

TFunctionLoadArgs indicates an expected call of TFunctionLoadArgs.

func (*MockRedisMockRecorder) TSAdd added in v1.3.0 

func (mr *MockRedisMockRecorder) TSAdd(ctx, key, timestamp, value any) *gomock.Call

TSAdd indicates an expected call of TSAdd.

func (*MockRedisMockRecorder) TSAddWithArgs added in v1.3.0 

func (mr *MockRedisMockRecorder) TSAddWithArgs(ctx, key, timestamp, value, options any) *gomock.Call

TSAddWithArgs indicates an expected call of TSAddWithArgs.

func (*MockRedisMockRecorder) TSAlter added in v1.3.0 

func (mr *MockRedisMockRecorder) TSAlter(ctx, key, options any) *gomock.Call

TSAlter indicates an expected call of TSAlter.

func (*MockRedisMockRecorder) TSCreate added in v1.3.0 

func (mr *MockRedisMockRecorder) TSCreate(ctx, key any) *gomock.Call

TSCreate indicates an expected call of TSCreate.

func (*MockRedisMockRecorder) TSCreateRule added in v1.3.0 

func (mr *MockRedisMockRecorder) TSCreateRule(ctx, sourceKey, destKey, aggregator, bucketDuration any) *gomock.Call

TSCreateRule indicates an expected call of TSCreateRule.

func (*MockRedisMockRecorder) TSCreateRuleWithArgs added in v1.3.0 

func (mr *MockRedisMockRecorder) TSCreateRuleWithArgs(ctx, sourceKey, destKey, aggregator, bucketDuration, options any) *gomock.Call

TSCreateRuleWithArgs indicates an expected call of TSCreateRuleWithArgs.

func (*MockRedisMockRecorder) TSCreateWithArgs added in v1.3.0 

func (mr *MockRedisMockRecorder) TSCreateWithArgs(ctx, key, options any) *gomock.Call

TSCreateWithArgs indicates an expected call of TSCreateWithArgs.

func (*MockRedisMockRecorder) TSDecrBy added in v1.3.0 

func (mr *MockRedisMockRecorder) TSDecrBy(ctx, Key, timestamp any) *gomock.Call

TSDecrBy indicates an expected call of TSDecrBy.

func (*MockRedisMockRecorder) TSDecrByWithArgs added in v1.3.0 

func (mr *MockRedisMockRecorder) TSDecrByWithArgs(ctx, key, timestamp, options any) *gomock.Call

TSDecrByWithArgs indicates an expected call of TSDecrByWithArgs.

func (*MockRedisMockRecorder) TSDel added in v1.3.0 

func (mr *MockRedisMockRecorder) TSDel(ctx, Key, fromTimestamp, toTimestamp any) *gomock.Call

TSDel indicates an expected call of TSDel.

func (*MockRedisMockRecorder) TSDeleteRule added in v1.3.0 

func (mr *MockRedisMockRecorder) TSDeleteRule(ctx, sourceKey, destKey any) *gomock.Call

TSDeleteRule indicates an expected call of TSDeleteRule.

func (*MockRedisMockRecorder) TSGet added in v1.3.0 

func (mr *MockRedisMockRecorder) TSGet(ctx, key any) *gomock.Call

TSGet indicates an expected call of TSGet.

func (*MockRedisMockRecorder) TSGetWithArgs added in v1.3.0 

func (mr *MockRedisMockRecorder) TSGetWithArgs(ctx, key, options any) *gomock.Call

TSGetWithArgs indicates an expected call of TSGetWithArgs.

func (*MockRedisMockRecorder) TSIncrBy added in v1.3.0 

func (mr *MockRedisMockRecorder) TSIncrBy(ctx, Key, timestamp any) *gomock.Call

TSIncrBy indicates an expected call of TSIncrBy.

func (*MockRedisMockRecorder) TSIncrByWithArgs added in v1.3.0 

func (mr *MockRedisMockRecorder) TSIncrByWithArgs(ctx, key, timestamp, options any) *gomock.Call

TSIncrByWithArgs indicates an expected call of TSIncrByWithArgs.

func (*MockRedisMockRecorder) TSInfo added in v1.3.0 

func (mr *MockRedisMockRecorder) TSInfo(ctx, key any) *gomock.Call

TSInfo indicates an expected call of TSInfo.

func (*MockRedisMockRecorder) TSInfoWithArgs added in v1.3.0 

func (mr *MockRedisMockRecorder) TSInfoWithArgs(ctx, key, options any) *gomock.Call

TSInfoWithArgs indicates an expected call of TSInfoWithArgs.

func (*MockRedisMockRecorder) TSMAdd added in v1.3.0 

func (mr *MockRedisMockRecorder) TSMAdd(ctx, ktvSlices any) *gomock.Call

TSMAdd indicates an expected call of TSMAdd.

func (*MockRedisMockRecorder) TSMGet added in v1.3.0 

func (mr *MockRedisMockRecorder) TSMGet(ctx, filters any) *gomock.Call

TSMGet indicates an expected call of TSMGet.

func (*MockRedisMockRecorder) TSMGetWithArgs added in v1.3.0 

func (mr *MockRedisMockRecorder) TSMGetWithArgs(ctx, filters, options any) *gomock.Call

TSMGetWithArgs indicates an expected call of TSMGetWithArgs.

func (*MockRedisMockRecorder) TSMRange added in v1.3.0 

func (mr *MockRedisMockRecorder) TSMRange(ctx, fromTimestamp, toTimestamp, filterExpr any) *gomock.Call

TSMRange indicates an expected call of TSMRange.

func (*MockRedisMockRecorder) TSMRangeWithArgs added in v1.3.0 

func (mr *MockRedisMockRecorder) TSMRangeWithArgs(ctx, fromTimestamp, toTimestamp, filterExpr, options any) *gomock.Call

TSMRangeWithArgs indicates an expected call of TSMRangeWithArgs.

func (*MockRedisMockRecorder) TSMRevRange added in v1.3.0 

func (mr *MockRedisMockRecorder) TSMRevRange(ctx, fromTimestamp, toTimestamp, filterExpr any) *gomock.Call

TSMRevRange indicates an expected call of TSMRevRange.

func (*MockRedisMockRecorder) TSMRevRangeWithArgs added in v1.3.0 

func (mr *MockRedisMockRecorder) TSMRevRangeWithArgs(ctx, fromTimestamp, toTimestamp, filterExpr, options any) *gomock.Call

TSMRevRangeWithArgs indicates an expected call of TSMRevRangeWithArgs.

func (*MockRedisMockRecorder) TSQueryIndex added in v1.3.0 

func (mr *MockRedisMockRecorder) TSQueryIndex(ctx, filterExpr any) *gomock.Call

TSQueryIndex indicates an expected call of TSQueryIndex.

func (*MockRedisMockRecorder) TSRange added in v1.3.0 

func (mr *MockRedisMockRecorder) TSRange(ctx, key, fromTimestamp, toTimestamp any) *gomock.Call

TSRange indicates an expected call of TSRange.

func (*MockRedisMockRecorder) TSRangeWithArgs added in v1.3.0 

func (mr *MockRedisMockRecorder) TSRangeWithArgs(ctx, key, fromTimestamp, toTimestamp, options any) *gomock.Call

TSRangeWithArgs indicates an expected call of TSRangeWithArgs.

func (*MockRedisMockRecorder) TSRevRange added in v1.3.0 

func (mr *MockRedisMockRecorder) TSRevRange(ctx, key, fromTimestamp, toTimestamp any) *gomock.Call

TSRevRange indicates an expected call of TSRevRange.

func (*MockRedisMockRecorder) TSRevRangeWithArgs added in v1.3.0 

func (mr *MockRedisMockRecorder) TSRevRangeWithArgs(ctx, key, fromTimestamp, toTimestamp, options any) *gomock.Call

TSRevRangeWithArgs indicates an expected call of TSRevRangeWithArgs.

func (*MockRedisMockRecorder) TTL added in v1.3.0 

func (mr *MockRedisMockRecorder) TTL(ctx, key any) *gomock.Call

TTL indicates an expected call of TTL.

func (*MockRedisMockRecorder) Time added in v1.3.0 

func (mr *MockRedisMockRecorder) Time(ctx any) *gomock.Call

Time indicates an expected call of Time.

func (*MockRedisMockRecorder) TopKAdd added in v1.3.0 

func (mr *MockRedisMockRecorder) TopKAdd(ctx, key any, elements ...any) *gomock.Call

TopKAdd indicates an expected call of TopKAdd.

func (*MockRedisMockRecorder) TopKCount added in v1.3.0 

func (mr *MockRedisMockRecorder) TopKCount(ctx, key any, elements ...any) *gomock.Call

TopKCount indicates an expected call of TopKCount.

func (*MockRedisMockRecorder) TopKIncrBy added in v1.3.0 

func (mr *MockRedisMockRecorder) TopKIncrBy(ctx, key any, elements ...any) *gomock.Call

TopKIncrBy indicates an expected call of TopKIncrBy.

func (*MockRedisMockRecorder) TopKInfo added in v1.3.0 

func (mr *MockRedisMockRecorder) TopKInfo(ctx, key any) *gomock.Call

TopKInfo indicates an expected call of TopKInfo.

func (*MockRedisMockRecorder) TopKList added in v1.3.0 

func (mr *MockRedisMockRecorder) TopKList(ctx, key any) *gomock.Call

TopKList indicates an expected call of TopKList.

func (*MockRedisMockRecorder) TopKListWithCount added in v1.3.0 

func (mr *MockRedisMockRecorder) TopKListWithCount(ctx, key any) *gomock.Call

TopKListWithCount indicates an expected call of TopKListWithCount.

func (*MockRedisMockRecorder) TopKQuery added in v1.3.0 

func (mr *MockRedisMockRecorder) TopKQuery(ctx, key any, elements ...any) *gomock.Call

TopKQuery indicates an expected call of TopKQuery.

func (*MockRedisMockRecorder) TopKReserve added in v1.3.0 

func (mr *MockRedisMockRecorder) TopKReserve(ctx, key, k any) *gomock.Call

TopKReserve indicates an expected call of TopKReserve.

func (*MockRedisMockRecorder) TopKReserveWithOptions added in v1.3.0 

func (mr *MockRedisMockRecorder) TopKReserveWithOptions(ctx, key, k, width, depth, decay any) *gomock.Call

TopKReserveWithOptions indicates an expected call of TopKReserveWithOptions.

func (*MockRedisMockRecorder) Touch added in v1.3.0 

func (mr *MockRedisMockRecorder) Touch(ctx any, keys ...any) *gomock.Call

Touch indicates an expected call of Touch.

func (*MockRedisMockRecorder) TxPipeline added in v1.3.0 

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

TxPipeline indicates an expected call of TxPipeline.

func (*MockRedisMockRecorder) TxPipelined added in v1.3.0 

func (mr *MockRedisMockRecorder) TxPipelined(ctx, fn any) *gomock.Call

TxPipelined indicates an expected call of TxPipelined.

func (*MockRedisMockRecorder) Type added in v1.3.0 

func (mr *MockRedisMockRecorder) Type(ctx, key any) *gomock.Call

Type indicates an expected call of Type. 

func (mr *MockRedisMockRecorder) Unlink(ctx any, keys ...any) *gomock.Call

Unlink indicates an expected call of Unlink.

func (*MockRedisMockRecorder) XAck added in v1.3.0 

func (mr *MockRedisMockRecorder) XAck(ctx, stream, group any, ids ...any) *gomock.Call

XAck indicates an expected call of XAck.

func (*MockRedisMockRecorder) XAdd added in v1.3.0 

func (mr *MockRedisMockRecorder) XAdd(ctx, a any) *gomock.Call

XAdd indicates an expected call of XAdd.

func (*MockRedisMockRecorder) XAutoClaim added in v1.3.0 

func (mr *MockRedisMockRecorder) XAutoClaim(ctx, a any) *gomock.Call

XAutoClaim indicates an expected call of XAutoClaim.

func (*MockRedisMockRecorder) XAutoClaimJustID added in v1.3.0 

func (mr *MockRedisMockRecorder) XAutoClaimJustID(ctx, a any) *gomock.Call

XAutoClaimJustID indicates an expected call of XAutoClaimJustID.

func (*MockRedisMockRecorder) XClaim added in v1.3.0 

func (mr *MockRedisMockRecorder) XClaim(ctx, a any) *gomock.Call

XClaim indicates an expected call of XClaim.

func (*MockRedisMockRecorder) XClaimJustID added in v1.3.0 

func (mr *MockRedisMockRecorder) XClaimJustID(ctx, a any) *gomock.Call

XClaimJustID indicates an expected call of XClaimJustID.

func (*MockRedisMockRecorder) XDel added in v1.3.0 

func (mr *MockRedisMockRecorder) XDel(ctx, stream any, ids ...any) *gomock.Call

XDel indicates an expected call of XDel.

func (*MockRedisMockRecorder) XGroupCreate added in v1.3.0 

func (mr *MockRedisMockRecorder) XGroupCreate(ctx, stream, group, start any) *gomock.Call

XGroupCreate indicates an expected call of XGroupCreate.

func (*MockRedisMockRecorder) XGroupCreateConsumer added in v1.3.0 

func (mr *MockRedisMockRecorder) XGroupCreateConsumer(ctx, stream, group, consumer any) *gomock.Call

XGroupCreateConsumer indicates an expected call of XGroupCreateConsumer.

func (*MockRedisMockRecorder) XGroupCreateMkStream added in v1.3.0 

func (mr *MockRedisMockRecorder) XGroupCreateMkStream(ctx, stream, group, start any) *gomock.Call

XGroupCreateMkStream indicates an expected call of XGroupCreateMkStream.

func (*MockRedisMockRecorder) XGroupDelConsumer added in v1.3.0 

func (mr *MockRedisMockRecorder) XGroupDelConsumer(ctx, stream, group, consumer any) *gomock.Call

XGroupDelConsumer indicates an expected call of XGroupDelConsumer.

func (*MockRedisMockRecorder) XGroupDestroy added in v1.3.0 

func (mr *MockRedisMockRecorder) XGroupDestroy(ctx, stream, group any) *gomock.Call

XGroupDestroy indicates an expected call of XGroupDestroy.

func (*MockRedisMockRecorder) XGroupSetID added in v1.3.0 

func (mr *MockRedisMockRecorder) XGroupSetID(ctx, stream, group, start any) *gomock.Call

XGroupSetID indicates an expected call of XGroupSetID.

func (*MockRedisMockRecorder) XInfoConsumers added in v1.3.0 

func (mr *MockRedisMockRecorder) XInfoConsumers(ctx, key, group any) *gomock.Call

XInfoConsumers indicates an expected call of XInfoConsumers.

func (*MockRedisMockRecorder) XInfoGroups added in v1.3.0 

func (mr *MockRedisMockRecorder) XInfoGroups(ctx, key any) *gomock.Call

XInfoGroups indicates an expected call of XInfoGroups.

func (*MockRedisMockRecorder) XInfoStream added in v1.3.0 

func (mr *MockRedisMockRecorder) XInfoStream(ctx, key any) *gomock.Call

XInfoStream indicates an expected call of XInfoStream.

func (*MockRedisMockRecorder) XInfoStreamFull added in v1.3.0 

func (mr *MockRedisMockRecorder) XInfoStreamFull(ctx, key, count any) *gomock.Call

XInfoStreamFull indicates an expected call of XInfoStreamFull.

func (*MockRedisMockRecorder) XLen added in v1.3.0 

func (mr *MockRedisMockRecorder) XLen(ctx, stream any) *gomock.Call

XLen indicates an expected call of XLen.

func (*MockRedisMockRecorder) XPending added in v1.3.0 

func (mr *MockRedisMockRecorder) XPending(ctx, stream, group any) *gomock.Call

XPending indicates an expected call of XPending.

func (*MockRedisMockRecorder) XPendingExt added in v1.3.0 

func (mr *MockRedisMockRecorder) XPendingExt(ctx, a any) *gomock.Call

XPendingExt indicates an expected call of XPendingExt.

func (*MockRedisMockRecorder) XRange added in v1.3.0 

func (mr *MockRedisMockRecorder) XRange(ctx, stream, start, stop any) *gomock.Call

XRange indicates an expected call of XRange.

func (*MockRedisMockRecorder) XRangeN added in v1.3.0 

func (mr *MockRedisMockRecorder) XRangeN(ctx, stream, start, stop, count any) *gomock.Call

XRangeN indicates an expected call of XRangeN.

func (*MockRedisMockRecorder) XRead added in v1.3.0 

func (mr *MockRedisMockRecorder) XRead(ctx, a any) *gomock.Call

XRead indicates an expected call of XRead.

func (*MockRedisMockRecorder) XReadGroup added in v1.3.0 

func (mr *MockRedisMockRecorder) XReadGroup(ctx, a any) *gomock.Call

XReadGroup indicates an expected call of XReadGroup.

func (*MockRedisMockRecorder) XReadStreams added in v1.3.0 

func (mr *MockRedisMockRecorder) XReadStreams(ctx any, streams ...any) *gomock.Call

XReadStreams indicates an expected call of XReadStreams.

func (*MockRedisMockRecorder) XRevRange added in v1.3.0 

func (mr *MockRedisMockRecorder) XRevRange(ctx, stream, start, stop any) *gomock.Call

XRevRange indicates an expected call of XRevRange.

func (*MockRedisMockRecorder) XRevRangeN added in v1.3.0 

func (mr *MockRedisMockRecorder) XRevRangeN(ctx, stream, start, stop, count any) *gomock.Call

XRevRangeN indicates an expected call of XRevRangeN.

func (*MockRedisMockRecorder) XTrimMaxLen added in v1.3.0 

func (mr *MockRedisMockRecorder) XTrimMaxLen(ctx, key, maxLen any) *gomock.Call

XTrimMaxLen indicates an expected call of XTrimMaxLen.

func (*MockRedisMockRecorder) XTrimMaxLenApprox added in v1.3.0 

func (mr *MockRedisMockRecorder) XTrimMaxLenApprox(ctx, key, maxLen, limit any) *gomock.Call

XTrimMaxLenApprox indicates an expected call of XTrimMaxLenApprox.

func (*MockRedisMockRecorder) XTrimMinID added in v1.3.0 

func (mr *MockRedisMockRecorder) XTrimMinID(ctx, key, minID any) *gomock.Call

XTrimMinID indicates an expected call of XTrimMinID.

func (*MockRedisMockRecorder) XTrimMinIDApprox added in v1.3.0 

func (mr *MockRedisMockRecorder) XTrimMinIDApprox(ctx, key, minID, limit any) *gomock.Call

XTrimMinIDApprox indicates an expected call of XTrimMinIDApprox.

func (*MockRedisMockRecorder) ZAdd added in v1.3.0 

func (mr *MockRedisMockRecorder) ZAdd(ctx, key any, members ...any) *gomock.Call

ZAdd indicates an expected call of ZAdd.

func (*MockRedisMockRecorder) ZAddArgs added in v1.3.0 

func (mr *MockRedisMockRecorder) ZAddArgs(ctx, key, args any) *gomock.Call

ZAddArgs indicates an expected call of ZAddArgs.

func (*MockRedisMockRecorder) ZAddArgsIncr added in v1.3.0 

func (mr *MockRedisMockRecorder) ZAddArgsIncr(ctx, key, args any) *gomock.Call

ZAddArgsIncr indicates an expected call of ZAddArgsIncr.

func (*MockRedisMockRecorder) ZAddGT added in v1.3.0 

func (mr *MockRedisMockRecorder) ZAddGT(ctx, key any, members ...any) *gomock.Call

ZAddGT indicates an expected call of ZAddGT.

func (*MockRedisMockRecorder) ZAddLT added in v1.3.0 

func (mr *MockRedisMockRecorder) ZAddLT(ctx, key any, members ...any) *gomock.Call

ZAddLT indicates an expected call of ZAddLT.

func (*MockRedisMockRecorder) ZAddNX added in v1.3.0 

func (mr *MockRedisMockRecorder) ZAddNX(ctx, key any, members ...any) *gomock.Call

ZAddNX indicates an expected call of ZAddNX.

func (*MockRedisMockRecorder) ZAddXX added in v1.3.0 

func (mr *MockRedisMockRecorder) ZAddXX(ctx, key any, members ...any) *gomock.Call

ZAddXX indicates an expected call of ZAddXX.

func (*MockRedisMockRecorder) ZCard added in v1.3.0 

func (mr *MockRedisMockRecorder) ZCard(ctx, key any) *gomock.Call

ZCard indicates an expected call of ZCard.

func (*MockRedisMockRecorder) ZCount added in v1.3.0 

func (mr *MockRedisMockRecorder) ZCount(ctx, key, min, max any) *gomock.Call

ZCount indicates an expected call of ZCount.

func (*MockRedisMockRecorder) ZDiff added in v1.3.0 

func (mr *MockRedisMockRecorder) ZDiff(ctx any, keys ...any) *gomock.Call

ZDiff indicates an expected call of ZDiff.

func (*MockRedisMockRecorder) ZDiffStore added in v1.3.0 

func (mr *MockRedisMockRecorder) ZDiffStore(ctx, destination any, keys ...any) *gomock.Call

ZDiffStore indicates an expected call of ZDiffStore.

func (*MockRedisMockRecorder) ZDiffWithScores added in v1.3.0 

func (mr *MockRedisMockRecorder) ZDiffWithScores(ctx any, keys ...any) *gomock.Call

ZDiffWithScores indicates an expected call of ZDiffWithScores.

func (*MockRedisMockRecorder) ZIncrBy added in v1.3.0 

func (mr *MockRedisMockRecorder) ZIncrBy(ctx, key, increment, member any) *gomock.Call

ZIncrBy indicates an expected call of ZIncrBy.

func (*MockRedisMockRecorder) ZInter added in v1.3.0 

func (mr *MockRedisMockRecorder) ZInter(ctx, store any) *gomock.Call

ZInter indicates an expected call of ZInter.

func (*MockRedisMockRecorder) ZInterCard added in v1.3.0 

func (mr *MockRedisMockRecorder) ZInterCard(ctx, limit any, keys ...any) *gomock.Call

ZInterCard indicates an expected call of ZInterCard.

func (*MockRedisMockRecorder) ZInterStore added in v1.3.0 

func (mr *MockRedisMockRecorder) ZInterStore(ctx, destination, store any) *gomock.Call

ZInterStore indicates an expected call of ZInterStore.

func (*MockRedisMockRecorder) ZInterWithScores added in v1.3.0 

func (mr *MockRedisMockRecorder) ZInterWithScores(ctx, store any) *gomock.Call

ZInterWithScores indicates an expected call of ZInterWithScores.

func (*MockRedisMockRecorder) ZLexCount added in v1.3.0 

func (mr *MockRedisMockRecorder) ZLexCount(ctx, key, min, max any) *gomock.Call

ZLexCount indicates an expected call of ZLexCount.

func (*MockRedisMockRecorder) ZMPop added in v1.3.0 

func (mr *MockRedisMockRecorder) ZMPop(ctx, order, count any, keys ...any) *gomock.Call

ZMPop indicates an expected call of ZMPop.

func (*MockRedisMockRecorder) ZMScore added in v1.3.0 

func (mr *MockRedisMockRecorder) ZMScore(ctx, key any, members ...any) *gomock.Call

ZMScore indicates an expected call of ZMScore.

func (*MockRedisMockRecorder) ZPopMax added in v1.3.0 

func (mr *MockRedisMockRecorder) ZPopMax(ctx, key any, count ...any) *gomock.Call

ZPopMax indicates an expected call of ZPopMax.

func (*MockRedisMockRecorder) ZPopMin added in v1.3.0 

func (mr *MockRedisMockRecorder) ZPopMin(ctx, key any, count ...any) *gomock.Call

ZPopMin indicates an expected call of ZPopMin.

func (*MockRedisMockRecorder) ZRandMember added in v1.3.0 

func (mr *MockRedisMockRecorder) ZRandMember(ctx, key, count any) *gomock.Call

ZRandMember indicates an expected call of ZRandMember.

func (*MockRedisMockRecorder) ZRandMemberWithScores added in v1.3.0 

func (mr *MockRedisMockRecorder) ZRandMemberWithScores(ctx, key, count any) *gomock.Call

ZRandMemberWithScores indicates an expected call of ZRandMemberWithScores.

func (*MockRedisMockRecorder) ZRange added in v1.3.0 

func (mr *MockRedisMockRecorder) ZRange(ctx, key, start, stop any) *gomock.Call

ZRange indicates an expected call of ZRange.

func (*MockRedisMockRecorder) ZRangeArgs added in v1.3.0 

func (mr *MockRedisMockRecorder) ZRangeArgs(ctx, z any) *gomock.Call

ZRangeArgs indicates an expected call of ZRangeArgs.

func (*MockRedisMockRecorder) ZRangeArgsWithScores added in v1.3.0 

func (mr *MockRedisMockRecorder) ZRangeArgsWithScores(ctx, z any) *gomock.Call

ZRangeArgsWithScores indicates an expected call of ZRangeArgsWithScores.

func (*MockRedisMockRecorder) ZRangeByLex added in v1.3.0 

func (mr *MockRedisMockRecorder) ZRangeByLex(ctx, key, opt any) *gomock.Call

ZRangeByLex indicates an expected call of ZRangeByLex.

func (*MockRedisMockRecorder) ZRangeByScore added in v1.3.0 

func (mr *MockRedisMockRecorder) ZRangeByScore(ctx, key, opt any) *gomock.Call

ZRangeByScore indicates an expected call of ZRangeByScore.

func (*MockRedisMockRecorder) ZRangeByScoreWithScores added in v1.3.0 

func (mr *MockRedisMockRecorder) ZRangeByScoreWithScores(ctx, key, opt any) *gomock.Call

ZRangeByScoreWithScores indicates an expected call of ZRangeByScoreWithScores.

func (*MockRedisMockRecorder) ZRangeStore added in v1.3.0 

func (mr *MockRedisMockRecorder) ZRangeStore(ctx, dst, z any) *gomock.Call

ZRangeStore indicates an expected call of ZRangeStore.

func (*MockRedisMockRecorder) ZRangeWithScores added in v1.3.0 

func (mr *MockRedisMockRecorder) ZRangeWithScores(ctx, key, start, stop any) *gomock.Call

ZRangeWithScores indicates an expected call of ZRangeWithScores.

func (*MockRedisMockRecorder) ZRank added in v1.3.0 

func (mr *MockRedisMockRecorder) ZRank(ctx, key, member any) *gomock.Call

ZRank indicates an expected call of ZRank.

func (*MockRedisMockRecorder) ZRankWithScore added in v1.3.0 

func (mr *MockRedisMockRecorder) ZRankWithScore(ctx, key, member any) *gomock.Call

ZRankWithScore indicates an expected call of ZRankWithScore.

func (*MockRedisMockRecorder) ZRem added in v1.3.0 

func (mr *MockRedisMockRecorder) ZRem(ctx, key any, members ...any) *gomock.Call

ZRem indicates an expected call of ZRem.

func (*MockRedisMockRecorder) ZRemRangeByLex added in v1.3.0 

func (mr *MockRedisMockRecorder) ZRemRangeByLex(ctx, key, min, max any) *gomock.Call

ZRemRangeByLex indicates an expected call of ZRemRangeByLex.

func (*MockRedisMockRecorder) ZRemRangeByRank added in v1.3.0 

func (mr *MockRedisMockRecorder) ZRemRangeByRank(ctx, key, start, stop any) *gomock.Call

ZRemRangeByRank indicates an expected call of ZRemRangeByRank.

func (*MockRedisMockRecorder) ZRemRangeByScore added in v1.3.0 

func (mr *MockRedisMockRecorder) ZRemRangeByScore(ctx, key, min, max any) *gomock.Call

ZRemRangeByScore indicates an expected call of ZRemRangeByScore.

func (*MockRedisMockRecorder) ZRevRange added in v1.3.0 

func (mr *MockRedisMockRecorder) ZRevRange(ctx, key, start, stop any) *gomock.Call

ZRevRange indicates an expected call of ZRevRange.

func (*MockRedisMockRecorder) ZRevRangeByLex added in v1.3.0 

func (mr *MockRedisMockRecorder) ZRevRangeByLex(ctx, key, opt any) *gomock.Call

ZRevRangeByLex indicates an expected call of ZRevRangeByLex.

func (*MockRedisMockRecorder) ZRevRangeByScore added in v1.3.0 

func (mr *MockRedisMockRecorder) ZRevRangeByScore(ctx, key, opt any) *gomock.Call

ZRevRangeByScore indicates an expected call of ZRevRangeByScore.

func (*MockRedisMockRecorder) ZRevRangeByScoreWithScores added in v1.3.0 

func (mr *MockRedisMockRecorder) ZRevRangeByScoreWithScores(ctx, key, opt any) *gomock.Call

ZRevRangeByScoreWithScores indicates an expected call of ZRevRangeByScoreWithScores.

func (*MockRedisMockRecorder) ZRevRangeWithScores added in v1.3.0 

func (mr *MockRedisMockRecorder) ZRevRangeWithScores(ctx, key, start, stop any) *gomock.Call

ZRevRangeWithScores indicates an expected call of ZRevRangeWithScores.

func (*MockRedisMockRecorder) ZRevRank added in v1.3.0 

func (mr *MockRedisMockRecorder) ZRevRank(ctx, key, member any) *gomock.Call

ZRevRank indicates an expected call of ZRevRank.

func (*MockRedisMockRecorder) ZRevRankWithScore added in v1.3.0 

func (mr *MockRedisMockRecorder) ZRevRankWithScore(ctx, key, member any) *gomock.Call

ZRevRankWithScore indicates an expected call of ZRevRankWithScore.

func (*MockRedisMockRecorder) ZScan added in v1.3.0 

func (mr *MockRedisMockRecorder) ZScan(ctx, key, cursor, match, count any) *gomock.Call

ZScan indicates an expected call of ZScan.

func (*MockRedisMockRecorder) ZScore added in v1.3.0 

func (mr *MockRedisMockRecorder) ZScore(ctx, key, member any) *gomock.Call

ZScore indicates an expected call of ZScore.

func (*MockRedisMockRecorder) ZUnion added in v1.3.0 

func (mr *MockRedisMockRecorder) ZUnion(ctx, store any) *gomock.Call

ZUnion indicates an expected call of ZUnion.

func (*MockRedisMockRecorder) ZUnionStore added in v1.3.0 

func (mr *MockRedisMockRecorder) ZUnionStore(ctx, dest, store any) *gomock.Call

ZUnionStore indicates an expected call of ZUnionStore.

func (*MockRedisMockRecorder) ZUnionWithScores added in v1.3.0 

func (mr *MockRedisMockRecorder) ZUnionWithScores(ctx, store any) *gomock.Call

ZUnionWithScores indicates an expected call of ZUnionWithScores.

type MockTransaction added in v1.13.0 

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

MockTransaction is a mock of Transaction interface.

func NewMockTransaction added in v1.13.0 

func NewMockTransaction(ctrl *gomock.Controller) *MockTransaction

NewMockTransaction creates a new mock instance.

func (*MockTransaction) AbortTransaction added in v1.13.0 

func (m *MockTransaction) AbortTransaction(arg0 context.Context) error

AbortTransaction mocks base method.

func (*MockTransaction) CommitTransaction added in v1.13.0 

func (m *MockTransaction) CommitTransaction(arg0 context.Context) error

CommitTransaction mocks base method.

func (*MockTransaction) EXPECT added in v1.13.0 

func (m *MockTransaction) EXPECT() *MockTransactionMockRecorder

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

func (*MockTransaction) EndSession added in v1.13.0 

func (m *MockTransaction) EndSession(arg0 context.Context)

EndSession mocks base method.

func (*MockTransaction) StartTransaction added in v1.13.0 

func (m *MockTransaction) StartTransaction() error

StartTransaction mocks base method.

type MockTransactionMockRecorder added in v1.13.0 

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

MockTransactionMockRecorder is the mock recorder for MockTransaction.

func (*MockTransactionMockRecorder) AbortTransaction added in v1.13.0 

func (mr *MockTransactionMockRecorder) AbortTransaction(arg0 any) *gomock.Call

AbortTransaction indicates an expected call of AbortTransaction.

func (*MockTransactionMockRecorder) CommitTransaction added in v1.13.0 

func (mr *MockTransactionMockRecorder) CommitTransaction(arg0 any) *gomock.Call

CommitTransaction indicates an expected call of CommitTransaction.

func (*MockTransactionMockRecorder) EndSession added in v1.13.0 

func (mr *MockTransactionMockRecorder) EndSession(arg0 any) *gomock.Call

EndSession indicates an expected call of EndSession.

func (*MockTransactionMockRecorder) StartTransaction added in v1.13.0 

func (mr *MockTransactionMockRecorder) StartTransaction() *gomock.Call

StartTransaction indicates an expected call of StartTransaction.

type Mockprovider added in v1.12.0 

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

Mockprovider is a mock of provider interface.

func NewMockprovider added in v1.12.0 

func NewMockprovider(ctrl *gomock.Controller) *Mockprovider

NewMockprovider creates a new mock instance.

func (*Mockprovider) Connect added in v1.12.0 

func (m *Mockprovider) Connect()

Connect mocks base method.

func (*Mockprovider) EXPECT added in v1.12.0 

func (m *Mockprovider) EXPECT() *MockproviderMockRecorder

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

func (*Mockprovider) UseLogger added in v1.12.0 

func (m *Mockprovider) UseLogger(logger any)

UseLogger mocks base method.

func (*Mockprovider) UseMetrics added in v1.12.0 

func (m *Mockprovider) UseMetrics(metrics any)

UseMetrics mocks base method.

type MockproviderMockRecorder added in v1.12.0 

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

MockproviderMockRecorder is the mock recorder for Mockprovider.

func (*MockproviderMockRecorder) Connect added in v1.12.0 

func (mr *MockproviderMockRecorder) Connect() *gomock.Call

Connect indicates an expected call of Connect.

func (*MockproviderMockRecorder) UseLogger added in v1.12.0 

func (mr *MockproviderMockRecorder) UseLogger(logger any) *gomock.Call

UseLogger indicates an expected call of UseLogger.

func (*MockproviderMockRecorder) UseMetrics added in v1.12.0 

func (mr *MockproviderMockRecorder) UseMetrics(metrics any) *gomock.Call

UseMetrics indicates an expected call of UseMetrics.

type Mocks added in v1.3.0 

type Mocks struct {
	Redis      *MockRedis
	SQL        *MockDB
	Clickhouse *MockClickhouse
	Cassandra  *MockCassandra
	Mongo      *MockMongo
	KVStore    *MockKVStore
	File       *file.MockFileSystemProvider
}

type Mongo added in v1.12.0 

type Mongo interface {
	// Find executes a query to find documents in a collection based on a filter and stores the results
	// into the provided results interface.
	Find(ctx context.Context, collection string, filter interface{}, results interface{}) error

	// FindOne executes a query to find a single document in a collection based on a filter and stores the result
	// into the provided result interface.
	FindOne(ctx context.Context, collection string, filter interface{}, result interface{}) error

	// InsertOne inserts a single document into a collection.
	// It returns the identifier of the inserted document and an error, if any.
	InsertOne(ctx context.Context, collection string, document interface{}) (interface{}, error)

	// InsertMany inserts multiple documents into a collection.
	// It returns the identifiers of the inserted documents and an error, if any.
	InsertMany(ctx context.Context, collection string, documents []interface{}) ([]interface{}, error)

	// DeleteOne deletes a single document from a collection based on a filter.
	// It returns the number of documents deleted and an error, if any.
	DeleteOne(ctx context.Context, collection string, filter interface{}) (int64, error)

	// DeleteMany deletes multiple documents from a collection based on a filter.
	// It returns the number of documents deleted and an error, if any.
	DeleteMany(ctx context.Context, collection string, filter interface{}) (int64, error)

	// UpdateByID updates a document in a collection by its ID.
	// It returns the number of documents updated and an error if any.
	UpdateByID(ctx context.Context, collection string, id interface{}, update interface{}) (int64, error)

	// UpdateOne updates a single document in a collection based on a filter.
	// It returns an error if any.
	UpdateOne(ctx context.Context, collection string, filter interface{}, update interface{}) error

	// UpdateMany updates multiple documents in a collection based on a filter.
	// It returns the number of documents updated and an error if any.
	UpdateMany(ctx context.Context, collection string, filter interface{}, update interface{}) (int64, error)

	// CountDocuments counts the number of documents in a collection based on a filter.
	// It returns the count and an error if any.
	CountDocuments(ctx context.Context, collection string, filter interface{}) (int64, error)

	// Drop an entire collection from the database.
	// It returns an error if any.
	Drop(ctx context.Context, collection string) error

	// CreateCollection creates a new collection with specified name and default options.
	CreateCollection(ctx context.Context, name string) error

	// StartSession starts a session and provide methods to run commands in a transaction.
	StartSession() (interface{}, error)

	HealthChecker
}

Mongo is an interface representing a MongoDB database client with common CRUD operations.

type MongoProvider added in v1.12.0 

type MongoProvider interface {
	Mongo
	// contains filtered or unexported methods
}

MongoProvider is an interface that extends Mongo with additional methods for logging, metrics, and connection management. Which is used for initializing datasource.

type Redis added in v1.3.0 

type Redis interface {
	redis.Cmdable
	redis.HashCmdable
	HealthCheck() datasource.Health
	Close() error
}

type Transaction added in v1.13.0 

type Transaction interface {
	StartTransaction() error
	AbortTransaction(context.Context) error
	CommitTransaction(context.Context) error
	EndSession(context.Context)
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.