Documentation
¶
Overview ¶
Package mocks is a generated GoMock package.
Index ¶
- type MockCoordinator
- func (m *MockCoordinator) CreateMapTask(ctx context.Context, inputFile string) (mapreduce.MapTask, error)
- func (m *MockCoordinator) CreateReduceTask(ctx context.Context, inputFiles ...string) (mapreduce.ReduceTask, error)
- func (m *MockCoordinator) EXPECT() *MockCoordinatorMockRecorder
- func (m *MockCoordinator) FlushCreatedTasksToWorkers(ctx context.Context) error
- func (m *MockCoordinator) GetMapTask(ctx context.Context) (mapreduce.MapTask, error)
- func (m *MockCoordinator) GetReduceTask(ctx context.Context) (mapreduce.ReduceTask, error)
- func (m *MockCoordinator) MapTasksRescheduler()
- func (m *MockCoordinator) ReduceTasksRescheduler()
- func (m *MockCoordinator) ReportMapTask(ctx context.Context, taskResult mapreduce.MapTaskResult) error
- func (m *MockCoordinator) ReportReduceTask(ctx context.Context, taskResult mapreduce.ReduceTaskResult) error
- type MockCoordinatorMockRecorder
- func (mr *MockCoordinatorMockRecorder) CreateMapTask(ctx, inputFile interface{}) *gomock.Call
- func (mr *MockCoordinatorMockRecorder) CreateReduceTask(ctx interface{}, inputFiles ...interface{}) *gomock.Call
- func (mr *MockCoordinatorMockRecorder) FlushCreatedTasksToWorkers(ctx interface{}) *gomock.Call
- func (mr *MockCoordinatorMockRecorder) GetMapTask(ctx interface{}) *gomock.Call
- func (mr *MockCoordinatorMockRecorder) GetReduceTask(ctx interface{}) *gomock.Call
- func (mr *MockCoordinatorMockRecorder) MapTasksRescheduler() *gomock.Call
- func (mr *MockCoordinatorMockRecorder) ReduceTasksRescheduler() *gomock.Call
- func (mr *MockCoordinatorMockRecorder) ReportMapTask(ctx, taskResult interface{}) *gomock.Call
- func (mr *MockCoordinatorMockRecorder) ReportReduceTask(ctx, taskResult interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockCoordinator ¶
type MockCoordinator struct {
// contains filtered or unexported fields
}
MockCoordinator is a mock of Coordinator interface.
func NewMockCoordinator ¶
func NewMockCoordinator(ctrl *gomock.Controller) *MockCoordinator
NewMockCoordinator creates a new mock instance.
func (*MockCoordinator) CreateMapTask ¶
func (m *MockCoordinator) CreateMapTask(ctx context.Context, inputFile string) (mapreduce.MapTask, error)
CreateMapTask mocks base method.
func (*MockCoordinator) CreateReduceTask ¶
func (m *MockCoordinator) CreateReduceTask(ctx context.Context, inputFiles ...string) (mapreduce.ReduceTask, error)
CreateReduceTask mocks base method.
func (*MockCoordinator) EXPECT ¶
func (m *MockCoordinator) EXPECT() *MockCoordinatorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockCoordinator) FlushCreatedTasksToWorkers ¶
func (m *MockCoordinator) FlushCreatedTasksToWorkers(ctx context.Context) error
FlushCreatedTasksToWorkers mocks base method.
func (*MockCoordinator) GetMapTask ¶
GetMapTask mocks base method.
func (*MockCoordinator) GetReduceTask ¶
func (m *MockCoordinator) GetReduceTask(ctx context.Context) (mapreduce.ReduceTask, error)
GetReduceTask mocks base method.
func (*MockCoordinator) MapTasksRescheduler ¶
func (m *MockCoordinator) MapTasksRescheduler()
MapTasksRescheduler mocks base method.
func (*MockCoordinator) ReduceTasksRescheduler ¶
func (m *MockCoordinator) ReduceTasksRescheduler()
ReduceTasksRescheduler mocks base method.
func (*MockCoordinator) ReportMapTask ¶
func (m *MockCoordinator) ReportMapTask(ctx context.Context, taskResult mapreduce.MapTaskResult) error
ReportMapTask mocks base method.
func (*MockCoordinator) ReportReduceTask ¶
func (m *MockCoordinator) ReportReduceTask(ctx context.Context, taskResult mapreduce.ReduceTaskResult) error
ReportReduceTask mocks base method.
type MockCoordinatorMockRecorder ¶
type MockCoordinatorMockRecorder struct {
// contains filtered or unexported fields
}
MockCoordinatorMockRecorder is the mock recorder for MockCoordinator.
func (*MockCoordinatorMockRecorder) CreateMapTask ¶
func (mr *MockCoordinatorMockRecorder) CreateMapTask(ctx, inputFile interface{}) *gomock.Call
CreateMapTask indicates an expected call of CreateMapTask.
func (*MockCoordinatorMockRecorder) CreateReduceTask ¶
func (mr *MockCoordinatorMockRecorder) CreateReduceTask(ctx interface{}, inputFiles ...interface{}) *gomock.Call
CreateReduceTask indicates an expected call of CreateReduceTask.
func (*MockCoordinatorMockRecorder) FlushCreatedTasksToWorkers ¶
func (mr *MockCoordinatorMockRecorder) FlushCreatedTasksToWorkers(ctx interface{}) *gomock.Call
FlushCreatedTasksToWorkers indicates an expected call of FlushCreatedTasksToWorkers.
func (*MockCoordinatorMockRecorder) GetMapTask ¶
func (mr *MockCoordinatorMockRecorder) GetMapTask(ctx interface{}) *gomock.Call
GetMapTask indicates an expected call of GetMapTask.
func (*MockCoordinatorMockRecorder) GetReduceTask ¶
func (mr *MockCoordinatorMockRecorder) GetReduceTask(ctx interface{}) *gomock.Call
GetReduceTask indicates an expected call of GetReduceTask.
func (*MockCoordinatorMockRecorder) MapTasksRescheduler ¶
func (mr *MockCoordinatorMockRecorder) MapTasksRescheduler() *gomock.Call
MapTasksRescheduler indicates an expected call of MapTasksRescheduler.
func (*MockCoordinatorMockRecorder) ReduceTasksRescheduler ¶
func (mr *MockCoordinatorMockRecorder) ReduceTasksRescheduler() *gomock.Call
ReduceTasksRescheduler indicates an expected call of ReduceTasksRescheduler.
func (*MockCoordinatorMockRecorder) ReportMapTask ¶
func (mr *MockCoordinatorMockRecorder) ReportMapTask(ctx, taskResult interface{}) *gomock.Call
ReportMapTask indicates an expected call of ReportMapTask.
func (*MockCoordinatorMockRecorder) ReportReduceTask ¶
func (mr *MockCoordinatorMockRecorder) ReportReduceTask(ctx, taskResult interface{}) *gomock.Call
ReportReduceTask indicates an expected call of ReportReduceTask.
Source Files