dynworker

package
v1.0.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 10, 2026 License: MIT Imports: 4 Imported by: 0

Documentation

Overview

Package dynworker is a generated GoMock package.

Package dynworker is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockTaskQueue added in v1.0.6 

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

MockTaskQueue is a mock of TaskQueue interface.

func NewMockTaskQueue added in v1.0.6 

func NewMockTaskQueue(ctrl *gomock.Controller) *MockTaskQueue

NewMockTaskQueue creates a new mock instance.

func (*MockTaskQueue) EXPECT added in v1.0.6 

func (m *MockTaskQueue) EXPECT() *MockTaskQueueMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockTaskQueue) Get added in v1.0.6 

func (m *MockTaskQueue) Get(arg0 context.Context) (*dynworker.Task, error)

Get mocks base method.

func (*MockTaskQueue) Len added in v1.0.6 

func (m *MockTaskQueue) Len() int

Len mocks base method.

func (*MockTaskQueue) Put added in v1.0.6 

func (m *MockTaskQueue) Put(arg0 context.Context, arg1 *dynworker.Task) error

Put mocks base method.

type MockTaskQueueMockRecorder added in v1.0.6 

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

MockTaskQueueMockRecorder is the mock recorder for MockTaskQueue.

func (*MockTaskQueueMockRecorder) Get added in v1.0.6 

func (mr *MockTaskQueueMockRecorder) Get(arg0 any) *gomock.Call

Get indicates an expected call of Get.

func (*MockTaskQueueMockRecorder) Len added in v1.0.6 

func (mr *MockTaskQueueMockRecorder) Len() *gomock.Call

Len indicates an expected call of Len.

func (*MockTaskQueueMockRecorder) Put added in v1.0.6 

func (mr *MockTaskQueueMockRecorder) Put(arg0, arg1 any) *gomock.Call

Put indicates an expected call of Put.

type MockWorkerPool 

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

MockWorkerPool is a mock of WorkerPool interface.

func NewMockWorkerPool 

func NewMockWorkerPool(ctrl *gomock.Controller) *MockWorkerPool

NewMockWorkerPool creates a new mock instance.

func (*MockWorkerPool) EXPECT 

func (m *MockWorkerPool) EXPECT() *MockWorkerPoolMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockWorkerPool) MaxWorkers 

func (m *MockWorkerPool) MaxWorkers() int64

MaxWorkers mocks base method.

func (*MockWorkerPool) MinWorkers 

func (m *MockWorkerPool) MinWorkers() int64

MinWorkers mocks base method.

func (*MockWorkerPool) Name added in v1.0.6 

func (m *MockWorkerPool) Name() string

Name mocks base method.

func (*MockWorkerPool) SetMaxWorkers added in v0.5.9 

func (m *MockWorkerPool) SetMaxWorkers(arg0 int64)

SetMaxWorkers mocks base method.

func (*MockWorkerPool) SetMinWorkers added in v0.5.9 

func (m *MockWorkerPool) SetMinWorkers(arg0 int64)

SetMinWorkers mocks base method.

func (*MockWorkerPool) SetScalerFunction added in v1.0.6 

func (m *MockWorkerPool) SetScalerFunction(arg0 dynworker.ScalerFn)

SetScalerFunction mocks base method.

func (*MockWorkerPool) SetTaskFunction added in v0.5.9 

func (m *MockWorkerPool) SetTaskFunction(arg0 dynworker.TaskFn)

SetTaskFunction mocks base method.

func (*MockWorkerPool) Start 

func (m *MockWorkerPool) Start()

Start mocks base method.

func (*MockWorkerPool) Stop 

func (m *MockWorkerPool) Stop()

Stop mocks base method.

func (*MockWorkerPool) Submit 

func (m *MockWorkerPool) Submit(arg0 dynworker.UserData) error

Submit mocks base method.

func (*MockWorkerPool) WorkerCount 

func (m *MockWorkerPool) WorkerCount() int64

WorkerCount mocks base method.

type MockWorkerPoolMockRecorder 

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

MockWorkerPoolMockRecorder is the mock recorder for MockWorkerPool.

func (*MockWorkerPoolMockRecorder) MaxWorkers 

func (mr *MockWorkerPoolMockRecorder) MaxWorkers() *gomock.Call

MaxWorkers indicates an expected call of MaxWorkers.

func (*MockWorkerPoolMockRecorder) MinWorkers 

func (mr *MockWorkerPoolMockRecorder) MinWorkers() *gomock.Call

MinWorkers indicates an expected call of MinWorkers.

func (*MockWorkerPoolMockRecorder) Name added in v1.0.6 

func (mr *MockWorkerPoolMockRecorder) Name() *gomock.Call

Name indicates an expected call of Name.

func (*MockWorkerPoolMockRecorder) SetMaxWorkers added in v0.5.9 

func (mr *MockWorkerPoolMockRecorder) SetMaxWorkers(arg0 any) *gomock.Call

SetMaxWorkers indicates an expected call of SetMaxWorkers.

func (*MockWorkerPoolMockRecorder) SetMinWorkers added in v0.5.9 

func (mr *MockWorkerPoolMockRecorder) SetMinWorkers(arg0 any) *gomock.Call

SetMinWorkers indicates an expected call of SetMinWorkers.

func (*MockWorkerPoolMockRecorder) SetScalerFunction added in v1.0.6 

func (mr *MockWorkerPoolMockRecorder) SetScalerFunction(arg0 any) *gomock.Call

SetScalerFunction indicates an expected call of SetScalerFunction.

func (*MockWorkerPoolMockRecorder) SetTaskFunction added in v0.5.9 

func (mr *MockWorkerPoolMockRecorder) SetTaskFunction(arg0 any) *gomock.Call

SetTaskFunction indicates an expected call of SetTaskFunction.

func (*MockWorkerPoolMockRecorder) Start 

func (mr *MockWorkerPoolMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start.

func (*MockWorkerPoolMockRecorder) Stop 

func (mr *MockWorkerPoolMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop.

func (*MockWorkerPoolMockRecorder) Submit 

func (mr *MockWorkerPoolMockRecorder) Submit(arg0 any) *gomock.Call

Submit indicates an expected call of Submit.

func (*MockWorkerPoolMockRecorder) WorkerCount 

func (mr *MockWorkerPoolMockRecorder) WorkerCount() *gomock.Call

WorkerCount indicates an expected call of WorkerCount.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.