mocks

Documentation

Index

• type FnWorker
  • func NewFnWorker(t NewFnWorkerT) *FnWorker
  • func (_m *FnWorker) IsRunning() bool
  • func (_m *FnWorker) Start(ctx context.Context)
  • func (_m *FnWorker) Stop()
• type FnWorkerPool
  • func NewFnWorkerPool(t NewFnWorkerPoolT) *FnWorkerPool
  • func (_m *FnWorkerPool) AddTask(task worker.TaskFunc)
  • func (_m *FnWorkerPool) AddWorkers(count int)
  • func (_m *FnWorkerPool) RemoveWorkers(count int)
  • func (_m *FnWorkerPool) Stop()
  • func (_m *FnWorkerPool) TaskChannel() chan worker.TaskFunc
  • func (_m *FnWorkerPool) WorkersCount() int
• type NewFnWorkerPoolT
• type NewFnWorkerT
• type NewTaskT
• type NewWorkerPoolT
• type NewWorkerT
• type Task
  • func NewTask(t NewTaskT) *Task
  • func (_m *Task) Run(ctx context.Context)
• type Worker
  • func NewWorker(t NewWorkerT) *Worker
  • func (_m *Worker) IsRunning() bool
  • func (_m *Worker) Start(ctx context.Context)
  • func (_m *Worker) Stop()
• type WorkerPool
  • func NewWorkerPool(t NewWorkerPoolT) *WorkerPool
  • func (_m *WorkerPool) AddTask(task worker.Task)
  • func (_m *WorkerPool) AddWorkers(count int)
  • func (_m *WorkerPool) RemoveWorkers(count int)
  • func (_m *WorkerPool) Stop()
  • func (_m *WorkerPool) TaskChannel() chan worker.Task
  • func (_m *WorkerPool) WorkersCount() int

Types

type FnWorker

type FnWorker struct {
	mock.Mock
}

FnWorker is an autogenerated mock type for the FnWorker type

func NewFnWorker

func NewFnWorker(t NewFnWorkerT) *FnWorker

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

func (*FnWorker) IsRunning

func (_m *FnWorker) IsRunning() bool

IsRunning provides a mock function with given fields:

func (*FnWorker) Start

func (_m *FnWorker) Start(ctx context.Context)

Start provides a mock function with given fields: ctx

func (*FnWorker) Stop

func (_m *FnWorker) Stop()

Stop provides a mock function with given fields:

type FnWorkerPool

type FnWorkerPool struct {
	mock.Mock
}

FnWorkerPool is an autogenerated mock type for the FnWorkerPool type

func NewFnWorkerPool

func NewFnWorkerPool(t NewFnWorkerPoolT) *FnWorkerPool

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

func (*FnWorkerPool) AddTask

func (_m *FnWorkerPool) AddTask(task worker.TaskFunc)

AddTask provides a mock function with given fields: task

func (*FnWorkerPool) AddWorkers

func (_m *FnWorkerPool) AddWorkers(count int)

AddWorkers provides a mock function with given fields: count

func (*FnWorkerPool) RemoveWorkers

func (_m *FnWorkerPool) RemoveWorkers(count int)

RemoveWorkers provides a mock function with given fields: count

func (*FnWorkerPool) Stop

func (_m *FnWorkerPool) Stop()

Stop provides a mock function with given fields:

func (*FnWorkerPool) TaskChannel

func (_m *FnWorkerPool) TaskChannel() chan worker.TaskFunc

TaskChannel provides a mock function with given fields:

func (*FnWorkerPool) WorkersCount

func (_m *FnWorkerPool) WorkersCount() int

WorkersCount provides a mock function with given fields:

type NewFnWorkerPoolT

type NewFnWorkerPoolT interface {
	mock.TestingT
	Cleanup(func())
}

type NewFnWorkerT

type NewFnWorkerT interface {
	mock.TestingT
	Cleanup(func())
}

type NewTaskT

type NewTaskT interface {
	mock.TestingT
	Cleanup(func())
}

type NewWorkerPoolT

type NewWorkerPoolT interface {
	mock.TestingT
	Cleanup(func())
}

type NewWorkerT

type NewWorkerT interface {
	mock.TestingT
	Cleanup(func())
}

type Task

type Task struct {
	mock.Mock
}

Task is an autogenerated mock type for the Task type

func NewTask

func NewTask(t NewTaskT) *Task

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

func (*Task) Run

func (_m *Task) Run(ctx context.Context)

Run provides a mock function with given fields: ctx

type Worker

type Worker struct {
	mock.Mock
}

Worker is an autogenerated mock type for the Worker type

func NewWorker

func NewWorker(t NewWorkerT) *Worker

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

func (*Worker) IsRunning

func (_m *Worker) IsRunning() bool

IsRunning provides a mock function with given fields:

func (*Worker) Start

func (_m *Worker) Start(ctx context.Context)

Start provides a mock function with given fields: ctx

func (*Worker) Stop

func (_m *Worker) Stop()

Stop provides a mock function with given fields:

type WorkerPool

type WorkerPool struct {
	mock.Mock
}

WorkerPool is an autogenerated mock type for the WorkerPool type

func NewWorkerPool

func NewWorkerPool(t NewWorkerPoolT) *WorkerPool

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

func (*WorkerPool) AddTask

func (_m *WorkerPool) AddTask(task worker.Task)

AddTask provides a mock function with given fields: task

func (*WorkerPool) AddWorkers

func (_m *WorkerPool) AddWorkers(count int)

AddWorkers provides a mock function with given fields: count

func (*WorkerPool) RemoveWorkers

func (_m *WorkerPool) RemoveWorkers(count int)

RemoveWorkers provides a mock function with given fields: count

func (*WorkerPool) Stop

func (_m *WorkerPool) Stop()

Stop provides a mock function with given fields:

func (*WorkerPool) TaskChannel

func (_m *WorkerPool) TaskChannel() chan worker.Task

TaskChannel provides a mock function with given fields:

func (*WorkerPool) WorkersCount

func (_m *WorkerPool) WorkersCount() int

WorkersCount provides a mock function with given fields: