mocks

package
v2.15.0 Latest Latest
Warning

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

 Go to latest Published: Aug 19, 2024 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type KVStore added in v2.10.0 

type KVStore struct {
	mock.Mock
}

KVStore is an autogenerated mock type for the KVStore type

func NewKVStore added in v2.10.0 

func NewKVStore(t interface {
	mock.TestingT
	Cleanup(func())
}) *KVStore

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

func (*KVStore) Get added in v2.10.0 

func (_m *KVStore) Get(ctx context.Context, key string) ([]byte, error)

Get provides a mock function with given fields: ctx, key

func (*KVStore) Store added in v2.10.0 

func (_m *KVStore) Store(ctx context.Context, key string, val []byte) error

Store provides a mock function with given fields: ctx, key, val

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 

type KVStore_Get_Call struct {
	*mock.Call
}

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 

type KVStore_Store_Call struct {
	*mock.Call
}

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 

type ORM struct {
	mock.Mock
}

ORM is an autogenerated mock type for the ORM type

func NewORM 

func NewORM(t interface {
	mock.TestingT
	Cleanup(func())
}) *ORM

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 

func (_m *ORM) AssertBridgesExist(ctx context.Context, p pipeline.Pipeline) error

AssertBridgesExist provides a mock function with given fields: ctx, p

func (*ORM) Close 

func (_m *ORM) Close() error

Close provides a mock function with given fields:

func (*ORM) CountPipelineRunsByJobID 

func (_m *ORM) CountPipelineRunsByJobID(ctx context.Context, jobID int32) (int32, error)

CountPipelineRunsByJobID provides a mock function with given fields: ctx, jobID

func (*ORM) CreateJob 

func (_m *ORM) CreateJob(ctx context.Context, jb *job.Job) error

CreateJob provides a mock function with given fields: ctx, jb

func (*ORM) DataSource added in v2.12.0 

func (_m *ORM) DataSource() sqlutil.DataSource

DataSource provides a mock function with given fields:

func (*ORM) DeleteJob 

func (_m *ORM) DeleteJob(ctx context.Context, id int32) error

DeleteJob provides a mock function with given fields: ctx, id

func (*ORM) DismissError 

func (_m *ORM) DismissError(ctx context.Context, errorID int64) error

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) FindJob 

func (_m *ORM) FindJob(ctx context.Context, id int32) (job.Job, error)

FindJob provides a mock function with given fields: ctx, id

func (*ORM) FindJobByExternalJobID 

func (_m *ORM) FindJobByExternalJobID(ctx context.Context, _a1 uuid.UUID) (job.Job, error)

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 

func (_m *ORM) FindJobIDByWorkflow(ctx context.Context, spec job.WorkflowSpec) (int32, error)

FindJobIDByWorkflow provides a mock function with given fields: ctx, spec

func (*ORM) FindJobIDsWithBridge 

func (_m *ORM) FindJobIDsWithBridge(ctx context.Context, name string) ([]int32, error)

FindJobIDsWithBridge provides a mock function with given fields: ctx, name

func (*ORM) FindJobTx 

func (_m *ORM) FindJobTx(ctx context.Context, id int32) (job.Job, error)

FindJobTx provides a mock function with given fields: ctx, id

func (*ORM) FindJobWithoutSpecErrors 

func (_m *ORM) FindJobWithoutSpecErrors(ctx context.Context, id int32) (job.Job, error)

FindJobWithoutSpecErrors provides a mock function with given fields: ctx, id

func (*ORM) FindJobs 

func (_m *ORM) FindJobs(ctx context.Context, offset int, limit int) ([]job.Job, int, error)

FindJobs provides a mock function with given fields: ctx, offset, limit

func (*ORM) FindJobsByPipelineSpecIDs 

func (_m *ORM) FindJobsByPipelineSpecIDs(ctx context.Context, ids []int32) ([]job.Job, error)

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 

func (_m *ORM) FindPipelineRunByID(ctx context.Context, id int64) (pipeline.Run, error)

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 

func (_m *ORM) FindPipelineRunsByIDs(ctx context.Context, ids []int64) ([]pipeline.Run, error)

FindPipelineRunsByIDs provides a mock function with given fields: ctx, ids

func (*ORM) FindSpecError 

func (_m *ORM) FindSpecError(ctx context.Context, id int64) (job.SpecError, error)

FindSpecError provides a mock function with given fields: ctx, id

func (*ORM) FindSpecErrorsByJobIDs 

func (_m *ORM) FindSpecErrorsByJobIDs(ctx context.Context, ids []int32) ([]job.SpecError, error)

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) InsertJob 

func (_m *ORM) InsertJob(ctx context.Context, _a1 *job.Job) error

InsertJob provides a mock function with given fields: ctx, _a1

func (*ORM) InsertWebhookSpec 

func (_m *ORM) InsertWebhookSpec(ctx context.Context, webhookSpec *job.WebhookSpec) error

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 

func (_m *ORM) RecordError(ctx context.Context, jobID int32, description string) error

RecordError provides a mock function with given fields: ctx, jobID, description

func (*ORM) TryRecordError 

func (_m *ORM) TryRecordError(ctx context.Context, jobID int32, description string)

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 

type ORM_AssertBridgesExist_Call struct {
	*mock.Call
}

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 

type ORM_Close_Call struct {
	*mock.Call
}

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 

