mocks

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) DeleteJob(ctx context.Context, id string) error
  • func (_m *Persistent) FindAllJob(ctx context.Context, filter taskqueueworker.Filter) []taskqueueworker.Job
  • func (_m *Persistent) FindJobByID(ctx context.Context, id string, excludeFields ...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
  • func (_m *QueueStorage) Clear(ctx context.Context, taskName string)
  • func (_m *QueueStorage) NextJob(ctx context.Context, taskName string) string
  • func (_m *QueueStorage) PopJob(ctx context.Context, taskName string) string
  • func (_m *QueueStorage) PushJob(ctx context.Context, job *taskqueueworker.Job)

Types

type Persistent

type Persistent struct {
	mock.Mock
}

Persistent is an autogenerated mock type for the Persistent type

func (*Persistent) AggregateAllTaskJob

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

func (_m *Persistent) CleanJob(ctx context.Context, taskName string)

CleanJob provides a mock function with given fields: ctx, taskName

func (*Persistent) CountAllJob

func (_m *Persistent) CountAllJob(ctx context.Context, filter taskqueueworker.Filter) int

CountAllJob provides a mock function with given fields: ctx, filter

func (*Persistent) DeleteJob

func (_m *Persistent) DeleteJob(ctx context.Context, id string) error

DeleteJob provides a mock function with given fields: ctx, id

func (*Persistent) FindAllJob

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

func (_m *Persistent) FindJobByID(ctx context.Context, id string, excludeFields ...string) (*taskqueueworker.Job, error)

FindJobByID provides a mock function with given fields: ctx, id, excludeFields

func (*Persistent) SaveJob

func (_m *Persistent) SaveJob(ctx context.Context, job *taskqueueworker.Job, retryHistories ...taskqueueworker.RetryHistory)

SaveJob provides a mock function with given fields: ctx, job, retryHistories

func (*Persistent) UpdateAllStatus

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

type QueueStorage struct {
	mock.Mock
}

QueueStorage is an autogenerated mock type for the QueueStorage type

func (*QueueStorage) Clear

func (_m *QueueStorage) Clear(ctx context.Context, taskName string)

Clear provides a mock function with given fields: ctx, taskName

func (*QueueStorage) NextJob

func (_m *QueueStorage) NextJob(ctx context.Context, taskName string) string

NextJob provides a mock function with given fields: ctx, taskName

func (*QueueStorage) PopJob

func (_m *QueueStorage) PopJob(ctx context.Context, taskName string) string

PopJob provides a mock function with given fields: ctx, taskName

func (*QueueStorage) PushJob

func (_m *QueueStorage) PushJob(ctx context.Context, job *taskqueueworker.Job)

PushJob provides a mock function with given fields: ctx, job