mocks

Documentation

Index

• type JobQueue
  • func NewJobQueue(t mockConstructorTestingTNewJobQueue) *JobQueue
  • func (_m *JobQueue) Dequeue(ctx context.Context, kinds []string, fn worker.DequeueFn) error
  • func (_m *JobQueue) EXPECT() *JobQueue_Expecter
  • func (_m *JobQueue) Enqueue(ctx context.Context, jobs ...worker.Job) error
• type JobQueue_Dequeue_Call
  • func (_c *JobQueue_Dequeue_Call) Return(_a0 error) *JobQueue_Dequeue_Call
  • func (_c *JobQueue_Dequeue_Call) Run(run func(ctx context.Context, kinds []string, fn worker.DequeueFn)) *JobQueue_Dequeue_Call
• type JobQueue_Enqueue_Call
  • func (_c *JobQueue_Enqueue_Call) Return(_a0 error) *JobQueue_Enqueue_Call
  • func (_c *JobQueue_Enqueue_Call) Run(run func(ctx context.Context, jobs ...worker.Job)) *JobQueue_Enqueue_Call
• type JobQueue_Expecter
  • func (_e *JobQueue_Expecter) Dequeue(ctx interface{}, kinds interface{}, fn interface{}) *JobQueue_Dequeue_Call
  • func (_e *JobQueue_Expecter) Enqueue(ctx interface{}, jobs ...interface{}) *JobQueue_Enqueue_Call

Types

type JobQueue

type JobQueue struct {
	mock.Mock
}

JobQueue is an autogenerated mock type for the JobQueue type

func NewJobQueue

func NewJobQueue(t mockConstructorTestingTNewJobQueue) *JobQueue

NewJobQueue creates a new instance of JobQueue. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*JobQueue) Dequeue

func (_m *JobQueue) Dequeue(ctx context.Context, kinds []string, fn worker.DequeueFn) error

Dequeue provides a mock function with given fields: ctx, kinds, fn

func (*JobQueue) EXPECT

func (_m *JobQueue) EXPECT() *JobQueue_Expecter

func (*JobQueue) Enqueue

func (_m *JobQueue) Enqueue(ctx context.Context, jobs ...worker.Job) error

Enqueue provides a mock function with given fields: ctx, jobs

type JobQueue_Dequeue_Call

type JobQueue_Dequeue_Call struct {
	*mock.Call
}

JobQueue_Dequeue_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Dequeue'

func (*JobQueue_Dequeue_Call) Return

func (_c *JobQueue_Dequeue_Call) Return(_a0 error) *JobQueue_Dequeue_Call

func (*JobQueue_Dequeue_Call) Run

func (_c *JobQueue_Dequeue_Call) Run(run func(ctx context.Context, kinds []string, fn worker.DequeueFn)) *JobQueue_Dequeue_Call

type JobQueue_Enqueue_Call

type JobQueue_Enqueue_Call struct {
	*mock.Call
}

JobQueue_Enqueue_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Enqueue'

func (*JobQueue_Enqueue_Call) Return

func (_c *JobQueue_Enqueue_Call) Return(_a0 error) *JobQueue_Enqueue_Call

func (*JobQueue_Enqueue_Call) Run

func (_c *JobQueue_Enqueue_Call) Run(run func(ctx context.Context, jobs ...worker.Job)) *JobQueue_Enqueue_Call

type JobQueue_Expecter

type JobQueue_Expecter struct {
	// contains filtered or unexported fields
}

func (*JobQueue_Expecter) Dequeue

func (_e *JobQueue_Expecter) Dequeue(ctx interface{}, kinds interface{}, fn interface{}) *JobQueue_Dequeue_Call

Dequeue is a helper method to define mock.On call

• ctx context.Context
• kinds []string
• fn worker.DequeueFn

func (*JobQueue_Expecter) Enqueue

func (_e *JobQueue_Expecter) Enqueue(ctx interface{}, jobs ...interface{}) *JobQueue_Enqueue_Call

Enqueue is a helper method to define mock.On call

• ctx context.Context
• jobs ...worker.Job