Documentation
¶
Overview ¶
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Index ¶
- type MockIDGenerator
- type MockIDGeneratorMockRecorder
- type MockProducer
- type MockProducerMockRecorder
- type MockRepository
- func (m *MockRepository) CreateMapTask(arg0 context.Context, arg1 mapreduce.MapTask) error
- func (m *MockRepository) CreateReduceTask(arg0 context.Context, arg1 mapreduce.ReduceTask) error
- func (m *MockRepository) EXPECT() *MockRepositoryMockRecorder
- func (m *MockRepository) GetMapTask(arg0 context.Context, arg1 string) (mapreduce.MapTask, error)
- func (m *MockRepository) GetReduceTask(arg0 context.Context, arg1 string) (mapreduce.ReduceTask, error)
- func (m *MockRepository) QueryMapTasks(arg0 context.Context, arg1 repository.Filter) ([]mapreduce.MapTask, error)
- func (m *MockRepository) QueryReduceTasks(arg0 context.Context, arg1 repository.Filter) ([]mapreduce.ReduceTask, error)
- func (m *MockRepository) Transaction(arg0 context.Context, arg1 func(context.Context) (interface{}, error)) (interface{}, error)
- func (m *MockRepository) UpdateMapTask(arg0 context.Context, arg1 mapreduce.MapTask) error
- func (m *MockRepository) UpdateMapTasks(arg0 context.Context, arg1 []string, arg2 repository.UpdateFields) error
- func (m *MockRepository) UpdateReduceTask(arg0 context.Context, arg1 mapreduce.ReduceTask) error
- func (m *MockRepository) UpdateReduceTasks(arg0 context.Context, arg1 []string, arg2 repository.UpdateFields) error
- type MockRepositoryMockRecorder
- func (mr *MockRepositoryMockRecorder) CreateMapTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRepositoryMockRecorder) CreateReduceTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRepositoryMockRecorder) GetMapTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRepositoryMockRecorder) GetReduceTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRepositoryMockRecorder) QueryMapTasks(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRepositoryMockRecorder) QueryReduceTasks(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRepositoryMockRecorder) Transaction(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRepositoryMockRecorder) UpdateMapTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRepositoryMockRecorder) UpdateMapTasks(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockRepositoryMockRecorder) UpdateReduceTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRepositoryMockRecorder) UpdateReduceTasks(arg0, arg1, arg2 interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockIDGenerator ¶
type MockIDGenerator struct {
// contains filtered or unexported fields
}
MockIDGenerator is a mock of IDGenerator interface.
func NewMockIDGenerator ¶
func NewMockIDGenerator(ctrl *gomock.Controller) *MockIDGenerator
NewMockIDGenerator creates a new mock instance.
func (*MockIDGenerator) EXPECT ¶
func (m *MockIDGenerator) EXPECT() *MockIDGeneratorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockIDGenerator) GetID ¶
func (m *MockIDGenerator) GetID(arg0 context.Context, arg1 ids.EntityType) (string, error)
GetID mocks base method.
type MockIDGeneratorMockRecorder ¶
type MockIDGeneratorMockRecorder struct {
// contains filtered or unexported fields
}
MockIDGeneratorMockRecorder is the mock recorder for MockIDGenerator.
func (*MockIDGeneratorMockRecorder) GetID ¶
func (mr *MockIDGeneratorMockRecorder) GetID(arg0, arg1 interface{}) *gomock.Call
GetID indicates an expected call of GetID.
type MockProducer ¶
type MockProducer struct {
// contains filtered or unexported fields
}
MockProducer is a mock of Producer interface.
func NewMockProducer ¶
func NewMockProducer(ctrl *gomock.Controller) *MockProducer
NewMockProducer creates a new mock instance.
func (*MockProducer) EXPECT ¶
func (m *MockProducer) EXPECT() *MockProducerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockProducerMockRecorder ¶
type MockProducerMockRecorder struct {
// contains filtered or unexported fields
}
MockProducerMockRecorder is the mock recorder for MockProducer.
func (*MockProducerMockRecorder) Produce ¶
func (mr *MockProducerMockRecorder) Produce(arg0, arg1 interface{}) *gomock.Call
Produce indicates an expected call of Produce.
type MockRepository ¶
type MockRepository struct {
// contains filtered or unexported fields
}
MockRepository is a mock of Repository interface.
func NewMockRepository ¶
func NewMockRepository(ctrl *gomock.Controller) *MockRepository
NewMockRepository creates a new mock instance.
func (*MockRepository) CreateMapTask ¶
CreateMapTask mocks base method.
func (*MockRepository) CreateReduceTask ¶
func (m *MockRepository) CreateReduceTask(arg0 context.Context, arg1 mapreduce.ReduceTask) error
CreateReduceTask mocks base method.
func (*MockRepository) EXPECT ¶
func (m *MockRepository) EXPECT() *MockRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockRepository) GetMapTask ¶
GetMapTask mocks base method.
func (*MockRepository) GetReduceTask ¶
func (m *MockRepository) GetReduceTask(arg0 context.Context, arg1 string) (mapreduce.ReduceTask, error)
GetReduceTask mocks base method.
func (*MockRepository) QueryMapTasks ¶
func (m *MockRepository) QueryMapTasks(arg0 context.Context, arg1 repository.Filter) ([]mapreduce.MapTask, error)
QueryMapTasks mocks base method.
func (*MockRepository) QueryReduceTasks ¶
func (m *MockRepository) QueryReduceTasks(arg0 context.Context, arg1 repository.Filter) ([]mapreduce.ReduceTask, error)
QueryReduceTasks mocks base method.
func (*MockRepository) Transaction ¶
func (m *MockRepository) Transaction(arg0 context.Context, arg1 func(context.Context) (interface{}, error)) (interface{}, error)
Transaction mocks base method.
func (*MockRepository) UpdateMapTask ¶
UpdateMapTask mocks base method.
func (*MockRepository) UpdateMapTasks ¶
func (m *MockRepository) UpdateMapTasks(arg0 context.Context, arg1 []string, arg2 repository.UpdateFields) error
UpdateMapTasks mocks base method.
func (*MockRepository) UpdateReduceTask ¶
func (m *MockRepository) UpdateReduceTask(arg0 context.Context, arg1 mapreduce.ReduceTask) error
UpdateReduceTask mocks base method.
func (*MockRepository) UpdateReduceTasks ¶
func (m *MockRepository) UpdateReduceTasks(arg0 context.Context, arg1 []string, arg2 repository.UpdateFields) error
UpdateReduceTasks mocks base method.
type MockRepositoryMockRecorder ¶
type MockRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockRepositoryMockRecorder is the mock recorder for MockRepository.
func (*MockRepositoryMockRecorder) CreateMapTask ¶
func (mr *MockRepositoryMockRecorder) CreateMapTask(arg0, arg1 interface{}) *gomock.Call
CreateMapTask indicates an expected call of CreateMapTask.
func (*MockRepositoryMockRecorder) CreateReduceTask ¶
func (mr *MockRepositoryMockRecorder) CreateReduceTask(arg0, arg1 interface{}) *gomock.Call
CreateReduceTask indicates an expected call of CreateReduceTask.
func (*MockRepositoryMockRecorder) GetMapTask ¶
func (mr *MockRepositoryMockRecorder) GetMapTask(arg0, arg1 interface{}) *gomock.Call
GetMapTask indicates an expected call of GetMapTask.
func (*MockRepositoryMockRecorder) GetReduceTask ¶
func (mr *MockRepositoryMockRecorder) GetReduceTask(arg0, arg1 interface{}) *gomock.Call
GetReduceTask indicates an expected call of GetReduceTask.
func (*MockRepositoryMockRecorder) QueryMapTasks ¶
func (mr *MockRepositoryMockRecorder) QueryMapTasks(arg0, arg1 interface{}) *gomock.Call
QueryMapTasks indicates an expected call of QueryMapTasks.
func (*MockRepositoryMockRecorder) QueryReduceTasks ¶
func (mr *MockRepositoryMockRecorder) QueryReduceTasks(arg0, arg1 interface{}) *gomock.Call
QueryReduceTasks indicates an expected call of QueryReduceTasks.
func (*MockRepositoryMockRecorder) Transaction ¶
func (mr *MockRepositoryMockRecorder) Transaction(arg0, arg1 interface{}) *gomock.Call
Transaction indicates an expected call of Transaction.
func (*MockRepositoryMockRecorder) UpdateMapTask ¶
func (mr *MockRepositoryMockRecorder) UpdateMapTask(arg0, arg1 interface{}) *gomock.Call
UpdateMapTask indicates an expected call of UpdateMapTask.
func (*MockRepositoryMockRecorder) UpdateMapTasks ¶
func (mr *MockRepositoryMockRecorder) UpdateMapTasks(arg0, arg1, arg2 interface{}) *gomock.Call
UpdateMapTasks indicates an expected call of UpdateMapTasks.
func (*MockRepositoryMockRecorder) UpdateReduceTask ¶
func (mr *MockRepositoryMockRecorder) UpdateReduceTask(arg0, arg1 interface{}) *gomock.Call
UpdateReduceTask indicates an expected call of UpdateReduceTask.
func (*MockRepositoryMockRecorder) UpdateReduceTasks ¶
func (mr *MockRepositoryMockRecorder) UpdateReduceTasks(arg0, arg1, arg2 interface{}) *gomock.Call
UpdateReduceTasks indicates an expected call of UpdateReduceTasks.