mocks

Documentation

Index

• type Dispatcher
  • func NewDispatcher(t mockConstructorTestingTNewDispatcher) *Dispatcher
  • func (_m *Dispatcher) Close() error
  • func (_m *Dispatcher) Push(_a0 pipelines.Task) error
  • func (_m *Dispatcher) Wait()
• type Doer
  • func NewDoer(t mockConstructorTestingTNewDoer) *Doer
  • func (_m *Doer) Close() error
  • func (_m *Doer) Do(_a0 pipelines.Task) error
• type Hasher
  • func NewHasher(t mockConstructorTestingTNewHasher) *Hasher
  • func (_m *Hasher) Execute(_a0 string, _a1 uint64) uint64
• type Task
  • func NewTask(t mockConstructorTestingTNewTask) *Task
  • func (_m *Task) Do() error
  • func (_m *Task) ID() string
• type TaskDecorator
  • func NewTaskDecorator(t mockConstructorTestingTNewTaskDecorator) *TaskDecorator
  • func (_m *TaskDecorator) Execute(_a0 pipelines.TaskExecutor) pipelines.TaskExecutor
• type TaskExecutor
  • func NewTaskExecutor(t mockConstructorTestingTNewTaskExecutor) *TaskExecutor
  • func (_m *TaskExecutor) Execute(_a0 pipelines.Task) error

Types

type Dispatcher

type Dispatcher struct {
	mock.Mock
}

Dispatcher is an autogenerated mock type for the Dispatcher type

func NewDispatcher

func NewDispatcher(t mockConstructorTestingTNewDispatcher) *Dispatcher

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

func (*Dispatcher) Close

func (_m *Dispatcher) Close() error

Close provides a mock function with given fields:

func (*Dispatcher) Push

func (_m *Dispatcher) Push(_a0 pipelines.Task) error

Push provides a mock function with given fields: _a0

func (*Dispatcher) Wait

func (_m *Dispatcher) Wait()

Wait provides a mock function with given fields:

type Doer

type Doer struct {
	mock.Mock
}

Doer is an autogenerated mock type for the Doer type

func NewDoer

func NewDoer(t mockConstructorTestingTNewDoer) *Doer

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

func (*Doer) Close

func (_m *Doer) Close() error

Close provides a mock function with given fields:

func (*Doer) Do

func (_m *Doer) Do(_a0 pipelines.Task) error

Do provides a mock function with given fields: _a0

type Hasher

type Hasher struct {
	mock.Mock
}

Hasher is an autogenerated mock type for the Hasher type

func NewHasher

func NewHasher(t mockConstructorTestingTNewHasher) *Hasher

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

func (*Hasher) Execute

func (_m *Hasher) Execute(_a0 string, _a1 uint64) uint64

Execute provides a mock function with given fields: _a0, _a1

type Task

type Task struct {
	mock.Mock
}

Task is an autogenerated mock type for the Task type

func NewTask

func NewTask(t mockConstructorTestingTNewTask) *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) Do

func (_m *Task) Do() error

Do provides a mock function with given fields:

func (*Task) ID

func (_m *Task) ID() string

ID provides a mock function with given fields:

type TaskDecorator

type TaskDecorator struct {
	mock.Mock
}

TaskDecorator is an autogenerated mock type for the TaskDecorator type

func NewTaskDecorator

func NewTaskDecorator(t mockConstructorTestingTNewTaskDecorator) *TaskDecorator

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

func (*TaskDecorator) Execute

func (_m *TaskDecorator) Execute(_a0 pipelines.TaskExecutor) pipelines.TaskExecutor

Execute provides a mock function with given fields: _a0

type TaskExecutor

type TaskExecutor struct {
	mock.Mock
}

TaskExecutor is an autogenerated mock type for the TaskExecutor type

func NewTaskExecutor

func NewTaskExecutor(t mockConstructorTestingTNewTaskExecutor) *TaskExecutor

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

func (*TaskExecutor) Execute

func (_m *TaskExecutor) Execute(_a0 pipelines.Task) error

Execute provides a mock function with given fields: _a0