container

package

Go to main page

Versions in this module

v1

v1.29.0

Dec 24, 2024

v1.28.2

Dec 10, 2024

v1.28.1

Nov 27, 2024

v1.28.0

Nov 27, 2024

Changes in this version

type Container

+ OpenTSDB OpenTSDB

+ type MockOpenTSDB struct

+ func NewMockOpenTSDB(ctrl *gomock.Controller) *MockOpenTSDB

+ func (m *MockOpenTSDB) DeleteAnnotation(ctx context.Context, annotation, res any) error

+ func (m *MockOpenTSDB) EXPECT() *MockOpenTSDBMockRecorder

+ func (m *MockOpenTSDB) GetAggregators(ctx context.Context, res any) error

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

+ func (m *MockOpenTSDB) PostAnnotation(ctx context.Context, annotation, res any) error

+ func (m *MockOpenTSDB) PutAnnotation(ctx context.Context, annotation, res any) error

+ func (m *MockOpenTSDB) PutDataPoints(ctx context.Context, data any, queryParam string, res any) error

+ func (m *MockOpenTSDB) QueryAnnotation(ctx context.Context, queryAnnoParam map[string]any, res any) error

+ func (m *MockOpenTSDB) QueryDataPoints(ctx context.Context, param, res any) error

+ func (m *MockOpenTSDB) QueryLatestDataPoints(ctx context.Context, param, res any) error

+ type MockOpenTSDBMockRecorder struct

+ func (mr *MockOpenTSDBMockRecorder) DeleteAnnotation(ctx, annotation, res any) *gomock.Call

+ func (mr *MockOpenTSDBMockRecorder) GetAggregators(ctx, res any) *gomock.Call

+ func (mr *MockOpenTSDBMockRecorder) HealthCheck(arg0 any) *gomock.Call

+ func (mr *MockOpenTSDBMockRecorder) PostAnnotation(ctx, annotation, res any) *gomock.Call

+ func (mr *MockOpenTSDBMockRecorder) PutAnnotation(ctx, annotation, res any) *gomock.Call

+ func (mr *MockOpenTSDBMockRecorder) PutDataPoints(ctx, data, queryParam, res any) *gomock.Call

+ func (mr *MockOpenTSDBMockRecorder) QueryAnnotation(ctx, queryAnnoParam, res any) *gomock.Call

+ func (mr *MockOpenTSDBMockRecorder) QueryDataPoints(ctx, param, res any) *gomock.Call

+ func (mr *MockOpenTSDBMockRecorder) QueryLatestDataPoints(ctx, param, res any) *gomock.Call

+ type MockOpenTSDBProvider struct

+ func NewMockOpenTSDBProvider(ctrl *gomock.Controller) *MockOpenTSDBProvider

+ func (m *MockOpenTSDBProvider) Connect()

+ func (m *MockOpenTSDBProvider) DeleteAnnotation(ctx context.Context, annotation, res any) error

+ func (m *MockOpenTSDBProvider) EXPECT() *MockOpenTSDBProviderMockRecorder

+ func (m *MockOpenTSDBProvider) GetAggregators(ctx context.Context, res any) error

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

+ func (m *MockOpenTSDBProvider) PostAnnotation(ctx context.Context, annotation, res any) error

+ func (m *MockOpenTSDBProvider) PutAnnotation(ctx context.Context, annotation, res any) error

+ func (m *MockOpenTSDBProvider) PutDataPoints(ctx context.Context, data any, queryParam string, res any) error

+ func (m *MockOpenTSDBProvider) QueryAnnotation(ctx context.Context, queryAnnoParam map[string]any, res any) error

+ func (m *MockOpenTSDBProvider) QueryDataPoints(ctx context.Context, param, res any) error

+ func (m *MockOpenTSDBProvider) QueryLatestDataPoints(ctx context.Context, param, res any) error

+ func (m *MockOpenTSDBProvider) UseLogger(logger any)

+ func (m *MockOpenTSDBProvider) UseMetrics(metrics any)

+ func (m *MockOpenTSDBProvider) UseTracer(tracer any)

+ type MockOpenTSDBProviderMockRecorder struct

+ func (mr *MockOpenTSDBProviderMockRecorder) Connect() *gomock.Call

+ func (mr *MockOpenTSDBProviderMockRecorder) DeleteAnnotation(ctx, annotation, res any) *gomock.Call

+ func (mr *MockOpenTSDBProviderMockRecorder) GetAggregators(ctx, res any) *gomock.Call

+ func (mr *MockOpenTSDBProviderMockRecorder) HealthCheck(arg0 any) *gomock.Call

+ func (mr *MockOpenTSDBProviderMockRecorder) PostAnnotation(ctx, annotation, res any) *gomock.Call

+ func (mr *MockOpenTSDBProviderMockRecorder) PutAnnotation(ctx, annotation, res any) *gomock.Call

+ func (mr *MockOpenTSDBProviderMockRecorder) PutDataPoints(ctx, data, queryParam, res any) *gomock.Call

+ func (mr *MockOpenTSDBProviderMockRecorder) QueryAnnotation(ctx, queryAnnoParam, res any) *gomock.Call

+ func (mr *MockOpenTSDBProviderMockRecorder) QueryDataPoints(ctx, param, res any) *gomock.Call

+ func (mr *MockOpenTSDBProviderMockRecorder) QueryLatestDataPoints(ctx, param, res any) *gomock.Call

+ func (mr *MockOpenTSDBProviderMockRecorder) UseLogger(logger any) *gomock.Call

+ func (mr *MockOpenTSDBProviderMockRecorder) UseMetrics(metrics any) *gomock.Call

+ func (mr *MockOpenTSDBProviderMockRecorder) UseTracer(tracer any) *gomock.Call

type Mocks

+ OpenTSDB *MockOpenTSDBProvider

+ type OpenTSDB interface

+ DeleteAnnotation func(ctx context.Context, annotation any, res any) error

+ GetAggregators func(ctx context.Context, res any) error

+ PostAnnotation func(ctx context.Context, annotation any, res any) error

+ PutAnnotation func(ctx context.Context, annotation any, res any) error

+ PutDataPoints func(ctx context.Context, data any, queryParam string, res any) error

+ QueryAnnotation func(ctx context.Context, queryAnnoParam map[string]any, res any) error

+ QueryDataPoints func(ctx context.Context, param any, res any) error

+ QueryLatestDataPoints func(ctx context.Context, param any, res any) error

+ type OpenTSDBProvider interface

v1.27.1

Nov 17, 2024

v1.27.0

Nov 15, 2024

v1.26.0

Nov 7, 2024

v1.25.0

Nov 4, 2024

v1.24.2

Oct 22, 2024

v1.24.1

Oct 17, 2024

v1.24.0

Oct 14, 2024

Changes in this version

+ type CassandraBatchWithContext interface

+ BatchQueryWithCtx func(ctx context.Context, name, stmt string, values ...any) error

+ ExecuteBatchCASWithCtx func(ctx context.Context, name string, dest ...any) (bool, error)

+ ExecuteBatchWithCtx func(ctx context.Context, name string) error

+ type CassandraWithContext interface

+ ExecCASWithCtx func(ctx context.Context, dest any, stmt string, values ...any) (bool, error)

+ ExecWithCtx func(ctx context.Context, stmt string, values ...any) error

+ NewBatchWithCtx func(ctx context.Context, name string, batchType int) error

+ QueryWithCtx func(ctx context.Context, dest any, stmt string, values ...any) error

+ type MockCassandraBatchWithContext struct

+ func NewMockCassandraBatchWithContext(ctrl *gomock.Controller) *MockCassandraBatchWithContext

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

+ func (m *MockCassandraBatchWithContext) BatchQueryWithCtx(ctx context.Context, name, stmt string, values ...any) error

+ func (m *MockCassandraBatchWithContext) EXPECT() *MockCassandraBatchWithContextMockRecorder

+ func (m *MockCassandraBatchWithContext) ExecuteBatch(name string) error

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

+ func (m *MockCassandraBatchWithContext) ExecuteBatchCASWithCtx(ctx context.Context, name string, dest ...any) (bool, error)

+ func (m *MockCassandraBatchWithContext) ExecuteBatchWithCtx(ctx context.Context, name string) error

+ type MockCassandraBatchWithContextMockRecorder struct

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

+ func (mr *MockCassandraBatchWithContextMockRecorder) BatchQueryWithCtx(ctx, name, stmt any, values ...any) *gomock.Call

+ func (mr *MockCassandraBatchWithContextMockRecorder) ExecuteBatch(name any) *gomock.Call

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

