container

package
v0.0.2 Latest Latest
Warning

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

 Go to latest Published: Oct 2, 2024 License: Apache-2.0 Imports: 32 Imported by: 0

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 

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

func WithMockHTTPService 

func WithMockHTTPService(httpServiceNames ...string) options

Types

type Cassandra 

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 

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 

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

type Clickhouse 

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 

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
	Solr       Solr
	DGraph     Dgraph

	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 

func (c *Container) Close() error

func (*Container) Create 

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

func (*Container) GetAppName 

func (c *Container) GetAppName() string

func (*Container) GetAppVersion 

func (c *Container) GetAppVersion() string

func (*Container) GetConnectionFromContext 

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 

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

func (*Container) GetSubscriber 

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

func (*Container) Health 

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

func (*Container) Metrics 

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

type DB 

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

type Dgraph 

type Dgraph interface {
	// Query executes a read-only query in the Dgraph database and returns the result.
	// Parameters:
	// - ctx: The context for the query, used for controlling timeouts, cancellation, etc.
	// - query: The Dgraph query string in GraphQL+- format.
	// Returns:
	// - any: The result of the query, usually of type *api.Response.
	// - error: An error if the query execution fails.
	Query(ctx context.Context, query string) (any, error)

	// QueryWithVars executes a read-only query with variables in the Dgraph database.
	// Parameters:
	// - ctx: The context for the query.
	// - query: The Dgraph query string in GraphQL+- format.
	// - vars: A map of variables to be used within the query.
	// Returns:
	// - any: The result of the query with variables, usually of type *api.Response.
	// - error: An error if the query execution fails.
	QueryWithVars(ctx context.Context, query string, vars map[string]string) (any, error)

	// Mutate executes a write operation (mutation) in the Dgraph database and returns the result.
	// Parameters:
	// - ctx: The context for the mutation.
	// - mu: The mutation operation, usually of type *api.Mutation.
	// Returns:
	// - any: The result of the mutation, usually of type *api.Assigned.
	// - error: An error if the mutation execution fails.
	Mutate(ctx context.Context, mu any) (any, error)

	// Alter applies schema or other changes to the Dgraph database.
	// Parameters:
	// - ctx: The context for the alter operation.
	// - op: The alter operation, usually of type *api.Operation.
	// Returns:
	// - error: An error if the operation fails.
	Alter(ctx context.Context, op any) error

	// NewTxn creates a new transaction (read-write) for interacting with the Dgraph database.
	// Returns:
	// - any: A new transaction, usually of type *api.Txn.
	NewTxn() any

	// NewReadOnlyTxn creates a new read-only transaction for querying the Dgraph database.
	// Returns:
	// - any: A new read-only transaction, usually of type *api.Txn.
	NewReadOnlyTxn() any

	// HealthChecker checks the health of the Dgraph instance, ensuring it is up and running.
	// Returns:
	// - error: An error if the health check fails.
	HealthChecker
}

Dgraph defines the methods for interacting with a Dgraph database.

type DgraphProvider 

type DgraphProvider interface {
	Dgraph
	// contains filtered or unexported methods
}

DgraphProvider extends Dgraph with connection management capabilities.

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 

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 

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

type Metrics 

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 

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

MockCassandra is a mock of Cassandra interface.

func NewMockCassandra 

func NewMockCassandra(ctrl *gomock.Controller) *MockCassandra

NewMockCassandra creates a new mock instance.

func (*MockCassandra) BatchQuery 

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

BatchQuery mocks base method.

func (*MockCassandra) EXPECT 

func (m *MockCassandra) EXPECT() *MockCassandraMockRecorder

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

func (*MockCassandra) Exec 

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

Exec mocks base method.

func (*MockCassandra) ExecCAS 

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

ExecCAS mocks base method.

func (*MockCassandra) ExecuteBatch 

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

ExecuteBatch mocks base method.

func (*MockCassandra) ExecuteBatchCAS 

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

ExecuteBatchCAS mocks base method.

func (*MockCassandra) HealthCheck 

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

HealthCheck mocks base method.

func (*MockCassandra) NewBatch 

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

NewBatch mocks base method.

func (*MockCassandra) Query 

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

Query mocks base method.

type MockCassandraBatch 

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

MockCassandraBatch is a mock of CassandraBatch interface.

func NewMockCassandraBatch 

func NewMockCassandraBatch(ctrl *gomock.Controller) *MockCassandraBatch

NewMockCassandraBatch creates a new mock instance.

func (*MockCassandraBatch) BatchQuery 

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

BatchQuery mocks base method.

func (*MockCassandraBatch) EXPECT 

func (m *MockCassandraBatch) EXPECT() *MockCassandraBatchMockRecorder

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

func (*MockCassandraBatch) ExecuteBatch 

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

ExecuteBatch mocks base method.

func (*MockCassandraBatch) ExecuteBatchCAS 

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

ExecuteBatchCAS mocks base method.

type MockCassandraBatchMockRecorder 

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

MockCassandraBatchMockRecorder is the mock recorder for MockCassandraBatch.

func (*MockCassandraBatchMockRecorder) BatchQuery 

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

BatchQuery indicates an expected call of BatchQuery.

func (*MockCassandraBatchMockRecorder) ExecuteBatch 

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

ExecuteBatch indicates an expected call of ExecuteBatch.

func (*MockCassandraBatchMockRecorder) ExecuteBatchCAS 

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

ExecuteBatchCAS indicates an expected call of ExecuteBatchCAS.

type MockCassandraMockRecorder 

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

MockCassandraMockRecorder is the mock recorder for MockCassandra.

func (*MockCassandraMockRecorder) BatchQuery 

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

BatchQuery indicates an expected call of BatchQuery.

func (*MockCassandraMockRecorder) Exec 

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

Exec indicates an expected call of Exec.

func (*MockCassandraMockRecorder) ExecCAS 

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

ExecCAS indicates an expected call of ExecCAS.

func (*MockCassandraMockRecorder) ExecuteBatch 

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

ExecuteBatch indicates an expected call of ExecuteBatch.

func (*MockCassandraMockRecorder) ExecuteBatchCAS 

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

ExecuteBatchCAS indicates an expected call of ExecuteBatchCAS.

func (*MockCassandraMockRecorder) HealthCheck 

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

HealthCheck indicates an expected call of HealthCheck.

func (*MockCassandraMockRecorder) NewBatch 

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

NewBatch indicates an expected call of NewBatch.

func (*MockCassandraMockRecorder) Query 

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

Query indicates an expected call of Query.

type MockCassandraProvider 

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

MockCassandraProvider is a mock of CassandraProvider interface.

func NewMockCassandraProvider 

func NewMockCassandraProvider(ctrl *gomock.Controller) *MockCassandraProvider

NewMockCassandraProvider creates a new mock instance.

func (*MockCassandraProvider) BatchQuery 

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

BatchQuery mocks base method.

func (*MockCassandraProvider) Connect 

func (m *MockCassandraProvider) Connect()

Connect mocks base method.

func (*MockCassandraProvider) EXPECT 

func (m *MockCassandraProvider) EXPECT() *MockCassandraProviderMockRecorder

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

func (*MockCassandraProvider) Exec 

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

Exec mocks base method.

func (*MockCassandraProvider) ExecCAS 

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

ExecCAS mocks base method.

func (*MockCassandraProvider) ExecuteBatch 

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

ExecuteBatch mocks base method.

func (*MockCassandraProvider) ExecuteBatchCAS 

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

ExecuteBatchCAS mocks base method.

func (*MockCassandraProvider) HealthCheck 

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

HealthCheck mocks base method.

func (*MockCassandraProvider) NewBatch 

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

NewBatch mocks base method.

func (*MockCassandraProvider) Query 

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

Query mocks base method.

func (*MockCassandraProvider) UseLogger 

func (m *MockCassandraProvider) UseLogger(logger any)

UseLogger mocks base method.

func (*MockCassandraProvider) UseMetrics 

func (m *MockCassandraProvider) UseMetrics(metrics any)

UseMetrics mocks base method.

func (*MockCassandraProvider) UseTracer 

func (m *MockCassandraProvider) UseTracer(tracer any)

UseTracer mocks base method.

type MockCassandraProviderMockRecorder 

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

MockCassandraProviderMockRecorder is the mock recorder for MockCassandraProvider.

func (*MockCassandraProviderMockRecorder) BatchQuery 

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

BatchQuery indicates an expected call of BatchQuery.

func (*MockCassandraProviderMockRecorder) Connect 

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

Connect indicates an expected call of Connect.

func (*MockCassandraProviderMockRecorder) Exec 

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

Exec indicates an expected call of Exec.

func (*MockCassandraProviderMockRecorder) ExecCAS 

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

ExecCAS indicates an expected call of ExecCAS.

func (*MockCassandraProviderMockRecorder) ExecuteBatch 

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

ExecuteBatch indicates an expected call of ExecuteBatch.

func (*MockCassandraProviderMockRecorder) ExecuteBatchCAS 

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

ExecuteBatchCAS indicates an expected call of ExecuteBatchCAS.

func (*MockCassandraProviderMockRecorder) HealthCheck 

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

HealthCheck indicates an expected call of HealthCheck.

func (*MockCassandraProviderMockRecorder) NewBatch 

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

NewBatch indicates an expected call of NewBatch.

func (*MockCassandraProviderMockRecorder) Query 

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

Query indicates an expected call of Query.

func (*MockCassandraProviderMockRecorder) UseLogger 

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

UseLogger indicates an expected call of UseLogger.

func (*MockCassandraProviderMockRecorder) UseMetrics 

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

UseMetrics indicates an expected call of UseMetrics.

func (*MockCassandraProviderMockRecorder) UseTracer 

func (mr *MockCassandraProviderMockRecorder) UseTracer(tracer any) *gomock.Call

UseTracer indicates an expected call of UseTracer.

type MockClickhouse 

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

MockClickhouse is a mock of Clickhouse interface.

func NewMockClickhouse 

func NewMockClickhouse(ctrl *gomock.Controller) *MockClickhouse

NewMockClickhouse creates a new mock instance.

func (*MockClickhouse) AsyncInsert 

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

AsyncInsert mocks base method.

func (*MockClickhouse) EXPECT 

func (m *MockClickhouse) EXPECT() *MockClickhouseMockRecorder

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

func (*MockClickhouse) Exec 

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

Exec mocks base method.

func (*MockClickhouse) HealthCheck 

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

HealthCheck mocks base method.

func (*MockClickhouse) Select 

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

Select mocks base method.

type MockClickhouseMockRecorder 

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

MockClickhouseMockRecorder is the mock recorder for MockClickhouse.

func (*MockClickhouseMockRecorder) AsyncInsert 

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

AsyncInsert indicates an expected call of AsyncInsert.

func (*MockClickhouseMockRecorder) Exec 

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

Exec indicates an expected call of Exec.

func (*MockClickhouseMockRecorder) HealthCheck 

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

HealthCheck indicates an expected call of HealthCheck.

func (*MockClickhouseMockRecorder) Select 

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

Select indicates an expected call of Select.

type MockClickhouseProvider 

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

MockClickhouseProvider is a mock of ClickhouseProvider interface.

func NewMockClickhouseProvider 

func NewMockClickhouseProvider(ctrl *gomock.Controller) *MockClickhouseProvider

NewMockClickhouseProvider creates a new mock instance.

func (*MockClickhouseProvider) AsyncInsert 

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

AsyncInsert mocks base method.

func (*MockClickhouseProvider) Connect 

func (m *MockClickhouseProvider) Connect()

Connect mocks base method.

func (*MockClickhouseProvider) EXPECT 

func (m *MockClickhouseProvider) EXPECT() *MockClickhouseProviderMockRecorder

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

func (*MockClickhouseProvider) Exec 

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

Exec mocks base method.

func (*MockClickhouseProvider) HealthCheck 

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

HealthCheck mocks base method.

func (*MockClickhouseProvider) Select 

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

Select mocks base method.

func (*MockClickhouseProvider) UseLogger 

func (m *MockClickhouseProvider) UseLogger(logger any)

UseLogger mocks base method.

func (*MockClickhouseProvider) UseMetrics 

func (m *MockClickhouseProvider) UseMetrics(metrics any)

UseMetrics mocks base method.

func (*MockClickhouseProvider) UseTracer 

func (m *MockClickhouseProvider) UseTracer(tracer any)

UseTracer mocks base method.

type MockClickhouseProviderMockRecorder 

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

MockClickhouseProviderMockRecorder is the mock recorder for MockClickhouseProvider.

func (*MockClickhouseProviderMockRecorder) AsyncInsert 

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

AsyncInsert indicates an expected call of AsyncInsert.

func (*MockClickhouseProviderMockRecorder) Connect 

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

Connect indicates an expected call of Connect.

func (*MockClickhouseProviderMockRecorder) Exec 

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

Exec indicates an expected call of Exec.

func (*MockClickhouseProviderMockRecorder) HealthCheck 

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

HealthCheck indicates an expected call of HealthCheck.

func (*MockClickhouseProviderMockRecorder) Select 

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

Select indicates an expected call of Select.

func (*MockClickhouseProviderMockRecorder) UseLogger 

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

UseLogger indicates an expected call of UseLogger.

func (*MockClickhouseProviderMockRecorder) UseMetrics 

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

UseMetrics indicates an expected call of UseMetrics.

func (*MockClickhouseProviderMockRecorder) UseTracer 

func (mr *MockClickhouseProviderMockRecorder) UseTracer(tracer any) *gomock.Call

UseTracer indicates an expected call of UseTracer.

type MockDB 

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

MockDB is a mock of DB interface.

func NewMockDB 

func NewMockDB(ctrl *gomock.Controller) *MockDB

NewMockDB creates a new mock instance.

func (*MockDB) Begin 

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

Begin mocks base method.

func (*MockDB) Close 

func (m *MockDB) Close() error

Close mocks base method.

func (*MockDB) Dialect 

func (m *MockDB) Dialect() string

Dialect mocks base method.

func (*MockDB) EXPECT 

func (m *MockDB) EXPECT() *MockDBMockRecorder

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

func (*MockDB) Exec 

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

Exec mocks base method.

func (*MockDB) ExecContext 

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

ExecContext mocks base method.

func (*MockDB) HealthCheck 

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

HealthCheck mocks base method.

func (*MockDB) Prepare 

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

Prepare mocks base method.

func (*MockDB) Query 

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

Query mocks base method.

func (*MockDB) QueryContext 

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

QueryContext mocks base method.

func (*MockDB) QueryRow 

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

QueryRow mocks base method.

func (*MockDB) QueryRowContext 

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

QueryRowContext mocks base method.

func (*MockDB) Select 

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

Select mocks base method.

type MockDBMockRecorder 

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

MockDBMockRecorder is the mock recorder for MockDB.

func (*MockDBMockRecorder) Begin 

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

Begin indicates an expected call of Begin.

func (*MockDBMockRecorder) Close 

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

Close indicates an expected call of Close.

func (*MockDBMockRecorder) Dialect 

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

Dialect indicates an expected call of Dialect.

func (*MockDBMockRecorder) Exec 

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

Exec indicates an expected call of Exec.

func (*MockDBMockRecorder) ExecContext 

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

ExecContext indicates an expected call of ExecContext.

func (*MockDBMockRecorder) HealthCheck 

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

HealthCheck indicates an expected call of HealthCheck.

func (*MockDBMockRecorder) Prepare 

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

Prepare indicates an expected call of Prepare.

func (*MockDBMockRecorder) Query 

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

Query indicates an expected call of Query.

func (*MockDBMockRecorder) QueryContext 

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

QueryContext indicates an expected call of QueryContext.

func (*MockDBMockRecorder) QueryRow 

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

QueryRow indicates an expected call of QueryRow.

func (*MockDBMockRecorder) QueryRowContext 

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

QueryRowContext indicates an expected call of QueryRowContext.

func (*MockDBMockRecorder) Select 

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

Select indicates an expected call of Select.

type MockDgraph 

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

MockDgraph is a mock of Dgraph interface.

func NewMockDgraph 

func NewMockDgraph(ctrl *gomock.Controller) *MockDgraph

NewMockDgraph creates a new mock instance.

func (*MockDgraph) Alter 

func (m *MockDgraph) Alter(ctx context.Context, op any) error

Alter mocks base method.

func (*MockDgraph) EXPECT 

func (m *MockDgraph) EXPECT() *MockDgraphMockRecorder

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

func (*MockDgraph) HealthCheck 

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

HealthCheck mocks base method.

func (*MockDgraph) Mutate 

func (m *MockDgraph) Mutate(ctx context.Context, mu any) (any, error)

Mutate mocks base method.

func (*MockDgraph) NewReadOnlyTxn 

func (m *MockDgraph) NewReadOnlyTxn() any

NewReadOnlyTxn mocks base method.

func (*MockDgraph) NewTxn 

func (m *MockDgraph) NewTxn() any

NewTxn mocks base method.

func (*MockDgraph) Query 

func (m *MockDgraph) Query(ctx context.Context, query string) (any, error)

Query mocks base method.

func (*MockDgraph) QueryWithVars 

func (m *MockDgraph) QueryWithVars(ctx context.Context, query string, vars map[string]string) (any, error)

QueryWithVars mocks base method.

type MockDgraphMockRecorder 

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

MockDgraphMockRecorder is the mock recorder for MockDgraph.

func (*MockDgraphMockRecorder) Alter 

func (mr *MockDgraphMockRecorder) Alter(ctx, op any) *gomock.Call

Alter indicates an expected call of Alter.

func (*MockDgraphMockRecorder) HealthCheck 

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

HealthCheck indicates an expected call of HealthCheck.

func (*MockDgraphMockRecorder) Mutate 

func (mr *MockDgraphMockRecorder) Mutate(ctx, mu any) *gomock.Call

Mutate indicates an expected call of Mutate.

func (*MockDgraphMockRecorder) NewReadOnlyTxn 

func (mr *MockDgraphMockRecorder) NewReadOnlyTxn() *gomock.Call

NewReadOnlyTxn indicates an expected call of NewReadOnlyTxn.

func (*MockDgraphMockRecorder) NewTxn 

func (mr *MockDgraphMockRecorder) NewTxn() *gomock.Call

NewTxn indicates an expected call of NewTxn.

func (*MockDgraphMockRecorder) Query 

func (mr *MockDgraphMockRecorder) Query(ctx, query any) *gomock.Call

Query indicates an expected call of Query.

func (*MockDgraphMockRecorder) QueryWithVars 

func (mr *MockDgraphMockRecorder) QueryWithVars(ctx, query, vars any) *gomock.Call

QueryWithVars indicates an expected call of QueryWithVars.

type MockDgraphProvider 

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

MockDgraphProvider is a mock of DgraphProvider interface.

func NewMockDgraphProvider 

func NewMockDgraphProvider(ctrl *gomock.Controller) *MockDgraphProvider

NewMockDgraphProvider creates a new mock instance.

func (*MockDgraphProvider) Alter 

func (m *MockDgraphProvider) Alter(ctx context.Context, op any) error

Alter mocks base method.

func (*MockDgraphProvider) Connect 

func (m *MockDgraphProvider) Connect()

Connect mocks base method.

func (*MockDgraphProvider) EXPECT 

func (m *MockDgraphProvider) EXPECT() *MockDgraphProviderMockRecorder

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

func (*MockDgraphProvider) HealthCheck 

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

HealthCheck mocks base method.

func (*MockDgraphProvider) Mutate 

func (m *MockDgraphProvider) Mutate(ctx context.Context, mu any) (any, error)

Mutate mocks base method.

func (*MockDgraphProvider) NewReadOnlyTxn 

func (m *MockDgraphProvider) NewReadOnlyTxn() any

NewReadOnlyTxn mocks base method.

func (*MockDgraphProvider) NewTxn 

func (m *MockDgraphProvider) NewTxn() any

NewTxn mocks base method.

func (*MockDgraphProvider) Query 

func (m *MockDgraphProvider) Query(ctx context.Context, query string) (any, error)

Query mocks base method.

func (*MockDgraphProvider) QueryWithVars 

func (m *MockDgraphProvider) QueryWithVars(ctx context.Context, query string, vars map[string]string) (any, error)

QueryWithVars mocks base method.

func (*MockDgraphProvider) UseLogger 

func (m *MockDgraphProvider) UseLogger(logger any)

UseLogger mocks base method.

func (*MockDgraphProvider) UseMetrics 

func (m *MockDgraphProvider) UseMetrics(metrics any)

UseMetrics mocks base method.

func (*MockDgraphProvider) UseTracer 

func (m *MockDgraphProvider) UseTracer(tracer any)

UseTracer mocks base method.

type MockDgraphProviderMockRecorder 

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

MockDgraphProviderMockRecorder is the mock recorder for MockDgraphProvider.

func (*MockDgraphProviderMockRecorder) Alter 

func (mr *MockDgraphProviderMockRecorder) Alter(ctx, op any) *gomock.Call

Alter indicates an expected call of Alter.

func (*MockDgraphProviderMockRecorder) Connect 

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

Connect indicates an expected call of Connect.

func (*MockDgraphProviderMockRecorder) HealthCheck 

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

HealthCheck indicates an expected call of HealthCheck.

func (*MockDgraphProviderMockRecorder) Mutate 

func (mr *MockDgraphProviderMockRecorder) Mutate(ctx, mu any) *gomock.Call

Mutate indicates an expected call of Mutate.

func (*MockDgraphProviderMockRecorder) NewReadOnlyTxn 

func (mr *MockDgraphProviderMockRecorder) NewReadOnlyTxn() *gomock.Call

NewReadOnlyTxn indicates an expected call of NewReadOnlyTxn.

func (*MockDgraphProviderMockRecorder) NewTxn 

func (mr *MockDgraphProviderMockRecorder) NewTxn() *gomock.Call

NewTxn indicates an expected call of NewTxn.

func (*MockDgraphProviderMockRecorder) Query 

func (mr *MockDgraphProviderMockRecorder) Query(ctx, query any) *gomock.Call

Query indicates an expected call of Query.

func (*MockDgraphProviderMockRecorder) QueryWithVars 

func (mr *MockDgraphProviderMockRecorder) QueryWithVars(ctx, query, vars any) *gomock.Call

QueryWithVars indicates an expected call of QueryWithVars.

func (*MockDgraphProviderMockRecorder) UseLogger 

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

UseLogger indicates an expected call of UseLogger.

func (*MockDgraphProviderMockRecorder) UseMetrics 

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

UseMetrics indicates an expected call of UseMetrics.

func (*MockDgraphProviderMockRecorder) UseTracer 

func (mr *MockDgraphProviderMockRecorder) UseTracer(tracer any) *gomock.Call

UseTracer indicates an expected call of UseTracer.

type MockHealthChecker 

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

MockHealthChecker is a mock of HealthChecker interface.

func NewMockHealthChecker 

func NewMockHealthChecker(ctrl *gomock.Controller) *MockHealthChecker

NewMockHealthChecker creates a new mock instance.

