Documentation
¶
Index ¶
- type Persistent
- func (_m *Persistent) AggregateAllTaskJob(ctx context.Context, filter taskqueueworker.Filter) []taskqueueworker.TaskResolver
- func (_m *Persistent) CleanJob(ctx context.Context, taskName string)
- func (_m *Persistent) CountAllJob(ctx context.Context, filter taskqueueworker.Filter) int
- func (_m *Persistent) FindAllJob(ctx context.Context, filter taskqueueworker.Filter) []taskqueueworker.Job
- func (_m *Persistent) FindJobByID(ctx context.Context, id string) (*taskqueueworker.Job, error)
- func (_m *Persistent) SaveJob(ctx context.Context, job *taskqueueworker.Job)
- func (_m *Persistent) UpdateAllStatus(ctx context.Context, taskName string, ...)
- type QueueStorage
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Persistent ¶ added in v1.7.1
Persistent is an autogenerated mock type for the Persistent type
func (*Persistent) AggregateAllTaskJob ¶ added in v1.7.1
func (_m *Persistent) AggregateAllTaskJob(ctx context.Context, filter taskqueueworker.Filter) []taskqueueworker.TaskResolver
AggregateAllTaskJob provides a mock function with given fields: ctx, filter
func (*Persistent) CleanJob ¶ added in v1.7.1
func (_m *Persistent) CleanJob(ctx context.Context, taskName string)
CleanJob provides a mock function with given fields: ctx, taskName
func (*Persistent) CountAllJob ¶ added in v1.7.1
func (_m *Persistent) CountAllJob(ctx context.Context, filter taskqueueworker.Filter) int
CountAllJob provides a mock function with given fields: ctx, filter
func (*Persistent) FindAllJob ¶ added in v1.7.1
func (_m *Persistent) FindAllJob(ctx context.Context, filter taskqueueworker.Filter) []taskqueueworker.Job
FindAllJob provides a mock function with given fields: ctx, filter
func (*Persistent) FindJobByID ¶ added in v1.7.1
func (_m *Persistent) FindJobByID(ctx context.Context, id string) (*taskqueueworker.Job, error)
FindJobByID provides a mock function with given fields: ctx, id
func (*Persistent) SaveJob ¶ added in v1.7.1
func (_m *Persistent) SaveJob(ctx context.Context, job *taskqueueworker.Job)
SaveJob provides a mock function with given fields: ctx, job
func (*Persistent) UpdateAllStatus ¶ added in v1.7.1
func (_m *Persistent) UpdateAllStatus(ctx context.Context, taskName string, currentStatus []taskqueueworker.JobStatusEnum, updatedStatus taskqueueworker.JobStatusEnum)
UpdateAllStatus provides a mock function with given fields: ctx, taskName, currentStatus, updatedStatus
type QueueStorage ¶
QueueStorage is an autogenerated mock type for the QueueStorage type
func (*QueueStorage) Clear ¶
func (_m *QueueStorage) Clear(taskName string)
Clear provides a mock function with given fields: taskName
func (*QueueStorage) NextJob ¶
func (_m *QueueStorage) NextJob(taskName string) string
NextJob provides a mock function with given fields: taskName
func (*QueueStorage) PopJob ¶
func (_m *QueueStorage) PopJob(taskName string) string
PopJob provides a mock function with given fields: taskName
func (*QueueStorage) PushJob ¶
func (_m *QueueStorage) PushJob(job *taskqueueworker.Job)
PushJob provides a mock function with given fields: job
Source Files