mocks

Documentation

Index

• type Persistent
  • func (_m *Persistent) AggregateAllTaskJob(ctx context.Context, filter *taskqueueworker.Filter) []taskqueueworker.TaskSummary
  • func (_m *Persistent) CleanJob(ctx context.Context, filter *taskqueueworker.Filter) int64
  • func (_m *Persistent) CountAllJob(ctx context.Context, filter *taskqueueworker.Filter) int
  • func (_m *Persistent) DeleteJob(ctx context.Context, id string) (taskqueueworker.Job, 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) SetSummary(_a0 taskqueueworker.Summary)
  • func (_m *Persistent) Summary() taskqueueworker.Summary
  • func (_m *Persistent) UpdateJob(ctx context.Context, filter *taskqueueworker.Filter, ...) (int64, int64, error)
• 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)
• type Summary
  • func (_m *Summary) FindAllSummary(ctx context.Context, filter *taskqueueworker.Filter) []taskqueueworker.TaskSummary
  • func (_m *Summary) FindDetailSummary(ctx context.Context, taskName string) taskqueueworker.TaskSummary
  • func (_m *Summary) IncrementSummary(ctx context.Context, taskName string, incr map[string]interface{})
  • func (_m *Summary) UpdateSummary(ctx context.Context, taskName string, updated map[string]interface{})

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.TaskSummary

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

func (*Persistent) CleanJob

func (_m *Persistent) CleanJob(ctx context.Context, filter *taskqueueworker.Filter) int64

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

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) (taskqueueworker.Job, 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) SetSummary

func (_m *Persistent) SetSummary(_a0 taskqueueworker.Summary)

SetSummary provides a mock function with given fields: _a0

func (*Persistent) Summary

func (_m *Persistent) Summary() taskqueueworker.Summary

Summary provides a mock function with given fields:

func (*Persistent) UpdateJob

func (_m *Persistent) UpdateJob(ctx context.Context, filter *taskqueueworker.Filter, updated map[string]interface{}, retryHistories ...taskqueueworker.RetryHistory) (int64, int64, error)

UpdateJob provides a mock function with given fields: ctx, filter, updated, retryHistories

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

type Summary

type Summary struct {
	mock.Mock
}

Summary is an autogenerated mock type for the Summary type

func (*Summary) FindAllSummary

func (_m *Summary) FindAllSummary(ctx context.Context, filter *taskqueueworker.Filter) []taskqueueworker.TaskSummary

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

func (*Summary) FindDetailSummary

func (_m *Summary) FindDetailSummary(ctx context.Context, taskName string) taskqueueworker.TaskSummary

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

func (*Summary) IncrementSummary

func (_m *Summary) IncrementSummary(ctx context.Context, taskName string, incr map[string]interface{})

IncrementSummary provides a mock function with given fields: ctx, taskName, incr

func (*Summary) UpdateSummary

func (_m *Summary) UpdateSummary(ctx context.Context, taskName string, updated map[string]interface{})

UpdateSummary provides a mock function with given fields: ctx, taskName, updated