mock_task

package
v0.0.0-debug-20260702 Latest Latest
Warning

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

 Go to latest Published: Jul 2, 2026 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package mock_task is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockTaskRunner 

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

MockTaskRunner is a mock of TaskRunner interface.

func NewMockTaskRunner 

func NewMockTaskRunner(ctrl *gomock.Controller) *MockTaskRunner

NewMockTaskRunner creates a new mock instance.

func (*MockTaskRunner) Attach 

func (m *MockTaskRunner) Attach(ctx context.Context, taskID uint64, routine taskservice.ActiveRoutine) error

Attach mocks base method.

func (*MockTaskRunner) EXPECT 

func (m *MockTaskRunner) EXPECT() *MockTaskRunnerMockRecorder

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

func (*MockTaskRunner) GetExecutor 

func (m *MockTaskRunner) GetExecutor(code task.TaskCode) taskservice.TaskExecutor

GetExecutor mocks base method.

func (*MockTaskRunner) ID 

func (m *MockTaskRunner) ID() string

ID mocks base method.

func (*MockTaskRunner) Parallelism 

func (m *MockTaskRunner) Parallelism() int

Parallelism mocks base method.

func (*MockTaskRunner) RegisterExecutor 

func (m *MockTaskRunner) RegisterExecutor(code task.TaskCode, executor taskservice.TaskExecutor)

RegisterExecutor mocks base method.

func (*MockTaskRunner) Start 

func (m *MockTaskRunner) Start() error

Start mocks base method.

func (*MockTaskRunner) Stop 

func (m *MockTaskRunner) Stop() error

Stop mocks base method.

type MockTaskRunnerMockRecorder 

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

MockTaskRunnerMockRecorder is the mock recorder for MockTaskRunner.

func (*MockTaskRunnerMockRecorder) Attach 

func (mr *MockTaskRunnerMockRecorder) Attach(ctx, taskID, routine any) *gomock.Call

Attach indicates an expected call of Attach.

func (*MockTaskRunnerMockRecorder) GetExecutor 

func (mr *MockTaskRunnerMockRecorder) GetExecutor(code any) *gomock.Call

GetExecutor indicates an expected call of GetExecutor.

func (*MockTaskRunnerMockRecorder) ID 

func (mr *MockTaskRunnerMockRecorder) ID() *gomock.Call

ID indicates an expected call of ID.

func (*MockTaskRunnerMockRecorder) Parallelism 

func (mr *MockTaskRunnerMockRecorder) Parallelism() *gomock.Call

Parallelism indicates an expected call of Parallelism.

func (*MockTaskRunnerMockRecorder) RegisterExecutor 

func (mr *MockTaskRunnerMockRecorder) RegisterExecutor(code, executor any) *gomock.Call

RegisterExecutor indicates an expected call of RegisterExecutor.

func (*MockTaskRunnerMockRecorder) Start 

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

Start indicates an expected call of Start.

func (*MockTaskRunnerMockRecorder) Stop 

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

Stop indicates an expected call of Stop.

type MockTaskService 

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

MockTaskService is a mock of TaskService interface.

func NewMockTaskService 

func NewMockTaskService(ctrl *gomock.Controller) *MockTaskService

NewMockTaskService creates a new mock instance.

func (*MockTaskService) Allocate 

func (m *MockTaskService) Allocate(ctx context.Context, value task.AsyncTask, taskRunner string) error

Allocate mocks base method.

func (*MockTaskService) Close 

func (m *MockTaskService) Close() error

Close mocks base method.

func (*MockTaskService) Complete 

func (m *MockTaskService) Complete(ctx context.Context, taskRunner string, task task.AsyncTask, result task.ExecuteResult) error

Complete mocks base method.

func (*MockTaskService) CreateAsyncTask 

func (m *MockTaskService) CreateAsyncTask(arg0 context.Context, arg1 task.TaskMetadata) error

CreateAsyncTask mocks base method.

func (*MockTaskService) CreateBatch 