func (*MockHealthChecker) EXPECT 

func (m *MockHealthChecker) EXPECT() *MockHealthCheckerMockRecorder

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

func (*MockHealthChecker) HealthCheck 

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

HealthCheck mocks base method.

type MockHealthCheckerMockRecorder 

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

MockHealthCheckerMockRecorder is the mock recorder for MockHealthChecker.

func (*MockHealthCheckerMockRecorder) HealthCheck 

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

HealthCheck indicates an expected call of HealthCheck.

type MockKVStore 

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

MockKVStore is a mock of KVStore interface.

func NewMockKVStore 

func NewMockKVStore(ctrl *gomock.Controller) *MockKVStore

NewMockKVStore creates a new mock instance.

func (*MockKVStore) Delete 

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

Delete mocks base method.

func (*MockKVStore) EXPECT 

func (m *MockKVStore) EXPECT() *MockKVStoreMockRecorder

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

func (*MockKVStore) Get 

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

Get mocks base method.

func (*MockKVStore) HealthCheck 

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

HealthCheck mocks base method.

func (*MockKVStore) Set 

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

Set mocks base method.

type MockKVStoreMockRecorder 

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

MockKVStoreMockRecorder is the mock recorder for MockKVStore.

func (*MockKVStoreMockRecorder) Delete 

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

Delete indicates an expected call of Delete.

func (*MockKVStoreMockRecorder) Get 

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

Get indicates an expected call of Get.

func (*MockKVStoreMockRecorder) HealthCheck 

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

HealthCheck indicates an expected call of HealthCheck.

func (*MockKVStoreMockRecorder) Set 

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

Set indicates an expected call of Set.

type MockKVStoreProvider 

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

MockKVStoreProvider is a mock of KVStoreProvider interface.

func NewMockKVStoreProvider 

func NewMockKVStoreProvider(ctrl *gomock.Controller) *MockKVStoreProvider

NewMockKVStoreProvider creates a new mock instance.

func (*MockKVStoreProvider) Connect 

func (m *MockKVStoreProvider) Connect()

Connect mocks base method.

func (*MockKVStoreProvider) Delete 

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

Delete mocks base method.

func (*MockKVStoreProvider) EXPECT 

func (m *MockKVStoreProvider) EXPECT() *MockKVStoreProviderMockRecorder

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

func (*MockKVStoreProvider) Get 

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

Get mocks base method.

func (*MockKVStoreProvider) HealthCheck 

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

HealthCheck mocks base method.

func (*MockKVStoreProvider) Set 

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

Set mocks base method.

func (*MockKVStoreProvider) UseLogger 

func (m *MockKVStoreProvider) UseLogger(logger any)

UseLogger mocks base method.

func (*MockKVStoreProvider) UseMetrics 

func (m *MockKVStoreProvider) UseMetrics(metrics any)

UseMetrics mocks base method.

func (*MockKVStoreProvider) UseTracer 

func (m *MockKVStoreProvider) UseTracer(tracer any)

UseTracer mocks base method.

type MockKVStoreProviderMockRecorder 

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

MockKVStoreProviderMockRecorder is the mock recorder for MockKVStoreProvider.

func (*MockKVStoreProviderMockRecorder) Connect 

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

Connect indicates an expected call of Connect.

func (*MockKVStoreProviderMockRecorder) Delete 

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

Delete indicates an expected call of Delete.

func (*MockKVStoreProviderMockRecorder) Get 

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

Get indicates an expected call of Get.

func (*MockKVStoreProviderMockRecorder) HealthCheck 

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

HealthCheck indicates an expected call of HealthCheck.

func (*MockKVStoreProviderMockRecorder) Set 

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

Set indicates an expected call of Set.

func (*MockKVStoreProviderMockRecorder) UseLogger 

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

UseLogger indicates an expected call of UseLogger.

func (*MockKVStoreProviderMockRecorder) UseMetrics 

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

UseMetrics indicates an expected call of UseMetrics.

func (*MockKVStoreProviderMockRecorder) UseTracer 

func (mr *MockKVStoreProviderMockRecorder) UseTracer(tracer any) *gomock.Call

UseTracer indicates an expected call of UseTracer.

type MockMetrics 

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

MockMetrics is a mock of Metrics interface.

func NewMockMetrics 

func NewMockMetrics(ctrl *gomock.Controller) *MockMetrics

NewMockMetrics creates a new mock instance.

func (*MockMetrics) DeltaUpDownCounter 

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

DeltaUpDownCounter mocks base method.

func (*MockMetrics) EXPECT 

func (m *MockMetrics) EXPECT() *MockMetricsMockRecorder

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

func (*MockMetrics) IncrementCounter 

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

IncrementCounter mocks base method.

func (*MockMetrics) NewCounter 

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

NewCounter mocks base method.

func (*MockMetrics) NewGauge 

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

NewGauge mocks base method.

func (*MockMetrics) NewHistogram 

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

NewHistogram mocks base method.

func (*MockMetrics) NewUpDownCounter 

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

NewUpDownCounter mocks base method.

func (*MockMetrics) RecordHistogram 

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

RecordHistogram mocks base method.

func (*MockMetrics) SetGauge 

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

SetGauge mocks base method.

type MockMetricsMockRecorder 

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

MockMetricsMockRecorder is the mock recorder for MockMetrics.

func (*MockMetricsMockRecorder) DeltaUpDownCounter 

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

DeltaUpDownCounter indicates an expected call of DeltaUpDownCounter.

func (*MockMetricsMockRecorder) IncrementCounter 

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

IncrementCounter indicates an expected call of IncrementCounter.

func (*MockMetricsMockRecorder) NewCounter 

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

NewCounter indicates an expected call of NewCounter.

func (*MockMetricsMockRecorder) NewGauge 

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

NewGauge indicates an expected call of NewGauge.

func (*MockMetricsMockRecorder) NewHistogram 

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

NewHistogram indicates an expected call of NewHistogram.

func (*MockMetricsMockRecorder) NewUpDownCounter 

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

NewUpDownCounter indicates an expected call of NewUpDownCounter.

func (*MockMetricsMockRecorder) RecordHistogram 

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

RecordHistogram indicates an expected call of RecordHistogram.

func (*MockMetricsMockRecorder) SetGauge 

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

SetGauge indicates an expected call of SetGauge.

type MockMongo 

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

MockMongo is a mock of Mongo interface.

func NewMockMongo 

func NewMockMongo(ctrl *gomock.Controller) *MockMongo

NewMockMongo creates a new mock instance.

func (*MockMongo) CountDocuments 

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

CountDocuments mocks base method.

func (*MockMongo) CreateCollection 

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

CreateCollection mocks base method.

func (*MockMongo) DeleteMany 

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

DeleteMany mocks base method.

func (*MockMongo) DeleteOne 

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

DeleteOne mocks base method.

func (*MockMongo) Drop 

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

Drop mocks base method.

func (*MockMongo) EXPECT 

func (m *MockMongo) EXPECT() *MockMongoMockRecorder

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

func (*MockMongo) Find 

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

Find mocks base method.

func (*MockMongo) FindOne 

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

FindOne mocks base method.

func (*MockMongo) HealthCheck 

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

HealthCheck mocks base method.

func (*MockMongo) InsertMany 

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

InsertMany mocks base method.

func (*MockMongo) InsertOne 

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

InsertOne mocks base method.

func (*MockMongo) StartSession 

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

StartSession mocks base method.

func (*MockMongo) UpdateByID 

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

UpdateByID mocks base method.

func (*MockMongo) UpdateMany 

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

UpdateMany mocks base method.

func (*MockMongo) UpdateOne 

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

UpdateOne mocks base method.

type MockMongoMockRecorder 

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

MockMongoMockRecorder is the mock recorder for MockMongo.

func (*MockMongoMockRecorder) CountDocuments 

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

CountDocuments indicates an expected call of CountDocuments.

func (*MockMongoMockRecorder) CreateCollection 

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

CreateCollection indicates an expected call of CreateCollection.

func (*MockMongoMockRecorder) DeleteMany 

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

DeleteMany indicates an expected call of DeleteMany.

func (*MockMongoMockRecorder) DeleteOne 

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

DeleteOne indicates an expected call of DeleteOne.

func (*MockMongoMockRecorder) Drop 

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

Drop indicates an expected call of Drop.

func (*MockMongoMockRecorder) Find 

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

Find indicates an expected call of Find.

func (*MockMongoMockRecorder) FindOne 

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

FindOne indicates an expected call of FindOne.

func (*MockMongoMockRecorder) HealthCheck 

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

HealthCheck indicates an expected call of HealthCheck.

func (*MockMongoMockRecorder) InsertMany 

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

InsertMany indicates an expected call of InsertMany.

func (*MockMongoMockRecorder) InsertOne 

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

InsertOne indicates an expected call of InsertOne.

func (*MockMongoMockRecorder) StartSession 

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

StartSession indicates an expected call of StartSession.

func (*MockMongoMockRecorder) UpdateByID 

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

UpdateByID indicates an expected call of UpdateByID.

func (*MockMongoMockRecorder) UpdateMany 

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

UpdateMany indicates an expected call of UpdateMany.

func (*MockMongoMockRecorder) UpdateOne 

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

UpdateOne indicates an expected call of UpdateOne.

type MockMongoProvider 

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

MockMongoProvider is a mock of MongoProvider interface.

func NewMockMongoProvider 

func NewMockMongoProvider(ctrl *gomock.Controller) *MockMongoProvider

NewMockMongoProvider creates a new mock instance.

func (*MockMongoProvider) Connect 

func (m *MockMongoProvider) Connect()

Connect mocks base method.

func (*MockMongoProvider) CountDocuments 

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

CountDocuments mocks base method.

func (*MockMongoProvider) CreateCollection 

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

CreateCollection mocks base method.

func (*MockMongoProvider) DeleteMany 

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

DeleteMany mocks base method.

func (*MockMongoProvider) DeleteOne 

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

DeleteOne mocks base method.

func (*MockMongoProvider) Drop 

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

Drop mocks base method.

func (*MockMongoProvider) EXPECT 

func (m *MockMongoProvider) EXPECT() *MockMongoProviderMockRecorder

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

func (*MockMongoProvider) Find 

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

Find mocks base method.

func (*MockMongoProvider) FindOne 

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

FindOne mocks base method.

func (*MockMongoProvider) HealthCheck 

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

HealthCheck mocks base method.

func (*MockMongoProvider) InsertMany 

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

InsertMany mocks base method.

func (*MockMongoProvider) InsertOne 

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

InsertOne mocks base method.

func (*MockMongoProvider) StartSession 

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

StartSession mocks base method.

func (*MockMongoProvider) UpdateByID 

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

UpdateByID mocks base method.

func (*MockMongoProvider) UpdateMany 

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

UpdateMany mocks base method.

func (*MockMongoProvider) UpdateOne 

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

UpdateOne mocks base method.

func (*MockMongoProvider) UseLogger 

func (m *MockMongoProvider) UseLogger(logger any)

UseLogger mocks base method.

func (*MockMongoProvider) UseMetrics 

func (m *MockMongoProvider) UseMetrics(metrics any)

UseMetrics mocks base method.

func (*MockMongoProvider) UseTracer 

func (m *MockMongoProvider) UseTracer(tracer any)

UseTracer mocks base method.

type MockMongoProviderMockRecorder 

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

MockMongoProviderMockRecorder is the mock recorder for MockMongoProvider.

func (*MockMongoProviderMockRecorder) Connect 

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

Connect indicates an expected call of Connect.

func (*MockMongoProviderMockRecorder) CountDocuments 

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

CountDocuments indicates an expected call of CountDocuments.

func (*MockMongoProviderMockRecorder) CreateCollection 

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

CreateCollection indicates an expected call of CreateCollection.

func (*MockMongoProviderMockRecorder) DeleteMany 

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

DeleteMany indicates an expected call of DeleteMany.

func (*MockMongoProviderMockRecorder) DeleteOne 

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

DeleteOne indicates an expected call of DeleteOne.

func (*MockMongoProviderMockRecorder) Drop 

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

Drop indicates an expected call of Drop.

func (*MockMongoProviderMockRecorder) Find 

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

Find indicates an expected call of Find.

func (*MockMongoProviderMockRecorder) FindOne 

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

FindOne indicates an expected call of FindOne.

func (*MockMongoProviderMockRecorder) HealthCheck 

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

HealthCheck indicates an expected call of HealthCheck.

func (*MockMongoProviderMockRecorder) InsertMany 

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

InsertMany indicates an expected call of InsertMany.

func (*MockMongoProviderMockRecorder) InsertOne 

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

InsertOne indicates an expected call of InsertOne.

func (*MockMongoProviderMockRecorder) StartSession 

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

StartSession indicates an expected call of StartSession.

func (*MockMongoProviderMockRecorder) UpdateByID 

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

UpdateByID indicates an expected call of UpdateByID.

func (*MockMongoProviderMockRecorder) UpdateMany 

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

UpdateMany indicates an expected call of UpdateMany.

func (*MockMongoProviderMockRecorder) UpdateOne 

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

UpdateOne indicates an expected call of UpdateOne.

func (*MockMongoProviderMockRecorder) UseLogger 

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

UseLogger indicates an expected call of UseLogger.

func (*MockMongoProviderMockRecorder) UseMetrics 

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

UseMetrics indicates an expected call of UseMetrics.

func (*MockMongoProviderMockRecorder) UseTracer 

func (mr *MockMongoProviderMockRecorder) UseTracer(tracer any) *gomock.Call

UseTracer indicates an expected call of UseTracer.

type MockPubSub 

type MockPubSub struct {
}

func (*MockPubSub) Close 

func (*MockPubSub) Close() error

func (*MockPubSub) CreateTopic 

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

func (*MockPubSub) DeleteTopic 

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

func (*MockPubSub) Health 

func (*MockPubSub) Health() datasource.Health

func (*MockPubSub) Publish 

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

func (*MockPubSub) Subscribe 

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

type MockRedis 

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

MockRedis is a mock of Redis interface.

func NewMockRedis 

func NewMockRedis(ctrl *gomock.Controller) *MockRedis

NewMockRedis creates a new mock instance.

func (*MockRedis) ACLDryRun 

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

ACLDryRun mocks base method.

func (*MockRedis) ACLLog 

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

ACLLog mocks base method.

func (*MockRedis) ACLLogReset 

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

ACLLogReset mocks base method.

func (*MockRedis) Append 

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

Append mocks base method.

func (*MockRedis) BFAdd 

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

BFAdd mocks base method.

func (*MockRedis) BFCard 

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

BFCard mocks base method.

func (*MockRedis) BFExists 

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

BFExists mocks base method.

func (*MockRedis) BFInfo 

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

BFInfo mocks base method.

func (*MockRedis) BFInfoArg 

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

BFInfoArg mocks base method.

func (*MockRedis) BFInfoCapacity 

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

BFInfoCapacity mocks base method.

func (*MockRedis) BFInfoExpansion 

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

BFInfoExpansion mocks base method.

func (*MockRedis) BFInfoFilters 

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

BFInfoFilters mocks base method.

func (*MockRedis) BFInfoItems 

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

BFInfoItems mocks base method.

func (*MockRedis) BFInfoSize 

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

BFInfoSize mocks base method.

func (*MockRedis) BFInsert 

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

BFInsert mocks base method.

func (*MockRedis) BFLoadChunk 

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

BFLoadChunk mocks base method.

func (*MockRedis) BFMAdd 

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

BFMAdd mocks base method.

func (*MockRedis) BFMExists 

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

BFMExists mocks base method.

func (*MockRedis) BFReserve 

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

BFReserve mocks base method.

func (*MockRedis) BFReserveExpansion 

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

BFReserveExpansion mocks base method.

func (*MockRedis) BFReserveNonScaling 

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

BFReserveNonScaling mocks base method.

func (*MockRedis) BFReserveWithArgs 

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

BFReserveWithArgs mocks base method.

func (*MockRedis) BFScanDump 

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

BFScanDump mocks base method.

func (*MockRedis) BLMPop 

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 

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

BLMove mocks base method.

func (*MockRedis) BLPop 

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

BLPop mocks base method.

func (*MockRedis) BRPop 

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

BRPop mocks base method.

func (*MockRedis) BRPopLPush 

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

BRPopLPush mocks base method.

func (*MockRedis) BZMPop 

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 

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

BZPopMax mocks base method.

func (*MockRedis) BZPopMin 

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

BZPopMin mocks base method.

func (*MockRedis) BgRewriteAOF 

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

BgRewriteAOF mocks base method.

func (*MockRedis) BgSave 

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

BgSave mocks base method.

func (*MockRedis) BitCount 

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

BitCount mocks base method.

func (*MockRedis) BitField 

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

BitField mocks base method.

func (*MockRedis) BitFieldRO 

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

BitFieldRO mocks base method.

func (*MockRedis) BitOpAnd 

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

BitOpAnd mocks base method.

func (*MockRedis) BitOpNot 

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

BitOpNot mocks base method.

func (*MockRedis) BitOpOr 

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

BitOpOr mocks base method.

func (*MockRedis) BitOpXor 

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

BitOpXor mocks base method.

func (*MockRedis) BitPos 

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

BitPos mocks base method.

func (*MockRedis) BitPosSpan 

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 

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

CFAdd mocks base method.

func (*MockRedis) CFAddNX 

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

CFAddNX mocks base method.

func (*MockRedis) CFCount 

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

CFCount mocks base method.

func (*MockRedis) CFDel 

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

CFDel mocks base method.

func (*MockRedis) CFExists 

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

CFExists mocks base method.

func (*MockRedis) CFInfo 

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

CFInfo mocks base method.

func (*MockRedis) CFInsert 

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

CFInsert mocks base method.

func (*MockRedis) CFInsertNX 

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

CFInsertNX mocks base method.

func (*MockRedis) CFLoadChunk 

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

CFLoadChunk mocks base method.

func (*MockRedis) CFMExists 

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

CFMExists mocks base method.

func (*MockRedis) CFReserve 

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

CFReserve mocks base method.

func (*MockRedis) CFReserveBucketSize 

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

CFReserveBucketSize mocks base method.

func (*MockRedis) CFReserveExpansion 

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

CFReserveExpansion mocks base method.

func (*MockRedis) CFReserveMaxIterations 

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

CFReserveMaxIterations mocks base method.

func (*MockRedis) CFReserveWithArgs 

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

CFReserveWithArgs mocks base method.

func (*MockRedis) CFScanDump 

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

CFScanDump mocks base method.

func (*MockRedis) CMSIncrBy 

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

CMSIncrBy mocks base method.

func (*MockRedis) CMSInfo 

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

CMSInfo mocks base method.

func (*MockRedis) CMSInitByDim 

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

CMSInitByDim mocks base method.

func (*MockRedis) CMSInitByProb 

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

CMSInitByProb mocks base method.

func (*MockRedis) CMSMerge 

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

CMSMerge mocks base method.

func (*MockRedis) CMSMergeWithWeight 

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

CMSMergeWithWeight mocks base method.

func (*MockRedis) CMSQuery 

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

CMSQuery mocks base method.

func (*MockRedis) ClientGetName 

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

ClientGetName mocks base method.

func (*MockRedis) ClientID 

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

ClientID mocks base method.

func (*MockRedis) ClientInfo 

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

ClientInfo mocks base method.

func (*MockRedis) ClientKill 

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

ClientKill mocks base method.

func (*MockRedis) ClientKillByFilter 

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

ClientKillByFilter mocks base method.

func (*MockRedis) ClientList 

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

ClientList mocks base method.

func (*MockRedis) ClientPause 

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

ClientPause mocks base method.

func (*MockRedis) ClientUnblock 

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

ClientUnblock mocks base method.

func (*MockRedis) ClientUnblockWithError 

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

ClientUnblockWithError mocks base method.

func (*MockRedis) ClientUnpause 

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

ClientUnpause mocks base method.

func (*MockRedis) Close 

func (m *MockRedis) Close() error

Close mocks base method.

func (*MockRedis) ClusterAddSlots 

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

ClusterAddSlots mocks base method.

func (*MockRedis) ClusterAddSlotsRange 

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

ClusterAddSlotsRange mocks base method.

func (*MockRedis) ClusterCountFailureReports 

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

ClusterCountFailureReports mocks base method.

func (*MockRedis) ClusterCountKeysInSlot 

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

ClusterCountKeysInSlot mocks base method.

func (*MockRedis) ClusterDelSlots 

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

ClusterDelSlots mocks base method.

func (*MockRedis) ClusterDelSlotsRange 

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

ClusterDelSlotsRange mocks base method.

func (*MockRedis) ClusterFailover 

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

ClusterFailover mocks base method.

func (*MockRedis) ClusterForget 

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

ClusterForget mocks base method.

func (*MockRedis) ClusterGetKeysInSlot 

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

ClusterGetKeysInSlot mocks base method.

func (*MockRedis) ClusterInfo 

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

ClusterInfo mocks base method.

func (*MockRedis) ClusterKeySlot 

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 

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

ClusterMeet mocks base method.

func (*MockRedis) ClusterMyShardID 

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

ClusterMyShardID mocks base method.

func (*MockRedis) ClusterNodes 

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

ClusterNodes mocks base method.

func (*MockRedis) ClusterReplicate 

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

ClusterReplicate mocks base method.

func (*MockRedis) ClusterResetHard 

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

ClusterResetHard mocks base method.

func (*MockRedis) ClusterResetSoft 

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

ClusterResetSoft mocks base method.

func (*MockRedis) ClusterSaveConfig 

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

ClusterSaveConfig mocks base method.

func (*MockRedis) ClusterShards 

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

ClusterShards mocks base method.

func (*MockRedis) ClusterSlaves 

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

ClusterSlaves mocks base method.

func (*MockRedis) ClusterSlots 

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

ClusterSlots mocks base method.

func (*MockRedis) Command 

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

Command mocks base method.

func (*MockRedis) CommandGetKeys 

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

CommandGetKeys mocks base method.

func (*MockRedis) CommandGetKeysAndFlags 

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

CommandGetKeysAndFlags mocks base method.

func (*MockRedis) CommandList 

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

CommandList mocks base method.

func (*MockRedis) ConfigGet 

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

ConfigGet mocks base method.

func (*MockRedis) ConfigResetStat 

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

ConfigResetStat mocks base method.

func (*MockRedis) ConfigRewrite 

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

ConfigRewrite mocks base method.

func (*MockRedis) ConfigSet 

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

ConfigSet mocks base method.

func (*MockRedis) Copy 

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

Copy mocks base method.

func (*MockRedis) DBSize 

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

DBSize mocks base method.

func (*MockRedis) DebugObject 

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

DebugObject mocks base method.

func (*MockRedis) Decr 

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

Decr mocks base method.

func (*MockRedis) DecrBy 

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

DecrBy mocks base method.

func (*MockRedis) Del 

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

Del mocks base method.

func (*MockRedis) Dump 

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

Dump mocks base method.

