mocks

package
v0.0.0-...-dfed899 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 11, 2024 License: GPL-3.0 Imports: 6 Imported by: 0

Documentation

Overview

Package mocks is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockChangeBroadcaster 

type MockChangeBroadcaster struct {
	// contains filtered or unexported fields
}

MockChangeBroadcaster is a mock of ChangeBroadcaster interface.

func NewMockChangeBroadcaster 

func NewMockChangeBroadcaster(ctrl *gomock.Controller) *MockChangeBroadcaster

NewMockChangeBroadcaster creates a new mock instance.

func (*MockChangeBroadcaster) BroadcastJobUpdate 

func (m *MockChangeBroadcaster) BroadcastJobUpdate(arg0 api.EventJobUpdate)

BroadcastJobUpdate mocks base method.

func (*MockChangeBroadcaster) BroadcastTaskUpdate 

func (m *MockChangeBroadcaster) BroadcastTaskUpdate(arg0 api.EventTaskUpdate)

BroadcastTaskUpdate mocks base method.

func (*MockChangeBroadcaster) EXPECT 

func (m *MockChangeBroadcaster) EXPECT() *MockChangeBroadcasterMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockChangeBroadcasterMockRecorder 

type MockChangeBroadcasterMockRecorder struct {
	// contains filtered or unexported fields
}

MockChangeBroadcasterMockRecorder is the mock recorder for MockChangeBroadcaster.

func (*MockChangeBroadcasterMockRecorder) BroadcastJobUpdate 

func (mr *MockChangeBroadcasterMockRecorder) BroadcastJobUpdate(arg0 interface{}) *gomock.Call

BroadcastJobUpdate indicates an expected call of BroadcastJobUpdate.

func (*MockChangeBroadcasterMockRecorder) BroadcastTaskUpdate 

func (mr *MockChangeBroadcasterMockRecorder) BroadcastTaskUpdate(arg0 interface{}) *gomock.Call

BroadcastTaskUpdate indicates an expected call of BroadcastTaskUpdate.

type MockLogStorage 

type MockLogStorage struct {
	// contains filtered or unexported fields
}

MockLogStorage is a mock of LogStorage interface.

func NewMockLogStorage 

func NewMockLogStorage(ctrl *gomock.Controller) *MockLogStorage

NewMockLogStorage creates a new mock instance.

func (*MockLogStorage) EXPECT 

func (m *MockLogStorage) EXPECT() *MockLogStorageMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockLogStorage) WriteTimestamped 

func (m *MockLogStorage) WriteTimestamped(arg0 zerolog.Logger, arg1, arg2, arg3 string) error

WriteTimestamped mocks base method.

type MockLogStorageMockRecorder 

type MockLogStorageMockRecorder struct {
	// contains filtered or unexported fields
}

MockLogStorageMockRecorder is the mock recorder for MockLogStorage.

func (*MockLogStorageMockRecorder) WriteTimestamped 

func (mr *MockLogStorageMockRecorder) WriteTimestamped(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

WriteTimestamped indicates an expected call of WriteTimestamped.

type MockPersistenceService 

type MockPersistenceService struct {
	// contains filtered or unexported fields
}

MockPersistenceService is a mock of PersistenceService interface.

func NewMockPersistenceService 

func NewMockPersistenceService(ctrl *gomock.Controller) *MockPersistenceService

NewMockPersistenceService creates a new mock instance.

func (*MockPersistenceService) CountTasksOfJobInStatus 

func (m *MockPersistenceService) CountTasksOfJobInStatus(arg0 context.Context, arg1 *persistence.Job, arg2 ...api.TaskStatus) (int, int, error)

CountTasksOfJobInStatus mocks base method.

func (*MockPersistenceService) EXPECT 

func (m *MockPersistenceService) EXPECT() *MockPersistenceServiceMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockPersistenceService) FetchJobsInStatus 

func (m *MockPersistenceService) FetchJobsInStatus(arg0 context.Context, arg1 ...api.JobStatus) ([]*persistence.Job, error)

FetchJobsInStatus mocks base method.

func (*MockPersistenceService) FetchTasksOfWorkerInStatus 

func (m *MockPersistenceService) FetchTasksOfWorkerInStatus(arg0 context.Context, arg1 *persistence.Worker, arg2 api.TaskStatus) ([]*persistence.Task, error)

FetchTasksOfWorkerInStatus mocks base method.

func (*MockPersistenceService) FetchTasksOfWorkerInStatusOfJob 

func (m *MockPersistenceService) FetchTasksOfWorkerInStatusOfJob(arg0 context.Context, arg1 *persistence.Worker, arg2 api.TaskStatus, arg3 *persistence.Job) ([]*persistence.Task, error)

FetchTasksOfWorkerInStatusOfJob mocks base method.

func (*MockPersistenceService) JobHasTasksInStatus 

func (m *MockPersistenceService) JobHasTasksInStatus(arg0 context.Context, arg1 *persistence.Job, arg2 api.TaskStatus) (bool, error)

JobHasTasksInStatus mocks base method.

func (*MockPersistenceService) SaveJobStatus 

func (m *MockPersistenceService) SaveJobStatus(arg0 context.Context, arg1 *persistence.Job) error

SaveJobStatus mocks base method.

func (*MockPersistenceService) SaveTask 

func (m *MockPersistenceService) SaveTask(arg0 context.Context, arg1 *persistence.Task) error

SaveTask mocks base method.

func (*MockPersistenceService) SaveTaskActivity 

func (m *MockPersistenceService) SaveTaskActivity(arg0 context.Context, arg1 *persistence.Task) error

SaveTaskActivity mocks base method.

func (*MockPersistenceService) SaveTaskStatus 

func (m *MockPersistenceService) SaveTaskStatus(arg0 context.Context, arg1 *persistence.Task) error

SaveTaskStatus mocks base method.

func (*MockPersistenceService) UpdateJobsTaskStatuses 

func (m *MockPersistenceService) UpdateJobsTaskStatuses(arg0 context.Context, arg1 *persistence.Job, arg2 api.TaskStatus, arg3 string) error

UpdateJobsTaskStatuses mocks base method.

func (*MockPersistenceService) UpdateJobsTaskStatusesConditional 

func (m *MockPersistenceService) UpdateJobsTaskStatusesConditional(arg0 context.Context, arg1 *persistence.Job, arg2 []api.TaskStatus, arg3 api.TaskStatus, arg4 string) error

UpdateJobsTaskStatusesConditional mocks base method.

type MockPersistenceServiceMockRecorder 

type MockPersistenceServiceMockRecorder struct {
	// contains filtered or unexported fields
}

MockPersistenceServiceMockRecorder is the mock recorder for MockPersistenceService.

func (*MockPersistenceServiceMockRecorder) CountTasksOfJobInStatus 

func (mr *MockPersistenceServiceMockRecorder) CountTasksOfJobInStatus(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

CountTasksOfJobInStatus indicates an expected call of CountTasksOfJobInStatus.

func (*MockPersistenceServiceMockRecorder) FetchJobsInStatus 

func (mr *MockPersistenceServiceMockRecorder) FetchJobsInStatus(arg0 interface{}, arg1 ...interface{}) *gomock.Call

FetchJobsInStatus indicates an expected call of FetchJobsInStatus.

func (*MockPersistenceServiceMockRecorder) FetchTasksOfWorkerInStatus 

func (mr *MockPersistenceServiceMockRecorder) FetchTasksOfWorkerInStatus(arg0, arg1, arg2 interface{}) *gomock.Call

FetchTasksOfWorkerInStatus indicates an expected call of FetchTasksOfWorkerInStatus.

func (*MockPersistenceServiceMockRecorder) FetchTasksOfWorkerInStatusOfJob 

func (mr *MockPersistenceServiceMockRecorder) FetchTasksOfWorkerInStatusOfJob(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

FetchTasksOfWorkerInStatusOfJob indicates an expected call of FetchTasksOfWorkerInStatusOfJob.

func (*MockPersistenceServiceMockRecorder) JobHasTasksInStatus 

func (mr *MockPersistenceServiceMockRecorder) JobHasTasksInStatus(arg0, arg1, arg2 interface{}) *gomock.Call

JobHasTasksInStatus indicates an expected call of JobHasTasksInStatus.

func (*MockPersistenceServiceMockRecorder) SaveJobStatus 

func (mr *MockPersistenceServiceMockRecorder) SaveJobStatus(arg0, arg1 interface{}) *gomock.Call

SaveJobStatus indicates an expected call of SaveJobStatus.

func (*MockPersistenceServiceMockRecorder) SaveTask 

func (mr *MockPersistenceServiceMockRecorder) SaveTask(arg0, arg1 interface{}) *gomock.Call

SaveTask indicates an expected call of SaveTask.

func (*MockPersistenceServiceMockRecorder) SaveTaskActivity 

func (mr *MockPersistenceServiceMockRecorder) SaveTaskActivity(arg0, arg1 interface{}) *gomock.Call

SaveTaskActivity indicates an expected call of SaveTaskActivity.

func (*MockPersistenceServiceMockRecorder) SaveTaskStatus 

func (mr *MockPersistenceServiceMockRecorder) SaveTaskStatus(arg0, arg1 interface{}) *gomock.Call

SaveTaskStatus indicates an expected call of SaveTaskStatus.

func (*MockPersistenceServiceMockRecorder) UpdateJobsTaskStatuses 

func (mr *MockPersistenceServiceMockRecorder) UpdateJobsTaskStatuses(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

UpdateJobsTaskStatuses indicates an expected call of UpdateJobsTaskStatuses.

func (*MockPersistenceServiceMockRecorder) UpdateJobsTaskStatusesConditional 

func (mr *MockPersistenceServiceMockRecorder) UpdateJobsTaskStatusesConditional(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call

UpdateJobsTaskStatusesConditional indicates an expected call of UpdateJobsTaskStatusesConditional.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.