func (m *MockTaskService) CreateBatch(arg0 context.Context, arg1 []task.TaskMetadata) error

CreateBatch mocks base method.

func (*MockTaskService) CreateCronTask 

func (m *MockTaskService) CreateCronTask(ctx context.Context, task task.TaskMetadata, cronExpr string) error

CreateCronTask mocks base method.

func (*MockTaskService) CreateDaemonTask 

func (m *MockTaskService) CreateDaemonTask(ctx context.Context, value task.TaskMetadata, details *task.Details) error

CreateDaemonTask mocks base method.

func (*MockTaskService) EXPECT 

func (m *MockTaskService) EXPECT() *MockTaskServiceMockRecorder

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

func (*MockTaskService) GetStorage 

func (m *MockTaskService) GetStorage() taskservice.TaskStorage

GetStorage mocks base method.

func (*MockTaskService) Heartbeat 

func (m *MockTaskService) Heartbeat(ctx context.Context, task task.AsyncTask) error

Heartbeat mocks base method.

func (*MockTaskService) HeartbeatDaemonTask 

func (m *MockTaskService) HeartbeatDaemonTask(ctx context.Context, task task.DaemonTask) error

HeartbeatDaemonTask mocks base method.

func (*MockTaskService) QueryAsyncTask 

func (m *MockTaskService) QueryAsyncTask(arg0 context.Context, arg1 ...taskservice.Condition) ([]task.AsyncTask, error)

QueryAsyncTask mocks base method.

func (*MockTaskService) QueryCronTask 

func (m *MockTaskService) QueryCronTask(arg0 context.Context, arg1 ...taskservice.Condition) ([]task.CronTask, error)

QueryCronTask mocks base method.

func (*MockTaskService) QueryDaemonTask 

func (m *MockTaskService) QueryDaemonTask(ctx context.Context, conds ...taskservice.Condition) ([]task.DaemonTask, error)

QueryDaemonTask mocks base method.

func (*MockTaskService) StartScheduleCronTask 

func (m *MockTaskService) StartScheduleCronTask()

StartScheduleCronTask mocks base method.

func (*MockTaskService) StartScheduleSQLTask 

func (m *MockTaskService) StartScheduleSQLTask()

StartScheduleSQLTask mocks base method.

func (*MockTaskService) StopScheduleCronTask 

func (m *MockTaskService) StopScheduleCronTask()

StopScheduleCronTask mocks base method.

func (*MockTaskService) StopScheduleSQLTask 

func (m *MockTaskService) StopScheduleSQLTask()

StopScheduleSQLTask mocks base method.

func (*MockTaskService) TruncateCompletedTasks 

func (m *MockTaskService) TruncateCompletedTasks(ctx context.Context) error

TruncateCompletedTasks mocks base method.

func (*MockTaskService) UpdateDaemonTask 

func (m *MockTaskService) UpdateDaemonTask(ctx context.Context, tasks []task.DaemonTask, cond ...taskservice.Condition) (int, error)

UpdateDaemonTask mocks base method.

type MockTaskServiceHolder 

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

MockTaskServiceHolder is a mock of TaskServiceHolder interface.

func NewMockTaskServiceHolder 

func NewMockTaskServiceHolder(ctrl *gomock.Controller) *MockTaskServiceHolder

NewMockTaskServiceHolder creates a new mock instance.

func (*MockTaskServiceHolder) Close 

func (m *MockTaskServiceHolder) Close() error

Close mocks base method.

func (*MockTaskServiceHolder) Create 

func (m *MockTaskServiceHolder) Create(command logservice.CreateTaskService) error

Create mocks base method.

func (*MockTaskServiceHolder) EXPECT 

func (m *MockTaskServiceHolder) EXPECT() *MockTaskServiceHolderMockRecorder

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

func (*MockTaskServiceHolder) Get 

func (m *MockTaskServiceHolder) Get() (taskservice.TaskService, bool)

Get mocks base method.

type MockTaskServiceHolderMockRecorder 

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

MockTaskServiceHolderMockRecorder is the mock recorder for MockTaskServiceHolder.

func (*MockTaskServiceHolderMockRecorder) Close 

func (mr *MockTaskServiceHolderMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockTaskServiceHolderMockRecorder) Create 

func (mr *MockTaskServiceHolderMockRecorder) Create(command any) *gomock.Call

Create indicates an expected call of Create.

func (*MockTaskServiceHolderMockRecorder) Get 

func (mr *MockTaskServiceHolderMockRecorder) Get() *gomock.Call

Get indicates an expected call of Get.

type MockTaskServiceMockRecorder 

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

MockTaskServiceMockRecorder is the mock recorder for MockTaskService.

func (*MockTaskServiceMockRecorder) Allocate 

func (mr *MockTaskServiceMockRecorder) Allocate(ctx, value, taskRunner any) *gomock.Call

Allocate indicates an expected call of Allocate.

func (*MockTaskServiceMockRecorder) Close 

func (mr *MockTaskServiceMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockTaskServiceMockRecorder) Complete 

func (mr *MockTaskServiceMockRecorder) Complete(ctx, taskRunner, task, result any) *gomock.Call

Complete indicates an expected call of Complete.

func (*MockTaskServiceMockRecorder) CreateAsyncTask 

func (mr *MockTaskServiceMockRecorder) CreateAsyncTask(arg0, arg1 any) *gomock.Call

CreateAsyncTask indicates an expected call of CreateAsyncTask.

func (*MockTaskServiceMockRecorder) CreateBatch 

func (mr *MockTaskServiceMockRecorder) CreateBatch(arg0, arg1 any) *gomock.Call

CreateBatch indicates an expected call of CreateBatch.

func (*MockTaskServiceMockRecorder) CreateCronTask 

func (mr *MockTaskServiceMockRecorder) CreateCronTask(ctx, task, cronExpr any) *gomock.Call

CreateCronTask indicates an expected call of CreateCronTask.

func (*MockTaskServiceMockRecorder) CreateDaemonTask 

func (mr *MockTaskServiceMockRecorder) CreateDaemonTask(ctx, value, details any) *gomock.Call

CreateDaemonTask indicates an expected call of CreateDaemonTask.

func (*MockTaskServiceMockRecorder) GetStorage 

func (mr *MockTaskServiceMockRecorder) GetStorage() *gomock.Call

GetStorage indicates an expected call of GetStorage.

func (*MockTaskServiceMockRecorder) Heartbeat 

func (mr *MockTaskServiceMockRecorder) Heartbeat(ctx, task any) *gomock.Call

Heartbeat indicates an expected call of Heartbeat.

func (*MockTaskServiceMockRecorder) HeartbeatDaemonTask 

func (mr *MockTaskServiceMockRecorder) HeartbeatDaemonTask(ctx, task any) *gomock.Call

HeartbeatDaemonTask indicates an expected call of HeartbeatDaemonTask.

func (*MockTaskServiceMockRecorder) QueryAsyncTask 

func (mr *MockTaskServiceMockRecorder) QueryAsyncTask(arg0 any, arg1 ...any) *gomock.Call

QueryAsyncTask indicates an expected call of QueryAsyncTask.

func (*MockTaskServiceMockRecorder) QueryCronTask 

func (mr *MockTaskServiceMockRecorder) QueryCronTask(arg0 any, arg1 ...any) *gomock.Call

QueryCronTask indicates an expected call of QueryCronTask.

func (*MockTaskServiceMockRecorder) QueryDaemonTask 

func (mr *MockTaskServiceMockRecorder) QueryDaemonTask(ctx any, conds ...any) *gomock.Call

QueryDaemonTask indicates an expected call of QueryDaemonTask.

func (*MockTaskServiceMockRecorder) StartScheduleCronTask 

func (mr *MockTaskServiceMockRecorder) StartScheduleCronTask() *gomock.Call

StartScheduleCronTask indicates an expected call of StartScheduleCronTask.

