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) 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
  • func (_m *QueueStorage) Clear(taskName string)
  • func (_m *QueueStorage) NextJob(taskName string) string
  • func (_m *QueueStorage) PopJob(taskName string) string
  • func (_m *QueueStorage) PushJob(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) 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) (*taskqueueworker.Job, error)

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

func (*Persistent) SaveJob

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

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

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(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