func (*MockRedis) EXPECT 

func (m *MockRedis) EXPECT() *MockRedisMockRecorder

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

func (*MockRedis) Echo 

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

Echo mocks base method.

func (*MockRedis) Eval 

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

Eval mocks base method.

func (*MockRedis) EvalRO 

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

EvalRO mocks base method.

func (*MockRedis) EvalSha 

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

EvalSha mocks base method.

func (*MockRedis) EvalShaRO 

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

EvalShaRO mocks base method.

func (*MockRedis) Exists 

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

Exists mocks base method.

func (*MockRedis) Expire 

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

Expire mocks base method.

func (*MockRedis) ExpireAt 

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

ExpireAt mocks base method.

func (*MockRedis) ExpireGT 

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

ExpireGT mocks base method.

func (*MockRedis) ExpireLT 

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

ExpireLT mocks base method.

func (*MockRedis) ExpireNX 

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

ExpireNX mocks base method.

func (*MockRedis) ExpireTime 

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

ExpireTime mocks base method.

func (*MockRedis) ExpireXX 

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

ExpireXX mocks base method.

func (*MockRedis) FCall 

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

FCall mocks base method.

func (*MockRedis) FCallRO 

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

FCallRO mocks base method.

func (*MockRedis) FCallRo 

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

FCallRo mocks base method.

func (*MockRedis) FlushAll 

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

FlushAll mocks base method.

func (*MockRedis) FlushAllAsync 

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

FlushAllAsync mocks base method.

func (*MockRedis) FlushDB 

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

FlushDB mocks base method.

func (*MockRedis) FlushDBAsync 

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

FlushDBAsync mocks base method.

func (*MockRedis) FunctionDelete 

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

FunctionDelete mocks base method.

func (*MockRedis) FunctionDump 

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

FunctionDump mocks base method.

func (*MockRedis) FunctionFlush 

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

FunctionFlush mocks base method.

func (*MockRedis) FunctionFlushAsync 

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

FunctionFlushAsync mocks base method.

func (*MockRedis) FunctionKill 

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

FunctionKill mocks base method.

func (*MockRedis) FunctionList 

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

FunctionList mocks base method.

func (*MockRedis) FunctionLoad 

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

FunctionLoad mocks base method.

func (*MockRedis) FunctionLoadReplace 

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

FunctionLoadReplace mocks base method.

func (*MockRedis) FunctionRestore 

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

FunctionRestore mocks base method.

func (*MockRedis) FunctionStats 

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

FunctionStats mocks base method.

func (*MockRedis) GeoAdd 

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

GeoAdd mocks base method.

func (*MockRedis) GeoDist 

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

GeoDist mocks base method.

func (*MockRedis) GeoHash 

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

GeoHash mocks base method.

func (*MockRedis) GeoPos 

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

GeoPos mocks base method.

func (*MockRedis) GeoRadius 

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

GeoRadius mocks base method.

func (*MockRedis) GeoRadiusByMember 

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

GeoRadiusByMember mocks base method.

func (*MockRedis) GeoRadiusByMemberStore 

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

GeoRadiusByMemberStore mocks base method.

func (*MockRedis) GeoRadiusStore 

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

GeoRadiusStore mocks base method.

func (*MockRedis) GeoSearch 

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

GeoSearch mocks base method.

func (*MockRedis) GeoSearchLocation 

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

GeoSearchLocation mocks base method.

func (*MockRedis) GeoSearchStore 

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

GeoSearchStore mocks base method.

func (*MockRedis) Get 

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

Get mocks base method.

func (*MockRedis) GetBit 

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

GetBit mocks base method.

func (*MockRedis) GetDel 

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

GetDel mocks base method.

func (*MockRedis) GetEx 

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

GetEx mocks base method.

func (*MockRedis) GetRange 

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

GetRange mocks base method.

func (*MockRedis) GetSet 

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

GetSet mocks base method.

func (*MockRedis) HDel 

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

HDel mocks base method.

func (*MockRedis) HExists 

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

HExists mocks base method.

func (*MockRedis) HExpire 

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

HExpire mocks base method.

func (*MockRedis) HExpireAt 

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

HExpireAt mocks base method.

func (*MockRedis) HExpireAtWithArgs 

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 

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

HExpireTime mocks base method.

func (*MockRedis) HExpireWithArgs 

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 

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

HGet mocks base method.

func (*MockRedis) HGetAll 

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

HGetAll mocks base method.

func (*MockRedis) HIncrBy 

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

HIncrBy mocks base method.

func (*MockRedis) HIncrByFloat 

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

HIncrByFloat mocks base method.

func (*MockRedis) HKeys 

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

HKeys mocks base method.

func (*MockRedis) HLen 

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

HLen mocks base method.

func (*MockRedis) HMGet 

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

HMGet mocks base method.

func (*MockRedis) HMSet 

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

HMSet mocks base method.

func (*MockRedis) HPExpire 

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

HPExpire mocks base method.

func (*MockRedis) HPExpireAt 

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

HPExpireAt mocks base method.

func (*MockRedis) HPExpireAtWithArgs 

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 

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

HPExpireTime mocks base method.

func (*MockRedis) HPExpireWithArgs 

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 

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

HPTTL mocks base method.

func (*MockRedis) HPersist 

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

HPersist mocks base method.

func (*MockRedis) HRandField 

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

HRandField mocks base method.

func (*MockRedis) HRandFieldWithValues 

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

HRandFieldWithValues mocks base method.

func (*MockRedis) HScan 

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

HScan mocks base method.

func (*MockRedis) HScanNoValues 

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

HScanNoValues mocks base method.

func (*MockRedis) HSet 

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

HSet mocks base method.

func (*MockRedis) HSetNX 

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

HSetNX mocks base method.

func (*MockRedis) HTTL 

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

HTTL mocks base method.

func (*MockRedis) HVals 

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

HVals mocks base method.

func (*MockRedis) HealthCheck 

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

HealthCheck mocks base method.

func (*MockRedis) Incr 

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

Incr mocks base method.

func (*MockRedis) IncrBy 

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

IncrBy mocks base method.

func (*MockRedis) IncrByFloat 

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

IncrByFloat mocks base method.

func (*MockRedis) Info 

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

Info mocks base method.

func (*MockRedis) JSONArrAppend 

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

JSONArrAppend mocks base method.

func (*MockRedis) JSONArrIndex 

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

JSONArrIndex mocks base method.

func (*MockRedis) JSONArrIndexWithArgs 

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

JSONArrIndexWithArgs mocks base method.

func (*MockRedis) JSONArrInsert 

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

JSONArrInsert mocks base method.

func (*MockRedis) JSONArrLen 

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

JSONArrLen mocks base method.

func (*MockRedis) JSONArrPop 

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

JSONArrPop mocks base method.

func (*MockRedis) JSONArrTrim 

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

JSONArrTrim mocks base method.

func (*MockRedis) JSONArrTrimWithArgs 

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

JSONArrTrimWithArgs mocks base method.

func (*MockRedis) JSONClear 

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

JSONClear mocks base method.

func (*MockRedis) JSONDebugMemory 

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

JSONDebugMemory mocks base method.

func (*MockRedis) JSONDel 

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

JSONDel mocks base method.

func (*MockRedis) JSONForget 

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

JSONForget mocks base method.

func (*MockRedis) JSONGet 

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

JSONGet mocks base method.

func (*MockRedis) JSONGetWithArgs 

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

JSONGetWithArgs mocks base method.

func (*MockRedis) JSONMGet 

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

JSONMGet mocks base method.

func (*MockRedis) JSONMSet 

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

JSONMSet mocks base method.

func (*MockRedis) JSONMSetArgs 

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

JSONMSetArgs mocks base method.

func (*MockRedis) JSONMerge 

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

JSONMerge mocks base method.

func (*MockRedis) JSONNumIncrBy 

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

JSONNumIncrBy mocks base method.

func (*MockRedis) JSONObjKeys 

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

JSONObjKeys mocks base method.

func (*MockRedis) JSONObjLen 

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

JSONObjLen mocks base method.

func (*MockRedis) JSONSet 

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

JSONSet mocks base method.

func (*MockRedis) JSONSetMode 

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

JSONSetMode mocks base method.

func (*MockRedis) JSONStrAppend 

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

JSONStrAppend mocks base method.

func (*MockRedis) JSONStrLen 

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

JSONStrLen mocks base method.

func (*MockRedis) JSONToggle 

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

JSONToggle mocks base method.

func (*MockRedis) JSONType 

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

JSONType mocks base method.

func (*MockRedis) Keys 

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

Keys mocks base method.

func (*MockRedis) LCS 

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

LCS mocks base method.

func (*MockRedis) LIndex 

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

LIndex mocks base method.

func (*MockRedis) LInsert 

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

LInsert mocks base method.

func (*MockRedis) LInsertAfter 

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

LInsertAfter mocks base method.

func (*MockRedis) LInsertBefore 

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

LInsertBefore mocks base method.

func (*MockRedis) LLen 

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

LLen mocks base method.

func (*MockRedis) LMPop 

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

LMPop mocks base method.

func (*MockRedis) LMove 

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

LMove mocks base method.

func (*MockRedis) LPop 

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

LPop mocks base method.

func (*MockRedis) LPopCount 

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

LPopCount mocks base method.

func (*MockRedis) LPos 

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

LPos mocks base method.

func (*MockRedis) LPosCount 

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

LPosCount mocks base method.

func (*MockRedis) LPush 

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

LPush mocks base method.

func (*MockRedis) LPushX 

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

LPushX mocks base method.

func (*MockRedis) LRange 

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

LRange mocks base method.

func (*MockRedis) LRem 

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

LRem mocks base method.

func (*MockRedis) LSet 

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

LSet mocks base method.

func (*MockRedis) LTrim 

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

LTrim mocks base method.

func (*MockRedis) LastSave 

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

LastSave mocks base method.

func (*MockRedis) MGet 

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

MGet mocks base method.

func (*MockRedis) MSet 

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

MSet mocks base method.

func (*MockRedis) MSetNX 

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

MSetNX mocks base method.

func (*MockRedis) MemoryUsage 

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

MemoryUsage mocks base method.

func (*MockRedis) Migrate 

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 

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

ModuleLoadex mocks base method.

func (*MockRedis) Move 

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

Move mocks base method.

func (*MockRedis) ObjectEncoding 

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

ObjectEncoding mocks base method.

func (*MockRedis) ObjectFreq 

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

ObjectFreq mocks base method.

func (*MockRedis) ObjectIdleTime 

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

ObjectIdleTime mocks base method.

func (*MockRedis) ObjectRefCount 

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

ObjectRefCount mocks base method.

func (*MockRedis) PExpire 

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

PExpire mocks base method.

func (*MockRedis) PExpireAt 

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

PExpireAt mocks base method.

func (*MockRedis) PExpireTime 

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

PExpireTime mocks base method.

func (*MockRedis) PFAdd 

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

PFAdd mocks base method.

func (*MockRedis) PFCount 

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

PFCount mocks base method.

func (*MockRedis) PFMerge 

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

PFMerge mocks base method.

func (*MockRedis) PTTL 

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

PTTL mocks base method.

func (*MockRedis) Persist 

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

Persist mocks base method.

func (*MockRedis) Ping 

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

Ping mocks base method.

func (*MockRedis) Pipeline 

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

Pipeline mocks base method.

func (*MockRedis) Pipelined 

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

Pipelined mocks base method.

func (*MockRedis) PubSubChannels 

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

PubSubChannels mocks base method.

func (*MockRedis) PubSubNumPat 

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

PubSubNumPat mocks base method.

func (*MockRedis) PubSubNumSub 

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

PubSubNumSub mocks base method.

func (*MockRedis) PubSubShardChannels 

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

PubSubShardChannels mocks base method.

func (*MockRedis) PubSubShardNumSub 

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

PubSubShardNumSub mocks base method.

func (*MockRedis) Publish 

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

Publish mocks base method.

func (*MockRedis) Quit 

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

Quit mocks base method.

func (*MockRedis) RPop 

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

RPop mocks base method.

func (*MockRedis) RPopCount 

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

RPopCount mocks base method.

func (*MockRedis) RPopLPush 

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

RPopLPush mocks base method.

func (*MockRedis) RPush 

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

RPush mocks base method.

func (*MockRedis) RPushX 

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

RPushX mocks base method.

func (*MockRedis) RandomKey 

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

RandomKey mocks base method.

func (*MockRedis) ReadOnly 

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

ReadOnly mocks base method.

func (*MockRedis) ReadWrite 

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

ReadWrite mocks base method.

func (*MockRedis) Rename 

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

Rename mocks base method.

func (*MockRedis) RenameNX 

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

RenameNX mocks base method.

func (*MockRedis) Restore 

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

Restore mocks base method.

func (*MockRedis) RestoreReplace 

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

RestoreReplace mocks base method.

func (*MockRedis) SAdd 

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

SAdd mocks base method.

func (*MockRedis) SCard 

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

SCard mocks base method.

func (*MockRedis) SDiff 

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

SDiff mocks base method.

func (*MockRedis) SDiffStore 

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

SDiffStore mocks base method.

func (*MockRedis) SInter 

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

SInter mocks base method.

func (*MockRedis) SInterCard 

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

SInterCard mocks base method.

func (*MockRedis) SInterStore 

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

SInterStore mocks base method.

func (*MockRedis) SIsMember 

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

SIsMember mocks base method.

func (*MockRedis) SMIsMember 

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

SMIsMember mocks base method.

func (*MockRedis) SMembers 

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

SMembers mocks base method.

func (*MockRedis) SMembersMap 

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

SMembersMap mocks base method.

func (*MockRedis) SMove 

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

SMove mocks base method.

func (*MockRedis) SPop 

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

SPop mocks base method.

func (*MockRedis) SPopN 

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

SPopN mocks base method.

func (*MockRedis) SPublish 

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

SPublish mocks base method.

func (*MockRedis) SRandMember 

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

SRandMember mocks base method.

func (*MockRedis) SRandMemberN 

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

SRandMemberN mocks base method.

func (*MockRedis) SRem 

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

SRem mocks base method.

func (*MockRedis) SScan 

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

SScan mocks base method.

func (*MockRedis) SUnion 

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

SUnion mocks base method.

func (*MockRedis) SUnionStore 

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

SUnionStore mocks base method.

func (*MockRedis) Save 

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

Save mocks base method.

func (*MockRedis) Scan 

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

Scan mocks base method.

func (*MockRedis) ScanType 

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

ScanType mocks base method.

func (*MockRedis) ScriptExists 

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

ScriptExists mocks base method.

func (*MockRedis) ScriptFlush 

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

ScriptFlush mocks base method.

func (*MockRedis) ScriptKill 

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

ScriptKill mocks base method.

func (*MockRedis) ScriptLoad 

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

ScriptLoad mocks base method.

func (*MockRedis) Set 

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

Set mocks base method.

func (*MockRedis) SetArgs 

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

SetArgs mocks base method.

func (*MockRedis) SetBit 

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

SetBit mocks base method.

func (*MockRedis) SetEx 

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

SetEx mocks base method.

func (*MockRedis) SetNX 

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

SetNX mocks base method.

func (*MockRedis) SetRange 

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

SetRange mocks base method.

func (*MockRedis) SetXX 

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

SetXX mocks base method.

func (*MockRedis) Shutdown 

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

Shutdown mocks base method.

func (*MockRedis) ShutdownNoSave 

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

ShutdownNoSave mocks base method.

func (*MockRedis) ShutdownSave 

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

ShutdownSave mocks base method.

func (*MockRedis) SlaveOf 

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

SlaveOf mocks base method.

func (*MockRedis) SlowLogGet 

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

SlowLogGet mocks base method.

func (*MockRedis) Sort 

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

Sort mocks base method.

func (*MockRedis) SortInterfaces 

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

SortInterfaces mocks base method.

func (*MockRedis) SortRO 

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

SortRO mocks base method.

func (*MockRedis) SortStore 

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

SortStore mocks base method.

func (*MockRedis) StrLen 

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

StrLen mocks base method.

func (*MockRedis) TDigestAdd 

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

TDigestAdd mocks base method.

func (*MockRedis) TDigestByRank 

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

TDigestByRank mocks base method.

func (*MockRedis) TDigestByRevRank 

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

TDigestByRevRank mocks base method.

func (*MockRedis) TDigestCDF 

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

TDigestCDF mocks base method.

func (*MockRedis) TDigestCreate 

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

TDigestCreate mocks base method.

func (*MockRedis) TDigestCreateWithCompression 

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

TDigestCreateWithCompression mocks base method.

func (*MockRedis) TDigestInfo 

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

TDigestInfo mocks base method.

func (*MockRedis) TDigestMax 

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

TDigestMax mocks base method.

func (*MockRedis) TDigestMerge 

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

TDigestMerge mocks base method.

func (*MockRedis) TDigestMin 

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

TDigestMin mocks base method.

func (*MockRedis) TDigestQuantile 

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

TDigestQuantile mocks base method.

func (*MockRedis) TDigestRank 

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

TDigestRank mocks base method.

func (*MockRedis) TDigestReset 

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

TDigestReset mocks base method.

func (*MockRedis) TDigestRevRank 

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

TDigestRevRank mocks base method.

func (*MockRedis) TDigestTrimmedMean 

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

TDigestTrimmedMean mocks base method.

func (*MockRedis) TFCall 

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

TFCall mocks base method.

func (*MockRedis) TFCallASYNC 

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

TFCallASYNC mocks base method.

func (*MockRedis) TFCallASYNCArgs 

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

TFCallASYNCArgs mocks base method.

func (*MockRedis) TFCallArgs 

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

TFCallArgs mocks base method.

func (*MockRedis) TFunctionDelete 

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

TFunctionDelete mocks base method.

func (*MockRedis) TFunctionList 

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

TFunctionList mocks base method.

func (*MockRedis) TFunctionListArgs 

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

TFunctionListArgs mocks base method.

func (*MockRedis) TFunctionLoad 

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

TFunctionLoad mocks base method.

func (*MockRedis) TFunctionLoadArgs 

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

TFunctionLoadArgs mocks base method.

func (*MockRedis) TSAdd 

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

TSAdd mocks base method.

func (*MockRedis) TSAddWithArgs 

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 

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

TSAlter mocks base method.

func (*MockRedis) TSCreate 

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

TSCreate mocks base method.

func (*MockRedis) TSCreateRule 

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

TSCreateRule mocks base method.

func (*MockRedis) TSCreateRuleWithArgs 

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 

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

TSCreateWithArgs mocks base method.

func (*MockRedis) TSDecrBy 

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

TSDecrBy mocks base method.

func (*MockRedis) TSDecrByWithArgs 

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

TSDecrByWithArgs mocks base method.

func (*MockRedis) TSDel 

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

TSDel mocks base method.

func (*MockRedis) TSDeleteRule 

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

TSDeleteRule mocks base method.

func (*MockRedis) TSGet 

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

TSGet mocks base method.

func (*MockRedis) TSGetWithArgs 

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

TSGetWithArgs mocks base method.

func (*MockRedis) TSIncrBy 

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

TSIncrBy mocks base method.

func (*MockRedis) TSIncrByWithArgs 

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

TSIncrByWithArgs mocks base method.

func (*MockRedis) TSInfo 

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

TSInfo mocks base method.

func (*MockRedis) TSInfoWithArgs 

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

TSInfoWithArgs mocks base method.

func (*MockRedis) TSMAdd 

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

TSMAdd mocks base method.

func (*MockRedis) TSMGet 

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

TSMGet mocks base method.

func (*MockRedis) TSMGetWithArgs 

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

TSMGetWithArgs mocks base method.

func (*MockRedis) TSMRange 

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

TSMRange mocks base method.

func (*MockRedis) TSMRangeWithArgs 

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

TSMRangeWithArgs mocks base method.

func (*MockRedis) TSMRevRange 

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

TSMRevRange mocks base method.

func (*MockRedis) TSMRevRangeWithArgs 

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

TSMRevRangeWithArgs mocks base method.

func (*MockRedis) TSQueryIndex 

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

TSQueryIndex mocks base method.

func (*MockRedis) TSRange 

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

TSRange mocks base method.

func (*MockRedis) TSRangeWithArgs 

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

TSRangeWithArgs mocks base method.

func (*MockRedis) TSRevRange 

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

TSRevRange mocks base method.

func (*MockRedis) TSRevRangeWithArgs 

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

TSRevRangeWithArgs mocks base method.

func (*MockRedis) TTL 

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

TTL mocks base method.

func (*MockRedis) Time 

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

Time mocks base method.

func (*MockRedis) TopKAdd 

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

TopKAdd mocks base method.

func (*MockRedis) TopKCount 

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

TopKCount mocks base method.

func (*MockRedis) TopKIncrBy 

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

TopKIncrBy mocks base method.

func (*MockRedis) TopKInfo 

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

TopKInfo mocks base method.

func (*MockRedis) TopKList 

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

TopKList mocks base method.

func (*MockRedis) TopKListWithCount 

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

TopKListWithCount mocks base method.

func (*MockRedis) TopKQuery 

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

TopKQuery mocks base method.

func (*MockRedis) TopKReserve 

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

TopKReserve mocks base method.

func (*MockRedis) TopKReserveWithOptions 

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

TopKReserveWithOptions mocks base method.

func (*MockRedis) Touch 

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

Touch mocks base method.

func (*MockRedis) TxPipeline 

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

TxPipeline mocks base method.

func (*MockRedis) TxPipelined 

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

TxPipelined mocks base method.

func (*MockRedis) Type 

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 

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

XAck mocks base method.

func (*MockRedis) XAdd 

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

XAdd mocks base method.

func (*MockRedis) XAutoClaim 

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

XAutoClaim mocks base method.

func (*MockRedis) XAutoClaimJustID 

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

XAutoClaimJustID mocks base method.

func (*MockRedis) XClaim 

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

XClaim mocks base method.

func (*MockRedis) XClaimJustID 

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

XClaimJustID mocks base method.

func (*MockRedis) XDel 

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

XDel mocks base method.

func (*MockRedis) XGroupCreate 

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

XGroupCreate mocks base method.

func (*MockRedis) XGroupCreateConsumer 

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

XGroupCreateConsumer mocks base method.

func (*MockRedis) XGroupCreateMkStream 

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

XGroupCreateMkStream mocks base method.

func (*MockRedis) XGroupDelConsumer 

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

XGroupDelConsumer mocks base method.

func (*MockRedis) XGroupDestroy 

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

XGroupDestroy mocks base method.

func (*MockRedis) XGroupSetID 

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

XGroupSetID mocks base method.

func (*MockRedis) XInfoConsumers 

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

XInfoConsumers mocks base method.

func (*MockRedis) XInfoGroups 

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

XInfoGroups mocks base method.

func (*MockRedis) XInfoStream 

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

XInfoStream mocks base method.

func (*MockRedis) XInfoStreamFull 

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

XInfoStreamFull mocks base method.

func (*MockRedis) XLen 

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

