Documentation ¶
Overview ¶
Package mocks is a generated GoMock package.
Index ¶
- type MockTasks
- func (m *MockTasks) CreateMapTask(ctx context.Context, task mapreduce.MapTask) error
- func (m *MockTasks) CreateReduceTask(ctx context.Context, task mapreduce.ReduceTask) error
- func (m *MockTasks) EXPECT() *MockTasksMockRecorder
- func (m *MockTasks) GetMapTask(ctx context.Context, id string) (mapreduce.MapTask, error)
- func (m *MockTasks) GetReduceTask(ctx context.Context, id string) (mapreduce.ReduceTask, error)
- func (m *MockTasks) QueryMapTasks(ctx context.Context, filter repository.Filter) ([]mapreduce.MapTask, error)
- func (m *MockTasks) QueryReduceTasks(ctx context.Context, filter repository.Filter) ([]mapreduce.ReduceTask, error)
- func (m *MockTasks) Transaction(ctx context.Context, transaction func(context.Context) (any, error)) (any, error)
- func (m *MockTasks) UpdateMapTask(ctx context.Context, task mapreduce.MapTask) error
- func (m *MockTasks) UpdateMapTasks(ctx context.Context, ids []string, fields repository.UpdateFields) error
- func (m *MockTasks) UpdateReduceTask(ctx context.Context, task mapreduce.ReduceTask) error
- func (m *MockTasks) UpdateReduceTasks(ctx context.Context, ids []string, fields repository.UpdateFields) error
- type MockTasksMockRecorder
- func (mr *MockTasksMockRecorder) CreateMapTask(ctx, task interface{}) *gomock.Call
- func (mr *MockTasksMockRecorder) CreateReduceTask(ctx, task interface{}) *gomock.Call
- func (mr *MockTasksMockRecorder) GetMapTask(ctx, id interface{}) *gomock.Call
- func (mr *MockTasksMockRecorder) GetReduceTask(ctx, id interface{}) *gomock.Call
- func (mr *MockTasksMockRecorder) QueryMapTasks(ctx, filter interface{}) *gomock.Call
- func (mr *MockTasksMockRecorder) QueryReduceTasks(ctx, filter interface{}) *gomock.Call
- func (mr *MockTasksMockRecorder) Transaction(ctx, transaction interface{}) *gomock.Call
- func (mr *MockTasksMockRecorder) UpdateMapTask(ctx, task interface{}) *gomock.Call
- func (mr *MockTasksMockRecorder) UpdateMapTasks(ctx, ids, fields interface{}) *gomock.Call
- func (mr *MockTasksMockRecorder) UpdateReduceTask(ctx, task interface{}) *gomock.Call
- func (mr *MockTasksMockRecorder) UpdateReduceTasks(ctx, ids, fields interface{}) *gomock.Call
- type MockTransaction
- type MockTransactionMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockTasks ¶
type MockTasks struct {
// contains filtered or unexported fields
}
MockTasks is a mock of Tasks interface.
func NewMockTasks ¶
func NewMockTasks(ctrl *gomock.Controller) *MockTasks
NewMockTasks creates a new mock instance.
func (*MockTasks) CreateMapTask ¶
CreateMapTask mocks base method.
func (*MockTasks) CreateReduceTask ¶
CreateReduceTask mocks base method.
func (*MockTasks) EXPECT ¶
func (m *MockTasks) EXPECT() *MockTasksMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockTasks) GetMapTask ¶
GetMapTask mocks base method.
func (*MockTasks) GetReduceTask ¶
GetReduceTask mocks base method.
func (*MockTasks) QueryMapTasks ¶
func (m *MockTasks) QueryMapTasks(ctx context.Context, filter repository.Filter) ([]mapreduce.MapTask, error)
QueryMapTasks mocks base method.
func (*MockTasks) QueryReduceTasks ¶
func (m *MockTasks) QueryReduceTasks(ctx context.Context, filter repository.Filter) ([]mapreduce.ReduceTask, error)
QueryReduceTasks mocks base method.
func (*MockTasks) Transaction ¶
func (m *MockTasks) Transaction(ctx context.Context, transaction func(context.Context) (any, error)) (any, error)
Transaction mocks base method.
func (*MockTasks) UpdateMapTask ¶
UpdateMapTask mocks base method.
func (*MockTasks) UpdateMapTasks ¶
func (m *MockTasks) UpdateMapTasks(ctx context.Context, ids []string, fields repository.UpdateFields) error
UpdateMapTasks mocks base method.
func (*MockTasks) UpdateReduceTask ¶
UpdateReduceTask mocks base method.
func (*MockTasks) UpdateReduceTasks ¶
func (m *MockTasks) UpdateReduceTasks(ctx context.Context, ids []string, fields repository.UpdateFields) error
UpdateReduceTasks mocks base method.
type MockTasksMockRecorder ¶
type MockTasksMockRecorder struct {
// contains filtered or unexported fields
}
MockTasksMockRecorder is the mock recorder for MockTasks.
func (*MockTasksMockRecorder) CreateMapTask ¶
func (mr *MockTasksMockRecorder) CreateMapTask(ctx, task interface{}) *gomock.Call
CreateMapTask indicates an expected call of CreateMapTask.
func (*MockTasksMockRecorder) CreateReduceTask ¶
func (mr *MockTasksMockRecorder) CreateReduceTask(ctx, task interface{}) *gomock.Call
CreateReduceTask indicates an expected call of CreateReduceTask.
func (*MockTasksMockRecorder) GetMapTask ¶
func (mr *MockTasksMockRecorder) GetMapTask(ctx, id interface{}) *gomock.Call
GetMapTask indicates an expected call of GetMapTask.
func (*MockTasksMockRecorder) GetReduceTask ¶
func (mr *MockTasksMockRecorder) GetReduceTask(ctx, id interface{}) *gomock.Call
GetReduceTask indicates an expected call of GetReduceTask.
func (*MockTasksMockRecorder) QueryMapTasks ¶
func (mr *MockTasksMockRecorder) QueryMapTasks(ctx, filter interface{}) *gomock.Call
QueryMapTasks indicates an expected call of QueryMapTasks.
func (*MockTasksMockRecorder) QueryReduceTasks ¶
func (mr *MockTasksMockRecorder) QueryReduceTasks(ctx, filter interface{}) *gomock.Call
QueryReduceTasks indicates an expected call of QueryReduceTasks.
func (*MockTasksMockRecorder) Transaction ¶
func (mr *MockTasksMockRecorder) Transaction(ctx, transaction interface{}) *gomock.Call
Transaction indicates an expected call of Transaction.
func (*MockTasksMockRecorder) UpdateMapTask ¶
func (mr *MockTasksMockRecorder) UpdateMapTask(ctx, task interface{}) *gomock.Call
UpdateMapTask indicates an expected call of UpdateMapTask.
func (*MockTasksMockRecorder) UpdateMapTasks ¶
func (mr *MockTasksMockRecorder) UpdateMapTasks(ctx, ids, fields interface{}) *gomock.Call
UpdateMapTasks indicates an expected call of UpdateMapTasks.
func (*MockTasksMockRecorder) UpdateReduceTask ¶
func (mr *MockTasksMockRecorder) UpdateReduceTask(ctx, task interface{}) *gomock.Call
UpdateReduceTask indicates an expected call of UpdateReduceTask.
func (*MockTasksMockRecorder) UpdateReduceTasks ¶
func (mr *MockTasksMockRecorder) UpdateReduceTasks(ctx, ids, fields interface{}) *gomock.Call
UpdateReduceTasks indicates an expected call of UpdateReduceTasks.
type MockTransaction ¶
type MockTransaction struct {
// contains filtered or unexported fields
}
MockTransaction is a mock of Transaction interface.
func NewMockTransaction ¶
func NewMockTransaction(ctrl *gomock.Controller) *MockTransaction
NewMockTransaction creates a new mock instance.
func (*MockTransaction) EXPECT ¶
func (m *MockTransaction) EXPECT() *MockTransactionMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockTransactionMockRecorder ¶
type MockTransactionMockRecorder struct {
// contains filtered or unexported fields
}
MockTransactionMockRecorder is the mock recorder for MockTransaction.
func (*MockTransactionMockRecorder) Transaction ¶
func (mr *MockTransactionMockRecorder) Transaction(ctx, transaction interface{}) *gomock.Call
Transaction indicates an expected call of Transaction.