mock_queueprocessor

package
v0.0.3 Latest Latest
Warning

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

 Go to latest Published: Nov 28, 2025 License: MIT Imports: 6 Imported by: 0

Documentation

Overview

Package mock_queueprocessor is a generated GoMock package.

Package mock_queueprocessor is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockTaskProcessor 

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

MockTaskProcessor is a mock of TaskProcessor interface.

func NewMockTaskProcessor 

func NewMockTaskProcessor(ctrl *gomock.Controller) *MockTaskProcessor

NewMockTaskProcessor creates a new mock instance.

func (*MockTaskProcessor) EXPECT 

func (m *MockTaskProcessor) EXPECT() *MockTaskProcessorMockRecorder

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

func (*MockTaskProcessor) ProcessTask 

func (m *MockTaskProcessor) ProcessTask(ctx context.Context, task *entity.Task) error

ProcessTask mocks base method.

type MockTaskProcessorMockRecorder 

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

MockTaskProcessorMockRecorder is the mock recorder for MockTaskProcessor.

func (*MockTaskProcessorMockRecorder) ProcessTask 

func (mr *MockTaskProcessorMockRecorder) ProcessTask(ctx, task any) *MockTaskProcessorProcessTaskCall

ProcessTask indicates an expected call of ProcessTask.

type MockTaskProcessorProcessTaskCall 

type MockTaskProcessorProcessTaskCall struct {
	*gomock.Call
}

MockTaskProcessorProcessTaskCall wrap *gomock.Call

func (*MockTaskProcessorProcessTaskCall) Do 

func (c *MockTaskProcessorProcessTaskCall) Do(f func(context.Context, *entity.Task) error) *MockTaskProcessorProcessTaskCall

Do rewrite *gomock.Call.Do

func (*MockTaskProcessorProcessTaskCall) DoAndReturn 

func (c *MockTaskProcessorProcessTaskCall) DoAndReturn(f func(context.Context, *entity.Task) error) *MockTaskProcessorProcessTaskCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockTaskProcessorProcessTaskCall) Return 

func (c *MockTaskProcessorProcessTaskCall) Return(arg0 error) *MockTaskProcessorProcessTaskCall

Return rewrite *gomock.Call.Return

type MockTaskStorage 

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

MockTaskStorage is a mock of TaskStorage interface.

func NewMockTaskStorage 

func NewMockTaskStorage(ctrl *gomock.Controller) *MockTaskStorage

NewMockTaskStorage creates a new mock instance.

func (*MockTaskStorage) CureTasks 

func (m *MockTaskStorage) CureTasks(ctx context.Context, taskType entity.TaskType, unhealthStatuses []entity.TaskStatus, updatedAtTimeAgo time.Duration, comment string) ([]*entity.Task, error)

CureTasks mocks base method.

func (*MockTaskStorage) DeleteTasks 

func (m *MockTaskStorage) DeleteTasks(ctx context.Context, taskType entity.TaskType, statuses []entity.TaskStatus, updatedAtTimeAgo time.Duration) ([]*entity.Task, error)

DeleteTasks mocks base method.

func (*MockTaskStorage) EXPECT 

func (m *MockTaskStorage) EXPECT() *MockTaskStorageMockRecorder

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

func (*MockTaskStorage) GetTasksForProcessing 

func (m *MockTaskStorage) GetTasksForProcessing(ctx context.Context, taskType entity.TaskType, maxTasks int64) ([]*entity.Task, error)

GetTasksForProcessing mocks base method.

func (*MockTaskStorage) UpdateTask 

func (m *MockTaskStorage) UpdateTask(ctx context.Context, taskID uuid.UUID, task *entity.Task) error

UpdateTask mocks base method.

type MockTaskStorageCureTasksCall 

type MockTaskStorageCureTasksCall struct {
	*gomock.Call
}

MockTaskStorageCureTasksCall wrap *gomock.Call

func (*MockTaskStorageCureTasksCall) Do 

func (c *MockTaskStorageCureTasksCall) Do(f func(context.Context, entity.TaskType, []entity.TaskStatus, time.Duration, string) ([]*entity.Task, error)) *MockTaskStorageCureTasksCall

Do rewrite *gomock.Call.Do

func (*MockTaskStorageCureTasksCall) DoAndReturn 

func (c *MockTaskStorageCureTasksCall) DoAndReturn(f func(context.Context, entity.TaskType, []entity.TaskStatus, time.Duration, string) ([]*entity.Task, error)) *MockTaskStorageCureTasksCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockTaskStorageCureTasksCall) Return 

func (c *MockTaskStorageCureTasksCall) Return(arg0 []*entity.Task, arg1 error) *MockTaskStorageCureTasksCall

Return rewrite *gomock.Call.Return

type MockTaskStorageDeleteTasksCall 

type MockTaskStorageDeleteTasksCall struct {
	*gomock.Call
}

MockTaskStorageDeleteTasksCall wrap *gomock.Call

func (*MockTaskStorageDeleteTasksCall) Do 

func (c *MockTaskStorageDeleteTasksCall) Do(f func(context.Context, entity.TaskType, []entity.TaskStatus, time.Duration) ([]*entity.Task, error)) *MockTaskStorageDeleteTasksCall

Do rewrite *gomock.Call.Do

func (*MockTaskStorageDeleteTasksCall) DoAndReturn 

func (c *MockTaskStorageDeleteTasksCall) DoAndReturn(f func(context.Context, entity.TaskType, []entity.TaskStatus, time.Duration) ([]*entity.Task, error)) *MockTaskStorageDeleteTasksCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockTaskStorageDeleteTasksCall) Return 

func (c *MockTaskStorageDeleteTasksCall) Return(arg0 []*entity.Task, arg1 error) *MockTaskStorageDeleteTasksCall

Return rewrite *gomock.Call.Return

type MockTaskStorageGetTasksForProcessingCall 

type MockTaskStorageGetTasksForProcessingCall struct {
	*gomock.Call
}

MockTaskStorageGetTasksForProcessingCall wrap *gomock.Call

func (*MockTaskStorageGetTasksForProcessingCall) Do 

func (c *MockTaskStorageGetTasksForProcessingCall) Do(f func(context.Context, entity.TaskType, int64) ([]*entity.Task, error)) *MockTaskStorageGetTasksForProcessingCall

Do rewrite *gomock.Call.Do

func (*MockTaskStorageGetTasksForProcessingCall) DoAndReturn 

func (c *MockTaskStorageGetTasksForProcessingCall) DoAndReturn(f func(context.Context, entity.TaskType, int64) ([]*entity.Task, error)) *MockTaskStorageGetTasksForProcessingCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockTaskStorageGetTasksForProcessingCall) Return 

func (c *MockTaskStorageGetTasksForProcessingCall) Return(arg0 []*entity.Task, arg1 error) *MockTaskStorageGetTasksForProcessingCall

Return rewrite *gomock.Call.Return

type MockTaskStorageMockRecorder 

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

MockTaskStorageMockRecorder is the mock recorder for MockTaskStorage.

func (*MockTaskStorageMockRecorder) CureTasks 

func (mr *MockTaskStorageMockRecorder) CureTasks(ctx, taskType, unhealthStatuses, updatedAtTimeAgo, comment any) *MockTaskStorageCureTasksCall

CureTasks indicates an expected call of CureTasks.

func (*MockTaskStorageMockRecorder) DeleteTasks 

func (mr *MockTaskStorageMockRecorder) DeleteTasks(ctx, taskType, statuses, updatedAtTimeAgo any) *MockTaskStorageDeleteTasksCall

DeleteTasks indicates an expected call of DeleteTasks.

func (*MockTaskStorageMockRecorder) GetTasksForProcessing 

func (mr *MockTaskStorageMockRecorder) GetTasksForProcessing(ctx, taskType, maxTasks any) *MockTaskStorageGetTasksForProcessingCall

GetTasksForProcessing indicates an expected call of GetTasksForProcessing.

func (*MockTaskStorageMockRecorder) UpdateTask 

func (mr *MockTaskStorageMockRecorder) UpdateTask(ctx, taskID, task any) *MockTaskStorageUpdateTaskCall

UpdateTask indicates an expected call of UpdateTask.

type MockTaskStorageUpdateTaskCall 

type MockTaskStorageUpdateTaskCall struct {
	*gomock.Call
}

MockTaskStorageUpdateTaskCall wrap *gomock.Call

func (*MockTaskStorageUpdateTaskCall) Do 

func (c *MockTaskStorageUpdateTaskCall) Do(f func(context.Context, uuid.UUID, *entity.Task) error) *MockTaskStorageUpdateTaskCall

Do rewrite *gomock.Call.Do

func (*MockTaskStorageUpdateTaskCall) DoAndReturn 

func (c *MockTaskStorageUpdateTaskCall) DoAndReturn(f func(context.Context, uuid.UUID, *entity.Task) error) *MockTaskStorageUpdateTaskCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockTaskStorageUpdateTaskCall) Return 

func (c *MockTaskStorageUpdateTaskCall) Return(arg0 error) *MockTaskStorageUpdateTaskCall

Return rewrite *gomock.Call.Return

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.