Documentation
¶
Overview ¶
Package mock_processor is a generated GoMock package.
Package mock_processor is a generated GoMock package.
Index ¶
- type MockTaskFetcher
- type MockTaskFetcherFetchTasksCall
- 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
- type MockTaskProcessor
- type MockTaskProcessorMockRecorder
- type MockTaskProcessorProcessTaskCall
- 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
- type MockTaskStorageGetTasksForProcessingCall
- 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
- type MockTaskStorageUpdateTaskCall
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockTaskFetcher ¶ added in v0.0.2
type MockTaskFetcher struct {
// contains filtered or unexported fields
}
MockTaskFetcher is a mock of TaskFetcher interface.
func NewMockTaskFetcher ¶ added in v0.0.2
func NewMockTaskFetcher(ctrl *gomock.Controller) *MockTaskFetcher
NewMockTaskFetcher creates a new mock instance.
func (*MockTaskFetcher) EXPECT ¶ added in v0.0.2
func (m *MockTaskFetcher) EXPECT() *MockTaskFetcherMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockTaskFetcher) FetchTasks ¶ added in v0.0.2
FetchTasks mocks base method.
type MockTaskFetcherFetchTasksCall ¶ added in v0.0.2
MockTaskFetcherFetchTasksCall wrap *gomock.Call
func (*MockTaskFetcherFetchTasksCall) Do ¶ added in v0.0.2
func (c *MockTaskFetcherFetchTasksCall) Do(f func(context.Context) ([]*entity.Task, error)) *MockTaskFetcherFetchTasksCall
Do rewrite *gomock.Call.Do
func (*MockTaskFetcherFetchTasksCall) DoAndReturn ¶ added in v0.0.2
func (c *MockTaskFetcherFetchTasksCall) DoAndReturn(f func(context.Context) ([]*entity.Task, error)) *MockTaskFetcherFetchTasksCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockTaskFetcherFetchTasksCall) Return ¶ added in v0.0.2
func (c *MockTaskFetcherFetchTasksCall) Return(arg0 []*entity.Task, arg1 error) *MockTaskFetcherFetchTasksCall
Return rewrite *gomock.Call.Return
type MockTaskFetcherMockRecorder ¶ added in v0.0.2
type MockTaskFetcherMockRecorder struct {
// contains filtered or unexported fields
}
MockTaskFetcherMockRecorder is the mock recorder for MockTaskFetcher.
func (*MockTaskFetcherMockRecorder) FetchTasks ¶ added in v0.0.2
func (mr *MockTaskFetcherMockRecorder) FetchTasks(ctx any) *MockTaskFetcherFetchTasksCall
FetchTasks indicates an expected call of FetchTasks.
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, payload string) 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, payload any) *MockTaskProcessorProcessTaskCall
ProcessTask indicates an expected call of ProcessTask.
type MockTaskProcessorProcessTaskCall ¶
MockTaskProcessorProcessTaskCall wrap *gomock.Call
func (*MockTaskProcessorProcessTaskCall) Do ¶
func (c *MockTaskProcessorProcessTaskCall) Do(f func(context.Context, string) error) *MockTaskProcessorProcessTaskCall
Do rewrite *gomock.Call.Do
func (*MockTaskProcessorProcessTaskCall) DoAndReturn ¶
func (c *MockTaskProcessorProcessTaskCall) DoAndReturn(f func(context.Context, string) 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) 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 MockTaskStorageGetTasksForProcessingCall ¶
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) 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 ¶
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