+ func (mr *MockCassandraBatchWithContextMockRecorder) ExecuteBatchCASWithCtx(ctx, name any, dest ...any) *gomock.Call

+ func (mr *MockCassandraBatchWithContextMockRecorder) ExecuteBatchWithCtx(ctx, name any) *gomock.Call

type MockCassandraProvider

+ func (m *MockCassandraProvider) BatchQueryWithCtx(ctx context.Context, name, stmt string, values ...any) error

+ func (m *MockCassandraProvider) ExecCASWithCtx(ctx context.Context, dest any, stmt string, values ...any) (bool, error)

+ func (m *MockCassandraProvider) ExecWithCtx(ctx context.Context, stmt string, values ...any) error

+ func (m *MockCassandraProvider) ExecuteBatchCASWithCtx(ctx context.Context, name string, dest ...any) (bool, error)

+ func (m *MockCassandraProvider) ExecuteBatchWithCtx(ctx context.Context, name string) error

+ func (m *MockCassandraProvider) NewBatchWithCtx(ctx context.Context, name string, batchType int) error

+ func (m *MockCassandraProvider) QueryWithCtx(ctx context.Context, dest any, stmt string, values ...any) error

type MockCassandraProviderMockRecorder

+ func (mr *MockCassandraProviderMockRecorder) BatchQueryWithCtx(ctx, name, stmt any, values ...any) *gomock.Call

+ func (mr *MockCassandraProviderMockRecorder) ExecCASWithCtx(ctx, dest, stmt any, values ...any) *gomock.Call

+ func (mr *MockCassandraProviderMockRecorder) ExecWithCtx(ctx, stmt any, values ...any) *gomock.Call

+ func (mr *MockCassandraProviderMockRecorder) ExecuteBatchCASWithCtx(ctx, name any, dest ...any) *gomock.Call

+ func (mr *MockCassandraProviderMockRecorder) ExecuteBatchWithCtx(ctx, name any) *gomock.Call

+ func (mr *MockCassandraProviderMockRecorder) NewBatchWithCtx(ctx, name, batchType any) *gomock.Call

+ func (mr *MockCassandraProviderMockRecorder) QueryWithCtx(ctx, dest, stmt any, values ...any) *gomock.Call

+ type MockCassandraWithContext struct

+ func NewMockCassandraWithContext(ctrl *gomock.Controller) *MockCassandraWithContext

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

+ func (m *MockCassandraWithContext) BatchQueryWithCtx(ctx context.Context, name, stmt string, values ...any) error

+ func (m *MockCassandraWithContext) EXPECT() *MockCassandraWithContextMockRecorder

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

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

+ func (m *MockCassandraWithContext) ExecCASWithCtx(ctx context.Context, dest any, stmt string, values ...any) (bool, error)

+ func (m *MockCassandraWithContext) ExecWithCtx(ctx context.Context, stmt string, values ...any) error

+ func (m *MockCassandraWithContext) ExecuteBatch(name string) error

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

+ func (m *MockCassandraWithContext) ExecuteBatchCASWithCtx(ctx context.Context, name string, dest ...any) (bool, error)

+ func (m *MockCassandraWithContext) ExecuteBatchWithCtx(ctx context.Context, name string) error

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

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

+ func (m *MockCassandraWithContext) NewBatchWithCtx(ctx context.Context, name string, batchType int) error

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

+ func (m *MockCassandraWithContext) QueryWithCtx(ctx context.Context, dest any, stmt string, values ...any) error

+ type MockCassandraWithContextMockRecorder struct

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

+ func (mr *MockCassandraWithContextMockRecorder) BatchQueryWithCtx(ctx, name, stmt any, values ...any) *gomock.Call

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

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

+ func (mr *MockCassandraWithContextMockRecorder) ExecCASWithCtx(ctx, dest, stmt any, values ...any) *gomock.Call

+ func (mr *MockCassandraWithContextMockRecorder) ExecWithCtx(ctx, stmt any, values ...any) *gomock.Call

+ func (mr *MockCassandraWithContextMockRecorder) ExecuteBatch(name any) *gomock.Call

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

+ func (mr *MockCassandraWithContextMockRecorder) ExecuteBatchCASWithCtx(ctx, name any, dest ...any) *gomock.Call

+ func (mr *MockCassandraWithContextMockRecorder) ExecuteBatchWithCtx(ctx, name any) *gomock.Call

+ func (mr *MockCassandraWithContextMockRecorder) HealthCheck(arg0 any) *gomock.Call

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

+ func (mr *MockCassandraWithContextMockRecorder) NewBatchWithCtx(ctx, name, batchType any) *gomock.Call

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

+ func (mr *MockCassandraWithContextMockRecorder) QueryWithCtx(ctx, dest, stmt any, values ...any) *gomock.Call

+ type MockPubSubProvider struct

+ func NewMockPubSubProvider(ctrl *gomock.Controller) *MockPubSubProvider

+ func (m *MockPubSubProvider) Close() error

+ func (m *MockPubSubProvider) Connect()

+ func (m *MockPubSubProvider) CreateTopic(context context.Context, name string) error

+ func (m *MockPubSubProvider) DeleteTopic(context context.Context, name string) error

+ func (m *MockPubSubProvider) EXPECT() *MockPubSubProviderMockRecorder

+ func (m *MockPubSubProvider) Health() datasource.Health

+ func (m *MockPubSubProvider) Publish(ctx context.Context, topic string, message []byte) error

+ func (m *MockPubSubProvider) Subscribe(ctx context.Context, topic string) (*pubsub.Message, error)

+ func (m *MockPubSubProvider) UseLogger(logger any)

+ func (m *MockPubSubProvider) UseMetrics(metrics any)

+ func (m *MockPubSubProvider) UseTracer(tracer any)

+ type MockPubSubProviderMockRecorder struct

+ func (mr *MockPubSubProviderMockRecorder) Close() *gomock.Call

+ func (mr *MockPubSubProviderMockRecorder) Connect() *gomock.Call

+ func (mr *MockPubSubProviderMockRecorder) CreateTopic(context, name any) *gomock.Call

+ func (mr *MockPubSubProviderMockRecorder) DeleteTopic(context, name any) *gomock.Call

+ func (mr *MockPubSubProviderMockRecorder) Health() *gomock.Call

+ func (mr *MockPubSubProviderMockRecorder) Publish(ctx, topic, message any) *gomock.Call

+ func (mr *MockPubSubProviderMockRecorder) Subscribe(ctx, topic any) *gomock.Call

+ func (mr *MockPubSubProviderMockRecorder) UseLogger(logger any) *gomock.Call

+ func (mr *MockPubSubProviderMockRecorder) UseMetrics(metrics any) *gomock.Call

+ func (mr *MockPubSubProviderMockRecorder) UseTracer(tracer any) *gomock.Call

v1.23.0

Oct 7, 2024

v1.22.1

Oct 3, 2024

v1.22.0

Oct 1, 2024

Changes in this version

type MockCassandraProvider

+ func (m *MockCassandraProvider) UseTracer(tracer any)

type MockCassandraProviderMockRecorder

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

type MockClickhouseProvider

+ func (m *MockClickhouseProvider) UseTracer(tracer any)

type MockClickhouseProviderMockRecorder

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

type MockDgraphProvider

+ func (m *MockDgraphProvider) UseTracer(tracer any)

type MockDgraphProviderMockRecorder

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

type MockKVStoreProvider

+ func (m *MockKVStoreProvider) UseTracer(tracer any)

type MockKVStoreProviderMockRecorder

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

type MockMongoProvider

+ func (m *MockMongoProvider) UseTracer(tracer any)

type MockMongoProviderMockRecorder

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

+ type MockSolr struct

+ func NewMockSolr(ctrl *gomock.Controller) *MockSolr

+ func (m *MockSolr) AddField(ctx context.Context, collection string, document *bytes.Buffer) (any, error)

+ func (m *MockSolr) Create(ctx context.Context, collection string, document *bytes.Buffer, ...) (any, error)

+ func (m *MockSolr) Delete(ctx context.Context, collection string, document *bytes.Buffer, ...) (any, error)

+ func (m *MockSolr) DeleteField(ctx context.Context, collection string, document *bytes.Buffer) (any, error)

+ func (m *MockSolr) EXPECT() *MockSolrMockRecorder

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

+ func (m *MockSolr) ListFields(ctx context.Context, collection string, params map[string]any) (any, error)

+ func (m *MockSolr) Retrieve(ctx context.Context, collection string, params map[string]any) (any, error)

+ func (m *MockSolr) Search(ctx context.Context, collection string, params map[string]any) (any, error)

+ func (m *MockSolr) Update(ctx context.Context, collection string, document *bytes.Buffer, ...) (any, error)

