Documentation
¶
Overview ¶
Package mock_test is a generated GoMock package.
Package mock_test is a generated GoMock package.
Package mock_test is a generated GoMock package.
Package mock_test is a generated GoMock package.
Package mock_test is a generated GoMock package.
Package mock_test 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 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) (common.IDocumentKey, error)
- func (m *MockIDestination) ProcessData(arg0 map[string]any) error
- type MockIDestinationMockRecorder
- type MockIMigrate
- type MockIMigrateMockRecorder
- type MockISource
- func (m *MockISource[Index, Options]) EXPECT() *MockISourceMockRecorder[Index, Options]
- func (m *MockISource[Index, Options]) GetIndexes(ctx context.Context) ([]Index, error)
- func (m *MockISource[Index, Options]) Init(opts *Options) error
- func (m *MockISource[Index, 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[T any] struct { // contains filtered or unexported fields }
MockAnalyzer is a mock of Analyzer interface.
func NewMockAnalyzer ¶
func NewMockAnalyzer[T any](ctrl *gomock.Controller) *MockAnalyzer[T]
NewMockAnalyzer creates a new mock instance.
func (*MockAnalyzer[T]) AnalyzeData ¶
func (m *MockAnalyzer[T]) AnalyzeData(data map[string]any)
AnalyzeData mocks base method.
func (*MockAnalyzer[T]) EXPECT ¶
func (m *MockAnalyzer[T]) EXPECT() *MockAnalyzerMockRecorder[T]
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockAnalyzer[T]) GetCouchbaseQuery ¶
func (m *MockAnalyzer[T]) GetCouchbaseQuery(bucket, scope, collection string) []common.Index
GetCouchbaseQuery mocks base method.
func (*MockAnalyzer[T]) Init ¶
func (m *MockAnalyzer[T]) Init(index []T, suk common.IDocumentKey)
Init mocks base method.
type MockAnalyzerMockRecorder ¶
type MockAnalyzerMockRecorder[T any] struct { // contains filtered or unexported fields }
MockAnalyzerMockRecorder is the mock recorder for MockAnalyzer.
func (*MockAnalyzerMockRecorder[T]) AnalyzeData ¶
func (mr *MockAnalyzerMockRecorder[T]) AnalyzeData(data any) *gomock.Call
AnalyzeData indicates an expected call of AnalyzeData.
func (*MockAnalyzerMockRecorder[T]) GetCouchbaseQuery ¶
func (mr *MockAnalyzerMockRecorder[T]) 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 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) (common.IDocumentKey, 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 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 ¶
MockISource is a mock of ISource interface.
func NewMockISource ¶
func NewMockISource[Index any, Options any](ctrl *gomock.Controller) *MockISource[Index, Options]
NewMockISource creates a new mock instance.
func (*MockISource[Index, Options]) EXPECT ¶
func (m *MockISource[Index, Options]) EXPECT() *MockISourceMockRecorder[Index, Options]
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockISource[Index, Options]) GetIndexes ¶
func (m *MockISource[Index, Options]) GetIndexes(ctx context.Context) ([]Index, error)
GetIndexes mocks base method.
func (*MockISource[Index, Options]) Init ¶
func (m *MockISource[Index, Options]) Init(opts *Options) error
Init mocks base method.
func (*MockISource[Index, Options]) StreamData ¶
func (m *MockISource[Index, Options]) StreamData(arg0 context.Context, arg1 chan map[string]any) error
StreamData mocks base method.
type MockISourceMockRecorder ¶
type MockISourceMockRecorder[Index any, Options any] struct { // contains filtered or unexported fields }
MockISourceMockRecorder is the mock recorder for MockISource.
func (*MockISourceMockRecorder[Index, Options]) GetIndexes ¶
func (mr *MockISourceMockRecorder[Index, Options]) GetIndexes(ctx any) *gomock.Call
GetIndexes indicates an expected call of GetIndexes.
func (*MockISourceMockRecorder[Index, Options]) Init ¶
func (mr *MockISourceMockRecorder[Index, Options]) Init(opts any) *gomock.Call
Init indicates an expected call of Init.
func (*MockISourceMockRecorder[Index, Options]) StreamData ¶
func (mr *MockISourceMockRecorder[Index, 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.
Source Files