type ORM_CountPipelineRunsByJobID_Call struct {
	*mock.Call
}

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 

type ORM_CreateJob_Call struct {
	*mock.Call
}

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 

type ORM_DataSource_Call struct {
	*mock.Call
}

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 

type ORM_DeleteJob_Call struct {
	*mock.Call
}

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 

type ORM_DismissError_Call struct {
	*mock.Call
}

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 

type ORM_FindJobByExternalJobID_Call struct {
	*mock.Call
}

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 

type ORM_FindJobIDByAddress_Call struct {
	*mock.Call
}

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 

type ORM_FindJobIDByWorkflow_Call struct {
	*mock.Call
}

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 

type ORM_FindJobIDsWithBridge_Call struct {
	*mock.Call
}

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 

type ORM_FindJobTx_Call struct {
	*mock.Call
}

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 

type ORM_FindJobWithoutSpecErrors_Call struct {
	*mock.Call
}

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 

type ORM_FindJob_Call struct {
	*mock.Call
}

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 

type ORM_FindJobsByPipelineSpecIDs_Call struct {
	*mock.Call
}

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 

type ORM_FindJobs_Call struct {
	*mock.Call
}

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 

type ORM_FindOCR2JobIDByAddress_Call struct {
	*mock.Call
}

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 

type ORM_FindPipelineRunByID_Call struct {
	*mock.Call
}

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 

type ORM_FindPipelineRunIDsByJobID_Call struct {
	*mock.Call
}

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 

type ORM_FindPipelineRunsByIDs_Call struct {
	*mock.Call
}

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 

type ORM_FindSpecError_Call struct {
	*mock.Call
}

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 

type ORM_FindSpecErrorsByJobIDs_Call struct {
	*mock.Call
}

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 

type ORM_FindTaskResultByRunIDAndTaskName_Call struct {
	*mock.Call
}

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 

type ORM_InsertJob_Call struct {
	*mock.Call
}

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 

type ORM_InsertWebhookSpec_Call struct {
	*mock.Call
}

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 

type ORM_PipelineRuns_Call struct {
	*mock.Call
}

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 

func (_c *ORM_PipelineRuns_Call) RunAndReturn(run func(context.Context, *int32, int, int) ([]pipeline.Run, int, error)) *ORM_PipelineRuns_Call

type ORM_RecordError_Call added in v2.15.0 

type ORM_RecordError_Call struct {
	*mock.Call
}

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 

type ORM_TryRecordError_Call struct {
	*mock.Call
}

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 

type ORM_WithDataSource_Call struct {
	*mock.Call
}

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 

type ServiceCtx struct {
	mock.Mock
}

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

func (*ServiceCtx) Start 

func (_m *ServiceCtx) Start(_a0 context.Context) error

Start provides a mock function with given fields: _a0

type ServiceCtx_Close_Call added in v2.15.0 

type ServiceCtx_Close_Call struct {
	*mock.Call
}

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 

type ServiceCtx_Start_Call struct {
	*mock.Call
}

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 

type Spawner struct {
	mock.Mock
}

Spawner is an autogenerated mock type for the Spawner type

func NewSpawner 

func NewSpawner(t interface {
	mock.TestingT
	Cleanup(func())
}) *Spawner

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 

func (_m *Spawner) ActiveJobs() map[int32]job.Job

ActiveJobs provides a mock function with given fields:

func (*Spawner) Close 

func (_m *Spawner) Close() error

Close provides a mock function with given fields:

func (*Spawner) CreateJob 

func (_m *Spawner) CreateJob(ctx context.Context, ds sqlutil.DataSource, jb *job.Job) error

CreateJob provides a mock function with given fields: ctx, ds, jb

func (*Spawner) DeleteJob 

func (_m *Spawner) DeleteJob(ctx context.Context, ds sqlutil.DataSource, jobID int32) error

DeleteJob provides a mock function with given fields: ctx, ds, jobID

func (*Spawner) EXPECT added in v2.15.0 

func (_m *Spawner) EXPECT() *Spawner_Expecter

func (*Spawner) HealthReport 

func (_m *Spawner) HealthReport() map[string]error

HealthReport provides a mock function with given fields:

func (*Spawner) Name 

func (_m *Spawner) Name() string

Name provides a mock function with given fields:

func (*Spawner) Ready 

func (_m *Spawner) Ready() error

Ready provides a mock function with given fields:

func (*Spawner) Start 

func (_m *Spawner) Start(_a0 context.Context) error

Start provides a mock function with given fields: _a0

func (*Spawner) StartService 

func (_m *Spawner) StartService(ctx context.Context, spec job.Job) error

StartService provides a mock function with given fields: ctx, spec

type Spawner_ActiveJobs_Call added in v2.15.0 

type Spawner_ActiveJobs_Call struct {
	*mock.Call
}

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 

type Spawner_Close_Call struct {
	*mock.Call
}

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 

type Spawner_CreateJob_Call struct {
	*mock.Call
}

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 

type Spawner_DeleteJob_Call struct {
	*mock.Call
}

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 

type Spawner_HealthReport_Call struct {
	*mock.Call
}

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 

type Spawner_Name_Call struct {
	*mock.Call
}

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 

type Spawner_Ready_Call struct {
	*mock.Call
}

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 

type Spawner_StartService_Call struct {
	*mock.Call
}

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 

type Spawner_Start_Call struct {
	*mock.Call
}

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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