XLen mocks base method.

func (*MockRedis) XPending 

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

XPending mocks base method.

func (*MockRedis) XPendingExt 

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

XPendingExt mocks base method.

func (*MockRedis) XRange 

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

XRange mocks base method.

func (*MockRedis) XRangeN 

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

XRangeN mocks base method.

func (*MockRedis) XRead 

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

XRead mocks base method.

func (*MockRedis) XReadGroup 

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

XReadGroup mocks base method.

func (*MockRedis) XReadStreams 

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

XReadStreams mocks base method.

func (*MockRedis) XRevRange 

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

XRevRange mocks base method.

func (*MockRedis) XRevRangeN 

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

XRevRangeN mocks base method.

func (*MockRedis) XTrimMaxLen 

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

XTrimMaxLen mocks base method.

func (*MockRedis) XTrimMaxLenApprox 

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

XTrimMaxLenApprox mocks base method.

func (*MockRedis) XTrimMinID 

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

XTrimMinID mocks base method.

func (*MockRedis) XTrimMinIDApprox 

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

XTrimMinIDApprox mocks base method.

func (*MockRedis) ZAdd 

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

ZAdd mocks base method.

func (*MockRedis) ZAddArgs 

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

ZAddArgs mocks base method.

func (*MockRedis) ZAddArgsIncr 

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

ZAddArgsIncr mocks base method.

func (*MockRedis) ZAddGT 

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

ZAddGT mocks base method.

func (*MockRedis) ZAddLT 

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

ZAddLT mocks base method.

func (*MockRedis) ZAddNX 

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

ZAddNX mocks base method.

func (*MockRedis) ZAddXX 

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

ZAddXX mocks base method.

func (*MockRedis) ZCard 

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

ZCard mocks base method.

func (*MockRedis) ZCount 

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

ZCount mocks base method.

func (*MockRedis) ZDiff 

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

ZDiff mocks base method.

func (*MockRedis) ZDiffStore 

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

ZDiffStore mocks base method.

func (*MockRedis) ZDiffWithScores 

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

ZDiffWithScores mocks base method.

func (*MockRedis) ZIncrBy 

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

ZIncrBy mocks base method.

func (*MockRedis) ZInter 

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

ZInter mocks base method.

func (*MockRedis) ZInterCard 

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

ZInterCard mocks base method.

func (*MockRedis) ZInterStore 

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

ZInterStore mocks base method.

func (*MockRedis) ZInterWithScores 

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

ZInterWithScores mocks base method.

func (*MockRedis) ZLexCount 

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

ZLexCount mocks base method.

func (*MockRedis) ZMPop 

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

ZMPop mocks base method.

func (*MockRedis) ZMScore 

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

ZMScore mocks base method.

func (*MockRedis) ZPopMax 

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

ZPopMax mocks base method.

func (*MockRedis) ZPopMin 

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

ZPopMin mocks base method.

func (*MockRedis) ZRandMember 

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

ZRandMember mocks base method.

func (*MockRedis) ZRandMemberWithScores 

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

ZRandMemberWithScores mocks base method.

func (*MockRedis) ZRange 

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

ZRange mocks base method.

func (*MockRedis) ZRangeArgs 

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

ZRangeArgs mocks base method.

func (*MockRedis) ZRangeArgsWithScores 

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

ZRangeArgsWithScores mocks base method.

func (*MockRedis) ZRangeByLex 

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

ZRangeByLex mocks base method.

func (*MockRedis) ZRangeByScore 

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

ZRangeByScore mocks base method.

func (*MockRedis) ZRangeByScoreWithScores 

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

ZRangeByScoreWithScores mocks base method.

func (*MockRedis) ZRangeStore 

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

ZRangeStore mocks base method.

func (*MockRedis) ZRangeWithScores 

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

ZRangeWithScores mocks base method.

func (*MockRedis) ZRank 

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

ZRank mocks base method.

func (*MockRedis) ZRankWithScore 

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

ZRankWithScore mocks base method.

func (*MockRedis) ZRem 

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

ZRem mocks base method.

func (*MockRedis) ZRemRangeByLex 

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

ZRemRangeByLex mocks base method.

func (*MockRedis) ZRemRangeByRank 

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

ZRemRangeByRank mocks base method.

func (*MockRedis) ZRemRangeByScore 

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

ZRemRangeByScore mocks base method.

func (*MockRedis) ZRevRange 

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

ZRevRange mocks base method.

func (*MockRedis) ZRevRangeByLex 

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

ZRevRangeByLex mocks base method.

func (*MockRedis) ZRevRangeByScore 

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

ZRevRangeByScore mocks base method.

func (*MockRedis) ZRevRangeByScoreWithScores 

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

ZRevRangeByScoreWithScores mocks base method.

func (*MockRedis) ZRevRangeWithScores 

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

ZRevRangeWithScores mocks base method.

func (*MockRedis) ZRevRank 

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

ZRevRank mocks base method.

func (*MockRedis) ZRevRankWithScore 

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

ZRevRankWithScore mocks base method.

func (*MockRedis) ZScan 

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

ZScan mocks base method.

func (*MockRedis) ZScore 

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

ZScore mocks base method.

func (*MockRedis) ZUnion 

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

ZUnion mocks base method.

func (*MockRedis) ZUnionStore 

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

ZUnionStore mocks base method.

func (*MockRedis) ZUnionWithScores 

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

ZUnionWithScores mocks base method.

type MockRedisMockRecorder 

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

MockRedisMockRecorder is the mock recorder for MockRedis.

func (*MockRedisMockRecorder) ACLDryRun 

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

ACLDryRun indicates an expected call of ACLDryRun.

func (*MockRedisMockRecorder) ACLLog 

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

ACLLog indicates an expected call of ACLLog.

func (*MockRedisMockRecorder) ACLLogReset 

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

ACLLogReset indicates an expected call of ACLLogReset.

func (*MockRedisMockRecorder) Append 

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

Append indicates an expected call of Append.

func (*MockRedisMockRecorder) BFAdd 

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

BFAdd indicates an expected call of BFAdd.

func (*MockRedisMockRecorder) BFCard 

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

BFCard indicates an expected call of BFCard.

func (*MockRedisMockRecorder) BFExists 

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

BFExists indicates an expected call of BFExists.

func (*MockRedisMockRecorder) BFInfo 

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

BFInfo indicates an expected call of BFInfo.

func (*MockRedisMockRecorder) BFInfoArg 

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

BFInfoArg indicates an expected call of BFInfoArg.

func (*MockRedisMockRecorder) BFInfoCapacity 

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

BFInfoCapacity indicates an expected call of BFInfoCapacity.

func (*MockRedisMockRecorder) BFInfoExpansion 

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

BFInfoExpansion indicates an expected call of BFInfoExpansion.

func (*MockRedisMockRecorder) BFInfoFilters 

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

BFInfoFilters indicates an expected call of BFInfoFilters.

func (*MockRedisMockRecorder) BFInfoItems 

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

BFInfoItems indicates an expected call of BFInfoItems.

func (*MockRedisMockRecorder) BFInfoSize 

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

BFInfoSize indicates an expected call of BFInfoSize.

func (*MockRedisMockRecorder) BFInsert 

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

BFInsert indicates an expected call of BFInsert.

func (*MockRedisMockRecorder) BFLoadChunk 

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

BFLoadChunk indicates an expected call of BFLoadChunk.

func (*MockRedisMockRecorder) BFMAdd 

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

BFMAdd indicates an expected call of BFMAdd.

func (*MockRedisMockRecorder) BFMExists 

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

BFMExists indicates an expected call of BFMExists.

func (*MockRedisMockRecorder) BFReserve 

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

BFReserve indicates an expected call of BFReserve.

func (*MockRedisMockRecorder) BFReserveExpansion 

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

BFReserveExpansion indicates an expected call of BFReserveExpansion.

func (*MockRedisMockRecorder) BFReserveNonScaling 

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

BFReserveNonScaling indicates an expected call of BFReserveNonScaling.

func (*MockRedisMockRecorder) BFReserveWithArgs 

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

BFReserveWithArgs indicates an expected call of BFReserveWithArgs.

func (*MockRedisMockRecorder) BFScanDump 

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

BFScanDump indicates an expected call of BFScanDump.

func (*MockRedisMockRecorder) BLMPop 

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

BLMPop indicates an expected call of BLMPop.

func (*MockRedisMockRecorder) BLMove 

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

BLMove indicates an expected call of BLMove.

func (*MockRedisMockRecorder) BLPop 

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

BLPop indicates an expected call of BLPop.

func (*MockRedisMockRecorder) BRPop 

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

BRPop indicates an expected call of BRPop.

func (*MockRedisMockRecorder) BRPopLPush 

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

BRPopLPush indicates an expected call of BRPopLPush.

func (*MockRedisMockRecorder) BZMPop 

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

BZMPop indicates an expected call of BZMPop.

func (*MockRedisMockRecorder) BZPopMax 

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

BZPopMax indicates an expected call of BZPopMax.

func (*MockRedisMockRecorder) BZPopMin 

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

BZPopMin indicates an expected call of BZPopMin.

func (*MockRedisMockRecorder) BgRewriteAOF 

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

BgRewriteAOF indicates an expected call of BgRewriteAOF.

func (*MockRedisMockRecorder) BgSave 

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

BgSave indicates an expected call of BgSave.

func (*MockRedisMockRecorder) BitCount 

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

BitCount indicates an expected call of BitCount.

func (*MockRedisMockRecorder) BitField 

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

BitField indicates an expected call of BitField.

func (*MockRedisMockRecorder) BitFieldRO 

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

BitFieldRO indicates an expected call of BitFieldRO.

func (*MockRedisMockRecorder) BitOpAnd 

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

BitOpAnd indicates an expected call of BitOpAnd.

func (*MockRedisMockRecorder) BitOpNot 

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

BitOpNot indicates an expected call of BitOpNot.

func (*MockRedisMockRecorder) BitOpOr 

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

BitOpOr indicates an expected call of BitOpOr.

func (*MockRedisMockRecorder) BitOpXor 

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

BitOpXor indicates an expected call of BitOpXor.

func (*MockRedisMockRecorder) BitPos 

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

BitPos indicates an expected call of BitPos.

func (*MockRedisMockRecorder) BitPosSpan 

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

BitPosSpan indicates an expected call of BitPosSpan.

func (*MockRedisMockRecorder) CFAdd 

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

CFAdd indicates an expected call of CFAdd.

func (*MockRedisMockRecorder) CFAddNX 

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

CFAddNX indicates an expected call of CFAddNX.

func (*MockRedisMockRecorder) CFCount 

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

CFCount indicates an expected call of CFCount.

func (*MockRedisMockRecorder) CFDel 

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

CFDel indicates an expected call of CFDel.

func (*MockRedisMockRecorder) CFExists 

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

CFExists indicates an expected call of CFExists.

func (*MockRedisMockRecorder) CFInfo 

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

CFInfo indicates an expected call of CFInfo.

func (*MockRedisMockRecorder) CFInsert 

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

CFInsert indicates an expected call of CFInsert.

func (*MockRedisMockRecorder) CFInsertNX 

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

CFInsertNX indicates an expected call of CFInsertNX.

func (*MockRedisMockRecorder) CFLoadChunk 

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

CFLoadChunk indicates an expected call of CFLoadChunk.

func (*MockRedisMockRecorder) CFMExists 

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

CFMExists indicates an expected call of CFMExists.

func (*MockRedisMockRecorder) CFReserve 

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

CFReserve indicates an expected call of CFReserve.

func (*MockRedisMockRecorder) CFReserveBucketSize 

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

CFReserveBucketSize indicates an expected call of CFReserveBucketSize.

func (*MockRedisMockRecorder) CFReserveExpansion 

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

CFReserveExpansion indicates an expected call of CFReserveExpansion.

func (*MockRedisMockRecorder) CFReserveMaxIterations 

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

CFReserveMaxIterations indicates an expected call of CFReserveMaxIterations.

func (*MockRedisMockRecorder) CFReserveWithArgs 

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

CFReserveWithArgs indicates an expected call of CFReserveWithArgs.

func (*MockRedisMockRecorder) CFScanDump 

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

CFScanDump indicates an expected call of CFScanDump.

func (*MockRedisMockRecorder) CMSIncrBy 

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

CMSIncrBy indicates an expected call of CMSIncrBy.

func (*MockRedisMockRecorder) CMSInfo 

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

CMSInfo indicates an expected call of CMSInfo.

func (*MockRedisMockRecorder) CMSInitByDim 

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

CMSInitByDim indicates an expected call of CMSInitByDim.

func (*MockRedisMockRecorder) CMSInitByProb 

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

CMSInitByProb indicates an expected call of CMSInitByProb.

func (*MockRedisMockRecorder) CMSMerge 

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

CMSMerge indicates an expected call of CMSMerge.

func (*MockRedisMockRecorder) CMSMergeWithWeight 

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

CMSMergeWithWeight indicates an expected call of CMSMergeWithWeight.

func (*MockRedisMockRecorder) CMSQuery 

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

CMSQuery indicates an expected call of CMSQuery.

func (*MockRedisMockRecorder) ClientGetName 

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

ClientGetName indicates an expected call of ClientGetName.

func (*MockRedisMockRecorder) ClientID 

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

ClientID indicates an expected call of ClientID.

func (*MockRedisMockRecorder) ClientInfo 

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

ClientInfo indicates an expected call of ClientInfo.

func (*MockRedisMockRecorder) ClientKill 

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

ClientKill indicates an expected call of ClientKill.

func (*MockRedisMockRecorder) ClientKillByFilter 

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

ClientKillByFilter indicates an expected call of ClientKillByFilter.

func (*MockRedisMockRecorder) ClientList 

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

ClientList indicates an expected call of ClientList.

func (*MockRedisMockRecorder) ClientPause 

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

ClientPause indicates an expected call of ClientPause.

func (*MockRedisMockRecorder) ClientUnblock 

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

ClientUnblock indicates an expected call of ClientUnblock.

func (*MockRedisMockRecorder) ClientUnblockWithError 

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

ClientUnblockWithError indicates an expected call of ClientUnblockWithError.

func (*MockRedisMockRecorder) ClientUnpause 

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

ClientUnpause indicates an expected call of ClientUnpause.

func (*MockRedisMockRecorder) Close 

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

Close indicates an expected call of Close.

func (*MockRedisMockRecorder) ClusterAddSlots 

func (mr *MockRedisMockRecorder) ClusterAddSlots(ctx any, slots ...any) *gomock.Call

ClusterAddSlots indicates an expected call of ClusterAddSlots.

func (*MockRedisMockRecorder) ClusterAddSlotsRange 

func (mr *MockRedisMockRecorder) ClusterAddSlotsRange(ctx, min, max any) *gomock.Call

ClusterAddSlotsRange indicates an expected call of ClusterAddSlotsRange.

func (*MockRedisMockRecorder) ClusterCountFailureReports 

func (mr *MockRedisMockRecorder) ClusterCountFailureReports(ctx, nodeID any) *gomock.Call

ClusterCountFailureReports indicates an expected call of ClusterCountFailureReports.

func (*MockRedisMockRecorder) ClusterCountKeysInSlot 

func (mr *MockRedisMockRecorder) ClusterCountKeysInSlot(ctx, slot any) *gomock.Call

ClusterCountKeysInSlot indicates an expected call of ClusterCountKeysInSlot.

func (*MockRedisMockRecorder) ClusterDelSlots 

func (mr *MockRedisMockRecorder) ClusterDelSlots(ctx any, slots ...any) *gomock.Call

ClusterDelSlots indicates an expected call of ClusterDelSlots.

func (*MockRedisMockRecorder) ClusterDelSlotsRange 

func (mr *MockRedisMockRecorder) ClusterDelSlotsRange(ctx, min, max any) *gomock.Call

ClusterDelSlotsRange indicates an expected call of ClusterDelSlotsRange.

func (*MockRedisMockRecorder) ClusterFailover 

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

ClusterFailover indicates an expected call of ClusterFailover.

func (*MockRedisMockRecorder) ClusterForget 

func (mr *MockRedisMockRecorder) ClusterForget(ctx, nodeID any) *gomock.Call

ClusterForget indicates an expected call of ClusterForget.

func (*MockRedisMockRecorder) ClusterGetKeysInSlot 

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

ClusterGetKeysInSlot indicates an expected call of ClusterGetKeysInSlot.

func (*MockRedisMockRecorder) ClusterInfo 

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

ClusterInfo indicates an expected call of ClusterInfo.

func (*MockRedisMockRecorder) ClusterKeySlot 

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 

func (mr *MockRedisMockRecorder) ClusterMeet(ctx, host, port any) *gomock.Call

ClusterMeet indicates an expected call of ClusterMeet.

func (*MockRedisMockRecorder) ClusterMyShardID 

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

ClusterMyShardID indicates an expected call of ClusterMyShardID.

func (*MockRedisMockRecorder) ClusterNodes 

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

ClusterNodes indicates an expected call of ClusterNodes.

func (*MockRedisMockRecorder) ClusterReplicate 

func (mr *MockRedisMockRecorder) ClusterReplicate(ctx, nodeID any) *gomock.Call

ClusterReplicate indicates an expected call of ClusterReplicate.

func (*MockRedisMockRecorder) ClusterResetHard 

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

ClusterResetHard indicates an expected call of ClusterResetHard.

func (*MockRedisMockRecorder) ClusterResetSoft 

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

ClusterResetSoft indicates an expected call of ClusterResetSoft.

func (*MockRedisMockRecorder) ClusterSaveConfig 

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

ClusterSaveConfig indicates an expected call of ClusterSaveConfig.

func (*MockRedisMockRecorder) ClusterShards 

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

ClusterShards indicates an expected call of ClusterShards.

func (*MockRedisMockRecorder) ClusterSlaves 

func (mr *MockRedisMockRecorder) ClusterSlaves(ctx, nodeID any) *gomock.Call

ClusterSlaves indicates an expected call of ClusterSlaves.

func (*MockRedisMockRecorder) ClusterSlots 

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

ClusterSlots indicates an expected call of ClusterSlots.

func (*MockRedisMockRecorder) Command 

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

Command indicates an expected call of Command.

func (*MockRedisMockRecorder) CommandGetKeys 

func (mr *MockRedisMockRecorder) CommandGetKeys(ctx any, commands ...any) *gomock.Call

CommandGetKeys indicates an expected call of CommandGetKeys.

func (*MockRedisMockRecorder) CommandGetKeysAndFlags 

func (mr *MockRedisMockRecorder) CommandGetKeysAndFlags(ctx any, commands ...any) *gomock.Call

CommandGetKeysAndFlags indicates an expected call of CommandGetKeysAndFlags.

func (*MockRedisMockRecorder) CommandList 

func (mr *MockRedisMockRecorder) CommandList(ctx, filter any) *gomock.Call

CommandList indicates an expected call of CommandList.

func (*MockRedisMockRecorder) ConfigGet 

func (mr *MockRedisMockRecorder) ConfigGet(ctx, parameter any) *gomock.Call

ConfigGet indicates an expected call of ConfigGet.

func (*MockRedisMockRecorder) ConfigResetStat 

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

ConfigResetStat indicates an expected call of ConfigResetStat.

func (*MockRedisMockRecorder) ConfigRewrite 

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

ConfigRewrite indicates an expected call of ConfigRewrite.

func (*MockRedisMockRecorder) ConfigSet 

func (mr *MockRedisMockRecorder) ConfigSet(ctx, parameter, value any) *gomock.Call

ConfigSet indicates an expected call of ConfigSet.

func (*MockRedisMockRecorder) Copy 

func (mr *MockRedisMockRecorder) Copy(ctx, sourceKey, destKey, db, replace any) *gomock.Call

Copy indicates an expected call of Copy.

func (*MockRedisMockRecorder) DBSize 

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

DBSize indicates an expected call of DBSize.

func (*MockRedisMockRecorder) DebugObject 

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

DebugObject indicates an expected call of DebugObject.

func (*MockRedisMockRecorder) Decr 

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

Decr indicates an expected call of Decr.

func (*MockRedisMockRecorder) DecrBy 

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

DecrBy indicates an expected call of DecrBy.

func (*MockRedisMockRecorder) Del 

func (mr *MockRedisMockRecorder) Del(ctx any, keys ...any) *gomock.Call

Del indicates an expected call of Del.

func (*MockRedisMockRecorder) Dump 

func (mr *MockRedisMockRecorder) Dump(ctx, key any) *gomock.Call

Dump indicates an expected call of Dump.

func (*MockRedisMockRecorder) Echo 

func (mr *MockRedisMockRecorder) Echo(ctx, message any) *gomock.Call

Echo indicates an expected call of Echo.

func (*MockRedisMockRecorder) Eval 

func (mr *MockRedisMockRecorder) Eval(ctx, script, keys any, args ...any) *gomock.Call

Eval indicates an expected call of Eval.

func (*MockRedisMockRecorder) EvalRO 

func (mr *MockRedisMockRecorder) EvalRO(ctx, script, keys any, args ...any) *gomock.Call

EvalRO indicates an expected call of EvalRO.

func (*MockRedisMockRecorder) EvalSha 

func (mr *MockRedisMockRecorder) EvalSha(ctx, sha1, keys any, args ...any) *gomock.Call

EvalSha indicates an expected call of EvalSha.

func (*MockRedisMockRecorder) EvalShaRO 

func (mr *MockRedisMockRecorder) EvalShaRO(ctx, sha1, keys any, args ...any) *gomock.Call

EvalShaRO indicates an expected call of EvalShaRO.

func (*MockRedisMockRecorder) Exists 

func (mr *MockRedisMockRecorder) Exists(ctx any, keys ...any) *gomock.Call

Exists indicates an expected call of Exists.

func (*MockRedisMockRecorder) Expire 

func (mr *MockRedisMockRecorder) Expire(ctx, key, expiration any) *gomock.Call

Expire indicates an expected call of Expire.

func (*MockRedisMockRecorder) ExpireAt 

func (mr *MockRedisMockRecorder) ExpireAt(ctx, key, tm any) *gomock.Call

ExpireAt indicates an expected call of ExpireAt.

func (*MockRedisMockRecorder) ExpireGT 

func (mr *MockRedisMockRecorder) ExpireGT(ctx, key, expiration any) *gomock.Call

ExpireGT indicates an expected call of ExpireGT.

func (*MockRedisMockRecorder) ExpireLT 

func (mr *MockRedisMockRecorder) ExpireLT(ctx, key, expiration any) *gomock.Call

ExpireLT indicates an expected call of ExpireLT.

func (*MockRedisMockRecorder) ExpireNX 

func (mr *MockRedisMockRecorder) ExpireNX(ctx, key, expiration any) *gomock.Call

ExpireNX indicates an expected call of ExpireNX.

func (*MockRedisMockRecorder) ExpireTime 

func (mr *MockRedisMockRecorder) ExpireTime(ctx, key any) *gomock.Call

