Documentation ¶
Index ¶
- type MockJobsInterface
- func (_m *MockJobsInterface) BaseJobSettingsNameToJobIdMap(ctx context.Context, request jobs.ListJobsRequest) (map[string]int64, error)
- func (_m *MockJobsInterface) CancelAllRuns(ctx context.Context, request jobs.CancelAllRuns) error
- func (_m *MockJobsInterface) CancelRun(ctx context.Context, cancelRun jobs.CancelRun) (*jobs.WaitGetRunJobTerminatedOrSkipped[struct{}], error)
- func (_m *MockJobsInterface) CancelRunAndWait(ctx context.Context, cancelRun jobs.CancelRun, ...) (*jobs.Run, error)
- func (_m *MockJobsInterface) CancelRunByRunId(ctx context.Context, runId int64) error
- func (_m *MockJobsInterface) CancelRunByRunIdAndWait(ctx context.Context, runId int64, options ...retries.Option[jobs.Run]) (*jobs.Run, error)
- func (_m *MockJobsInterface) Create(ctx context.Context, request jobs.CreateJob) (*jobs.CreateResponse, error)
- func (_m *MockJobsInterface) Delete(ctx context.Context, request jobs.DeleteJob) error
- func (_m *MockJobsInterface) DeleteByJobId(ctx context.Context, jobId int64) error
- func (_m *MockJobsInterface) DeleteRun(ctx context.Context, request jobs.DeleteRun) error
- func (_m *MockJobsInterface) DeleteRunByRunId(ctx context.Context, runId int64) error
- func (_m *MockJobsInterface) EXPECT() *MockJobsInterface_Expecter
- func (_m *MockJobsInterface) ExportRun(ctx context.Context, request jobs.ExportRunRequest) (*jobs.ExportRunOutput, error)
- func (_m *MockJobsInterface) Get(ctx context.Context, request jobs.GetJobRequest) (*jobs.Job, error)
- func (_m *MockJobsInterface) GetByJobId(ctx context.Context, jobId int64) (*jobs.Job, error)
- func (_m *MockJobsInterface) GetBySettingsName(ctx context.Context, name string) (*jobs.BaseJob, error)
- func (_m *MockJobsInterface) GetPermissionLevels(ctx context.Context, request jobs.GetJobPermissionLevelsRequest) (*jobs.GetJobPermissionLevelsResponse, error)
- func (_m *MockJobsInterface) GetPermissionLevelsByJobId(ctx context.Context, jobId string) (*jobs.GetJobPermissionLevelsResponse, error)
- func (_m *MockJobsInterface) GetPermissions(ctx context.Context, request jobs.GetJobPermissionsRequest) (*jobs.JobPermissions, error)
- func (_m *MockJobsInterface) GetPermissionsByJobId(ctx context.Context, jobId string) (*jobs.JobPermissions, error)
- func (_m *MockJobsInterface) GetRun(ctx context.Context, request jobs.GetRunRequest) (*jobs.Run, error)
- func (_m *MockJobsInterface) GetRunOutput(ctx context.Context, request jobs.GetRunOutputRequest) (*jobs.RunOutput, error)
- func (_m *MockJobsInterface) GetRunOutputByRunId(ctx context.Context, runId int64) (*jobs.RunOutput, error)
- func (_m *MockJobsInterface) Impl() jobs.JobsService
- func (_m *MockJobsInterface) List(ctx context.Context, request jobs.ListJobsRequest) listing.Iterator[jobs.BaseJob]
- func (_m *MockJobsInterface) ListAll(ctx context.Context, request jobs.ListJobsRequest) ([]jobs.BaseJob, error)
- func (_m *MockJobsInterface) ListRuns(ctx context.Context, request jobs.ListRunsRequest) listing.Iterator[jobs.BaseRun]
- func (_m *MockJobsInterface) ListRunsAll(ctx context.Context, request jobs.ListRunsRequest) ([]jobs.BaseRun, error)
- func (_m *MockJobsInterface) RepairRun(ctx context.Context, repairRun jobs.RepairRun) (*jobs.WaitGetRunJobTerminatedOrSkipped[jobs.RepairRunResponse], error)
- func (_m *MockJobsInterface) RepairRunAndWait(ctx context.Context, repairRun jobs.RepairRun, ...) (*jobs.Run, error)
- func (_m *MockJobsInterface) Reset(ctx context.Context, request jobs.ResetJob) error
- func (_m *MockJobsInterface) RunNow(ctx context.Context, runNow jobs.RunNow) (*jobs.WaitGetRunJobTerminatedOrSkipped[jobs.RunNowResponse], error)
- func (_m *MockJobsInterface) RunNowAndWait(ctx context.Context, runNow jobs.RunNow, options ...retries.Option[jobs.Run]) (*jobs.Run, error)
- func (_m *MockJobsInterface) SetPermissions(ctx context.Context, request jobs.JobPermissionsRequest) (*jobs.JobPermissions, error)
- func (_m *MockJobsInterface) Submit(ctx context.Context, submitRun jobs.SubmitRun) (*jobs.WaitGetRunJobTerminatedOrSkipped[jobs.SubmitRunResponse], error)
- func (_m *MockJobsInterface) SubmitAndWait(ctx context.Context, submitRun jobs.SubmitRun, ...) (*jobs.Run, error)
- func (_m *MockJobsInterface) Update(ctx context.Context, request jobs.UpdateJob) error
- func (_m *MockJobsInterface) UpdatePermissions(ctx context.Context, request jobs.JobPermissionsRequest) (*jobs.JobPermissions, error)
- func (_m *MockJobsInterface) WaitGetRunJobTerminatedOrSkipped(ctx context.Context, runId int64, timeout time.Duration, ...) (*jobs.Run, error)
- func (_m *MockJobsInterface) WithImpl(impl jobs.JobsService) jobs.JobsInterface
- type MockJobsInterface_BaseJobSettingsNameToJobIdMap_Call
- func (_c *MockJobsInterface_BaseJobSettingsNameToJobIdMap_Call) Return(_a0 map[string]int64, _a1 error) *MockJobsInterface_BaseJobSettingsNameToJobIdMap_Call
- func (_c *MockJobsInterface_BaseJobSettingsNameToJobIdMap_Call) Run(run func(ctx context.Context, request jobs.ListJobsRequest)) *MockJobsInterface_BaseJobSettingsNameToJobIdMap_Call
- func (_c *MockJobsInterface_BaseJobSettingsNameToJobIdMap_Call) RunAndReturn(run func(context.Context, jobs.ListJobsRequest) (map[string]int64, error)) *MockJobsInterface_BaseJobSettingsNameToJobIdMap_Call
- type MockJobsInterface_CancelAllRuns_Call
- func (_c *MockJobsInterface_CancelAllRuns_Call) Return(_a0 error) *MockJobsInterface_CancelAllRuns_Call
- func (_c *MockJobsInterface_CancelAllRuns_Call) Run(run func(ctx context.Context, request jobs.CancelAllRuns)) *MockJobsInterface_CancelAllRuns_Call
- func (_c *MockJobsInterface_CancelAllRuns_Call) RunAndReturn(run func(context.Context, jobs.CancelAllRuns) error) *MockJobsInterface_CancelAllRuns_Call
- type MockJobsInterface_CancelRunAndWait_Call
- func (_c *MockJobsInterface_CancelRunAndWait_Call) Return(_a0 *jobs.Run, _a1 error) *MockJobsInterface_CancelRunAndWait_Call
- func (_c *MockJobsInterface_CancelRunAndWait_Call) Run(run func(ctx context.Context, cancelRun jobs.CancelRun, ...)) *MockJobsInterface_CancelRunAndWait_Call
- func (_c *MockJobsInterface_CancelRunAndWait_Call) RunAndReturn(...) *MockJobsInterface_CancelRunAndWait_Call
- type MockJobsInterface_CancelRunByRunIdAndWait_Call
- func (_c *MockJobsInterface_CancelRunByRunIdAndWait_Call) Return(_a0 *jobs.Run, _a1 error) *MockJobsInterface_CancelRunByRunIdAndWait_Call
- func (_c *MockJobsInterface_CancelRunByRunIdAndWait_Call) Run(...) *MockJobsInterface_CancelRunByRunIdAndWait_Call
- func (_c *MockJobsInterface_CancelRunByRunIdAndWait_Call) RunAndReturn(...) *MockJobsInterface_CancelRunByRunIdAndWait_Call
- type MockJobsInterface_CancelRunByRunId_Call
- func (_c *MockJobsInterface_CancelRunByRunId_Call) Return(_a0 error) *MockJobsInterface_CancelRunByRunId_Call
- func (_c *MockJobsInterface_CancelRunByRunId_Call) Run(run func(ctx context.Context, runId int64)) *MockJobsInterface_CancelRunByRunId_Call
- func (_c *MockJobsInterface_CancelRunByRunId_Call) RunAndReturn(run func(context.Context, int64) error) *MockJobsInterface_CancelRunByRunId_Call
- type MockJobsInterface_CancelRun_Call
- func (_c *MockJobsInterface_CancelRun_Call) Return(_a0 *jobs.WaitGetRunJobTerminatedOrSkipped[struct{}], _a1 error) *MockJobsInterface_CancelRun_Call
- func (_c *MockJobsInterface_CancelRun_Call) Run(run func(ctx context.Context, cancelRun jobs.CancelRun)) *MockJobsInterface_CancelRun_Call
- func (_c *MockJobsInterface_CancelRun_Call) RunAndReturn(...) *MockJobsInterface_CancelRun_Call
- type MockJobsInterface_Create_Call
- func (_c *MockJobsInterface_Create_Call) Return(_a0 *jobs.CreateResponse, _a1 error) *MockJobsInterface_Create_Call
- func (_c *MockJobsInterface_Create_Call) Run(run func(ctx context.Context, request jobs.CreateJob)) *MockJobsInterface_Create_Call
- func (_c *MockJobsInterface_Create_Call) RunAndReturn(run func(context.Context, jobs.CreateJob) (*jobs.CreateResponse, error)) *MockJobsInterface_Create_Call
- type MockJobsInterface_DeleteByJobId_Call
- func (_c *MockJobsInterface_DeleteByJobId_Call) Return(_a0 error) *MockJobsInterface_DeleteByJobId_Call
- func (_c *MockJobsInterface_DeleteByJobId_Call) Run(run func(ctx context.Context, jobId int64)) *MockJobsInterface_DeleteByJobId_Call
- func (_c *MockJobsInterface_DeleteByJobId_Call) RunAndReturn(run func(context.Context, int64) error) *MockJobsInterface_DeleteByJobId_Call
- type MockJobsInterface_DeleteRunByRunId_Call
- func (_c *MockJobsInterface_DeleteRunByRunId_Call) Return(_a0 error) *MockJobsInterface_DeleteRunByRunId_Call
- func (_c *MockJobsInterface_DeleteRunByRunId_Call) Run(run func(ctx context.Context, runId int64)) *MockJobsInterface_DeleteRunByRunId_Call
- func (_c *MockJobsInterface_DeleteRunByRunId_Call) RunAndReturn(run func(context.Context, int64) error) *MockJobsInterface_DeleteRunByRunId_Call
- type MockJobsInterface_DeleteRun_Call
- func (_c *MockJobsInterface_DeleteRun_Call) Return(_a0 error) *MockJobsInterface_DeleteRun_Call
- func (_c *MockJobsInterface_DeleteRun_Call) Run(run func(ctx context.Context, request jobs.DeleteRun)) *MockJobsInterface_DeleteRun_Call
- func (_c *MockJobsInterface_DeleteRun_Call) RunAndReturn(run func(context.Context, jobs.DeleteRun) error) *MockJobsInterface_DeleteRun_Call
- type MockJobsInterface_Delete_Call
- func (_c *MockJobsInterface_Delete_Call) Return(_a0 error) *MockJobsInterface_Delete_Call
- func (_c *MockJobsInterface_Delete_Call) Run(run func(ctx context.Context, request jobs.DeleteJob)) *MockJobsInterface_Delete_Call
- func (_c *MockJobsInterface_Delete_Call) RunAndReturn(run func(context.Context, jobs.DeleteJob) error) *MockJobsInterface_Delete_Call
- type MockJobsInterface_Expecter
- func (_e *MockJobsInterface_Expecter) BaseJobSettingsNameToJobIdMap(ctx interface{}, request interface{}) *MockJobsInterface_BaseJobSettingsNameToJobIdMap_Call
- func (_e *MockJobsInterface_Expecter) CancelAllRuns(ctx interface{}, request interface{}) *MockJobsInterface_CancelAllRuns_Call
- func (_e *MockJobsInterface_Expecter) CancelRun(ctx interface{}, cancelRun interface{}) *MockJobsInterface_CancelRun_Call
- func (_e *MockJobsInterface_Expecter) CancelRunAndWait(ctx interface{}, cancelRun interface{}, options ...interface{}) *MockJobsInterface_CancelRunAndWait_Call
- func (_e *MockJobsInterface_Expecter) CancelRunByRunId(ctx interface{}, runId interface{}) *MockJobsInterface_CancelRunByRunId_Call
- func (_e *MockJobsInterface_Expecter) CancelRunByRunIdAndWait(ctx interface{}, runId interface{}, options ...interface{}) *MockJobsInterface_CancelRunByRunIdAndWait_Call
- func (_e *MockJobsInterface_Expecter) Create(ctx interface{}, request interface{}) *MockJobsInterface_Create_Call
- func (_e *MockJobsInterface_Expecter) Delete(ctx interface{}, request interface{}) *MockJobsInterface_Delete_Call
- func (_e *MockJobsInterface_Expecter) DeleteByJobId(ctx interface{}, jobId interface{}) *MockJobsInterface_DeleteByJobId_Call
- func (_e *MockJobsInterface_Expecter) DeleteRun(ctx interface{}, request interface{}) *MockJobsInterface_DeleteRun_Call
- func (_e *MockJobsInterface_Expecter) DeleteRunByRunId(ctx interface{}, runId interface{}) *MockJobsInterface_DeleteRunByRunId_Call
- func (_e *MockJobsInterface_Expecter) ExportRun(ctx interface{}, request interface{}) *MockJobsInterface_ExportRun_Call
- func (_e *MockJobsInterface_Expecter) Get(ctx interface{}, request interface{}) *MockJobsInterface_Get_Call
- func (_e *MockJobsInterface_Expecter) GetByJobId(ctx interface{}, jobId interface{}) *MockJobsInterface_GetByJobId_Call
- func (_e *MockJobsInterface_Expecter) GetBySettingsName(ctx interface{}, name interface{}) *MockJobsInterface_GetBySettingsName_Call
- func (_e *MockJobsInterface_Expecter) GetPermissionLevels(ctx interface{}, request interface{}) *MockJobsInterface_GetPermissionLevels_Call
- func (_e *MockJobsInterface_Expecter) GetPermissionLevelsByJobId(ctx interface{}, jobId interface{}) *MockJobsInterface_GetPermissionLevelsByJobId_Call
- func (_e *MockJobsInterface_Expecter) GetPermissions(ctx interface{}, request interface{}) *MockJobsInterface_GetPermissions_Call
- func (_e *MockJobsInterface_Expecter) GetPermissionsByJobId(ctx interface{}, jobId interface{}) *MockJobsInterface_GetPermissionsByJobId_Call
- func (_e *MockJobsInterface_Expecter) GetRun(ctx interface{}, request interface{}) *MockJobsInterface_GetRun_Call
- func (_e *MockJobsInterface_Expecter) GetRunOutput(ctx interface{}, request interface{}) *MockJobsInterface_GetRunOutput_Call
- func (_e *MockJobsInterface_Expecter) GetRunOutputByRunId(ctx interface{}, runId interface{}) *MockJobsInterface_GetRunOutputByRunId_Call
- func (_e *MockJobsInterface_Expecter) Impl() *MockJobsInterface_Impl_Call
- func (_e *MockJobsInterface_Expecter) List(ctx interface{}, request interface{}) *MockJobsInterface_List_Call
- func (_e *MockJobsInterface_Expecter) ListAll(ctx interface{}, request interface{}) *MockJobsInterface_ListAll_Call
- func (_e *MockJobsInterface_Expecter) ListRuns(ctx interface{}, request interface{}) *MockJobsInterface_ListRuns_Call
- func (_e *MockJobsInterface_Expecter) ListRunsAll(ctx interface{}, request interface{}) *MockJobsInterface_ListRunsAll_Call
- func (_e *MockJobsInterface_Expecter) RepairRun(ctx interface{}, repairRun interface{}) *MockJobsInterface_RepairRun_Call
- func (_e *MockJobsInterface_Expecter) RepairRunAndWait(ctx interface{}, repairRun interface{}, options ...interface{}) *MockJobsInterface_RepairRunAndWait_Call
- func (_e *MockJobsInterface_Expecter) Reset(ctx interface{}, request interface{}) *MockJobsInterface_Reset_Call
- func (_e *MockJobsInterface_Expecter) RunNow(ctx interface{}, runNow interface{}) *MockJobsInterface_RunNow_Call
- func (_e *MockJobsInterface_Expecter) RunNowAndWait(ctx interface{}, runNow interface{}, options ...interface{}) *MockJobsInterface_RunNowAndWait_Call
- func (_e *MockJobsInterface_Expecter) SetPermissions(ctx interface{}, request interface{}) *MockJobsInterface_SetPermissions_Call
- func (_e *MockJobsInterface_Expecter) Submit(ctx interface{}, submitRun interface{}) *MockJobsInterface_Submit_Call
- func (_e *MockJobsInterface_Expecter) SubmitAndWait(ctx interface{}, submitRun interface{}, options ...interface{}) *MockJobsInterface_SubmitAndWait_Call
- func (_e *MockJobsInterface_Expecter) Update(ctx interface{}, request interface{}) *MockJobsInterface_Update_Call
- func (_e *MockJobsInterface_Expecter) UpdatePermissions(ctx interface{}, request interface{}) *MockJobsInterface_UpdatePermissions_Call
- func (_e *MockJobsInterface_Expecter) WaitGetRunJobTerminatedOrSkipped(ctx interface{}, runId interface{}, timeout interface{}, callback interface{}) *MockJobsInterface_WaitGetRunJobTerminatedOrSkipped_Call
- func (_e *MockJobsInterface_Expecter) WithImpl(impl interface{}) *MockJobsInterface_WithImpl_Call
- type MockJobsInterface_ExportRun_Call
- func (_c *MockJobsInterface_ExportRun_Call) Return(_a0 *jobs.ExportRunOutput, _a1 error) *MockJobsInterface_ExportRun_Call
- func (_c *MockJobsInterface_ExportRun_Call) Run(run func(ctx context.Context, request jobs.ExportRunRequest)) *MockJobsInterface_ExportRun_Call
- func (_c *MockJobsInterface_ExportRun_Call) RunAndReturn(...) *MockJobsInterface_ExportRun_Call
- type MockJobsInterface_GetByJobId_Call
- func (_c *MockJobsInterface_GetByJobId_Call) Return(_a0 *jobs.Job, _a1 error) *MockJobsInterface_GetByJobId_Call
- func (_c *MockJobsInterface_GetByJobId_Call) Run(run func(ctx context.Context, jobId int64)) *MockJobsInterface_GetByJobId_Call
- func (_c *MockJobsInterface_GetByJobId_Call) RunAndReturn(run func(context.Context, int64) (*jobs.Job, error)) *MockJobsInterface_GetByJobId_Call
- type MockJobsInterface_GetBySettingsName_Call
- func (_c *MockJobsInterface_GetBySettingsName_Call) Return(_a0 *jobs.BaseJob, _a1 error) *MockJobsInterface_GetBySettingsName_Call
- func (_c *MockJobsInterface_GetBySettingsName_Call) Run(run func(ctx context.Context, name string)) *MockJobsInterface_GetBySettingsName_Call
- func (_c *MockJobsInterface_GetBySettingsName_Call) RunAndReturn(run func(context.Context, string) (*jobs.BaseJob, error)) *MockJobsInterface_GetBySettingsName_Call
- type MockJobsInterface_GetPermissionLevelsByJobId_Call
- func (_c *MockJobsInterface_GetPermissionLevelsByJobId_Call) Return(_a0 *jobs.GetJobPermissionLevelsResponse, _a1 error) *MockJobsInterface_GetPermissionLevelsByJobId_Call
- func (_c *MockJobsInterface_GetPermissionLevelsByJobId_Call) Run(run func(ctx context.Context, jobId string)) *MockJobsInterface_GetPermissionLevelsByJobId_Call
- func (_c *MockJobsInterface_GetPermissionLevelsByJobId_Call) RunAndReturn(...) *MockJobsInterface_GetPermissionLevelsByJobId_Call
- type MockJobsInterface_GetPermissionLevels_Call
- func (_c *MockJobsInterface_GetPermissionLevels_Call) Return(_a0 *jobs.GetJobPermissionLevelsResponse, _a1 error) *MockJobsInterface_GetPermissionLevels_Call
- func (_c *MockJobsInterface_GetPermissionLevels_Call) Run(run func(ctx context.Context, request jobs.GetJobPermissionLevelsRequest)) *MockJobsInterface_GetPermissionLevels_Call
- func (_c *MockJobsInterface_GetPermissionLevels_Call) RunAndReturn(...) *MockJobsInterface_GetPermissionLevels_Call
- type MockJobsInterface_GetPermissionsByJobId_Call
- func (_c *MockJobsInterface_GetPermissionsByJobId_Call) Return(_a0 *jobs.JobPermissions, _a1 error) *MockJobsInterface_GetPermissionsByJobId_Call
- func (_c *MockJobsInterface_GetPermissionsByJobId_Call) Run(run func(ctx context.Context, jobId string)) *MockJobsInterface_GetPermissionsByJobId_Call
- func (_c *MockJobsInterface_GetPermissionsByJobId_Call) RunAndReturn(run func(context.Context, string) (*jobs.JobPermissions, error)) *MockJobsInterface_GetPermissionsByJobId_Call
- type MockJobsInterface_GetPermissions_Call
- func (_c *MockJobsInterface_GetPermissions_Call) Return(_a0 *jobs.JobPermissions, _a1 error) *MockJobsInterface_GetPermissions_Call
- func (_c *MockJobsInterface_GetPermissions_Call) Run(run func(ctx context.Context, request jobs.GetJobPermissionsRequest)) *MockJobsInterface_GetPermissions_Call
- func (_c *MockJobsInterface_GetPermissions_Call) RunAndReturn(...) *MockJobsInterface_GetPermissions_Call
- type MockJobsInterface_GetRunOutputByRunId_Call
- func (_c *MockJobsInterface_GetRunOutputByRunId_Call) Return(_a0 *jobs.RunOutput, _a1 error) *MockJobsInterface_GetRunOutputByRunId_Call
- func (_c *MockJobsInterface_GetRunOutputByRunId_Call) Run(run func(ctx context.Context, runId int64)) *MockJobsInterface_GetRunOutputByRunId_Call
- func (_c *MockJobsInterface_GetRunOutputByRunId_Call) RunAndReturn(run func(context.Context, int64) (*jobs.RunOutput, error)) *MockJobsInterface_GetRunOutputByRunId_Call
- type MockJobsInterface_GetRunOutput_Call
- func (_c *MockJobsInterface_GetRunOutput_Call) Return(_a0 *jobs.RunOutput, _a1 error) *MockJobsInterface_GetRunOutput_Call
- func (_c *MockJobsInterface_GetRunOutput_Call) Run(run func(ctx context.Context, request jobs.GetRunOutputRequest)) *MockJobsInterface_GetRunOutput_Call
- func (_c *MockJobsInterface_GetRunOutput_Call) RunAndReturn(run func(context.Context, jobs.GetRunOutputRequest) (*jobs.RunOutput, error)) *MockJobsInterface_GetRunOutput_Call
- type MockJobsInterface_GetRun_Call
- func (_c *MockJobsInterface_GetRun_Call) Return(_a0 *jobs.Run, _a1 error) *MockJobsInterface_GetRun_Call
- func (_c *MockJobsInterface_GetRun_Call) Run(run func(ctx context.Context, request jobs.GetRunRequest)) *MockJobsInterface_GetRun_Call
- func (_c *MockJobsInterface_GetRun_Call) RunAndReturn(run func(context.Context, jobs.GetRunRequest) (*jobs.Run, error)) *MockJobsInterface_GetRun_Call
- type MockJobsInterface_Get_Call
- func (_c *MockJobsInterface_Get_Call) Return(_a0 *jobs.Job, _a1 error) *MockJobsInterface_Get_Call
- func (_c *MockJobsInterface_Get_Call) Run(run func(ctx context.Context, request jobs.GetJobRequest)) *MockJobsInterface_Get_Call
- func (_c *MockJobsInterface_Get_Call) RunAndReturn(run func(context.Context, jobs.GetJobRequest) (*jobs.Job, error)) *MockJobsInterface_Get_Call
- type MockJobsInterface_Impl_Call
- type MockJobsInterface_ListAll_Call
- func (_c *MockJobsInterface_ListAll_Call) Return(_a0 []jobs.BaseJob, _a1 error) *MockJobsInterface_ListAll_Call
- func (_c *MockJobsInterface_ListAll_Call) Run(run func(ctx context.Context, request jobs.ListJobsRequest)) *MockJobsInterface_ListAll_Call
- func (_c *MockJobsInterface_ListAll_Call) RunAndReturn(run func(context.Context, jobs.ListJobsRequest) ([]jobs.BaseJob, error)) *MockJobsInterface_ListAll_Call
- type MockJobsInterface_ListRunsAll_Call
- func (_c *MockJobsInterface_ListRunsAll_Call) Return(_a0 []jobs.BaseRun, _a1 error) *MockJobsInterface_ListRunsAll_Call
- func (_c *MockJobsInterface_ListRunsAll_Call) Run(run func(ctx context.Context, request jobs.ListRunsRequest)) *MockJobsInterface_ListRunsAll_Call
- func (_c *MockJobsInterface_ListRunsAll_Call) RunAndReturn(run func(context.Context, jobs.ListRunsRequest) ([]jobs.BaseRun, error)) *MockJobsInterface_ListRunsAll_Call
- type MockJobsInterface_ListRuns_Call
- func (_c *MockJobsInterface_ListRuns_Call) Return(_a0 listing.Iterator[jobs.BaseRun]) *MockJobsInterface_ListRuns_Call
- func (_c *MockJobsInterface_ListRuns_Call) Run(run func(ctx context.Context, request jobs.ListRunsRequest)) *MockJobsInterface_ListRuns_Call
- func (_c *MockJobsInterface_ListRuns_Call) RunAndReturn(run func(context.Context, jobs.ListRunsRequest) listing.Iterator[jobs.BaseRun]) *MockJobsInterface_ListRuns_Call
- type MockJobsInterface_List_Call
- func (_c *MockJobsInterface_List_Call) Return(_a0 listing.Iterator[jobs.BaseJob]) *MockJobsInterface_List_Call
- func (_c *MockJobsInterface_List_Call) Run(run func(ctx context.Context, request jobs.ListJobsRequest)) *MockJobsInterface_List_Call
- func (_c *MockJobsInterface_List_Call) RunAndReturn(run func(context.Context, jobs.ListJobsRequest) listing.Iterator[jobs.BaseJob]) *MockJobsInterface_List_Call
- type MockJobsInterface_RepairRunAndWait_Call
- func (_c *MockJobsInterface_RepairRunAndWait_Call) Return(_a0 *jobs.Run, _a1 error) *MockJobsInterface_RepairRunAndWait_Call
- func (_c *MockJobsInterface_RepairRunAndWait_Call) Run(run func(ctx context.Context, repairRun jobs.RepairRun, ...)) *MockJobsInterface_RepairRunAndWait_Call
- func (_c *MockJobsInterface_RepairRunAndWait_Call) RunAndReturn(...) *MockJobsInterface_RepairRunAndWait_Call
- type MockJobsInterface_RepairRun_Call
- func (_c *MockJobsInterface_RepairRun_Call) Return(_a0 *jobs.WaitGetRunJobTerminatedOrSkipped[jobs.RepairRunResponse], _a1 error) *MockJobsInterface_RepairRun_Call
- func (_c *MockJobsInterface_RepairRun_Call) Run(run func(ctx context.Context, repairRun jobs.RepairRun)) *MockJobsInterface_RepairRun_Call
- func (_c *MockJobsInterface_RepairRun_Call) RunAndReturn(...) *MockJobsInterface_RepairRun_Call
- type MockJobsInterface_Reset_Call
- func (_c *MockJobsInterface_Reset_Call) Return(_a0 error) *MockJobsInterface_Reset_Call
- func (_c *MockJobsInterface_Reset_Call) Run(run func(ctx context.Context, request jobs.ResetJob)) *MockJobsInterface_Reset_Call
- func (_c *MockJobsInterface_Reset_Call) RunAndReturn(run func(context.Context, jobs.ResetJob) error) *MockJobsInterface_Reset_Call
- type MockJobsInterface_RunNowAndWait_Call
- func (_c *MockJobsInterface_RunNowAndWait_Call) Return(_a0 *jobs.Run, _a1 error) *MockJobsInterface_RunNowAndWait_Call
- func (_c *MockJobsInterface_RunNowAndWait_Call) Run(...) *MockJobsInterface_RunNowAndWait_Call
- func (_c *MockJobsInterface_RunNowAndWait_Call) RunAndReturn(...) *MockJobsInterface_RunNowAndWait_Call
- type MockJobsInterface_RunNow_Call
- func (_c *MockJobsInterface_RunNow_Call) Return(_a0 *jobs.WaitGetRunJobTerminatedOrSkipped[jobs.RunNowResponse], _a1 error) *MockJobsInterface_RunNow_Call
- func (_c *MockJobsInterface_RunNow_Call) Run(run func(ctx context.Context, runNow jobs.RunNow)) *MockJobsInterface_RunNow_Call
- func (_c *MockJobsInterface_RunNow_Call) RunAndReturn(...) *MockJobsInterface_RunNow_Call
- type MockJobsInterface_SetPermissions_Call
- func (_c *MockJobsInterface_SetPermissions_Call) Return(_a0 *jobs.JobPermissions, _a1 error) *MockJobsInterface_SetPermissions_Call
- func (_c *MockJobsInterface_SetPermissions_Call) Run(run func(ctx context.Context, request jobs.JobPermissionsRequest)) *MockJobsInterface_SetPermissions_Call
- func (_c *MockJobsInterface_SetPermissions_Call) RunAndReturn(...) *MockJobsInterface_SetPermissions_Call
- type MockJobsInterface_SubmitAndWait_Call
- func (_c *MockJobsInterface_SubmitAndWait_Call) Return(_a0 *jobs.Run, _a1 error) *MockJobsInterface_SubmitAndWait_Call
- func (_c *MockJobsInterface_SubmitAndWait_Call) Run(run func(ctx context.Context, submitRun jobs.SubmitRun, ...)) *MockJobsInterface_SubmitAndWait_Call
- func (_c *MockJobsInterface_SubmitAndWait_Call) RunAndReturn(...) *MockJobsInterface_SubmitAndWait_Call
- type MockJobsInterface_Submit_Call
- func (_c *MockJobsInterface_Submit_Call) Return(_a0 *jobs.WaitGetRunJobTerminatedOrSkipped[jobs.SubmitRunResponse], _a1 error) *MockJobsInterface_Submit_Call
- func (_c *MockJobsInterface_Submit_Call) Run(run func(ctx context.Context, submitRun jobs.SubmitRun)) *MockJobsInterface_Submit_Call
- func (_c *MockJobsInterface_Submit_Call) RunAndReturn(...) *MockJobsInterface_Submit_Call
- type MockJobsInterface_UpdatePermissions_Call
- func (_c *MockJobsInterface_UpdatePermissions_Call) Return(_a0 *jobs.JobPermissions, _a1 error) *MockJobsInterface_UpdatePermissions_Call
- func (_c *MockJobsInterface_UpdatePermissions_Call) Run(run func(ctx context.Context, request jobs.JobPermissionsRequest)) *MockJobsInterface_UpdatePermissions_Call
- func (_c *MockJobsInterface_UpdatePermissions_Call) RunAndReturn(...) *MockJobsInterface_UpdatePermissions_Call
- type MockJobsInterface_Update_Call
- func (_c *MockJobsInterface_Update_Call) Return(_a0 error) *MockJobsInterface_Update_Call
- func (_c *MockJobsInterface_Update_Call) Run(run func(ctx context.Context, request jobs.UpdateJob)) *MockJobsInterface_Update_Call
- func (_c *MockJobsInterface_Update_Call) RunAndReturn(run func(context.Context, jobs.UpdateJob) error) *MockJobsInterface_Update_Call
- type MockJobsInterface_WaitGetRunJobTerminatedOrSkipped_Call
- func (_c *MockJobsInterface_WaitGetRunJobTerminatedOrSkipped_Call) Return(_a0 *jobs.Run, _a1 error) *MockJobsInterface_WaitGetRunJobTerminatedOrSkipped_Call
- func (_c *MockJobsInterface_WaitGetRunJobTerminatedOrSkipped_Call) Run(run func(ctx context.Context, runId int64, timeout time.Duration, ...)) *MockJobsInterface_WaitGetRunJobTerminatedOrSkipped_Call
- func (_c *MockJobsInterface_WaitGetRunJobTerminatedOrSkipped_Call) RunAndReturn(...) *MockJobsInterface_WaitGetRunJobTerminatedOrSkipped_Call
- type MockJobsInterface_WithImpl_Call
- func (_c *MockJobsInterface_WithImpl_Call) Return(_a0 jobs.JobsInterface) *MockJobsInterface_WithImpl_Call
- func (_c *MockJobsInterface_WithImpl_Call) Run(run func(impl jobs.JobsService)) *MockJobsInterface_WithImpl_Call
- func (_c *MockJobsInterface_WithImpl_Call) RunAndReturn(run func(jobs.JobsService) jobs.JobsInterface) *MockJobsInterface_WithImpl_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockJobsInterface ¶
MockJobsInterface is an autogenerated mock type for the JobsInterface type
func NewMockJobsInterface ¶
func NewMockJobsInterface(t interface { mock.TestingT Cleanup(func()) }) *MockJobsInterface
NewMockJobsInterface creates a new instance of MockJobsInterface. 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 (*MockJobsInterface) BaseJobSettingsNameToJobIdMap ¶
func (_m *MockJobsInterface) BaseJobSettingsNameToJobIdMap(ctx context.Context, request jobs.ListJobsRequest) (map[string]int64, error)
BaseJobSettingsNameToJobIdMap provides a mock function with given fields: ctx, request
func (*MockJobsInterface) CancelAllRuns ¶
func (_m *MockJobsInterface) CancelAllRuns(ctx context.Context, request jobs.CancelAllRuns) error
CancelAllRuns provides a mock function with given fields: ctx, request
func (*MockJobsInterface) CancelRun ¶
func (_m *MockJobsInterface) CancelRun(ctx context.Context, cancelRun jobs.CancelRun) (*jobs.WaitGetRunJobTerminatedOrSkipped[struct{}], error)
CancelRun provides a mock function with given fields: ctx, cancelRun
func (*MockJobsInterface) CancelRunAndWait ¶
func (_m *MockJobsInterface) CancelRunAndWait(ctx context.Context, cancelRun jobs.CancelRun, options ...retries.Option[jobs.Run]) (*jobs.Run, error)
CancelRunAndWait provides a mock function with given fields: ctx, cancelRun, options
func (*MockJobsInterface) CancelRunByRunId ¶
func (_m *MockJobsInterface) CancelRunByRunId(ctx context.Context, runId int64) error
CancelRunByRunId provides a mock function with given fields: ctx, runId
func (*MockJobsInterface) CancelRunByRunIdAndWait ¶
func (_m *MockJobsInterface) CancelRunByRunIdAndWait(ctx context.Context, runId int64, options ...retries.Option[jobs.Run]) (*jobs.Run, error)
CancelRunByRunIdAndWait provides a mock function with given fields: ctx, runId, options
func (*MockJobsInterface) Create ¶
func (_m *MockJobsInterface) Create(ctx context.Context, request jobs.CreateJob) (*jobs.CreateResponse, error)
Create provides a mock function with given fields: ctx, request
func (*MockJobsInterface) DeleteByJobId ¶
func (_m *MockJobsInterface) DeleteByJobId(ctx context.Context, jobId int64) error
DeleteByJobId provides a mock function with given fields: ctx, jobId
func (*MockJobsInterface) DeleteRun ¶
DeleteRun provides a mock function with given fields: ctx, request
func (*MockJobsInterface) DeleteRunByRunId ¶
func (_m *MockJobsInterface) DeleteRunByRunId(ctx context.Context, runId int64) error
DeleteRunByRunId provides a mock function with given fields: ctx, runId
func (*MockJobsInterface) EXPECT ¶
func (_m *MockJobsInterface) EXPECT() *MockJobsInterface_Expecter
func (*MockJobsInterface) ExportRun ¶
func (_m *MockJobsInterface) ExportRun(ctx context.Context, request jobs.ExportRunRequest) (*jobs.ExportRunOutput, error)
ExportRun provides a mock function with given fields: ctx, request
func (*MockJobsInterface) Get ¶
func (_m *MockJobsInterface) Get(ctx context.Context, request jobs.GetJobRequest) (*jobs.Job, error)
Get provides a mock function with given fields: ctx, request
func (*MockJobsInterface) GetByJobId ¶
GetByJobId provides a mock function with given fields: ctx, jobId
func (*MockJobsInterface) GetBySettingsName ¶
func (_m *MockJobsInterface) GetBySettingsName(ctx context.Context, name string) (*jobs.BaseJob, error)
GetBySettingsName provides a mock function with given fields: ctx, name
func (*MockJobsInterface) GetPermissionLevels ¶
func (_m *MockJobsInterface) GetPermissionLevels(ctx context.Context, request jobs.GetJobPermissionLevelsRequest) (*jobs.GetJobPermissionLevelsResponse, error)
GetPermissionLevels provides a mock function with given fields: ctx, request
func (*MockJobsInterface) GetPermissionLevelsByJobId ¶
func (_m *MockJobsInterface) GetPermissionLevelsByJobId(ctx context.Context, jobId string) (*jobs.GetJobPermissionLevelsResponse, error)
GetPermissionLevelsByJobId provides a mock function with given fields: ctx, jobId
func (*MockJobsInterface) GetPermissions ¶
func (_m *MockJobsInterface) GetPermissions(ctx context.Context, request jobs.GetJobPermissionsRequest) (*jobs.JobPermissions, error)
GetPermissions provides a mock function with given fields: ctx, request
func (*MockJobsInterface) GetPermissionsByJobId ¶
func (_m *MockJobsInterface) GetPermissionsByJobId(ctx context.Context, jobId string) (*jobs.JobPermissions, error)
GetPermissionsByJobId provides a mock function with given fields: ctx, jobId
func (*MockJobsInterface) GetRun ¶
func (_m *MockJobsInterface) GetRun(ctx context.Context, request jobs.GetRunRequest) (*jobs.Run, error)
GetRun provides a mock function with given fields: ctx, request
func (*MockJobsInterface) GetRunOutput ¶
func (_m *MockJobsInterface) GetRunOutput(ctx context.Context, request jobs.GetRunOutputRequest) (*jobs.RunOutput, error)
GetRunOutput provides a mock function with given fields: ctx, request
func (*MockJobsInterface) GetRunOutputByRunId ¶
func (_m *MockJobsInterface) GetRunOutputByRunId(ctx context.Context, runId int64) (*jobs.RunOutput, error)
GetRunOutputByRunId provides a mock function with given fields: ctx, runId
func (*MockJobsInterface) Impl ¶
func (_m *MockJobsInterface) Impl() jobs.JobsService
Impl provides a mock function with given fields:
func (*MockJobsInterface) List ¶
func (_m *MockJobsInterface) List(ctx context.Context, request jobs.ListJobsRequest) listing.Iterator[jobs.BaseJob]
List provides a mock function with given fields: ctx, request
func (*MockJobsInterface) ListAll ¶
func (_m *MockJobsInterface) ListAll(ctx context.Context, request jobs.ListJobsRequest) ([]jobs.BaseJob, error)
ListAll provides a mock function with given fields: ctx, request
func (*MockJobsInterface) ListRuns ¶
func (_m *MockJobsInterface) ListRuns(ctx context.Context, request jobs.ListRunsRequest) listing.Iterator[jobs.BaseRun]
ListRuns provides a mock function with given fields: ctx, request
func (*MockJobsInterface) ListRunsAll ¶
func (_m *MockJobsInterface) ListRunsAll(ctx context.Context, request jobs.ListRunsRequest) ([]jobs.BaseRun, error)
ListRunsAll provides a mock function with given fields: ctx, request
func (*MockJobsInterface) RepairRun ¶
func (_m *MockJobsInterface) RepairRun(ctx context.Context, repairRun jobs.RepairRun) (*jobs.WaitGetRunJobTerminatedOrSkipped[jobs.RepairRunResponse], error)
RepairRun provides a mock function with given fields: ctx, repairRun
func (*MockJobsInterface) RepairRunAndWait ¶
func (_m *MockJobsInterface) RepairRunAndWait(ctx context.Context, repairRun jobs.RepairRun, options ...retries.Option[jobs.Run]) (*jobs.Run, error)
RepairRunAndWait provides a mock function with given fields: ctx, repairRun, options
func (*MockJobsInterface) RunNow ¶
func (_m *MockJobsInterface) RunNow(ctx context.Context, runNow jobs.RunNow) (*jobs.WaitGetRunJobTerminatedOrSkipped[jobs.RunNowResponse], error)
RunNow provides a mock function with given fields: ctx, runNow
func (*MockJobsInterface) RunNowAndWait ¶
func (_m *MockJobsInterface) RunNowAndWait(ctx context.Context, runNow jobs.RunNow, options ...retries.Option[jobs.Run]) (*jobs.Run, error)
RunNowAndWait provides a mock function with given fields: ctx, runNow, options
func (*MockJobsInterface) SetPermissions ¶
func (_m *MockJobsInterface) SetPermissions(ctx context.Context, request jobs.JobPermissionsRequest) (*jobs.JobPermissions, error)
SetPermissions provides a mock function with given fields: ctx, request
func (*MockJobsInterface) Submit ¶
func (_m *MockJobsInterface) Submit(ctx context.Context, submitRun jobs.SubmitRun) (*jobs.WaitGetRunJobTerminatedOrSkipped[jobs.SubmitRunResponse], error)
Submit provides a mock function with given fields: ctx, submitRun
func (*MockJobsInterface) SubmitAndWait ¶
func (_m *MockJobsInterface) SubmitAndWait(ctx context.Context, submitRun jobs.SubmitRun, options ...retries.Option[jobs.Run]) (*jobs.Run, error)
SubmitAndWait provides a mock function with given fields: ctx, submitRun, options
func (*MockJobsInterface) UpdatePermissions ¶
func (_m *MockJobsInterface) UpdatePermissions(ctx context.Context, request jobs.JobPermissionsRequest) (*jobs.JobPermissions, error)
UpdatePermissions provides a mock function with given fields: ctx, request
func (*MockJobsInterface) WaitGetRunJobTerminatedOrSkipped ¶
func (_m *MockJobsInterface) WaitGetRunJobTerminatedOrSkipped(ctx context.Context, runId int64, timeout time.Duration, callback func(*jobs.Run)) (*jobs.Run, error)
WaitGetRunJobTerminatedOrSkipped provides a mock function with given fields: ctx, runId, timeout, callback
func (*MockJobsInterface) WithImpl ¶
func (_m *MockJobsInterface) WithImpl(impl jobs.JobsService) jobs.JobsInterface
WithImpl provides a mock function with given fields: impl
type MockJobsInterface_BaseJobSettingsNameToJobIdMap_Call ¶
MockJobsInterface_BaseJobSettingsNameToJobIdMap_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'BaseJobSettingsNameToJobIdMap'
func (*MockJobsInterface_BaseJobSettingsNameToJobIdMap_Call) Return ¶
func (_c *MockJobsInterface_BaseJobSettingsNameToJobIdMap_Call) Return(_a0 map[string]int64, _a1 error) *MockJobsInterface_BaseJobSettingsNameToJobIdMap_Call
func (*MockJobsInterface_BaseJobSettingsNameToJobIdMap_Call) Run ¶
func (_c *MockJobsInterface_BaseJobSettingsNameToJobIdMap_Call) Run(run func(ctx context.Context, request jobs.ListJobsRequest)) *MockJobsInterface_BaseJobSettingsNameToJobIdMap_Call
func (*MockJobsInterface_BaseJobSettingsNameToJobIdMap_Call) RunAndReturn ¶
func (_c *MockJobsInterface_BaseJobSettingsNameToJobIdMap_Call) RunAndReturn(run func(context.Context, jobs.ListJobsRequest) (map[string]int64, error)) *MockJobsInterface_BaseJobSettingsNameToJobIdMap_Call
type MockJobsInterface_CancelAllRuns_Call ¶
MockJobsInterface_CancelAllRuns_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CancelAllRuns'
func (*MockJobsInterface_CancelAllRuns_Call) Return ¶
func (_c *MockJobsInterface_CancelAllRuns_Call) Return(_a0 error) *MockJobsInterface_CancelAllRuns_Call
func (*MockJobsInterface_CancelAllRuns_Call) Run ¶
func (_c *MockJobsInterface_CancelAllRuns_Call) Run(run func(ctx context.Context, request jobs.CancelAllRuns)) *MockJobsInterface_CancelAllRuns_Call
func (*MockJobsInterface_CancelAllRuns_Call) RunAndReturn ¶
func (_c *MockJobsInterface_CancelAllRuns_Call) RunAndReturn(run func(context.Context, jobs.CancelAllRuns) error) *MockJobsInterface_CancelAllRuns_Call
type MockJobsInterface_CancelRunAndWait_Call ¶
MockJobsInterface_CancelRunAndWait_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CancelRunAndWait'
func (*MockJobsInterface_CancelRunAndWait_Call) Return ¶
func (_c *MockJobsInterface_CancelRunAndWait_Call) Return(_a0 *jobs.Run, _a1 error) *MockJobsInterface_CancelRunAndWait_Call
func (*MockJobsInterface_CancelRunAndWait_Call) Run ¶
func (_c *MockJobsInterface_CancelRunAndWait_Call) Run(run func(ctx context.Context, cancelRun jobs.CancelRun, options ...retries.Option[jobs.Run])) *MockJobsInterface_CancelRunAndWait_Call
func (*MockJobsInterface_CancelRunAndWait_Call) RunAndReturn ¶
type MockJobsInterface_CancelRunByRunIdAndWait_Call ¶
MockJobsInterface_CancelRunByRunIdAndWait_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CancelRunByRunIdAndWait'
func (*MockJobsInterface_CancelRunByRunIdAndWait_Call) Return ¶
func (_c *MockJobsInterface_CancelRunByRunIdAndWait_Call) Return(_a0 *jobs.Run, _a1 error) *MockJobsInterface_CancelRunByRunIdAndWait_Call
func (*MockJobsInterface_CancelRunByRunIdAndWait_Call) Run ¶
func (_c *MockJobsInterface_CancelRunByRunIdAndWait_Call) Run(run func(ctx context.Context, runId int64, options ...retries.Option[jobs.Run])) *MockJobsInterface_CancelRunByRunIdAndWait_Call
func (*MockJobsInterface_CancelRunByRunIdAndWait_Call) RunAndReturn ¶
type MockJobsInterface_CancelRunByRunId_Call ¶
MockJobsInterface_CancelRunByRunId_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CancelRunByRunId'
func (*MockJobsInterface_CancelRunByRunId_Call) Return ¶
func (_c *MockJobsInterface_CancelRunByRunId_Call) Return(_a0 error) *MockJobsInterface_CancelRunByRunId_Call
func (*MockJobsInterface_CancelRunByRunId_Call) Run ¶
func (_c *MockJobsInterface_CancelRunByRunId_Call) Run(run func(ctx context.Context, runId int64)) *MockJobsInterface_CancelRunByRunId_Call
func (*MockJobsInterface_CancelRunByRunId_Call) RunAndReturn ¶
func (_c *MockJobsInterface_CancelRunByRunId_Call) RunAndReturn(run func(context.Context, int64) error) *MockJobsInterface_CancelRunByRunId_Call
type MockJobsInterface_CancelRun_Call ¶
MockJobsInterface_CancelRun_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CancelRun'
func (*MockJobsInterface_CancelRun_Call) Return ¶
func (_c *MockJobsInterface_CancelRun_Call) Return(_a0 *jobs.WaitGetRunJobTerminatedOrSkipped[struct{}], _a1 error) *MockJobsInterface_CancelRun_Call
func (*MockJobsInterface_CancelRun_Call) Run ¶
func (_c *MockJobsInterface_CancelRun_Call) Run(run func(ctx context.Context, cancelRun jobs.CancelRun)) *MockJobsInterface_CancelRun_Call
func (*MockJobsInterface_CancelRun_Call) RunAndReturn ¶
func (_c *MockJobsInterface_CancelRun_Call) RunAndReturn(run func(context.Context, jobs.CancelRun) (*jobs.WaitGetRunJobTerminatedOrSkipped[struct{}], error)) *MockJobsInterface_CancelRun_Call
type MockJobsInterface_Create_Call ¶
MockJobsInterface_Create_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Create'
func (*MockJobsInterface_Create_Call) Return ¶
func (_c *MockJobsInterface_Create_Call) Return(_a0 *jobs.CreateResponse, _a1 error) *MockJobsInterface_Create_Call
func (*MockJobsInterface_Create_Call) Run ¶
func (_c *MockJobsInterface_Create_Call) Run(run func(ctx context.Context, request jobs.CreateJob)) *MockJobsInterface_Create_Call
func (*MockJobsInterface_Create_Call) RunAndReturn ¶
func (_c *MockJobsInterface_Create_Call) RunAndReturn(run func(context.Context, jobs.CreateJob) (*jobs.CreateResponse, error)) *MockJobsInterface_Create_Call
type MockJobsInterface_DeleteByJobId_Call ¶
MockJobsInterface_DeleteByJobId_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteByJobId'
func (*MockJobsInterface_DeleteByJobId_Call) Return ¶
func (_c *MockJobsInterface_DeleteByJobId_Call) Return(_a0 error) *MockJobsInterface_DeleteByJobId_Call
func (*MockJobsInterface_DeleteByJobId_Call) Run ¶
func (_c *MockJobsInterface_DeleteByJobId_Call) Run(run func(ctx context.Context, jobId int64)) *MockJobsInterface_DeleteByJobId_Call
func (*MockJobsInterface_DeleteByJobId_Call) RunAndReturn ¶
func (_c *MockJobsInterface_DeleteByJobId_Call) RunAndReturn(run func(context.Context, int64) error) *MockJobsInterface_DeleteByJobId_Call
type MockJobsInterface_DeleteRunByRunId_Call ¶
MockJobsInterface_DeleteRunByRunId_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteRunByRunId'
func (*MockJobsInterface_DeleteRunByRunId_Call) Return ¶
func (_c *MockJobsInterface_DeleteRunByRunId_Call) Return(_a0 error) *MockJobsInterface_DeleteRunByRunId_Call
func (*MockJobsInterface_DeleteRunByRunId_Call) Run ¶
func (_c *MockJobsInterface_DeleteRunByRunId_Call) Run(run func(ctx context.Context, runId int64)) *MockJobsInterface_DeleteRunByRunId_Call
func (*MockJobsInterface_DeleteRunByRunId_Call) RunAndReturn ¶
func (_c *MockJobsInterface_DeleteRunByRunId_Call) RunAndReturn(run func(context.Context, int64) error) *MockJobsInterface_DeleteRunByRunId_Call
type MockJobsInterface_DeleteRun_Call ¶
MockJobsInterface_DeleteRun_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteRun'
func (*MockJobsInterface_DeleteRun_Call) Return ¶
func (_c *MockJobsInterface_DeleteRun_Call) Return(_a0 error) *MockJobsInterface_DeleteRun_Call
func (*MockJobsInterface_DeleteRun_Call) Run ¶
func (_c *MockJobsInterface_DeleteRun_Call) Run(run func(ctx context.Context, request jobs.DeleteRun)) *MockJobsInterface_DeleteRun_Call
func (*MockJobsInterface_DeleteRun_Call) RunAndReturn ¶
func (_c *MockJobsInterface_DeleteRun_Call) RunAndReturn(run func(context.Context, jobs.DeleteRun) error) *MockJobsInterface_DeleteRun_Call
type MockJobsInterface_Delete_Call ¶
MockJobsInterface_Delete_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Delete'
func (*MockJobsInterface_Delete_Call) Return ¶
func (_c *MockJobsInterface_Delete_Call) Return(_a0 error) *MockJobsInterface_Delete_Call
func (*MockJobsInterface_Delete_Call) Run ¶
func (_c *MockJobsInterface_Delete_Call) Run(run func(ctx context.Context, request jobs.DeleteJob)) *MockJobsInterface_Delete_Call
func (*MockJobsInterface_Delete_Call) RunAndReturn ¶
func (_c *MockJobsInterface_Delete_Call) RunAndReturn(run func(context.Context, jobs.DeleteJob) error) *MockJobsInterface_Delete_Call
type MockJobsInterface_Expecter ¶
type MockJobsInterface_Expecter struct {
// contains filtered or unexported fields
}
func (*MockJobsInterface_Expecter) BaseJobSettingsNameToJobIdMap ¶
func (_e *MockJobsInterface_Expecter) BaseJobSettingsNameToJobIdMap(ctx interface{}, request interface{}) *MockJobsInterface_BaseJobSettingsNameToJobIdMap_Call
BaseJobSettingsNameToJobIdMap is a helper method to define mock.On call
- ctx context.Context
- request jobs.ListJobsRequest
func (*MockJobsInterface_Expecter) CancelAllRuns ¶
func (_e *MockJobsInterface_Expecter) CancelAllRuns(ctx interface{}, request interface{}) *MockJobsInterface_CancelAllRuns_Call
CancelAllRuns is a helper method to define mock.On call
- ctx context.Context
- request jobs.CancelAllRuns
func (*MockJobsInterface_Expecter) CancelRun ¶
func (_e *MockJobsInterface_Expecter) CancelRun(ctx interface{}, cancelRun interface{}) *MockJobsInterface_CancelRun_Call
CancelRun is a helper method to define mock.On call
- ctx context.Context
- cancelRun jobs.CancelRun
func (*MockJobsInterface_Expecter) CancelRunAndWait ¶
func (_e *MockJobsInterface_Expecter) CancelRunAndWait(ctx interface{}, cancelRun interface{}, options ...interface{}) *MockJobsInterface_CancelRunAndWait_Call
CancelRunAndWait is a helper method to define mock.On call
- ctx context.Context
- cancelRun jobs.CancelRun
- options ...retries.Option[jobs.Run]
func (*MockJobsInterface_Expecter) CancelRunByRunId ¶
func (_e *MockJobsInterface_Expecter) CancelRunByRunId(ctx interface{}, runId interface{}) *MockJobsInterface_CancelRunByRunId_Call
CancelRunByRunId is a helper method to define mock.On call
- ctx context.Context
- runId int64
func (*MockJobsInterface_Expecter) CancelRunByRunIdAndWait ¶
func (_e *MockJobsInterface_Expecter) CancelRunByRunIdAndWait(ctx interface{}, runId interface{}, options ...interface{}) *MockJobsInterface_CancelRunByRunIdAndWait_Call
CancelRunByRunIdAndWait is a helper method to define mock.On call
- ctx context.Context
- runId int64
- options ...retries.Option[jobs.Run]
func (*MockJobsInterface_Expecter) Create ¶
func (_e *MockJobsInterface_Expecter) Create(ctx interface{}, request interface{}) *MockJobsInterface_Create_Call
Create is a helper method to define mock.On call
- ctx context.Context
- request jobs.CreateJob
func (*MockJobsInterface_Expecter) Delete ¶
func (_e *MockJobsInterface_Expecter) Delete(ctx interface{}, request interface{}) *MockJobsInterface_Delete_Call
Delete is a helper method to define mock.On call
- ctx context.Context
- request jobs.DeleteJob
func (*MockJobsInterface_Expecter) DeleteByJobId ¶
func (_e *MockJobsInterface_Expecter) DeleteByJobId(ctx interface{}, jobId interface{}) *MockJobsInterface_DeleteByJobId_Call
DeleteByJobId is a helper method to define mock.On call
- ctx context.Context
- jobId int64
func (*MockJobsInterface_Expecter) DeleteRun ¶
func (_e *MockJobsInterface_Expecter) DeleteRun(ctx interface{}, request interface{}) *MockJobsInterface_DeleteRun_Call
DeleteRun is a helper method to define mock.On call
- ctx context.Context
- request jobs.DeleteRun
func (*MockJobsInterface_Expecter) DeleteRunByRunId ¶
func (_e *MockJobsInterface_Expecter) DeleteRunByRunId(ctx interface{}, runId interface{}) *MockJobsInterface_DeleteRunByRunId_Call
DeleteRunByRunId is a helper method to define mock.On call
- ctx context.Context
- runId int64
func (*MockJobsInterface_Expecter) ExportRun ¶
func (_e *MockJobsInterface_Expecter) ExportRun(ctx interface{}, request interface{}) *MockJobsInterface_ExportRun_Call
ExportRun is a helper method to define mock.On call
- ctx context.Context
- request jobs.ExportRunRequest
func (*MockJobsInterface_Expecter) Get ¶
func (_e *MockJobsInterface_Expecter) Get(ctx interface{}, request interface{}) *MockJobsInterface_Get_Call
Get is a helper method to define mock.On call
- ctx context.Context
- request jobs.GetJobRequest
func (*MockJobsInterface_Expecter) GetByJobId ¶
func (_e *MockJobsInterface_Expecter) GetByJobId(ctx interface{}, jobId interface{}) *MockJobsInterface_GetByJobId_Call
GetByJobId is a helper method to define mock.On call
- ctx context.Context
- jobId int64
func (*MockJobsInterface_Expecter) GetBySettingsName ¶
func (_e *MockJobsInterface_Expecter) GetBySettingsName(ctx interface{}, name interface{}) *MockJobsInterface_GetBySettingsName_Call
GetBySettingsName is a helper method to define mock.On call
- ctx context.Context
- name string
func (*MockJobsInterface_Expecter) GetPermissionLevels ¶
func (_e *MockJobsInterface_Expecter) GetPermissionLevels(ctx interface{}, request interface{}) *MockJobsInterface_GetPermissionLevels_Call
GetPermissionLevels is a helper method to define mock.On call
- ctx context.Context
- request jobs.GetJobPermissionLevelsRequest
func (*MockJobsInterface_Expecter) GetPermissionLevelsByJobId ¶
func (_e *MockJobsInterface_Expecter) GetPermissionLevelsByJobId(ctx interface{}, jobId interface{}) *MockJobsInterface_GetPermissionLevelsByJobId_Call
GetPermissionLevelsByJobId is a helper method to define mock.On call
- ctx context.Context
- jobId string
func (*MockJobsInterface_Expecter) GetPermissions ¶
func (_e *MockJobsInterface_Expecter) GetPermissions(ctx interface{}, request interface{}) *MockJobsInterface_GetPermissions_Call
GetPermissions is a helper method to define mock.On call
- ctx context.Context
- request jobs.GetJobPermissionsRequest
func (*MockJobsInterface_Expecter) GetPermissionsByJobId ¶
func (_e *MockJobsInterface_Expecter) GetPermissionsByJobId(ctx interface{}, jobId interface{}) *MockJobsInterface_GetPermissionsByJobId_Call
GetPermissionsByJobId is a helper method to define mock.On call
- ctx context.Context
- jobId string
func (*MockJobsInterface_Expecter) GetRun ¶
func (_e *MockJobsInterface_Expecter) GetRun(ctx interface{}, request interface{}) *MockJobsInterface_GetRun_Call
GetRun is a helper method to define mock.On call
- ctx context.Context
- request jobs.GetRunRequest
func (*MockJobsInterface_Expecter) GetRunOutput ¶
func (_e *MockJobsInterface_Expecter) GetRunOutput(ctx interface{}, request interface{}) *MockJobsInterface_GetRunOutput_Call
GetRunOutput is a helper method to define mock.On call
- ctx context.Context
- request jobs.GetRunOutputRequest
func (*MockJobsInterface_Expecter) GetRunOutputByRunId ¶
func (_e *MockJobsInterface_Expecter) GetRunOutputByRunId(ctx interface{}, runId interface{}) *MockJobsInterface_GetRunOutputByRunId_Call
GetRunOutputByRunId is a helper method to define mock.On call
- ctx context.Context
- runId int64
func (*MockJobsInterface_Expecter) Impl ¶
func (_e *MockJobsInterface_Expecter) Impl() *MockJobsInterface_Impl_Call
Impl is a helper method to define mock.On call
func (*MockJobsInterface_Expecter) List ¶
func (_e *MockJobsInterface_Expecter) List(ctx interface{}, request interface{}) *MockJobsInterface_List_Call
List is a helper method to define mock.On call
- ctx context.Context
- request jobs.ListJobsRequest
func (*MockJobsInterface_Expecter) ListAll ¶
func (_e *MockJobsInterface_Expecter) ListAll(ctx interface{}, request interface{}) *MockJobsInterface_ListAll_Call
ListAll is a helper method to define mock.On call
- ctx context.Context
- request jobs.ListJobsRequest
func (*MockJobsInterface_Expecter) ListRuns ¶
func (_e *MockJobsInterface_Expecter) ListRuns(ctx interface{}, request interface{}) *MockJobsInterface_ListRuns_Call
ListRuns is a helper method to define mock.On call
- ctx context.Context
- request jobs.ListRunsRequest
func (*MockJobsInterface_Expecter) ListRunsAll ¶
func (_e *MockJobsInterface_Expecter) ListRunsAll(ctx interface{}, request interface{}) *MockJobsInterface_ListRunsAll_Call
ListRunsAll is a helper method to define mock.On call
- ctx context.Context
- request jobs.ListRunsRequest
func (*MockJobsInterface_Expecter) RepairRun ¶
func (_e *MockJobsInterface_Expecter) RepairRun(ctx interface{}, repairRun interface{}) *MockJobsInterface_RepairRun_Call
RepairRun is a helper method to define mock.On call
- ctx context.Context
- repairRun jobs.RepairRun
func (*MockJobsInterface_Expecter) RepairRunAndWait ¶
func (_e *MockJobsInterface_Expecter) RepairRunAndWait(ctx interface{}, repairRun interface{}, options ...interface{}) *MockJobsInterface_RepairRunAndWait_Call
RepairRunAndWait is a helper method to define mock.On call
- ctx context.Context
- repairRun jobs.RepairRun
- options ...retries.Option[jobs.Run]
func (*MockJobsInterface_Expecter) Reset ¶
func (_e *MockJobsInterface_Expecter) Reset(ctx interface{}, request interface{}) *MockJobsInterface_Reset_Call
Reset is a helper method to define mock.On call
- ctx context.Context
- request jobs.ResetJob
func (*MockJobsInterface_Expecter) RunNow ¶
func (_e *MockJobsInterface_Expecter) RunNow(ctx interface{}, runNow interface{}) *MockJobsInterface_RunNow_Call
RunNow is a helper method to define mock.On call
- ctx context.Context
- runNow jobs.RunNow
func (*MockJobsInterface_Expecter) RunNowAndWait ¶
func (_e *MockJobsInterface_Expecter) RunNowAndWait(ctx interface{}, runNow interface{}, options ...interface{}) *MockJobsInterface_RunNowAndWait_Call
RunNowAndWait is a helper method to define mock.On call
- ctx context.Context
- runNow jobs.RunNow
- options ...retries.Option[jobs.Run]
func (*MockJobsInterface_Expecter) SetPermissions ¶
func (_e *MockJobsInterface_Expecter) SetPermissions(ctx interface{}, request interface{}) *MockJobsInterface_SetPermissions_Call
SetPermissions is a helper method to define mock.On call
- ctx context.Context
- request jobs.JobPermissionsRequest
func (*MockJobsInterface_Expecter) Submit ¶
func (_e *MockJobsInterface_Expecter) Submit(ctx interface{}, submitRun interface{}) *MockJobsInterface_Submit_Call
Submit is a helper method to define mock.On call
- ctx context.Context
- submitRun jobs.SubmitRun
func (*MockJobsInterface_Expecter) SubmitAndWait ¶
func (_e *MockJobsInterface_Expecter) SubmitAndWait(ctx interface{}, submitRun interface{}, options ...interface{}) *MockJobsInterface_SubmitAndWait_Call
SubmitAndWait is a helper method to define mock.On call
- ctx context.Context
- submitRun jobs.SubmitRun
- options ...retries.Option[jobs.Run]
func (*MockJobsInterface_Expecter) Update ¶
func (_e *MockJobsInterface_Expecter) Update(ctx interface{}, request interface{}) *MockJobsInterface_Update_Call
Update is a helper method to define mock.On call
- ctx context.Context
- request jobs.UpdateJob
func (*MockJobsInterface_Expecter) UpdatePermissions ¶
func (_e *MockJobsInterface_Expecter) UpdatePermissions(ctx interface{}, request interface{}) *MockJobsInterface_UpdatePermissions_Call
UpdatePermissions is a helper method to define mock.On call
- ctx context.Context
- request jobs.JobPermissionsRequest
func (*MockJobsInterface_Expecter) WaitGetRunJobTerminatedOrSkipped ¶
func (_e *MockJobsInterface_Expecter) WaitGetRunJobTerminatedOrSkipped(ctx interface{}, runId interface{}, timeout interface{}, callback interface{}) *MockJobsInterface_WaitGetRunJobTerminatedOrSkipped_Call
WaitGetRunJobTerminatedOrSkipped is a helper method to define mock.On call
- ctx context.Context
- runId int64
- timeout time.Duration
- callback func(*jobs.Run)
func (*MockJobsInterface_Expecter) WithImpl ¶
func (_e *MockJobsInterface_Expecter) WithImpl(impl interface{}) *MockJobsInterface_WithImpl_Call
WithImpl is a helper method to define mock.On call
- impl jobs.JobsService
type MockJobsInterface_ExportRun_Call ¶
MockJobsInterface_ExportRun_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ExportRun'
func (*MockJobsInterface_ExportRun_Call) Return ¶
func (_c *MockJobsInterface_ExportRun_Call) Return(_a0 *jobs.ExportRunOutput, _a1 error) *MockJobsInterface_ExportRun_Call
func (*MockJobsInterface_ExportRun_Call) Run ¶
func (_c *MockJobsInterface_ExportRun_Call) Run(run func(ctx context.Context, request jobs.ExportRunRequest)) *MockJobsInterface_ExportRun_Call
func (*MockJobsInterface_ExportRun_Call) RunAndReturn ¶
func (_c *MockJobsInterface_ExportRun_Call) RunAndReturn(run func(context.Context, jobs.ExportRunRequest) (*jobs.ExportRunOutput, error)) *MockJobsInterface_ExportRun_Call
type MockJobsInterface_GetByJobId_Call ¶
MockJobsInterface_GetByJobId_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetByJobId'
func (*MockJobsInterface_GetByJobId_Call) Return ¶
func (_c *MockJobsInterface_GetByJobId_Call) Return(_a0 *jobs.Job, _a1 error) *MockJobsInterface_GetByJobId_Call
func (*MockJobsInterface_GetByJobId_Call) Run ¶
func (_c *MockJobsInterface_GetByJobId_Call) Run(run func(ctx context.Context, jobId int64)) *MockJobsInterface_GetByJobId_Call
func (*MockJobsInterface_GetByJobId_Call) RunAndReturn ¶
func (_c *MockJobsInterface_GetByJobId_Call) RunAndReturn(run func(context.Context, int64) (*jobs.Job, error)) *MockJobsInterface_GetByJobId_Call
type MockJobsInterface_GetBySettingsName_Call ¶
MockJobsInterface_GetBySettingsName_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetBySettingsName'
func (*MockJobsInterface_GetBySettingsName_Call) Return ¶
func (_c *MockJobsInterface_GetBySettingsName_Call) Return(_a0 *jobs.BaseJob, _a1 error) *MockJobsInterface_GetBySettingsName_Call
func (*MockJobsInterface_GetBySettingsName_Call) Run ¶
func (_c *MockJobsInterface_GetBySettingsName_Call) Run(run func(ctx context.Context, name string)) *MockJobsInterface_GetBySettingsName_Call
func (*MockJobsInterface_GetBySettingsName_Call) RunAndReturn ¶
func (_c *MockJobsInterface_GetBySettingsName_Call) RunAndReturn(run func(context.Context, string) (*jobs.BaseJob, error)) *MockJobsInterface_GetBySettingsName_Call
type MockJobsInterface_GetPermissionLevelsByJobId_Call ¶
MockJobsInterface_GetPermissionLevelsByJobId_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetPermissionLevelsByJobId'
func (*MockJobsInterface_GetPermissionLevelsByJobId_Call) Run ¶
func (_c *MockJobsInterface_GetPermissionLevelsByJobId_Call) Run(run func(ctx context.Context, jobId string)) *MockJobsInterface_GetPermissionLevelsByJobId_Call
func (*MockJobsInterface_GetPermissionLevelsByJobId_Call) RunAndReturn ¶
func (_c *MockJobsInterface_GetPermissionLevelsByJobId_Call) RunAndReturn(run func(context.Context, string) (*jobs.GetJobPermissionLevelsResponse, error)) *MockJobsInterface_GetPermissionLevelsByJobId_Call
type MockJobsInterface_GetPermissionLevels_Call ¶
MockJobsInterface_GetPermissionLevels_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetPermissionLevels'
func (*MockJobsInterface_GetPermissionLevels_Call) Return ¶
func (_c *MockJobsInterface_GetPermissionLevels_Call) Return(_a0 *jobs.GetJobPermissionLevelsResponse, _a1 error) *MockJobsInterface_GetPermissionLevels_Call
func (*MockJobsInterface_GetPermissionLevels_Call) Run ¶
func (_c *MockJobsInterface_GetPermissionLevels_Call) Run(run func(ctx context.Context, request jobs.GetJobPermissionLevelsRequest)) *MockJobsInterface_GetPermissionLevels_Call
func (*MockJobsInterface_GetPermissionLevels_Call) RunAndReturn ¶
func (_c *MockJobsInterface_GetPermissionLevels_Call) RunAndReturn(run func(context.Context, jobs.GetJobPermissionLevelsRequest) (*jobs.GetJobPermissionLevelsResponse, error)) *MockJobsInterface_GetPermissionLevels_Call
type MockJobsInterface_GetPermissionsByJobId_Call ¶
MockJobsInterface_GetPermissionsByJobId_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetPermissionsByJobId'
func (*MockJobsInterface_GetPermissionsByJobId_Call) Return ¶
func (_c *MockJobsInterface_GetPermissionsByJobId_Call) Return(_a0 *jobs.JobPermissions, _a1 error) *MockJobsInterface_GetPermissionsByJobId_Call
func (*MockJobsInterface_GetPermissionsByJobId_Call) Run ¶
func (_c *MockJobsInterface_GetPermissionsByJobId_Call) Run(run func(ctx context.Context, jobId string)) *MockJobsInterface_GetPermissionsByJobId_Call
func (*MockJobsInterface_GetPermissionsByJobId_Call) RunAndReturn ¶
func (_c *MockJobsInterface_GetPermissionsByJobId_Call) RunAndReturn(run func(context.Context, string) (*jobs.JobPermissions, error)) *MockJobsInterface_GetPermissionsByJobId_Call
type MockJobsInterface_GetPermissions_Call ¶
MockJobsInterface_GetPermissions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetPermissions'
func (*MockJobsInterface_GetPermissions_Call) Return ¶
func (_c *MockJobsInterface_GetPermissions_Call) Return(_a0 *jobs.JobPermissions, _a1 error) *MockJobsInterface_GetPermissions_Call
func (*MockJobsInterface_GetPermissions_Call) Run ¶
func (_c *MockJobsInterface_GetPermissions_Call) Run(run func(ctx context.Context, request jobs.GetJobPermissionsRequest)) *MockJobsInterface_GetPermissions_Call
func (*MockJobsInterface_GetPermissions_Call) RunAndReturn ¶
func (_c *MockJobsInterface_GetPermissions_Call) RunAndReturn(run func(context.Context, jobs.GetJobPermissionsRequest) (*jobs.JobPermissions, error)) *MockJobsInterface_GetPermissions_Call
type MockJobsInterface_GetRunOutputByRunId_Call ¶
MockJobsInterface_GetRunOutputByRunId_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetRunOutputByRunId'
func (*MockJobsInterface_GetRunOutputByRunId_Call) Return ¶
func (_c *MockJobsInterface_GetRunOutputByRunId_Call) Return(_a0 *jobs.RunOutput, _a1 error) *MockJobsInterface_GetRunOutputByRunId_Call
func (*MockJobsInterface_GetRunOutputByRunId_Call) Run ¶
func (_c *MockJobsInterface_GetRunOutputByRunId_Call) Run(run func(ctx context.Context, runId int64)) *MockJobsInterface_GetRunOutputByRunId_Call
func (*MockJobsInterface_GetRunOutputByRunId_Call) RunAndReturn ¶
func (_c *MockJobsInterface_GetRunOutputByRunId_Call) RunAndReturn(run func(context.Context, int64) (*jobs.RunOutput, error)) *MockJobsInterface_GetRunOutputByRunId_Call
type MockJobsInterface_GetRunOutput_Call ¶
MockJobsInterface_GetRunOutput_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetRunOutput'
func (*MockJobsInterface_GetRunOutput_Call) Return ¶
func (_c *MockJobsInterface_GetRunOutput_Call) Return(_a0 *jobs.RunOutput, _a1 error) *MockJobsInterface_GetRunOutput_Call
func (*MockJobsInterface_GetRunOutput_Call) Run ¶
func (_c *MockJobsInterface_GetRunOutput_Call) Run(run func(ctx context.Context, request jobs.GetRunOutputRequest)) *MockJobsInterface_GetRunOutput_Call
func (*MockJobsInterface_GetRunOutput_Call) RunAndReturn ¶
func (_c *MockJobsInterface_GetRunOutput_Call) RunAndReturn(run func(context.Context, jobs.GetRunOutputRequest) (*jobs.RunOutput, error)) *MockJobsInterface_GetRunOutput_Call
type MockJobsInterface_GetRun_Call ¶
MockJobsInterface_GetRun_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetRun'
func (*MockJobsInterface_GetRun_Call) Return ¶
func (_c *MockJobsInterface_GetRun_Call) Return(_a0 *jobs.Run, _a1 error) *MockJobsInterface_GetRun_Call
func (*MockJobsInterface_GetRun_Call) Run ¶
func (_c *MockJobsInterface_GetRun_Call) Run(run func(ctx context.Context, request jobs.GetRunRequest)) *MockJobsInterface_GetRun_Call
func (*MockJobsInterface_GetRun_Call) RunAndReturn ¶
func (_c *MockJobsInterface_GetRun_Call) RunAndReturn(run func(context.Context, jobs.GetRunRequest) (*jobs.Run, error)) *MockJobsInterface_GetRun_Call
type MockJobsInterface_Get_Call ¶
MockJobsInterface_Get_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Get'
func (*MockJobsInterface_Get_Call) Return ¶
func (_c *MockJobsInterface_Get_Call) Return(_a0 *jobs.Job, _a1 error) *MockJobsInterface_Get_Call
func (*MockJobsInterface_Get_Call) Run ¶
func (_c *MockJobsInterface_Get_Call) Run(run func(ctx context.Context, request jobs.GetJobRequest)) *MockJobsInterface_Get_Call
func (*MockJobsInterface_Get_Call) RunAndReturn ¶
func (_c *MockJobsInterface_Get_Call) RunAndReturn(run func(context.Context, jobs.GetJobRequest) (*jobs.Job, error)) *MockJobsInterface_Get_Call
type MockJobsInterface_Impl_Call ¶
MockJobsInterface_Impl_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Impl'
func (*MockJobsInterface_Impl_Call) Return ¶
func (_c *MockJobsInterface_Impl_Call) Return(_a0 jobs.JobsService) *MockJobsInterface_Impl_Call
func (*MockJobsInterface_Impl_Call) Run ¶
func (_c *MockJobsInterface_Impl_Call) Run(run func()) *MockJobsInterface_Impl_Call
func (*MockJobsInterface_Impl_Call) RunAndReturn ¶
func (_c *MockJobsInterface_Impl_Call) RunAndReturn(run func() jobs.JobsService) *MockJobsInterface_Impl_Call
type MockJobsInterface_ListAll_Call ¶
MockJobsInterface_ListAll_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListAll'
func (*MockJobsInterface_ListAll_Call) Return ¶
func (_c *MockJobsInterface_ListAll_Call) Return(_a0 []jobs.BaseJob, _a1 error) *MockJobsInterface_ListAll_Call
func (*MockJobsInterface_ListAll_Call) Run ¶
func (_c *MockJobsInterface_ListAll_Call) Run(run func(ctx context.Context, request jobs.ListJobsRequest)) *MockJobsInterface_ListAll_Call
func (*MockJobsInterface_ListAll_Call) RunAndReturn ¶
func (_c *MockJobsInterface_ListAll_Call) RunAndReturn(run func(context.Context, jobs.ListJobsRequest) ([]jobs.BaseJob, error)) *MockJobsInterface_ListAll_Call
type MockJobsInterface_ListRunsAll_Call ¶
MockJobsInterface_ListRunsAll_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListRunsAll'
func (*MockJobsInterface_ListRunsAll_Call) Return ¶
func (_c *MockJobsInterface_ListRunsAll_Call) Return(_a0 []jobs.BaseRun, _a1 error) *MockJobsInterface_ListRunsAll_Call
func (*MockJobsInterface_ListRunsAll_Call) Run ¶
func (_c *MockJobsInterface_ListRunsAll_Call) Run(run func(ctx context.Context, request jobs.ListRunsRequest)) *MockJobsInterface_ListRunsAll_Call
func (*MockJobsInterface_ListRunsAll_Call) RunAndReturn ¶
func (_c *MockJobsInterface_ListRunsAll_Call) RunAndReturn(run func(context.Context, jobs.ListRunsRequest) ([]jobs.BaseRun, error)) *MockJobsInterface_ListRunsAll_Call
type MockJobsInterface_ListRuns_Call ¶
MockJobsInterface_ListRuns_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListRuns'
func (*MockJobsInterface_ListRuns_Call) Return ¶
func (_c *MockJobsInterface_ListRuns_Call) Return(_a0 listing.Iterator[jobs.BaseRun]) *MockJobsInterface_ListRuns_Call
func (*MockJobsInterface_ListRuns_Call) Run ¶
func (_c *MockJobsInterface_ListRuns_Call) Run(run func(ctx context.Context, request jobs.ListRunsRequest)) *MockJobsInterface_ListRuns_Call
func (*MockJobsInterface_ListRuns_Call) RunAndReturn ¶
func (_c *MockJobsInterface_ListRuns_Call) RunAndReturn(run func(context.Context, jobs.ListRunsRequest) listing.Iterator[jobs.BaseRun]) *MockJobsInterface_ListRuns_Call
type MockJobsInterface_List_Call ¶
MockJobsInterface_List_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'List'
func (*MockJobsInterface_List_Call) Return ¶
func (_c *MockJobsInterface_List_Call) Return(_a0 listing.Iterator[jobs.BaseJob]) *MockJobsInterface_List_Call
func (*MockJobsInterface_List_Call) Run ¶
func (_c *MockJobsInterface_List_Call) Run(run func(ctx context.Context, request jobs.ListJobsRequest)) *MockJobsInterface_List_Call
func (*MockJobsInterface_List_Call) RunAndReturn ¶
func (_c *MockJobsInterface_List_Call) RunAndReturn(run func(context.Context, jobs.ListJobsRequest) listing.Iterator[jobs.BaseJob]) *MockJobsInterface_List_Call
type MockJobsInterface_RepairRunAndWait_Call ¶
MockJobsInterface_RepairRunAndWait_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RepairRunAndWait'
func (*MockJobsInterface_RepairRunAndWait_Call) Return ¶
func (_c *MockJobsInterface_RepairRunAndWait_Call) Return(_a0 *jobs.Run, _a1 error) *MockJobsInterface_RepairRunAndWait_Call
func (*MockJobsInterface_RepairRunAndWait_Call) Run ¶
func (_c *MockJobsInterface_RepairRunAndWait_Call) Run(run func(ctx context.Context, repairRun jobs.RepairRun, options ...retries.Option[jobs.Run])) *MockJobsInterface_RepairRunAndWait_Call
func (*MockJobsInterface_RepairRunAndWait_Call) RunAndReturn ¶
type MockJobsInterface_RepairRun_Call ¶
MockJobsInterface_RepairRun_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RepairRun'
func (*MockJobsInterface_RepairRun_Call) Return ¶
func (_c *MockJobsInterface_RepairRun_Call) Return(_a0 *jobs.WaitGetRunJobTerminatedOrSkipped[jobs.RepairRunResponse], _a1 error) *MockJobsInterface_RepairRun_Call
func (*MockJobsInterface_RepairRun_Call) Run ¶
func (_c *MockJobsInterface_RepairRun_Call) Run(run func(ctx context.Context, repairRun jobs.RepairRun)) *MockJobsInterface_RepairRun_Call
func (*MockJobsInterface_RepairRun_Call) RunAndReturn ¶
func (_c *MockJobsInterface_RepairRun_Call) RunAndReturn(run func(context.Context, jobs.RepairRun) (*jobs.WaitGetRunJobTerminatedOrSkipped[jobs.RepairRunResponse], error)) *MockJobsInterface_RepairRun_Call
type MockJobsInterface_Reset_Call ¶
MockJobsInterface_Reset_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Reset'
func (*MockJobsInterface_Reset_Call) Return ¶
func (_c *MockJobsInterface_Reset_Call) Return(_a0 error) *MockJobsInterface_Reset_Call
func (*MockJobsInterface_Reset_Call) Run ¶
func (_c *MockJobsInterface_Reset_Call) Run(run func(ctx context.Context, request jobs.ResetJob)) *MockJobsInterface_Reset_Call
func (*MockJobsInterface_Reset_Call) RunAndReturn ¶
func (_c *MockJobsInterface_Reset_Call) RunAndReturn(run func(context.Context, jobs.ResetJob) error) *MockJobsInterface_Reset_Call
type MockJobsInterface_RunNowAndWait_Call ¶
MockJobsInterface_RunNowAndWait_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RunNowAndWait'
func (*MockJobsInterface_RunNowAndWait_Call) Return ¶
func (_c *MockJobsInterface_RunNowAndWait_Call) Return(_a0 *jobs.Run, _a1 error) *MockJobsInterface_RunNowAndWait_Call
func (*MockJobsInterface_RunNowAndWait_Call) Run ¶
func (_c *MockJobsInterface_RunNowAndWait_Call) Run(run func(ctx context.Context, runNow jobs.RunNow, options ...retries.Option[jobs.Run])) *MockJobsInterface_RunNowAndWait_Call
func (*MockJobsInterface_RunNowAndWait_Call) RunAndReturn ¶
type MockJobsInterface_RunNow_Call ¶
MockJobsInterface_RunNow_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RunNow'
func (*MockJobsInterface_RunNow_Call) Return ¶
func (_c *MockJobsInterface_RunNow_Call) Return(_a0 *jobs.WaitGetRunJobTerminatedOrSkipped[jobs.RunNowResponse], _a1 error) *MockJobsInterface_RunNow_Call
func (*MockJobsInterface_RunNow_Call) Run ¶
func (_c *MockJobsInterface_RunNow_Call) Run(run func(ctx context.Context, runNow jobs.RunNow)) *MockJobsInterface_RunNow_Call
func (*MockJobsInterface_RunNow_Call) RunAndReturn ¶
func (_c *MockJobsInterface_RunNow_Call) RunAndReturn(run func(context.Context, jobs.RunNow) (*jobs.WaitGetRunJobTerminatedOrSkipped[jobs.RunNowResponse], error)) *MockJobsInterface_RunNow_Call
type MockJobsInterface_SetPermissions_Call ¶
MockJobsInterface_SetPermissions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetPermissions'
func (*MockJobsInterface_SetPermissions_Call) Return ¶
func (_c *MockJobsInterface_SetPermissions_Call) Return(_a0 *jobs.JobPermissions, _a1 error) *MockJobsInterface_SetPermissions_Call
func (*MockJobsInterface_SetPermissions_Call) Run ¶
func (_c *MockJobsInterface_SetPermissions_Call) Run(run func(ctx context.Context, request jobs.JobPermissionsRequest)) *MockJobsInterface_SetPermissions_Call
func (*MockJobsInterface_SetPermissions_Call) RunAndReturn ¶
func (_c *MockJobsInterface_SetPermissions_Call) RunAndReturn(run func(context.Context, jobs.JobPermissionsRequest) (*jobs.JobPermissions, error)) *MockJobsInterface_SetPermissions_Call
type MockJobsInterface_SubmitAndWait_Call ¶
MockJobsInterface_SubmitAndWait_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SubmitAndWait'
func (*MockJobsInterface_SubmitAndWait_Call) Return ¶
func (_c *MockJobsInterface_SubmitAndWait_Call) Return(_a0 *jobs.Run, _a1 error) *MockJobsInterface_SubmitAndWait_Call
func (*MockJobsInterface_SubmitAndWait_Call) Run ¶
func (_c *MockJobsInterface_SubmitAndWait_Call) Run(run func(ctx context.Context, submitRun jobs.SubmitRun, options ...retries.Option[jobs.Run])) *MockJobsInterface_SubmitAndWait_Call
func (*MockJobsInterface_SubmitAndWait_Call) RunAndReturn ¶
type MockJobsInterface_Submit_Call ¶
MockJobsInterface_Submit_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Submit'
func (*MockJobsInterface_Submit_Call) Return ¶
func (_c *MockJobsInterface_Submit_Call) Return(_a0 *jobs.WaitGetRunJobTerminatedOrSkipped[jobs.SubmitRunResponse], _a1 error) *MockJobsInterface_Submit_Call
func (*MockJobsInterface_Submit_Call) Run ¶
func (_c *MockJobsInterface_Submit_Call) Run(run func(ctx context.Context, submitRun jobs.SubmitRun)) *MockJobsInterface_Submit_Call
func (*MockJobsInterface_Submit_Call) RunAndReturn ¶
func (_c *MockJobsInterface_Submit_Call) RunAndReturn(run func(context.Context, jobs.SubmitRun) (*jobs.WaitGetRunJobTerminatedOrSkipped[jobs.SubmitRunResponse], error)) *MockJobsInterface_Submit_Call
type MockJobsInterface_UpdatePermissions_Call ¶
MockJobsInterface_UpdatePermissions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdatePermissions'
func (*MockJobsInterface_UpdatePermissions_Call) Return ¶
func (_c *MockJobsInterface_UpdatePermissions_Call) Return(_a0 *jobs.JobPermissions, _a1 error) *MockJobsInterface_UpdatePermissions_Call
func (*MockJobsInterface_UpdatePermissions_Call) Run ¶
func (_c *MockJobsInterface_UpdatePermissions_Call) Run(run func(ctx context.Context, request jobs.JobPermissionsRequest)) *MockJobsInterface_UpdatePermissions_Call
func (*MockJobsInterface_UpdatePermissions_Call) RunAndReturn ¶
func (_c *MockJobsInterface_UpdatePermissions_Call) RunAndReturn(run func(context.Context, jobs.JobPermissionsRequest) (*jobs.JobPermissions, error)) *MockJobsInterface_UpdatePermissions_Call
type MockJobsInterface_Update_Call ¶
MockJobsInterface_Update_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Update'
func (*MockJobsInterface_Update_Call) Return ¶
func (_c *MockJobsInterface_Update_Call) Return(_a0 error) *MockJobsInterface_Update_Call
func (*MockJobsInterface_Update_Call) Run ¶
func (_c *MockJobsInterface_Update_Call) Run(run func(ctx context.Context, request jobs.UpdateJob)) *MockJobsInterface_Update_Call
func (*MockJobsInterface_Update_Call) RunAndReturn ¶
func (_c *MockJobsInterface_Update_Call) RunAndReturn(run func(context.Context, jobs.UpdateJob) error) *MockJobsInterface_Update_Call
type MockJobsInterface_WaitGetRunJobTerminatedOrSkipped_Call ¶
MockJobsInterface_WaitGetRunJobTerminatedOrSkipped_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WaitGetRunJobTerminatedOrSkipped'
func (*MockJobsInterface_WaitGetRunJobTerminatedOrSkipped_Call) Return ¶
func (_c *MockJobsInterface_WaitGetRunJobTerminatedOrSkipped_Call) Return(_a0 *jobs.Run, _a1 error) *MockJobsInterface_WaitGetRunJobTerminatedOrSkipped_Call
func (*MockJobsInterface_WaitGetRunJobTerminatedOrSkipped_Call) Run ¶
func (_c *MockJobsInterface_WaitGetRunJobTerminatedOrSkipped_Call) Run(run func(ctx context.Context, runId int64, timeout time.Duration, callback func(*jobs.Run))) *MockJobsInterface_WaitGetRunJobTerminatedOrSkipped_Call
func (*MockJobsInterface_WaitGetRunJobTerminatedOrSkipped_Call) RunAndReturn ¶
type MockJobsInterface_WithImpl_Call ¶
MockJobsInterface_WithImpl_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WithImpl'
func (*MockJobsInterface_WithImpl_Call) Return ¶
func (_c *MockJobsInterface_WithImpl_Call) Return(_a0 jobs.JobsInterface) *MockJobsInterface_WithImpl_Call
func (*MockJobsInterface_WithImpl_Call) Run ¶
func (_c *MockJobsInterface_WithImpl_Call) Run(run func(impl jobs.JobsService)) *MockJobsInterface_WithImpl_Call
func (*MockJobsInterface_WithImpl_Call) RunAndReturn ¶
func (_c *MockJobsInterface_WithImpl_Call) RunAndReturn(run func(jobs.JobsService) jobs.JobsInterface) *MockJobsInterface_WithImpl_Call