+ func (m *MockSolr) UpdateField(ctx context.Context, collection string, document *bytes.Buffer) (any, error)

+ type MockSolrMockRecorder struct

+ func (mr *MockSolrMockRecorder) AddField(ctx, collection, document any) *gomock.Call

+ func (mr *MockSolrMockRecorder) Create(ctx, collection, document, params any) *gomock.Call

+ func (mr *MockSolrMockRecorder) Delete(ctx, collection, document, params any) *gomock.Call

+ func (mr *MockSolrMockRecorder) DeleteField(ctx, collection, document any) *gomock.Call

+ func (mr *MockSolrMockRecorder) HealthCheck(arg0 any) *gomock.Call

+ func (mr *MockSolrMockRecorder) ListFields(ctx, collection, params any) *gomock.Call

+ func (mr *MockSolrMockRecorder) Retrieve(ctx, collection, params any) *gomock.Call

+ func (mr *MockSolrMockRecorder) Search(ctx, collection, params any) *gomock.Call

+ func (mr *MockSolrMockRecorder) Update(ctx, collection, document, params any) *gomock.Call

+ func (mr *MockSolrMockRecorder) UpdateField(ctx, collection, document any) *gomock.Call

+ type MockSolrProvider struct

+ func NewMockSolrProvider(ctrl *gomock.Controller) *MockSolrProvider

+ func (m *MockSolrProvider) AddField(ctx context.Context, collection string, document *bytes.Buffer) (any, error)

+ func (m *MockSolrProvider) Connect()

+ func (m *MockSolrProvider) Create(ctx context.Context, collection string, document *bytes.Buffer, ...) (any, error)

+ func (m *MockSolrProvider) Delete(ctx context.Context, collection string, document *bytes.Buffer, ...) (any, error)

+ func (m *MockSolrProvider) DeleteField(ctx context.Context, collection string, document *bytes.Buffer) (any, error)

+ func (m *MockSolrProvider) EXPECT() *MockSolrProviderMockRecorder

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

+ func (m *MockSolrProvider) ListFields(ctx context.Context, collection string, params map[string]any) (any, error)

+ func (m *MockSolrProvider) Retrieve(ctx context.Context, collection string, params map[string]any) (any, error)

+ func (m *MockSolrProvider) Search(ctx context.Context, collection string, params map[string]any) (any, error)

+ func (m *MockSolrProvider) Update(ctx context.Context, collection string, document *bytes.Buffer, ...) (any, error)

+ func (m *MockSolrProvider) UpdateField(ctx context.Context, collection string, document *bytes.Buffer) (any, error)

+ func (m *MockSolrProvider) UseLogger(logger any)

+ func (m *MockSolrProvider) UseMetrics(metrics any)

+ func (m *MockSolrProvider) UseTracer(tracer any)

+ type MockSolrProviderMockRecorder struct

+ func (mr *MockSolrProviderMockRecorder) AddField(ctx, collection, document any) *gomock.Call

+ func (mr *MockSolrProviderMockRecorder) Connect() *gomock.Call

+ func (mr *MockSolrProviderMockRecorder) Create(ctx, collection, document, params any) *gomock.Call

+ func (mr *MockSolrProviderMockRecorder) Delete(ctx, collection, document, params any) *gomock.Call

+ func (mr *MockSolrProviderMockRecorder) DeleteField(ctx, collection, document any) *gomock.Call

+ func (mr *MockSolrProviderMockRecorder) HealthCheck(arg0 any) *gomock.Call

+ func (mr *MockSolrProviderMockRecorder) ListFields(ctx, collection, params any) *gomock.Call

+ func (mr *MockSolrProviderMockRecorder) Retrieve(ctx, collection, params any) *gomock.Call

+ func (mr *MockSolrProviderMockRecorder) Search(ctx, collection, params any) *gomock.Call

+ func (mr *MockSolrProviderMockRecorder) Update(ctx, collection, document, params any) *gomock.Call

+ func (mr *MockSolrProviderMockRecorder) UpdateField(ctx, collection, document any) *gomock.Call

+ func (mr *MockSolrProviderMockRecorder) UseLogger(logger any) *gomock.Call

+ func (mr *MockSolrProviderMockRecorder) UseMetrics(metrics any) *gomock.Call

+ func (mr *MockSolrProviderMockRecorder) UseTracer(tracer any) *gomock.Call

type Mockprovider

+ func (m *Mockprovider) UseTracer(tracer any)

type MockproviderMockRecorder

+ func (mr *MockproviderMockRecorder) UseTracer(tracer any) *gomock.Call

+ type PubSubProvider interface

v1.21.0

Sep 23, 2024

Changes in this version

type Container

+ DGraph Dgraph

+ type Dgraph interface

+ Alter func(ctx context.Context, op any) error

+ Mutate func(ctx context.Context, mu any) (any, error)

+ NewReadOnlyTxn func() any

+ NewTxn func() any

+ Query func(ctx context.Context, query string) (any, error)

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

+ type DgraphProvider interface

+ type MockDgraph struct

+ func NewMockDgraph(ctrl *gomock.Controller) *MockDgraph

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

+ func (m *MockDgraph) EXPECT() *MockDgraphMockRecorder

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

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

+ func (m *MockDgraph) NewReadOnlyTxn() any

+ func (m *MockDgraph) NewTxn() any

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

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

+ type MockDgraphMockRecorder struct

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

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

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

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

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

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

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

+ type MockDgraphProvider struct

+ func NewMockDgraphProvider(ctrl *gomock.Controller) *MockDgraphProvider

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

+ func (m *MockDgraphProvider) Connect()

+ func (m *MockDgraphProvider) EXPECT() *MockDgraphProviderMockRecorder

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

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

+ func (m *MockDgraphProvider) NewReadOnlyTxn() any

+ func (m *MockDgraphProvider) NewTxn() any

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

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

+ func (m *MockDgraphProvider) UseLogger(logger any)

+ func (m *MockDgraphProvider) UseMetrics(metrics any)

+ type MockDgraphProviderMockRecorder struct

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

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

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

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

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

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

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

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

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

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

type Mocks

+ DGraph *MockDgraph

+ Metrics *MockMetrics

v1.20.0

Sep 16, 2024

Changes in this version

+ func WithMockHTTPService(httpServiceNames ...string) options

type Container

+ Solr Solr

type Mocks

+ HTTPService *service.MockHTTP

+ type Solr interface

+ AddField func(ctx context.Context, collection string, document *bytes.Buffer) (any, error)

+ Create func(ctx context.Context, collection string, document *bytes.Buffer, ...) (any, error)

+ Delete func(ctx context.Context, collection string, document *bytes.Buffer, ...) (any, error)

+ DeleteField func(ctx context.Context, collection string, document *bytes.Buffer) (any, error)

+ ListFields func(ctx context.Context, collection string, params map[string]any) (any, error)

+ Retrieve func(ctx context.Context, collection string, params map[string]any) (any, error)

+ Search func(ctx context.Context, collection string, params map[string]any) (any, error)

+ Update func(ctx context.Context, collection string, document *bytes.Buffer, ...) (any, error)

+ UpdateField func(ctx context.Context, collection string, document *bytes.Buffer) (any, error)

+ type SolrProvider interface

v1.19.1

Sep 9, 2024

v1.19.0

Sep 2, 2024

v1.18.0

Aug 26, 2024

Changes in this version

type Mocks

+ File *file.MockFileSystemProvider

v1.17.0

Aug 12, 2024

Changes in this version

type Cassandra

+ NewBatch func(name string, batchType int) error

+ type CassandraBatch interface

+ BatchQuery func(name, stmt string, values ...any) error

+ ExecuteBatch func(name string) error

+ ExecuteBatchCAS func(name string, dest ...any) (bool, error)

type Container

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

type MockCassandra

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

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

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

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

+ type MockCassandraBatch struct

+ func NewMockCassandraBatch(ctrl *gomock.Controller) *MockCassandraBatch

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

+ func (m *MockCassandraBatch) EXPECT() *MockCassandraBatchMockRecorder

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

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

+ type MockCassandraBatchMockRecorder struct

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

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

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

type MockCassandraMockRecorder

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

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

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

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

type MockCassandraProvider

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

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

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

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

type MockCassandraProviderMockRecorder

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

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

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

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

v1.16.1

Aug 6, 2024

v1.16.0

Aug 5, 2024

Changes in this version

type Container

+ func (c *Container) Close() error

type DB

+ Close func() error

type MockDB

+ func (m *MockDB) Close() error

type MockDBMockRecorder

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

type MockPubSub

+ func (*MockPubSub) Close() error

type MockRedis

