Documentation
¶
Overview ¶
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Index ¶
- type MockAnalyzer
- type MockAnalyzerMockRecorder
- type MockCouchbaseIRepo
- func (m *MockCouchbaseIRepo) CreateCollection(scope, name string) error
- func (m *MockCouchbaseIRepo) CreateIndex(query string) error
- func (m *MockCouchbaseIRepo) CreateScope(name string) error
- func (m *MockCouchbaseIRepo) EXPECT() *MockCouchbaseIRepoMockRecorder
- func (m *MockCouchbaseIRepo) GetAllScopes() ([]gocb.ScopeSpec, error)
- func (m *MockCouchbaseIRepo) Init(uri string, opts *option.Options) error
- func (m *MockCouchbaseIRepo) UpsertData(scope, collection string, docs []gocb.BulkOp) error
- type MockCouchbaseIRepoMockRecorder
- func (mr *MockCouchbaseIRepoMockRecorder) CreateCollection(scope, name any) *gomock.Call
- func (mr *MockCouchbaseIRepoMockRecorder) CreateIndex(query any) *gomock.Call
- func (mr *MockCouchbaseIRepoMockRecorder) CreateScope(name any) *gomock.Call
- func (mr *MockCouchbaseIRepoMockRecorder) GetAllScopes() *gomock.Call
- func (mr *MockCouchbaseIRepoMockRecorder) Init(uri, opts any) *gomock.Call
- func (mr *MockCouchbaseIRepoMockRecorder) UpsertData(scope, collection, docs any) *gomock.Call
- type MockDynamoDbIPaginator
- type MockDynamoDbIPaginatorMockRecorder
- type MockDynamoDbIRepo
- func (m *MockDynamoDbIRepo) EXPECT() *MockDynamoDbIRepoMockRecorder
- func (m *MockDynamoDbIRepo) GetIndexes(ctx context.Context) ([]repo.Index, error)
- func (m *MockDynamoDbIRepo) GetPrimaryIndex(ctx context.Context) (repo.Index, error)
- func (m *MockDynamoDbIRepo) Init(opts *option.Options) error
- func (m *MockDynamoDbIRepo) NewPaginator(segment, totalSegments, limit int32) repo.IPaginator
- type MockDynamoDbIRepoMockRecorder
- func (mr *MockDynamoDbIRepoMockRecorder) GetIndexes(ctx any) *gomock.Call
- func (mr *MockDynamoDbIRepoMockRecorder) GetPrimaryIndex(ctx any) *gomock.Call
- func (mr *MockDynamoDbIRepoMockRecorder) Init(opts any) *gomock.Call
- func (mr *MockDynamoDbIRepoMockRecorder) NewPaginator(segment, totalSegments, limit any) *gomock.Call
- type MockIDestination
- func (m *MockIDestination) Complete() error
- func (m *MockIDestination) CreateIndexes(indexes []common.Index) error
- func (m *MockIDestination) EXPECT() *MockIDestinationMockRecorder
- func (m *MockIDestination) Init(opts *option.Options, documentKey common.ICBDocumentKey) error
- func (m *MockIDestination) ProcessData(arg0 map[string]any) error
- type MockIDestinationMockRecorder
- type MockIMigrate
- type MockIMigrateMockRecorder
- type MockISource
- func (m *MockISource[Options]) EXPECT() *MockISourceMockRecorder[Options]
- func (m *MockISource[Options]) GetCouchbaseIndexesQuery(bucket, scope, collection string) ([]common.Index, error)
- func (m *MockISource[Options]) Init(opts *Options, documentKey common.ICBDocumentKey) error
- func (m *MockISource[Options]) StreamData(arg0 context.Context, arg1 chan map[string]any) error
- type MockISourceMockRecorder
- type MockMongoICursor
- type MockMongoICursorMockRecorder
- type MockMongoIRepo
- func (m *MockMongoIRepo) EXPECT() *MockMongoIRepoMockRecorder
- func (m *MockMongoIRepo) Find(collection string, ctx context.Context, filter any, ...) (repo.ICursor, error)
- func (m *MockMongoIRepo) GetIndexes(ctx context.Context, collection string) ([]repo.Indexes, error)
- func (m *MockMongoIRepo) Init(opts *option.Options) error
- type MockMongoIRepoMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockAnalyzer ¶
type MockAnalyzer struct {
// contains filtered or unexported fields
}
MockAnalyzer is a mock of Analyzer interface.
func NewMockAnalyzer ¶
func NewMockAnalyzer(ctrl *gomock.Controller) *MockAnalyzer
NewMockAnalyzer creates a new mock instance.
func (*MockAnalyzer) AnalyzeData ¶
func (m *MockAnalyzer) AnalyzeData(data map[string]any)
AnalyzeData mocks base method.
func (*MockAnalyzer) EXPECT ¶
func (m *MockAnalyzer) EXPECT() *MockAnalyzerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockAnalyzer) GetCouchbaseQuery ¶
func (m *MockAnalyzer) GetCouchbaseQuery(bucket, scope, collection string) []common.Index
GetCouchbaseQuery mocks base method.
func (*MockAnalyzer) Init ¶
func (m *MockAnalyzer) Init(index []mongo.Index, documentKey common.ICBDocumentKey)
Init mocks base method.
type MockAnalyzerMockRecorder ¶
type MockAnalyzerMockRecorder struct {
// contains filtered or unexported fields
}
MockAnalyzerMockRecorder is the mock recorder for MockAnalyzer.
func (*MockAnalyzerMockRecorder) AnalyzeData ¶
func (mr *MockAnalyzerMockRecorder) AnalyzeData(data any) *gomock.Call
AnalyzeData indicates an expected call of AnalyzeData.
func (*MockAnalyzerMockRecorder) GetCouchbaseQuery ¶
func (mr *MockAnalyzerMockRecorder) GetCouchbaseQuery(bucket, scope, collection any) *gomock.Call
GetCouchbaseQuery indicates an expected call of GetCouchbaseQuery.
type MockCouchbaseIRepo ¶
type MockCouchbaseIRepo struct {
// contains filtered or unexported fields
}
MockCouchbaseIRepo is a mock of IRepo interface.
func NewMockCouchbaseIRepo ¶
func NewMockCouchbaseIRepo(ctrl *gomock.Controller) *MockCouchbaseIRepo
NewMockCouchbaseIRepo creates a new mock instance.
func (*MockCouchbaseIRepo) CreateCollection ¶
func (m *MockCouchbaseIRepo) CreateCollection(scope, name string) error
CreateCollection mocks base method.
func (*MockCouchbaseIRepo) CreateIndex ¶
func (m *MockCouchbaseIRepo) CreateIndex(query string) error
CreateIndex mocks base method.
func (*MockCouchbaseIRepo) CreateScope ¶
func (m *MockCouchbaseIRepo) CreateScope(name string) error
CreateScope mocks base method.
func (*MockCouchbaseIRepo) EXPECT ¶
func (m *MockCouchbaseIRepo) EXPECT() *MockCouchbaseIRepoMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockCouchbaseIRepo) GetAllScopes ¶
func (m *MockCouchbaseIRepo) GetAllScopes() ([]gocb.ScopeSpec, error)
GetAllScopes mocks base method.
func (*MockCouchbaseIRepo) Init ¶
func (m *MockCouchbaseIRepo) Init(uri string, opts *option.Options) error
Init mocks base method.
func (*MockCouchbaseIRepo) UpsertData ¶
func (m *MockCouchbaseIRepo) UpsertData(scope, collection string, docs []gocb.BulkOp) error
UpsertData mocks base method.
type MockCouchbaseIRepoMockRecorder ¶
type MockCouchbaseIRepoMockRecorder struct {
// contains filtered or unexported fields
}
MockCouchbaseIRepoMockRecorder is the mock recorder for MockCouchbaseIRepo.
func (*MockCouchbaseIRepoMockRecorder) CreateCollection ¶
func (mr *MockCouchbaseIRepoMockRecorder) CreateCollection(scope, name any) *gomock.Call
CreateCollection indicates an expected call of CreateCollection.
func (*MockCouchbaseIRepoMockRecorder) CreateIndex ¶
func (mr *MockCouchbaseIRepoMockRecorder) CreateIndex(query any) *gomock.Call
CreateIndex indicates an expected call of CreateIndex.
func (*MockCouchbaseIRepoMockRecorder) CreateScope ¶
func (mr *MockCouchbaseIRepoMockRecorder) CreateScope(name any) *gomock.Call
CreateScope indicates an expected call of CreateScope.
func (*MockCouchbaseIRepoMockRecorder) GetAllScopes ¶
func (mr *MockCouchbaseIRepoMockRecorder) GetAllScopes() *gomock.Call
GetAllScopes indicates an expected call of GetAllScopes.
func (*MockCouchbaseIRepoMockRecorder) Init ¶
func (mr *MockCouchbaseIRepoMockRecorder) Init(uri, opts any) *gomock.Call
Init indicates an expected call of Init.
func (*MockCouchbaseIRepoMockRecorder) UpsertData ¶
func (mr *MockCouchbaseIRepoMockRecorder) UpsertData(scope, collection, docs any) *gomock.Call
UpsertData indicates an expected call of UpsertData.
type MockDynamoDbIPaginator ¶
type MockDynamoDbIPaginator struct {
// contains filtered or unexported fields
}
MockDynamoDbIPaginator is a mock of IPaginator interface.
func NewMockDynamoDbIPaginator ¶
func NewMockDynamoDbIPaginator(ctrl *gomock.Controller) *MockDynamoDbIPaginator
NewMockDynamoDbIPaginator creates a new mock instance.
func (*MockDynamoDbIPaginator) EXPECT ¶
func (m *MockDynamoDbIPaginator) EXPECT() *MockDynamoDbIPaginatorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDynamoDbIPaginator) HasMorePages ¶
func (m *MockDynamoDbIPaginator) HasMorePages() bool
HasMorePages mocks base method.
func (*MockDynamoDbIPaginator) NextPage ¶
func (m *MockDynamoDbIPaginator) NextPage(ctx context.Context, optFns ...func(*dynamodb.Options)) (*dynamodb.ScanOutput, error)
NextPage mocks base method.
type MockDynamoDbIPaginatorMockRecorder ¶
type MockDynamoDbIPaginatorMockRecorder struct {
// contains filtered or unexported fields
}
MockDynamoDbIPaginatorMockRecorder is the mock recorder for MockDynamoDbIPaginator.
func (*MockDynamoDbIPaginatorMockRecorder) HasMorePages ¶
func (mr *MockDynamoDbIPaginatorMockRecorder) HasMorePages() *gomock.Call
HasMorePages indicates an expected call of HasMorePages.
type MockDynamoDbIRepo ¶
type MockDynamoDbIRepo struct {
// contains filtered or unexported fields
}
MockDynamoDbIRepo is a mock of IRepo interface.
func NewMockDynamoDbIRepo ¶
func NewMockDynamoDbIRepo(ctrl *gomock.Controller) *MockDynamoDbIRepo
NewMockDynamoDbIRepo creates a new mock instance.
func (*MockDynamoDbIRepo) EXPECT ¶
func (m *MockDynamoDbIRepo) EXPECT() *MockDynamoDbIRepoMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDynamoDbIRepo) GetIndexes ¶
GetIndexes mocks base method.
func (*MockDynamoDbIRepo) GetPrimaryIndex ¶
GetPrimaryIndex mocks base method.
func (*MockDynamoDbIRepo) Init ¶
func (m *MockDynamoDbIRepo) Init(opts *option.Options) error
Init mocks base method.
func (*MockDynamoDbIRepo) NewPaginator ¶
func (m *MockDynamoDbIRepo) NewPaginator(segment, totalSegments, limit int32) repo.IPaginator
NewPaginator mocks base method.
type MockDynamoDbIRepoMockRecorder ¶
type MockDynamoDbIRepoMockRecorder struct {
// contains filtered or unexported fields
}
MockDynamoDbIRepoMockRecorder is the mock recorder for MockDynamoDbIRepo.
func (*MockDynamoDbIRepoMockRecorder) GetIndexes ¶
func (mr *MockDynamoDbIRepoMockRecorder) GetIndexes(ctx any) *gomock.Call
GetIndexes indicates an expected call of GetIndexes.
func (*MockDynamoDbIRepoMockRecorder) GetPrimaryIndex ¶
func (mr *MockDynamoDbIRepoMockRecorder) GetPrimaryIndex(ctx any) *gomock.Call
GetPrimaryIndex indicates an expected call of GetPrimaryIndex.
func (*MockDynamoDbIRepoMockRecorder) Init ¶
func (mr *MockDynamoDbIRepoMockRecorder) Init(opts any) *gomock.Call
Init indicates an expected call of Init.
func (*MockDynamoDbIRepoMockRecorder) NewPaginator ¶
func (mr *MockDynamoDbIRepoMockRecorder) NewPaginator(segment, totalSegments, limit any) *gomock.Call
NewPaginator indicates an expected call of NewPaginator.
type MockIDestination ¶
type MockIDestination struct {
// contains filtered or unexported fields
}
MockIDestination is a mock of IDestination interface.
func NewMockIDestination ¶
func NewMockIDestination(ctrl *gomock.Controller) *MockIDestination
NewMockIDestination creates a new mock instance.
func (*MockIDestination) Complete ¶
func (m *MockIDestination) Complete() error
Complete mocks base method.
func (*MockIDestination) CreateIndexes ¶
func (m *MockIDestination) CreateIndexes(indexes []common.Index) error
CreateIndexes mocks base method.
func (*MockIDestination) EXPECT ¶
func (m *MockIDestination) EXPECT() *MockIDestinationMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockIDestination) Init ¶
func (m *MockIDestination) Init(opts *option.Options, documentKey common.ICBDocumentKey) error
Init mocks base method.
func (*MockIDestination) ProcessData ¶
func (m *MockIDestination) ProcessData(arg0 map[string]any) error
ProcessData mocks base method.
type MockIDestinationMockRecorder ¶
type MockIDestinationMockRecorder struct {
// contains filtered or unexported fields
}
MockIDestinationMockRecorder is the mock recorder for MockIDestination.
func (*MockIDestinationMockRecorder) Complete ¶
func (mr *MockIDestinationMockRecorder) Complete() *gomock.Call
Complete indicates an expected call of Complete.
func (*MockIDestinationMockRecorder) CreateIndexes ¶
func (mr *MockIDestinationMockRecorder) CreateIndexes(indexes any) *gomock.Call
CreateIndexes indicates an expected call of CreateIndexes.
func (*MockIDestinationMockRecorder) Init ¶
func (mr *MockIDestinationMockRecorder) Init(opts, documentKey any) *gomock.Call
Init indicates an expected call of Init.
func (*MockIDestinationMockRecorder) ProcessData ¶
func (mr *MockIDestinationMockRecorder) ProcessData(arg0 any) *gomock.Call
ProcessData indicates an expected call of ProcessData.
type MockIMigrate ¶
type MockIMigrate[Options any] struct { // contains filtered or unexported fields }
MockIMigrate is a mock of IMigrate interface.
func NewMockIMigrate ¶
func NewMockIMigrate[Options any](ctrl *gomock.Controller) *MockIMigrate[Options]
NewMockIMigrate creates a new mock instance.
func (*MockIMigrate[Options]) Copy ¶
func (m *MockIMigrate[Options]) Copy(mOpts *Options, cbOpts *option.Options, copyIndexes bool, bufferSize int) error
Copy mocks base method.
func (*MockIMigrate[Options]) EXPECT ¶
func (m *MockIMigrate[Options]) EXPECT() *MockIMigrateMockRecorder[Options]
EXPECT returns an object that allows the caller to indicate expected use.
type MockIMigrateMockRecorder ¶
type MockIMigrateMockRecorder[Options any] struct { // contains filtered or unexported fields }
MockIMigrateMockRecorder is the mock recorder for MockIMigrate.
type MockISource ¶
type MockISource[Options any] struct { // contains filtered or unexported fields }
MockISource is a mock of ISource interface.
func NewMockISource ¶
func NewMockISource[Options any](ctrl *gomock.Controller) *MockISource[Options]
NewMockISource creates a new mock instance.
func (*MockISource[Options]) EXPECT ¶
func (m *MockISource[Options]) EXPECT() *MockISourceMockRecorder[Options]
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockISource[Options]) GetCouchbaseIndexesQuery ¶
func (m *MockISource[Options]) GetCouchbaseIndexesQuery(bucket, scope, collection string) ([]common.Index, error)
GetCouchbaseIndexesQuery mocks base method.
func (*MockISource[Options]) Init ¶
func (m *MockISource[Options]) Init(opts *Options, documentKey common.ICBDocumentKey) error
Init mocks base method.
func (*MockISource[Options]) StreamData ¶
StreamData mocks base method.
type MockISourceMockRecorder ¶
type MockISourceMockRecorder[Options any] struct { // contains filtered or unexported fields }
MockISourceMockRecorder is the mock recorder for MockISource.
func (*MockISourceMockRecorder[Options]) GetCouchbaseIndexesQuery ¶
func (mr *MockISourceMockRecorder[Options]) GetCouchbaseIndexesQuery(bucket, scope, collection any) *gomock.Call
GetCouchbaseIndexesQuery indicates an expected call of GetCouchbaseIndexesQuery.
func (*MockISourceMockRecorder[Options]) Init ¶
func (mr *MockISourceMockRecorder[Options]) Init(opts, documentKey any) *gomock.Call
Init indicates an expected call of Init.
func (*MockISourceMockRecorder[Options]) StreamData ¶
func (mr *MockISourceMockRecorder[Options]) StreamData(arg0, arg1 any) *gomock.Call
StreamData indicates an expected call of StreamData.
type MockMongoICursor ¶
type MockMongoICursor struct {
// contains filtered or unexported fields
}
MockMongoICursor is a mock of ICursor interface.
func NewMockMongoICursor ¶
func NewMockMongoICursor(ctrl *gomock.Controller) *MockMongoICursor
NewMockMongoICursor creates a new mock instance.
func (*MockMongoICursor) Close ¶
func (m *MockMongoICursor) Close(ctx context.Context) error
Close mocks base method.
func (*MockMongoICursor) Decode ¶
func (m *MockMongoICursor) Decode(val any) error
Decode mocks base method.
func (*MockMongoICursor) EXPECT ¶
func (m *MockMongoICursor) EXPECT() *MockMongoICursorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockMongoICursorMockRecorder ¶
type MockMongoICursorMockRecorder struct {
// contains filtered or unexported fields
}
MockMongoICursorMockRecorder is the mock recorder for MockMongoICursor.
func (*MockMongoICursorMockRecorder) Close ¶
func (mr *MockMongoICursorMockRecorder) Close(ctx any) *gomock.Call
Close indicates an expected call of Close.
func (*MockMongoICursorMockRecorder) Decode ¶
func (mr *MockMongoICursorMockRecorder) Decode(val any) *gomock.Call
Decode indicates an expected call of Decode.
func (*MockMongoICursorMockRecorder) Err ¶
func (mr *MockMongoICursorMockRecorder) Err() *gomock.Call
Err indicates an expected call of Err.
type MockMongoIRepo ¶
type MockMongoIRepo struct {
// contains filtered or unexported fields
}
MockMongoIRepo is a mock of IRepo interface.
func NewMockMongoIRepo ¶
func NewMockMongoIRepo(ctrl *gomock.Controller) *MockMongoIRepo
NewMockMongoIRepo creates a new mock instance.
func (*MockMongoIRepo) EXPECT ¶
func (m *MockMongoIRepo) EXPECT() *MockMongoIRepoMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockMongoIRepo) Find ¶
func (m *MockMongoIRepo) Find(collection string, ctx context.Context, filter any, opts ...*options.FindOptions) (repo.ICursor, error)
Find mocks base method.
func (*MockMongoIRepo) GetIndexes ¶
GetIndexes mocks base method.
type MockMongoIRepoMockRecorder ¶
type MockMongoIRepoMockRecorder struct {
// contains filtered or unexported fields
}
MockMongoIRepoMockRecorder is the mock recorder for MockMongoIRepo.
func (*MockMongoIRepoMockRecorder) Find ¶
func (mr *MockMongoIRepoMockRecorder) Find(collection, ctx, filter any, opts ...any) *gomock.Call
Find indicates an expected call of Find.
func (*MockMongoIRepoMockRecorder) GetIndexes ¶
func (mr *MockMongoIRepoMockRecorder) GetIndexes(ctx, collection any) *gomock.Call
GetIndexes indicates an expected call of GetIndexes.