mocks

package
v0.0.13 Latest Latest
Warning

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

 Go to latest Published: Oct 18, 2026 License: MIT Imports: 16 Imported by: 0

Documentation

Overview

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockAPI 

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

MockAPI is a mock of API interface.

func NewMockAPI 

func NewMockAPI(ctrl *gomock.Controller) *MockAPI

NewMockAPI creates a new mock instance.

func (*MockAPI) ChangeMessageVisibility 

func (m *MockAPI) ChangeMessageVisibility(ctx context.Context, in *sqs.ChangeMessageVisibilityInput, optFns ...func(*sqs.Options)) (*sqs.ChangeMessageVisibilityOutput, error)

ChangeMessageVisibility mocks base method.

func (*MockAPI) CreateQueue 

func (m *MockAPI) CreateQueue(ctx context.Context, in *sqs.CreateQueueInput, optFns ...func(*sqs.Options)) (*sqs.CreateQueueOutput, error)

CreateQueue mocks base method.

func (*MockAPI) DeleteMessage 

func (m *MockAPI) DeleteMessage(ctx context.Context, in *sqs.DeleteMessageInput, optFns ...func(*sqs.Options)) (*sqs.DeleteMessageOutput, error)

DeleteMessage mocks base method.

func (*MockAPI) DeleteMessageBatch 

func (m *MockAPI) DeleteMessageBatch(ctx context.Context, in *sqs.DeleteMessageBatchInput, optFns ...func(*sqs.Options)) (*sqs.DeleteMessageBatchOutput, error)

DeleteMessageBatch mocks base method.

func (*MockAPI) EXPECT 

func (m *MockAPI) EXPECT() *MockAPIMockRecorder

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

func (*MockAPI) GetQueueUrl 

func (m *MockAPI) GetQueueUrl(ctx context.Context, in *sqs.GetQueueUrlInput, optFns ...func(*sqs.Options)) (*sqs.GetQueueUrlOutput, error)

GetQueueUrl mocks base method.

func (*MockAPI) ReceiveMessage 

func (m *MockAPI) ReceiveMessage(ctx context.Context, in *sqs.ReceiveMessageInput, optFns ...func(*sqs.Options)) (*sqs.ReceiveMessageOutput, error)

ReceiveMessage mocks base method.

func (*MockAPI) SendMessage 

func (m *MockAPI) SendMessage(ctx context.Context, in *sqs.SendMessageInput, optFns ...func(*sqs.Options)) (*sqs.SendMessageOutput, error)

SendMessage mocks base method.

func (*MockAPI) SendMessageBatch 

func (m *MockAPI) SendMessageBatch(ctx context.Context, in *sqs.SendMessageBatchInput, optFns ...func(*sqs.Options)) (*sqs.SendMessageBatchOutput, error)

SendMessageBatch mocks base method.

type MockAPIMockRecorder 

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

MockAPIMockRecorder is the mock recorder for MockAPI.

func (*MockAPIMockRecorder) ChangeMessageVisibility 

func (mr *MockAPIMockRecorder) ChangeMessageVisibility(ctx, in any, optFns ...any) *gomock.Call

ChangeMessageVisibility indicates an expected call of ChangeMessageVisibility.

func (*MockAPIMockRecorder) CreateQueue 

func (mr *MockAPIMockRecorder) CreateQueue(ctx, in any, optFns ...any) *gomock.Call

CreateQueue indicates an expected call of CreateQueue.

func (*MockAPIMockRecorder) DeleteMessage 

func (mr *MockAPIMockRecorder) DeleteMessage(ctx, in any, optFns ...any) *gomock.Call

DeleteMessage indicates an expected call of DeleteMessage.

func (*MockAPIMockRecorder) DeleteMessageBatch 

func (mr *MockAPIMockRecorder) DeleteMessageBatch(ctx, in any, optFns ...any) *gomock.Call

DeleteMessageBatch indicates an expected call of DeleteMessageBatch.

func (*MockAPIMockRecorder) GetQueueUrl 

func (mr *MockAPIMockRecorder) GetQueueUrl(ctx, in any, optFns ...any) *gomock.Call

GetQueueUrl indicates an expected call of GetQueueUrl.

func (*MockAPIMockRecorder) ReceiveMessage 

func (mr *MockAPIMockRecorder) ReceiveMessage(ctx, in any, optFns ...any) *gomock.Call

ReceiveMessage indicates an expected call of ReceiveMessage.

func (*MockAPIMockRecorder) SendMessage 

func (mr *MockAPIMockRecorder) SendMessage(ctx, in any, optFns ...any) *gomock.Call

SendMessage indicates an expected call of SendMessage.

func (*MockAPIMockRecorder) SendMessageBatch 

func (mr *MockAPIMockRecorder) SendMessageBatch(ctx, in any, optFns ...any) *gomock.Call

SendMessageBatch indicates an expected call of SendMessageBatch.

type MockAnalyticsCompactor 

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

MockAnalyticsCompactor is a mock of AnalyticsCompactor interface.

func NewMockAnalyticsCompactor 

func NewMockAnalyticsCompactor(ctrl *gomock.Controller) *MockAnalyticsCompactor

NewMockAnalyticsCompactor creates a new mock instance.

func (*MockAnalyticsCompactor) Compact 

func (m *MockAnalyticsCompactor) Compact(ctx context.Context, cube string, grain types.Grain, org string, bucket time.Time) error

Compact mocks base method.

func (*MockAnalyticsCompactor) EXPECT 

func (m *MockAnalyticsCompactor) EXPECT() *MockAnalyticsCompactorMockRecorder

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

type MockAnalyticsCompactorMockRecorder 

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

MockAnalyticsCompactorMockRecorder is the mock recorder for MockAnalyticsCompactor.

func (*MockAnalyticsCompactorMockRecorder) Compact 

func (mr *MockAnalyticsCompactorMockRecorder) Compact(ctx, cube, grain, org, bucket any) *gomock.Call

Compact indicates an expected call of Compact.

type MockAnalyticsStore 

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

MockAnalyticsStore is a mock of AnalyticsStore interface.

func NewMockAnalyticsStore 

func NewMockAnalyticsStore(ctrl *gomock.Controller) *MockAnalyticsStore

NewMockAnalyticsStore creates a new mock instance.

func (*MockAnalyticsStore) Aggregate 

func (m *MockAnalyticsStore) Aggregate(ctx context.Context, q types.AggregateQuery) (interfaces.RowStream, error)

Aggregate mocks base method.

func (*MockAnalyticsStore) EXPECT 

func (m *MockAnalyticsStore) EXPECT() *MockAnalyticsStoreMockRecorder

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

func (*MockAnalyticsStore) Liveness added in v0.0.6 

func (m *MockAnalyticsStore) Liveness(ctx context.Context) error

Liveness mocks base method.

func (*MockAnalyticsStore) Readiness added in v0.0.6 

func (m *MockAnalyticsStore) Readiness(ctx context.Context) error

Readiness mocks base method.

func (*MockAnalyticsStore) Start 

func (m *MockAnalyticsStore) Start(ctx context.Context) error

Start mocks base method.

func (*MockAnalyticsStore) Stop 

func (m *MockAnalyticsStore) Stop(ctx context.Context) error

Stop mocks base method.

func (*MockAnalyticsStore) Write 

func (m *MockAnalyticsStore) Write(ctx context.Context, facts []types.Fact) error

Write mocks base method.

type MockAnalyticsStoreMockRecorder 

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

MockAnalyticsStoreMockRecorder is the mock recorder for MockAnalyticsStore.

func (*MockAnalyticsStoreMockRecorder) Aggregate 

func (mr *MockAnalyticsStoreMockRecorder) Aggregate(ctx, q any) *gomock.Call

Aggregate indicates an expected call of Aggregate.

func (*MockAnalyticsStoreMockRecorder) Liveness added in v0.0.6 

func (mr *MockAnalyticsStoreMockRecorder) Liveness(ctx any) *gomock.Call

Liveness indicates an expected call of Liveness.

func (*MockAnalyticsStoreMockRecorder) Readiness added in v0.0.6 

func (mr *MockAnalyticsStoreMockRecorder) Readiness(ctx any) *gomock.Call

Readiness indicates an expected call of Readiness.

func (*MockAnalyticsStoreMockRecorder) Start 

func (mr *MockAnalyticsStoreMockRecorder) Start(ctx any) *gomock.Call

Start indicates an expected call of Start.

func (*MockAnalyticsStoreMockRecorder) Stop 

func (mr *MockAnalyticsStoreMockRecorder) Stop(ctx any) *gomock.Call

Stop indicates an expected call of Stop.

func (*MockAnalyticsStoreMockRecorder) Write 

func (mr *MockAnalyticsStoreMockRecorder) Write(ctx, facts any) *gomock.Call

Write indicates an expected call of Write.

type MockAnyJob 

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

MockAnyJob is a mock of AnyJob interface.

func NewMockAnyJob 

func NewMockAnyJob(ctrl *gomock.Controller) *MockAnyJob

NewMockAnyJob creates a new mock instance.

func (*MockAnyJob) EXPECT 

func (m *MockAnyJob) EXPECT() *MockAnyJobMockRecorder

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

func (*MockAnyJob) Execute 

func (m *MockAnyJob) Execute(ctx context.Context, runner interfaces.CommandRunner, root string) (types.StepResults, error)

Execute mocks base method.

func (*MockAnyJob) Meta 

func (m *MockAnyJob) Meta() types.JobMeta

Meta mocks base method.

type MockAnyJobMockRecorder 

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

MockAnyJobMockRecorder is the mock recorder for MockAnyJob.

func (*MockAnyJobMockRecorder) Execute 

func (mr *MockAnyJobMockRecorder) Execute(ctx, runner, root any) *gomock.Call

Execute indicates an expected call of Execute.

func (*MockAnyJobMockRecorder) Meta 

func (mr *MockAnyJobMockRecorder) Meta() *gomock.Call

Meta indicates an expected call of Meta.

type MockAssumeRoleAPIClient 

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

MockAssumeRoleAPIClient is a mock of AssumeRoleAPIClient interface.

func NewMockAssumeRoleAPIClient 

func NewMockAssumeRoleAPIClient(ctrl *gomock.Controller) *MockAssumeRoleAPIClient

NewMockAssumeRoleAPIClient creates a new mock instance.

func (*MockAssumeRoleAPIClient) AssumeRole 

func (m *MockAssumeRoleAPIClient) AssumeRole(ctx context.Context, params *sts.AssumeRoleInput, optFns ...func(*sts.Options)) (*sts.AssumeRoleOutput, error)

AssumeRole mocks base method.

func (*MockAssumeRoleAPIClient) EXPECT 

func (m *MockAssumeRoleAPIClient) EXPECT() *MockAssumeRoleAPIClientMockRecorder

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

type MockAssumeRoleAPIClientMockRecorder 

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

MockAssumeRoleAPIClientMockRecorder is the mock recorder for MockAssumeRoleAPIClient.

func (*MockAssumeRoleAPIClientMockRecorder) AssumeRole 

func (mr *MockAssumeRoleAPIClientMockRecorder) AssumeRole(ctx, params any, optFns ...any) *gomock.Call

AssumeRole indicates an expected call of AssumeRole.

type MockBulkhead 

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

MockBulkhead is a mock of Bulkhead interface.

func NewMockBulkhead 

func NewMockBulkhead(ctrl *gomock.Controller) *MockBulkhead

NewMockBulkhead creates a new mock instance.

func (*MockBulkhead) EXPECT 

func (m *MockBulkhead) EXPECT() *MockBulkheadMockRecorder

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

func (*MockBulkhead) Execute 

func (m *MockBulkhead) Execute(ctx context.Context, fn func() error) error

Execute mocks base method.

func (*MockBulkhead) TryExecute 

func (m *MockBulkhead) TryExecute(fn func() error) error

TryExecute mocks base method.

type MockBulkheadMockRecorder 

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

MockBulkheadMockRecorder is the mock recorder for MockBulkhead.

func (*MockBulkheadMockRecorder) Execute 

func (mr *MockBulkheadMockRecorder) Execute(ctx, fn any) *gomock.Call

Execute indicates an expected call of Execute.

func (*MockBulkheadMockRecorder) TryExecute 

func (mr *MockBulkheadMockRecorder) TryExecute(fn any) *gomock.Call

TryExecute indicates an expected call of TryExecute.

type MockByteCache 

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

MockByteCache is a mock of ByteCache interface.

func NewMockByteCache 

func NewMockByteCache(ctrl *gomock.Controller) *MockByteCache

NewMockByteCache creates a new mock instance.

func (*MockByteCache) Delete 

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

Delete mocks base method.

func (*MockByteCache) EXPECT 

func (m *MockByteCache) EXPECT() *MockByteCacheMockRecorder

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

func (*MockByteCache) Get 

func (m *MockByteCache) Get(ctx context.Context, key string) ([]byte, bool)

Get mocks base method.

func (*MockByteCache) Set 

func (m *MockByteCache) Set(ctx context.Context, key string, value []byte, ttl time.Duration)

Set mocks base method.

type MockByteCacheMockRecorder 

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

MockByteCacheMockRecorder is the mock recorder for MockByteCache.

func (*MockByteCacheMockRecorder) Delete 

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

Delete indicates an expected call of Delete.

func (*MockByteCacheMockRecorder) Get 

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

Get indicates an expected call of Get.

func (*MockByteCacheMockRecorder) Set 

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

Set indicates an expected call of Set.

type MockCQLBatch added in v0.0.7 

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

MockCQLBatch is a mock of CQLBatch interface.

func NewMockCQLBatch added in v0.0.7 

func NewMockCQLBatch(ctrl *gomock.Controller) *MockCQLBatch

NewMockCQLBatch creates a new mock instance.

func (*MockCQLBatch) EXPECT added in v0.0.7 

func (m *MockCQLBatch) EXPECT() *MockCQLBatchMockRecorder

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

func (*MockCQLBatch) Query added in v0.0.7 

func (m *MockCQLBatch) Query(stmt string, values ...any)

Query mocks base method.

func (*MockCQLBatch) Size added in v0.0.7 

func (m *MockCQLBatch) Size() int

Size mocks base method.

func (*MockCQLBatch) WithContext added in v0.0.7 

func (m *MockCQLBatch) WithContext(ctx context.Context) interfaces.CQLBatch

WithContext mocks base method.

type MockCQLBatchMockRecorder added in v0.0.7 

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

MockCQLBatchMockRecorder is the mock recorder for MockCQLBatch.

func (*MockCQLBatchMockRecorder) Query added in v0.0.7 

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

Query indicates an expected call of Query.

func (*MockCQLBatchMockRecorder) Size added in v0.0.7 

func (mr *MockCQLBatchMockRecorder) Size() *gomock.Call

Size indicates an expected call of Size.

func (*MockCQLBatchMockRecorder) WithContext added in v0.0.7 

func (mr *MockCQLBatchMockRecorder) WithContext(ctx any) *gomock.Call

WithContext indicates an expected call of WithContext.

type MockCQLIter added in v0.0.7 

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

MockCQLIter is a mock of CQLIter interface.

func NewMockCQLIter added in v0.0.7 

func NewMockCQLIter(ctrl *gomock.Controller) *MockCQLIter

NewMockCQLIter creates a new mock instance.

func (*MockCQLIter) Close added in v0.0.7 

func (m *MockCQLIter) Close() error

Close mocks base method.

func (*MockCQLIter) EXPECT added in v0.0.7 

func (m *MockCQLIter) EXPECT() *MockCQLIterMockRecorder

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

func (*MockCQLIter) PageState added in v0.0.7 

func (m *MockCQLIter) PageState() []byte

PageState mocks base method.

func (*MockCQLIter) Scan added in v0.0.7 

func (m *MockCQLIter) Scan(dest ...any) bool

Scan mocks base method.

type MockCQLIterMockRecorder added in v0.0.7 

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

MockCQLIterMockRecorder is the mock recorder for MockCQLIter.

func (*MockCQLIterMockRecorder) Close added in v0.0.7 

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

Close indicates an expected call of Close.

func (*MockCQLIterMockRecorder) PageState added in v0.0.7 

func (mr *MockCQLIterMockRecorder) PageState() *gomock.Call

PageState indicates an expected call of PageState.

func (*MockCQLIterMockRecorder) Scan added in v0.0.7 

func (mr *MockCQLIterMockRecorder) Scan(dest ...any) *gomock.Call

Scan indicates an expected call of Scan.

type MockCQLQuery added in v0.0.7 

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

MockCQLQuery is a mock of CQLQuery interface.

func NewMockCQLQuery added in v0.0.7 

func NewMockCQLQuery(ctrl *gomock.Controller) *MockCQLQuery

NewMockCQLQuery creates a new mock instance.

func (*MockCQLQuery) EXPECT added in v0.0.7 

func (m *MockCQLQuery) EXPECT() *MockCQLQueryMockRecorder

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

func (*MockCQLQuery) Exec added in v0.0.7 

func (m *MockCQLQuery) Exec() error

Exec mocks base method.

func (*MockCQLQuery) Idempotent added in v0.0.7 

func (m *MockCQLQuery) Idempotent(idempotent bool) interfaces.CQLQuery

Idempotent mocks base method.

func (*MockCQLQuery) Iter added in v0.0.7 

func (m *MockCQLQuery) Iter() interfaces.CQLIter

Iter mocks base method.

func (*MockCQLQuery) PageSize added in v0.0.7 

func (m *MockCQLQuery) PageSize(n int) interfaces.CQLQuery

PageSize mocks base method.

func (*MockCQLQuery) PageState added in v0.0.7 

func (m *MockCQLQuery) PageState(state []byte) interfaces.CQLQuery

PageState mocks base method.

func (*MockCQLQuery) WithContext added in v0.0.7 

func (m *MockCQLQuery) WithContext(ctx context.Context) interfaces.CQLQuery

WithContext mocks base method.

type MockCQLQueryMockRecorder added in v0.0.7 

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

MockCQLQueryMockRecorder is the mock recorder for MockCQLQuery.

func (*MockCQLQueryMockRecorder) Exec added in v0.0.7 

func (mr *MockCQLQueryMockRecorder) Exec() *gomock.Call

Exec indicates an expected call of Exec.

func (*MockCQLQueryMockRecorder) Idempotent added in v0.0.7 

func (mr *MockCQLQueryMockRecorder) Idempotent(idempotent any) *gomock.Call

Idempotent indicates an expected call of Idempotent.

func (*MockCQLQueryMockRecorder) Iter added in v0.0.7 

func (mr *MockCQLQueryMockRecorder) Iter() *gomock.Call

Iter indicates an expected call of Iter.

func (*MockCQLQueryMockRecorder) PageSize added in v0.0.7 

func (mr *MockCQLQueryMockRecorder) PageSize(n any) *gomock.Call

PageSize indicates an expected call of PageSize.

func (*MockCQLQueryMockRecorder) PageState added in v0.0.7 

