Documentation
¶
Index ¶
- type KVStore
- type KVStore_Expecter
- type KVStore_Get_Call
- type KVStore_Store_Call
- type ORM
- func (_m *ORM) AssertBridgesExist(ctx context.Context, p pipeline.Pipeline) error
- func (_m *ORM) Close() error
- func (_m *ORM) CountPipelineRunsByJobID(ctx context.Context, jobID int32) (int32, error)
- func (_m *ORM) CreateJob(ctx context.Context, jb *job.Job) error
- func (_m *ORM) DataSource() sqlutil.DataSource
- func (_m *ORM) DeleteJob(ctx context.Context, id int32) error
- func (_m *ORM) DismissError(ctx context.Context, errorID int64) error
- func (_m *ORM) EXPECT() *ORM_Expecter
- func (_m *ORM) FindJob(ctx context.Context, id int32) (job.Job, error)
- func (_m *ORM) FindJobByExternalJobID(ctx context.Context, _a1 uuid.UUID) (job.Job, error)
- func (_m *ORM) FindJobIDByAddress(ctx context.Context, address types.EIP55Address, evmChainID *big.Big) (int32, error)
- func (_m *ORM) FindJobIDByWorkflow(ctx context.Context, spec job.WorkflowSpec) (int32, error)
- func (_m *ORM) FindJobIDsWithBridge(ctx context.Context, name string) ([]int32, error)
- func (_m *ORM) FindJobTx(ctx context.Context, id int32) (job.Job, error)
- func (_m *ORM) FindJobWithoutSpecErrors(ctx context.Context, id int32) (job.Job, error)
- func (_m *ORM) FindJobs(ctx context.Context, offset int, limit int) ([]job.Job, int, error)
- func (_m *ORM) FindJobsByPipelineSpecIDs(ctx context.Context, ids []int32) ([]job.Job, error)
- func (_m *ORM) FindOCR2JobIDByAddress(ctx context.Context, contractID string, feedID *common.Hash) (int32, error)
- func (_m *ORM) FindPipelineRunByID(ctx context.Context, id int64) (pipeline.Run, error)
- func (_m *ORM) FindPipelineRunIDsByJobID(ctx context.Context, jobID int32, offset int, limit int) ([]int64, error)
- func (_m *ORM) FindPipelineRunsByIDs(ctx context.Context, ids []int64) ([]pipeline.Run, error)
- func (_m *ORM) FindSpecError(ctx context.Context, id int64) (job.SpecError, error)
- func (_m *ORM) FindSpecErrorsByJobIDs(ctx context.Context, ids []int32) ([]job.SpecError, error)
- func (_m *ORM) FindTaskResultByRunIDAndTaskName(ctx context.Context, runID int64, taskName string) ([]byte, error)
- func (_m *ORM) InsertJob(ctx context.Context, _a1 *job.Job) error
- func (_m *ORM) InsertWebhookSpec(ctx context.Context, webhookSpec *job.WebhookSpec) error
- func (_m *ORM) PipelineRuns(ctx context.Context, jobID *int32, offset int, size int) ([]pipeline.Run, int, error)
- func (_m *ORM) RecordError(ctx context.Context, jobID int32, description string) error
- func (_m *ORM) TryRecordError(ctx context.Context, jobID int32, description string)
- func (_m *ORM) WithDataSource(source sqlutil.DataSource) job.ORM
- type ORM_AssertBridgesExist_Call
- func (_c *ORM_AssertBridgesExist_Call) Return(_a0 error) *ORM_AssertBridgesExist_Call
- func (_c *ORM_AssertBridgesExist_Call) Run(run func(ctx context.Context, p pipeline.Pipeline)) *ORM_AssertBridgesExist_Call
- func (_c *ORM_AssertBridgesExist_Call) RunAndReturn(run func(context.Context, pipeline.Pipeline) error) *ORM_AssertBridgesExist_Call
- type ORM_Close_Call
- type ORM_CountPipelineRunsByJobID_Call
- func (_c *ORM_CountPipelineRunsByJobID_Call) Return(count int32, err error) *ORM_CountPipelineRunsByJobID_Call
- func (_c *ORM_CountPipelineRunsByJobID_Call) Run(run func(ctx context.Context, jobID int32)) *ORM_CountPipelineRunsByJobID_Call
- func (_c *ORM_CountPipelineRunsByJobID_Call) RunAndReturn(run func(context.Context, int32) (int32, error)) *ORM_CountPipelineRunsByJobID_Call
- type ORM_CreateJob_Call
- type ORM_DataSource_Call
- type ORM_DeleteJob_Call
- type ORM_DismissError_Call
- type ORM_Expecter
- func (_e *ORM_Expecter) AssertBridgesExist(ctx interface{}, p interface{}) *ORM_AssertBridgesExist_Call
- func (_e *ORM_Expecter) Close() *ORM_Close_Call
- func (_e *ORM_Expecter) CountPipelineRunsByJobID(ctx interface{}, jobID interface{}) *ORM_CountPipelineRunsByJobID_Call
- func (_e *ORM_Expecter) CreateJob(ctx interface{}, jb interface{}) *ORM_CreateJob_Call
- func (_e *ORM_Expecter) DataSource() *ORM_DataSource_Call
- func (_e *ORM_Expecter) DeleteJob(ctx interface{}, id interface{}) *ORM_DeleteJob_Call
- func (_e *ORM_Expecter) DismissError(ctx interface{}, errorID interface{}) *ORM_DismissError_Call
- func (_e *ORM_Expecter) FindJob(ctx interface{}, id interface{}) *ORM_FindJob_Call
- func (_e *ORM_Expecter) FindJobByExternalJobID(ctx interface{}, _a1 interface{}) *ORM_FindJobByExternalJobID_Call
- func (_e *ORM_Expecter) FindJobIDByAddress(ctx interface{}, address interface{}, evmChainID interface{}) *ORM_FindJobIDByAddress_Call
- func (_e *ORM_Expecter) FindJobIDByWorkflow(ctx interface{}, spec interface{}) *ORM_FindJobIDByWorkflow_Call
- func (_e *ORM_Expecter) FindJobIDsWithBridge(ctx interface{}, name interface{}) *ORM_FindJobIDsWithBridge_Call
- func (_e *ORM_Expecter) FindJobTx(ctx interface{}, id interface{}) *ORM_FindJobTx_Call
- func (_e *ORM_Expecter) FindJobWithoutSpecErrors(ctx interface{}, id interface{}) *ORM_FindJobWithoutSpecErrors_Call
- func (_e *ORM_Expecter) FindJobs(ctx interface{}, offset interface{}, limit interface{}) *ORM_FindJobs_Call
- func (_e *ORM_Expecter) FindJobsByPipelineSpecIDs(ctx interface{}, ids interface{}) *ORM_FindJobsByPipelineSpecIDs_Call
- func (_e *ORM_Expecter) FindOCR2JobIDByAddress(ctx interface{}, contractID interface{}, feedID interface{}) *ORM_FindOCR2JobIDByAddress_Call
- func (_e *ORM_Expecter) FindPipelineRunByID(ctx interface{}, id interface{}) *ORM_FindPipelineRunByID_Call
- func (_e *ORM_Expecter) FindPipelineRunIDsByJobID(ctx interface{}, jobID interface{}, offset interface{}, limit interface{}) *ORM_FindPipelineRunIDsByJobID_Call
- func (_e *ORM_Expecter) FindPipelineRunsByIDs(ctx interface{}, ids interface{}) *ORM_FindPipelineRunsByIDs_Call
- func (_e *ORM_Expecter) FindSpecError(ctx interface{}, id interface{}) *ORM_FindSpecError_Call
- func (_e *ORM_Expecter) FindSpecErrorsByJobIDs(ctx interface{}, ids interface{}) *ORM_FindSpecErrorsByJobIDs_Call
- func (_e *ORM_Expecter) FindTaskResultByRunIDAndTaskName(ctx interface{}, runID interface{}, taskName interface{}) *ORM_FindTaskResultByRunIDAndTaskName_Call
- func (_e *ORM_Expecter) InsertJob(ctx interface{}, _a1 interface{}) *ORM_InsertJob_Call
- func (_e *ORM_Expecter) InsertWebhookSpec(ctx interface{}, webhookSpec interface{}) *ORM_InsertWebhookSpec_Call
- func (_e *ORM_Expecter) PipelineRuns(ctx interface{}, jobID interface{}, offset interface{}, size interface{}) *ORM_PipelineRuns_Call
- func (_e *ORM_Expecter) RecordError(ctx interface{}, jobID interface{}, description interface{}) *ORM_RecordError_Call
- func (_e *ORM_Expecter) TryRecordError(ctx interface{}, jobID interface{}, description interface{}) *ORM_TryRecordError_Call
- func (_e *ORM_Expecter) WithDataSource(source interface{}) *ORM_WithDataSource_Call
- type ORM_FindJobByExternalJobID_Call
- func (_c *ORM_FindJobByExternalJobID_Call) Return(_a0 job.Job, _a1 error) *ORM_FindJobByExternalJobID_Call
- func (_c *ORM_FindJobByExternalJobID_Call) Run(run func(ctx context.Context, _a1 uuid.UUID)) *ORM_FindJobByExternalJobID_Call
- func (_c *ORM_FindJobByExternalJobID_Call) RunAndReturn(run func(context.Context, uuid.UUID) (job.Job, error)) *ORM_FindJobByExternalJobID_Call
- type ORM_FindJobIDByAddress_Call
- func (_c *ORM_FindJobIDByAddress_Call) Return(_a0 int32, _a1 error) *ORM_FindJobIDByAddress_Call
- func (_c *ORM_FindJobIDByAddress_Call) Run(run func(ctx context.Context, address types.EIP55Address, evmChainID *big.Big)) *ORM_FindJobIDByAddress_Call
- func (_c *ORM_FindJobIDByAddress_Call) RunAndReturn(run func(context.Context, types.EIP55Address, *big.Big) (int32, error)) *ORM_FindJobIDByAddress_Call
- type ORM_FindJobIDByWorkflow_Call
- func (_c *ORM_FindJobIDByWorkflow_Call) Return(_a0 int32, _a1 error) *ORM_FindJobIDByWorkflow_Call
- func (_c *ORM_FindJobIDByWorkflow_Call) Run(run func(ctx context.Context, spec job.WorkflowSpec)) *ORM_FindJobIDByWorkflow_Call
- func (_c *ORM_FindJobIDByWorkflow_Call) RunAndReturn(run func(context.Context, job.WorkflowSpec) (int32, error)) *ORM_FindJobIDByWorkflow_Call
- type ORM_FindJobIDsWithBridge_Call
- func (_c *ORM_FindJobIDsWithBridge_Call) Return(_a0 []int32, _a1 error) *ORM_FindJobIDsWithBridge_Call
- func (_c *ORM_FindJobIDsWithBridge_Call) Run(run func(ctx context.Context, name string)) *ORM_FindJobIDsWithBridge_Call
- func (_c *ORM_FindJobIDsWithBridge_Call) RunAndReturn(run func(context.Context, string) ([]int32, error)) *ORM_FindJobIDsWithBridge_Call
- type ORM_FindJobTx_Call
- type ORM_FindJobWithoutSpecErrors_Call
- func (_c *ORM_FindJobWithoutSpecErrors_Call) Return(jb job.Job, err error) *ORM_FindJobWithoutSpecErrors_Call
- func (_c *ORM_FindJobWithoutSpecErrors_Call) Run(run func(ctx context.Context, id int32)) *ORM_FindJobWithoutSpecErrors_Call
- func (_c *ORM_FindJobWithoutSpecErrors_Call) RunAndReturn(run func(context.Context, int32) (job.Job, error)) *ORM_FindJobWithoutSpecErrors_Call
- type ORM_FindJob_Call
- type ORM_FindJobsByPipelineSpecIDs_Call
- func (_c *ORM_FindJobsByPipelineSpecIDs_Call) Return(_a0 []job.Job, _a1 error) *ORM_FindJobsByPipelineSpecIDs_Call
- func (_c *ORM_FindJobsByPipelineSpecIDs_Call) Run(run func(ctx context.Context, ids []int32)) *ORM_FindJobsByPipelineSpecIDs_Call
- func (_c *ORM_FindJobsByPipelineSpecIDs_Call) RunAndReturn(run func(context.Context, []int32) ([]job.Job, error)) *ORM_FindJobsByPipelineSpecIDs_Call
- type ORM_FindJobs_Call
- func (_c *ORM_FindJobs_Call) Return(_a0 []job.Job, _a1 int, _a2 error) *ORM_FindJobs_Call
- func (_c *ORM_FindJobs_Call) Run(run func(ctx context.Context, offset int, limit int)) *ORM_FindJobs_Call
- func (_c *ORM_FindJobs_Call) RunAndReturn(run func(context.Context, int, int) ([]job.Job, int, error)) *ORM_FindJobs_Call
- type ORM_FindOCR2JobIDByAddress_Call
- func (_c *ORM_FindOCR2JobIDByAddress_Call) Return(_a0 int32, _a1 error) *ORM_FindOCR2JobIDByAddress_Call
- func (_c *ORM_FindOCR2JobIDByAddress_Call) Run(run func(ctx context.Context, contractID string, feedID *common.Hash)) *ORM_FindOCR2JobIDByAddress_Call
- func (_c *ORM_FindOCR2JobIDByAddress_Call) RunAndReturn(run func(context.Context, string, *common.Hash) (int32, error)) *ORM_FindOCR2JobIDByAddress_Call
- type ORM_FindPipelineRunByID_Call
- func (_c *ORM_FindPipelineRunByID_Call) Return(_a0 pipeline.Run, _a1 error) *ORM_FindPipelineRunByID_Call
- func (_c *ORM_FindPipelineRunByID_Call) Run(run func(ctx context.Context, id int64)) *ORM_FindPipelineRunByID_Call
- func (_c *ORM_FindPipelineRunByID_Call) RunAndReturn(run func(context.Context, int64) (pipeline.Run, error)) *ORM_FindPipelineRunByID_Call
- type ORM_FindPipelineRunIDsByJobID_Call
- func (_c *ORM_FindPipelineRunIDsByJobID_Call) Return(ids []int64, err error) *ORM_FindPipelineRunIDsByJobID_Call
- func (_c *ORM_FindPipelineRunIDsByJobID_Call) Run(run func(ctx context.Context, jobID int32, offset int, limit int)) *ORM_FindPipelineRunIDsByJobID_Call
- func (_c *ORM_FindPipelineRunIDsByJobID_Call) RunAndReturn(run func(context.Context, int32, int, int) ([]int64, error)) *ORM_FindPipelineRunIDsByJobID_Call
- type ORM_FindPipelineRunsByIDs_Call
- func (_c *ORM_FindPipelineRunsByIDs_Call) Return(runs []pipeline.Run, err error) *ORM_FindPipelineRunsByIDs_Call
- func (_c *ORM_FindPipelineRunsByIDs_Call) Run(run func(ctx context.Context, ids []int64)) *ORM_FindPipelineRunsByIDs_Call
- func (_c *ORM_FindPipelineRunsByIDs_Call) RunAndReturn(run func(context.Context, []int64) ([]pipeline.Run, error)) *ORM_FindPipelineRunsByIDs_Call
- type ORM_FindSpecError_Call
- func (_c *ORM_FindSpecError_Call) Return(_a0 job.SpecError, _a1 error) *ORM_FindSpecError_Call
- func (_c *ORM_FindSpecError_Call) Run(run func(ctx context.Context, id int64)) *ORM_FindSpecError_Call
- func (_c *ORM_FindSpecError_Call) RunAndReturn(run func(context.Context, int64) (job.SpecError, error)) *ORM_FindSpecError_Call
- type ORM_FindSpecErrorsByJobIDs_Call
- func (_c *ORM_FindSpecErrorsByJobIDs_Call) Return(_a0 []job.SpecError, _a1 error) *ORM_FindSpecErrorsByJobIDs_Call
- func (_c *ORM_FindSpecErrorsByJobIDs_Call) Run(run func(ctx context.Context, ids []int32)) *ORM_FindSpecErrorsByJobIDs_Call
- func (_c *ORM_FindSpecErrorsByJobIDs_Call) RunAndReturn(run func(context.Context, []int32) ([]job.SpecError, error)) *ORM_FindSpecErrorsByJobIDs_Call
- type ORM_FindTaskResultByRunIDAndTaskName_Call
- func (_c *ORM_FindTaskResultByRunIDAndTaskName_Call) Return(_a0 []byte, _a1 error) *ORM_FindTaskResultByRunIDAndTaskName_Call
- func (_c *ORM_FindTaskResultByRunIDAndTaskName_Call) Run(run func(ctx context.Context, runID int64, taskName string)) *ORM_FindTaskResultByRunIDAndTaskName_Call
- func (_c *ORM_FindTaskResultByRunIDAndTaskName_Call) RunAndReturn(run func(context.Context, int64, string) ([]byte, error)) *ORM_FindTaskResultByRunIDAndTaskName_Call
- type ORM_InsertJob_Call
- type ORM_InsertWebhookSpec_Call
- func (_c *ORM_InsertWebhookSpec_Call) Return(_a0 error) *ORM_InsertWebhookSpec_Call
- func (_c *ORM_InsertWebhookSpec_Call) Run(run func(ctx context.Context, webhookSpec *job.WebhookSpec)) *ORM_InsertWebhookSpec_Call
- func (_c *ORM_InsertWebhookSpec_Call) RunAndReturn(run func(context.Context, *job.WebhookSpec) error) *ORM_InsertWebhookSpec_Call
- type ORM_PipelineRuns_Call
- func (_c *ORM_PipelineRuns_Call) Return(_a0 []pipeline.Run, _a1 int, _a2 error) *ORM_PipelineRuns_Call
- func (_c *ORM_PipelineRuns_Call) Run(run func(ctx context.Context, jobID *int32, offset int, size int)) *ORM_PipelineRuns_Call
- func (_c *ORM_PipelineRuns_Call) RunAndReturn(run func(context.Context, *int32, int, int) ([]pipeline.Run, int, error)) *ORM_PipelineRuns_Call
- type ORM_RecordError_Call
- func (_c *ORM_RecordError_Call) Return(_a0 error) *ORM_RecordError_Call
- func (_c *ORM_RecordError_Call) Run(run func(ctx context.Context, jobID int32, description string)) *ORM_RecordError_Call
- func (_c *ORM_RecordError_Call) RunAndReturn(run func(context.Context, int32, string) error) *ORM_RecordError_Call
- type ORM_TryRecordError_Call
- func (_c *ORM_TryRecordError_Call) Return() *ORM_TryRecordError_Call
- func (_c *ORM_TryRecordError_Call) Run(run func(ctx context.Context, jobID int32, description string)) *ORM_TryRecordError_Call
- func (_c *ORM_TryRecordError_Call) RunAndReturn(run func(context.Context, int32, string)) *ORM_TryRecordError_Call
- type ORM_WithDataSource_Call
- type ServiceCtx
- type ServiceCtx_Close_Call
- type ServiceCtx_Expecter
- type ServiceCtx_Start_Call
- type Spawner
- func (_m *Spawner) ActiveJobs() map[int32]job.Job
- func (_m *Spawner) Close() error
- func (_m *Spawner) CreateJob(ctx context.Context, ds sqlutil.DataSource, jb *job.Job) error
- func (_m *Spawner) DeleteJob(ctx context.Context, ds sqlutil.DataSource, jobID int32) error
- func (_m *Spawner) EXPECT() *Spawner_Expecter
- func (_m *Spawner) HealthReport() map[string]error
- func (_m *Spawner) Name() string
- func (_m *Spawner) Ready() error
- func (_m *Spawner) Start(_a0 context.Context) error
- func (_m *Spawner) StartService(ctx context.Context, spec job.Job) error
- type Spawner_ActiveJobs_Call
- type Spawner_Close_Call
- type Spawner_CreateJob_Call
- func (_c *Spawner_CreateJob_Call) Return(err error) *Spawner_CreateJob_Call
- func (_c *Spawner_CreateJob_Call) Run(run func(ctx context.Context, ds sqlutil.DataSource, jb *job.Job)) *Spawner_CreateJob_Call
- func (_c *Spawner_CreateJob_Call) RunAndReturn(run func(context.Context, sqlutil.DataSource, *job.Job) error) *Spawner_CreateJob_Call
- type Spawner_DeleteJob_Call
- func (_c *Spawner_DeleteJob_Call) Return(_a0 error) *Spawner_DeleteJob_Call
- func (_c *Spawner_DeleteJob_Call) Run(run func(ctx context.Context, ds sqlutil.DataSource, jobID int32)) *Spawner_DeleteJob_Call
- func (_c *Spawner_DeleteJob_Call) RunAndReturn(run func(context.Context, sqlutil.DataSource, int32) error) *Spawner_DeleteJob_Call
- type Spawner_Expecter
- func (_e *Spawner_Expecter) ActiveJobs() *Spawner_ActiveJobs_Call
- func (_e *Spawner_Expecter) Close() *Spawner_Close_Call
- func (_e *Spawner_Expecter) CreateJob(ctx interface{}, ds interface{}, jb interface{}) *Spawner_CreateJob_Call
- func (_e *Spawner_Expecter) DeleteJob(ctx interface{}, ds interface{}, jobID interface{}) *Spawner_DeleteJob_Call
- func (_e *Spawner_Expecter) HealthReport() *Spawner_HealthReport_Call
- func (_e *Spawner_Expecter) Name() *Spawner_Name_Call
- func (_e *Spawner_Expecter) Ready() *Spawner_Ready_Call
- func (_e *Spawner_Expecter) Start(_a0 interface{}) *Spawner_Start_Call
- func (_e *Spawner_Expecter) StartService(ctx interface{}, spec interface{}) *Spawner_StartService_Call
- type Spawner_HealthReport_Call
- type Spawner_Name_Call
- type Spawner_Ready_Call
- type Spawner_StartService_Call
- func (_c *Spawner_StartService_Call) Return(_a0 error) *Spawner_StartService_Call
- func (_c *Spawner_StartService_Call) Run(run func(ctx context.Context, spec job.Job)) *Spawner_StartService_Call
- func (_c *Spawner_StartService_Call) RunAndReturn(run func(context.Context, job.Job) error) *Spawner_StartService_Call
- type Spawner_Start_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KVStore ¶ added in v2.10.0
KVStore is an autogenerated mock type for the KVStore type
func NewKVStore ¶ added in v2.10.0
NewKVStore creates a new instance of KVStore. 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 (*KVStore) EXPECT ¶ added in v2.15.0
func (_m *KVStore) EXPECT() *KVStore_Expecter
type KVStore_Expecter ¶ added in v2.15.0
type KVStore_Expecter struct {
// contains filtered or unexported fields
}
func (*KVStore_Expecter) Get ¶ added in v2.15.0
func (_e *KVStore_Expecter) Get(ctx interface{}, key interface{}) *KVStore_Get_Call
Get is a helper method to define mock.On call
- ctx context.Context
- key string
func (*KVStore_Expecter) Store ¶ added in v2.15.0
func (_e *KVStore_Expecter) Store(ctx interface{}, key interface{}, val interface{}) *KVStore_Store_Call
Store is a helper method to define mock.On call
- ctx context.Context
- key string
- val []byte
type KVStore_Get_Call ¶ added in v2.15.0
KVStore_Get_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Get'
func (*KVStore_Get_Call) Return ¶ added in v2.15.0
func (_c *KVStore_Get_Call) Return(_a0 []byte, _a1 error) *KVStore_Get_Call
func (*KVStore_Get_Call) Run ¶ added in v2.15.0
func (_c *KVStore_Get_Call) Run(run func(ctx context.Context, key string)) *KVStore_Get_Call
func (*KVStore_Get_Call) RunAndReturn ¶ added in v2.15.0
func (_c *KVStore_Get_Call) RunAndReturn(run func(context.Context, string) ([]byte, error)) *KVStore_Get_Call
type KVStore_Store_Call ¶ added in v2.15.0
KVStore_Store_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Store'
func (*KVStore_Store_Call) Return ¶ added in v2.15.0
func (_c *KVStore_Store_Call) Return(_a0 error) *KVStore_Store_Call
func (*KVStore_Store_Call) Run ¶ added in v2.15.0
func (_c *KVStore_Store_Call) Run(run func(ctx context.Context, key string, val []byte)) *KVStore_Store_Call
func (*KVStore_Store_Call) RunAndReturn ¶ added in v2.15.0
func (_c *KVStore_Store_Call) RunAndReturn(run func(context.Context, string, []byte) error) *KVStore_Store_Call
type ORM ¶
ORM is an autogenerated mock type for the ORM type
func NewORM ¶
NewORM creates a new instance of ORM. 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 (*ORM) AssertBridgesExist ¶
AssertBridgesExist provides a mock function with given fields: ctx, p
func (*ORM) CountPipelineRunsByJobID ¶
CountPipelineRunsByJobID provides a mock function with given fields: ctx, jobID
func (*ORM) DataSource ¶ added in v2.12.0
func (_m *ORM) DataSource() sqlutil.DataSource
DataSource provides a mock function with given fields:
func (*ORM) DismissError ¶
DismissError provides a mock function with given fields: ctx, errorID
func (*ORM) EXPECT ¶ added in v2.15.0
func (_m *ORM) EXPECT() *ORM_Expecter
func (*ORM) FindJobByExternalJobID ¶
FindJobByExternalJobID provides a mock function with given fields: ctx, _a1
func (*ORM) FindJobIDByAddress ¶
func (_m *ORM) FindJobIDByAddress(ctx context.Context, address types.EIP55Address, evmChainID *big.Big) (int32, error)
FindJobIDByAddress provides a mock function with given fields: ctx, address, evmChainID
func (*ORM) FindJobIDByWorkflow ¶ added in v2.13.0
FindJobIDByWorkflow provides a mock function with given fields: ctx, spec
func (*ORM) FindJobIDsWithBridge ¶
FindJobIDsWithBridge provides a mock function with given fields: ctx, name
func (*ORM) FindJobWithoutSpecErrors ¶
FindJobWithoutSpecErrors provides a mock function with given fields: ctx, id
func (*ORM) FindJobsByPipelineSpecIDs ¶
FindJobsByPipelineSpecIDs provides a mock function with given fields: ctx, ids
func (*ORM) FindOCR2JobIDByAddress ¶ added in v2.3.0
func (_m *ORM) FindOCR2JobIDByAddress(ctx context.Context, contractID string, feedID *common.Hash) (int32, error)
FindOCR2JobIDByAddress provides a mock function with given fields: ctx, contractID, feedID
func (*ORM) FindPipelineRunByID ¶
FindPipelineRunByID provides a mock function with given fields: ctx, id
func (*ORM) FindPipelineRunIDsByJobID ¶
func (_m *ORM) FindPipelineRunIDsByJobID(ctx context.Context, jobID int32, offset int, limit int) ([]int64, error)
FindPipelineRunIDsByJobID provides a mock function with given fields: ctx, jobID, offset, limit
func (*ORM) FindPipelineRunsByIDs ¶
FindPipelineRunsByIDs provides a mock function with given fields: ctx, ids
func (*ORM) FindSpecError ¶
FindSpecError provides a mock function with given fields: ctx, id
func (*ORM) FindSpecErrorsByJobIDs ¶
FindSpecErrorsByJobIDs provides a mock function with given fields: ctx, ids
func (*ORM) FindTaskResultByRunIDAndTaskName ¶
func (_m *ORM) FindTaskResultByRunIDAndTaskName(ctx context.Context, runID int64, taskName string) ([]byte, error)
FindTaskResultByRunIDAndTaskName provides a mock function with given fields: ctx, runID, taskName
func (*ORM) InsertWebhookSpec ¶
InsertWebhookSpec provides a mock function with given fields: ctx, webhookSpec
func (*ORM) PipelineRuns ¶
func (_m *ORM) PipelineRuns(ctx context.Context, jobID *int32, offset int, size int) ([]pipeline.Run, int, error)
PipelineRuns provides a mock function with given fields: ctx, jobID, offset, size
func (*ORM) RecordError ¶
RecordError provides a mock function with given fields: ctx, jobID, description
func (*ORM) TryRecordError ¶
TryRecordError provides a mock function with given fields: ctx, jobID, description
func (*ORM) WithDataSource ¶ added in v2.12.0
func (_m *ORM) WithDataSource(source sqlutil.DataSource) job.ORM
WithDataSource provides a mock function with given fields: source
type ORM_AssertBridgesExist_Call ¶ added in v2.15.0
ORM_AssertBridgesExist_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AssertBridgesExist'
func (*ORM_AssertBridgesExist_Call) Return ¶ added in v2.15.0
func (_c *ORM_AssertBridgesExist_Call) Return(_a0 error) *ORM_AssertBridgesExist_Call
func (*ORM_AssertBridgesExist_Call) Run ¶ added in v2.15.0
func (_c *ORM_AssertBridgesExist_Call) Run(run func(ctx context.Context, p pipeline.Pipeline)) *ORM_AssertBridgesExist_Call
func (*ORM_AssertBridgesExist_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_AssertBridgesExist_Call) RunAndReturn(run func(context.Context, pipeline.Pipeline) error) *ORM_AssertBridgesExist_Call
type ORM_Close_Call ¶ added in v2.15.0
ORM_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'
func (*ORM_Close_Call) Return ¶ added in v2.15.0
func (_c *ORM_Close_Call) Return(_a0 error) *ORM_Close_Call
func (*ORM_Close_Call) Run ¶ added in v2.15.0
func (_c *ORM_Close_Call) Run(run func()) *ORM_Close_Call
func (*ORM_Close_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_Close_Call) RunAndReturn(run func() error) *ORM_Close_Call
type ORM_CountPipelineRunsByJobID_Call ¶ added in v2.15.0
ORM_CountPipelineRunsByJobID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CountPipelineRunsByJobID'
func (*ORM_CountPipelineRunsByJobID_Call) Return ¶ added in v2.15.0
func (_c *ORM_CountPipelineRunsByJobID_Call) Return(count int32, err error) *ORM_CountPipelineRunsByJobID_Call
func (*ORM_CountPipelineRunsByJobID_Call) Run ¶ added in v2.15.0
func (_c *ORM_CountPipelineRunsByJobID_Call) Run(run func(ctx context.Context, jobID int32)) *ORM_CountPipelineRunsByJobID_Call
func (*ORM_CountPipelineRunsByJobID_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_CountPipelineRunsByJobID_Call) RunAndReturn(run func(context.Context, int32) (int32, error)) *ORM_CountPipelineRunsByJobID_Call
type ORM_CreateJob_Call ¶ added in v2.15.0
ORM_CreateJob_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateJob'
func (*ORM_CreateJob_Call) Return ¶ added in v2.15.0
func (_c *ORM_CreateJob_Call) Return(_a0 error) *ORM_CreateJob_Call
func (*ORM_CreateJob_Call) Run ¶ added in v2.15.0
func (_c *ORM_CreateJob_Call) Run(run func(ctx context.Context, jb *job.Job)) *ORM_CreateJob_Call
func (*ORM_CreateJob_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_CreateJob_Call) RunAndReturn(run func(context.Context, *job.Job) error) *ORM_CreateJob_Call
type ORM_DataSource_Call ¶ added in v2.15.0
ORM_DataSource_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DataSource'
func (*ORM_DataSource_Call) Return ¶ added in v2.15.0
func (_c *ORM_DataSource_Call) Return(_a0 sqlutil.DataSource) *ORM_DataSource_Call
func (*ORM_DataSource_Call) Run ¶ added in v2.15.0
func (_c *ORM_DataSource_Call) Run(run func()) *ORM_DataSource_Call
func (*ORM_DataSource_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_DataSource_Call) RunAndReturn(run func() sqlutil.DataSource) *ORM_DataSource_Call
type ORM_DeleteJob_Call ¶ added in v2.15.0
ORM_DeleteJob_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteJob'
func (*ORM_DeleteJob_Call) Return ¶ added in v2.15.0
func (_c *ORM_DeleteJob_Call) Return(_a0 error) *ORM_DeleteJob_Call
func (*ORM_DeleteJob_Call) Run ¶ added in v2.15.0
func (_c *ORM_DeleteJob_Call) Run(run func(ctx context.Context, id int32)) *ORM_DeleteJob_Call
func (*ORM_DeleteJob_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_DeleteJob_Call) RunAndReturn(run func(context.Context, int32) error) *ORM_DeleteJob_Call
type ORM_DismissError_Call ¶ added in v2.15.0
ORM_DismissError_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DismissError'
func (*ORM_DismissError_Call) Return ¶ added in v2.15.0
func (_c *ORM_DismissError_Call) Return(_a0 error) *ORM_DismissError_Call
func (*ORM_DismissError_Call) Run ¶ added in v2.15.0
func (_c *ORM_DismissError_Call) Run(run func(ctx context.Context, errorID int64)) *ORM_DismissError_Call
func (*ORM_DismissError_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_DismissError_Call) RunAndReturn(run func(context.Context, int64) error) *ORM_DismissError_Call
type ORM_Expecter ¶ added in v2.15.0
type ORM_Expecter struct {
// contains filtered or unexported fields
}
func (*ORM_Expecter) AssertBridgesExist ¶ added in v2.15.0
func (_e *ORM_Expecter) AssertBridgesExist(ctx interface{}, p interface{}) *ORM_AssertBridgesExist_Call
AssertBridgesExist is a helper method to define mock.On call
- ctx context.Context
- p pipeline.Pipeline
func (*ORM_Expecter) Close ¶ added in v2.15.0
func (_e *ORM_Expecter) Close() *ORM_Close_Call
Close is a helper method to define mock.On call
func (*ORM_Expecter) CountPipelineRunsByJobID ¶ added in v2.15.0
func (_e *ORM_Expecter) CountPipelineRunsByJobID(ctx interface{}, jobID interface{}) *ORM_CountPipelineRunsByJobID_Call
CountPipelineRunsByJobID is a helper method to define mock.On call
- ctx context.Context
- jobID int32
func (*ORM_Expecter) CreateJob ¶ added in v2.15.0
func (_e *ORM_Expecter) CreateJob(ctx interface{}, jb interface{}) *ORM_CreateJob_Call
CreateJob is a helper method to define mock.On call
- ctx context.Context
- jb *job.Job
func (*ORM_Expecter) DataSource ¶ added in v2.15.0
func (_e *ORM_Expecter) DataSource() *ORM_DataSource_Call
DataSource is a helper method to define mock.On call
func (*ORM_Expecter) DeleteJob ¶ added in v2.15.0
func (_e *ORM_Expecter) DeleteJob(ctx interface{}, id interface{}) *ORM_DeleteJob_Call
DeleteJob is a helper method to define mock.On call
- ctx context.Context
- id int32
func (*ORM_Expecter) DismissError ¶ added in v2.15.0
func (_e *ORM_Expecter) DismissError(ctx interface{}, errorID interface{}) *ORM_DismissError_Call
DismissError is a helper method to define mock.On call
- ctx context.Context
- errorID int64
func (*ORM_Expecter) FindJob ¶ added in v2.15.0
func (_e *ORM_Expecter) FindJob(ctx interface{}, id interface{}) *ORM_FindJob_Call
FindJob is a helper method to define mock.On call
- ctx context.Context
- id int32
func (*ORM_Expecter) FindJobByExternalJobID ¶ added in v2.15.0
func (_e *ORM_Expecter) FindJobByExternalJobID(ctx interface{}, _a1 interface{}) *ORM_FindJobByExternalJobID_Call
FindJobByExternalJobID is a helper method to define mock.On call
- ctx context.Context
- _a1 uuid.UUID
func (*ORM_Expecter) FindJobIDByAddress ¶ added in v2.15.0
func (_e *ORM_Expecter) FindJobIDByAddress(ctx interface{}, address interface{}, evmChainID interface{}) *ORM_FindJobIDByAddress_Call
FindJobIDByAddress is a helper method to define mock.On call
- ctx context.Context
- address types.EIP55Address
- evmChainID *big.Big
func (*ORM_Expecter) FindJobIDByWorkflow ¶ added in v2.15.0
func (_e *ORM_Expecter) FindJobIDByWorkflow(ctx interface{}, spec interface{}) *ORM_FindJobIDByWorkflow_Call
FindJobIDByWorkflow is a helper method to define mock.On call
- ctx context.Context
- spec job.WorkflowSpec
func (*ORM_Expecter) FindJobIDsWithBridge ¶ added in v2.15.0
func (_e *ORM_Expecter) FindJobIDsWithBridge(ctx interface{}, name interface{}) *ORM_FindJobIDsWithBridge_Call
FindJobIDsWithBridge is a helper method to define mock.On call
- ctx context.Context
- name string
func (*ORM_Expecter) FindJobTx ¶ added in v2.15.0
func (_e *ORM_Expecter) FindJobTx(ctx interface{}, id interface{}) *ORM_FindJobTx_Call
FindJobTx is a helper method to define mock.On call
- ctx context.Context
- id int32
func (*ORM_Expecter) FindJobWithoutSpecErrors ¶ added in v2.15.0
func (_e *ORM_Expecter) FindJobWithoutSpecErrors(ctx interface{}, id interface{}) *ORM_FindJobWithoutSpecErrors_Call
FindJobWithoutSpecErrors is a helper method to define mock.On call
- ctx context.Context
- id int32
func (*ORM_Expecter) FindJobs ¶ added in v2.15.0
func (_e *ORM_Expecter) FindJobs(ctx interface{}, offset interface{}, limit interface{}) *ORM_FindJobs_Call
FindJobs is a helper method to define mock.On call
- ctx context.Context
- offset int
- limit int
func (*ORM_Expecter) FindJobsByPipelineSpecIDs ¶ added in v2.15.0
func (_e *ORM_Expecter) FindJobsByPipelineSpecIDs(ctx interface{}, ids interface{}) *ORM_FindJobsByPipelineSpecIDs_Call
FindJobsByPipelineSpecIDs is a helper method to define mock.On call
- ctx context.Context
- ids []int32
func (*ORM_Expecter) FindOCR2JobIDByAddress ¶ added in v2.15.0
func (_e *ORM_Expecter) FindOCR2JobIDByAddress(ctx interface{}, contractID interface{}, feedID interface{}) *ORM_FindOCR2JobIDByAddress_Call
FindOCR2JobIDByAddress is a helper method to define mock.On call
- ctx context.Context
- contractID string
- feedID *common.Hash
func (*ORM_Expecter) FindPipelineRunByID ¶ added in v2.15.0
func (_e *ORM_Expecter) FindPipelineRunByID(ctx interface{}, id interface{}) *ORM_FindPipelineRunByID_Call
FindPipelineRunByID is a helper method to define mock.On call
- ctx context.Context
- id int64
func (*ORM_Expecter) FindPipelineRunIDsByJobID ¶ added in v2.15.0
func (_e *ORM_Expecter) FindPipelineRunIDsByJobID(ctx interface{}, jobID interface{}, offset interface{}, limit interface{}) *ORM_FindPipelineRunIDsByJobID_Call
FindPipelineRunIDsByJobID is a helper method to define mock.On call
- ctx context.Context
- jobID int32
- offset int
- limit int
func (*ORM_Expecter) FindPipelineRunsByIDs ¶ added in v2.15.0
func (_e *ORM_Expecter) FindPipelineRunsByIDs(ctx interface{}, ids interface{}) *ORM_FindPipelineRunsByIDs_Call
FindPipelineRunsByIDs is a helper method to define mock.On call
- ctx context.Context
- ids []int64
func (*ORM_Expecter) FindSpecError ¶ added in v2.15.0
func (_e *ORM_Expecter) FindSpecError(ctx interface{}, id interface{}) *ORM_FindSpecError_Call
FindSpecError is a helper method to define mock.On call
- ctx context.Context
- id int64
func (*ORM_Expecter) FindSpecErrorsByJobIDs ¶ added in v2.15.0
func (_e *ORM_Expecter) FindSpecErrorsByJobIDs(ctx interface{}, ids interface{}) *ORM_FindSpecErrorsByJobIDs_Call
FindSpecErrorsByJobIDs is a helper method to define mock.On call
- ctx context.Context
- ids []int32
func (*ORM_Expecter) FindTaskResultByRunIDAndTaskName ¶ added in v2.15.0
func (_e *ORM_Expecter) FindTaskResultByRunIDAndTaskName(ctx interface{}, runID interface{}, taskName interface{}) *ORM_FindTaskResultByRunIDAndTaskName_Call
FindTaskResultByRunIDAndTaskName is a helper method to define mock.On call
- ctx context.Context
- runID int64
- taskName string
func (*ORM_Expecter) InsertJob ¶ added in v2.15.0
func (_e *ORM_Expecter) InsertJob(ctx interface{}, _a1 interface{}) *ORM_InsertJob_Call
InsertJob is a helper method to define mock.On call
- ctx context.Context
- _a1 *job.Job
func (*ORM_Expecter) InsertWebhookSpec ¶ added in v2.15.0
func (_e *ORM_Expecter) InsertWebhookSpec(ctx interface{}, webhookSpec interface{}) *ORM_InsertWebhookSpec_Call
InsertWebhookSpec is a helper method to define mock.On call
- ctx context.Context
- webhookSpec *job.WebhookSpec
func (*ORM_Expecter) PipelineRuns ¶ added in v2.15.0
func (_e *ORM_Expecter) PipelineRuns(ctx interface{}, jobID interface{}, offset interface{}, size interface{}) *ORM_PipelineRuns_Call
PipelineRuns is a helper method to define mock.On call
- ctx context.Context
- jobID *int32
- offset int
- size int
func (*ORM_Expecter) RecordError ¶ added in v2.15.0
func (_e *ORM_Expecter) RecordError(ctx interface{}, jobID interface{}, description interface{}) *ORM_RecordError_Call
RecordError is a helper method to define mock.On call
- ctx context.Context
- jobID int32
- description string
func (*ORM_Expecter) TryRecordError ¶ added in v2.15.0
func (_e *ORM_Expecter) TryRecordError(ctx interface{}, jobID interface{}, description interface{}) *ORM_TryRecordError_Call
TryRecordError is a helper method to define mock.On call
- ctx context.Context
- jobID int32
- description string
func (*ORM_Expecter) WithDataSource ¶ added in v2.15.0
func (_e *ORM_Expecter) WithDataSource(source interface{}) *ORM_WithDataSource_Call
WithDataSource is a helper method to define mock.On call
- source sqlutil.DataSource
type ORM_FindJobByExternalJobID_Call ¶ added in v2.15.0
ORM_FindJobByExternalJobID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindJobByExternalJobID'
func (*ORM_FindJobByExternalJobID_Call) Return ¶ added in v2.15.0
func (_c *ORM_FindJobByExternalJobID_Call) Return(_a0 job.Job, _a1 error) *ORM_FindJobByExternalJobID_Call
func (*ORM_FindJobByExternalJobID_Call) Run ¶ added in v2.15.0
func (_c *ORM_FindJobByExternalJobID_Call) Run(run func(ctx context.Context, _a1 uuid.UUID)) *ORM_FindJobByExternalJobID_Call
func (*ORM_FindJobByExternalJobID_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_FindJobByExternalJobID_Call) RunAndReturn(run func(context.Context, uuid.UUID) (job.Job, error)) *ORM_FindJobByExternalJobID_Call
type ORM_FindJobIDByAddress_Call ¶ added in v2.15.0
ORM_FindJobIDByAddress_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindJobIDByAddress'
func (*ORM_FindJobIDByAddress_Call) Return ¶ added in v2.15.0
func (_c *ORM_FindJobIDByAddress_Call) Return(_a0 int32, _a1 error) *ORM_FindJobIDByAddress_Call
func (*ORM_FindJobIDByAddress_Call) Run ¶ added in v2.15.0
func (_c *ORM_FindJobIDByAddress_Call) Run(run func(ctx context.Context, address types.EIP55Address, evmChainID *big.Big)) *ORM_FindJobIDByAddress_Call
func (*ORM_FindJobIDByAddress_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_FindJobIDByAddress_Call) RunAndReturn(run func(context.Context, types.EIP55Address, *big.Big) (int32, error)) *ORM_FindJobIDByAddress_Call
type ORM_FindJobIDByWorkflow_Call ¶ added in v2.15.0
ORM_FindJobIDByWorkflow_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindJobIDByWorkflow'
func (*ORM_FindJobIDByWorkflow_Call) Return ¶ added in v2.15.0
func (_c *ORM_FindJobIDByWorkflow_Call) Return(_a0 int32, _a1 error) *ORM_FindJobIDByWorkflow_Call
func (*ORM_FindJobIDByWorkflow_Call) Run ¶ added in v2.15.0
func (_c *ORM_FindJobIDByWorkflow_Call) Run(run func(ctx context.Context, spec job.WorkflowSpec)) *ORM_FindJobIDByWorkflow_Call
func (*ORM_FindJobIDByWorkflow_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_FindJobIDByWorkflow_Call) RunAndReturn(run func(context.Context, job.WorkflowSpec) (int32, error)) *ORM_FindJobIDByWorkflow_Call
type ORM_FindJobIDsWithBridge_Call ¶ added in v2.15.0
ORM_FindJobIDsWithBridge_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindJobIDsWithBridge'
func (*ORM_FindJobIDsWithBridge_Call) Return ¶ added in v2.15.0
func (_c *ORM_FindJobIDsWithBridge_Call) Return(_a0 []int32, _a1 error) *ORM_FindJobIDsWithBridge_Call
func (*ORM_FindJobIDsWithBridge_Call) Run ¶ added in v2.15.0
func (_c *ORM_FindJobIDsWithBridge_Call) Run(run func(ctx context.Context, name string)) *ORM_FindJobIDsWithBridge_Call
func (*ORM_FindJobIDsWithBridge_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_FindJobIDsWithBridge_Call) RunAndReturn(run func(context.Context, string) ([]int32, error)) *ORM_FindJobIDsWithBridge_Call
type ORM_FindJobTx_Call ¶ added in v2.15.0
ORM_FindJobTx_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindJobTx'
func (*ORM_FindJobTx_Call) Return ¶ added in v2.15.0
func (_c *ORM_FindJobTx_Call) Return(_a0 job.Job, _a1 error) *ORM_FindJobTx_Call
func (*ORM_FindJobTx_Call) Run ¶ added in v2.15.0
func (_c *ORM_FindJobTx_Call) Run(run func(ctx context.Context, id int32)) *ORM_FindJobTx_Call
func (*ORM_FindJobTx_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_FindJobTx_Call) RunAndReturn(run func(context.Context, int32) (job.Job, error)) *ORM_FindJobTx_Call
type ORM_FindJobWithoutSpecErrors_Call ¶ added in v2.15.0
ORM_FindJobWithoutSpecErrors_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindJobWithoutSpecErrors'
func (*ORM_FindJobWithoutSpecErrors_Call) Return ¶ added in v2.15.0
func (_c *ORM_FindJobWithoutSpecErrors_Call) Return(jb job.Job, err error) *ORM_FindJobWithoutSpecErrors_Call
func (*ORM_FindJobWithoutSpecErrors_Call) Run ¶ added in v2.15.0
func (_c *ORM_FindJobWithoutSpecErrors_Call) Run(run func(ctx context.Context, id int32)) *ORM_FindJobWithoutSpecErrors_Call
func (*ORM_FindJobWithoutSpecErrors_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_FindJobWithoutSpecErrors_Call) RunAndReturn(run func(context.Context, int32) (job.Job, error)) *ORM_FindJobWithoutSpecErrors_Call
type ORM_FindJob_Call ¶ added in v2.15.0
ORM_FindJob_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindJob'
func (*ORM_FindJob_Call) Return ¶ added in v2.15.0
func (_c *ORM_FindJob_Call) Return(_a0 job.Job, _a1 error) *ORM_FindJob_Call
func (*ORM_FindJob_Call) Run ¶ added in v2.15.0
func (_c *ORM_FindJob_Call) Run(run func(ctx context.Context, id int32)) *ORM_FindJob_Call
func (*ORM_FindJob_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_FindJob_Call) RunAndReturn(run func(context.Context, int32) (job.Job, error)) *ORM_FindJob_Call
type ORM_FindJobsByPipelineSpecIDs_Call ¶ added in v2.15.0
ORM_FindJobsByPipelineSpecIDs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindJobsByPipelineSpecIDs'
func (*ORM_FindJobsByPipelineSpecIDs_Call) Return ¶ added in v2.15.0
func (_c *ORM_FindJobsByPipelineSpecIDs_Call) Return(_a0 []job.Job, _a1 error) *ORM_FindJobsByPipelineSpecIDs_Call
func (*ORM_FindJobsByPipelineSpecIDs_Call) Run ¶ added in v2.15.0
func (_c *ORM_FindJobsByPipelineSpecIDs_Call) Run(run func(ctx context.Context, ids []int32)) *ORM_FindJobsByPipelineSpecIDs_Call
func (*ORM_FindJobsByPipelineSpecIDs_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_FindJobsByPipelineSpecIDs_Call) RunAndReturn(run func(context.Context, []int32) ([]job.Job, error)) *ORM_FindJobsByPipelineSpecIDs_Call
type ORM_FindJobs_Call ¶ added in v2.15.0
ORM_FindJobs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindJobs'
func (*ORM_FindJobs_Call) Return ¶ added in v2.15.0
func (_c *ORM_FindJobs_Call) Return(_a0 []job.Job, _a1 int, _a2 error) *ORM_FindJobs_Call
func (*ORM_FindJobs_Call) Run ¶ added in v2.15.0
func (_c *ORM_FindJobs_Call) Run(run func(ctx context.Context, offset int, limit int)) *ORM_FindJobs_Call
func (*ORM_FindJobs_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_FindJobs_Call) RunAndReturn(run func(context.Context, int, int) ([]job.Job, int, error)) *ORM_FindJobs_Call
type ORM_FindOCR2JobIDByAddress_Call ¶ added in v2.15.0
ORM_FindOCR2JobIDByAddress_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindOCR2JobIDByAddress'
func (*ORM_FindOCR2JobIDByAddress_Call) Return ¶ added in v2.15.0
func (_c *ORM_FindOCR2JobIDByAddress_Call) Return(_a0 int32, _a1 error) *ORM_FindOCR2JobIDByAddress_Call
func (*ORM_FindOCR2JobIDByAddress_Call) Run ¶ added in v2.15.0
func (_c *ORM_FindOCR2JobIDByAddress_Call) Run(run func(ctx context.Context, contractID string, feedID *common.Hash)) *ORM_FindOCR2JobIDByAddress_Call
func (*ORM_FindOCR2JobIDByAddress_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_FindOCR2JobIDByAddress_Call) RunAndReturn(run func(context.Context, string, *common.Hash) (int32, error)) *ORM_FindOCR2JobIDByAddress_Call
type ORM_FindPipelineRunByID_Call ¶ added in v2.15.0
ORM_FindPipelineRunByID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindPipelineRunByID'
func (*ORM_FindPipelineRunByID_Call) Return ¶ added in v2.15.0
func (_c *ORM_FindPipelineRunByID_Call) Return(_a0 pipeline.Run, _a1 error) *ORM_FindPipelineRunByID_Call
func (*ORM_FindPipelineRunByID_Call) Run ¶ added in v2.15.0
func (_c *ORM_FindPipelineRunByID_Call) Run(run func(ctx context.Context, id int64)) *ORM_FindPipelineRunByID_Call
func (*ORM_FindPipelineRunByID_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_FindPipelineRunByID_Call) RunAndReturn(run func(context.Context, int64) (pipeline.Run, error)) *ORM_FindPipelineRunByID_Call
type ORM_FindPipelineRunIDsByJobID_Call ¶ added in v2.15.0
ORM_FindPipelineRunIDsByJobID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindPipelineRunIDsByJobID'
func (*ORM_FindPipelineRunIDsByJobID_Call) Return ¶ added in v2.15.0
func (_c *ORM_FindPipelineRunIDsByJobID_Call) Return(ids []int64, err error) *ORM_FindPipelineRunIDsByJobID_Call
func (*ORM_FindPipelineRunIDsByJobID_Call) Run ¶ added in v2.15.0
func (_c *ORM_FindPipelineRunIDsByJobID_Call) Run(run func(ctx context.Context, jobID int32, offset int, limit int)) *ORM_FindPipelineRunIDsByJobID_Call
func (*ORM_FindPipelineRunIDsByJobID_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_FindPipelineRunIDsByJobID_Call) RunAndReturn(run func(context.Context, int32, int, int) ([]int64, error)) *ORM_FindPipelineRunIDsByJobID_Call
type ORM_FindPipelineRunsByIDs_Call ¶ added in v2.15.0
ORM_FindPipelineRunsByIDs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindPipelineRunsByIDs'
func (*ORM_FindPipelineRunsByIDs_Call) Return ¶ added in v2.15.0
func (_c *ORM_FindPipelineRunsByIDs_Call) Return(runs []pipeline.Run, err error) *ORM_FindPipelineRunsByIDs_Call
func (*ORM_FindPipelineRunsByIDs_Call) Run ¶ added in v2.15.0
func (_c *ORM_FindPipelineRunsByIDs_Call) Run(run func(ctx context.Context, ids []int64)) *ORM_FindPipelineRunsByIDs_Call
func (*ORM_FindPipelineRunsByIDs_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_FindPipelineRunsByIDs_Call) RunAndReturn(run func(context.Context, []int64) ([]pipeline.Run, error)) *ORM_FindPipelineRunsByIDs_Call
type ORM_FindSpecError_Call ¶ added in v2.15.0
ORM_FindSpecError_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindSpecError'
func (*ORM_FindSpecError_Call) Return ¶ added in v2.15.0
func (_c *ORM_FindSpecError_Call) Return(_a0 job.SpecError, _a1 error) *ORM_FindSpecError_Call
func (*ORM_FindSpecError_Call) Run ¶ added in v2.15.0
func (_c *ORM_FindSpecError_Call) Run(run func(ctx context.Context, id int64)) *ORM_FindSpecError_Call
func (*ORM_FindSpecError_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_FindSpecError_Call) RunAndReturn(run func(context.Context, int64) (job.SpecError, error)) *ORM_FindSpecError_Call
type ORM_FindSpecErrorsByJobIDs_Call ¶ added in v2.15.0
ORM_FindSpecErrorsByJobIDs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindSpecErrorsByJobIDs'
func (*ORM_FindSpecErrorsByJobIDs_Call) Return ¶ added in v2.15.0
func (_c *ORM_FindSpecErrorsByJobIDs_Call) Return(_a0 []job.SpecError, _a1 error) *ORM_FindSpecErrorsByJobIDs_Call
func (*ORM_FindSpecErrorsByJobIDs_Call) Run ¶ added in v2.15.0
func (_c *ORM_FindSpecErrorsByJobIDs_Call) Run(run func(ctx context.Context, ids []int32)) *ORM_FindSpecErrorsByJobIDs_Call
func (*ORM_FindSpecErrorsByJobIDs_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_FindSpecErrorsByJobIDs_Call) RunAndReturn(run func(context.Context, []int32) ([]job.SpecError, error)) *ORM_FindSpecErrorsByJobIDs_Call
type ORM_FindTaskResultByRunIDAndTaskName_Call ¶ added in v2.15.0
ORM_FindTaskResultByRunIDAndTaskName_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindTaskResultByRunIDAndTaskName'
func (*ORM_FindTaskResultByRunIDAndTaskName_Call) Return ¶ added in v2.15.0
func (_c *ORM_FindTaskResultByRunIDAndTaskName_Call) Return(_a0 []byte, _a1 error) *ORM_FindTaskResultByRunIDAndTaskName_Call
func (*ORM_FindTaskResultByRunIDAndTaskName_Call) Run ¶ added in v2.15.0
func (_c *ORM_FindTaskResultByRunIDAndTaskName_Call) Run(run func(ctx context.Context, runID int64, taskName string)) *ORM_FindTaskResultByRunIDAndTaskName_Call
func (*ORM_FindTaskResultByRunIDAndTaskName_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_FindTaskResultByRunIDAndTaskName_Call) RunAndReturn(run func(context.Context, int64, string) ([]byte, error)) *ORM_FindTaskResultByRunIDAndTaskName_Call
type ORM_InsertJob_Call ¶ added in v2.15.0
ORM_InsertJob_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InsertJob'
func (*ORM_InsertJob_Call) Return ¶ added in v2.15.0
func (_c *ORM_InsertJob_Call) Return(_a0 error) *ORM_InsertJob_Call
func (*ORM_InsertJob_Call) Run ¶ added in v2.15.0
func (_c *ORM_InsertJob_Call) Run(run func(ctx context.Context, _a1 *job.Job)) *ORM_InsertJob_Call
func (*ORM_InsertJob_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_InsertJob_Call) RunAndReturn(run func(context.Context, *job.Job) error) *ORM_InsertJob_Call
type ORM_InsertWebhookSpec_Call ¶ added in v2.15.0
ORM_InsertWebhookSpec_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InsertWebhookSpec'
func (*ORM_InsertWebhookSpec_Call) Return ¶ added in v2.15.0
func (_c *ORM_InsertWebhookSpec_Call) Return(_a0 error) *ORM_InsertWebhookSpec_Call
func (*ORM_InsertWebhookSpec_Call) Run ¶ added in v2.15.0
func (_c *ORM_InsertWebhookSpec_Call) Run(run func(ctx context.Context, webhookSpec *job.WebhookSpec)) *ORM_InsertWebhookSpec_Call
func (*ORM_InsertWebhookSpec_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_InsertWebhookSpec_Call) RunAndReturn(run func(context.Context, *job.WebhookSpec) error) *ORM_InsertWebhookSpec_Call
type ORM_PipelineRuns_Call ¶ added in v2.15.0
ORM_PipelineRuns_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PipelineRuns'
func (*ORM_PipelineRuns_Call) Return ¶ added in v2.15.0
func (_c *ORM_PipelineRuns_Call) Return(_a0 []pipeline.Run, _a1 int, _a2 error) *ORM_PipelineRuns_Call
func (*ORM_PipelineRuns_Call) Run ¶ added in v2.15.0
func (_c *ORM_PipelineRuns_Call) Run(run func(ctx context.Context, jobID *int32, offset int, size int)) *ORM_PipelineRuns_Call
func (*ORM_PipelineRuns_Call) RunAndReturn ¶ added in v2.15.0
type ORM_RecordError_Call ¶ added in v2.15.0
ORM_RecordError_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RecordError'
func (*ORM_RecordError_Call) Return ¶ added in v2.15.0
func (_c *ORM_RecordError_Call) Return(_a0 error) *ORM_RecordError_Call
func (*ORM_RecordError_Call) Run ¶ added in v2.15.0
func (_c *ORM_RecordError_Call) Run(run func(ctx context.Context, jobID int32, description string)) *ORM_RecordError_Call
func (*ORM_RecordError_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_RecordError_Call) RunAndReturn(run func(context.Context, int32, string) error) *ORM_RecordError_Call
type ORM_TryRecordError_Call ¶ added in v2.15.0
ORM_TryRecordError_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'TryRecordError'
func (*ORM_TryRecordError_Call) Return ¶ added in v2.15.0
func (_c *ORM_TryRecordError_Call) Return() *ORM_TryRecordError_Call
func (*ORM_TryRecordError_Call) Run ¶ added in v2.15.0
func (_c *ORM_TryRecordError_Call) Run(run func(ctx context.Context, jobID int32, description string)) *ORM_TryRecordError_Call
func (*ORM_TryRecordError_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_TryRecordError_Call) RunAndReturn(run func(context.Context, int32, string)) *ORM_TryRecordError_Call
type ORM_WithDataSource_Call ¶ added in v2.15.0
ORM_WithDataSource_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WithDataSource'
func (*ORM_WithDataSource_Call) Return ¶ added in v2.15.0
func (_c *ORM_WithDataSource_Call) Return(_a0 job.ORM) *ORM_WithDataSource_Call
func (*ORM_WithDataSource_Call) Run ¶ added in v2.15.0
func (_c *ORM_WithDataSource_Call) Run(run func(source sqlutil.DataSource)) *ORM_WithDataSource_Call
func (*ORM_WithDataSource_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_WithDataSource_Call) RunAndReturn(run func(sqlutil.DataSource) job.ORM) *ORM_WithDataSource_Call
type ServiceCtx ¶
ServiceCtx is an autogenerated mock type for the ServiceCtx type
func NewServiceCtx ¶
func NewServiceCtx(t interface { mock.TestingT Cleanup(func()) }) *ServiceCtx
NewServiceCtx creates a new instance of ServiceCtx. 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 (*ServiceCtx) Close ¶
func (_m *ServiceCtx) Close() error
Close provides a mock function with given fields:
func (*ServiceCtx) EXPECT ¶ added in v2.15.0
func (_m *ServiceCtx) EXPECT() *ServiceCtx_Expecter
type ServiceCtx_Close_Call ¶ added in v2.15.0
ServiceCtx_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'
func (*ServiceCtx_Close_Call) Return ¶ added in v2.15.0
func (_c *ServiceCtx_Close_Call) Return(_a0 error) *ServiceCtx_Close_Call
func (*ServiceCtx_Close_Call) Run ¶ added in v2.15.0
func (_c *ServiceCtx_Close_Call) Run(run func()) *ServiceCtx_Close_Call
func (*ServiceCtx_Close_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ServiceCtx_Close_Call) RunAndReturn(run func() error) *ServiceCtx_Close_Call
type ServiceCtx_Expecter ¶ added in v2.15.0
type ServiceCtx_Expecter struct {
// contains filtered or unexported fields
}
func (*ServiceCtx_Expecter) Close ¶ added in v2.15.0
func (_e *ServiceCtx_Expecter) Close() *ServiceCtx_Close_Call
Close is a helper method to define mock.On call
func (*ServiceCtx_Expecter) Start ¶ added in v2.15.0
func (_e *ServiceCtx_Expecter) Start(_a0 interface{}) *ServiceCtx_Start_Call
Start is a helper method to define mock.On call
- _a0 context.Context
type ServiceCtx_Start_Call ¶ added in v2.15.0
ServiceCtx_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'
func (*ServiceCtx_Start_Call) Return ¶ added in v2.15.0
func (_c *ServiceCtx_Start_Call) Return(_a0 error) *ServiceCtx_Start_Call
func (*ServiceCtx_Start_Call) Run ¶ added in v2.15.0
func (_c *ServiceCtx_Start_Call) Run(run func(_a0 context.Context)) *ServiceCtx_Start_Call
func (*ServiceCtx_Start_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ServiceCtx_Start_Call) RunAndReturn(run func(context.Context) error) *ServiceCtx_Start_Call
type Spawner ¶
Spawner is an autogenerated mock type for the Spawner type
func NewSpawner ¶
NewSpawner creates a new instance of Spawner. 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 (*Spawner) ActiveJobs ¶
ActiveJobs provides a mock function with given fields:
func (*Spawner) EXPECT ¶ added in v2.15.0
func (_m *Spawner) EXPECT() *Spawner_Expecter
func (*Spawner) HealthReport ¶
HealthReport provides a mock function with given fields:
type Spawner_ActiveJobs_Call ¶ added in v2.15.0
Spawner_ActiveJobs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ActiveJobs'
func (*Spawner_ActiveJobs_Call) Return ¶ added in v2.15.0
func (_c *Spawner_ActiveJobs_Call) Return(_a0 map[int32]job.Job) *Spawner_ActiveJobs_Call
func (*Spawner_ActiveJobs_Call) Run ¶ added in v2.15.0
func (_c *Spawner_ActiveJobs_Call) Run(run func()) *Spawner_ActiveJobs_Call
func (*Spawner_ActiveJobs_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Spawner_ActiveJobs_Call) RunAndReturn(run func() map[int32]job.Job) *Spawner_ActiveJobs_Call
type Spawner_Close_Call ¶ added in v2.15.0
Spawner_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'
func (*Spawner_Close_Call) Return ¶ added in v2.15.0
func (_c *Spawner_Close_Call) Return(_a0 error) *Spawner_Close_Call
func (*Spawner_Close_Call) Run ¶ added in v2.15.0
func (_c *Spawner_Close_Call) Run(run func()) *Spawner_Close_Call
func (*Spawner_Close_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Spawner_Close_Call) RunAndReturn(run func() error) *Spawner_Close_Call
type Spawner_CreateJob_Call ¶ added in v2.15.0
Spawner_CreateJob_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateJob'
func (*Spawner_CreateJob_Call) Return ¶ added in v2.15.0
func (_c *Spawner_CreateJob_Call) Return(err error) *Spawner_CreateJob_Call
func (*Spawner_CreateJob_Call) Run ¶ added in v2.15.0
func (_c *Spawner_CreateJob_Call) Run(run func(ctx context.Context, ds sqlutil.DataSource, jb *job.Job)) *Spawner_CreateJob_Call
func (*Spawner_CreateJob_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Spawner_CreateJob_Call) RunAndReturn(run func(context.Context, sqlutil.DataSource, *job.Job) error) *Spawner_CreateJob_Call
type Spawner_DeleteJob_Call ¶ added in v2.15.0
Spawner_DeleteJob_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteJob'
func (*Spawner_DeleteJob_Call) Return ¶ added in v2.15.0
func (_c *Spawner_DeleteJob_Call) Return(_a0 error) *Spawner_DeleteJob_Call
func (*Spawner_DeleteJob_Call) Run ¶ added in v2.15.0
func (_c *Spawner_DeleteJob_Call) Run(run func(ctx context.Context, ds sqlutil.DataSource, jobID int32)) *Spawner_DeleteJob_Call
func (*Spawner_DeleteJob_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Spawner_DeleteJob_Call) RunAndReturn(run func(context.Context, sqlutil.DataSource, int32) error) *Spawner_DeleteJob_Call
type Spawner_Expecter ¶ added in v2.15.0
type Spawner_Expecter struct {
// contains filtered or unexported fields
}
func (*Spawner_Expecter) ActiveJobs ¶ added in v2.15.0
func (_e *Spawner_Expecter) ActiveJobs() *Spawner_ActiveJobs_Call
ActiveJobs is a helper method to define mock.On call
func (*Spawner_Expecter) Close ¶ added in v2.15.0
func (_e *Spawner_Expecter) Close() *Spawner_Close_Call
Close is a helper method to define mock.On call
func (*Spawner_Expecter) CreateJob ¶ added in v2.15.0
func (_e *Spawner_Expecter) CreateJob(ctx interface{}, ds interface{}, jb interface{}) *Spawner_CreateJob_Call
CreateJob is a helper method to define mock.On call
- ctx context.Context
- ds sqlutil.DataSource
- jb *job.Job
func (*Spawner_Expecter) DeleteJob ¶ added in v2.15.0
func (_e *Spawner_Expecter) DeleteJob(ctx interface{}, ds interface{}, jobID interface{}) *Spawner_DeleteJob_Call
DeleteJob is a helper method to define mock.On call
- ctx context.Context
- ds sqlutil.DataSource
- jobID int32
func (*Spawner_Expecter) HealthReport ¶ added in v2.15.0
func (_e *Spawner_Expecter) HealthReport() *Spawner_HealthReport_Call
HealthReport is a helper method to define mock.On call
func (*Spawner_Expecter) Name ¶ added in v2.15.0
func (_e *Spawner_Expecter) Name() *Spawner_Name_Call
Name is a helper method to define mock.On call
func (*Spawner_Expecter) Ready ¶ added in v2.15.0
func (_e *Spawner_Expecter) Ready() *Spawner_Ready_Call
Ready is a helper method to define mock.On call
func (*Spawner_Expecter) Start ¶ added in v2.15.0
func (_e *Spawner_Expecter) Start(_a0 interface{}) *Spawner_Start_Call
Start is a helper method to define mock.On call
- _a0 context.Context
func (*Spawner_Expecter) StartService ¶ added in v2.15.0
func (_e *Spawner_Expecter) StartService(ctx interface{}, spec interface{}) *Spawner_StartService_Call
StartService is a helper method to define mock.On call
- ctx context.Context
- spec job.Job
type Spawner_HealthReport_Call ¶ added in v2.15.0
Spawner_HealthReport_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HealthReport'
func (*Spawner_HealthReport_Call) Return ¶ added in v2.15.0
func (_c *Spawner_HealthReport_Call) Return(_a0 map[string]error) *Spawner_HealthReport_Call
func (*Spawner_HealthReport_Call) Run ¶ added in v2.15.0
func (_c *Spawner_HealthReport_Call) Run(run func()) *Spawner_HealthReport_Call
func (*Spawner_HealthReport_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Spawner_HealthReport_Call) RunAndReturn(run func() map[string]error) *Spawner_HealthReport_Call
type Spawner_Name_Call ¶ added in v2.15.0
Spawner_Name_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Name'
func (*Spawner_Name_Call) Return ¶ added in v2.15.0
func (_c *Spawner_Name_Call) Return(_a0 string) *Spawner_Name_Call
func (*Spawner_Name_Call) Run ¶ added in v2.15.0
func (_c *Spawner_Name_Call) Run(run func()) *Spawner_Name_Call
func (*Spawner_Name_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Spawner_Name_Call) RunAndReturn(run func() string) *Spawner_Name_Call
type Spawner_Ready_Call ¶ added in v2.15.0
Spawner_Ready_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Ready'
func (*Spawner_Ready_Call) Return ¶ added in v2.15.0
func (_c *Spawner_Ready_Call) Return(_a0 error) *Spawner_Ready_Call
func (*Spawner_Ready_Call) Run ¶ added in v2.15.0
func (_c *Spawner_Ready_Call) Run(run func()) *Spawner_Ready_Call
func (*Spawner_Ready_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Spawner_Ready_Call) RunAndReturn(run func() error) *Spawner_Ready_Call
type Spawner_StartService_Call ¶ added in v2.15.0
Spawner_StartService_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StartService'
func (*Spawner_StartService_Call) Return ¶ added in v2.15.0
func (_c *Spawner_StartService_Call) Return(_a0 error) *Spawner_StartService_Call
func (*Spawner_StartService_Call) Run ¶ added in v2.15.0
func (_c *Spawner_StartService_Call) Run(run func(ctx context.Context, spec job.Job)) *Spawner_StartService_Call
func (*Spawner_StartService_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Spawner_StartService_Call) RunAndReturn(run func(context.Context, job.Job) error) *Spawner_StartService_Call
type Spawner_Start_Call ¶ added in v2.15.0
Spawner_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'
func (*Spawner_Start_Call) Return ¶ added in v2.15.0
func (_c *Spawner_Start_Call) Return(_a0 error) *Spawner_Start_Call
func (*Spawner_Start_Call) Run ¶ added in v2.15.0
func (_c *Spawner_Start_Call) Run(run func(_a0 context.Context)) *Spawner_Start_Call
func (*Spawner_Start_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Spawner_Start_Call) RunAndReturn(run func(context.Context) error) *Spawner_Start_Call