+ func (m *MockRedis) Close() error

type MockRedisMockRecorder

+ func (mr *MockRedisMockRecorder) Close() *gomock.Call

type Redis

+ Close func() error

v1.15.0

Jul 22, 2024

Changes in this version

type Container

+ KVStore KVStore

+ type KVStore interface

+ Delete func(ctx context.Context, key string) error

+ Get func(ctx context.Context, key string) (string, error)

+ Set func(ctx context.Context, key, value string) error

+ type KVStoreProvider interface

+ type MockKVStore struct

+ func NewMockKVStore(ctrl *gomock.Controller) *MockKVStore

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

+ func (m *MockKVStore) EXPECT() *MockKVStoreMockRecorder

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

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

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

+ type MockKVStoreMockRecorder struct

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

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

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

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

+ type MockKVStoreProvider struct

+ func NewMockKVStoreProvider(ctrl *gomock.Controller) *MockKVStoreProvider

+ func (m *MockKVStoreProvider) Connect()

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

+ func (m *MockKVStoreProvider) EXPECT() *MockKVStoreProviderMockRecorder

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

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

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

+ func (m *MockKVStoreProvider) UseLogger(logger any)

+ func (m *MockKVStoreProvider) UseMetrics(metrics any)

+ type MockKVStoreProviderMockRecorder struct

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

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

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

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

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

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

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

type MockRedis

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

+ func (m *MockRedis) FTAggregate(ctx context.Context, index, query string) *redis.MapStringInterfaceCmd

+ func (m *MockRedis) FTAggregateWithArgs(ctx context.Context, index, query string, options *redis.FTAggregateOptions) *redis.AggregateCmd

+ func (m *MockRedis) FTAliasAdd(ctx context.Context, index, alias string) *redis.StatusCmd

+ func (m *MockRedis) FTAliasDel(ctx context.Context, alias string) *redis.StatusCmd

+ func (m *MockRedis) FTAliasUpdate(ctx context.Context, index, alias string) *redis.StatusCmd

+ func (m *MockRedis) FTAlter(ctx context.Context, index string, skipInitalScan bool, definition []any) *redis.StatusCmd

+ func (m *MockRedis) FTConfigGet(ctx context.Context, option string) *redis.MapMapStringInterfaceCmd

+ func (m *MockRedis) FTConfigSet(ctx context.Context, option string, value any) *redis.StatusCmd

+ func (m *MockRedis) FTCreate(ctx context.Context, index string, options *redis.FTCreateOptions, ...) *redis.StatusCmd

+ func (m *MockRedis) FTCursorDel(ctx context.Context, index string, cursorId int) *redis.StatusCmd

+ func (m *MockRedis) FTCursorRead(ctx context.Context, index string, cursorId, count int) *redis.MapStringInterfaceCmd

+ func (m *MockRedis) FTDictAdd(ctx context.Context, dict string, term ...any) *redis.IntCmd

+ func (m *MockRedis) FTDictDel(ctx context.Context, dict string, term ...any) *redis.IntCmd

+ func (m *MockRedis) FTDictDump(ctx context.Context, dict string) *redis.StringSliceCmd

+ func (m *MockRedis) FTDropIndex(ctx context.Context, index string) *redis.StatusCmd

+ func (m *MockRedis) FTDropIndexWithArgs(ctx context.Context, index string, options *redis.FTDropIndexOptions) *redis.StatusCmd

+ func (m *MockRedis) FTExplain(ctx context.Context, index, query string) *redis.StringCmd

+ func (m *MockRedis) FTExplainWithArgs(ctx context.Context, index, query string, options *redis.FTExplainOptions) *redis.StringCmd

+ func (m *MockRedis) FTInfo(ctx context.Context, index string) *redis.FTInfoCmd

+ func (m *MockRedis) FTSearch(ctx context.Context, index, query string) *redis.FTSearchCmd

+ func (m *MockRedis) FTSearchWithArgs(ctx context.Context, index, query string, options *redis.FTSearchOptions) *redis.FTSearchCmd

+ func (m *MockRedis) FTSpellCheck(ctx context.Context, index, query string) *redis.FTSpellCheckCmd

+ func (m *MockRedis) FTSpellCheckWithArgs(ctx context.Context, index, query string, options *redis.FTSpellCheckOptions) *redis.FTSpellCheckCmd

+ func (m *MockRedis) FTSynDump(ctx context.Context, index string) *redis.FTSynDumpCmd

+ func (m *MockRedis) FTSynUpdate(ctx context.Context, index string, synGroupId any, terms []any) *redis.StatusCmd

+ func (m *MockRedis) FTSynUpdateWithArgs(ctx context.Context, index string, synGroupId any, ...) *redis.StatusCmd

+ func (m *MockRedis) FTTagVals(ctx context.Context, index, field string) *redis.StringSliceCmd

+ func (m *MockRedis) FT_List(ctx context.Context) *redis.StringSliceCmd

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

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

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

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

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

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

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

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

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

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

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

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

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

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

type MockRedisMockRecorder

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

