mocks

Documentation

Overview

Package mocks is a generated GoMock package.

Index

• type MockCoordinator
  • func NewMockCoordinator(ctrl *gomock.Controller) *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) 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) ReportMapTask(ctx, taskResult interface{}) *gomock.Call
  • func (mr *MockCoordinatorMockRecorder) ReportReduceTask(ctx, taskResult interface{}) *gomock.Call

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

func (m *MockCoordinator) GetMapTask(ctx context.Context) (mapreduce.MapTask, error)

GetMapTask mocks base method.

func (*MockCoordinator) GetReduceTask

func (m *MockCoordinator) GetReduceTask(ctx context.Context) (mapreduce.ReduceTask, error)

GetReduceTask 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) 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.