func (mr *MockCQLQueryMockRecorder) PageState(state any) *gomock.Call

PageState indicates an expected call of PageState.

func (*MockCQLQueryMockRecorder) WithContext added in v0.0.7 

func (mr *MockCQLQueryMockRecorder) WithContext(ctx any) *gomock.Call

WithContext indicates an expected call of WithContext.

type MockCQLSession added in v0.0.7 

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

MockCQLSession is a mock of CQLSession interface.

func NewMockCQLSession added in v0.0.7 

func NewMockCQLSession(ctrl *gomock.Controller) *MockCQLSession

NewMockCQLSession creates a new mock instance.

func (*MockCQLSession) Batch added in v0.0.7 

func (m *MockCQLSession) Batch(kind interfaces.CQLBatchKind) interfaces.CQLBatch

Batch mocks base method.

func (*MockCQLSession) Close added in v0.0.7 

func (m *MockCQLSession) Close()

Close mocks base method.

func (*MockCQLSession) EXPECT added in v0.0.7 

func (m *MockCQLSession) EXPECT() *MockCQLSessionMockRecorder

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

func (*MockCQLSession) ExecuteBatch added in v0.0.7 

func (m *MockCQLSession) ExecuteBatch(b interfaces.CQLBatch) error

ExecuteBatch mocks base method.

func (*MockCQLSession) Query added in v0.0.7 

func (m *MockCQLSession) Query(stmt string, values ...any) interfaces.CQLQuery

Query mocks base method.

type MockCQLSessionMockRecorder added in v0.0.7 

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

MockCQLSessionMockRecorder is the mock recorder for MockCQLSession.

func (*MockCQLSessionMockRecorder) Batch added in v0.0.7 

func (mr *MockCQLSessionMockRecorder) Batch(kind any) *gomock.Call

Batch indicates an expected call of Batch.

func (*MockCQLSessionMockRecorder) Close added in v0.0.7 

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

Close indicates an expected call of Close.

func (*MockCQLSessionMockRecorder) ExecuteBatch added in v0.0.7 

func (mr *MockCQLSessionMockRecorder) ExecuteBatch(b any) *gomock.Call

ExecuteBatch indicates an expected call of ExecuteBatch.

func (*MockCQLSessionMockRecorder) Query added in v0.0.7 

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

Query indicates an expected call of Query.

type MockCRUDNoListRepository added in v0.0.7 

type MockCRUDNoListRepository[T any, ID comparable] struct {
	// contains filtered or unexported fields
}

MockCRUDNoListRepository is a mock of CRUDNoListRepository interface.

func NewMockCRUDNoListRepository added in v0.0.7 

func NewMockCRUDNoListRepository[T any, ID comparable](ctrl *gomock.Controller) *MockCRUDNoListRepository[T, ID]

NewMockCRUDNoListRepository creates a new mock instance.

func (*MockCRUDNoListRepository[T, ID]) Create added in v0.0.7 

func (m *MockCRUDNoListRepository[T, ID]) Create(ctx context.Context, in *T) (*T, error)

Create mocks base method.

func (*MockCRUDNoListRepository[T, ID]) Delete added in v0.0.7 

func (m *MockCRUDNoListRepository[T, ID]) Delete(ctx context.Context, id ID) error

Delete mocks base method.

func (*MockCRUDNoListRepository[T, ID]) EXPECT added in v0.0.7 

func (m *MockCRUDNoListRepository[T, ID]) EXPECT() *MockCRUDNoListRepositoryMockRecorder[T, ID]

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

func (*MockCRUDNoListRepository[T, ID]) Get added in v0.0.7 

func (m *MockCRUDNoListRepository[T, ID]) Get(ctx context.Context, id ID) (*T, error)

Get mocks base method.

func (*MockCRUDNoListRepository[T, ID]) Update added in v0.0.7 

func (m *MockCRUDNoListRepository[T, ID]) Update(ctx context.Context, id ID, in *T) (*T, error)

Update mocks base method.

type MockCRUDNoListRepositoryMockRecorder added in v0.0.7 

type MockCRUDNoListRepositoryMockRecorder[T any, ID comparable] struct {
	// contains filtered or unexported fields
}

MockCRUDNoListRepositoryMockRecorder is the mock recorder for MockCRUDNoListRepository.

func (*MockCRUDNoListRepositoryMockRecorder[T, ID]) Create added in v0.0.7 

func (mr *MockCRUDNoListRepositoryMockRecorder[T, ID]) Create(ctx, in any) *gomock.Call

Create indicates an expected call of Create.

func (*MockCRUDNoListRepositoryMockRecorder[T, ID]) Delete added in v0.0.7 

func (mr *MockCRUDNoListRepositoryMockRecorder[T, ID]) Delete(ctx, id any) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockCRUDNoListRepositoryMockRecorder[T, ID]) Get added in v0.0.7 

func (mr *MockCRUDNoListRepositoryMockRecorder[T, ID]) Get(ctx, id any) *gomock.Call

Get indicates an expected call of Get.

func (*MockCRUDNoListRepositoryMockRecorder[T, ID]) Update added in v0.0.7 

func (mr *MockCRUDNoListRepositoryMockRecorder[T, ID]) Update(ctx, id, in any) *gomock.Call

Update indicates an expected call of Update.

type MockCRUDNoListStore added in v0.0.7 

type MockCRUDNoListStore[T any, ID comparable] struct {
	// contains filtered or unexported fields
}

MockCRUDNoListStore is a mock of CRUDNoListStore interface.

func NewMockCRUDNoListStore added in v0.0.7 

func NewMockCRUDNoListStore[T any, ID comparable](ctrl *gomock.Controller) *MockCRUDNoListStore[T, ID]

NewMockCRUDNoListStore creates a new mock instance.

func (*MockCRUDNoListStore[T, ID]) Create added in v0.0.7 

func (m *MockCRUDNoListStore[T, ID]) Create(ctx context.Context, in *T) (*T, error)

Create mocks base method.

func (*MockCRUDNoListStore[T, ID]) Delete added in v0.0.7 

func (m *MockCRUDNoListStore[T, ID]) Delete(ctx context.Context, id ID) error

Delete mocks base method.

func (*MockCRUDNoListStore[T, ID]) EXPECT added in v0.0.7 

func (m *MockCRUDNoListStore[T, ID]) EXPECT() *MockCRUDNoListStoreMockRecorder[T, ID]

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

func (*MockCRUDNoListStore[T, ID]) Exists added in v0.0.7 

func (m *MockCRUDNoListStore[T, ID]) Exists(ctx context.Context, id ID) (bool, error)

Exists mocks base method.

func (*MockCRUDNoListStore[T, ID]) Get added in v0.0.7 

func (m *MockCRUDNoListStore[T, ID]) Get(ctx context.Context, id ID) (*T, error)

Get mocks base method.

func (*MockCRUDNoListStore[T, ID]) Update added in v0.0.7 

func (m *MockCRUDNoListStore[T, ID]) Update(ctx context.Context, id ID, in *T) (*T, error)

Update mocks base method.

type MockCRUDNoListStoreMockRecorder added in v0.0.7 

type MockCRUDNoListStoreMockRecorder[T any, ID comparable] struct {
	// contains filtered or unexported fields
}

MockCRUDNoListStoreMockRecorder is the mock recorder for MockCRUDNoListStore.

func (*MockCRUDNoListStoreMockRecorder[T, ID]) Create added in v0.0.7 

func (mr *MockCRUDNoListStoreMockRecorder[T, ID]) Create(ctx, in any) *gomock.Call

Create indicates an expected call of Create.

func (*MockCRUDNoListStoreMockRecorder[T, ID]) Delete added in v0.0.7 

func (mr *MockCRUDNoListStoreMockRecorder[T, ID]) Delete(ctx, id any) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockCRUDNoListStoreMockRecorder[T, ID]) Exists added in v0.0.7 

func (mr *MockCRUDNoListStoreMockRecorder[T, ID]) Exists(ctx, id any) *gomock.Call

Exists indicates an expected call of Exists.

func (*MockCRUDNoListStoreMockRecorder[T, ID]) Get added in v0.0.7 

func (mr *MockCRUDNoListStoreMockRecorder[T, ID]) Get(ctx, id any) *gomock.Call

Get indicates an expected call of Get.

func (*MockCRUDNoListStoreMockRecorder[T, ID]) Update added in v0.0.7 

func (mr *MockCRUDNoListStoreMockRecorder[T, ID]) Update(ctx, id, in any) *gomock.Call

Update indicates an expected call of Update.

type MockCacheInvalidator added in v0.0.4 

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

MockCacheInvalidator is a mock of CacheInvalidator interface.

func NewMockCacheInvalidator added in v0.0.4 

func NewMockCacheInvalidator(ctrl *gomock.Controller) *MockCacheInvalidator

NewMockCacheInvalidator creates a new mock instance.

func (*MockCacheInvalidator) EXPECT added in v0.0.4 

func (m *MockCacheInvalidator) EXPECT() *MockCacheInvalidatorMockRecorder

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

func (*MockCacheInvalidator) InvalidateAll added in v0.0.4 

func (m *MockCacheInvalidator) InvalidateAll(ctx context.Context) error

InvalidateAll mocks base method.

func (*MockCacheInvalidator) InvalidatePrefix added in v0.0.4 

func (m *MockCacheInvalidator) InvalidatePrefix(ctx context.Context, prefix string) error

InvalidatePrefix mocks base method.

type MockCacheInvalidatorMockRecorder added in v0.0.4 

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

MockCacheInvalidatorMockRecorder is the mock recorder for MockCacheInvalidator.

func (*MockCacheInvalidatorMockRecorder) InvalidateAll added in v0.0.4 

func (mr *MockCacheInvalidatorMockRecorder) InvalidateAll(ctx any) *gomock.Call

InvalidateAll indicates an expected call of InvalidateAll.

func (*MockCacheInvalidatorMockRecorder) InvalidatePrefix added in v0.0.4 

func (mr *MockCacheInvalidatorMockRecorder) InvalidatePrefix(ctx, prefix any) *gomock.Call

InvalidatePrefix indicates an expected call of InvalidatePrefix.

type MockCircuitBreaker 

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

MockCircuitBreaker is a mock of CircuitBreaker interface.

func NewMockCircuitBreaker 

func NewMockCircuitBreaker(ctrl *gomock.Controller) *MockCircuitBreaker

NewMockCircuitBreaker creates a new mock instance.

func (*MockCircuitBreaker) EXPECT 

func (m *MockCircuitBreaker) EXPECT() *MockCircuitBreakerMockRecorder

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

func (*MockCircuitBreaker) Execute 

func (m *MockCircuitBreaker) Execute(fn func() error) error

Execute mocks base method.

type MockCircuitBreakerMockRecorder 

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

MockCircuitBreakerMockRecorder is the mock recorder for MockCircuitBreaker.

func (*MockCircuitBreakerMockRecorder) Execute 

func (mr *MockCircuitBreakerMockRecorder) Execute(fn any) *gomock.Call

Execute indicates an expected call of Execute.

type MockClientStream 

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

MockClientStream is a mock of ClientStream interface.

func NewMockClientStream 

func NewMockClientStream(ctrl *gomock.Controller) *MockClientStream

NewMockClientStream creates a new mock instance.

func (*MockClientStream) CloseSend 

func (m *MockClientStream) CloseSend() error

CloseSend mocks base method.

func (*MockClientStream) Context 

func (m *MockClientStream) Context() context.Context

Context mocks base method.

func (*MockClientStream) EXPECT 

func (m *MockClientStream) EXPECT() *MockClientStreamMockRecorder

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

func (*MockClientStream) Header 

func (m *MockClientStream) Header() (metadata.MD, error)

Header mocks base method.

func (*MockClientStream) RecvMsg 

func (m_2 *MockClientStream) RecvMsg(m any) error

RecvMsg mocks base method.

func (*MockClientStream) SendMsg 

func (m_2 *MockClientStream) SendMsg(m any) error

SendMsg mocks base method.

func (*MockClientStream) Trailer 

func (m *MockClientStream) Trailer() metadata.MD

Trailer mocks base method.

type MockClientStreamMockRecorder 

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

MockClientStreamMockRecorder is the mock recorder for MockClientStream.

func (*MockClientStreamMockRecorder) CloseSend 

func (mr *MockClientStreamMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend.

func (*MockClientStreamMockRecorder) Context 

func (mr *MockClientStreamMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockClientStreamMockRecorder) Header 

func (mr *MockClientStreamMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header.

func (*MockClientStreamMockRecorder) RecvMsg 

func (mr *MockClientStreamMockRecorder) RecvMsg(m any) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockClientStreamMockRecorder) SendMsg 

func (mr *MockClientStreamMockRecorder) SendMsg(m any) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockClientStreamMockRecorder) Trailer 

func (mr *MockClientStreamMockRecorder) Trailer() *gomock.Call

Trailer indicates an expected call of Trailer.

type MockCmdHook 

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

MockCmdHook is a mock of CmdHook interface.

func NewMockCmdHook 

func NewMockCmdHook(ctrl *gomock.Controller) *MockCmdHook

NewMockCmdHook creates a new mock instance.

func (*MockCmdHook) EXPECT 

func (m *MockCmdHook) EXPECT() *MockCmdHookMockRecorder

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

func (*MockCmdHook) OnFailure 

func (m *MockCmdHook) OnFailure(cmdStr string)

OnFailure mocks base method.

func (*MockCmdHook) OnStart 

func (m *MockCmdHook) OnStart(cmdStr string)

OnStart mocks base method.

func (*MockCmdHook) OnSuccess 

func (m *MockCmdHook) OnSuccess(cmdStr string)

OnSuccess mocks base method.

type MockCmdHookMockRecorder 

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

MockCmdHookMockRecorder is the mock recorder for MockCmdHook.

func (*MockCmdHookMockRecorder) OnFailure 

func (mr *MockCmdHookMockRecorder) OnFailure(cmdStr any) *gomock.Call

OnFailure indicates an expected call of OnFailure.

func (*MockCmdHookMockRecorder) OnStart 

func (mr *MockCmdHookMockRecorder) OnStart(cmdStr any) *gomock.Call

OnStart indicates an expected call of OnStart.

func (*MockCmdHookMockRecorder) OnSuccess 

func (mr *MockCmdHookMockRecorder) OnSuccess(cmdStr any) *gomock.Call

OnSuccess indicates an expected call of OnSuccess.

type MockCommandRunner 

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

MockCommandRunner is a mock of CommandRunner interface.

func NewMockCommandRunner 

func NewMockCommandRunner(ctrl *gomock.Controller) *MockCommandRunner

NewMockCommandRunner creates a new mock instance.

func (*MockCommandRunner) EXPECT 

func (m *MockCommandRunner) EXPECT() *MockCommandRunnerMockRecorder

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

func (*MockCommandRunner) Exists 

func (m *MockCommandRunner) Exists(name string) bool

Exists mocks base method.

func (*MockCommandRunner) RequireTool 

func (m *MockCommandRunner) RequireTool(name, installHint string) error

RequireTool mocks base method.

func (*MockCommandRunner) Run 

func (m *MockCommandRunner) Run(ctx context.Context, dir, name string, args ...string) error

Run mocks base method.

func (*MockCommandRunner) RunBuffered 

func (m *MockCommandRunner) RunBuffered(ctx context.Context, dir, name string, args ...string) interfaces.CmdResult

RunBuffered mocks base method.

func (*MockCommandRunner) RunBufferedWithEnv 

func (m *MockCommandRunner) RunBufferedWithEnv(ctx context.Context, dir string, extraEnv []string, name string, args ...string) interfaces.CmdResult

RunBufferedWithEnv mocks base method.

func (*MockCommandRunner) RunWithEnv 

func (m *MockCommandRunner) RunWithEnv(ctx context.Context, dir string, extraEnv []string, name string, args ...string) error

RunWithEnv mocks base method.

type MockCommandRunnerMockRecorder 

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

MockCommandRunnerMockRecorder is the mock recorder for MockCommandRunner.

func (*MockCommandRunnerMockRecorder) Exists 

func (mr *MockCommandRunnerMockRecorder) Exists(name any) *gomock.Call

Exists indicates an expected call of Exists.

func (*MockCommandRunnerMockRecorder) RequireTool 

func (mr *MockCommandRunnerMockRecorder) RequireTool(name, installHint any) *gomock.Call

RequireTool indicates an expected call of RequireTool.

func (*MockCommandRunnerMockRecorder) Run 

func (mr *MockCommandRunnerMockRecorder) Run(ctx, dir, name any, args ...any) *gomock.Call

Run indicates an expected call of Run.

func (*MockCommandRunnerMockRecorder) RunBuffered 

func (mr *MockCommandRunnerMockRecorder) RunBuffered(ctx, dir, name any, args ...any) *gomock.Call

RunBuffered indicates an expected call of RunBuffered.

func (*MockCommandRunnerMockRecorder) RunBufferedWithEnv 

func (mr *MockCommandRunnerMockRecorder) RunBufferedWithEnv(ctx, dir, extraEnv, name any, args ...any) *gomock.Call

RunBufferedWithEnv indicates an expected call of RunBufferedWithEnv.

func (*MockCommandRunnerMockRecorder) RunWithEnv 

func (mr *MockCommandRunnerMockRecorder) RunWithEnv(ctx, dir, extraEnv, name any, args ...any) *gomock.Call

RunWithEnv indicates an expected call of RunWithEnv.

type MockConfigLoader 

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

MockConfigLoader is a mock of ConfigLoader interface.

func NewMockConfigLoader 

func NewMockConfigLoader(ctrl *gomock.Controller) *MockConfigLoader

NewMockConfigLoader creates a new mock instance.

func (*MockConfigLoader) EXPECT 

func (m *MockConfigLoader) EXPECT() *MockConfigLoaderMockRecorder

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

func (*MockConfigLoader) Get 

func (m *MockConfigLoader) Get(key string) any

Get mocks base method.

func (*MockConfigLoader) GetBool 

func (m *MockConfigLoader) GetBool(key string) bool

GetBool mocks base method.

func (*MockConfigLoader) GetInt 

func (m *MockConfigLoader) GetInt(key string) int

GetInt mocks base method.

func (*MockConfigLoader) GetString 

func (m *MockConfigLoader) GetString(key string) string

GetString mocks base method.

func (*MockConfigLoader) Unmarshal 

func (m *MockConfigLoader) Unmarshal(target any) error

Unmarshal mocks base method.

func (*MockConfigLoader) UnmarshalKey 

func (m *MockConfigLoader) UnmarshalKey(key string, target any) error

UnmarshalKey mocks base method.

type MockConfigLoaderMockRecorder 

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

MockConfigLoaderMockRecorder is the mock recorder for MockConfigLoader.

func (*MockConfigLoaderMockRecorder) Get 

func (mr *MockConfigLoaderMockRecorder) Get(key any) *gomock.Call

Get indicates an expected call of Get.

func (*MockConfigLoaderMockRecorder) GetBool 

func (mr *MockConfigLoaderMockRecorder) GetBool(key any) *gomock.Call

GetBool indicates an expected call of GetBool.

func (*MockConfigLoaderMockRecorder) GetInt 

func (mr *MockConfigLoaderMockRecorder) GetInt(key any) *gomock.Call

GetInt indicates an expected call of GetInt.

func (*MockConfigLoaderMockRecorder) GetString 

func (mr *MockConfigLoaderMockRecorder) GetString(key any) *gomock.Call

GetString indicates an expected call of GetString.

func (*MockConfigLoaderMockRecorder) Unmarshal 

func (mr *MockConfigLoaderMockRecorder) Unmarshal(target any) *gomock.Call

Unmarshal indicates an expected call of Unmarshal.

func (*MockConfigLoaderMockRecorder) UnmarshalKey 

func (mr *MockConfigLoaderMockRecorder) UnmarshalKey(key, target any) *gomock.Call

UnmarshalKey indicates an expected call of UnmarshalKey.

type MockConnectorSource 

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

MockConnectorSource is a mock of ConnectorSource interface.

func NewMockConnectorSource 

func NewMockConnectorSource(ctrl *gomock.Controller) *MockConnectorSource

NewMockConnectorSource creates a new mock instance.

func (*MockConnectorSource) EXPECT 

func (m *MockConnectorSource) EXPECT() *MockConnectorSourceMockRecorder

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

func (*MockConnectorSource) ListPage 

func (m *MockConnectorSource) ListPage(ctx context.Context, continuationToken string, limit int) ([]interfaces.StorageObject, string, error)

ListPage mocks base method.

func (*MockConnectorSource) TestConnection 

func (m *MockConnectorSource) TestConnection(ctx context.Context) (int, error)

TestConnection mocks base method.

type MockConnectorSourceMockRecorder 

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

MockConnectorSourceMockRecorder is the mock recorder for MockConnectorSource.

func (*MockConnectorSourceMockRecorder) ListPage 

func (mr *MockConnectorSourceMockRecorder) ListPage(ctx, continuationToken, limit any) *gomock.Call

ListPage indicates an expected call of ListPage.

func (*MockConnectorSourceMockRecorder) TestConnection 

func (mr *MockConnectorSourceMockRecorder) TestConnection(ctx any) *gomock.Call

TestConnection indicates an expected call of TestConnection.

type MockCounter 

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

MockCounter is a mock of Counter interface.

func NewMockCounter 

func NewMockCounter(ctrl *gomock.Controller) *MockCounter

NewMockCounter creates a new mock instance.

func (*MockCounter) Add 

func (m *MockCounter) Add(value float64, labelValues ...string)

Add mocks base method.

func (*MockCounter) EXPECT 

func (m *MockCounter) EXPECT() *MockCounterMockRecorder

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

func (*MockCounter) Inc 

func (m *MockCounter) Inc(labelValues ...string)

Inc mocks base method.

type MockCounterMockRecorder 

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

MockCounterMockRecorder is the mock recorder for MockCounter.

func (*MockCounterMockRecorder) Add 

func (mr *MockCounterMockRecorder) Add(value any, labelValues ...any) *gomock.Call

Add indicates an expected call of Add.

func (*MockCounterMockRecorder) Inc 

func (mr *MockCounterMockRecorder) Inc(labelValues ...any) *gomock.Call

Inc indicates an expected call of Inc.

type MockCountingPublisher added in v0.0.4 

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

MockCountingPublisher is a mock of CountingPublisher interface.

func NewMockCountingPublisher added in v0.0.4 

func NewMockCountingPublisher(ctrl *gomock.Controller) *MockCountingPublisher

NewMockCountingPublisher creates a new mock instance.

func (*MockCountingPublisher) EXPECT added in v0.0.4 

func (m *MockCountingPublisher) EXPECT() *MockCountingPublisherMockRecorder

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

func (*MockCountingPublisher) Publish added in v0.0.4 

func (m *MockCountingPublisher) Publish(ctx context.Context, topic string, payload []byte) error

Publish mocks base method.

func (*MockCountingPublisher) PublishBatch added in v0.0.4 

func (m *MockCountingPublisher) PublishBatch(ctx context.Context, topic string, payloads [][]byte) error

PublishBatch mocks base method.

func (*MockCountingPublisher) PublishCount added in v0.0.4 

func (m *MockCountingPublisher) PublishCount(ctx context.Context, topic string, payload []byte) (int, error)

PublishCount mocks base method.

type MockCountingPublisherMockRecorder added in v0.0.4 

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

MockCountingPublisherMockRecorder is the mock recorder for MockCountingPublisher.

func (*MockCountingPublisherMockRecorder) Publish added in v0.0.4 

func (mr *MockCountingPublisherMockRecorder) Publish(ctx, topic, payload any) *gomock.Call

Publish indicates an expected call of Publish.

func (*MockCountingPublisherMockRecorder) PublishBatch added in v0.0.4 

func (mr *MockCountingPublisherMockRecorder) PublishBatch(ctx, topic, payloads any) *gomock.Call

PublishBatch indicates an expected call of PublishBatch.

func (*MockCountingPublisherMockRecorder) PublishCount added in v0.0.4 

func (mr *MockCountingPublisherMockRecorder) PublishCount(ctx, topic, payload any) *gomock.Call

PublishCount indicates an expected call of PublishCount.

type MockCreator added in v0.0.11 

type MockCreator[T any, C any] struct {
	// contains filtered or unexported fields
}

MockCreator is a mock of Creator interface.

func NewMockCreator added in v0.0.11 

func NewMockCreator[T any, C any](ctrl *gomock.Controller) *MockCreator[T, C]

NewMockCreator creates a new mock instance.

func (*MockCreator[T, C]) Create added in v0.0.11 

func (m *MockCreator[T, C]) Create(ctx context.Context, in C) (*T, error)

Create mocks base method.

func (*MockCreator[T, C]) EXPECT added in v0.0.11 

func (m *MockCreator[T, C]) EXPECT() *MockCreatorMockRecorder[T, C]

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

type MockCreatorMockRecorder added in v0.0.11 

type MockCreatorMockRecorder[T any, C any] struct {
	// contains filtered or unexported fields
}

MockCreatorMockRecorder is the mock recorder for MockCreator.

func (*MockCreatorMockRecorder[T, C]) Create added in v0.0.11 

func (mr *MockCreatorMockRecorder[T, C]) Create(ctx, in any) *gomock.Call

Create indicates an expected call of Create.

type MockDeadLetterBackend 

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

MockDeadLetterBackend is a mock of DeadLetterBackend interface.

func NewMockDeadLetterBackend 

func NewMockDeadLetterBackend(ctrl *gomock.Controller) *MockDeadLetterBackend

NewMockDeadLetterBackend creates a new mock instance.

func (*MockDeadLetterBackend) EXPECT 

func (m *MockDeadLetterBackend) EXPECT() *MockDeadLetterBackendMockRecorder

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

func (*MockDeadLetterBackend) Send 

func (m *MockDeadLetterBackend) Send(ctx context.Context, letter interfaces.DeadLetter) error

Send mocks base method.

type MockDeadLetterBackendMockRecorder 

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

MockDeadLetterBackendMockRecorder is the mock recorder for MockDeadLetterBackend.

func (*MockDeadLetterBackendMockRecorder) Send 

func (mr *MockDeadLetterBackendMockRecorder) Send(ctx, letter any) *gomock.Call

Send indicates an expected call of Send.

type MockDecorgenStore added in v0.0.8 

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

MockDecorgenStore is a mock of Store interface.

func NewMockDecorgenStore added in v0.0.8 

func NewMockDecorgenStore(ctrl *gomock.Controller) *MockDecorgenStore

NewMockDecorgenStore creates a new mock instance.

func (*MockDecorgenStore) Close added in v0.0.8 

func (m *MockDecorgenStore) Close(ctx context.Context)

Close mocks base method.

func (*MockDecorgenStore) EXPECT added in v0.0.8 

func (m *MockDecorgenStore) EXPECT() *MockDecorgenStoreMockRecorder

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

func (*MockDecorgenStore) Exists added in v0.0.8 

func (m *MockDecorgenStore) Exists(ctx context.Context, id string) (bool, error)

Exists mocks base method.

func (*MockDecorgenStore) Mark added in v0.0.8 

func (m *MockDecorgenStore) Mark(ctx context.Context, id string, reasons ...string) error

Mark mocks base method.

func (*MockDecorgenStore) Name added in v0.0.8 

func (m *MockDecorgenStore) Name() string

Name mocks base method.

func (*MockDecorgenStore) Pair added in v0.0.8 

func (m *MockDecorgenStore) Pair(ctx context.Context) (int, string, error)

Pair mocks base method.

type MockDecorgenStoreMockRecorder added in v0.0.8 

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

MockDecorgenStoreMockRecorder is the mock recorder for MockDecorgenStore.

func (*MockDecorgenStoreMockRecorder) Close added in v0.0.8 

func (mr *MockDecorgenStoreMockRecorder) Close(ctx any) *gomock.Call

Close indicates an expected call of Close.

func (*MockDecorgenStoreMockRecorder) Exists added in v0.0.8 

func (mr *MockDecorgenStoreMockRecorder) Exists(ctx, id any) *gomock.Call

Exists indicates an expected call of Exists.

func (*MockDecorgenStoreMockRecorder) Mark added in v0.0.8 

func (mr *MockDecorgenStoreMockRecorder) Mark(ctx, id any, reasons ...any) *gomock.Call

Mark indicates an expected call of Mark.

func (*MockDecorgenStoreMockRecorder) Name added in v0.0.8 

func (mr *MockDecorgenStoreMockRecorder) Name() *gomock.Call

Name indicates an expected call of Name.

func (*MockDecorgenStoreMockRecorder) Pair added in v0.0.8 

func (mr *MockDecorgenStoreMockRecorder) Pair(ctx any) *gomock.Call

Pair indicates an expected call of Pair.

type MockDeduplicator 

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

MockDeduplicator is a mock of Deduplicator interface.

func NewMockDeduplicator 

func NewMockDeduplicator(ctrl *gomock.Controller) *MockDeduplicator

NewMockDeduplicator creates a new mock instance.

func (*MockDeduplicator) EXPECT 

func (m *MockDeduplicator) EXPECT() *MockDeduplicatorMockRecorder

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

func (*MockDeduplicator) Seen 

func (m *MockDeduplicator) Seen(ctx context.Context, key string) (bool, error)

Seen mocks base method.

type MockDeduplicatorMockRecorder 

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

MockDeduplicatorMockRecorder is the mock recorder for MockDeduplicator.

func (*MockDeduplicatorMockRecorder) Seen 

func (mr *MockDeduplicatorMockRecorder) Seen(ctx, key any) *gomock.Call

Seen indicates an expected call of Seen.

type MockDeleter added in v0.0.7 

type MockDeleter[ID comparable] struct {
	// contains filtered or unexported fields
}

MockDeleter is a mock of Deleter interface.

func NewMockDeleter added in v0.0.7 

func NewMockDeleter[ID comparable](ctrl *gomock.Controller) *MockDeleter[ID]

NewMockDeleter creates a new mock instance.

func (*MockDeleter[ID]) Delete added in v0.0.7 

func (m *MockDeleter[ID]) Delete(ctx context.Context, id ID) error

Delete mocks base method.

func (*MockDeleter[ID]) EXPECT added in v0.0.7 

func (m *MockDeleter[ID]) EXPECT() *MockDeleterMockRecorder[ID]

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

type MockDeleterMockRecorder added in v0.0.7 

type MockDeleterMockRecorder[ID comparable] struct {
	// contains filtered or unexported fields
}

MockDeleterMockRecorder is the mock recorder for MockDeleter.

func (*MockDeleterMockRecorder[ID]) Delete added in v0.0.7 

func (mr *MockDeleterMockRecorder[ID]) Delete(ctx, id any) *gomock.Call

Delete indicates an expected call of Delete.

type MockDistributedLock 

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

MockDistributedLock is a mock of DistributedLock interface.

func NewMockDistributedLock 

func NewMockDistributedLock(ctrl *gomock.Controller) *MockDistributedLock

NewMockDistributedLock creates a new mock instance.

func (*MockDistributedLock) Acquire 

func (m *MockDistributedLock) Acquire(ctx context.Context, key string) (string, bool, error)

Acquire mocks base method.

func (*MockDistributedLock) EXPECT 

func (m *MockDistributedLock) EXPECT() *MockDistributedLockMockRecorder

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

func (*MockDistributedLock) Release 

func (m *MockDistributedLock) Release(ctx context.Context, key, token string) error

Release mocks base method.

func (*MockDistributedLock) Renew 

func (m *MockDistributedLock) Renew(ctx context.Context, key, token string) (bool, error)

Renew mocks base method.

type MockDistributedLockMockRecorder 

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

MockDistributedLockMockRecorder is the mock recorder for MockDistributedLock.

func (*MockDistributedLockMockRecorder) Acquire 

func (mr *MockDistributedLockMockRecorder) Acquire(ctx, key any) *gomock.Call

Acquire indicates an expected call of Acquire.

func (*MockDistributedLockMockRecorder) Release 

func (mr *MockDistributedLockMockRecorder) Release(ctx, key, token any) *gomock.Call

Release indicates an expected call of Release.

func (*MockDistributedLockMockRecorder) Renew 

func (mr *MockDistributedLockMockRecorder) Renew(ctx, key, token any) *gomock.Call

Renew indicates an expected call of Renew.

type MockDynamicConsumer 

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

MockDynamicConsumer is a mock of DynamicConsumer interface.

func NewMockDynamicConsumer 

func NewMockDynamicConsumer(ctrl *gomock.Controller) *MockDynamicConsumer

NewMockDynamicConsumer creates a new mock instance.

func (*MockDynamicConsumer) Close 

func (m *MockDynamicConsumer) Close() error

Close mocks base method.

func (*MockDynamicConsumer) EXPECT 

func (m *MockDynamicConsumer) EXPECT() *MockDynamicConsumerMockRecorder

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

func (*MockDynamicConsumer) Subscribe 

func (m *MockDynamicConsumer) Subscribe(ctx context.Context, topic string, handler interfaces.MessageHandler) error

Subscribe mocks base method.

func (*MockDynamicConsumer) Unsubscribe 

func (m *MockDynamicConsumer) Unsubscribe(ctx context.Context, topic string) error

Unsubscribe mocks base method.

type MockDynamicConsumerMockRecorder 

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

MockDynamicConsumerMockRecorder is the mock recorder for MockDynamicConsumer.

func (*MockDynamicConsumerMockRecorder) Close 

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

Close indicates an expected call of Close.

func (*MockDynamicConsumerMockRecorder) Subscribe 

func (mr *MockDynamicConsumerMockRecorder) Subscribe(ctx, topic, handler any) *gomock.Call

Subscribe indicates an expected call of Subscribe.

func (*MockDynamicConsumerMockRecorder) Unsubscribe 

func (mr *MockDynamicConsumerMockRecorder) Unsubscribe(ctx, topic any) *gomock.Call

Unsubscribe indicates an expected call of Unsubscribe.

type MockEncryptor added in v0.0.4 

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

MockEncryptor is a mock of Encryptor interface.

func NewMockEncryptor added in v0.0.4 

func NewMockEncryptor(ctrl *gomock.Controller) *MockEncryptor

NewMockEncryptor creates a new mock instance.

func (*MockEncryptor) Decrypt added in v0.0.4 

func (m *MockEncryptor) Decrypt(ciphertext []byte) ([]byte, error)

Decrypt mocks base method.

func (*MockEncryptor) EXPECT added in v0.0.4 

func (m *MockEncryptor) EXPECT() *MockEncryptorMockRecorder

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

func (*MockEncryptor) Encrypt added in v0.0.4 

func (m *MockEncryptor) Encrypt(plaintext []byte) ([]byte, error)

Encrypt mocks base method.

type MockEncryptorMockRecorder added in v0.0.4 

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

MockEncryptorMockRecorder is the mock recorder for MockEncryptor.

func (*MockEncryptorMockRecorder) Decrypt added in v0.0.4 

func (mr *MockEncryptorMockRecorder) Decrypt(ciphertext any) *gomock.Call

Decrypt indicates an expected call of Decrypt.

func (*MockEncryptorMockRecorder) Encrypt added in v0.0.4 

func (mr *MockEncryptorMockRecorder) Encrypt(plaintext any) *gomock.Call

Encrypt indicates an expected call of Encrypt.

type MockEvent 

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

MockEvent is a mock of Event interface.

func NewMockEvent 

func NewMockEvent(ctrl *gomock.Controller) *MockEvent

NewMockEvent creates a new mock instance.

func (*MockEvent) EXPECT 

func (m *MockEvent) EXPECT() *MockEventMockRecorder

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

func (*MockEvent) Metadata 

func (m *MockEvent) Metadata() events.EventMetadata

Metadata mocks base method.

func (*MockEvent) Type 

func (m *MockEvent) Type() events.EventType

Type mocks base method.

type MockEventMockRecorder 

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

MockEventMockRecorder is the mock recorder for MockEvent.

func (*MockEventMockRecorder) Metadata 

func (mr *MockEventMockRecorder) Metadata() *gomock.Call

Metadata indicates an expected call of Metadata.

func (*MockEventMockRecorder) Type 

func (mr *MockEventMockRecorder) Type() *gomock.Call

Type indicates an expected call of Type.

type MockEventPublisher added in v0.0.4 

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

MockEventPublisher is a mock of EventPublisher interface.

func NewMockEventPublisher added in v0.0.4 

func NewMockEventPublisher(ctrl *gomock.Controller) *MockEventPublisher

NewMockEventPublisher creates a new mock instance.

func (*MockEventPublisher) EXPECT added in v0.0.4 

func (m *MockEventPublisher) EXPECT() *MockEventPublisherMockRecorder

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

func (*MockEventPublisher) Publish added in v0.0.4 

func (m *MockEventPublisher) Publish(ctx context.Context, event events.Event) error

Publish mocks base method.

func (*MockEventPublisher) PublishBatch added in v0.0.4 

func (m *MockEventPublisher) PublishBatch(ctx context.Context, arg1 []events.Event) error

PublishBatch mocks base method.

type MockEventPublisherMockRecorder added in v0.0.4 

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

MockEventPublisherMockRecorder is the mock recorder for MockEventPublisher.

func (*MockEventPublisherMockRecorder) Publish added in v0.0.4 

func (mr *MockEventPublisherMockRecorder) Publish(ctx, event any) *gomock.Call

Publish indicates an expected call of Publish.

func (*MockEventPublisherMockRecorder) PublishBatch added in v0.0.4 

func (mr *MockEventPublisherMockRecorder) PublishBatch(ctx, arg1 any) *gomock.Call

PublishBatch indicates an expected call of PublishBatch.

type MockExecutionObserver 

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

