Versions in this module Expand all Collapse all v0 v0.0.3 Nov 28, 2025 Changes in this version + type MockTaskProcessor struct + func NewMockTaskProcessor(ctrl *gomock.Controller) *MockTaskProcessor + func (m *MockTaskProcessor) EXPECT() *MockTaskProcessorMockRecorder + func (m *MockTaskProcessor) ProcessTask(ctx context.Context, task *entity.Task) error + type MockTaskProcessorMockRecorder struct + func (mr *MockTaskProcessorMockRecorder) ProcessTask(ctx, task any) *MockTaskProcessorProcessTaskCall + type MockTaskProcessorProcessTaskCall struct + func (c *MockTaskProcessorProcessTaskCall) Do(f func(context.Context, *entity.Task) error) *MockTaskProcessorProcessTaskCall + func (c *MockTaskProcessorProcessTaskCall) DoAndReturn(f func(context.Context, *entity.Task) error) *MockTaskProcessorProcessTaskCall + func (c *MockTaskProcessorProcessTaskCall) Return(arg0 error) *MockTaskProcessorProcessTaskCall + type MockTaskStorage struct + func NewMockTaskStorage(ctrl *gomock.Controller) *MockTaskStorage + func (m *MockTaskStorage) CureTasks(ctx context.Context, taskType entity.TaskType, ...) ([]*entity.Task, error) + func (m *MockTaskStorage) DeleteTasks(ctx context.Context, taskType entity.TaskType, statuses []entity.TaskStatus, ...) ([]*entity.Task, error) + func (m *MockTaskStorage) EXPECT() *MockTaskStorageMockRecorder + func (m *MockTaskStorage) GetTasksForProcessing(ctx context.Context, taskType entity.TaskType, maxTasks int64) ([]*entity.Task, error) + func (m *MockTaskStorage) UpdateTask(ctx context.Context, taskID uuid.UUID, task *entity.Task) error + type MockTaskStorageCureTasksCall struct + func (c *MockTaskStorageCureTasksCall) Do(...) *MockTaskStorageCureTasksCall + func (c *MockTaskStorageCureTasksCall) DoAndReturn(...) *MockTaskStorageCureTasksCall + func (c *MockTaskStorageCureTasksCall) Return(arg0 []*entity.Task, arg1 error) *MockTaskStorageCureTasksCall + type MockTaskStorageDeleteTasksCall struct + func (c *MockTaskStorageDeleteTasksCall) Do(...) *MockTaskStorageDeleteTasksCall + func (c *MockTaskStorageDeleteTasksCall) DoAndReturn(...) *MockTaskStorageDeleteTasksCall + func (c *MockTaskStorageDeleteTasksCall) Return(arg0 []*entity.Task, arg1 error) *MockTaskStorageDeleteTasksCall + type MockTaskStorageGetTasksForProcessingCall struct + func (c *MockTaskStorageGetTasksForProcessingCall) Do(f func(context.Context, entity.TaskType, int64) ([]*entity.Task, error)) *MockTaskStorageGetTasksForProcessingCall + func (c *MockTaskStorageGetTasksForProcessingCall) DoAndReturn(f func(context.Context, entity.TaskType, int64) ([]*entity.Task, error)) *MockTaskStorageGetTasksForProcessingCall + func (c *MockTaskStorageGetTasksForProcessingCall) Return(arg0 []*entity.Task, arg1 error) *MockTaskStorageGetTasksForProcessingCall + type MockTaskStorageMockRecorder struct + func (mr *MockTaskStorageMockRecorder) CureTasks(ctx, taskType, unhealthStatuses, updatedAtTimeAgo, comment any) *MockTaskStorageCureTasksCall + func (mr *MockTaskStorageMockRecorder) DeleteTasks(ctx, taskType, statuses, updatedAtTimeAgo any) *MockTaskStorageDeleteTasksCall + func (mr *MockTaskStorageMockRecorder) GetTasksForProcessing(ctx, taskType, maxTasks any) *MockTaskStorageGetTasksForProcessingCall + func (mr *MockTaskStorageMockRecorder) UpdateTask(ctx, taskID, task any) *MockTaskStorageUpdateTaskCall + type MockTaskStorageUpdateTaskCall struct + func (c *MockTaskStorageUpdateTaskCall) Do(f func(context.Context, uuid.UUID, *entity.Task) error) *MockTaskStorageUpdateTaskCall + func (c *MockTaskStorageUpdateTaskCall) DoAndReturn(f func(context.Context, uuid.UUID, *entity.Task) error) *MockTaskStorageUpdateTaskCall + func (c *MockTaskStorageUpdateTaskCall) Return(arg0 error) *MockTaskStorageUpdateTaskCall
Go to main page