Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Executor ¶
Executor is an autogenerated mock type for the Executor type
func NewExecutor ¶
NewExecutor creates a new instance of Executor. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*Executor) NewFixedWorkerPool ¶
func (_m *Executor) NewFixedWorkerPool(ctx context.Context, options *commons.Options) asyncgo.WorkerPool
NewFixedWorkerPool provides a mock function with given fields: ctx, options
type ExecutorService ¶
ExecutorService is an autogenerated mock type for the ExecutorService type
func NewExecutorService ¶
func NewExecutorService(t interface {
mock.TestingT
Cleanup(func())
}) *ExecutorService
NewExecutorService creates a new instance of ExecutorService. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*ExecutorService) NewFixedWorkerPool ¶
func (_m *ExecutorService) NewFixedWorkerPool(options *commons.Options) asyncgo.WorkerPool
NewFixedWorkerPool provides a mock function with given fields: options
type Queue ¶
Queue is an autogenerated mock type for the Queue type
func NewQueue ¶
NewQueue creates a new instance of Queue. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
type Task ¶
Task is an autogenerated mock type for the Task type
type TaskQueue ¶
TaskQueue is an autogenerated mock type for the TaskQueue type
func NewTaskQueue ¶
NewTaskQueue creates a new instance of TaskQueue. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
type WorkerPool ¶
WorkerPool is an autogenerated mock type for the WorkerPool type
func NewWorkerPool ¶
func NewWorkerPool(t interface {
mock.TestingT
Cleanup(func())
}) *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. The first argument is typically a *testing.T value.
func (*WorkerPool) ChannelBufferSize ¶
func (_m *WorkerPool) ChannelBufferSize() int64
ChannelBufferSize provides a mock function with given fields:
func (*WorkerPool) PoolSize ¶
func (_m *WorkerPool) PoolSize() int64
PoolSize provides a mock function with given fields:
func (*WorkerPool) Shutdown ¶
func (_m *WorkerPool) Shutdown()
Shutdown provides a mock function with given fields:
func (*WorkerPool) Submit ¶
func (_m *WorkerPool) Submit(function interface{}, args ...interface{}) (*asyncgo.Future, error)
Submit provides a mock function with given fields: function, args
func (*WorkerPool) Terminate ¶
func (_m *WorkerPool) Terminate()
Terminate provides a mock function with given fields:
func (*WorkerPool) WaitAll ¶
func (_m *WorkerPool) WaitAll() error
WaitAll provides a mock function with given fields:
Source Files