MockExecutionObserver is a mock of ExecutionObserver interface.

func NewMockExecutionObserver 

func NewMockExecutionObserver(ctrl *gomock.Controller) *MockExecutionObserver

NewMockExecutionObserver creates a new mock instance.

func (*MockExecutionObserver) EXPECT 

func (m *MockExecutionObserver) EXPECT() *MockExecutionObserverMockRecorder

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

func (*MockExecutionObserver) OnGateComplete 

func (m *MockExecutionObserver) OnGateComplete(gateName string, results types.StepResults, elapsed time.Duration)

OnGateComplete mocks base method.

func (*MockExecutionObserver) OnGateStart 

func (m *MockExecutionObserver) OnGateStart(name string, phases []string)

OnGateStart mocks base method.

func (*MockExecutionObserver) OnPhaseComplete 

func (m *MockExecutionObserver) OnPhaseComplete(name string, results types.StepResults, elapsed time.Duration)

OnPhaseComplete mocks base method.

func (*MockExecutionObserver) OnPhaseStart 

func (m *MockExecutionObserver) OnPhaseStart(name string, jobs []string)

OnPhaseStart mocks base method.

func (*MockExecutionObserver) OnStepComplete 

func (m *MockExecutionObserver) OnStepComplete(result types.StepResult)

OnStepComplete mocks base method.

func (*MockExecutionObserver) OnStepStart 

func (m *MockExecutionObserver) OnStepStart(name, group string)

OnStepStart mocks base method.

type MockExecutionObserverMockRecorder 

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

MockExecutionObserverMockRecorder is the mock recorder for MockExecutionObserver.

func (*MockExecutionObserverMockRecorder) OnGateComplete 

func (mr *MockExecutionObserverMockRecorder) OnGateComplete(gateName, results, elapsed any) *gomock.Call

OnGateComplete indicates an expected call of OnGateComplete.

func (*MockExecutionObserverMockRecorder) OnGateStart 

func (mr *MockExecutionObserverMockRecorder) OnGateStart(name, phases any) *gomock.Call

OnGateStart indicates an expected call of OnGateStart.

func (*MockExecutionObserverMockRecorder) OnPhaseComplete 

func (mr *MockExecutionObserverMockRecorder) OnPhaseComplete(name, results, elapsed any) *gomock.Call

OnPhaseComplete indicates an expected call of OnPhaseComplete.

func (*MockExecutionObserverMockRecorder) OnPhaseStart 

func (mr *MockExecutionObserverMockRecorder) OnPhaseStart(name, jobs any) *gomock.Call

OnPhaseStart indicates an expected call of OnPhaseStart.

func (*MockExecutionObserverMockRecorder) OnStepComplete 

func (mr *MockExecutionObserverMockRecorder) OnStepComplete(result any) *gomock.Call

OnStepComplete indicates an expected call of OnStepComplete.

func (*MockExecutionObserverMockRecorder) OnStepStart 

func (mr *MockExecutionObserverMockRecorder) OnStepStart(name, group any) *gomock.Call

OnStepStart indicates an expected call of OnStepStart.

type MockExister added in v0.0.7 

type MockExister[ID comparable] struct {
	// contains filtered or unexported fields
}

MockExister is a mock of Exister interface.

func NewMockExister added in v0.0.7 

func NewMockExister[ID comparable](ctrl *gomock.Controller) *MockExister[ID]

NewMockExister creates a new mock instance.

func (*MockExister[ID]) EXPECT added in v0.0.7 

func (m *MockExister[ID]) EXPECT() *MockExisterMockRecorder[ID]

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

func (*MockExister[ID]) Exists added in v0.0.7 

func (m *MockExister[ID]) Exists(ctx context.Context, id ID) (bool, error)

Exists mocks base method.

type MockExisterMockRecorder added in v0.0.7 

type MockExisterMockRecorder[ID comparable] struct {
	// contains filtered or unexported fields
}

MockExisterMockRecorder is the mock recorder for MockExister.

func (*MockExisterMockRecorder[ID]) Exists added in v0.0.7 

func (mr *MockExisterMockRecorder[ID]) Exists(ctx, id any) *gomock.Call

Exists indicates an expected call of Exists.

type MockGauge 

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

MockGauge is a mock of Gauge interface.

func NewMockGauge 

func NewMockGauge(ctrl *gomock.Controller) *MockGauge

NewMockGauge creates a new mock instance.

func (*MockGauge) Dec 

func (m *MockGauge) Dec(labelValues ...string)

Dec mocks base method.

func (*MockGauge) EXPECT 

func (m *MockGauge) EXPECT() *MockGaugeMockRecorder

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

func (*MockGauge) Inc 

func (m *MockGauge) Inc(labelValues ...string)

Inc mocks base method.

func (*MockGauge) Set 

func (m *MockGauge) Set(value float64, labelValues ...string)

Set mocks base method.

type MockGaugeMockRecorder 

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

MockGaugeMockRecorder is the mock recorder for MockGauge.

func (*MockGaugeMockRecorder) Dec 

func (mr *MockGaugeMockRecorder) Dec(labelValues ...any) *gomock.Call

Dec indicates an expected call of Dec.

func (*MockGaugeMockRecorder) Inc 

func (mr *MockGaugeMockRecorder) Inc(labelValues ...any) *gomock.Call

Inc indicates an expected call of Inc.

func (*MockGaugeMockRecorder) Set 

func (mr *MockGaugeMockRecorder) Set(value any, labelValues ...any) *gomock.Call

Set indicates an expected call of Set.

type MockHistogram 

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

MockHistogram is a mock of Histogram interface.

func NewMockHistogram 

func NewMockHistogram(ctrl *gomock.Controller) *MockHistogram

NewMockHistogram creates a new mock instance.

func (*MockHistogram) EXPECT 

func (m *MockHistogram) EXPECT() *MockHistogramMockRecorder

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

func (*MockHistogram) Observe 

func (m *MockHistogram) Observe(value float64, labelValues ...string)

Observe mocks base method.

type MockHistogramMockRecorder 

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

MockHistogramMockRecorder is the mock recorder for MockHistogram.

func (*MockHistogramMockRecorder) Observe 

func (mr *MockHistogramMockRecorder) Observe(value any, labelValues ...any) *gomock.Call

Observe indicates an expected call of Observe.

type MockInsertOnlyStore added in v0.0.7 

type MockInsertOnlyStore[T any] struct {
	// contains filtered or unexported fields
}

MockInsertOnlyStore is a mock of InsertOnlyStore interface.

func NewMockInsertOnlyStore added in v0.0.7 

func NewMockInsertOnlyStore[T any](ctrl *gomock.Controller) *MockInsertOnlyStore[T]

NewMockInsertOnlyStore creates a new mock instance.

func (*MockInsertOnlyStore[T]) EXPECT added in v0.0.7 

func (m *MockInsertOnlyStore[T]) EXPECT() *MockInsertOnlyStoreMockRecorder[T]

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

func (*MockInsertOnlyStore[T]) Insert added in v0.0.7 

func (m *MockInsertOnlyStore[T]) Insert(ctx context.Context, entity *T) error

Insert mocks base method.

type MockInsertOnlyStoreMockRecorder added in v0.0.7 

type MockInsertOnlyStoreMockRecorder[T any] struct {
	// contains filtered or unexported fields
}

MockInsertOnlyStoreMockRecorder is the mock recorder for MockInsertOnlyStore.

func (*MockInsertOnlyStoreMockRecorder[T]) Insert added in v0.0.7 

func (mr *MockInsertOnlyStoreMockRecorder[T]) Insert(ctx, entity any) *gomock.Call

Insert indicates an expected call of Insert.

type MockInserter added in v0.0.7 

type MockInserter[T any] struct {
	// contains filtered or unexported fields
}

MockInserter is a mock of Inserter interface.

func NewMockInserter added in v0.0.7 

func NewMockInserter[T any](ctrl *gomock.Controller) *MockInserter[T]

NewMockInserter creates a new mock instance.

func (*MockInserter[T]) EXPECT added in v0.0.7 

func (m *MockInserter[T]) EXPECT() *MockInserterMockRecorder[T]

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

func (*MockInserter[T]) Insert added in v0.0.7 

func (m *MockInserter[T]) Insert(ctx context.Context, entity *T) error

Insert mocks base method.

type MockInserterMockRecorder added in v0.0.7 

type MockInserterMockRecorder[T any] struct {
	// contains filtered or unexported fields
}

MockInserterMockRecorder is the mock recorder for MockInserter.

func (*MockInserterMockRecorder[T]) Insert added in v0.0.7 

func (mr *MockInserterMockRecorder[T]) Insert(ctx, entity any) *gomock.Call

Insert indicates an expected call of Insert.

type MockKeyedLimiter added in v0.0.6 

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

MockKeyedLimiter is a mock of KeyedLimiter interface.

func NewMockKeyedLimiter added in v0.0.6 

func NewMockKeyedLimiter(ctrl *gomock.Controller) *MockKeyedLimiter

NewMockKeyedLimiter creates a new mock instance.

func (*MockKeyedLimiter) EXPECT added in v0.0.6 

func (m *MockKeyedLimiter) EXPECT() *MockKeyedLimiterMockRecorder

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

func (*MockKeyedLimiter) TryAcquire added in v0.0.6 

func (m *MockKeyedLimiter) TryAcquire(key string) (func(), bool)

TryAcquire mocks base method.

type MockKeyedLimiterMockRecorder added in v0.0.6 

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

MockKeyedLimiterMockRecorder is the mock recorder for MockKeyedLimiter.

func (*MockKeyedLimiterMockRecorder) TryAcquire added in v0.0.6 

func (mr *MockKeyedLimiterMockRecorder) TryAcquire(key any) *gomock.Call

TryAcquire indicates an expected call of TryAcquire.

type MockLeaderElector 

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

MockLeaderElector is a mock of LeaderElector interface.

func NewMockLeaderElector 

func NewMockLeaderElector(ctrl *gomock.Controller) *MockLeaderElector

NewMockLeaderElector creates a new mock instance.

func (*MockLeaderElector) EXPECT 

func (m *MockLeaderElector) EXPECT() *MockLeaderElectorMockRecorder

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

func (*MockLeaderElector) IsLeader 

func (m *MockLeaderElector) IsLeader(ctx context.Context) (bool, error)

IsLeader mocks base method.

type MockLeaderElectorMockRecorder 

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

MockLeaderElectorMockRecorder is the mock recorder for MockLeaderElector.

func (*MockLeaderElectorMockRecorder) IsLeader 

func (mr *MockLeaderElectorMockRecorder) IsLeader(ctx any) *gomock.Call

IsLeader indicates an expected call of IsLeader.

type MockLifecycle 

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

MockLifecycle is a mock of Lifecycle interface.

func NewMockLifecycle 

func NewMockLifecycle(ctrl *gomock.Controller) *MockLifecycle

NewMockLifecycle creates a new mock instance.

func (*MockLifecycle) EXPECT 

func (m *MockLifecycle) EXPECT() *MockLifecycleMockRecorder

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

func (*MockLifecycle) Start 

func (m *MockLifecycle) Start(ctx context.Context) error

Start mocks base method.

func (*MockLifecycle) Stop 

func (m *MockLifecycle) Stop(ctx context.Context) error

Stop mocks base method.

type MockLifecycleMockRecorder 

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

MockLifecycleMockRecorder is the mock recorder for MockLifecycle.

func (*MockLifecycleMockRecorder) Start 

func (mr *MockLifecycleMockRecorder) Start(ctx any) *gomock.Call

Start indicates an expected call of Start.

func (*MockLifecycleMockRecorder) Stop 

func (mr *MockLifecycleMockRecorder) Stop(ctx any) *gomock.Call

Stop indicates an expected call of Stop.

type MockLister added in v0.0.7 

type MockLister[T any, P any] struct {
	// contains filtered or unexported fields
}

MockLister is a mock of Lister interface.

func NewMockLister added in v0.0.7 

func NewMockLister[T any, P any](ctrl *gomock.Controller) *MockLister[T, P]

NewMockLister creates a new mock instance.

func (*MockLister[T, P]) EXPECT added in v0.0.7 

func (m *MockLister[T, P]) EXPECT() *MockListerMockRecorder[T, P]

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

func (*MockLister[T, P]) List added in v0.0.7 

func (m *MockLister[T, P]) List(ctx context.Context, params P, page types.PageRequest) (*types.Page[T], error)

List mocks base method.

type MockListerMockRecorder added in v0.0.7 

type MockListerMockRecorder[T any, P any] struct {
	// contains filtered or unexported fields
}

MockListerMockRecorder is the mock recorder for MockLister.

func (*MockListerMockRecorder[T, P]) List added in v0.0.7 

func (mr *MockListerMockRecorder[T, P]) List(ctx, params, page any) *gomock.Call

List indicates an expected call of List.

type MockLocker added in v0.0.4 

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

MockLocker is a mock of Locker interface.

func NewMockLocker added in v0.0.4 

func NewMockLocker(ctrl *gomock.Controller) *MockLocker

NewMockLocker creates a new mock instance.

func (*MockLocker) Acquire added in v0.0.4 

func (m *MockLocker) Acquire(ctx context.Context, key string) (string, bool, error)

Acquire mocks base method.

func (*MockLocker) EXPECT added in v0.0.4 

func (m *MockLocker) EXPECT() *MockLockerMockRecorder

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

func (*MockLocker) Hold added in v0.0.4 

func (m *MockLocker) Hold(ctx context.Context, key string) (context.Context, func(), bool, error)

Hold mocks base method.

func (*MockLocker) Release added in v0.0.4 

func (m *MockLocker) Release(ctx context.Context, key, token string) error

Release mocks base method.

func (*MockLocker) Renew added in v0.0.4 

func (m *MockLocker) Renew(ctx context.Context, key, token string) (bool, error)

Renew mocks base method.

type MockLockerMockRecorder added in v0.0.4 

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

MockLockerMockRecorder is the mock recorder for MockLocker.

func (*MockLockerMockRecorder) Acquire added in v0.0.4 

func (mr *MockLockerMockRecorder) Acquire(ctx, key any) *gomock.Call

Acquire indicates an expected call of Acquire.

func (*MockLockerMockRecorder) Hold added in v0.0.4 

func (mr *MockLockerMockRecorder) Hold(ctx, key any) *gomock.Call

Hold indicates an expected call of Hold.

func (*MockLockerMockRecorder) Release added in v0.0.4 

func (mr *MockLockerMockRecorder) Release(ctx, key, token any) *gomock.Call

Release indicates an expected call of Release.

func (*MockLockerMockRecorder) Renew added in v0.0.4 

func (mr *MockLockerMockRecorder) Renew(ctx, key, token any) *gomock.Call

Renew indicates an expected call of Renew.

type MockLogger 

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

MockLogger is a mock of Logger interface.

func NewMockLogger 

func NewMockLogger(ctrl *gomock.Controller) *MockLogger

NewMockLogger creates a new mock instance.

func (*MockLogger) Debug 

func (m *MockLogger) Debug(msg string, keysAndValues ...any)

Debug mocks base method.

func (*MockLogger) EXPECT 

func (m *MockLogger) EXPECT() *MockLoggerMockRecorder

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

func (*MockLogger) Error 

func (m *MockLogger) Error(msg string, keysAndValues ...any)

Error mocks base method.

func (*MockLogger) Info 

func (m *MockLogger) Info(msg string, keysAndValues ...any)

Info mocks base method.

func (*MockLogger) Warn 

func (m *MockLogger) Warn(msg string, keysAndValues ...any)

Warn mocks base method.

func (*MockLogger) With 

func (m *MockLogger) With(keysAndValues ...any) interfaces.Logger

With mocks base method.

func (*MockLogger) WithContext 

func (m *MockLogger) WithContext(ctx context.Context) interfaces.Logger

WithContext mocks base method.

type MockLoggerMockRecorder 

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

MockLoggerMockRecorder is the mock recorder for MockLogger.

func (*MockLoggerMockRecorder) Debug 

func (mr *MockLoggerMockRecorder) Debug(msg any, keysAndValues ...any) *gomock.Call

Debug indicates an expected call of Debug.

func (*MockLoggerMockRecorder) Error 

func (mr *MockLoggerMockRecorder) Error(msg any, keysAndValues ...any) *gomock.Call

Error indicates an expected call of Error.

func (*MockLoggerMockRecorder) Info 

func (mr *MockLoggerMockRecorder) Info(msg any, keysAndValues ...any) *gomock.Call

Info indicates an expected call of Info.

func (*MockLoggerMockRecorder) Warn 

func (mr *MockLoggerMockRecorder) Warn(msg any, keysAndValues ...any) *gomock.Call

Warn indicates an expected call of Warn.

func (*MockLoggerMockRecorder) With 

func (mr *MockLoggerMockRecorder) With(keysAndValues ...any) *gomock.Call

With indicates an expected call of With.

func (*MockLoggerMockRecorder) WithContext 

func (mr *MockLoggerMockRecorder) WithContext(ctx any) *gomock.Call

WithContext indicates an expected call of WithContext.

type MockMessageConsumer added in v0.0.4 

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

MockMessageConsumer is a mock of MessageConsumer interface.

func NewMockMessageConsumer added in v0.0.4 

func NewMockMessageConsumer(ctrl *gomock.Controller) *MockMessageConsumer

NewMockMessageConsumer creates a new mock instance.

func (*MockMessageConsumer) Close added in v0.0.4 

func (m *MockMessageConsumer) Close() error

Close mocks base method.

func (*MockMessageConsumer) EXPECT added in v0.0.4 

func (m *MockMessageConsumer) EXPECT() *MockMessageConsumerMockRecorder

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

func (*MockMessageConsumer) Subscribe added in v0.0.4 

func (m *MockMessageConsumer) Subscribe(ctx context.Context, topic string, handler interfaces.MessageHandler) error

Subscribe mocks base method.

type MockMessageConsumerMockRecorder added in v0.0.4 

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

MockMessageConsumerMockRecorder is the mock recorder for MockMessageConsumer.

func (*MockMessageConsumerMockRecorder) Close added in v0.0.4 

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

Close indicates an expected call of Close.

func (*MockMessageConsumerMockRecorder) Subscribe added in v0.0.4 

func (mr *MockMessageConsumerMockRecorder) Subscribe(ctx, topic, handler any) *gomock.Call

Subscribe indicates an expected call of Subscribe.

type MockMessagePublisher 

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

MockMessagePublisher is a mock of MessagePublisher interface.

func NewMockMessagePublisher 

func NewMockMessagePublisher(ctrl *gomock.Controller) *MockMessagePublisher

NewMockMessagePublisher creates a new mock instance.

func (*MockMessagePublisher) EXPECT 

func (m *MockMessagePublisher) EXPECT() *MockMessagePublisherMockRecorder

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

func (*MockMessagePublisher) Publish 

func (m *MockMessagePublisher) Publish(ctx context.Context, topic string, payload []byte) error

Publish mocks base method.

func (*MockMessagePublisher) PublishBatch 

func (m *MockMessagePublisher) PublishBatch(ctx context.Context, topic string, payloads [][]byte) error

PublishBatch mocks base method.

type MockMessagePublisherMockRecorder 

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

MockMessagePublisherMockRecorder is the mock recorder for MockMessagePublisher.

func (*MockMessagePublisherMockRecorder) Publish 

func (mr *MockMessagePublisherMockRecorder) Publish(ctx, topic, payload any) *gomock.Call

Publish indicates an expected call of Publish.

func (*MockMessagePublisherMockRecorder) PublishBatch 

func (mr *MockMessagePublisherMockRecorder) PublishBatch(ctx, topic, payloads any) *gomock.Call

PublishBatch indicates an expected call of PublishBatch.

type MockMetrics 

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

MockMetrics is a mock of Metrics interface.

func NewMockMetrics 

func NewMockMetrics(ctrl *gomock.Controller) *MockMetrics

NewMockMetrics creates a new mock instance.

func (*MockMetrics) Counter 

func (m *MockMetrics) Counter(name, help string, labels ...string) interfaces.Counter

Counter mocks base method.

func (*MockMetrics) EXPECT 

func (m *MockMetrics) EXPECT() *MockMetricsMockRecorder

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

func (*MockMetrics) Gauge 

func (m *MockMetrics) Gauge(name, help string, labels ...string) interfaces.Gauge

Gauge mocks base method.

func (*MockMetrics) Handler 

func (m *MockMetrics) Handler() http.Handler

Handler mocks base method.

func (*MockMetrics) Histogram 

func (m *MockMetrics) Histogram(name, help string, buckets []float64, labels ...string) interfaces.Histogram

Histogram mocks base method.

type MockMetricsMockRecorder 

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

MockMetricsMockRecorder is the mock recorder for MockMetrics.

func (*MockMetricsMockRecorder) Counter 

func (mr *MockMetricsMockRecorder) Counter(name, help any, labels ...any) *gomock.Call

Counter indicates an expected call of Counter.

func (*MockMetricsMockRecorder) Gauge 

func (mr *MockMetricsMockRecorder) Gauge(name, help any, labels ...any) *gomock.Call

Gauge indicates an expected call of Gauge.

func (*MockMetricsMockRecorder) Handler 

func (mr *MockMetricsMockRecorder) Handler() *gomock.Call

Handler indicates an expected call of Handler.

func (*MockMetricsMockRecorder) Histogram 

func (mr *MockMetricsMockRecorder) Histogram(name, help, buckets any, labels ...any) *gomock.Call

Histogram indicates an expected call of Histogram.

type MockMetricsQuerier added in v0.0.8 

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

MockMetricsQuerier is a mock of MetricsQuerier interface.

func NewMockMetricsQuerier added in v0.0.8 

func NewMockMetricsQuerier(ctrl *gomock.Controller) *MockMetricsQuerier

NewMockMetricsQuerier creates a new mock instance.

func (*MockMetricsQuerier) EXPECT added in v0.0.8 

func (m *MockMetricsQuerier) EXPECT() *MockMetricsQuerierMockRecorder

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

func (*MockMetricsQuerier) Query added in v0.0.8 

func (m *MockMetricsQuerier) Query(ctx context.Context, query string) (float64, error)

Query mocks base method.

func (*MockMetricsQuerier) QueryRange added in v0.0.8 

func (m *MockMetricsQuerier) QueryRange(ctx context.Context, query string, start, end time.Time, step time.Duration) ([]types.MetricSample, error)

QueryRange mocks base method.

type MockMetricsQuerierMockRecorder added in v0.0.8 

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

MockMetricsQuerierMockRecorder is the mock recorder for MockMetricsQuerier.

func (*MockMetricsQuerierMockRecorder) Query added in v0.0.8 

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

Query indicates an expected call of Query.

func (*MockMetricsQuerierMockRecorder) QueryRange added in v0.0.8 

func (mr *MockMetricsQuerierMockRecorder) QueryRange(ctx, query, start, end, step any) *gomock.Call

QueryRange indicates an expected call of QueryRange.

type MockOp added in v0.0.12 

type MockOp[In any, Out any] struct {
	// contains filtered or unexported fields
}

MockOp is a mock of Op interface.

func NewMockOp added in v0.0.12 

func NewMockOp[In any, Out any](ctrl *gomock.Controller) *MockOp[In, Out]

NewMockOp creates a new mock instance.

func (*MockOp[In, Out]) EXPECT added in v0.0.12 

func (m *MockOp[In, Out]) EXPECT() *MockOpMockRecorder[In, Out]

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

func (*MockOp[In, Out]) Execute added in v0.0.12 

func (m *MockOp[In, Out]) Execute(ctx context.Context, in In) (Out, error)

Execute mocks base method.

type MockOpMockRecorder added in v0.0.12 

type MockOpMockRecorder[In any, Out any] struct {
	// contains filtered or unexported fields
}

MockOpMockRecorder is the mock recorder for MockOp.

func (*MockOpMockRecorder[In, Out]) Execute added in v0.0.12 

func (mr *MockOpMockRecorder[In, Out]) Execute(ctx, in any) *gomock.Call

Execute indicates an expected call of Execute.

type MockOpService added in v0.0.7 

type MockOpService[A any, R any] struct {
	// contains filtered or unexported fields
}

MockOpService is a mock of OpService interface.

func NewMockOpService added in v0.0.7 

func NewMockOpService[A any, R any](ctrl *gomock.Controller) *MockOpService[A, R]

NewMockOpService creates a new mock instance.

func (*MockOpService[A, R]) EXPECT added in v0.0.7 

func (m *MockOpService[A, R]) EXPECT() *MockOpServiceMockRecorder[A, R]

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

func (*MockOpService[A, R]) Name added in v0.0.7 

func (m *MockOpService[A, R]) Name() string

Name mocks base method.

func (*MockOpService[A, R]) Run added in v0.0.7 

func (m *MockOpService[A, R]) Run(ctx context.Context, args A) (R, error)

Run mocks base method.

type MockOpServiceMockRecorder added in v0.0.7 

type MockOpServiceMockRecorder[A any, R any] struct {
	// contains filtered or unexported fields
}

MockOpServiceMockRecorder is the mock recorder for MockOpService.

func (*MockOpServiceMockRecorder[A, R]) Name added in v0.0.7 

func (mr *MockOpServiceMockRecorder[A, R]) Name() *gomock.Call

Name indicates an expected call of Name.

func (*MockOpServiceMockRecorder[A, R]) Run added in v0.0.7 

func (mr *MockOpServiceMockRecorder[A, R]) Run(ctx, args any) *gomock.Call

Run indicates an expected call of Run.

type MockOutboxS3API 

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

MockOutboxS3API is a mock of API interface.

func NewMockOutboxS3API 

func NewMockOutboxS3API(ctrl *gomock.Controller) *MockOutboxS3API

NewMockOutboxS3API creates a new mock instance.

func (*MockOutboxS3API) EXPECT 

func (m *MockOutboxS3API) EXPECT() *MockOutboxS3APIMockRecorder

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

func (*MockOutboxS3API) PutObject 

func (m *MockOutboxS3API) PutObject(ctx context.Context, in *s3.PutObjectInput, optFns ...func(*s3.Options)) (*s3.PutObjectOutput, error)

PutObject mocks base method.

type MockOutboxS3APIMockRecorder 

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

MockOutboxS3APIMockRecorder is the mock recorder for MockOutboxS3API.

func (*MockOutboxS3APIMockRecorder) PutObject 

func (mr *MockOutboxS3APIMockRecorder) PutObject(ctx, in any, optFns ...any) *gomock.Call

PutObject indicates an expected call of PutObject.

type MockOutboxSQSAPI 

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

MockOutboxSQSAPI is a mock of API interface.

func NewMockOutboxSQSAPI 

func NewMockOutboxSQSAPI(ctrl *gomock.Controller) *MockOutboxSQSAPI

NewMockOutboxSQSAPI creates a new mock instance.

func (*MockOutboxSQSAPI) EXPECT 

func (m *MockOutboxSQSAPI) EXPECT() *MockOutboxSQSAPIMockRecorder

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

func (*MockOutboxSQSAPI) GetQueueUrl 

func (m *MockOutboxSQSAPI) GetQueueUrl(ctx context.Context, in *sqs.GetQueueUrlInput, optFns ...func(*sqs.Options)) (*sqs.GetQueueUrlOutput, error)

GetQueueUrl mocks base method.

func (*MockOutboxSQSAPI) SendMessageBatch 

func (m *MockOutboxSQSAPI) SendMessageBatch(ctx context.Context, in *sqs.SendMessageBatchInput, optFns ...func(*sqs.Options)) (*sqs.SendMessageBatchOutput, error)

SendMessageBatch mocks base method.

type MockOutboxSQSAPIMockRecorder 

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

MockOutboxSQSAPIMockRecorder is the mock recorder for MockOutboxSQSAPI.

func (*MockOutboxSQSAPIMockRecorder) GetQueueUrl 

func (mr *MockOutboxSQSAPIMockRecorder) GetQueueUrl(ctx, in any, optFns ...any) *gomock.Call

GetQueueUrl indicates an expected call of GetQueueUrl.

func (*MockOutboxSQSAPIMockRecorder) SendMessageBatch 

func (mr *MockOutboxSQSAPIMockRecorder) SendMessageBatch(ctx, in any, optFns ...any) *gomock.Call

SendMessageBatch indicates an expected call of SendMessageBatch.

type MockOutboxSink 

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

MockOutboxSink is a mock of OutboxSink interface.

func NewMockOutboxSink 

func NewMockOutboxSink(ctrl *gomock.Controller) *MockOutboxSink

NewMockOutboxSink creates a new mock instance.

func (*MockOutboxSink) EXPECT 

func (m *MockOutboxSink) EXPECT() *MockOutboxSinkMockRecorder

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

func (*MockOutboxSink) Send 

func (m *MockOutboxSink) Send(ctx context.Context, recs []types.OutboxRecord) []error

Send mocks base method.

type MockOutboxSinkMockRecorder 

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

MockOutboxSinkMockRecorder is the mock recorder for MockOutboxSink.

func (*MockOutboxSinkMockRecorder) Send 

func (mr *MockOutboxSinkMockRecorder) Send(ctx, recs any) *gomock.Call

Send indicates an expected call of Send.

type MockOutboxStore 

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

MockOutboxStore is a mock of OutboxStore interface.

func NewMockOutboxStore 

func NewMockOutboxStore(ctrl *gomock.Controller) *MockOutboxStore

NewMockOutboxStore creates a new mock instance.

func (*MockOutboxStore) Claim 

func (m *MockOutboxStore) Claim(ctx context.Context, lane string, limit int) ([]types.OutboxRecord, error)

Claim mocks base method.

func (*MockOutboxStore) DeleteSentBefore added in v0.0.7 

func (m *MockOutboxStore) DeleteSentBefore(ctx context.Context, cutoff time.Time) (int, error)

DeleteSentBefore mocks base method.

func (*MockOutboxStore) EXPECT 

func (m *MockOutboxStore) EXPECT() *MockOutboxStoreMockRecorder

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

func (*MockOutboxStore) MarkSent 

func (m *MockOutboxStore) MarkSent(ctx context.Context, id uuid.UUID) error

MarkSent mocks base method.

func (*MockOutboxStore) Park 

func (m *MockOutboxStore) Park(ctx context.Context, id uuid.UUID, lastErr string) error

Park mocks base method.

func (*MockOutboxStore) Retry 

func (m *MockOutboxStore) Retry(ctx context.Context, id uuid.UUID, next time.Time, lastErr string) error

Retry mocks base method.

func (*MockOutboxStore) Stats 

func (m *MockOutboxStore) Stats(ctx context.Context, lane string) (types.OutboxStats, error)

Stats mocks base method.

type MockOutboxStoreMockRecorder 

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

MockOutboxStoreMockRecorder is the mock recorder for MockOutboxStore.

func (*MockOutboxStoreMockRecorder) Claim 

func (mr *MockOutboxStoreMockRecorder) Claim(ctx, lane, limit any) *gomock.Call

Claim indicates an expected call of Claim.

func (*MockOutboxStoreMockRecorder) DeleteSentBefore added in v0.0.7 

func (mr *MockOutboxStoreMockRecorder) DeleteSentBefore(ctx, cutoff any) *gomock.Call

DeleteSentBefore indicates an expected call of DeleteSentBefore.

func (*MockOutboxStoreMockRecorder) MarkSent 

func (mr *MockOutboxStoreMockRecorder) MarkSent(ctx, id any) *gomock.Call

MarkSent indicates an expected call of MarkSent.

func (*MockOutboxStoreMockRecorder) Park 

func (mr *MockOutboxStoreMockRecorder) Park(ctx, id, lastErr any) *gomock.Call

Park indicates an expected call of Park.

func (*MockOutboxStoreMockRecorder) Retry 

func (mr *MockOutboxStoreMockRecorder) Retry(ctx, id, next, lastErr any) *gomock.Call

Retry indicates an expected call of Retry.

func (*MockOutboxStoreMockRecorder) Stats 

func (mr *MockOutboxStoreMockRecorder) Stats(ctx, lane any) *gomock.Call

Stats indicates an expected call of Stats.

type MockPatternConsumer 

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

MockPatternConsumer is a mock of PatternConsumer interface.

func NewMockPatternConsumer 

func NewMockPatternConsumer(ctrl *gomock.Controller) *MockPatternConsumer

NewMockPatternConsumer creates a new mock instance.

func (*MockPatternConsumer) Close 

func (m *MockPatternConsumer) Close() error

Close mocks base method.

func (*MockPatternConsumer) EXPECT 

func (m *MockPatternConsumer) EXPECT() *MockPatternConsumerMockRecorder

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

func (*MockPatternConsumer) PSubscribe 

func (m *MockPatternConsumer) PSubscribe(ctx context.Context, pattern string, handler interfaces.MessageHandler) error

PSubscribe mocks base method.

func (*MockPatternConsumer) PUnsubscribe 

func (m *MockPatternConsumer) PUnsubscribe(ctx context.Context, pattern string) error

PUnsubscribe mocks base method.

func (*MockPatternConsumer) Subscribe 

func (m *MockPatternConsumer) Subscribe(ctx context.Context, topic string, handler interfaces.MessageHandler) error

Subscribe mocks base method.

func (*MockPatternConsumer) Unsubscribe 

func (m *MockPatternConsumer) Unsubscribe(ctx context.Context, topic string) error

Unsubscribe mocks base method.

type MockPatternConsumerMockRecorder 

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

MockPatternConsumerMockRecorder is the mock recorder for MockPatternConsumer.

func (*MockPatternConsumerMockRecorder) Close 

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

Close indicates an expected call of Close.

func (*MockPatternConsumerMockRecorder) PSubscribe 

func (mr *MockPatternConsumerMockRecorder) PSubscribe(ctx, pattern, handler any) *gomock.Call

PSubscribe indicates an expected call of PSubscribe.

func (*MockPatternConsumerMockRecorder) PUnsubscribe 

func (mr *MockPatternConsumerMockRecorder) PUnsubscribe(ctx, pattern any) *gomock.Call

PUnsubscribe indicates an expected call of PUnsubscribe.

func (*MockPatternConsumerMockRecorder) Subscribe 

func (mr *MockPatternConsumerMockRecorder) Subscribe(ctx, topic, handler any) *gomock.Call

Subscribe indicates an expected call of Subscribe.

func (*MockPatternConsumerMockRecorder) Unsubscribe 

func (mr *MockPatternConsumerMockRecorder) Unsubscribe(ctx, topic any) *gomock.Call

Unsubscribe indicates an expected call of Unsubscribe.

type MockPipeline 

type MockPipeline[In any, Out any] struct {
	// contains filtered or unexported fields
}

MockPipeline is a mock of Pipeline interface.

func NewMockPipeline 

func NewMockPipeline[In any, Out any](ctrl *gomock.Controller) *MockPipeline[In, Out]

NewMockPipeline creates a new mock instance.

func (*MockPipeline[In, Out]) EXPECT 

func (m *MockPipeline[In, Out]) EXPECT() *MockPipelineMockRecorder[In, Out]

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

func (*MockPipeline[In, Out]) Execute 

func (m *MockPipeline[In, Out]) Execute(ctx context.Context, input In) (Out, error)

Execute mocks base method.

type MockPipelineMockRecorder 

type MockPipelineMockRecorder[In any, Out any] struct {
	// contains filtered or unexported fields
}

MockPipelineMockRecorder is the mock recorder for MockPipeline.

func (*MockPipelineMockRecorder[In, Out]) Execute 

func (mr *MockPipelineMockRecorder[In, Out]) Execute(ctx, input any) *gomock.Call

Execute indicates an expected call of Execute.

type MockPrometheusHTTPDoer 

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

MockPrometheusHTTPDoer is a mock of HTTPDoer interface.

func NewMockPrometheusHTTPDoer 

func NewMockPrometheusHTTPDoer(ctrl *gomock.Controller) *MockPrometheusHTTPDoer

NewMockPrometheusHTTPDoer creates a new mock instance.

func (*MockPrometheusHTTPDoer) Do 

func (m *MockPrometheusHTTPDoer) Do(req *http.Request) (*http.Response, error)

Do mocks base method.

func (*MockPrometheusHTTPDoer) EXPECT 

func (m *MockPrometheusHTTPDoer) EXPECT() *MockPrometheusHTTPDoerMockRecorder

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

type MockPrometheusHTTPDoerMockRecorder 

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

MockPrometheusHTTPDoerMockRecorder is the mock recorder for MockPrometheusHTTPDoer.

func (*MockPrometheusHTTPDoerMockRecorder) Do 

func (mr *MockPrometheusHTTPDoerMockRecorder) Do(req any) *gomock.Call

Do indicates an expected call of Do.

type MockRateLimiter 

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

MockRateLimiter is a mock of RateLimiter interface.

func NewMockRateLimiter 

func NewMockRateLimiter(ctrl *gomock.Controller) *MockRateLimiter

NewMockRateLimiter creates a new mock instance.

func (*MockRateLimiter) Allow 

func (m *MockRateLimiter) Allow() bool

Allow mocks base method.

func (*MockRateLimiter) EXPECT 

func (m *MockRateLimiter) EXPECT() *MockRateLimiterMockRecorder

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

func (*MockRateLimiter) Wait 

func (m *MockRateLimiter) Wait(ctx context.Context) error

Wait mocks base method.

type MockRateLimiterMockRecorder 

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

MockRateLimiterMockRecorder is the mock recorder for MockRateLimiter.

func (*MockRateLimiterMockRecorder) Allow 

func (mr *MockRateLimiterMockRecorder) Allow() *gomock.Call

Allow indicates an expected call of Allow.

func (*MockRateLimiterMockRecorder) Wait 

func (mr *MockRateLimiterMockRecorder) Wait(ctx any) *gomock.Call

Wait indicates an expected call of Wait.

type MockReadCloser 

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

MockReadCloser is a mock of ReadCloser interface.

func NewMockReadCloser 

func NewMockReadCloser(ctrl *gomock.Controller) *MockReadCloser

NewMockReadCloser creates a new mock instance.

func (*MockReadCloser) Close 

func (m *MockReadCloser) Close() error

Close mocks base method.

func (*MockReadCloser) EXPECT 

func (m *MockReadCloser) EXPECT() *MockReadCloserMockRecorder

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

func (*MockReadCloser) Read 

func (m *MockReadCloser) Read(p []byte) (int, error)

Read mocks base method.

type MockReadCloserMockRecorder 

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

MockReadCloserMockRecorder is the mock recorder for MockReadCloser.

func (*MockReadCloserMockRecorder) Close 

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

Close indicates an expected call of Close.

func (*MockReadCloserMockRecorder) Read 

func (mr *MockReadCloserMockRecorder) Read(p any) *gomock.Call

Read indicates an expected call of Read.

type MockReadListExistStore added in v0.0.7 

type MockReadListExistStore[T any, P any, ID comparable] struct {
	// contains filtered or unexported fields
}

MockReadListExistStore is a mock of ReadListExistStore interface.

func NewMockReadListExistStore added in v0.0.7 

func NewMockReadListExistStore[T any, P any, ID comparable](ctrl *gomock.Controller) *MockReadListExistStore[T, P, ID]

NewMockReadListExistStore creates a new mock instance.

func (*MockReadListExistStore[T, P, ID]) EXPECT added in v0.0.7 

func (m *MockReadListExistStore[T, P, ID]) EXPECT() *MockReadListExistStoreMockRecorder[T, P, ID]

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

func (*MockReadListExistStore[T, P, ID]) Exists added in v0.0.7 

func (m *MockReadListExistStore[T, P, ID]) Exists(ctx context.Context, id ID) (bool, error)

Exists mocks base method.

func (*MockReadListExistStore[T, P, ID]) Get added in v0.0.7 

func (m *MockReadListExistStore[T, P, ID]) Get(ctx context.Context, id ID) (*T, error)

Get mocks base method.

func (*MockReadListExistStore[T, P, ID]) List added in v0.0.7 

func (m *MockReadListExistStore[T, P, ID]) List(ctx context.Context, params P, page types.PageRequest) (*types.Page[T], error)

List mocks base method.

type MockReadListExistStoreMockRecorder added in v0.0.7 

type MockReadListExistStoreMockRecorder[T any, P any, ID comparable] struct {
	// contains filtered or unexported fields
}

MockReadListExistStoreMockRecorder is the mock recorder for MockReadListExistStore.

func (*MockReadListExistStoreMockRecorder[T, P, ID]) Exists added in v0.0.7 

func (mr *MockReadListExistStoreMockRecorder[T, P, ID]) Exists(ctx, id any) *gomock.Call

Exists indicates an expected call of Exists.

func (*MockReadListExistStoreMockRecorder[T, P, ID]) Get added in v0.0.7 

func (mr *MockReadListExistStoreMockRecorder[T, P, ID]) Get(ctx, id any) *gomock.Call

Get indicates an expected call of Get.

func (*MockReadListExistStoreMockRecorder[T, P, ID]) List added in v0.0.7 

func (mr *MockReadListExistStoreMockRecorder[T, P, ID]) List(ctx, params, page any) *gomock.Call

List indicates an expected call of List.

type MockReader added in v0.0.7 

type MockReader[T any, ID comparable] struct {
	// contains filtered or unexported fields
}

MockReader is a mock of Reader interface.

func NewMockReader added in v0.0.7 

func NewMockReader[T any, ID comparable](ctrl *gomock.Controller) *MockReader[T, ID]

NewMockReader creates a new mock instance.

func (*MockReader[T, ID]) EXPECT added in v0.0.7 

func (m *MockReader[T, ID]) EXPECT() *MockReaderMockRecorder[T, ID]

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

func (*MockReader[T, ID]) Get added in v0.0.7 

func (m *MockReader[T, ID]) Get(ctx context.Context, id ID) (*T, error)

Get mocks base method.

type MockReaderMockRecorder added in v0.0.7 

type MockReaderMockRecorder[T any, ID comparable] struct {
	// contains filtered or unexported fields
}

MockReaderMockRecorder is the mock recorder for MockReader.

func (*MockReaderMockRecorder[T, ID]) Get added in v0.0.7 

func (mr *MockReaderMockRecorder[T, ID]) Get(ctx, id any) *gomock.Call

Get indicates an expected call of Get.

type MockReplayBuffer 

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

MockReplayBuffer is a mock of ReplayBuffer interface.

func NewMockReplayBuffer 

func NewMockReplayBuffer(ctrl *gomock.Controller) *MockReplayBuffer

NewMockReplayBuffer creates a new mock instance.

func (*MockReplayBuffer) Append 

func (m *MockReplayBuffer) Append(ctx context.Context, key, msgID string, payload []byte) error

Append mocks base method.

func (*MockReplayBuffer) Delete 

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

Delete mocks base method.

func (*MockReplayBuffer) EXPECT 

func (m *MockReplayBuffer) EXPECT() *MockReplayBufferMockRecorder

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

func (*MockReplayBuffer) Prune 

func (m *MockReplayBuffer) Prune(ctx context.Context, key, upToMsgID string) error

Prune mocks base method.

func (*MockReplayBuffer) ReplayAfter 

func (m *MockReplayBuffer) ReplayAfter(ctx context.Context, key, afterMsgID string) ([]interfaces.BufferedMessage, bool, error)

ReplayAfter mocks base method.

type MockReplayBufferMockRecorder 

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

MockReplayBufferMockRecorder is the mock recorder for MockReplayBuffer.

func (*MockReplayBufferMockRecorder) Append 

func (mr *MockReplayBufferMockRecorder) Append(ctx, key, msgID, payload any) *gomock.Call

Append indicates an expected call of Append.

func (*MockReplayBufferMockRecorder) Delete 

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

Delete indicates an expected call of Delete.

func (*MockReplayBufferMockRecorder) Prune 

func (mr *MockReplayBufferMockRecorder) Prune(ctx, key, upToMsgID any) *gomock.Call

Prune indicates an expected call of Prune.

func (*MockReplayBufferMockRecorder) ReplayAfter 

func (mr *MockReplayBufferMockRecorder) ReplayAfter(ctx, key, afterMsgID any) *gomock.Call

ReplayAfter indicates an expected call of ReplayAfter.

type MockRepository added in v0.0.4 

type MockRepository[T any, P any, ID comparable] struct {
	// contains filtered or unexported fields
}

MockRepository is a mock of Repository interface.

func NewMockRepository added in v0.0.4 

func NewMockRepository[T any, P any, ID comparable](ctrl *gomock.Controller) *MockRepository[T, P, ID]

NewMockRepository creates a new mock instance.

func (*MockRepository[T, P, ID]) Create added in v0.0.4 

func (m *MockRepository[T, P, ID]) Create(ctx context.Context, in *T) (*T, error)

Create mocks base method.

func (*MockRepository[T, P, ID]) Delete added in v0.0.4 

func (m *MockRepository[T, P, ID]) Delete(ctx context.Context, id ID) error

Delete mocks base method.

func (*MockRepository[T, P, ID]) EXPECT added in v0.0.4 

func (m *MockRepository[T, P, ID]) EXPECT() *MockRepositoryMockRecorder[T, P, ID]

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

func (*MockRepository[T, P, ID]) Exists added in v0.0.4 

func (m *MockRepository[T, P, ID]) Exists(ctx context.Context, id ID) (bool, error)

Exists mocks base method.

func (*MockRepository[T, P, ID]) Get added in v0.0.4 

func (m *MockRepository[T, P, ID]) Get(ctx context.Context, id ID) (*T, error)

Get mocks base method.

func (*MockRepository[T, P, ID]) List added in v0.0.4 

func (m *MockRepository[T, P, ID]) List(ctx context.Context, params P, page types.PageRequest) (*types.Page[T], error)

List mocks base method.

func (*MockRepository[T, P, ID]) Update added in v0.0.4 

func (m *MockRepository[T, P, ID]) Update(ctx context.Context, id ID, in *T) (*T, error)

Update mocks base method.

type MockRepositoryMockRecorder added in v0.0.4 

type MockRepositoryMockRecorder[T any, P any, ID comparable] struct {
	// contains filtered or unexported fields
}

MockRepositoryMockRecorder is the mock recorder for MockRepository.

func (*MockRepositoryMockRecorder[T, P, ID]) Create added in v0.0.4 

func (mr *MockRepositoryMockRecorder[T, P, ID]) Create(ctx, in any) *gomock.Call

Create indicates an expected call of Create.

func (*MockRepositoryMockRecorder[T, P, ID]) Delete added in v0.0.4 

func (mr *MockRepositoryMockRecorder[T, P, ID]) Delete(ctx, id any) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockRepositoryMockRecorder[T, P, ID]) Exists added in v0.0.4 

func (mr *MockRepositoryMockRecorder[T, P, ID]) Exists(ctx, id any) *gomock.Call

Exists indicates an expected call of Exists.

func (*MockRepositoryMockRecorder[T, P, ID]) Get added in v0.0.4 

func (mr *MockRepositoryMockRecorder[T, P, ID]) Get(ctx, id any) *gomock.Call

Get indicates an expected call of Get.

func (*MockRepositoryMockRecorder[T, P, ID]) List added in v0.0.4 

func (mr *MockRepositoryMockRecorder[T, P, ID]) List(ctx, params, page any) *gomock.Call

List indicates an expected call of List.

func (*MockRepositoryMockRecorder[T, P, ID]) Update added in v0.0.4 

func (mr *MockRepositoryMockRecorder[T, P, ID]) Update(ctx, id, in any) *gomock.Call

Update indicates an expected call of Update.

type MockResource added in v0.0.11 

type MockResource[T any, P any, ID comparable, C any, U any] struct {
	// contains filtered or unexported fields
}

MockResource is a mock of Resource interface.

func NewMockResource added in v0.0.11 

func NewMockResource[T any, P any, ID comparable, C any, U any](ctrl *gomock.Controller) *MockResource[T, P, ID, C, U]

NewMockResource creates a new mock instance.

func (*MockResource[T, P, ID, C, U]) Create added in v0.0.11 

func (m *MockResource[T, P, ID, C, U]) Create(ctx context.Context, in C) (*T, error)

Create mocks base method.

func (*MockResource[T, P, ID, C, U]) Delete added in v0.0.11 

func (m *MockResource[T, P, ID, C, U]) Delete(ctx context.Context, id ID) error

Delete mocks base method.

func (*MockResource[T, P, ID, C, U]) EXPECT added in v0.0.11 

func (m *MockResource[T, P, ID, C, U]) EXPECT() *MockResourceMockRecorder[T, P, ID, C, U]

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

func (*MockResource[T, P, ID, C, U]) Exists added in v0.0.11 

func (m *MockResource[T, P, ID, C, U]) Exists(ctx context.Context, id ID) (bool, error)

Exists mocks base method.

func (*MockResource[T, P, ID, C, U]) Get added in v0.0.11 

func (m *MockResource[T, P, ID, C, U]) Get(ctx context.Context, id ID) (*T, error)

Get mocks base method.

func (*MockResource[T, P, ID, C, U]) List added in v0.0.11 

func (m *MockResource[T, P, ID, C, U]) List(ctx context.Context, params P, page types.PageRequest) (*types.Page[T], error)

List mocks base method.

func (*MockResource[T, P, ID, C, U]) Update added in v0.0.11 

func (m *MockResource[T, P, ID, C, U]) Update(ctx context.Context, id ID, in U) (*T, error)

Update mocks base method.

type MockResourceMockRecorder added in v0.0.11 

type MockResourceMockRecorder[T any, P any, ID comparable, C any, U any] struct {
	// contains filtered or unexported fields
}

MockResourceMockRecorder is the mock recorder for MockResource.

func (*MockResourceMockRecorder[T, P, ID, C, U]) Create added in v0.0.11 

func (mr *MockResourceMockRecorder[T, P, ID, C, U]) Create(ctx, in any) *gomock.Call

Create indicates an expected call of Create.

func (*MockResourceMockRecorder[T, P, ID, C, U]) Delete added in v0.0.11 

func (mr *MockResourceMockRecorder[T, P, ID, C, U]) Delete(ctx, id any) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockResourceMockRecorder[T, P, ID, C, U]) Exists added in v0.0.11 

func (mr *MockResourceMockRecorder[T, P, ID, C, U]) Exists(ctx, id any) *gomock.Call

Exists indicates an expected call of Exists.

func (*MockResourceMockRecorder[T, P, ID, C, U]) Get added in v0.0.11 

func (mr *MockResourceMockRecorder[T, P, ID, C, U]) Get(ctx, id any) *gomock.Call

Get indicates an expected call of Get.

func (*MockResourceMockRecorder[T, P, ID, C, U]) List added in v0.0.11 

func (mr *MockResourceMockRecorder[T, P, ID, C, U]) List(ctx, params, page any) *gomock.Call

List indicates an expected call of List.

func (*MockResourceMockRecorder[T, P, ID, C, U]) Update added in v0.0.11 

func (mr *MockResourceMockRecorder[T, P, ID, C, U]) Update(ctx, id, in any) *gomock.Call

Update indicates an expected call of Update.

type MockRetrier 

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

MockRetrier is a mock of Retrier interface.

func NewMockRetrier 

func NewMockRetrier(ctrl *gomock.Controller) *MockRetrier

NewMockRetrier creates a new mock instance.

func (*MockRetrier) EXPECT 

func (m *MockRetrier) EXPECT() *MockRetrierMockRecorder

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

func (*MockRetrier) Retry 

func (m *MockRetrier) Retry(ctx context.Context, op func() error) error

Retry mocks base method.

type MockRetrierMockRecorder 

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

MockRetrierMockRecorder is the mock recorder for MockRetrier.

func (*MockRetrierMockRecorder) Retry 

func (mr *MockRetrierMockRecorder) Retry(ctx, op any) *gomock.Call

Retry indicates an expected call of Retry.

type MockRoundTripper 

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

MockRoundTripper is a mock of RoundTripper interface.

func NewMockRoundTripper 

func NewMockRoundTripper(ctrl *gomock.Controller) *MockRoundTripper

NewMockRoundTripper creates a new mock instance.

func (*MockRoundTripper) EXPECT 

func (m *MockRoundTripper) EXPECT() *MockRoundTripperMockRecorder

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

func (*MockRoundTripper) RoundTrip 

func (m *MockRoundTripper) RoundTrip(arg0 *http.Request) (*http.Response, error)

RoundTrip mocks base method.

type MockRoundTripperMockRecorder 

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

MockRoundTripperMockRecorder is the mock recorder for MockRoundTripper.

func (*MockRoundTripperMockRecorder) RoundTrip 

func (mr *MockRoundTripperMockRecorder) RoundTrip(arg0 any) *gomock.Call

RoundTrip indicates an expected call of RoundTrip.

type MockRowStream 

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

MockRowStream is a mock of RowStream interface.

func NewMockRowStream 

func NewMockRowStream(ctrl *gomock.Controller) *MockRowStream

NewMockRowStream creates a new mock instance.

func (*MockRowStream) Close 

func (m *MockRowStream) Close() error

Close mocks base method.

func (*MockRowStream) EXPECT 

func (m *MockRowStream) EXPECT() *MockRowStreamMockRecorder

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

func (*MockRowStream) Next 

func (m *MockRowStream) Next(ctx context.Context) ([]types.Row, bool, error)

Next mocks base method.

func (*MockRowStream) ResumeToken 

func (m *MockRowStream) ResumeToken() []byte

ResumeToken mocks base method.

type MockRowStreamMockRecorder 

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

MockRowStreamMockRecorder is the mock recorder for MockRowStream.

func (*MockRowStreamMockRecorder) Close 

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

Close indicates an expected call of Close.

func (*MockRowStreamMockRecorder) Next 

func (mr *MockRowStreamMockRecorder) Next(ctx any) *gomock.Call

Next indicates an expected call of Next.

func (*MockRowStreamMockRecorder) ResumeToken 

func (mr *MockRowStreamMockRecorder) ResumeToken() *gomock.Call

ResumeToken indicates an expected call of ResumeToken.

type MockS3API 

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

MockS3API is a mock of S3API interface.

func NewMockS3API 

func NewMockS3API(ctrl *gomock.Controller) *MockS3API

NewMockS3API creates a new mock instance.

func (*MockS3API) AbortMultipartUpload 

func (m *MockS3API) AbortMultipartUpload(arg0 context.Context, arg1 *s3.AbortMultipartUploadInput, arg2 ...func(*s3.Options)) (*s3.AbortMultipartUploadOutput, error)

AbortMultipartUpload mocks base method.

func (*MockS3API) CompleteMultipartUpload 

func (m *MockS3API) CompleteMultipartUpload(arg0 context.Context, arg1 *s3.CompleteMultipartUploadInput, arg2 ...func(*s3.Options)) (*s3.CompleteMultipartUploadOutput, error)

CompleteMultipartUpload mocks base method.

func (*MockS3API) CreateBucket 

func (m *MockS3API) CreateBucket(arg0 context.Context, arg1 *s3.CreateBucketInput, arg2 ...func(*s3.Options)) (*s3.CreateBucketOutput, error)

CreateBucket mocks base method.

func (*MockS3API) CreateMultipartUpload 

func (m *MockS3API) CreateMultipartUpload(arg0 context.Context, arg1 *s3.CreateMultipartUploadInput, arg2 ...func(*s3.Options)) (*s3.CreateMultipartUploadOutput, error)

CreateMultipartUpload mocks base method.

func (*MockS3API) DeleteObject 

func (m *MockS3API) DeleteObject(arg0 context.Context, arg1 *s3.DeleteObjectInput, arg2 ...func(*s3.Options)) (*s3.DeleteObjectOutput, error)

DeleteObject mocks base method.

func (*MockS3API) DeleteObjects 

func (m *MockS3API) DeleteObjects(arg0 context.Context, arg1 *s3.DeleteObjectsInput, arg2 ...func(*s3.Options)) (*s3.DeleteObjectsOutput, error)

DeleteObjects mocks base method.

func (*MockS3API) EXPECT 

func (m *MockS3API) EXPECT() *MockS3APIMockRecorder

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

func (*MockS3API) GetObject 

func (m *MockS3API) GetObject(arg0 context.Context, arg1 *s3.GetObjectInput, arg2 ...func(*s3.Options)) (*s3.GetObjectOutput, error)

GetObject mocks base method.

func (*MockS3API) HeadBucket 

func (m *MockS3API) HeadBucket(arg0 context.Context, arg1 *s3.HeadBucketInput, arg2 ...func(*s3.Options)) (*s3.HeadBucketOutput, error)

HeadBucket mocks base method.

func (*MockS3API) HeadObject 

func (m *MockS3API) HeadObject(arg0 context.Context, arg1 *s3.HeadObjectInput, arg2 ...func(*s3.Options)) (*s3.HeadObjectOutput, error)

HeadObject mocks base method.

func (*MockS3API) ListMultipartUploads 

func (m *MockS3API) ListMultipartUploads(arg0 context.Context, arg1 *s3.ListMultipartUploadsInput, arg2 ...func(*s3.Options)) (*s3.ListMultipartUploadsOutput, error)

ListMultipartUploads mocks base method.

func (*MockS3API) ListObjectsV2 

func (m *MockS3API) ListObjectsV2(arg0 context.Context, arg1 *s3.ListObjectsV2Input, arg2 ...func(*s3.Options)) (*s3.ListObjectsV2Output, error)

ListObjectsV2 mocks base method.

func (*MockS3API) PutObject 

func (m *MockS3API) PutObject(arg0 context.Context, arg1 *s3.PutObjectInput, arg2 ...func(*s3.Options)) (*s3.PutObjectOutput, error)

PutObject mocks base method.

func (*MockS3API) UploadPart 

func (m *MockS3API) UploadPart(arg0 context.Context, arg1 *s3.UploadPartInput, arg2 ...func(*s3.Options)) (*s3.UploadPartOutput, error)

UploadPart mocks base method.

type MockS3APIMockRecorder 

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

MockS3APIMockRecorder is the mock recorder for MockS3API.

func (*MockS3APIMockRecorder) AbortMultipartUpload 

func (mr *MockS3APIMockRecorder) AbortMultipartUpload(arg0, arg1 any, arg2 ...any) *gomock.Call

AbortMultipartUpload indicates an expected call of AbortMultipartUpload.

func (*MockS3APIMockRecorder) CompleteMultipartUpload 

func (mr *MockS3APIMockRecorder) CompleteMultipartUpload(arg0, arg1 any, arg2 ...any) *gomock.Call

CompleteMultipartUpload indicates an expected call of CompleteMultipartUpload.

func (*MockS3APIMockRecorder) CreateBucket 

func (mr *MockS3APIMockRecorder) CreateBucket(arg0, arg1 any, arg2 ...any) *gomock.Call

CreateBucket indicates an expected call of CreateBucket.

func (*MockS3APIMockRecorder) CreateMultipartUpload 

func (mr *MockS3APIMockRecorder) CreateMultipartUpload(arg0, arg1 any, arg2 ...any) *gomock.Call

CreateMultipartUpload indicates an expected call of CreateMultipartUpload.

func (*MockS3APIMockRecorder) DeleteObject 

func (mr *MockS3APIMockRecorder) DeleteObject(arg0, arg1 any, arg2 ...any) *gomock.Call

DeleteObject indicates an expected call of DeleteObject.

func (*MockS3APIMockRecorder) DeleteObjects 

func (mr *MockS3APIMockRecorder) DeleteObjects(arg0, arg1 any, arg2 ...any) *gomock.Call

DeleteObjects indicates an expected call of DeleteObjects.

func (*MockS3APIMockRecorder) GetObject 

func (mr *MockS3APIMockRecorder) GetObject(arg0, arg1 any, arg2 ...any) *gomock.Call

GetObject indicates an expected call of GetObject.

func (*MockS3APIMockRecorder) HeadBucket 

func (mr *MockS3APIMockRecorder) HeadBucket(arg0, arg1 any, arg2 ...any) *gomock.Call

HeadBucket indicates an expected call of HeadBucket.

func (*MockS3APIMockRecorder) HeadObject 

func (mr *MockS3APIMockRecorder) HeadObject(arg0, arg1 any, arg2 ...any) *gomock.Call

HeadObject indicates an expected call of HeadObject.

func (*MockS3APIMockRecorder) ListMultipartUploads 

func (mr *MockS3APIMockRecorder) ListMultipartUploads(arg0, arg1 any, arg2 ...any) *gomock.Call

ListMultipartUploads indicates an expected call of ListMultipartUploads.

func (*MockS3APIMockRecorder) ListObjectsV2 

func (mr *MockS3APIMockRecorder) ListObjectsV2(arg0, arg1 any, arg2 ...any) *gomock.Call

ListObjectsV2 indicates an expected call of ListObjectsV2.

func (*MockS3APIMockRecorder) PutObject 

func (mr *MockS3APIMockRecorder) PutObject(arg0, arg1 any, arg2 ...any) *gomock.Call

PutObject indicates an expected call of PutObject.

func (*MockS3APIMockRecorder) UploadPart 

func (mr *MockS3APIMockRecorder) UploadPart(arg0, arg1 any, arg2 ...any) *gomock.Call

UploadPart indicates an expected call of UploadPart.

type MockSecretsManagerAPI 

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

MockSecretsManagerAPI is a mock of SecretsManagerAPI interface.

func NewMockSecretsManagerAPI 

func NewMockSecretsManagerAPI(ctrl *gomock.Controller) *MockSecretsManagerAPI

NewMockSecretsManagerAPI creates a new mock instance.

func (*MockSecretsManagerAPI) EXPECT 

func (m *MockSecretsManagerAPI) EXPECT() *MockSecretsManagerAPIMockRecorder

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

func (*MockSecretsManagerAPI) GetSecretValue 

func (m *MockSecretsManagerAPI) GetSecretValue(arg0 context.Context, arg1 *secretsmanager.GetSecretValueInput, arg2 ...func(*secretsmanager.Options)) (*secretsmanager.GetSecretValueOutput, error)

GetSecretValue mocks base method.

type MockSecretsManagerAPIMockRecorder 

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

MockSecretsManagerAPIMockRecorder is the mock recorder for MockSecretsManagerAPI.

func (*MockSecretsManagerAPIMockRecorder) GetSecretValue 

func (mr *MockSecretsManagerAPIMockRecorder) GetSecretValue(arg0, arg1 any, arg2 ...any) *gomock.Call

GetSecretValue indicates an expected call of GetSecretValue.

type MockService 

type MockService[T any, P any, ID comparable] struct {
	// contains filtered or unexported fields
}

MockService is a mock of Service interface.

func NewMockService 

func NewMockService[T any, P any, ID comparable](ctrl *gomock.Controller) *MockService[T, P, ID]

NewMockService creates a new mock instance.

func (*MockService[T, P, ID]) Create 

func (m *MockService[T, P, ID]) Create(ctx context.Context, in *T) (*T, error)

Create mocks base method.

func (*MockService[T, P, ID]) Delete 

func (m *MockService[T, P, ID]) Delete(ctx context.Context, id ID) error

Delete mocks base method.

func (*MockService[T, P, ID]) EXPECT 

func (m *MockService[T, P, ID]) EXPECT() *MockServiceMockRecorder[T, P, ID]

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

func (*MockService[T, P, ID]) Get 

func (m *MockService[T, P, ID]) Get(ctx context.Context, id ID) (*T, error)

Get mocks base method.

func (*MockService[T, P, ID]) List 

func (m *MockService[T, P, ID]) List(ctx context.Context, params P, page types.PageRequest) (*types.Page[T], error)

List mocks base method.

func (*MockService[T, P, ID]) Update 

func (m *MockService[T, P, ID]) Update(ctx context.Context, id ID, in *T) (*T, error)

Update mocks base method.

type MockServiceMockRecorder 

type MockServiceMockRecorder[T any, P any, ID comparable] struct {
	// contains filtered or unexported fields
}

MockServiceMockRecorder is the mock recorder for MockService.

func (*MockServiceMockRecorder[T, P, ID]) Create 

func (mr *MockServiceMockRecorder[T, P, ID]) Create(ctx, in any) *gomock.Call

Create indicates an expected call of Create.

func (*MockServiceMockRecorder[T, P, ID]) Delete 

func (mr *MockServiceMockRecorder[T, P, ID]) Delete(ctx, id any) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockServiceMockRecorder[T, P, ID]) Get 

func (mr *MockServiceMockRecorder[T, P, ID]) Get(ctx, id any) *gomock.Call

Get indicates an expected call of Get.

func (*MockServiceMockRecorder[T, P, ID]) List 

func (mr *MockServiceMockRecorder[T, P, ID]) List(ctx, params, page any) *gomock.Call

List indicates an expected call of List.

func (*MockServiceMockRecorder[T, P, ID]) Update 

func (mr *MockServiceMockRecorder[T, P, ID]) Update(ctx, id, in any) *gomock.Call

Update indicates an expected call of Update.

type MockSource added in v0.0.4 

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

MockSource is a mock of Source interface.

func NewMockSource added in v0.0.4 

func NewMockSource(ctrl *gomock.Controller) *MockSource

NewMockSource creates a new mock instance.

func (*MockSource) EXPECT added in v0.0.4 

func (m *MockSource) EXPECT() *MockSourceMockRecorder

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

func (*MockSource) Get added in v0.0.4 

func (m *MockSource) Get(ctx context.Context, ref types.Ref) (types.Secret, error)

Get mocks base method.

func (*MockSource) Put added in v0.0.4 

func (m *MockSource) Put(ctx context.Context, ref types.Ref, value types.Secret) error

Put mocks base method.

type MockSourceBuilder 

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

MockSourceBuilder is a mock of SourceBuilder interface.

func NewMockSourceBuilder 

func NewMockSourceBuilder(ctrl *gomock.Controller) *MockSourceBuilder

NewMockSourceBuilder creates a new mock instance.

func (*MockSourceBuilder) Build 

func (m *MockSourceBuilder) Build(ctx context.Context, cfg interfaces.SourceConfig) (interfaces.ConnectorSource, error)

Build mocks base method.

func (*MockSourceBuilder) EXPECT 

func (m *MockSourceBuilder) EXPECT() *MockSourceBuilderMockRecorder

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

type MockSourceBuilderMockRecorder 

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

MockSourceBuilderMockRecorder is the mock recorder for MockSourceBuilder.

func (*MockSourceBuilderMockRecorder) Build 

func (mr *MockSourceBuilderMockRecorder) Build(ctx, cfg any) *gomock.Call

Build indicates an expected call of Build.

type MockSourceMockRecorder added in v0.0.4 

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

MockSourceMockRecorder is the mock recorder for MockSource.

func (*MockSourceMockRecorder) Get added in v0.0.4 

func (mr *MockSourceMockRecorder) Get(ctx, ref any) *gomock.Call

Get indicates an expected call of Get.

func (*MockSourceMockRecorder) Put added in v0.0.4 

func (mr *MockSourceMockRecorder) Put(ctx, ref, value any) *gomock.Call

Put indicates an expected call of Put.

type MockSpan 

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

MockSpan is a mock of Span interface.

func NewMockSpan 

func NewMockSpan(ctrl *gomock.Controller) *MockSpan

NewMockSpan creates a new mock instance.

func (*MockSpan) EXPECT 

func (m *MockSpan) EXPECT() *MockSpanMockRecorder

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

func (*MockSpan) End 

func (m *MockSpan) End()

End mocks base method.

func (*MockSpan) RecordError 

func (m *MockSpan) RecordError(err error)

RecordError mocks base method.

func (*MockSpan) SetAttribute 

func (m *MockSpan) SetAttribute(key string, value any)

SetAttribute mocks base method.

func (*MockSpan) SetStatus 

func (m *MockSpan) SetStatus(code interfaces.SpanStatusCode, description string)

SetStatus mocks base method.

type MockSpanMockRecorder 

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

MockSpanMockRecorder is the mock recorder for MockSpan.

func (*MockSpanMockRecorder) End 

func (mr *MockSpanMockRecorder) End() *gomock.Call

End indicates an expected call of End.

func (*MockSpanMockRecorder) RecordError 

func (mr *MockSpanMockRecorder) RecordError(err any) *gomock.Call

RecordError indicates an expected call of RecordError.

func (*MockSpanMockRecorder) SetAttribute 

func (mr *MockSpanMockRecorder) SetAttribute(key, value any) *gomock.Call

SetAttribute indicates an expected call of SetAttribute.

func (*MockSpanMockRecorder) SetStatus 

func (mr *MockSpanMockRecorder) SetStatus(code, description any) *gomock.Call

SetStatus indicates an expected call of SetStatus.

type MockStorageClient 

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

MockStorageClient is a mock of StorageClient interface.

func NewMockStorageClient 

func NewMockStorageClient(ctrl *gomock.Controller) *MockStorageClient

NewMockStorageClient creates a new mock instance.

func (*MockStorageClient) AbortMultipartUpload 

func (m *MockStorageClient) AbortMultipartUpload(ctx context.Context, bucket, key, uploadID string) error

AbortMultipartUpload mocks base method.

func (*MockStorageClient) CompleteMultipartUpload 

func (m *MockStorageClient) CompleteMultipartUpload(ctx context.Context, bucket, key, uploadID string, parts []interfaces.CompletedPart) error

CompleteMultipartUpload mocks base method.

func (*MockStorageClient) CreateMultipartUpload 

func (m *MockStorageClient) CreateMultipartUpload(ctx context.Context, bucket, key, contentType string) (string, error)

CreateMultipartUpload mocks base method.

func (*MockStorageClient) Delete 

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

Delete mocks base method.

func (*MockStorageClient) DeleteBatch 

func (m *MockStorageClient) DeleteBatch(ctx context.Context, bucket string, keys []string) error

DeleteBatch mocks base method.

func (*MockStorageClient) Download 

func (m *MockStorageClient) Download(ctx context.Context, bucket, key string) (io.ReadCloser, error)

Download mocks base method.

func (*MockStorageClient) EXPECT 

func (m *MockStorageClient) EXPECT() *MockStorageClientMockRecorder

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

func (*MockStorageClient) EnsureBucket 

func (m *MockStorageClient) EnsureBucket(ctx context.Context, bucket string) error

EnsureBucket mocks base method.

func (*MockStorageClient) Exists 

func (m *MockStorageClient) Exists(ctx context.Context, bucket, key string) (bool, error)

Exists mocks base method.

func (*MockStorageClient) ListMultipartUploads 

func (m *MockStorageClient) ListMultipartUploads(ctx context.Context, bucket string) ([]interfaces.MultipartUpload, error)

ListMultipartUploads mocks base method.

func (*MockStorageClient) ListObjects 

func (m *MockStorageClient) ListObjects(ctx context.Context, bucket, prefix string) ([]interfaces.StorageObject, error)

ListObjects mocks base method.

func (*MockStorageClient) ListObjectsPage 

func (m *MockStorageClient) ListObjectsPage(ctx context.Context, bucket, prefix string, limit int) ([]interfaces.StorageObject, error)

ListObjectsPage mocks base method.

func (*MockStorageClient) ListObjectsPageToken 

func (m *MockStorageClient) ListObjectsPageToken(ctx context.Context, bucket, prefix, continuationToken string, limit int) ([]interfaces.StorageObject, string, error)

ListObjectsPageToken mocks base method.

func (*MockStorageClient) PresignPutURL 

func (m *MockStorageClient) PresignPutURL(ctx context.Context, bucket, key string, expirySeconds int, contentType string) (string, error)

PresignPutURL mocks base method.

func (*MockStorageClient) PresignURL 

func (m *MockStorageClient) PresignURL(ctx context.Context, bucket, key string, expirySeconds int, displayFilename string) (string, error)

PresignURL mocks base method.

func (*MockStorageClient) PresignUploadPart 

func (m *MockStorageClient) PresignUploadPart(ctx context.Context, bucket, key, uploadID string, partNumber int32, expirySeconds int) (string, error)

PresignUploadPart mocks base method.

func (*MockStorageClient) Stat 

func (m *MockStorageClient) Stat(ctx context.Context, bucket, key string) (interfaces.StorageObject, error)

Stat mocks base method.

func (*MockStorageClient) Upload 

func (m *MockStorageClient) Upload(ctx context.Context, bucket, key string, body io.Reader, contentType string) error

Upload mocks base method.

type MockStorageClientMockRecorder 

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

MockStorageClientMockRecorder is the mock recorder for MockStorageClient.

func (*MockStorageClientMockRecorder) AbortMultipartUpload 

func (mr *MockStorageClientMockRecorder) AbortMultipartUpload(ctx, bucket, key, uploadID any) *gomock.Call

AbortMultipartUpload indicates an expected call of AbortMultipartUpload.

func (*MockStorageClientMockRecorder) CompleteMultipartUpload 

func (mr *MockStorageClientMockRecorder) CompleteMultipartUpload(ctx, bucket, key, uploadID, parts any) *gomock.Call

CompleteMultipartUpload indicates an expected call of CompleteMultipartUpload.

func (*MockStorageClientMockRecorder) CreateMultipartUpload 

func (mr *MockStorageClientMockRecorder) CreateMultipartUpload(ctx, bucket, key, contentType any) *gomock.Call

CreateMultipartUpload indicates an expected call of CreateMultipartUpload.

func (*MockStorageClientMockRecorder) Delete 

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

Delete indicates an expected call of Delete.

func (*MockStorageClientMockRecorder) DeleteBatch 

func (mr *MockStorageClientMockRecorder) DeleteBatch(ctx, bucket, keys any) *gomock.Call

DeleteBatch indicates an expected call of DeleteBatch.

func (*MockStorageClientMockRecorder) Download 

func (mr *MockStorageClientMockRecorder) Download(ctx, bucket, key any) *gomock.Call

Download indicates an expected call of Download.

func (*MockStorageClientMockRecorder) EnsureBucket 

func (mr *MockStorageClientMockRecorder) EnsureBucket(ctx, bucket any) *gomock.Call

EnsureBucket indicates an expected call of EnsureBucket.

func (*MockStorageClientMockRecorder) Exists 

func (mr *MockStorageClientMockRecorder) Exists(ctx, bucket, key any) *gomock.Call

Exists indicates an expected call of Exists.

func (*MockStorageClientMockRecorder) ListMultipartUploads 

func (mr *MockStorageClientMockRecorder) ListMultipartUploads(ctx, bucket any) *gomock.Call

ListMultipartUploads indicates an expected call of ListMultipartUploads.

func (*MockStorageClientMockRecorder) ListObjects 

func (mr *MockStorageClientMockRecorder) ListObjects(ctx, bucket, prefix any) *gomock.Call

ListObjects indicates an expected call of ListObjects.

func (*MockStorageClientMockRecorder) ListObjectsPage 

func (mr *MockStorageClientMockRecorder) ListObjectsPage(ctx, bucket, prefix, limit any) *gomock.Call

ListObjectsPage indicates an expected call of ListObjectsPage.

func (*MockStorageClientMockRecorder) ListObjectsPageToken 

func (mr *MockStorageClientMockRecorder) ListObjectsPageToken(ctx, bucket, prefix, continuationToken, limit any) *gomock.Call

ListObjectsPageToken indicates an expected call of ListObjectsPageToken.

func (*MockStorageClientMockRecorder) PresignPutURL 