func (*MockTaskServiceMockRecorder) StartScheduleSQLTask 

func (mr *MockTaskServiceMockRecorder) StartScheduleSQLTask() *gomock.Call

StartScheduleSQLTask indicates an expected call of StartScheduleSQLTask.

func (*MockTaskServiceMockRecorder) StopScheduleCronTask 

func (mr *MockTaskServiceMockRecorder) StopScheduleCronTask() *gomock.Call

StopScheduleCronTask indicates an expected call of StopScheduleCronTask.

func (*MockTaskServiceMockRecorder) StopScheduleSQLTask 

func (mr *MockTaskServiceMockRecorder) StopScheduleSQLTask() *gomock.Call

StopScheduleSQLTask indicates an expected call of StopScheduleSQLTask.

func (*MockTaskServiceMockRecorder) TruncateCompletedTasks 

func (mr *MockTaskServiceMockRecorder) TruncateCompletedTasks(ctx any) *gomock.Call

TruncateCompletedTasks indicates an expected call of TruncateCompletedTasks.

func (*MockTaskServiceMockRecorder) UpdateDaemonTask 

func (mr *MockTaskServiceMockRecorder) UpdateDaemonTask(ctx, tasks any, cond ...any) *gomock.Call

UpdateDaemonTask indicates an expected call of UpdateDaemonTask.

type MockTaskStorage 

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

MockTaskStorage is a mock of TaskStorage interface.

func NewMockTaskStorage 

func NewMockTaskStorage(ctrl *gomock.Controller) *MockTaskStorage

NewMockTaskStorage creates a new mock instance.

func (*MockTaskStorage) AcquireSQLTaskRun 

func (m *MockTaskStorage) AcquireSQLTaskRun(ctx context.Context, sqlTask taskservice.SQLTask, run taskservice.SQLTaskRun) (uint64, error)

AcquireSQLTaskRun mocks base method.

func (*MockTaskStorage) AddAsyncTask 

func (m *MockTaskStorage) AddAsyncTask(arg0 context.Context, arg1 ...task.AsyncTask) (int, error)

AddAsyncTask mocks base method.

func (*MockTaskStorage) AddCronTask 

func (m *MockTaskStorage) AddCronTask(arg0 context.Context, arg1 ...task.CronTask) (int, error)

AddCronTask mocks base method.

func (*MockTaskStorage) AddDaemonTask 

func (m *MockTaskStorage) AddDaemonTask(ctx context.Context, tasks ...task.DaemonTask) (int, error)

AddDaemonTask mocks base method.

func (*MockTaskStorage) AddSQLTask 

func (m *MockTaskStorage) AddSQLTask(ctx context.Context, tasks ...taskservice.SQLTask) (int, error)

AddSQLTask mocks base method.

func (*MockTaskStorage) AddSQLTaskRun 

func (m *MockTaskStorage) AddSQLTaskRun(ctx context.Context, runs ...taskservice.SQLTaskRun) (int, error)

AddSQLTaskRun mocks base method.

func (*MockTaskStorage) Close 

func (m *MockTaskStorage) Close() error

Close mocks base method.

func (*MockTaskStorage) CompleteSQLTaskRun 

func (m *MockTaskStorage) CompleteSQLTaskRun(ctx context.Context, run taskservice.SQLTaskRun) (int, error)

CompleteSQLTaskRun mocks base method.

func (*MockTaskStorage) DeleteAsyncTask 

func (m *MockTaskStorage) DeleteAsyncTask(arg0 context.Context, arg1 ...taskservice.Condition) (int, error)

DeleteAsyncTask mocks base method.

func (*MockTaskStorage) DeleteDaemonTask 

func (m *MockTaskStorage) DeleteDaemonTask(ctx context.Context, condition ...taskservice.Condition) (int, error)

DeleteDaemonTask mocks base method.

func (*MockTaskStorage) DeleteSQLTask 

func (m *MockTaskStorage) DeleteSQLTask(ctx context.Context, condition ...taskservice.Condition) (int, error)

DeleteSQLTask mocks base method.

func (*MockTaskStorage) EXPECT 

func (m *MockTaskStorage) EXPECT() *MockTaskStorageMockRecorder

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

func (*MockTaskStorage) HeartbeatDaemonTask 

func (m *MockTaskStorage) HeartbeatDaemonTask(ctx context.Context, task []task.DaemonTask) (int, error)

HeartbeatDaemonTask mocks base method.

func (*MockTaskStorage) PingContext 

func (m *MockTaskStorage) PingContext(arg0 context.Context) error

PingContext mocks base method.

func (*MockTaskStorage) QueryAsyncTask 

func (m *MockTaskStorage) QueryAsyncTask(arg0 context.Context, arg1 ...taskservice.Condition) ([]task.AsyncTask, error)

QueryAsyncTask mocks base method.

func (*MockTaskStorage) QueryCronTask 

func (m *MockTaskStorage) QueryCronTask(arg0 context.Context, arg1 ...taskservice.Condition) ([]task.CronTask, error)

QueryCronTask mocks base method.

func (*MockTaskStorage) QueryDaemonTask 

func (m *MockTaskStorage) QueryDaemonTask(ctx context.Context, condition ...taskservice.Condition) ([]task.DaemonTask, error)

QueryDaemonTask mocks base method.

func (*MockTaskStorage) QueryLatestSQLTaskRun 

func (m *MockTaskStorage) QueryLatestSQLTaskRun(ctx context.Context, accountID uint32, taskIDs []uint64) ([]taskservice.SQLTaskRun, error)

QueryLatestSQLTaskRun mocks base method.

func (*MockTaskStorage) QuerySQLTask 

func (m *MockTaskStorage) QuerySQLTask(ctx context.Context, condition ...taskservice.Condition) ([]taskservice.SQLTask, error)

QuerySQLTask mocks base method.

func (*MockTaskStorage) QuerySQLTaskRun 

func (m *MockTaskStorage) QuerySQLTaskRun(ctx context.Context, condition ...taskservice.Condition) ([]taskservice.SQLTaskRun, error)

QuerySQLTaskRun mocks base method.

func (*MockTaskStorage) TriggerSQLTask 

func (m *MockTaskStorage) TriggerSQLTask(ctx context.Context, sqlTask taskservice.SQLTask, asyncTask task.AsyncTask) (int, error)

TriggerSQLTask mocks base method.

func (*MockTaskStorage) UpdateAsyncTask 

func (m *MockTaskStorage) UpdateAsyncTask(arg0 context.Context, arg1 []task.AsyncTask, arg2 ...taskservice.Condition) (int, error)

UpdateAsyncTask mocks base method.

func (*MockTaskStorage) UpdateCronTask 

func (m *MockTaskStorage) UpdateCronTask(arg0 context.Context, arg1 task.CronTask, arg2 task.AsyncTask) (int, error)

UpdateCronTask mocks base method.

func (*MockTaskStorage) UpdateDaemonTask 

func (m *MockTaskStorage) UpdateDaemonTask(ctx context.Context, tasks []task.DaemonTask, conds ...taskservice.Condition) (int, error)

UpdateDaemonTask mocks base method.

func (*MockTaskStorage) UpdateSQLTask 

func (m *MockTaskStorage) UpdateSQLTask(ctx context.Context, tasks []taskservice.SQLTask, conds ...taskservice.Condition) (int, error)

UpdateSQLTask mocks base method.

func (*MockTaskStorage) UpdateSQLTaskRun 

func (m *MockTaskStorage) UpdateSQLTaskRun(ctx context.Context, runs []taskservice.SQLTaskRun, conds ...taskservice.Condition) (int, error)

UpdateSQLTaskRun mocks base method.

type MockTaskStorageFactory 

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

MockTaskStorageFactory is a mock of TaskStorageFactory interface.

func NewMockTaskStorageFactory 

func NewMockTaskStorageFactory(ctrl *gomock.Controller) *MockTaskStorageFactory

NewMockTaskStorageFactory creates a new mock instance.

func (*MockTaskStorageFactory) Create 

func (m *MockTaskStorageFactory) Create(address string) (taskservice.TaskStorage, error)

Create mocks base method.

func (*MockTaskStorageFactory) EXPECT 

func (m *MockTaskStorageFactory) EXPECT() *MockTaskStorageFactoryMockRecorder

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

type MockTaskStorageFactoryMockRecorder 

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

MockTaskStorageFactoryMockRecorder is the mock recorder for MockTaskStorageFactory.

func (*MockTaskStorageFactoryMockRecorder) Create 

func (mr *MockTaskStorageFactoryMockRecorder) Create(address any) *gomock.Call

Create indicates an expected call of Create.

type MockTaskStorageMockRecorder 

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

MockTaskStorageMockRecorder is the mock recorder for MockTaskStorage.

func (*MockTaskStorageMockRecorder) AcquireSQLTaskRun 

func (mr *MockTaskStorageMockRecorder) AcquireSQLTaskRun(ctx, sqlTask, run any) *gomock.Call

AcquireSQLTaskRun indicates an expected call of AcquireSQLTaskRun.

func (*MockTaskStorageMockRecorder) AddAsyncTask 

func (mr *MockTaskStorageMockRecorder) AddAsyncTask(arg0 any, arg1 ...any) *gomock.Call

AddAsyncTask indicates an expected call of AddAsyncTask.

func (*MockTaskStorageMockRecorder) AddCronTask 

func (mr *MockTaskStorageMockRecorder) AddCronTask(arg0 any, arg1 ...any) *gomock.Call

AddCronTask indicates an expected call of AddCronTask.

func (*MockTaskStorageMockRecorder) AddDaemonTask 

func (mr *MockTaskStorageMockRecorder) AddDaemonTask(ctx any, tasks ...any) *gomock.Call

AddDaemonTask indicates an expected call of AddDaemonTask.

func (*MockTaskStorageMockRecorder) AddSQLTask 

func (mr *MockTaskStorageMockRecorder) AddSQLTask(ctx any, tasks ...any) *gomock.Call

AddSQLTask indicates an expected call of AddSQLTask.

func (*MockTaskStorageMockRecorder) AddSQLTaskRun 

func (mr *MockTaskStorageMockRecorder) AddSQLTaskRun(ctx any, runs ...any) *gomock.Call

AddSQLTaskRun indicates an expected call of AddSQLTaskRun.

func (*MockTaskStorageMockRecorder) Close 

func (mr *MockTaskStorageMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockTaskStorageMockRecorder) CompleteSQLTaskRun 

func (mr *MockTaskStorageMockRecorder) CompleteSQLTaskRun(ctx, run any) *gomock.Call

CompleteSQLTaskRun indicates an expected call of CompleteSQLTaskRun.

func (*MockTaskStorageMockRecorder) DeleteAsyncTask 

func (mr *MockTaskStorageMockRecorder) DeleteAsyncTask(arg0 any, arg1 ...any) *gomock.Call

DeleteAsyncTask indicates an expected call of DeleteAsyncTask.

func (*MockTaskStorageMockRecorder) DeleteDaemonTask 

func (mr *MockTaskStorageMockRecorder) DeleteDaemonTask(ctx any, condition ...any) *gomock.Call

DeleteDaemonTask indicates an expected call of DeleteDaemonTask.

func (*MockTaskStorageMockRecorder) DeleteSQLTask 

func (mr *MockTaskStorageMockRecorder) DeleteSQLTask(ctx any, condition ...any) *gomock.Call

DeleteSQLTask indicates an expected call of DeleteSQLTask.

func (*MockTaskStorageMockRecorder) HeartbeatDaemonTask 

func (mr *MockTaskStorageMockRecorder) HeartbeatDaemonTask(ctx, task any) *gomock.Call

HeartbeatDaemonTask indicates an expected call of HeartbeatDaemonTask.

func (*MockTaskStorageMockRecorder) PingContext 

func (mr *MockTaskStorageMockRecorder) PingContext(arg0 any) *gomock.Call

PingContext indicates an expected call of PingContext.

func (*MockTaskStorageMockRecorder) QueryAsyncTask 

func (mr *MockTaskStorageMockRecorder) QueryAsyncTask(arg0 any, arg1 ...any) *gomock.Call

QueryAsyncTask indicates an expected call of QueryAsyncTask.

func (*MockTaskStorageMockRecorder) QueryCronTask 

func (mr *MockTaskStorageMockRecorder) QueryCronTask(arg0 any, arg1 ...any) *gomock.Call

QueryCronTask indicates an expected call of QueryCronTask.

func (*MockTaskStorageMockRecorder) QueryDaemonTask 

func (mr *MockTaskStorageMockRecorder) QueryDaemonTask(ctx any, condition ...any) *gomock.Call

QueryDaemonTask indicates an expected call of QueryDaemonTask.

func (*MockTaskStorageMockRecorder) QueryLatestSQLTaskRun 

func (mr *MockTaskStorageMockRecorder) QueryLatestSQLTaskRun(ctx, accountID, taskIDs any) *gomock.Call

QueryLatestSQLTaskRun indicates an expected call of QueryLatestSQLTaskRun.

func (*MockTaskStorageMockRecorder) QuerySQLTask 

func (mr *MockTaskStorageMockRecorder) QuerySQLTask(ctx any, condition ...any) *gomock.Call

QuerySQLTask indicates an expected call of QuerySQLTask.

func (*MockTaskStorageMockRecorder) QuerySQLTaskRun 

func (mr *MockTaskStorageMockRecorder) QuerySQLTaskRun(ctx any, condition ...any) *gomock.Call

QuerySQLTaskRun indicates an expected call of QuerySQLTaskRun.

func (*MockTaskStorageMockRecorder) TriggerSQLTask 

func (mr *MockTaskStorageMockRecorder) TriggerSQLTask(ctx, sqlTask, asyncTask any) *gomock.Call

TriggerSQLTask indicates an expected call of TriggerSQLTask.

func (*MockTaskStorageMockRecorder) UpdateAsyncTask 

func (mr *MockTaskStorageMockRecorder) UpdateAsyncTask(arg0, arg1 any, arg2 ...any) *gomock.Call

UpdateAsyncTask indicates an expected call of UpdateAsyncTask.

func (*MockTaskStorageMockRecorder) UpdateCronTask 

func (mr *MockTaskStorageMockRecorder) UpdateCronTask(arg0, arg1, arg2 any) *gomock.Call

UpdateCronTask indicates an expected call of UpdateCronTask.

func (*MockTaskStorageMockRecorder) UpdateDaemonTask 

func (mr *MockTaskStorageMockRecorder) UpdateDaemonTask(ctx, tasks any, conds ...any) *gomock.Call

UpdateDaemonTask indicates an expected call of UpdateDaemonTask.

func (*MockTaskStorageMockRecorder) UpdateSQLTask 

func (mr *MockTaskStorageMockRecorder) UpdateSQLTask(ctx, tasks any, conds ...any) *gomock.Call

UpdateSQLTask indicates an expected call of UpdateSQLTask.

func (*MockTaskStorageMockRecorder) UpdateSQLTaskRun 

func (mr *MockTaskStorageMockRecorder) UpdateSQLTaskRun(ctx, runs any, conds ...any) *gomock.Call

UpdateSQLTaskRun indicates an expected call of UpdateSQLTaskRun.

type Mockcondition 

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

Mockcondition is a mock of condition interface.

func NewMockcondition 

func NewMockcondition(ctrl *gomock.Controller) *Mockcondition

NewMockcondition creates a new mock instance.

func (*Mockcondition) EXPECT 

func (m *Mockcondition) EXPECT() *MockconditionMockRecorder

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

type MockconditionMockRecorder 

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

MockconditionMockRecorder is the mock recorder for Mockcondition.

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.