+ func (mr *MockRedisMockRecorder) FTAggregate(ctx, index, query any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FTAggregateWithArgs(ctx, index, query, options any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FTAliasAdd(ctx, index, alias any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FTAliasDel(ctx, alias any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FTAliasUpdate(ctx, index, alias any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FTAlter(ctx, index, skipInitalScan, definition any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FTConfigGet(ctx, option any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FTConfigSet(ctx, option, value any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FTCreate(ctx, index, options any, schema ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FTCursorDel(ctx, index, cursorId any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FTCursorRead(ctx, index, cursorId, count any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FTDictAdd(ctx, dict any, term ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FTDictDel(ctx, dict any, term ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FTDictDump(ctx, dict any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FTDropIndex(ctx, index any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FTDropIndexWithArgs(ctx, index, options any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FTExplain(ctx, index, query any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FTExplainWithArgs(ctx, index, query, options any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FTInfo(ctx, index any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FTSearch(ctx, index, query any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FTSearchWithArgs(ctx, index, query, options any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FTSpellCheck(ctx, index, query any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FTSpellCheckWithArgs(ctx, index, query, options any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FTSynDump(ctx, index any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FTSynUpdate(ctx, index, synGroupId, terms any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FTSynUpdateWithArgs(ctx, index, synGroupId, options, terms any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FTTagVals(ctx, index, field any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FT_List(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) HExpire(ctx, key, expiration any, fields ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) HExpireAt(ctx, key, tm any, fields ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) HExpireAtWithArgs(ctx, key, tm, expirationArgs any, fields ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) HExpireTime(ctx, key any, fields ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) HExpireWithArgs(ctx, key, expiration, expirationArgs any, fields ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) HPExpire(ctx, key, expiration any, fields ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) HPExpireAt(ctx, key, tm any, fields ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) HPExpireAtWithArgs(ctx, key, tm, expirationArgs any, fields ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) HPExpireTime(ctx, key any, fields ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) HPExpireWithArgs(ctx, key, expiration, expirationArgs any, fields ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) HPTTL(ctx, key any, fields ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) HPersist(ctx, key any, fields ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) HScanNoValues(ctx, key, cursor, match, count any) *gomock.Call

+ func (mr *MockRedisMockRecorder) HTTL(ctx, key any, fields ...any) *gomock.Call

type Mocks

+ KVStore *MockKVStore

v1.14.1

Jul 12, 2024

v1.14.0

Jul 12, 2024

v1.13.0

Jul 8, 2024

Changes in this version

type MockCassandra

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

type MockCassandraMockRecorder

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

type MockCassandraProvider

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

type MockCassandraProviderMockRecorder

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

type MockClickhouse

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

type MockClickhouseMockRecorder

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

type MockClickhouseProvider

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

type MockClickhouseProviderMockRecorder

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

+ type MockHealthChecker struct

+ func NewMockHealthChecker(ctrl *gomock.Controller) *MockHealthChecker

+ func (m *MockHealthChecker) EXPECT() *MockHealthCheckerMockRecorder

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

+ type MockHealthCheckerMockRecorder struct

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

type MockMongo

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

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

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

type MockMongoMockRecorder

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

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

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

type MockMongoProvider

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

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

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

type MockMongoProviderMockRecorder

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

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

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

+ type MockTransaction struct

+ func NewMockTransaction(ctrl *gomock.Controller) *MockTransaction

+ func (m *MockTransaction) AbortTransaction(arg0 context.Context) error

+ func (m *MockTransaction) CommitTransaction(arg0 context.Context) error

+ func (m *MockTransaction) EXPECT() *MockTransactionMockRecorder

+ func (m *MockTransaction) EndSession(arg0 context.Context)

+ func (m *MockTransaction) StartTransaction() error

+ type MockTransactionMockRecorder struct

+ func (mr *MockTransactionMockRecorder) AbortTransaction(arg0 any) *gomock.Call

+ func (mr *MockTransactionMockRecorder) CommitTransaction(arg0 any) *gomock.Call

+ func (mr *MockTransactionMockRecorder) EndSession(arg0 any) *gomock.Call

+ func (mr *MockTransactionMockRecorder) StartTransaction() *gomock.Call

type Mongo

+ CreateCollection func(ctx context.Context, name string) error

+ StartSession func() (interface{}, error)

+ type Transaction interface

+ AbortTransaction func(context.Context) error

+ CommitTransaction func(context.Context) error

+ EndSession func(context.Context)

+ StartTransaction func() error

v1.12.0

Jun 28, 2024

Changes in this version

+ type Cassandra interface

+ Exec func(stmt string, values ...interface{}) error

+ ExecCAS func(dest interface{}, stmt string, values ...interface{}) (bool, error)

+ Query func(dest interface{}, stmt string, values ...interface{}) error

+ type CassandraProvider interface

+ type Clickhouse interface

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

+ Exec func(ctx context.Context, query string, args ...any) error

+ Select func(ctx context.Context, dest any, query string, args ...any) error

+ type ClickhouseProvider interface

+ type MockCassandra struct

+ func NewMockCassandra(ctrl *gomock.Controller) *MockCassandra

+ func (m *MockCassandra) EXPECT() *MockCassandraMockRecorder

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

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

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

+ type MockCassandraMockRecorder struct

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

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

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

+ type MockCassandraProvider struct

+ func NewMockCassandraProvider(ctrl *gomock.Controller) *MockCassandraProvider

+ func (m *MockCassandraProvider) Connect()

+ func (m *MockCassandraProvider) EXPECT() *MockCassandraProviderMockRecorder

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

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

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

+ func (m *MockCassandraProvider) UseLogger(logger any)

+ func (m *MockCassandraProvider) UseMetrics(metrics any)

+ type MockCassandraProviderMockRecorder struct

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

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

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

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

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

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

+ type MockClickhouse struct

+ func NewMockClickhouse(ctrl *gomock.Controller) *MockClickhouse

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

+ func (m *MockClickhouse) EXPECT() *MockClickhouseMockRecorder

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

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

+ type MockClickhouseMockRecorder struct

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

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

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

+ type MockClickhouseProvider struct

+ func NewMockClickhouseProvider(ctrl *gomock.Controller) *MockClickhouseProvider

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

+ func (m *MockClickhouseProvider) Connect()

+ func (m *MockClickhouseProvider) EXPECT() *MockClickhouseProviderMockRecorder

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

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

+ func (m *MockClickhouseProvider) UseLogger(logger any)

+ func (m *MockClickhouseProvider) UseMetrics(metrics any)

+ type MockClickhouseProviderMockRecorder struct

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

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

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

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

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

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

+ type MockMongo struct

+ func NewMockMongo(ctrl *gomock.Controller) *MockMongo

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

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

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

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

+ func (m *MockMongo) EXPECT() *MockMongoMockRecorder

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

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

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

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

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

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

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

+ type MockMongoMockRecorder struct

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

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

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

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

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

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

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

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

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

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

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

+ type MockMongoProvider struct

+ func NewMockMongoProvider(ctrl *gomock.Controller) *MockMongoProvider

+ func (m *MockMongoProvider) Connect()

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

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

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

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

+ func (m *MockMongoProvider) EXPECT() *MockMongoProviderMockRecorder

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

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

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

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

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

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

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

+ func (m *MockMongoProvider) UseLogger(logger any)

+ func (m *MockMongoProvider) UseMetrics(metrics any)

+ type MockMongoProviderMockRecorder struct

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type Mockprovider struct

+ func NewMockprovider(ctrl *gomock.Controller) *Mockprovider

+ func (m *Mockprovider) Connect()

+ func (m *Mockprovider) EXPECT() *MockproviderMockRecorder

+ func (m *Mockprovider) UseLogger(logger any)

+ func (m *Mockprovider) UseMetrics(metrics any)

+ type MockproviderMockRecorder struct

+ func (mr *MockproviderMockRecorder) Connect() *gomock.Call

+ func (mr *MockproviderMockRecorder) UseLogger(logger any) *gomock.Call

+ func (mr *MockproviderMockRecorder) UseMetrics(metrics any) *gomock.Call

type Mocks

+ Cassandra *MockCassandra

+ Clickhouse *MockClickhouse

+ Mongo *MockMongo

+ type Mongo interface

+ CountDocuments func(ctx context.Context, collection string, filter interface{}) (int64, error)

+ DeleteMany func(ctx context.Context, collection string, filter interface{}) (int64, error)

+ DeleteOne func(ctx context.Context, collection string, filter interface{}) (int64, error)

+ Drop func(ctx context.Context, collection string) error

+ Find func(ctx context.Context, collection string, filter interface{}, ...) error

+ FindOne func(ctx context.Context, collection string, filter interface{}, result interface{}) error

+ InsertMany func(ctx context.Context, collection string, documents []interface{}) ([]interface{}, error)

+ InsertOne func(ctx context.Context, collection string, document interface{}) (interface{}, error)

+ UpdateByID func(ctx context.Context, collection string, id interface{}, update interface{}) (int64, error)

+ UpdateMany func(ctx context.Context, collection string, filter interface{}, update interface{}) (int64, error)

+ UpdateOne func(ctx context.Context, collection string, filter interface{}, update interface{}) error

+ type MongoProvider interface

v1.11.0

Jun 21, 2024

Changes in this version

+ type Metrics interface

+ DeltaUpDownCounter func(ctx context.Context, name string, value float64, labels ...string)

+ IncrementCounter func(ctx context.Context, name string, labels ...string)

+ NewCounter func(name, desc string)

+ NewGauge func(name, desc string)

+ NewHistogram func(name, desc string, buckets ...float64)

+ NewUpDownCounter func(name, desc string)

+ RecordHistogram func(ctx context.Context, name string, value float64, labels ...string)

+ SetGauge func(name string, value float64, labels ...string)

+ type MockMetrics struct

+ func NewMockMetrics(ctrl *gomock.Controller) *MockMetrics

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

+ func (m *MockMetrics) EXPECT() *MockMetricsMockRecorder

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

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

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

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

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

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

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

+ type MockMetricsMockRecorder struct

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

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

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

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

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

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

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

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

v1.10.0

Jun 18, 2024

Changes in this version

type Container

+ Clickhouse datasource.Clickhouse

v1.9.0

Jun 11, 2024

Changes in this version

type Container

+ Cassandra datasource.Cassandra

+ File datasource.FileSystem

v1.8.1

Jun 5, 2024

v1.8.0

May 28, 2024

v1.7.0

May 27, 2024

v1.6.1

May 14, 2024

v1.6.0

May 12, 2024

v1.5.0

May 2, 2024

v1.4.1

Apr 27, 2024

Changes in this version

type DB

+ Dialect func() string

type MockDB

+ func (m *MockDB) Dialect() string

type MockDBMockRecorder

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

+ type MockPubSub struct

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

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

+ func (m *MockPubSub) Health() datasource.Health

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

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

v1.4.0

Apr 20, 2024

v1.3.1

Apr 10, 2024

v1.3.0

Apr 6, 2024

Changes in this version

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

type Container

+ Mongo datasource.Mongo

+ type DB interface

+ Begin func() (*gofrSQL.Tx, error)

+ Driver func() driver.Driver

+ Exec func(query string, args ...interface{}) (sql.Result, error)

+ ExecContext func(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ HealthCheck func() *datasource.Health

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

+ Query func(query string, args ...interface{}) (*sql.Rows, error)

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

+ QueryRow func(query string, args ...interface{}) *sql.Row

+ QueryRowContext func(ctx context.Context, query string, args ...interface{}) *sql.Row

+ Select func(ctx context.Context, data interface{}, query string, args ...interface{})

+ type MockDB struct

+ func NewMockDB(ctrl *gomock.Controller) *MockDB

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

+ func (m *MockDB) Driver() driver.Driver

+ func (m *MockDB) EXPECT() *MockDBMockRecorder

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

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

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

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

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

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

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

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

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

+ type MockDBMockRecorder struct

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

+ func (mr *MockDBMockRecorder) Driver() *gomock.Call

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

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

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

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

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

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

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

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

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

+ type MockRedis struct

+ func NewMockRedis(ctrl *gomock.Controller) *MockRedis

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (m *MockRedis) EXPECT() *MockRedisMockRecorder

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (m *MockRedis) TSCreateRuleWithArgs(ctx context.Context, sourceKey, destKey string, aggregator redis.Aggregator, ...) *redis.StatusCmd

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type MockRedisMockRecorder struct

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (mr *MockRedisMockRecorder) ClientUnpause(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ClusterAddSlots(ctx any, slots ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ClusterAddSlotsRange(ctx, min, max any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ClusterCountFailureReports(ctx, nodeID any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ClusterCountKeysInSlot(ctx, slot any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ClusterDelSlots(ctx any, slots ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ClusterDelSlotsRange(ctx, min, max any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ClusterFailover(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ClusterForget(ctx, nodeID any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ClusterGetKeysInSlot(ctx, slot, count any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ClusterInfo(ctx any) *gomock.Call

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

+ func (mr *MockRedisMockRecorder) ClusterLinks(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ClusterMeet(ctx, host, port any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ClusterMyShardID(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ClusterNodes(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ClusterReplicate(ctx, nodeID any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ClusterResetHard(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ClusterResetSoft(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ClusterSaveConfig(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ClusterShards(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ClusterSlaves(ctx, nodeID any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ClusterSlots(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) Command(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) CommandGetKeys(ctx any, commands ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) CommandGetKeysAndFlags(ctx any, commands ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) CommandList(ctx, filter any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ConfigGet(ctx, parameter any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ConfigResetStat(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ConfigRewrite(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ConfigSet(ctx, parameter, value any) *gomock.Call

+ func (mr *MockRedisMockRecorder) Copy(ctx, sourceKey, destKey, db, replace any) *gomock.Call

+ func (mr *MockRedisMockRecorder) DBSize(ctx any) *gomock.Call

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

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

+ func (mr *MockRedisMockRecorder) DecrBy(ctx, key, decrement any) *gomock.Call

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

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

+ func (mr *MockRedisMockRecorder) Echo(ctx, message any) *gomock.Call

+ func (mr *MockRedisMockRecorder) Eval(ctx, script, keys any, args ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) EvalRO(ctx, script, keys any, args ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) EvalSha(ctx, sha1, keys any, args ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) EvalShaRO(ctx, sha1, keys any, args ...any) *gomock.Call

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

+ func (mr *MockRedisMockRecorder) Expire(ctx, key, expiration any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ExpireAt(ctx, key, tm any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ExpireGT(ctx, key, expiration any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ExpireLT(ctx, key, expiration any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ExpireNX(ctx, key, expiration any) *gomock.Call

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

+ func (mr *MockRedisMockRecorder) ExpireXX(ctx, key, expiration any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FCall(ctx, function, keys any, args ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FCallRO(ctx, function, keys any, args ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FCallRo(ctx, function, keys any, args ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FlushAll(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FlushAllAsync(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FlushDB(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FlushDBAsync(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FunctionDelete(ctx, libName any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FunctionDump(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FunctionFlush(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FunctionFlushAsync(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FunctionKill(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FunctionList(ctx, q any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FunctionLoad(ctx, code any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FunctionLoadReplace(ctx, code any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FunctionRestore(ctx, libDump any) *gomock.Call

+ func (mr *MockRedisMockRecorder) FunctionStats(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) GeoAdd(ctx, key any, geoLocation ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) GeoDist(ctx, key, member1, member2, unit any) *gomock.Call

+ func (mr *MockRedisMockRecorder) GeoHash(ctx, key any, members ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) GeoPos(ctx, key any, members ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) GeoRadius(ctx, key, longitude, latitude, query any) *gomock.Call

+ func (mr *MockRedisMockRecorder) GeoRadiusByMember(ctx, key, member, query any) *gomock.Call

+ func (mr *MockRedisMockRecorder) GeoRadiusByMemberStore(ctx, key, member, query any) *gomock.Call

+ func (mr *MockRedisMockRecorder) GeoRadiusStore(ctx, key, longitude, latitude, query any) *gomock.Call

+ func (mr *MockRedisMockRecorder) GeoSearch(ctx, key, q any) *gomock.Call

+ func (mr *MockRedisMockRecorder) GeoSearchLocation(ctx, key, q any) *gomock.Call

+ func (mr *MockRedisMockRecorder) GeoSearchStore(ctx, key, store, q any) *gomock.Call

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

+ func (mr *MockRedisMockRecorder) GetBit(ctx, key, offset any) *gomock.Call

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

+ func (mr *MockRedisMockRecorder) GetEx(ctx, key, expiration any) *gomock.Call

+ func (mr *MockRedisMockRecorder) GetRange(ctx, key, start, end any) *gomock.Call

+ func (mr *MockRedisMockRecorder) GetSet(ctx, key, value any) *gomock.Call

+ func (mr *MockRedisMockRecorder) HDel(ctx, key any, fields ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) HExists(ctx, key, field any) *gomock.Call

+ func (mr *MockRedisMockRecorder) HGet(ctx, key, field any) *gomock.Call

+ func (mr *MockRedisMockRecorder) HGetAll(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) HIncrBy(ctx, key, field, incr any) *gomock.Call

+ func (mr *MockRedisMockRecorder) HIncrByFloat(ctx, key, field, incr any) *gomock.Call

+ func (mr *MockRedisMockRecorder) HKeys(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) HLen(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) HMGet(ctx, key any, fields ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) HMSet(ctx, key any, values ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) HRandField(ctx, key, count any) *gomock.Call

+ func (mr *MockRedisMockRecorder) HRandFieldWithValues(ctx, key, count any) *gomock.Call

+ func (mr *MockRedisMockRecorder) HScan(ctx, key, cursor, match, count any) *gomock.Call

+ func (mr *MockRedisMockRecorder) HSet(ctx, key any, values ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) HSetNX(ctx, key, field, value any) *gomock.Call

+ func (mr *MockRedisMockRecorder) HVals(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) HealthCheck() *gomock.Call

+ func (mr *MockRedisMockRecorder) Incr(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) IncrBy(ctx, key, value any) *gomock.Call

+ func (mr *MockRedisMockRecorder) IncrByFloat(ctx, key, value any) *gomock.Call

+ func (mr *MockRedisMockRecorder) Info(ctx any, section ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) JSONArrAppend(ctx, key, path any, values ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) JSONArrIndex(ctx, key, path any, value ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) JSONArrIndexWithArgs(ctx, key, path, options any, value ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) JSONArrInsert(ctx, key, path, index any, values ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) JSONArrLen(ctx, key, path any) *gomock.Call

+ func (mr *MockRedisMockRecorder) JSONArrPop(ctx, key, path, index any) *gomock.Call

+ func (mr *MockRedisMockRecorder) JSONArrTrim(ctx, key, path any) *gomock.Call

+ func (mr *MockRedisMockRecorder) JSONArrTrimWithArgs(ctx, key, path, options any) *gomock.Call

+ func (mr *MockRedisMockRecorder) JSONClear(ctx, key, path any) *gomock.Call

+ func (mr *MockRedisMockRecorder) JSONDebugMemory(ctx, key, path any) *gomock.Call

+ func (mr *MockRedisMockRecorder) JSONDel(ctx, key, path any) *gomock.Call

+ func (mr *MockRedisMockRecorder) JSONForget(ctx, key, path any) *gomock.Call

+ func (mr *MockRedisMockRecorder) JSONGet(ctx, key any, paths ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) JSONGetWithArgs(ctx, key, options any, paths ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) JSONMGet(ctx, path any, keys ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) JSONMSet(ctx any, params ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) JSONMSetArgs(ctx, docs any) *gomock.Call

+ func (mr *MockRedisMockRecorder) JSONMerge(ctx, key, path, value any) *gomock.Call

+ func (mr *MockRedisMockRecorder) JSONNumIncrBy(ctx, key, path, value any) *gomock.Call

+ func (mr *MockRedisMockRecorder) JSONObjKeys(ctx, key, path any) *gomock.Call

+ func (mr *MockRedisMockRecorder) JSONObjLen(ctx, key, path any) *gomock.Call

+ func (mr *MockRedisMockRecorder) JSONSet(ctx, key, path, value any) *gomock.Call

+ func (mr *MockRedisMockRecorder) JSONSetMode(ctx, key, path, value, mode any) *gomock.Call

+ func (mr *MockRedisMockRecorder) JSONStrAppend(ctx, key, path, value any) *gomock.Call

+ func (mr *MockRedisMockRecorder) JSONStrLen(ctx, key, path any) *gomock.Call

+ func (mr *MockRedisMockRecorder) JSONToggle(ctx, key, path any) *gomock.Call

+ func (mr *MockRedisMockRecorder) JSONType(ctx, key, path any) *gomock.Call

+ func (mr *MockRedisMockRecorder) Keys(ctx, pattern any) *gomock.Call

+ func (mr *MockRedisMockRecorder) LCS(ctx, q any) *gomock.Call

+ func (mr *MockRedisMockRecorder) LIndex(ctx, key, index any) *gomock.Call

+ func (mr *MockRedisMockRecorder) LInsert(ctx, key, op, pivot, value any) *gomock.Call

+ func (mr *MockRedisMockRecorder) LInsertAfter(ctx, key, pivot, value any) *gomock.Call

+ func (mr *MockRedisMockRecorder) LInsertBefore(ctx, key, pivot, value any) *gomock.Call

+ func (mr *MockRedisMockRecorder) LLen(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) LMPop(ctx, direction, count any, keys ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) LMove(ctx, source, destination, srcpos, destpos any) *gomock.Call

+ func (mr *MockRedisMockRecorder) LPop(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) LPopCount(ctx, key, count any) *gomock.Call

+ func (mr *MockRedisMockRecorder) LPos(ctx, key, value, args any) *gomock.Call

+ func (mr *MockRedisMockRecorder) LPosCount(ctx, key, value, count, args any) *gomock.Call

+ func (mr *MockRedisMockRecorder) LPush(ctx, key any, values ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) LPushX(ctx, key any, values ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) LRange(ctx, key, start, stop any) *gomock.Call

+ func (mr *MockRedisMockRecorder) LRem(ctx, key, count, value any) *gomock.Call

+ func (mr *MockRedisMockRecorder) LSet(ctx, key, index, value any) *gomock.Call

+ func (mr *MockRedisMockRecorder) LTrim(ctx, key, start, stop any) *gomock.Call

+ func (mr *MockRedisMockRecorder) LastSave(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) MGet(ctx any, keys ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) MSet(ctx any, values ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) MSetNX(ctx any, values ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) MemoryUsage(ctx, key any, samples ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) Migrate(ctx, host, port, key, db, timeout any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ModuleLoadex(ctx, conf any) *gomock.Call

+ func (mr *MockRedisMockRecorder) Move(ctx, key, db any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ObjectEncoding(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ObjectFreq(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ObjectIdleTime(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ObjectRefCount(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) PExpire(ctx, key, expiration any) *gomock.Call

+ func (mr *MockRedisMockRecorder) PExpireAt(ctx, key, tm any) *gomock.Call

+ func (mr *MockRedisMockRecorder) PExpireTime(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) PFAdd(ctx, key any, els ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) PFCount(ctx any, keys ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) PFMerge(ctx, dest any, keys ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) PTTL(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) Persist(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) Ping(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) Pipeline() *gomock.Call

+ func (mr *MockRedisMockRecorder) Pipelined(ctx, fn any) *gomock.Call

+ func (mr *MockRedisMockRecorder) PubSubChannels(ctx, pattern any) *gomock.Call

+ func (mr *MockRedisMockRecorder) PubSubNumPat(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) PubSubNumSub(ctx any, channels ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) PubSubShardChannels(ctx, pattern any) *gomock.Call

+ func (mr *MockRedisMockRecorder) PubSubShardNumSub(ctx any, channels ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) Publish(ctx, channel, message any) *gomock.Call

+ func (mr *MockRedisMockRecorder) Quit(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) RPop(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) RPopCount(ctx, key, count any) *gomock.Call

+ func (mr *MockRedisMockRecorder) RPopLPush(ctx, source, destination any) *gomock.Call

+ func (mr *MockRedisMockRecorder) RPush(ctx, key any, values ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) RPushX(ctx, key any, values ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) RandomKey(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ReadOnly(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ReadWrite(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) Rename(ctx, key, newkey any) *gomock.Call

+ func (mr *MockRedisMockRecorder) RenameNX(ctx, key, newkey any) *gomock.Call

+ func (mr *MockRedisMockRecorder) Restore(ctx, key, ttl, value any) *gomock.Call

+ func (mr *MockRedisMockRecorder) RestoreReplace(ctx, key, ttl, value any) *gomock.Call

+ func (mr *MockRedisMockRecorder) SAdd(ctx, key any, members ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) SCard(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) SDiff(ctx any, keys ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) SDiffStore(ctx, destination any, keys ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) SInter(ctx any, keys ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) SInterCard(ctx, limit any, keys ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) SInterStore(ctx, destination any, keys ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) SIsMember(ctx, key, member any) *gomock.Call

+ func (mr *MockRedisMockRecorder) SMIsMember(ctx, key any, members ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) SMembers(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) SMembersMap(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) SMove(ctx, source, destination, member any) *gomock.Call

+ func (mr *MockRedisMockRecorder) SPop(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) SPopN(ctx, key, count any) *gomock.Call

+ func (mr *MockRedisMockRecorder) SPublish(ctx, channel, message any) *gomock.Call

+ func (mr *MockRedisMockRecorder) SRandMember(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) SRandMemberN(ctx, key, count any) *gomock.Call

+ func (mr *MockRedisMockRecorder) SRem(ctx, key any, members ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) SScan(ctx, key, cursor, match, count any) *gomock.Call

+ func (mr *MockRedisMockRecorder) SUnion(ctx any, keys ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) SUnionStore(ctx, destination any, keys ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) Save(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) Scan(ctx, cursor, match, count any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ScanType(ctx, cursor, match, count, keyType any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ScriptExists(ctx any, hashes ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ScriptFlush(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ScriptKill(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ScriptLoad(ctx, script any) *gomock.Call

+ func (mr *MockRedisMockRecorder) Set(ctx, key, value, expiration any) *gomock.Call

+ func (mr *MockRedisMockRecorder) SetArgs(ctx, key, value, a any) *gomock.Call

+ func (mr *MockRedisMockRecorder) SetBit(ctx, key, offset, value any) *gomock.Call

+ func (mr *MockRedisMockRecorder) SetEx(ctx, key, value, expiration any) *gomock.Call

+ func (mr *MockRedisMockRecorder) SetNX(ctx, key, value, expiration any) *gomock.Call

+ func (mr *MockRedisMockRecorder) SetRange(ctx, key, offset, value any) *gomock.Call

+ func (mr *MockRedisMockRecorder) SetXX(ctx, key, value, expiration any) *gomock.Call

+ func (mr *MockRedisMockRecorder) Shutdown(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ShutdownNoSave(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ShutdownSave(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) SlaveOf(ctx, host, port any) *gomock.Call

+ func (mr *MockRedisMockRecorder) SlowLogGet(ctx, num any) *gomock.Call

+ func (mr *MockRedisMockRecorder) Sort(ctx, key, sort any) *gomock.Call

+ func (mr *MockRedisMockRecorder) SortInterfaces(ctx, key, sort any) *gomock.Call

+ func (mr *MockRedisMockRecorder) SortRO(ctx, key, sort any) *gomock.Call

+ func (mr *MockRedisMockRecorder) SortStore(ctx, key, store, sort any) *gomock.Call

+ func (mr *MockRedisMockRecorder) StrLen(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TDigestAdd(ctx, key any, elements ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TDigestByRank(ctx, key any, rank ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TDigestByRevRank(ctx, key any, rank ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TDigestCDF(ctx, key any, elements ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TDigestCreate(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TDigestCreateWithCompression(ctx, key, compression any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TDigestInfo(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TDigestMax(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TDigestMerge(ctx, destKey, options any, sourceKeys ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TDigestMin(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TDigestQuantile(ctx, key any, elements ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TDigestRank(ctx, key any, values ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TDigestReset(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TDigestRevRank(ctx, key any, values ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TDigestTrimmedMean(ctx, key, lowCutQuantile, highCutQuantile any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TFCall(ctx, libName, funcName, numKeys any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TFCallASYNC(ctx, libName, funcName, numKeys any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TFCallASYNCArgs(ctx, libName, funcName, numKeys, options any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TFCallArgs(ctx, libName, funcName, numKeys, options any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TFunctionDelete(ctx, libName any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TFunctionList(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TFunctionListArgs(ctx, options any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TFunctionLoad(ctx, lib any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TFunctionLoadArgs(ctx, lib, options any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TSAdd(ctx, key, timestamp, value any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TSAddWithArgs(ctx, key, timestamp, value, options any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TSAlter(ctx, key, options any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TSCreate(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TSCreateRule(ctx, sourceKey, destKey, aggregator, bucketDuration any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TSCreateRuleWithArgs(ctx, sourceKey, destKey, aggregator, bucketDuration, options any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TSCreateWithArgs(ctx, key, options any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TSDecrBy(ctx, Key, timestamp any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TSDecrByWithArgs(ctx, key, timestamp, options any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TSDel(ctx, Key, fromTimestamp, toTimestamp any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TSDeleteRule(ctx, sourceKey, destKey any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TSGet(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TSGetWithArgs(ctx, key, options any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TSIncrBy(ctx, Key, timestamp any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TSIncrByWithArgs(ctx, key, timestamp, options any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TSInfo(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TSInfoWithArgs(ctx, key, options any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TSMAdd(ctx, ktvSlices any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TSMGet(ctx, filters any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TSMGetWithArgs(ctx, filters, options any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TSMRange(ctx, fromTimestamp, toTimestamp, filterExpr any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TSMRangeWithArgs(ctx, fromTimestamp, toTimestamp, filterExpr, options any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TSMRevRange(ctx, fromTimestamp, toTimestamp, filterExpr any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TSMRevRangeWithArgs(ctx, fromTimestamp, toTimestamp, filterExpr, options any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TSQueryIndex(ctx, filterExpr any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TSRange(ctx, key, fromTimestamp, toTimestamp any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TSRangeWithArgs(ctx, key, fromTimestamp, toTimestamp, options any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TSRevRange(ctx, key, fromTimestamp, toTimestamp any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TSRevRangeWithArgs(ctx, key, fromTimestamp, toTimestamp, options any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TTL(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) Time(ctx any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TopKAdd(ctx, key any, elements ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TopKCount(ctx, key any, elements ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TopKIncrBy(ctx, key any, elements ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TopKInfo(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TopKList(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TopKListWithCount(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TopKQuery(ctx, key any, elements ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TopKReserve(ctx, key, k any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TopKReserveWithOptions(ctx, key, k, width, depth, decay any) *gomock.Call

+ func (mr *MockRedisMockRecorder) Touch(ctx any, keys ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) TxPipeline() *gomock.Call

+ func (mr *MockRedisMockRecorder) TxPipelined(ctx, fn any) *gomock.Call

+ func (mr *MockRedisMockRecorder) Type(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) Unlink(ctx any, keys ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) XAck(ctx, stream, group any, ids ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) XAdd(ctx, a any) *gomock.Call

+ func (mr *MockRedisMockRecorder) XAutoClaim(ctx, a any) *gomock.Call

+ func (mr *MockRedisMockRecorder) XAutoClaimJustID(ctx, a any) *gomock.Call

+ func (mr *MockRedisMockRecorder) XClaim(ctx, a any) *gomock.Call

+ func (mr *MockRedisMockRecorder) XClaimJustID(ctx, a any) *gomock.Call

+ func (mr *MockRedisMockRecorder) XDel(ctx, stream any, ids ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) XGroupCreate(ctx, stream, group, start any) *gomock.Call

+ func (mr *MockRedisMockRecorder) XGroupCreateConsumer(ctx, stream, group, consumer any) *gomock.Call

+ func (mr *MockRedisMockRecorder) XGroupCreateMkStream(ctx, stream, group, start any) *gomock.Call

+ func (mr *MockRedisMockRecorder) XGroupDelConsumer(ctx, stream, group, consumer any) *gomock.Call

+ func (mr *MockRedisMockRecorder) XGroupDestroy(ctx, stream, group any) *gomock.Call

+ func (mr *MockRedisMockRecorder) XGroupSetID(ctx, stream, group, start any) *gomock.Call

+ func (mr *MockRedisMockRecorder) XInfoConsumers(ctx, key, group any) *gomock.Call

+ func (mr *MockRedisMockRecorder) XInfoGroups(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) XInfoStream(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) XInfoStreamFull(ctx, key, count any) *gomock.Call

+ func (mr *MockRedisMockRecorder) XLen(ctx, stream any) *gomock.Call

+ func (mr *MockRedisMockRecorder) XPending(ctx, stream, group any) *gomock.Call

+ func (mr *MockRedisMockRecorder) XPendingExt(ctx, a any) *gomock.Call

+ func (mr *MockRedisMockRecorder) XRange(ctx, stream, start, stop any) *gomock.Call

+ func (mr *MockRedisMockRecorder) XRangeN(ctx, stream, start, stop, count any) *gomock.Call

+ func (mr *MockRedisMockRecorder) XRead(ctx, a any) *gomock.Call

+ func (mr *MockRedisMockRecorder) XReadGroup(ctx, a any) *gomock.Call

+ func (mr *MockRedisMockRecorder) XReadStreams(ctx any, streams ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) XRevRange(ctx, stream, start, stop any) *gomock.Call

+ func (mr *MockRedisMockRecorder) XRevRangeN(ctx, stream, start, stop, count any) *gomock.Call

+ func (mr *MockRedisMockRecorder) XTrimMaxLen(ctx, key, maxLen any) *gomock.Call

+ func (mr *MockRedisMockRecorder) XTrimMaxLenApprox(ctx, key, maxLen, limit any) *gomock.Call

+ func (mr *MockRedisMockRecorder) XTrimMinID(ctx, key, minID any) *gomock.Call

+ func (mr *MockRedisMockRecorder) XTrimMinIDApprox(ctx, key, minID, limit any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZAdd(ctx, key any, members ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZAddArgs(ctx, key, args any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZAddArgsIncr(ctx, key, args any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZAddGT(ctx, key any, members ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZAddLT(ctx, key any, members ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZAddNX(ctx, key any, members ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZAddXX(ctx, key any, members ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZCard(ctx, key any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZCount(ctx, key, min, max any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZDiff(ctx any, keys ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZDiffStore(ctx, destination any, keys ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZDiffWithScores(ctx any, keys ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZIncrBy(ctx, key, increment, member any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZInter(ctx, store any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZInterCard(ctx, limit any, keys ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZInterStore(ctx, destination, store any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZInterWithScores(ctx, store any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZLexCount(ctx, key, min, max any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZMPop(ctx, order, count any, keys ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZMScore(ctx, key any, members ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZPopMax(ctx, key any, count ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZPopMin(ctx, key any, count ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZRandMember(ctx, key, count any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZRandMemberWithScores(ctx, key, count any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZRange(ctx, key, start, stop any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZRangeArgs(ctx, z any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZRangeArgsWithScores(ctx, z any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZRangeByLex(ctx, key, opt any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZRangeByScore(ctx, key, opt any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZRangeByScoreWithScores(ctx, key, opt any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZRangeStore(ctx, dst, z any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZRangeWithScores(ctx, key, start, stop any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZRank(ctx, key, member any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZRankWithScore(ctx, key, member any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZRem(ctx, key any, members ...any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZRemRangeByLex(ctx, key, min, max any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZRemRangeByRank(ctx, key, start, stop any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZRemRangeByScore(ctx, key, min, max any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZRevRange(ctx, key, start, stop any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZRevRangeByLex(ctx, key, opt any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZRevRangeByScore(ctx, key, opt any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZRevRangeByScoreWithScores(ctx, key, opt any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZRevRangeWithScores(ctx, key, start, stop any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZRevRank(ctx, key, member any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZRevRankWithScore(ctx, key, member any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZScan(ctx, key, cursor, match, count any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZScore(ctx, key, member any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZUnion(ctx, store any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZUnionStore(ctx, dest, store any) *gomock.Call

+ func (mr *MockRedisMockRecorder) ZUnionWithScores(ctx, store any) *gomock.Call

+ type Mocks struct

+ Redis *MockRedis

+ SQL *MockDB

+ type Redis interface

+ HealthCheck func() datasource.Health

v1.2.1

Mar 27, 2024

v1.2.0

Mar 22, 2024

v1.1.1

Mar 14, 2024

Changes in this version

type Container

+ PubSub pubsub.Client

+ SQL *sql.DB

+ func NewEmptyContainer() *Container

+ func (c *Container) Create(conf config.Config)

+ func (c *Container) GetPublisher() pubsub.Publisher

+ func (c *Container) GetSubscriber() pubsub.Subscriber

v0

v0.3.0

Feb 19, 2024

v0.2.0

Feb 9, 2024

Changes in this version

type Container

+ func (c *Container) GetAppName() string

+ func (c *Container) GetAppVersion() string

+ func (c *Container) Metrics() metrics.Manager

v0.1.0

Jan 22, 2024

Changes in this version

+ type Container struct

+ DB *sql.DB

+ Redis *redis.Redis

+ Services map[string]service.HTTP

+ func NewContainer(conf config.Config) *Container

+ func (c *Container) GetHTTPService(serviceName string) service.HTTP

+ func (c *Container) Health() interface{}

+ type HealthChecker interface

+ HealthCheck func() interface{}

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL