Versions in this module Expand all Collapse all v0 v0.0.2 Nov 28, 2025 Changes in this version + type MockTaskFetcher struct + func NewMockTaskFetcher(ctrl *gomock.Controller) *MockTaskFetcher + func (m *MockTaskFetcher) EXPECT() *MockTaskFetcherMockRecorder + func (m *MockTaskFetcher) FetchTasks(ctx context.Context) ([]*entity.Task, error) + type MockTaskFetcherFetchTasksCall struct + func (c *MockTaskFetcherFetchTasksCall) Do(f func(context.Context) ([]*entity.Task, error)) *MockTaskFetcherFetchTasksCall + func (c *MockTaskFetcherFetchTasksCall) DoAndReturn(f func(context.Context) ([]*entity.Task, error)) *MockTaskFetcherFetchTasksCall + func (c *MockTaskFetcherFetchTasksCall) Return(arg0 []*entity.Task, arg1 error) *MockTaskFetcherFetchTasksCall + type MockTaskFetcherMockRecorder struct + func (mr *MockTaskFetcherMockRecorder) FetchTasks(ctx any) *MockTaskFetcherFetchTasksCall v0.0.1 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, payload string) error + type MockTaskProcessorMockRecorder struct + func (mr *MockTaskProcessorMockRecorder) ProcessTask(ctx, payload any) *MockTaskProcessorProcessTaskCall + type MockTaskProcessorProcessTaskCall struct + func (c *MockTaskProcessorProcessTaskCall) Do(f func(context.Context, string) error) *MockTaskProcessorProcessTaskCall + func (c *MockTaskProcessorProcessTaskCall) DoAndReturn(f func(context.Context, string) error) *MockTaskProcessorProcessTaskCall + func (c *MockTaskProcessorProcessTaskCall) Return(arg0 error) *MockTaskProcessorProcessTaskCall + type MockTaskStorage struct + func NewMockTaskStorage(ctrl *gomock.Controller) *MockTaskStorage + func (m *MockTaskStorage) EXPECT() *MockTaskStorageMockRecorder + func (m *MockTaskStorage) GetTasksForProcessing(ctx context.Context, taskType string, maxTasks int64) ([]*entity.Task, error) + func (m *MockTaskStorage) UpdateTask(ctx context.Context, taskID uuid.UUID, task *entity.Task) error + type MockTaskStorageGetTasksForProcessingCall struct + func (c *MockTaskStorageGetTasksForProcessingCall) Do(f func(context.Context, string, int64) ([]*entity.Task, error)) *MockTaskStorageGetTasksForProcessingCall + func (c *MockTaskStorageGetTasksForProcessingCall) DoAndReturn(f func(context.Context, string, int64) ([]*entity.Task, error)) *MockTaskStorageGetTasksForProcessingCall + func (c *MockTaskStorageGetTasksForProcessingCall) Return(arg0 []*entity.Task, arg1 error) *MockTaskStorageGetTasksForProcessingCall + type MockTaskStorageMockRecorder struct + 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