func (mr *MockStorageClientMockRecorder) PresignPutURL(ctx, bucket, key, expirySeconds, contentType any) *gomock.Call

PresignPutURL indicates an expected call of PresignPutURL.

func (*MockStorageClientMockRecorder) PresignURL 

func (mr *MockStorageClientMockRecorder) PresignURL(ctx, bucket, key, expirySeconds, displayFilename any) *gomock.Call

PresignURL indicates an expected call of PresignURL.

func (*MockStorageClientMockRecorder) PresignUploadPart 

func (mr *MockStorageClientMockRecorder) PresignUploadPart(ctx, bucket, key, uploadID, partNumber, expirySeconds any) *gomock.Call

PresignUploadPart indicates an expected call of PresignUploadPart.

func (*MockStorageClientMockRecorder) Stat 

func (mr *MockStorageClientMockRecorder) Stat(ctx, bucket, key any) *gomock.Call

Stat indicates an expected call of Stat.

func (*MockStorageClientMockRecorder) Upload 

func (mr *MockStorageClientMockRecorder) Upload(ctx, bucket, key, body, contentType any) *gomock.Call

Upload indicates an expected call of Upload.

type MockStore 

type MockStore[T any, P any, ID comparable] struct {
	// contains filtered or unexported fields
}

MockStore is a mock of Store interface.

func NewMockStore 

func NewMockStore[T any, P any, ID comparable](ctrl *gomock.Controller) *MockStore[T, P, ID]

NewMockStore creates a new mock instance.

func (*MockStore[T, P, ID]) Create 

func (m *MockStore[T, P, ID]) Create(ctx context.Context, in *T) (*T, error)

Create mocks base method.

func (*MockStore[T, P, ID]) Delete 

func (m *MockStore[T, P, ID]) Delete(ctx context.Context, id ID) error

Delete mocks base method.

func (*MockStore[T, P, ID]) EXPECT 

func (m *MockStore[T, P, ID]) EXPECT() *MockStoreMockRecorder[T, P, ID]

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

func (*MockStore[T, P, ID]) Exists 

func (m *MockStore[T, P, ID]) Exists(ctx context.Context, id ID) (bool, error)

Exists mocks base method.

func (*MockStore[T, P, ID]) Get 

func (m *MockStore[T, P, ID]) Get(ctx context.Context, id ID) (*T, error)

Get mocks base method.

func (*MockStore[T, P, ID]) List 

func (m *MockStore[T, P, ID]) List(ctx context.Context, params P, page types.PageRequest) (*types.Page[T], error)

List mocks base method.

func (*MockStore[T, P, ID]) Update 

func (m *MockStore[T, P, ID]) Update(ctx context.Context, id ID, in *T) (*T, error)

Update mocks base method.

type MockStoreMockRecorder 

type MockStoreMockRecorder[T any, P any, ID comparable] struct {
	// contains filtered or unexported fields
}

MockStoreMockRecorder is the mock recorder for MockStore.

func (*MockStoreMockRecorder[T, P, ID]) Create 

func (mr *MockStoreMockRecorder[T, P, ID]) Create(ctx, in any) *gomock.Call

Create indicates an expected call of Create.

func (*MockStoreMockRecorder[T, P, ID]) Delete 

func (mr *MockStoreMockRecorder[T, P, ID]) Delete(ctx, id any) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockStoreMockRecorder[T, P, ID]) Exists 

func (mr *MockStoreMockRecorder[T, P, ID]) Exists(ctx, id any) *gomock.Call

Exists indicates an expected call of Exists.

func (*MockStoreMockRecorder[T, P, ID]) Get 

func (mr *MockStoreMockRecorder[T, P, ID]) Get(ctx, id any) *gomock.Call

Get indicates an expected call of Get.

func (*MockStoreMockRecorder[T, P, ID]) List 

func (mr *MockStoreMockRecorder[T, P, ID]) List(ctx, params, page any) *gomock.Call

List indicates an expected call of List.

func (*MockStoreMockRecorder[T, P, ID]) Update 

func (mr *MockStoreMockRecorder[T, P, ID]) Update(ctx, id, in any) *gomock.Call

Update indicates an expected call of Update.

type MockStream added in v0.0.3 

type MockStream[T any] struct {
	// contains filtered or unexported fields
}

MockStream is a mock of Stream interface.

func NewMockStream added in v0.0.3 

func NewMockStream[T any](ctrl *gomock.Controller) *MockStream[T]

NewMockStream creates a new mock instance.

func (*MockStream[T]) Close added in v0.0.3 

func (m *MockStream[T]) Close() error

Close mocks base method.

func (*MockStream[T]) EXPECT added in v0.0.3 

func (m *MockStream[T]) EXPECT() *MockStreamMockRecorder[T]

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

func (*MockStream[T]) Next added in v0.0.3 

func (m *MockStream[T]) Next(ctx context.Context) (T, bool, error)

Next mocks base method.

type MockStreamMockRecorder added in v0.0.3 

type MockStreamMockRecorder[T any] struct {
	// contains filtered or unexported fields
}

MockStreamMockRecorder is the mock recorder for MockStream.

func (*MockStreamMockRecorder[T]) Close added in v0.0.3 

func (mr *MockStreamMockRecorder[T]) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockStreamMockRecorder[T]) Next added in v0.0.3 

func (mr *MockStreamMockRecorder[T]) Next(ctx any) *gomock.Call

Next indicates an expected call of Next.

type MockStreamingHandlerConn 

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

MockStreamingHandlerConn is a mock of StreamingHandlerConn interface.

func NewMockStreamingHandlerConn 

func NewMockStreamingHandlerConn(ctrl *gomock.Controller) *MockStreamingHandlerConn

NewMockStreamingHandlerConn creates a new mock instance.

func (*MockStreamingHandlerConn) EXPECT 

func (m *MockStreamingHandlerConn) EXPECT() *MockStreamingHandlerConnMockRecorder

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

func (*MockStreamingHandlerConn) Peer 

func (m *MockStreamingHandlerConn) Peer() connect.Peer

Peer mocks base method.

func (*MockStreamingHandlerConn) Receive 

func (m *MockStreamingHandlerConn) Receive(arg0 any) error

Receive mocks base method.

func (*MockStreamingHandlerConn) RequestHeader 

func (m *MockStreamingHandlerConn) RequestHeader() http.Header

RequestHeader mocks base method.

func (*MockStreamingHandlerConn) ResponseHeader 

func (m *MockStreamingHandlerConn) ResponseHeader() http.Header

ResponseHeader mocks base method.

func (*MockStreamingHandlerConn) ResponseTrailer 

func (m *MockStreamingHandlerConn) ResponseTrailer() http.Header

ResponseTrailer mocks base method.

func (*MockStreamingHandlerConn) Send 

func (m *MockStreamingHandlerConn) Send(arg0 any) error

Send mocks base method.

func (*MockStreamingHandlerConn) Spec 

func (m *MockStreamingHandlerConn) Spec() connect.Spec

Spec mocks base method.

type MockStreamingHandlerConnMockRecorder 

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

MockStreamingHandlerConnMockRecorder is the mock recorder for MockStreamingHandlerConn.

func (*MockStreamingHandlerConnMockRecorder) Peer 

func (mr *MockStreamingHandlerConnMockRecorder) Peer() *gomock.Call

Peer indicates an expected call of Peer.

func (*MockStreamingHandlerConnMockRecorder) Receive 

func (mr *MockStreamingHandlerConnMockRecorder) Receive(arg0 any) *gomock.Call

Receive indicates an expected call of Receive.

func (*MockStreamingHandlerConnMockRecorder) RequestHeader 

func (mr *MockStreamingHandlerConnMockRecorder) RequestHeader() *gomock.Call

RequestHeader indicates an expected call of RequestHeader.

func (*MockStreamingHandlerConnMockRecorder) ResponseHeader 

func (mr *MockStreamingHandlerConnMockRecorder) ResponseHeader() *gomock.Call

ResponseHeader indicates an expected call of ResponseHeader.

func (*MockStreamingHandlerConnMockRecorder) ResponseTrailer 

func (mr *MockStreamingHandlerConnMockRecorder) ResponseTrailer() *gomock.Call

ResponseTrailer indicates an expected call of ResponseTrailer.

func (*MockStreamingHandlerConnMockRecorder) Send 

func (mr *MockStreamingHandlerConnMockRecorder) Send(arg0 any) *gomock.Call

Send indicates an expected call of Send.

func (*MockStreamingHandlerConnMockRecorder) Spec 

func (mr *MockStreamingHandlerConnMockRecorder) Spec() *gomock.Call

Spec indicates an expected call of Spec.

type MockSuggester added in v0.0.11 

type MockSuggester[P any] struct {
	// contains filtered or unexported fields
}

MockSuggester is a mock of Suggester interface.

func NewMockSuggester added in v0.0.11 

func NewMockSuggester[P any](ctrl *gomock.Controller) *MockSuggester[P]

NewMockSuggester creates a new mock instance.

func (*MockSuggester[P]) EXPECT added in v0.0.11 

func (m *MockSuggester[P]) EXPECT() *MockSuggesterMockRecorder[P]

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

func (*MockSuggester[P]) SuggestValues added in v0.0.11 

func (m *MockSuggester[P]) SuggestValues(ctx context.Context, params P) (*types.Page[string], error)

SuggestValues mocks base method.

type MockSuggesterMockRecorder added in v0.0.11 

type MockSuggesterMockRecorder[P any] struct {
	// contains filtered or unexported fields
}

MockSuggesterMockRecorder is the mock recorder for MockSuggester.

func (*MockSuggesterMockRecorder[P]) SuggestValues added in v0.0.11 

func (mr *MockSuggesterMockRecorder[P]) SuggestValues(ctx, params any) *gomock.Call

SuggestValues indicates an expected call of SuggestValues.

type MockToolSpec 

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

MockToolSpec is a mock of ToolSpec interface.

func NewMockToolSpec 

func NewMockToolSpec(ctrl *gomock.Controller) *MockToolSpec

NewMockToolSpec creates a new mock instance.

func (*MockToolSpec) Binary 

func (m *MockToolSpec) Binary() string

Binary mocks base method.

func (*MockToolSpec) Cmd 

func (m *MockToolSpec) Cmd(args ...string) (string, []string)

Cmd mocks base method.

func (*MockToolSpec) EXPECT 

func (m *MockToolSpec) EXPECT() *MockToolSpecMockRecorder

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

func (*MockToolSpec) InstallHint 

func (m *MockToolSpec) InstallHint() string

InstallHint mocks base method.

func (*MockToolSpec) Name 

func (m *MockToolSpec) Name() string

Name mocks base method.

type MockToolSpecMockRecorder 

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

MockToolSpecMockRecorder is the mock recorder for MockToolSpec.

func (*MockToolSpecMockRecorder) Binary 

func (mr *MockToolSpecMockRecorder) Binary() *gomock.Call

Binary indicates an expected call of Binary.

func (*MockToolSpecMockRecorder) Cmd 

func (mr *MockToolSpecMockRecorder) Cmd(args ...any) *gomock.Call

Cmd indicates an expected call of Cmd.

func (*MockToolSpecMockRecorder) InstallHint 

func (mr *MockToolSpecMockRecorder) InstallHint() *gomock.Call

InstallHint indicates an expected call of InstallHint.

func (*MockToolSpecMockRecorder) Name 

func (mr *MockToolSpecMockRecorder) Name() *gomock.Call

Name indicates an expected call of Name.

type MockTracer 

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

MockTracer is a mock of Tracer interface.

func NewMockTracer 

func NewMockTracer(ctrl *gomock.Controller) *MockTracer

NewMockTracer creates a new mock instance.

func (*MockTracer) EXPECT 

func (m *MockTracer) EXPECT() *MockTracerMockRecorder

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

func (*MockTracer) Shutdown 

func (m *MockTracer) Shutdown(ctx context.Context) error

Shutdown mocks base method.

func (*MockTracer) Start 

func (m *MockTracer) Start(ctx context.Context, name string, opts ...interfaces.SpanOption) (context.Context, interfaces.Span)

Start mocks base method.

type MockTracerMockRecorder 

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

MockTracerMockRecorder is the mock recorder for MockTracer.

func (*MockTracerMockRecorder) Shutdown 

func (mr *MockTracerMockRecorder) Shutdown(ctx any) *gomock.Call

Shutdown indicates an expected call of Shutdown.

func (*MockTracerMockRecorder) Start 

func (mr *MockTracerMockRecorder) Start(ctx, name any, opts ...any) *gomock.Call

Start indicates an expected call of Start.

type MockTransaction added in v0.0.4 

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

MockTransaction is a mock of Transaction interface.

func NewMockTransaction added in v0.0.4 

func NewMockTransaction(ctrl *gomock.Controller) *MockTransaction

NewMockTransaction creates a new mock instance.

func (*MockTransaction) Commit added in v0.0.4 

func (m *MockTransaction) Commit() error

Commit mocks base method.

func (*MockTransaction) EXPECT added in v0.0.4 

func (m *MockTransaction) EXPECT() *MockTransactionMockRecorder

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

func (*MockTransaction) Rollback added in v0.0.4 

func (m *MockTransaction) Rollback() error

Rollback mocks base method.

type MockTransactionManager 

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

MockTransactionManager is a mock of TransactionManager interface.

func NewMockTransactionManager 

func NewMockTransactionManager(ctrl *gomock.Controller) *MockTransactionManager

NewMockTransactionManager creates a new mock instance.

func (*MockTransactionManager) Begin 

func (m *MockTransactionManager) Begin(ctx context.Context) (context.Context, interfaces.Transaction, error)

Begin mocks base method.

func (*MockTransactionManager) EXPECT 

func (m *MockTransactionManager) EXPECT() *MockTransactionManagerMockRecorder

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

func (*MockTransactionManager) WithTransaction 

func (m *MockTransactionManager) WithTransaction(ctx context.Context, fn func(context.Context) error) error

WithTransaction mocks base method.

type MockTransactionManagerMockRecorder 

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

MockTransactionManagerMockRecorder is the mock recorder for MockTransactionManager.

func (*MockTransactionManagerMockRecorder) Begin 

func (mr *MockTransactionManagerMockRecorder) Begin(ctx any) *gomock.Call

Begin indicates an expected call of Begin.

func (*MockTransactionManagerMockRecorder) WithTransaction 

func (mr *MockTransactionManagerMockRecorder) WithTransaction(ctx, fn any) *gomock.Call

WithTransaction indicates an expected call of WithTransaction.

type MockTransactionMockRecorder added in v0.0.4 

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

MockTransactionMockRecorder is the mock recorder for MockTransaction.

func (*MockTransactionMockRecorder) Commit added in v0.0.4 

func (mr *MockTransactionMockRecorder) Commit() *gomock.Call

Commit indicates an expected call of Commit.

func (*MockTransactionMockRecorder) Rollback added in v0.0.4 

func (mr *MockTransactionMockRecorder) Rollback() *gomock.Call

Rollback indicates an expected call of Rollback.

type MockUpdater added in v0.0.7 

type MockUpdater[T any, ID comparable, U any] struct {
	// contains filtered or unexported fields
}

MockUpdater is a mock of Updater interface.

func NewMockUpdater added in v0.0.7 

func NewMockUpdater[T any, ID comparable, U any](ctrl *gomock.Controller) *MockUpdater[T, ID, U]

NewMockUpdater creates a new mock instance.

func (*MockUpdater[T, ID, U]) EXPECT added in v0.0.7 

func (m *MockUpdater[T, ID, U]) EXPECT() *MockUpdaterMockRecorder[T, ID, U]

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

func (*MockUpdater[T, ID, U]) Update added in v0.0.7 

func (m *MockUpdater[T, ID, U]) Update(ctx context.Context, id ID, in U) (*T, error)

Update mocks base method.

type MockUpdaterMockRecorder added in v0.0.7 

type MockUpdaterMockRecorder[T any, ID comparable, U any] struct {
	// contains filtered or unexported fields
}

MockUpdaterMockRecorder is the mock recorder for MockUpdater.

func (*MockUpdaterMockRecorder[T, ID, U]) Update added in v0.0.7 

func (mr *MockUpdaterMockRecorder[T, ID, U]) Update(ctx, id, in any) *gomock.Call

Update indicates an expected call of Update.

type MockWorkflow 

type MockWorkflow[In any, Out any] struct {
	// contains filtered or unexported fields
}

MockWorkflow is a mock of Workflow interface.

func NewMockWorkflow 

func NewMockWorkflow[In any, Out any](ctrl *gomock.Controller) *MockWorkflow[In, Out]

NewMockWorkflow creates a new mock instance.

func (*MockWorkflow[In, Out]) EXPECT 

func (m *MockWorkflow[In, Out]) EXPECT() *MockWorkflowMockRecorder[In, Out]

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

func (*MockWorkflow[In, Out]) Execute 

func (m *MockWorkflow[In, Out]) Execute(ctx context.Context, input In) (Out, error)

Execute mocks base method.

type MockWorkflowMockRecorder 

type MockWorkflowMockRecorder[In any, Out any] struct {
	// contains filtered or unexported fields
}

MockWorkflowMockRecorder is the mock recorder for MockWorkflow.

func (*MockWorkflowMockRecorder[In, Out]) Execute 

func (mr *MockWorkflowMockRecorder[In, Out]) Execute(ctx, input any) *gomock.Call

Execute indicates an expected call of Execute.

type MockWriter added in v0.0.7 

type MockWriter[T any, ID comparable] struct {
	// contains filtered or unexported fields
}

MockWriter is a mock of Writer interface.

func NewMockWriter added in v0.0.7 

func NewMockWriter[T any, ID comparable](ctrl *gomock.Controller) *MockWriter[T, ID]

NewMockWriter creates a new mock instance.

func (*MockWriter[T, ID]) Create added in v0.0.7 

func (m *MockWriter[T, ID]) Create(ctx context.Context, in *T) (*T, error)

Create mocks base method.

func (*MockWriter[T, ID]) EXPECT added in v0.0.7 

func (m *MockWriter[T, ID]) EXPECT() *MockWriterMockRecorder[T, ID]

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

func (*MockWriter[T, ID]) Update added in v0.0.7 

func (m *MockWriter[T, ID]) Update(ctx context.Context, id ID, in *T) (*T, error)

Update mocks base method.

type MockWriterMockRecorder added in v0.0.7 

type MockWriterMockRecorder[T any, ID comparable] struct {
	// contains filtered or unexported fields
}

MockWriterMockRecorder is the mock recorder for MockWriter.

func (*MockWriterMockRecorder[T, ID]) Create added in v0.0.7 

func (mr *MockWriterMockRecorder[T, ID]) Create(ctx, in any) *gomock.Call

Create indicates an expected call of Create.

func (*MockWriterMockRecorder[T, ID]) Update added in v0.0.7 

func (mr *MockWriterMockRecorder[T, ID]) Update(ctx, id, in any) *gomock.Call

Update indicates an expected call of Update.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.