ExpireTime indicates an expected call of ExpireTime.

func (*MockRedisMockRecorder) ExpireXX 

func (mr *MockRedisMockRecorder) ExpireXX(ctx, key, expiration any) *gomock.Call

ExpireXX indicates an expected call of ExpireXX.

func (*MockRedisMockRecorder) FCall 

func (mr *MockRedisMockRecorder) FCall(ctx, function, keys any, args ...any) *gomock.Call

FCall indicates an expected call of FCall.

func (*MockRedisMockRecorder) FCallRO 

func (mr *MockRedisMockRecorder) FCallRO(ctx, function, keys any, args ...any) *gomock.Call

FCallRO indicates an expected call of FCallRO.

func (*MockRedisMockRecorder) FCallRo 

func (mr *MockRedisMockRecorder) FCallRo(ctx, function, keys any, args ...any) *gomock.Call

FCallRo indicates an expected call of FCallRo.

func (*MockRedisMockRecorder) FlushAll 

func (mr *MockRedisMockRecorder) FlushAll(ctx any) *gomock.Call

FlushAll indicates an expected call of FlushAll.

func (*MockRedisMockRecorder) FlushAllAsync 

func (mr *MockRedisMockRecorder) FlushAllAsync(ctx any) *gomock.Call

FlushAllAsync indicates an expected call of FlushAllAsync.

func (*MockRedisMockRecorder) FlushDB 

func (mr *MockRedisMockRecorder) FlushDB(ctx any) *gomock.Call

FlushDB indicates an expected call of FlushDB.

func (*MockRedisMockRecorder) FlushDBAsync 

func (mr *MockRedisMockRecorder) FlushDBAsync(ctx any) *gomock.Call

FlushDBAsync indicates an expected call of FlushDBAsync.

func (*MockRedisMockRecorder) FunctionDelete 

func (mr *MockRedisMockRecorder) FunctionDelete(ctx, libName any) *gomock.Call

FunctionDelete indicates an expected call of FunctionDelete.

func (*MockRedisMockRecorder) FunctionDump 

func (mr *MockRedisMockRecorder) FunctionDump(ctx any) *gomock.Call

FunctionDump indicates an expected call of FunctionDump.

func (*MockRedisMockRecorder) FunctionFlush 

func (mr *MockRedisMockRecorder) FunctionFlush(ctx any) *gomock.Call

FunctionFlush indicates an expected call of FunctionFlush.

func (*MockRedisMockRecorder) FunctionFlushAsync 

func (mr *MockRedisMockRecorder) FunctionFlushAsync(ctx any) *gomock.Call

FunctionFlushAsync indicates an expected call of FunctionFlushAsync.

func (*MockRedisMockRecorder) FunctionKill 

func (mr *MockRedisMockRecorder) FunctionKill(ctx any) *gomock.Call

FunctionKill indicates an expected call of FunctionKill.

func (*MockRedisMockRecorder) FunctionList 

func (mr *MockRedisMockRecorder) FunctionList(ctx, q any) *gomock.Call

FunctionList indicates an expected call of FunctionList.

func (*MockRedisMockRecorder) FunctionLoad 

func (mr *MockRedisMockRecorder) FunctionLoad(ctx, code any) *gomock.Call

FunctionLoad indicates an expected call of FunctionLoad.

func (*MockRedisMockRecorder) FunctionLoadReplace 

func (mr *MockRedisMockRecorder) FunctionLoadReplace(ctx, code any) *gomock.Call

FunctionLoadReplace indicates an expected call of FunctionLoadReplace.

func (*MockRedisMockRecorder) FunctionRestore 

func (mr *MockRedisMockRecorder) FunctionRestore(ctx, libDump any) *gomock.Call

FunctionRestore indicates an expected call of FunctionRestore.

func (*MockRedisMockRecorder) FunctionStats 

func (mr *MockRedisMockRecorder) FunctionStats(ctx any) *gomock.Call

FunctionStats indicates an expected call of FunctionStats.

func (*MockRedisMockRecorder) GeoAdd 

func (mr *MockRedisMockRecorder) GeoAdd(ctx, key any, geoLocation ...any) *gomock.Call

GeoAdd indicates an expected call of GeoAdd.

func (*MockRedisMockRecorder) GeoDist 

func (mr *MockRedisMockRecorder) GeoDist(ctx, key, member1, member2, unit any) *gomock.Call

GeoDist indicates an expected call of GeoDist.

func (*MockRedisMockRecorder) GeoHash 

func (mr *MockRedisMockRecorder) GeoHash(ctx, key any, members ...any) *gomock.Call

GeoHash indicates an expected call of GeoHash.

func (*MockRedisMockRecorder) GeoPos 

func (mr *MockRedisMockRecorder) GeoPos(ctx, key any, members ...any) *gomock.Call

GeoPos indicates an expected call of GeoPos.

func (*MockRedisMockRecorder) GeoRadius 

func (mr *MockRedisMockRecorder) GeoRadius(ctx, key, longitude, latitude, query any) *gomock.Call

GeoRadius indicates an expected call of GeoRadius.

func (*MockRedisMockRecorder) GeoRadiusByMember 

func (mr *MockRedisMockRecorder) GeoRadiusByMember(ctx, key, member, query any) *gomock.Call

GeoRadiusByMember indicates an expected call of GeoRadiusByMember.

func (*MockRedisMockRecorder) GeoRadiusByMemberStore 

func (mr *MockRedisMockRecorder) GeoRadiusByMemberStore(ctx, key, member, query any) *gomock.Call

GeoRadiusByMemberStore indicates an expected call of GeoRadiusByMemberStore.

func (*MockRedisMockRecorder) GeoRadiusStore 

func (mr *MockRedisMockRecorder) GeoRadiusStore(ctx, key, longitude, latitude, query any) *gomock.Call

GeoRadiusStore indicates an expected call of GeoRadiusStore.

func (*MockRedisMockRecorder) GeoSearch 

func (mr *MockRedisMockRecorder) GeoSearch(ctx, key, q any) *gomock.Call

GeoSearch indicates an expected call of GeoSearch.

func (*MockRedisMockRecorder) GeoSearchLocation 

func (mr *MockRedisMockRecorder) GeoSearchLocation(ctx, key, q any) *gomock.Call

GeoSearchLocation indicates an expected call of GeoSearchLocation.

func (*MockRedisMockRecorder) GeoSearchStore 

func (mr *MockRedisMockRecorder) GeoSearchStore(ctx, key, store, q any) *gomock.Call

GeoSearchStore indicates an expected call of GeoSearchStore.

func (*MockRedisMockRecorder) Get 

func (mr *MockRedisMockRecorder) Get(ctx, key any) *gomock.Call

Get indicates an expected call of Get.

func (*MockRedisMockRecorder) GetBit 

func (mr *MockRedisMockRecorder) GetBit(ctx, key, offset any) *gomock.Call

GetBit indicates an expected call of GetBit.

func (*MockRedisMockRecorder) GetDel 

func (mr *MockRedisMockRecorder) GetDel(ctx, key any) *gomock.Call

GetDel indicates an expected call of GetDel.

func (*MockRedisMockRecorder) GetEx 

func (mr *MockRedisMockRecorder) GetEx(ctx, key, expiration any) *gomock.Call

GetEx indicates an expected call of GetEx.

func (*MockRedisMockRecorder) GetRange 

func (mr *MockRedisMockRecorder) GetRange(ctx, key, start, end any) *gomock.Call

GetRange indicates an expected call of GetRange.

func (*MockRedisMockRecorder) GetSet 

func (mr *MockRedisMockRecorder) GetSet(ctx, key, value any) *gomock.Call

GetSet indicates an expected call of GetSet.

func (*MockRedisMockRecorder) HDel 

func (mr *MockRedisMockRecorder) HDel(ctx, key any, fields ...any) *gomock.Call

HDel indicates an expected call of HDel.

func (*MockRedisMockRecorder) HExists 

func (mr *MockRedisMockRecorder) HExists(ctx, key, field any) *gomock.Call

HExists indicates an expected call of HExists.

func (*MockRedisMockRecorder) HExpire 

func (mr *MockRedisMockRecorder) HExpire(ctx, key, expiration any, fields ...any) *gomock.Call

HExpire indicates an expected call of HExpire.

func (*MockRedisMockRecorder) HExpireAt 

func (mr *MockRedisMockRecorder) HExpireAt(ctx, key, tm any, fields ...any) *gomock.Call

HExpireAt indicates an expected call of HExpireAt.

func (*MockRedisMockRecorder) HExpireAtWithArgs 

func (mr *MockRedisMockRecorder) HExpireAtWithArgs(ctx, key, tm, expirationArgs any, fields ...any) *gomock.Call

HExpireAtWithArgs indicates an expected call of HExpireAtWithArgs.

func (*MockRedisMockRecorder) HExpireTime 

func (mr *MockRedisMockRecorder) HExpireTime(ctx, key any, fields ...any) *gomock.Call

HExpireTime indicates an expected call of HExpireTime.

func (*MockRedisMockRecorder) HExpireWithArgs 

func (mr *MockRedisMockRecorder) HExpireWithArgs(ctx, key, expiration, expirationArgs any, fields ...any) *gomock.Call

HExpireWithArgs indicates an expected call of HExpireWithArgs.

func (*MockRedisMockRecorder) HGet 

func (mr *MockRedisMockRecorder) HGet(ctx, key, field any) *gomock.Call

HGet indicates an expected call of HGet.

func (*MockRedisMockRecorder) HGetAll 

func (mr *MockRedisMockRecorder) HGetAll(ctx, key any) *gomock.Call

HGetAll indicates an expected call of HGetAll.

func (*MockRedisMockRecorder) HIncrBy 

func (mr *MockRedisMockRecorder) HIncrBy(ctx, key, field, incr any) *gomock.Call

HIncrBy indicates an expected call of HIncrBy.

func (*MockRedisMockRecorder) HIncrByFloat 

func (mr *MockRedisMockRecorder) HIncrByFloat(ctx, key, field, incr any) *gomock.Call

HIncrByFloat indicates an expected call of HIncrByFloat.

func (*MockRedisMockRecorder) HKeys 

func (mr *MockRedisMockRecorder) HKeys(ctx, key any) *gomock.Call

HKeys indicates an expected call of HKeys.

func (*MockRedisMockRecorder) HLen 

func (mr *MockRedisMockRecorder) HLen(ctx, key any) *gomock.Call

HLen indicates an expected call of HLen.

func (*MockRedisMockRecorder) HMGet 

func (mr *MockRedisMockRecorder) HMGet(ctx, key any, fields ...any) *gomock.Call

HMGet indicates an expected call of HMGet.

func (*MockRedisMockRecorder) HMSet 

func (mr *MockRedisMockRecorder) HMSet(ctx, key any, values ...any) *gomock.Call

HMSet indicates an expected call of HMSet.

func (*MockRedisMockRecorder) HPExpire 

func (mr *MockRedisMockRecorder) HPExpire(ctx, key, expiration any, fields ...any) *gomock.Call

HPExpire indicates an expected call of HPExpire.

func (*MockRedisMockRecorder) HPExpireAt 

func (mr *MockRedisMockRecorder) HPExpireAt(ctx, key, tm any, fields ...any) *gomock.Call

HPExpireAt indicates an expected call of HPExpireAt.

func (*MockRedisMockRecorder) HPExpireAtWithArgs 

func (mr *MockRedisMockRecorder) HPExpireAtWithArgs(ctx, key, tm, expirationArgs any, fields ...any) *gomock.Call

HPExpireAtWithArgs indicates an expected call of HPExpireAtWithArgs.

func (*MockRedisMockRecorder) HPExpireTime 

func (mr *MockRedisMockRecorder) HPExpireTime(ctx, key any, fields ...any) *gomock.Call

HPExpireTime indicates an expected call of HPExpireTime.

func (*MockRedisMockRecorder) HPExpireWithArgs 

func (mr *MockRedisMockRecorder) HPExpireWithArgs(ctx, key, expiration, expirationArgs any, fields ...any) *gomock.Call

HPExpireWithArgs indicates an expected call of HPExpireWithArgs.

func (*MockRedisMockRecorder) HPTTL 

func (mr *MockRedisMockRecorder) HPTTL(ctx, key any, fields ...any) *gomock.Call

HPTTL indicates an expected call of HPTTL.

func (*MockRedisMockRecorder) HPersist 

func (mr *MockRedisMockRecorder) HPersist(ctx, key any, fields ...any) *gomock.Call

HPersist indicates an expected call of HPersist.

func (*MockRedisMockRecorder) HRandField 

func (mr *MockRedisMockRecorder) HRandField(ctx, key, count any) *gomock.Call

HRandField indicates an expected call of HRandField.

func (*MockRedisMockRecorder) HRandFieldWithValues 

func (mr *MockRedisMockRecorder) HRandFieldWithValues(ctx, key, count any) *gomock.Call

HRandFieldWithValues indicates an expected call of HRandFieldWithValues.

func (*MockRedisMockRecorder) HScan 

func (mr *MockRedisMockRecorder) HScan(ctx, key, cursor, match, count any) *gomock.Call

HScan indicates an expected call of HScan.

func (*MockRedisMockRecorder) HScanNoValues 

func (mr *MockRedisMockRecorder) HScanNoValues(ctx, key, cursor, match, count any) *gomock.Call

HScanNoValues indicates an expected call of HScanNoValues.

func (*MockRedisMockRecorder) HSet 

func (mr *MockRedisMockRecorder) HSet(ctx, key any, values ...any) *gomock.Call

HSet indicates an expected call of HSet.

func (*MockRedisMockRecorder) HSetNX 

func (mr *MockRedisMockRecorder) HSetNX(ctx, key, field, value any) *gomock.Call

HSetNX indicates an expected call of HSetNX.

func (*MockRedisMockRecorder) HTTL 

func (mr *MockRedisMockRecorder) HTTL(ctx, key any, fields ...any) *gomock.Call

HTTL indicates an expected call of HTTL.

func (*MockRedisMockRecorder) HVals 

func (mr *MockRedisMockRecorder) HVals(ctx, key any) *gomock.Call

HVals indicates an expected call of HVals.

func (*MockRedisMockRecorder) HealthCheck 

func (mr *MockRedisMockRecorder) HealthCheck() *gomock.Call

HealthCheck indicates an expected call of HealthCheck.

func (*MockRedisMockRecorder) Incr 

func (mr *MockRedisMockRecorder) Incr(ctx, key any) *gomock.Call

Incr indicates an expected call of Incr.

func (*MockRedisMockRecorder) IncrBy 

func (mr *MockRedisMockRecorder) IncrBy(ctx, key, value any) *gomock.Call

IncrBy indicates an expected call of IncrBy.

func (*MockRedisMockRecorder) IncrByFloat 

func (mr *MockRedisMockRecorder) IncrByFloat(ctx, key, value any) *gomock.Call

IncrByFloat indicates an expected call of IncrByFloat.

func (*MockRedisMockRecorder) Info 

func (mr *MockRedisMockRecorder) Info(ctx any, section ...any) *gomock.Call

Info indicates an expected call of Info.

func (*MockRedisMockRecorder) JSONArrAppend 

func (mr *MockRedisMockRecorder) JSONArrAppend(ctx, key, path any, values ...any) *gomock.Call

JSONArrAppend indicates an expected call of JSONArrAppend.

func (*MockRedisMockRecorder) JSONArrIndex 

func (mr *MockRedisMockRecorder) JSONArrIndex(ctx, key, path any, value ...any) *gomock.Call

JSONArrIndex indicates an expected call of JSONArrIndex.

func (*MockRedisMockRecorder) JSONArrIndexWithArgs 

func (mr *MockRedisMockRecorder) JSONArrIndexWithArgs(ctx, key, path, options any, value ...any) *gomock.Call

JSONArrIndexWithArgs indicates an expected call of JSONArrIndexWithArgs.

func (*MockRedisMockRecorder) JSONArrInsert 

func (mr *MockRedisMockRecorder) JSONArrInsert(ctx, key, path, index any, values ...any) *gomock.Call

JSONArrInsert indicates an expected call of JSONArrInsert.

func (*MockRedisMockRecorder) JSONArrLen 

func (mr *MockRedisMockRecorder) JSONArrLen(ctx, key, path any) *gomock.Call

JSONArrLen indicates an expected call of JSONArrLen.

func (*MockRedisMockRecorder) JSONArrPop 

func (mr *MockRedisMockRecorder) JSONArrPop(ctx, key, path, index any) *gomock.Call

JSONArrPop indicates an expected call of JSONArrPop.

func (*MockRedisMockRecorder) JSONArrTrim 

func (mr *MockRedisMockRecorder) JSONArrTrim(ctx, key, path any) *gomock.Call

JSONArrTrim indicates an expected call of JSONArrTrim.

func (*MockRedisMockRecorder) JSONArrTrimWithArgs 

func (mr *MockRedisMockRecorder) JSONArrTrimWithArgs(ctx, key, path, options any) *gomock.Call

JSONArrTrimWithArgs indicates an expected call of JSONArrTrimWithArgs.

func (*MockRedisMockRecorder) JSONClear 

func (mr *MockRedisMockRecorder) JSONClear(ctx, key, path any) *gomock.Call

JSONClear indicates an expected call of JSONClear.

func (*MockRedisMockRecorder) JSONDebugMemory 

func (mr *MockRedisMockRecorder) JSONDebugMemory(ctx, key, path any) *gomock.Call

JSONDebugMemory indicates an expected call of JSONDebugMemory.

func (*MockRedisMockRecorder) JSONDel 

func (mr *MockRedisMockRecorder) JSONDel(ctx, key, path any) *gomock.Call

JSONDel indicates an expected call of JSONDel.

func (*MockRedisMockRecorder) JSONForget 

func (mr *MockRedisMockRecorder) JSONForget(ctx, key, path any) *gomock.Call

JSONForget indicates an expected call of JSONForget.

func (*MockRedisMockRecorder) JSONGet 

func (mr *MockRedisMockRecorder) JSONGet(ctx, key any, paths ...any) *gomock.Call

JSONGet indicates an expected call of JSONGet.

func (*MockRedisMockRecorder) JSONGetWithArgs 

func (mr *MockRedisMockRecorder) JSONGetWithArgs(ctx, key, options any, paths ...any) *gomock.Call

JSONGetWithArgs indicates an expected call of JSONGetWithArgs.

func (*MockRedisMockRecorder) JSONMGet 

func (mr *MockRedisMockRecorder) JSONMGet(ctx, path any, keys ...any) *gomock.Call

JSONMGet indicates an expected call of JSONMGet.

func (*MockRedisMockRecorder) JSONMSet 

func (mr *MockRedisMockRecorder) JSONMSet(ctx any, params ...any) *gomock.Call

JSONMSet indicates an expected call of JSONMSet.

func (*MockRedisMockRecorder) JSONMSetArgs 

func (mr *MockRedisMockRecorder) JSONMSetArgs(ctx, docs any) *gomock.Call

JSONMSetArgs indicates an expected call of JSONMSetArgs.

func (*MockRedisMockRecorder) JSONMerge 

func (mr *MockRedisMockRecorder) JSONMerge(ctx, key, path, value any) *gomock.Call

JSONMerge indicates an expected call of JSONMerge.

func (*MockRedisMockRecorder) JSONNumIncrBy 

func (mr *MockRedisMockRecorder) JSONNumIncrBy(ctx, key, path, value any) *gomock.Call

JSONNumIncrBy indicates an expected call of JSONNumIncrBy.

func (*MockRedisMockRecorder) JSONObjKeys 

func (mr *MockRedisMockRecorder) JSONObjKeys(ctx, key, path any) *gomock.Call

JSONObjKeys indicates an expected call of JSONObjKeys.

func (*MockRedisMockRecorder) JSONObjLen 

func (mr *MockRedisMockRecorder) JSONObjLen(ctx, key, path any) *gomock.Call

JSONObjLen indicates an expected call of JSONObjLen.

func (*MockRedisMockRecorder) JSONSet 

func (mr *MockRedisMockRecorder) JSONSet(ctx, key, path, value any) *gomock.Call

JSONSet indicates an expected call of JSONSet.

func (*MockRedisMockRecorder) JSONSetMode 

func (mr *MockRedisMockRecorder) JSONSetMode(ctx, key, path, value, mode any) *gomock.Call

JSONSetMode indicates an expected call of JSONSetMode.

func (*MockRedisMockRecorder) JSONStrAppend 

func (mr *MockRedisMockRecorder) JSONStrAppend(ctx, key, path, value any) *gomock.Call

JSONStrAppend indicates an expected call of JSONStrAppend.

func (*MockRedisMockRecorder) JSONStrLen 

func (mr *MockRedisMockRecorder) JSONStrLen(ctx, key, path any) *gomock.Call

JSONStrLen indicates an expected call of JSONStrLen.

func (*MockRedisMockRecorder) JSONToggle 

func (mr *MockRedisMockRecorder) JSONToggle(ctx, key, path any) *gomock.Call

JSONToggle indicates an expected call of JSONToggle.

func (*MockRedisMockRecorder) JSONType 

func (mr *MockRedisMockRecorder) JSONType(ctx, key, path any) *gomock.Call

JSONType indicates an expected call of JSONType.

func (*MockRedisMockRecorder) Keys 

func (mr *MockRedisMockRecorder) Keys(ctx, pattern any) *gomock.Call

Keys indicates an expected call of Keys.

func (*MockRedisMockRecorder) LCS 

func (mr *MockRedisMockRecorder) LCS(ctx, q any) *gomock.Call

LCS indicates an expected call of LCS.

func (*MockRedisMockRecorder) LIndex 

func (mr *MockRedisMockRecorder) LIndex(ctx, key, index any) *gomock.Call

LIndex indicates an expected call of LIndex.

func (*MockRedisMockRecorder) LInsert 

func (mr *MockRedisMockRecorder) LInsert(ctx, key, op, pivot, value any) *gomock.Call

LInsert indicates an expected call of LInsert.

func (*MockRedisMockRecorder) LInsertAfter 

func (mr *MockRedisMockRecorder) LInsertAfter(ctx, key, pivot, value any) *gomock.Call

LInsertAfter indicates an expected call of LInsertAfter.

func (*MockRedisMockRecorder) LInsertBefore 

func (mr *MockRedisMockRecorder) LInsertBefore(ctx, key, pivot, value any) *gomock.Call

LInsertBefore indicates an expected call of LInsertBefore.

func (*MockRedisMockRecorder) LLen 

func (mr *MockRedisMockRecorder) LLen(ctx, key any) *gomock.Call

LLen indicates an expected call of LLen.

func (*MockRedisMockRecorder) LMPop 

func (mr *MockRedisMockRecorder) LMPop(ctx, direction, count any, keys ...any) *gomock.Call

LMPop indicates an expected call of LMPop.

func (*MockRedisMockRecorder) LMove 

func (mr *MockRedisMockRecorder) LMove(ctx, source, destination, srcpos, destpos any) *gomock.Call

LMove indicates an expected call of LMove.

func (*MockRedisMockRecorder) LPop 

func (mr *MockRedisMockRecorder) LPop(ctx, key any) *gomock.Call

LPop indicates an expected call of LPop.

func (*MockRedisMockRecorder) LPopCount 

func (mr *MockRedisMockRecorder) LPopCount(ctx, key, count any) *gomock.Call

LPopCount indicates an expected call of LPopCount.

func (*MockRedisMockRecorder) LPos 

func (mr *MockRedisMockRecorder) LPos(ctx, key, value, args any) *gomock.Call

LPos indicates an expected call of LPos.

func (*MockRedisMockRecorder) LPosCount 

func (mr *MockRedisMockRecorder) LPosCount(ctx, key, value, count, args any) *gomock.Call

LPosCount indicates an expected call of LPosCount.

func (*MockRedisMockRecorder) LPush 

func (mr *MockRedisMockRecorder) LPush(ctx, key any, values ...any) *gomock.Call

LPush indicates an expected call of LPush.

func (*MockRedisMockRecorder) LPushX 

func (mr *MockRedisMockRecorder) LPushX(ctx, key any, values ...any) *gomock.Call

LPushX indicates an expected call of LPushX.

func (*MockRedisMockRecorder) LRange 

func (mr *MockRedisMockRecorder) LRange(ctx, key, start, stop any) *gomock.Call

LRange indicates an expected call of LRange.

func (*MockRedisMockRecorder) LRem 

func (mr *MockRedisMockRecorder) LRem(ctx, key, count, value any) *gomock.Call

LRem indicates an expected call of LRem.

func (*MockRedisMockRecorder) LSet 

func (mr *MockRedisMockRecorder) LSet(ctx, key, index, value any) *gomock.Call

LSet indicates an expected call of LSet.

func (*MockRedisMockRecorder) LTrim 

func (mr *MockRedisMockRecorder) LTrim(ctx, key, start, stop any) *gomock.Call

LTrim indicates an expected call of LTrim.

func (*MockRedisMockRecorder) LastSave 

func (mr *MockRedisMockRecorder) LastSave(ctx any) *gomock.Call

LastSave indicates an expected call of LastSave.

func (*MockRedisMockRecorder) MGet 

func (mr *MockRedisMockRecorder) MGet(ctx any, keys ...any) *gomock.Call

MGet indicates an expected call of MGet.

func (*MockRedisMockRecorder) MSet 

func (mr *MockRedisMockRecorder) MSet(ctx any, values ...any) *gomock.Call

MSet indicates an expected call of MSet.

func (*MockRedisMockRecorder) MSetNX 

func (mr *MockRedisMockRecorder) MSetNX(ctx any, values ...any) *gomock.Call

MSetNX indicates an expected call of MSetNX.

func (*MockRedisMockRecorder) MemoryUsage 

func (mr *MockRedisMockRecorder) MemoryUsage(ctx, key any, samples ...any) *gomock.Call

MemoryUsage indicates an expected call of MemoryUsage.

func (*MockRedisMockRecorder) Migrate 

func (mr *MockRedisMockRecorder) Migrate(ctx, host, port, key, db, timeout any) *gomock.Call

Migrate indicates an expected call of Migrate.

func (*MockRedisMockRecorder) ModuleLoadex 

func (mr *MockRedisMockRecorder) ModuleLoadex(ctx, conf any) *gomock.Call

ModuleLoadex indicates an expected call of ModuleLoadex.

func (*MockRedisMockRecorder) Move 

func (mr *MockRedisMockRecorder) Move(ctx, key, db any) *gomock.Call

Move indicates an expected call of Move.

func (*MockRedisMockRecorder) ObjectEncoding 

func (mr *MockRedisMockRecorder) ObjectEncoding(ctx, key any) *gomock.Call

ObjectEncoding indicates an expected call of ObjectEncoding.

func (*MockRedisMockRecorder) ObjectFreq 

func (mr *MockRedisMockRecorder) ObjectFreq(ctx, key any) *gomock.Call

ObjectFreq indicates an expected call of ObjectFreq.

func (*MockRedisMockRecorder) ObjectIdleTime 

func (mr *MockRedisMockRecorder) ObjectIdleTime(ctx, key any) *gomock.Call

ObjectIdleTime indicates an expected call of ObjectIdleTime.

func (*MockRedisMockRecorder) ObjectRefCount 

func (mr *MockRedisMockRecorder) ObjectRefCount(ctx, key any) *gomock.Call

ObjectRefCount indicates an expected call of ObjectRefCount.

func (*MockRedisMockRecorder) PExpire 

func (mr *MockRedisMockRecorder) PExpire(ctx, key, expiration any) *gomock.Call

PExpire indicates an expected call of PExpire.

func (*MockRedisMockRecorder) PExpireAt 

func (mr *MockRedisMockRecorder) PExpireAt(ctx, key, tm any) *gomock.Call

PExpireAt indicates an expected call of PExpireAt.

func (*MockRedisMockRecorder) PExpireTime 

func (mr *MockRedisMockRecorder) PExpireTime(ctx, key any) *gomock.Call

PExpireTime indicates an expected call of PExpireTime.

func (*MockRedisMockRecorder) PFAdd 

func (mr *MockRedisMockRecorder) PFAdd(ctx, key any, els ...any) *gomock.Call

PFAdd indicates an expected call of PFAdd.

func (*MockRedisMockRecorder) PFCount 

func (mr *MockRedisMockRecorder) PFCount(ctx any, keys ...any) *gomock.Call

PFCount indicates an expected call of PFCount.

func (*MockRedisMockRecorder) PFMerge 

func (mr *MockRedisMockRecorder) PFMerge(ctx, dest any, keys ...any) *gomock.Call

PFMerge indicates an expected call of PFMerge.

func (*MockRedisMockRecorder) PTTL 

func (mr *MockRedisMockRecorder) PTTL(ctx, key any) *gomock.Call

PTTL indicates an expected call of PTTL.

func (*MockRedisMockRecorder) Persist 

func (mr *MockRedisMockRecorder) Persist(ctx, key any) *gomock.Call

Persist indicates an expected call of Persist.

func (*MockRedisMockRecorder) Ping 

func (mr *MockRedisMockRecorder) Ping(ctx any) *gomock.Call

Ping indicates an expected call of Ping.

func (*MockRedisMockRecorder) Pipeline 

func (mr *MockRedisMockRecorder) Pipeline() *gomock.Call

Pipeline indicates an expected call of Pipeline.

func (*MockRedisMockRecorder) Pipelined 

func (mr *MockRedisMockRecorder) Pipelined(ctx, fn any) *gomock.Call

Pipelined indicates an expected call of Pipelined.

func (*MockRedisMockRecorder) PubSubChannels 

func (mr *MockRedisMockRecorder) PubSubChannels(ctx, pattern any) *gomock.Call

PubSubChannels indicates an expected call of PubSubChannels.

func (*MockRedisMockRecorder) PubSubNumPat 

func (mr *MockRedisMockRecorder) PubSubNumPat(ctx any) *gomock.Call

PubSubNumPat indicates an expected call of PubSubNumPat.

func (*MockRedisMockRecorder) PubSubNumSub 

func (mr *MockRedisMockRecorder) PubSubNumSub(ctx any, channels ...any) *gomock.Call

PubSubNumSub indicates an expected call of PubSubNumSub.

func (*MockRedisMockRecorder) PubSubShardChannels 

func (mr *MockRedisMockRecorder) PubSubShardChannels(ctx, pattern any) *gomock.Call

PubSubShardChannels indicates an expected call of PubSubShardChannels.

func (*MockRedisMockRecorder) PubSubShardNumSub 

func (mr *MockRedisMockRecorder) PubSubShardNumSub(ctx any, channels ...any) *gomock.Call

PubSubShardNumSub indicates an expected call of PubSubShardNumSub.

func (*MockRedisMockRecorder) Publish 

func (mr *MockRedisMockRecorder) Publish(ctx, channel, message any) *gomock.Call

Publish indicates an expected call of Publish.

func (*MockRedisMockRecorder) Quit 

func (mr *MockRedisMockRecorder) Quit(ctx any) *gomock.Call

Quit indicates an expected call of Quit.

func (*MockRedisMockRecorder) RPop 

func (mr *MockRedisMockRecorder) RPop(ctx, key any) *gomock.Call

RPop indicates an expected call of RPop.

func (*MockRedisMockRecorder) RPopCount 

func (mr *MockRedisMockRecorder) RPopCount(ctx, key, count any) *gomock.Call

RPopCount indicates an expected call of RPopCount.

func (*MockRedisMockRecorder) RPopLPush 

func (mr *MockRedisMockRecorder) RPopLPush(ctx, source, destination any) *gomock.Call

RPopLPush indicates an expected call of RPopLPush.

func (*MockRedisMockRecorder) RPush 

func (mr *MockRedisMockRecorder) RPush(ctx, key any, values ...any) *gomock.Call

RPush indicates an expected call of RPush.

func (*MockRedisMockRecorder) RPushX 

func (mr *MockRedisMockRecorder) RPushX(ctx, key any, values ...any) *gomock.Call

RPushX indicates an expected call of RPushX.

func (*MockRedisMockRecorder) RandomKey 

func (mr *MockRedisMockRecorder) RandomKey(ctx any) *gomock.Call

RandomKey indicates an expected call of RandomKey.

func (*MockRedisMockRecorder) ReadOnly 

func (mr *MockRedisMockRecorder) ReadOnly(ctx any) *gomock.Call

ReadOnly indicates an expected call of ReadOnly.

func (*MockRedisMockRecorder) ReadWrite 

func (mr *MockRedisMockRecorder) ReadWrite(ctx any) *gomock.Call

ReadWrite indicates an expected call of ReadWrite.

func (*MockRedisMockRecorder) Rename 

func (mr *MockRedisMockRecorder) Rename(ctx, key, newkey any) *gomock.Call

Rename indicates an expected call of Rename.

func (*MockRedisMockRecorder) RenameNX 

func (mr *MockRedisMockRecorder) RenameNX(ctx, key, newkey any) *gomock.Call

RenameNX indicates an expected call of RenameNX.

func (*MockRedisMockRecorder) Restore 

func (mr *MockRedisMockRecorder) Restore(ctx, key, ttl, value any) *gomock.Call

Restore indicates an expected call of Restore.

func (*MockRedisMockRecorder) RestoreReplace 

func (mr *MockRedisMockRecorder) RestoreReplace(ctx, key, ttl, value any) *gomock.Call

RestoreReplace indicates an expected call of RestoreReplace.

func (*MockRedisMockRecorder) SAdd 

func (mr *MockRedisMockRecorder) SAdd(ctx, key any, members ...any) *gomock.Call

SAdd indicates an expected call of SAdd.

func (*MockRedisMockRecorder) SCard 

func (mr *MockRedisMockRecorder) SCard(ctx, key any) *gomock.Call

SCard indicates an expected call of SCard.

func (*MockRedisMockRecorder) SDiff 

func (mr *MockRedisMockRecorder) SDiff(ctx any, keys ...any) *gomock.Call

SDiff indicates an expected call of SDiff.

func (*MockRedisMockRecorder) SDiffStore 

func (mr *MockRedisMockRecorder) SDiffStore(ctx, destination any, keys ...any) *gomock.Call

SDiffStore indicates an expected call of SDiffStore.

func (*MockRedisMockRecorder) SInter 

func (mr *MockRedisMockRecorder) SInter(ctx any, keys ...any) *gomock.Call

SInter indicates an expected call of SInter.

func (*MockRedisMockRecorder) SInterCard 

func (mr *MockRedisMockRecorder) SInterCard(ctx, limit any, keys ...any) *gomock.Call

SInterCard indicates an expected call of SInterCard.

func (*MockRedisMockRecorder) SInterStore 

func (mr *MockRedisMockRecorder) SInterStore(ctx, destination any, keys ...any) *gomock.Call

SInterStore indicates an expected call of SInterStore.

func (*MockRedisMockRecorder) SIsMember 

func (mr *MockRedisMockRecorder) SIsMember(ctx, key, member any) *gomock.Call

SIsMember indicates an expected call of SIsMember.

func (*MockRedisMockRecorder) SMIsMember 

func (mr *MockRedisMockRecorder) SMIsMember(ctx, key any, members ...any) *gomock.Call

SMIsMember indicates an expected call of SMIsMember.

func (*MockRedisMockRecorder) SMembers 

func (mr *MockRedisMockRecorder) SMembers(ctx, key any) *gomock.Call

SMembers indicates an expected call of SMembers.

func (*MockRedisMockRecorder) SMembersMap 

func (mr *MockRedisMockRecorder) SMembersMap(ctx, key any) *gomock.Call

SMembersMap indicates an expected call of SMembersMap.

func (*MockRedisMockRecorder) SMove 

func (mr *MockRedisMockRecorder) SMove(ctx, source, destination, member any) *gomock.Call

SMove indicates an expected call of SMove.

func (*MockRedisMockRecorder) SPop 

func (mr *MockRedisMockRecorder) SPop(ctx, key any) *gomock.Call

SPop indicates an expected call of SPop.

func (*MockRedisMockRecorder) SPopN 

func (mr *MockRedisMockRecorder) SPopN(ctx, key, count any) *gomock.Call

SPopN indicates an expected call of SPopN.

func (*MockRedisMockRecorder) SPublish 

func (mr *MockRedisMockRecorder) SPublish(ctx, channel, message any) *gomock.Call

SPublish indicates an expected call of SPublish.

func (*MockRedisMockRecorder) SRandMember 

func (mr *MockRedisMockRecorder) SRandMember(ctx, key any) *gomock.Call

SRandMember indicates an expected call of SRandMember.

func (*MockRedisMockRecorder) SRandMemberN 

func (mr *MockRedisMockRecorder) SRandMemberN(ctx, key, count any) *gomock.Call

SRandMemberN indicates an expected call of SRandMemberN.

func (*MockRedisMockRecorder) SRem 

func (mr *MockRedisMockRecorder) SRem(ctx, key any, members ...any) *gomock.Call

SRem indicates an expected call of SRem.

func (*MockRedisMockRecorder) SScan 

func (mr *MockRedisMockRecorder) SScan(ctx, key, cursor, match, count any) *gomock.Call

SScan indicates an expected call of SScan.

func (*MockRedisMockRecorder) SUnion 

func (mr *MockRedisMockRecorder) SUnion(ctx any, keys ...any) *gomock.Call

SUnion indicates an expected call of SUnion.

func (*MockRedisMockRecorder) SUnionStore 

func (mr *MockRedisMockRecorder) SUnionStore(ctx, destination any, keys ...any) *gomock.Call

SUnionStore indicates an expected call of SUnionStore.

func (*MockRedisMockRecorder) Save 

func (mr *MockRedisMockRecorder) Save(ctx any) *gomock.Call

Save indicates an expected call of Save.

func (*MockRedisMockRecorder) Scan 

func (mr *MockRedisMockRecorder) Scan(ctx, cursor, match, count any) *gomock.Call

Scan indicates an expected call of Scan.

func (*MockRedisMockRecorder) ScanType 

func (mr *MockRedisMockRecorder) ScanType(ctx, cursor, match, count, keyType any) *gomock.Call

ScanType indicates an expected call of ScanType.

func (*MockRedisMockRecorder) ScriptExists 

func (mr *MockRedisMockRecorder) ScriptExists(ctx any, hashes ...any) *gomock.Call

ScriptExists indicates an expected call of ScriptExists.

func (*MockRedisMockRecorder) ScriptFlush 

func (mr *MockRedisMockRecorder) ScriptFlush(ctx any) *gomock.Call

ScriptFlush indicates an expected call of ScriptFlush.

func (*MockRedisMockRecorder) ScriptKill 

func (mr *MockRedisMockRecorder) ScriptKill(ctx any) *gomock.Call

ScriptKill indicates an expected call of ScriptKill.

func (*MockRedisMockRecorder) ScriptLoad 

func (mr *MockRedisMockRecorder) ScriptLoad(ctx, script any) *gomock.Call

ScriptLoad indicates an expected call of ScriptLoad.

func (*MockRedisMockRecorder) Set 

func (mr *MockRedisMockRecorder) Set(ctx, key, value, expiration any) *gomock.Call

Set indicates an expected call of Set.

func (*MockRedisMockRecorder) SetArgs 

func (mr *MockRedisMockRecorder) SetArgs(ctx, key, value, a any) *gomock.Call

SetArgs indicates an expected call of SetArgs.

func (*MockRedisMockRecorder) SetBit 

func (mr *MockRedisMockRecorder) SetBit(ctx, key, offset, value any) *gomock.Call

SetBit indicates an expected call of SetBit.

func (*MockRedisMockRecorder) SetEx 

func (mr *MockRedisMockRecorder) SetEx(ctx, key, value, expiration any) *gomock.Call

SetEx indicates an expected call of SetEx.

func (*MockRedisMockRecorder) SetNX 

func (mr *MockRedisMockRecorder) SetNX(ctx, key, value, expiration any) *gomock.Call

SetNX indicates an expected call of SetNX.

func (*MockRedisMockRecorder) SetRange 

func (mr *MockRedisMockRecorder) SetRange(ctx, key, offset, value any) *gomock.Call

SetRange indicates an expected call of SetRange.

func (*MockRedisMockRecorder) SetXX 

func (mr *MockRedisMockRecorder) SetXX(ctx, key, value, expiration any) *gomock.Call

SetXX indicates an expected call of SetXX.

func (*MockRedisMockRecorder) Shutdown 

func (mr *MockRedisMockRecorder) Shutdown(ctx any) *gomock.Call

Shutdown indicates an expected call of Shutdown.

func (*MockRedisMockRecorder) ShutdownNoSave 

func (mr *MockRedisMockRecorder) ShutdownNoSave(ctx any) *gomock.Call

ShutdownNoSave indicates an expected call of ShutdownNoSave.

func (*MockRedisMockRecorder) ShutdownSave 

func (mr *MockRedisMockRecorder) ShutdownSave(ctx any) *gomock.Call

ShutdownSave indicates an expected call of ShutdownSave.

func (*MockRedisMockRecorder) SlaveOf 

func (mr *MockRedisMockRecorder) SlaveOf(ctx, host, port any) *gomock.Call

SlaveOf indicates an expected call of SlaveOf.

func (*MockRedisMockRecorder) SlowLogGet 

func (mr *MockRedisMockRecorder) SlowLogGet(ctx, num any) *gomock.Call

SlowLogGet indicates an expected call of SlowLogGet.

func (*MockRedisMockRecorder) Sort 

func (mr *MockRedisMockRecorder) Sort(ctx, key, sort any) *gomock.Call

Sort indicates an expected call of Sort.

func (*MockRedisMockRecorder) SortInterfaces 

func (mr *MockRedisMockRecorder) SortInterfaces(ctx, key, sort any) *gomock.Call

SortInterfaces indicates an expected call of SortInterfaces.

func (*MockRedisMockRecorder) SortRO 

func (mr *MockRedisMockRecorder) SortRO(ctx, key, sort any) *gomock.Call

SortRO indicates an expected call of SortRO.

func (*MockRedisMockRecorder) SortStore 

func (mr *MockRedisMockRecorder) SortStore(ctx, key, store, sort any) *gomock.Call

SortStore indicates an expected call of SortStore.

func (*MockRedisMockRecorder) StrLen 

func (mr *MockRedisMockRecorder) StrLen(ctx, key any) *gomock.Call

StrLen indicates an expected call of StrLen.

func (*MockRedisMockRecorder) TDigestAdd 

func (mr *MockRedisMockRecorder) TDigestAdd(ctx, key any, elements ...any) *gomock.Call

TDigestAdd indicates an expected call of TDigestAdd.

func (*MockRedisMockRecorder) TDigestByRank 

func (mr *MockRedisMockRecorder) TDigestByRank(ctx, key any, rank ...any) *gomock.Call

TDigestByRank indicates an expected call of TDigestByRank.

func (*MockRedisMockRecorder) TDigestByRevRank 

func (mr *MockRedisMockRecorder) TDigestByRevRank(ctx, key any, rank ...any) *gomock.Call

TDigestByRevRank indicates an expected call of TDigestByRevRank.

func (*MockRedisMockRecorder) TDigestCDF 

func (mr *MockRedisMockRecorder) TDigestCDF(ctx, key any, elements ...any) *gomock.Call

TDigestCDF indicates an expected call of TDigestCDF.

func (*MockRedisMockRecorder) TDigestCreate 

func (mr *MockRedisMockRecorder) TDigestCreate(ctx, key any) *gomock.Call

TDigestCreate indicates an expected call of TDigestCreate.

func (*MockRedisMockRecorder) TDigestCreateWithCompression 

func (mr *MockRedisMockRecorder) TDigestCreateWithCompression(ctx, key, compression any) *gomock.Call

TDigestCreateWithCompression indicates an expected call of TDigestCreateWithCompression.

func (*MockRedisMockRecorder) TDigestInfo 

func (mr *MockRedisMockRecorder) TDigestInfo(ctx, key any) *gomock.Call

TDigestInfo indicates an expected call of TDigestInfo.

func (*MockRedisMockRecorder) TDigestMax 

func (mr *MockRedisMockRecorder) TDigestMax(ctx, key any) *gomock.Call

TDigestMax indicates an expected call of TDigestMax.

func (*MockRedisMockRecorder) TDigestMerge 

func (mr *MockRedisMockRecorder) TDigestMerge(ctx, destKey, options any, sourceKeys ...any) *gomock.Call

TDigestMerge indicates an expected call of TDigestMerge.

func (*MockRedisMockRecorder) TDigestMin 

func (mr *MockRedisMockRecorder) TDigestMin(ctx, key any) *gomock.Call

TDigestMin indicates an expected call of TDigestMin.

func (*MockRedisMockRecorder) TDigestQuantile 

func (mr *MockRedisMockRecorder) TDigestQuantile(ctx, key any, elements ...any) *gomock.Call

TDigestQuantile indicates an expected call of TDigestQuantile.

func (*MockRedisMockRecorder) TDigestRank 

func (mr *MockRedisMockRecorder) TDigestRank(ctx, key any, values ...any) *gomock.Call

TDigestRank indicates an expected call of TDigestRank.

func (*MockRedisMockRecorder) TDigestReset 

func (mr *MockRedisMockRecorder) TDigestReset(ctx, key any) *gomock.Call

TDigestReset indicates an expected call of TDigestReset.

func (*MockRedisMockRecorder) TDigestRevRank 

func (mr *MockRedisMockRecorder) TDigestRevRank(ctx, key any, values ...any) *gomock.Call

TDigestRevRank indicates an expected call of TDigestRevRank.

func (*MockRedisMockRecorder) TDigestTrimmedMean 

func (mr *MockRedisMockRecorder) TDigestTrimmedMean(ctx, key, lowCutQuantile, highCutQuantile any) *gomock.Call

TDigestTrimmedMean indicates an expected call of TDigestTrimmedMean.

func (*MockRedisMockRecorder) TFCall 

func (mr *MockRedisMockRecorder) TFCall(ctx, libName, funcName, numKeys any) *gomock.Call

TFCall indicates an expected call of TFCall.

func (*MockRedisMockRecorder) TFCallASYNC 

func (mr *MockRedisMockRecorder) TFCallASYNC(ctx, libName, funcName, numKeys any) *gomock.Call

TFCallASYNC indicates an expected call of TFCallASYNC.

func (*MockRedisMockRecorder) TFCallASYNCArgs 

func (mr *MockRedisMockRecorder) TFCallASYNCArgs(ctx, libName, funcName, numKeys, options any) *gomock.Call

TFCallASYNCArgs indicates an expected call of TFCallASYNCArgs.

func (*MockRedisMockRecorder) TFCallArgs 

func (mr *MockRedisMockRecorder) TFCallArgs(ctx, libName, funcName, numKeys, options any) *gomock.Call

TFCallArgs indicates an expected call of TFCallArgs.

func (*MockRedisMockRecorder) TFunctionDelete 

func (mr *MockRedisMockRecorder) TFunctionDelete(ctx, libName any) *gomock.Call

TFunctionDelete indicates an expected call of TFunctionDelete.

func (*MockRedisMockRecorder) TFunctionList 

func (mr *MockRedisMockRecorder) TFunctionList(ctx any) *gomock.Call

TFunctionList indicates an expected call of TFunctionList.

func (*MockRedisMockRecorder) TFunctionListArgs 

func (mr *MockRedisMockRecorder) TFunctionListArgs(ctx, options any) *gomock.Call

TFunctionListArgs indicates an expected call of TFunctionListArgs.

func (*MockRedisMockRecorder) TFunctionLoad 

func (mr *MockRedisMockRecorder) TFunctionLoad(ctx, lib any) *gomock.Call

TFunctionLoad indicates an expected call of TFunctionLoad.

func (*MockRedisMockRecorder) TFunctionLoadArgs 

func (mr *MockRedisMockRecorder) TFunctionLoadArgs(ctx, lib, options any) *gomock.Call

TFunctionLoadArgs indicates an expected call of TFunctionLoadArgs.

func (*MockRedisMockRecorder) TSAdd 

func (mr *MockRedisMockRecorder) TSAdd(ctx, key, timestamp, value any) *gomock.Call

TSAdd indicates an expected call of TSAdd.

func (*MockRedisMockRecorder) TSAddWithArgs 

func (mr *MockRedisMockRecorder) TSAddWithArgs(ctx, key, timestamp, value, options any) *gomock.Call

TSAddWithArgs indicates an expected call of TSAddWithArgs.

func (*MockRedisMockRecorder) TSAlter 

func (mr *MockRedisMockRecorder) TSAlter(ctx, key, options any) *gomock.Call

TSAlter indicates an expected call of TSAlter.

func (*MockRedisMockRecorder) TSCreate 

func (mr *MockRedisMockRecorder) TSCreate(ctx, key any) *gomock.Call

TSCreate indicates an expected call of TSCreate.

func (*MockRedisMockRecorder) TSCreateRule 

func (mr *MockRedisMockRecorder) TSCreateRule(ctx, sourceKey, destKey, aggregator, bucketDuration any) *gomock.Call

TSCreateRule indicates an expected call of TSCreateRule.

func (*MockRedisMockRecorder) TSCreateRuleWithArgs 

func (mr *MockRedisMockRecorder) TSCreateRuleWithArgs(ctx, sourceKey, destKey, aggregator, bucketDuration, options any) *gomock.Call

TSCreateRuleWithArgs indicates an expected call of TSCreateRuleWithArgs.

func (*MockRedisMockRecorder) TSCreateWithArgs 

func (mr *MockRedisMockRecorder) TSCreateWithArgs(ctx, key, options any) *gomock.Call

TSCreateWithArgs indicates an expected call of TSCreateWithArgs.

func (*MockRedisMockRecorder) TSDecrBy 

func (mr *MockRedisMockRecorder) TSDecrBy(ctx, Key, timestamp any) *gomock.Call

TSDecrBy indicates an expected call of TSDecrBy.

func (*MockRedisMockRecorder) TSDecrByWithArgs 

func (mr *MockRedisMockRecorder) TSDecrByWithArgs(ctx, key, timestamp, options any) *gomock.Call

TSDecrByWithArgs indicates an expected call of TSDecrByWithArgs.

func (*MockRedisMockRecorder) TSDel 

func (mr *MockRedisMockRecorder) TSDel(ctx, Key, fromTimestamp, toTimestamp any) *gomock.Call

TSDel indicates an expected call of TSDel.

func (*MockRedisMockRecorder) TSDeleteRule 

func (mr *MockRedisMockRecorder) TSDeleteRule(ctx, sourceKey, destKey any) *gomock.Call

TSDeleteRule indicates an expected call of TSDeleteRule.

func (*MockRedisMockRecorder) TSGet 

func (mr *MockRedisMockRecorder) TSGet(ctx, key any) *gomock.Call

TSGet indicates an expected call of TSGet.

func (*MockRedisMockRecorder) TSGetWithArgs 

func (mr *MockRedisMockRecorder) TSGetWithArgs(ctx, key, options any) *gomock.Call

TSGetWithArgs indicates an expected call of TSGetWithArgs.

func (*MockRedisMockRecorder) TSIncrBy 

func (mr *MockRedisMockRecorder) TSIncrBy(ctx, Key, timestamp any) *gomock.Call

TSIncrBy indicates an expected call of TSIncrBy.

func (*MockRedisMockRecorder) TSIncrByWithArgs 

func (mr *MockRedisMockRecorder) TSIncrByWithArgs(ctx, key, timestamp, options any) *gomock.Call

TSIncrByWithArgs indicates an expected call of TSIncrByWithArgs.

func (*MockRedisMockRecorder) TSInfo 

func (mr *MockRedisMockRecorder) TSInfo(ctx, key any) *gomock.Call

TSInfo indicates an expected call of TSInfo.

func (*MockRedisMockRecorder) TSInfoWithArgs 

func (mr *MockRedisMockRecorder) TSInfoWithArgs(ctx, key, options any) *gomock.Call

TSInfoWithArgs indicates an expected call of TSInfoWithArgs.

func (*MockRedisMockRecorder) TSMAdd 

func (mr *MockRedisMockRecorder) TSMAdd(ctx, ktvSlices any) *gomock.Call

TSMAdd indicates an expected call of TSMAdd.

func (*MockRedisMockRecorder) TSMGet 

func (mr *MockRedisMockRecorder) TSMGet(ctx, filters any) *gomock.Call

TSMGet indicates an expected call of TSMGet.

func (*MockRedisMockRecorder) TSMGetWithArgs 

func (mr *MockRedisMockRecorder) TSMGetWithArgs(ctx, filters, options any) *gomock.Call

TSMGetWithArgs indicates an expected call of TSMGetWithArgs.

func (*MockRedisMockRecorder) TSMRange 

func (mr *MockRedisMockRecorder) TSMRange(ctx, fromTimestamp, toTimestamp, filterExpr any) *gomock.Call

TSMRange indicates an expected call of TSMRange.

func (*MockRedisMockRecorder) TSMRangeWithArgs 

func (mr *MockRedisMockRecorder) TSMRangeWithArgs(ctx, fromTimestamp, toTimestamp, filterExpr, options any) *gomock.Call

TSMRangeWithArgs indicates an expected call of TSMRangeWithArgs.

func (*MockRedisMockRecorder) TSMRevRange 

func (mr *MockRedisMockRecorder) TSMRevRange(ctx, fromTimestamp, toTimestamp, filterExpr any) *gomock.Call

TSMRevRange indicates an expected call of TSMRevRange.

func (*MockRedisMockRecorder) TSMRevRangeWithArgs 

func (mr *MockRedisMockRecorder) TSMRevRangeWithArgs(ctx, fromTimestamp, toTimestamp, filterExpr, options any) *gomock.Call

TSMRevRangeWithArgs indicates an expected call of TSMRevRangeWithArgs.

func (*MockRedisMockRecorder) TSQueryIndex 

func (mr *MockRedisMockRecorder) TSQueryIndex(ctx, filterExpr any) *gomock.Call

TSQueryIndex indicates an expected call of TSQueryIndex.

func (*MockRedisMockRecorder) TSRange 

func (mr *MockRedisMockRecorder) TSRange(ctx, key, fromTimestamp, toTimestamp any) *gomock.Call

TSRange indicates an expected call of TSRange.

func (*MockRedisMockRecorder) TSRangeWithArgs 

func (mr *MockRedisMockRecorder) TSRangeWithArgs(ctx, key, fromTimestamp, toTimestamp, options any) *gomock.Call

TSRangeWithArgs indicates an expected call of TSRangeWithArgs.

func (*MockRedisMockRecorder) TSRevRange 

func (mr *MockRedisMockRecorder) TSRevRange(ctx, key, fromTimestamp, toTimestamp any) *gomock.Call

TSRevRange indicates an expected call of TSRevRange.

func (*MockRedisMockRecorder) TSRevRangeWithArgs 

func (mr *MockRedisMockRecorder) TSRevRangeWithArgs(ctx, key, fromTimestamp, toTimestamp, options any) *gomock.Call

TSRevRangeWithArgs indicates an expected call of TSRevRangeWithArgs.

func (*MockRedisMockRecorder) TTL 

func (mr *MockRedisMockRecorder) TTL(ctx, key any) *gomock.Call

TTL indicates an expected call of TTL.

func (*MockRedisMockRecorder) Time 

func (mr *MockRedisMockRecorder) Time(ctx any) *gomock.Call

Time indicates an expected call of Time.

func (*MockRedisMockRecorder) TopKAdd 

func (mr *MockRedisMockRecorder) TopKAdd(ctx, key any, elements ...any) *gomock.Call

TopKAdd indicates an expected call of TopKAdd.

func (*MockRedisMockRecorder) TopKCount 

func (mr *MockRedisMockRecorder) TopKCount(ctx, key any, elements ...any) *gomock.Call

TopKCount indicates an expected call of TopKCount.

func (*MockRedisMockRecorder) TopKIncrBy 

func (mr *MockRedisMockRecorder) TopKIncrBy(ctx, key any, elements ...any) *gomock.Call

TopKIncrBy indicates an expected call of TopKIncrBy.

func (*MockRedisMockRecorder) TopKInfo 

func (mr *MockRedisMockRecorder) TopKInfo(ctx, key any) *gomock.Call

TopKInfo indicates an expected call of TopKInfo.

func (*MockRedisMockRecorder) TopKList 

func (mr *MockRedisMockRecorder) TopKList(ctx, key any) *gomock.Call

TopKList indicates an expected call of TopKList.

func (*MockRedisMockRecorder) TopKListWithCount 

func (mr *MockRedisMockRecorder) TopKListWithCount(ctx, key any) *gomock.Call

TopKListWithCount indicates an expected call of TopKListWithCount.

func (*MockRedisMockRecorder) TopKQuery 

func (mr *MockRedisMockRecorder) TopKQuery(ctx, key any, elements ...any) *gomock.Call

TopKQuery indicates an expected call of TopKQuery.

func (*MockRedisMockRecorder) TopKReserve 

func (mr *MockRedisMockRecorder) TopKReserve(ctx, key, k any) *gomock.Call

TopKReserve indicates an expected call of TopKReserve.

func (*MockRedisMockRecorder) TopKReserveWithOptions 

func (mr *MockRedisMockRecorder) TopKReserveWithOptions(ctx, key, k, width, depth, decay any) *gomock.Call

TopKReserveWithOptions indicates an expected call of TopKReserveWithOptions.

func (*MockRedisMockRecorder) Touch 

func (mr *MockRedisMockRecorder) Touch(ctx any, keys ...any) *gomock.Call

Touch indicates an expected call of Touch.

func (*MockRedisMockRecorder) TxPipeline 

func (mr *MockRedisMockRecorder) TxPipeline() *gomock.Call

TxPipeline indicates an expected call of TxPipeline.

func (*MockRedisMockRecorder) TxPipelined 

func (mr *MockRedisMockRecorder) TxPipelined(ctx, fn any) *gomock.Call

TxPipelined indicates an expected call of TxPipelined.

func (*MockRedisMockRecorder) Type 

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 

func (mr *MockRedisMockRecorder) XAck(ctx, stream, group any, ids ...any) *gomock.Call

XAck indicates an expected call of XAck.

func (*MockRedisMockRecorder) XAdd 

func (mr *MockRedisMockRecorder) XAdd(ctx, a any) *gomock.Call

XAdd indicates an expected call of XAdd.

func (*MockRedisMockRecorder) XAutoClaim 

func (mr *MockRedisMockRecorder) XAutoClaim(ctx, a any) *gomock.Call

XAutoClaim indicates an expected call of XAutoClaim.

func (*MockRedisMockRecorder) XAutoClaimJustID 

func (mr *MockRedisMockRecorder) XAutoClaimJustID(ctx, a any) *gomock.Call

XAutoClaimJustID indicates an expected call of XAutoClaimJustID.

func (*MockRedisMockRecorder) XClaim 

func (mr *MockRedisMockRecorder) XClaim(ctx, a any) *gomock.Call

XClaim indicates an expected call of XClaim.

func (*MockRedisMockRecorder) XClaimJustID 

func (mr *MockRedisMockRecorder) XClaimJustID(ctx, a any) *gomock.Call

XClaimJustID indicates an expected call of XClaimJustID.

func (*MockRedisMockRecorder) XDel 

func (mr *MockRedisMockRecorder) XDel(ctx, stream any, ids ...any) *gomock.Call

XDel indicates an expected call of XDel.

func (*MockRedisMockRecorder) XGroupCreate 

func (mr *MockRedisMockRecorder) XGroupCreate(ctx, stream, group, start any) *gomock.Call

XGroupCreate indicates an expected call of XGroupCreate.

func (*MockRedisMockRecorder) XGroupCreateConsumer 

func (mr *MockRedisMockRecorder) XGroupCreateConsumer(ctx, stream, group, consumer any) *gomock.Call

XGroupCreateConsumer indicates an expected call of XGroupCreateConsumer.

func (*MockRedisMockRecorder) XGroupCreateMkStream 

func (mr *MockRedisMockRecorder) XGroupCreateMkStream(ctx, stream, group, start any) *gomock.Call

XGroupCreateMkStream indicates an expected call of XGroupCreateMkStream.

func (*MockRedisMockRecorder) XGroupDelConsumer 

func (mr *MockRedisMockRecorder) XGroupDelConsumer(ctx, stream, group, consumer any) *gomock.Call

XGroupDelConsumer indicates an expected call of XGroupDelConsumer.

func (*MockRedisMockRecorder) XGroupDestroy 

func (mr *MockRedisMockRecorder) XGroupDestroy(ctx, stream, group any) *gomock.Call

XGroupDestroy indicates an expected call of XGroupDestroy.

func (*MockRedisMockRecorder) XGroupSetID 

func (mr *MockRedisMockRecorder) XGroupSetID(ctx, stream, group, start any) *gomock.Call

XGroupSetID indicates an expected call of XGroupSetID.

func (*MockRedisMockRecorder) XInfoConsumers 

func (mr *MockRedisMockRecorder) XInfoConsumers(ctx, key, group any) *gomock.Call

XInfoConsumers indicates an expected call of XInfoConsumers.

func (*MockRedisMockRecorder) XInfoGroups 

func (mr *MockRedisMockRecorder) XInfoGroups(ctx, key any) *gomock.Call

XInfoGroups indicates an expected call of XInfoGroups.

func (*MockRedisMockRecorder) XInfoStream 

func (mr *MockRedisMockRecorder) XInfoStream(ctx, key any) *gomock.Call

XInfoStream indicates an expected call of XInfoStream.

func (*MockRedisMockRecorder) XInfoStreamFull 

func (mr *MockRedisMockRecorder) XInfoStreamFull(ctx, key, count any) *gomock.Call

XInfoStreamFull indicates an expected call of XInfoStreamFull.

func (*MockRedisMockRecorder) XLen 

func (mr *MockRedisMockRecorder) XLen(ctx, stream any) *gomock.Call

XLen indicates an expected call of XLen.

func (*MockRedisMockRecorder) XPending 

func (mr *MockRedisMockRecorder) XPending(ctx, stream, group any) *gomock.Call

XPending indicates an expected call of XPending.

func (*MockRedisMockRecorder) XPendingExt 

func (mr *MockRedisMockRecorder) XPendingExt(ctx, a any) *gomock.Call

XPendingExt indicates an expected call of XPendingExt.

func (*MockRedisMockRecorder) XRange 

func (mr *MockRedisMockRecorder) XRange(ctx, stream, start, stop any) *gomock.Call

XRange indicates an expected call of XRange.

func (*MockRedisMockRecorder) XRangeN 

func (mr *MockRedisMockRecorder) XRangeN(ctx, stream, start, stop, count any) *gomock.Call

XRangeN indicates an expected call of XRangeN.

func (*MockRedisMockRecorder) XRead 

func (mr *MockRedisMockRecorder) XRead(ctx, a any) *gomock.Call

XRead indicates an expected call of XRead.

func (*MockRedisMockRecorder) XReadGroup 

func (mr *MockRedisMockRecorder) XReadGroup(ctx, a any) *gomock.Call

XReadGroup indicates an expected call of XReadGroup.

func (*MockRedisMockRecorder) XReadStreams 

func (mr *MockRedisMockRecorder) XReadStreams(ctx any, streams ...any) *gomock.Call

XReadStreams indicates an expected call of XReadStreams.

func (*MockRedisMockRecorder) XRevRange 

func (mr *MockRedisMockRecorder) XRevRange(ctx, stream, start, stop any) *gomock.Call

XRevRange indicates an expected call of XRevRange.

func (*MockRedisMockRecorder) XRevRangeN 

func (mr *MockRedisMockRecorder) XRevRangeN(ctx, stream, start, stop, count any) *gomock.Call

XRevRangeN indicates an expected call of XRevRangeN.

func (*MockRedisMockRecorder) XTrimMaxLen 

func (mr *MockRedisMockRecorder) XTrimMaxLen(ctx, key, maxLen any) *gomock.Call

XTrimMaxLen indicates an expected call of XTrimMaxLen.

func (*MockRedisMockRecorder) XTrimMaxLenApprox 

func (mr *MockRedisMockRecorder) XTrimMaxLenApprox(ctx, key, maxLen, limit any) *gomock.Call

XTrimMaxLenApprox indicates an expected call of XTrimMaxLenApprox.

func (*MockRedisMockRecorder) XTrimMinID 

func (mr *MockRedisMockRecorder) XTrimMinID(ctx, key, minID any) *gomock.Call

XTrimMinID indicates an expected call of XTrimMinID.

func (*MockRedisMockRecorder) XTrimMinIDApprox 

func (mr *MockRedisMockRecorder) XTrimMinIDApprox(ctx, key, minID, limit any) *gomock.Call

XTrimMinIDApprox indicates an expected call of XTrimMinIDApprox.

func (*MockRedisMockRecorder) ZAdd 

func (mr *MockRedisMockRecorder) ZAdd(ctx, key any, members ...any) *gomock.Call

ZAdd indicates an expected call of ZAdd.

func (*MockRedisMockRecorder) ZAddArgs 

func (mr *MockRedisMockRecorder) ZAddArgs(ctx, key, args any) *gomock.Call

ZAddArgs indicates an expected call of ZAddArgs.

func (*MockRedisMockRecorder) ZAddArgsIncr 

func (mr *MockRedisMockRecorder) ZAddArgsIncr(ctx, key, args any) *gomock.Call

ZAddArgsIncr indicates an expected call of ZAddArgsIncr.

func (*MockRedisMockRecorder) ZAddGT 

func (mr *MockRedisMockRecorder) ZAddGT(ctx, key any, members ...any) *gomock.Call

ZAddGT indicates an expected call of ZAddGT.

func (*MockRedisMockRecorder) ZAddLT 

func (mr *MockRedisMockRecorder) ZAddLT(ctx, key any, members ...any) *gomock.Call

ZAddLT indicates an expected call of ZAddLT.

func (*MockRedisMockRecorder) ZAddNX 

func (mr *MockRedisMockRecorder) ZAddNX(ctx, key any, members ...any) *gomock.Call

ZAddNX indicates an expected call of ZAddNX.

func (*MockRedisMockRecorder) ZAddXX 

func (mr *MockRedisMockRecorder) ZAddXX(ctx, key any, members ...any) *gomock.Call

ZAddXX indicates an expected call of ZAddXX.

func (*MockRedisMockRecorder) ZCard 

func (mr *MockRedisMockRecorder) ZCard(ctx, key any) *gomock.Call

ZCard indicates an expected call of ZCard.

func (*MockRedisMockRecorder) ZCount 

func (mr *MockRedisMockRecorder) ZCount(ctx, key, min, max any) *gomock.Call

ZCount indicates an expected call of ZCount.

func (*MockRedisMockRecorder) ZDiff 

func (mr *MockRedisMockRecorder) ZDiff(ctx any, keys ...any) *gomock.Call

ZDiff indicates an expected call of ZDiff.

func (*MockRedisMockRecorder) ZDiffStore 

func (mr *MockRedisMockRecorder) ZDiffStore(ctx, destination any, keys ...any) *gomock.Call

ZDiffStore indicates an expected call of ZDiffStore.

func (*MockRedisMockRecorder) ZDiffWithScores 

func (mr *MockRedisMockRecorder) ZDiffWithScores(ctx any, keys ...any) *gomock.Call

ZDiffWithScores indicates an expected call of ZDiffWithScores.

func (*MockRedisMockRecorder) ZIncrBy 

func (mr *MockRedisMockRecorder) ZIncrBy(ctx, key, increment, member any) *gomock.Call

ZIncrBy indicates an expected call of ZIncrBy.

func (*MockRedisMockRecorder) ZInter 

func (mr *MockRedisMockRecorder) ZInter(ctx, store any) *gomock.Call

ZInter indicates an expected call of ZInter.

func (*MockRedisMockRecorder) ZInterCard 

func (mr *MockRedisMockRecorder) ZInterCard(ctx, limit any, keys ...any) *gomock.Call

ZInterCard indicates an expected call of ZInterCard.

func (*MockRedisMockRecorder) ZInterStore 

func (mr *MockRedisMockRecorder) ZInterStore(ctx, destination, store any) *gomock.Call

ZInterStore indicates an expected call of ZInterStore.

func (*MockRedisMockRecorder) ZInterWithScores 

func (mr *MockRedisMockRecorder) ZInterWithScores(ctx, store any) *gomock.Call

ZInterWithScores indicates an expected call of ZInterWithScores.

func (*MockRedisMockRecorder) ZLexCount 

func (mr *MockRedisMockRecorder) ZLexCount(ctx, key, min, max any) *gomock.Call

ZLexCount indicates an expected call of ZLexCount.

func (*MockRedisMockRecorder) ZMPop 

func (mr *MockRedisMockRecorder) ZMPop(ctx, order, count any, keys ...any) *gomock.Call

ZMPop indicates an expected call of ZMPop.

func (*MockRedisMockRecorder) ZMScore 

func (mr *MockRedisMockRecorder) ZMScore(ctx, key any, members ...any) *gomock.Call

ZMScore indicates an expected call of ZMScore.

func (*MockRedisMockRecorder) ZPopMax 

func (mr *MockRedisMockRecorder) ZPopMax(ctx, key any, count ...any) *gomock.Call

ZPopMax indicates an expected call of ZPopMax.

func (*MockRedisMockRecorder) ZPopMin 

func (mr *MockRedisMockRecorder) ZPopMin(ctx, key any, count ...any) *gomock.Call

ZPopMin indicates an expected call of ZPopMin.

func (*MockRedisMockRecorder) ZRandMember 

func (mr *MockRedisMockRecorder) ZRandMember(ctx, key, count any) *gomock.Call

ZRandMember indicates an expected call of ZRandMember.

func (*MockRedisMockRecorder) ZRandMemberWithScores 

func (mr *MockRedisMockRecorder) ZRandMemberWithScores(ctx, key, count any) *gomock.Call

ZRandMemberWithScores indicates an expected call of ZRandMemberWithScores.

func (*MockRedisMockRecorder) ZRange 

func (mr *MockRedisMockRecorder) ZRange(ctx, key, start, stop any) *gomock.Call

ZRange indicates an expected call of ZRange.

func (*MockRedisMockRecorder) ZRangeArgs 

func (mr *MockRedisMockRecorder) ZRangeArgs(ctx, z any) *gomock.Call

ZRangeArgs indicates an expected call of ZRangeArgs.

func (*MockRedisMockRecorder) ZRangeArgsWithScores 

func (mr *MockRedisMockRecorder) ZRangeArgsWithScores(ctx, z any) *gomock.Call

ZRangeArgsWithScores indicates an expected call of ZRangeArgsWithScores.

func (*MockRedisMockRecorder) ZRangeByLex 

func (mr *MockRedisMockRecorder) ZRangeByLex(ctx, key, opt any) *gomock.Call

ZRangeByLex indicates an expected call of ZRangeByLex.

func (*MockRedisMockRecorder) ZRangeByScore 

func (mr *MockRedisMockRecorder) ZRangeByScore(ctx, key, opt any) *gomock.Call

ZRangeByScore indicates an expected call of ZRangeByScore.

func (*MockRedisMockRecorder) ZRangeByScoreWithScores 

func (mr *MockRedisMockRecorder) ZRangeByScoreWithScores(ctx, key, opt any) *gomock.Call

ZRangeByScoreWithScores indicates an expected call of ZRangeByScoreWithScores.

func (*MockRedisMockRecorder) ZRangeStore 

func (mr *MockRedisMockRecorder) ZRangeStore(ctx, dst, z any) *gomock.Call

ZRangeStore indicates an expected call of ZRangeStore.

func (*MockRedisMockRecorder) ZRangeWithScores 

func (mr *MockRedisMockRecorder) ZRangeWithScores(ctx, key, start, stop any) *gomock.Call

ZRangeWithScores indicates an expected call of ZRangeWithScores.

func (*MockRedisMockRecorder) ZRank 

func (mr *MockRedisMockRecorder) ZRank(ctx, key, member any) *gomock.Call

ZRank indicates an expected call of ZRank.

func (*MockRedisMockRecorder) ZRankWithScore 

func (mr *MockRedisMockRecorder) ZRankWithScore(ctx, key, member any) *gomock.Call

ZRankWithScore indicates an expected call of ZRankWithScore.

func (*MockRedisMockRecorder) ZRem 

func (mr *MockRedisMockRecorder) ZRem(ctx, key any, members ...any) *gomock.Call

ZRem indicates an expected call of ZRem.

func (*MockRedisMockRecorder) ZRemRangeByLex 

func (mr *MockRedisMockRecorder) ZRemRangeByLex(ctx, key, min, max any) *gomock.Call

ZRemRangeByLex indicates an expected call of ZRemRangeByLex.

func (*MockRedisMockRecorder) ZRemRangeByRank 

func (mr *MockRedisMockRecorder) ZRemRangeByRank(ctx, key, start, stop any) *gomock.Call

ZRemRangeByRank indicates an expected call of ZRemRangeByRank.

func (*MockRedisMockRecorder) ZRemRangeByScore 

func (mr *MockRedisMockRecorder) ZRemRangeByScore(ctx, key, min, max any) *gomock.Call

ZRemRangeByScore indicates an expected call of ZRemRangeByScore.

func (*MockRedisMockRecorder) ZRevRange 

func (mr *MockRedisMockRecorder) ZRevRange(ctx, key, start, stop any) *gomock.Call

ZRevRange indicates an expected call of ZRevRange.

func (*MockRedisMockRecorder) ZRevRangeByLex 

func (mr *MockRedisMockRecorder) ZRevRangeByLex(ctx, key, opt any) *gomock.Call

ZRevRangeByLex indicates an expected call of ZRevRangeByLex.

func (*MockRedisMockRecorder) ZRevRangeByScore 

func (mr *MockRedisMockRecorder) ZRevRangeByScore(ctx, key, opt any) *gomock.Call

ZRevRangeByScore indicates an expected call of ZRevRangeByScore.

func (*MockRedisMockRecorder) ZRevRangeByScoreWithScores 

func (mr *MockRedisMockRecorder) ZRevRangeByScoreWithScores(ctx, key, opt any) *gomock.Call

ZRevRangeByScoreWithScores indicates an expected call of ZRevRangeByScoreWithScores.

func (*MockRedisMockRecorder) ZRevRangeWithScores 

func (mr *MockRedisMockRecorder) ZRevRangeWithScores(ctx, key, start, stop any) *gomock.Call

ZRevRangeWithScores indicates an expected call of ZRevRangeWithScores.

func (*MockRedisMockRecorder) ZRevRank 

func (mr *MockRedisMockRecorder) ZRevRank(ctx, key, member any) *gomock.Call

ZRevRank indicates an expected call of ZRevRank.

func (*MockRedisMockRecorder) ZRevRankWithScore 

func (mr *MockRedisMockRecorder) ZRevRankWithScore(ctx, key, member any) *gomock.Call

ZRevRankWithScore indicates an expected call of ZRevRankWithScore.

func (*MockRedisMockRecorder) ZScan 

func (mr *MockRedisMockRecorder) ZScan(ctx, key, cursor, match, count any) *gomock.Call

ZScan indicates an expected call of ZScan.

func (*MockRedisMockRecorder) ZScore 

func (mr *MockRedisMockRecorder) ZScore(ctx, key, member any) *gomock.Call

ZScore indicates an expected call of ZScore.

func (*MockRedisMockRecorder) ZUnion 

func (mr *MockRedisMockRecorder) ZUnion(ctx, store any) *gomock.Call

ZUnion indicates an expected call of ZUnion.

func (*MockRedisMockRecorder) ZUnionStore 

func (mr *MockRedisMockRecorder) ZUnionStore(ctx, dest, store any) *gomock.Call

ZUnionStore indicates an expected call of ZUnionStore.

func (*MockRedisMockRecorder) ZUnionWithScores 

func (mr *MockRedisMockRecorder) ZUnionWithScores(ctx, store any) *gomock.Call

ZUnionWithScores indicates an expected call of ZUnionWithScores.

type MockSolr 

type MockSolr struct {
	// contains filtered or unexported fields
}

MockSolr is a mock of Solr interface.

func NewMockSolr 

func NewMockSolr(ctrl *gomock.Controller) *MockSolr

NewMockSolr creates a new mock instance.

func (*MockSolr) AddField 

func (m *MockSolr) AddField(ctx context.Context, collection string, document *bytes.Buffer) (any, error)

AddField mocks base method.

func (*MockSolr) Create 

func (m *MockSolr) Create(ctx context.Context, collection string, document *bytes.Buffer, params map[string]any) (any, error)

Create mocks base method.

func (*MockSolr) Delete 

func (m *MockSolr) Delete(ctx context.Context, collection string, document *bytes.Buffer, params map[string]any) (any, error)

Delete mocks base method.

func (*MockSolr) DeleteField 

func (m *MockSolr) DeleteField(ctx context.Context, collection string, document *bytes.Buffer) (any, error)

DeleteField mocks base method.

func (*MockSolr) EXPECT 

func (m *MockSolr) EXPECT() *MockSolrMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSolr) HealthCheck 

func (m *MockSolr) HealthCheck(arg0 context.Context) (any, error)

HealthCheck mocks base method.

func (*MockSolr) ListFields 

func (m *MockSolr) ListFields(ctx context.Context, collection string, params map[string]any) (any, error)

ListFields mocks base method.

func (*MockSolr) Retrieve 

func (m *MockSolr) Retrieve(ctx context.Context, collection string, params map[string]any) (any, error)

Retrieve mocks base method.

func (*MockSolr) Search 

func (m *MockSolr) Search(ctx context.Context, collection string, params map[string]any) (any, error)

Search mocks base method.

func (*MockSolr) Update 

func (m *MockSolr) Update(ctx context.Context, collection string, document *bytes.Buffer, params map[string]any) (any, error)

Update mocks base method.

func (*MockSolr) UpdateField 

func (m *MockSolr) UpdateField(ctx context.Context, collection string, document *bytes.Buffer) (any, error)

UpdateField mocks base method.

type MockSolrMockRecorder 

type MockSolrMockRecorder struct {
	// contains filtered or unexported fields
}

MockSolrMockRecorder is the mock recorder for MockSolr.

func (*MockSolrMockRecorder) AddField 

func (mr *MockSolrMockRecorder) AddField(ctx, collection, document any) *gomock.Call

AddField indicates an expected call of AddField.

func (*MockSolrMockRecorder) Create 

func (mr *MockSolrMockRecorder) Create(ctx, collection, document, params any) *gomock.Call

Create indicates an expected call of Create.

func (*MockSolrMockRecorder) Delete 

func (mr *MockSolrMockRecorder) Delete(ctx, collection, document, params any) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockSolrMockRecorder) DeleteField 

func (mr *MockSolrMockRecorder) DeleteField(ctx, collection, document any) *gomock.Call

DeleteField indicates an expected call of DeleteField.

func (*MockSolrMockRecorder) HealthCheck 

func (mr *MockSolrMockRecorder) HealthCheck(arg0 any) *gomock.Call

HealthCheck indicates an expected call of HealthCheck.

func (*MockSolrMockRecorder) ListFields 

func (mr *MockSolrMockRecorder) ListFields(ctx, collection, params any) *gomock.Call

ListFields indicates an expected call of ListFields.

func (*MockSolrMockRecorder) Retrieve 

func (mr *MockSolrMockRecorder) Retrieve(ctx, collection, params any) *gomock.Call

Retrieve indicates an expected call of Retrieve.

func (*MockSolrMockRecorder) Search 

func (mr *MockSolrMockRecorder) Search(ctx, collection, params any) *gomock.Call

Search indicates an expected call of Search.

func (*MockSolrMockRecorder) Update 

func (mr *MockSolrMockRecorder) Update(ctx, collection, document, params any) *gomock.Call

Update indicates an expected call of Update.

func (*MockSolrMockRecorder) UpdateField 

func (mr *MockSolrMockRecorder) UpdateField(ctx, collection, document any) *gomock.Call

UpdateField indicates an expected call of UpdateField.

type MockSolrProvider 

type MockSolrProvider struct {
	// contains filtered or unexported fields
}

MockSolrProvider is a mock of SolrProvider interface.

func NewMockSolrProvider 

func NewMockSolrProvider(ctrl *gomock.Controller) *MockSolrProvider

NewMockSolrProvider creates a new mock instance.

func (*MockSolrProvider) AddField 

func (m *MockSolrProvider) AddField(ctx context.Context, collection string, document *bytes.Buffer) (any, error)

AddField mocks base method.

func (*MockSolrProvider) Connect 

func (m *MockSolrProvider) Connect()

Connect mocks base method.

func (*MockSolrProvider) Create 

func (m *MockSolrProvider) Create(ctx context.Context, collection string, document *bytes.Buffer, params map[string]any) (any, error)

Create mocks base method.

func (*MockSolrProvider) Delete 

func (m *MockSolrProvider) Delete(ctx context.Context, collection string, document *bytes.Buffer, params map[string]any) (any, error)

Delete mocks base method.

func (*MockSolrProvider) DeleteField 

func (m *MockSolrProvider) DeleteField(ctx context.Context, collection string, document *bytes.Buffer) (any, error)

DeleteField mocks base method.

func (*MockSolrProvider) EXPECT 

func (m *MockSolrProvider) EXPECT() *MockSolrProviderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSolrProvider) HealthCheck 

func (m *MockSolrProvider) HealthCheck(arg0 context.Context) (any, error)

HealthCheck mocks base method.

func (*MockSolrProvider) ListFields 

func (m *MockSolrProvider) ListFields(ctx context.Context, collection string, params map[string]any) (any, error)

ListFields mocks base method.

func (*MockSolrProvider) Retrieve 

func (m *MockSolrProvider) Retrieve(ctx context.Context, collection string, params map[string]any) (any, error)

Retrieve mocks base method.

func (*MockSolrProvider) Search 

func (m *MockSolrProvider) Search(ctx context.Context, collection string, params map[string]any) (any, error)

Search mocks base method.

func (*MockSolrProvider) Update 

func (m *MockSolrProvider) Update(ctx context.Context, collection string, document *bytes.Buffer, params map[string]any) (any, error)

Update mocks base method.

func (*MockSolrProvider) UpdateField 

func (m *MockSolrProvider) UpdateField(ctx context.Context, collection string, document *bytes.Buffer) (any, error)

UpdateField mocks base method.

func (*MockSolrProvider) UseLogger 

func (m *MockSolrProvider) UseLogger(logger any)

UseLogger mocks base method.

func (*MockSolrProvider) UseMetrics 

func (m *MockSolrProvider) UseMetrics(metrics any)

UseMetrics mocks base method.

func (*MockSolrProvider) UseTracer 

func (m *MockSolrProvider) UseTracer(tracer any)

UseTracer mocks base method.

type MockSolrProviderMockRecorder 

type MockSolrProviderMockRecorder struct {
	// contains filtered or unexported fields
}

MockSolrProviderMockRecorder is the mock recorder for MockSolrProvider.

func (*MockSolrProviderMockRecorder) AddField 

func (mr *MockSolrProviderMockRecorder) AddField(ctx, collection, document any) *gomock.Call

AddField indicates an expected call of AddField.

func (*MockSolrProviderMockRecorder) Connect 

func (mr *MockSolrProviderMockRecorder) Connect() *gomock.Call

Connect indicates an expected call of Connect.

func (*MockSolrProviderMockRecorder) Create 

func (mr *MockSolrProviderMockRecorder) Create(ctx, collection, document, params any) *gomock.Call

Create indicates an expected call of Create.

func (*MockSolrProviderMockRecorder) Delete 

func (mr *MockSolrProviderMockRecorder) Delete(ctx, collection, document, params any) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockSolrProviderMockRecorder) DeleteField 

func (mr *MockSolrProviderMockRecorder) DeleteField(ctx, collection, document any) *gomock.Call

DeleteField indicates an expected call of DeleteField.

func (*MockSolrProviderMockRecorder) HealthCheck 

func (mr *MockSolrProviderMockRecorder) HealthCheck(arg0 any) *gomock.Call

HealthCheck indicates an expected call of HealthCheck.

func (*MockSolrProviderMockRecorder) ListFields 

func (mr *MockSolrProviderMockRecorder) ListFields(ctx, collection, params any) *gomock.Call

ListFields indicates an expected call of ListFields.

func (*MockSolrProviderMockRecorder) Retrieve 

func (mr *MockSolrProviderMockRecorder) Retrieve(ctx, collection, params any) *gomock.Call

Retrieve indicates an expected call of Retrieve.

func (*MockSolrProviderMockRecorder) Search 

func (mr *MockSolrProviderMockRecorder) Search(ctx, collection, params any) *gomock.Call

Search indicates an expected call of Search.

func (*MockSolrProviderMockRecorder) Update 

func (mr *MockSolrProviderMockRecorder) Update(ctx, collection, document, params any) *gomock.Call

Update indicates an expected call of Update.

func (*MockSolrProviderMockRecorder) UpdateField 

func (mr *MockSolrProviderMockRecorder) UpdateField(ctx, collection, document any) *gomock.Call

UpdateField indicates an expected call of UpdateField.

func (*MockSolrProviderMockRecorder) UseLogger 

func (mr *MockSolrProviderMockRecorder) UseLogger(logger any) *gomock.Call

UseLogger indicates an expected call of UseLogger.

func (*MockSolrProviderMockRecorder) UseMetrics 

func (mr *MockSolrProviderMockRecorder) UseMetrics(metrics any) *gomock.Call

UseMetrics indicates an expected call of UseMetrics.

func (*MockSolrProviderMockRecorder) UseTracer 

func (mr *MockSolrProviderMockRecorder) UseTracer(tracer any) *gomock.Call

UseTracer indicates an expected call of UseTracer.

type MockTransaction 

type MockTransaction struct {
	// contains filtered or unexported fields
}

MockTransaction is a mock of Transaction interface.

func NewMockTransaction 

func NewMockTransaction(ctrl *gomock.Controller) *MockTransaction

NewMockTransaction creates a new mock instance.

func (*MockTransaction) AbortTransaction 

func (m *MockTransaction) AbortTransaction(arg0 context.Context) error

AbortTransaction mocks base method.

func (*MockTransaction) CommitTransaction 

func (m *MockTransaction) CommitTransaction(arg0 context.Context) error

CommitTransaction mocks base method.

func (*MockTransaction) EXPECT 

func (m *MockTransaction) EXPECT() *MockTransactionMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockTransaction) EndSession 

func (m *MockTransaction) EndSession(arg0 context.Context)

EndSession mocks base method.

func (*MockTransaction) StartTransaction 

func (m *MockTransaction) StartTransaction() error

StartTransaction mocks base method.

type MockTransactionMockRecorder 

type MockTransactionMockRecorder struct {
	// contains filtered or unexported fields
}

MockTransactionMockRecorder is the mock recorder for MockTransaction.

func (*MockTransactionMockRecorder) AbortTransaction 

func (mr *MockTransactionMockRecorder) AbortTransaction(arg0 any) *gomock.Call

AbortTransaction indicates an expected call of AbortTransaction.

func (*MockTransactionMockRecorder) CommitTransaction 

func (mr *MockTransactionMockRecorder) CommitTransaction(arg0 any) *gomock.Call

CommitTransaction indicates an expected call of CommitTransaction.

func (*MockTransactionMockRecorder) EndSession 

func (mr *MockTransactionMockRecorder) EndSession(arg0 any) *gomock.Call

EndSession indicates an expected call of EndSession.

func (*MockTransactionMockRecorder) StartTransaction 

func (mr *MockTransactionMockRecorder) StartTransaction() *gomock.Call

StartTransaction indicates an expected call of StartTransaction.

type Mockprovider 

type Mockprovider struct {
	// contains filtered or unexported fields
}

Mockprovider is a mock of provider interface.

func NewMockprovider 

func NewMockprovider(ctrl *gomock.Controller) *Mockprovider

NewMockprovider creates a new mock instance.

func (*Mockprovider) Connect 

func (m *Mockprovider) Connect()

Connect mocks base method.

func (*Mockprovider) EXPECT 

func (m *Mockprovider) EXPECT() *MockproviderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*Mockprovider) UseLogger 

func (m *Mockprovider) UseLogger(logger any)

UseLogger mocks base method.

func (*Mockprovider) UseMetrics 

func (m *Mockprovider) UseMetrics(metrics any)

UseMetrics mocks base method.

func (*Mockprovider) UseTracer 

func (m *Mockprovider) UseTracer(tracer any)

UseTracer mocks base method.

type MockproviderMockRecorder 

type MockproviderMockRecorder struct {
	// contains filtered or unexported fields
}

MockproviderMockRecorder is the mock recorder for Mockprovider.

func (*MockproviderMockRecorder) Connect 

func (mr *MockproviderMockRecorder) Connect() *gomock.Call

Connect indicates an expected call of Connect.

func (*MockproviderMockRecorder) UseLogger 

func (mr *MockproviderMockRecorder) UseLogger(logger any) *gomock.Call

UseLogger indicates an expected call of UseLogger.

func (*MockproviderMockRecorder) UseMetrics 

func (mr *MockproviderMockRecorder) UseMetrics(metrics any) *gomock.Call

UseMetrics indicates an expected call of UseMetrics.

func (*MockproviderMockRecorder) UseTracer 

func (mr *MockproviderMockRecorder) UseTracer(tracer any) *gomock.Call

UseTracer indicates an expected call of UseTracer.

type Mocks 

type Mocks struct {
	Redis       *MockRedis
	SQL         *mockSQL
	Clickhouse  *MockClickhouse
	Cassandra   *MockCassandra
	Mongo       *MockMongo
	KVStore     *MockKVStore
	DGraph      *MockDgraph
	File        *file.MockFileSystemProvider
	HTTPService *service.MockHTTP
	Metrics     *MockMetrics
}

type Mongo 

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 any, results any) 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 any, result any) 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 any) (any, 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 []any) ([]any, 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 any) (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 any) (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 any, update any) (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 any, update any) 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 any, update any) (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 any) (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() (any, error)

	HealthChecker
}

Mongo is an interface representing a MongoDB database client with common CRUD operations.

type MongoProvider 

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 PubSubProvider added in v0.0.2 

type PubSubProvider interface {
	pubsub.Client
	// contains filtered or unexported methods
}

type Redis 

type Redis interface {
	redis.Cmdable
	redis.HashCmdable
	HealthCheck() datasource.Health
	Close() error
}

type Solr 

type Solr interface {
	Search(ctx context.Context, collection string, params map[string]any) (any, error)
	Create(ctx context.Context, collection string, document *bytes.Buffer, params map[string]any) (any, error)
	Update(ctx context.Context, collection string, document *bytes.Buffer, params map[string]any) (any, error)
	Delete(ctx context.Context, collection string, document *bytes.Buffer, params map[string]any) (any, error)

	Retrieve(ctx context.Context, collection string, params map[string]any) (any, error)
	ListFields(ctx context.Context, collection string, params map[string]any) (any, error)
	AddField(ctx context.Context, collection string, document *bytes.Buffer) (any, error)
	UpdateField(ctx context.Context, collection string, document *bytes.Buffer) (any, error)
	DeleteField(ctx context.Context, collection string, document *bytes.Buffer) (any, error)

	HealthChecker
}

type SolrProvider 

type SolrProvider interface {
	Solr
	// contains filtered or unexported methods
}

type Transaction 

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.