mocks

package
v2.5.1-celo-20230921 Latest Latest
Warning

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

Go to latest
Published: Sep 21, 2023 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	mock.Mock
}

Config is an autogenerated mock type for the Config type

func NewConfig

func NewConfig(t mockConstructorTestingTNewConfig) *Config

NewConfig creates a new instance of Config. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*Config) DatabaseDefaultQueryTimeout

func (_m *Config) DatabaseDefaultQueryTimeout() time.Duration

DatabaseDefaultQueryTimeout provides a mock function with given fields:

func (*Config) DefaultHTTPTimeout

func (_m *Config) DefaultHTTPTimeout() models.Duration

DefaultHTTPTimeout provides a mock function with given fields:

func (*Config) Dev

func (_m *Config) Dev() bool

Dev provides a mock function with given fields:

func (*Config) FeatureOffchainReporting

func (_m *Config) FeatureOffchainReporting() bool

FeatureOffchainReporting provides a mock function with given fields:

func (*Config) FeatureOffchainReporting2

func (_m *Config) FeatureOffchainReporting2() bool

FeatureOffchainReporting2 provides a mock function with given fields:

func (*Config) JobPipelineMaxSuccessfulRuns

func (_m *Config) JobPipelineMaxSuccessfulRuns() uint64

JobPipelineMaxSuccessfulRuns provides a mock function with given fields:

func (*Config) JobPipelineResultWriteQueueDepth

func (_m *Config) JobPipelineResultWriteQueueDepth() uint64

JobPipelineResultWriteQueueDepth provides a mock function with given fields:

func (*Config) LogSQL

func (_m *Config) LogSQL() bool

LogSQL provides a mock function with given fields:

func (*Config) OCR2BlockchainTimeout

func (_m *Config) OCR2BlockchainTimeout() time.Duration

OCR2BlockchainTimeout provides a mock function with given fields:

func (*Config) OCR2CaptureEATelemetry

func (_m *Config) OCR2CaptureEATelemetry() bool

OCR2CaptureEATelemetry provides a mock function with given fields:

func (*Config) OCR2ContractConfirmations

func (_m *Config) OCR2ContractConfirmations() uint16

OCR2ContractConfirmations provides a mock function with given fields:

func (*Config) OCR2ContractPollInterval

func (_m *Config) OCR2ContractPollInterval() time.Duration

OCR2ContractPollInterval provides a mock function with given fields:

func (*Config) OCR2ContractSubscribeInterval

func (_m *Config) OCR2ContractSubscribeInterval() time.Duration

OCR2ContractSubscribeInterval provides a mock function with given fields:

func (*Config) OCR2ContractTransmitterTransmitTimeout

func (_m *Config) OCR2ContractTransmitterTransmitTimeout() time.Duration

OCR2ContractTransmitterTransmitTimeout provides a mock function with given fields:

func (*Config) OCR2DatabaseTimeout

func (_m *Config) OCR2DatabaseTimeout() time.Duration

OCR2DatabaseTimeout provides a mock function with given fields:

func (*Config) OCR2KeyBundleID

func (_m *Config) OCR2KeyBundleID() (string, error)

OCR2KeyBundleID provides a mock function with given fields:

func (*Config) OCR2TraceLogging

func (_m *Config) OCR2TraceLogging() bool

OCR2TraceLogging provides a mock function with given fields:

func (*Config) OCRDevelopmentMode added in v2.1.0

func (_m *Config) OCRDevelopmentMode() bool

OCRDevelopmentMode provides a mock function with given fields:

type ConnectionsManager

type ConnectionsManager struct {
	mock.Mock
}

ConnectionsManager is an autogenerated mock type for the ConnectionsManager type

func NewConnectionsManager

func NewConnectionsManager(t mockConstructorTestingTNewConnectionsManager) *ConnectionsManager

NewConnectionsManager creates a new instance of ConnectionsManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*ConnectionsManager) Close

func (_m *ConnectionsManager) Close()

Close provides a mock function with given fields:

func (*ConnectionsManager) Connect

func (_m *ConnectionsManager) Connect(opts feeds.ConnectOpts)

Connect provides a mock function with given fields: opts

func (*ConnectionsManager) Disconnect

func (_m *ConnectionsManager) Disconnect(id int64) error

Disconnect provides a mock function with given fields: id

func (*ConnectionsManager) GetClient

func (_m *ConnectionsManager) GetClient(id int64) (proto.FeedsManagerClient, error)

GetClient provides a mock function with given fields: id

func (*ConnectionsManager) IsConnected

func (_m *ConnectionsManager) IsConnected(id int64) bool

IsConnected provides a mock function with given fields: id

type FeedsManagerClient

type FeedsManagerClient struct {
	mock.Mock
}

FeedsManagerClient is an autogenerated mock type for the FeedsManagerClient type

func NewFeedsManagerClient

func NewFeedsManagerClient(t mockConstructorTestingTNewFeedsManagerClient) *FeedsManagerClient

NewFeedsManagerClient creates a new instance of FeedsManagerClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*FeedsManagerClient) ApprovedJob

ApprovedJob provides a mock function with given fields: ctx, in

func (*FeedsManagerClient) CancelledJob

CancelledJob provides a mock function with given fields: ctx, in

func (*FeedsManagerClient) Healthcheck

Healthcheck provides a mock function with given fields: ctx, in

func (*FeedsManagerClient) RejectedJob

RejectedJob provides a mock function with given fields: ctx, in

func (*FeedsManagerClient) UpdateNode

UpdateNode provides a mock function with given fields: ctx, in

type ORM

type ORM struct {
	mock.Mock
}

ORM is an autogenerated mock type for the ORM type

func NewORM

func NewORM(t mockConstructorTestingTNewORM) *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.

func (*ORM) ApproveSpec

func (_m *ORM) ApproveSpec(id int64, externalJobID uuid.UUID, qopts ...pg.QOpt) error

ApproveSpec provides a mock function with given fields: id, externalJobID, qopts

func (*ORM) CancelSpec

func (_m *ORM) CancelSpec(id int64, qopts ...pg.QOpt) error

CancelSpec provides a mock function with given fields: id, qopts

func (*ORM) CountJobProposals

func (_m *ORM) CountJobProposals() (int64, error)

CountJobProposals provides a mock function with given fields:

func (*ORM) CountJobProposalsByStatus

func (_m *ORM) CountJobProposalsByStatus() (*feeds.JobProposalCounts, error)

CountJobProposalsByStatus provides a mock function with given fields:

func (*ORM) CountManagers

func (_m *ORM) CountManagers() (int64, error)

CountManagers provides a mock function with given fields:

func (*ORM) CreateBatchChainConfig

func (_m *ORM) CreateBatchChainConfig(cfgs []feeds.ChainConfig, qopts ...pg.QOpt) ([]int64, error)

CreateBatchChainConfig provides a mock function with given fields: cfgs, qopts

func (*ORM) CreateChainConfig

func (_m *ORM) CreateChainConfig(cfg feeds.ChainConfig, qopts ...pg.QOpt) (int64, error)

CreateChainConfig provides a mock function with given fields: cfg, qopts

func (*ORM) CreateJobProposal

func (_m *ORM) CreateJobProposal(jp *feeds.JobProposal) (int64, error)

CreateJobProposal provides a mock function with given fields: jp

func (*ORM) CreateManager

func (_m *ORM) CreateManager(ms *feeds.FeedsManager, qopts ...pg.QOpt) (int64, error)

CreateManager provides a mock function with given fields: ms, qopts

func (*ORM) CreateSpec

func (_m *ORM) CreateSpec(spec feeds.JobProposalSpec, qopts ...pg.QOpt) (int64, error)

CreateSpec provides a mock function with given fields: spec, qopts

func (*ORM) DeleteChainConfig

func (_m *ORM) DeleteChainConfig(id int64) (int64, error)

DeleteChainConfig provides a mock function with given fields: id

func (*ORM) DeleteProposal

func (_m *ORM) DeleteProposal(id int64, qopts ...pg.QOpt) error

DeleteProposal provides a mock function with given fields: id, qopts

func (*ORM) EXPECT

func (_m *ORM) EXPECT() *ORM_Expecter

func (*ORM) ExistsSpecByJobProposalIDAndVersion

func (_m *ORM) ExistsSpecByJobProposalIDAndVersion(jpID int64, version int32, qopts ...pg.QOpt) (bool, error)

ExistsSpecByJobProposalIDAndVersion provides a mock function with given fields: jpID, version, qopts

func (*ORM) GetApprovedSpec

func (_m *ORM) GetApprovedSpec(jpID int64, qopts ...pg.QOpt) (*feeds.JobProposalSpec, error)

GetApprovedSpec provides a mock function with given fields: jpID, qopts

func (*ORM) GetChainConfig

func (_m *ORM) GetChainConfig(id int64) (*feeds.ChainConfig, error)

GetChainConfig provides a mock function with given fields: id

func (*ORM) GetJobProposal

func (_m *ORM) GetJobProposal(id int64, qopts ...pg.QOpt) (*feeds.JobProposal, error)

GetJobProposal provides a mock function with given fields: id, qopts

func (*ORM) GetJobProposalByRemoteUUID

func (_m *ORM) GetJobProposalByRemoteUUID(_a0 uuid.UUID) (*feeds.JobProposal, error)

GetJobProposalByRemoteUUID provides a mock function with given fields: _a0

func (*ORM) GetLatestSpec

func (_m *ORM) GetLatestSpec(jpID int64) (*feeds.JobProposalSpec, error)

GetLatestSpec provides a mock function with given fields: jpID

func (*ORM) GetManager

func (_m *ORM) GetManager(id int64) (*feeds.FeedsManager, error)

GetManager provides a mock function with given fields: id

func (*ORM) GetSpec

func (_m *ORM) GetSpec(id int64, qopts ...pg.QOpt) (*feeds.JobProposalSpec, error)

GetSpec provides a mock function with given fields: id, qopts

func (*ORM) IsJobManaged

func (_m *ORM) IsJobManaged(jobID int64, qopts ...pg.QOpt) (bool, error)

IsJobManaged provides a mock function with given fields: jobID, qopts

func (*ORM) ListChainConfigsByManagerIDs

func (_m *ORM) ListChainConfigsByManagerIDs(mgrIDs []int64) ([]feeds.ChainConfig, error)

ListChainConfigsByManagerIDs provides a mock function with given fields: mgrIDs

func (*ORM) ListJobProposals

func (_m *ORM) ListJobProposals() ([]feeds.JobProposal, error)

ListJobProposals provides a mock function with given fields:

func (*ORM) ListJobProposalsByManagersIDs

func (_m *ORM) ListJobProposalsByManagersIDs(ids []int64, qopts ...pg.QOpt) ([]feeds.JobProposal, error)

ListJobProposalsByManagersIDs provides a mock function with given fields: ids, qopts

func (*ORM) ListManagers

func (_m *ORM) ListManagers() ([]feeds.FeedsManager, error)

ListManagers provides a mock function with given fields:

func (*ORM) ListManagersByIDs

func (_m *ORM) ListManagersByIDs(ids []int64) ([]feeds.FeedsManager, error)

ListManagersByIDs provides a mock function with given fields: ids

func (*ORM) ListSpecsByJobProposalIDs

func (_m *ORM) ListSpecsByJobProposalIDs(ids []int64, qopts ...pg.QOpt) ([]feeds.JobProposalSpec, error)

ListSpecsByJobProposalIDs provides a mock function with given fields: ids, qopts

func (*ORM) RejectSpec

func (_m *ORM) RejectSpec(id int64, qopts ...pg.QOpt) error

RejectSpec provides a mock function with given fields: id, qopts

func (*ORM) RevokeSpec

func (_m *ORM) RevokeSpec(id int64, qopts ...pg.QOpt) error

RevokeSpec provides a mock function with given fields: id, qopts

func (*ORM) UpdateChainConfig

func (_m *ORM) UpdateChainConfig(cfg feeds.ChainConfig) (int64, error)

UpdateChainConfig provides a mock function with given fields: cfg

func (*ORM) UpdateJobProposalStatus

func (_m *ORM) UpdateJobProposalStatus(id int64, status feeds.JobProposalStatus, qopts ...pg.QOpt) error

UpdateJobProposalStatus provides a mock function with given fields: id, status, qopts

func (*ORM) UpdateManager

func (_m *ORM) UpdateManager(mgr feeds.FeedsManager, qopts ...pg.QOpt) error

UpdateManager provides a mock function with given fields: mgr, qopts

func (*ORM) UpdateSpecDefinition

func (_m *ORM) UpdateSpecDefinition(id int64, spec string, qopts ...pg.QOpt) error

UpdateSpecDefinition provides a mock function with given fields: id, spec, qopts

func (*ORM) UpsertJobProposal

func (_m *ORM) UpsertJobProposal(jp *feeds.JobProposal, qopts ...pg.QOpt) (int64, error)

UpsertJobProposal provides a mock function with given fields: jp, qopts

type ORM_ApproveSpec_Call

type ORM_ApproveSpec_Call struct {
	*mock.Call
}

ORM_ApproveSpec_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ApproveSpec'

func (*ORM_ApproveSpec_Call) Return

func (*ORM_ApproveSpec_Call) Run

func (_c *ORM_ApproveSpec_Call) Run(run func(id int64, externalJobID uuid.UUID, qopts ...pg.QOpt)) *ORM_ApproveSpec_Call

func (*ORM_ApproveSpec_Call) RunAndReturn

func (_c *ORM_ApproveSpec_Call) RunAndReturn(run func(int64, uuid.UUID, ...pg.QOpt) error) *ORM_ApproveSpec_Call

type ORM_CancelSpec_Call

type ORM_CancelSpec_Call struct {
	*mock.Call
}

ORM_CancelSpec_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CancelSpec'

func (*ORM_CancelSpec_Call) Return

func (*ORM_CancelSpec_Call) Run

func (_c *ORM_CancelSpec_Call) Run(run func(id int64, qopts ...pg.QOpt)) *ORM_CancelSpec_Call

func (*ORM_CancelSpec_Call) RunAndReturn

func (_c *ORM_CancelSpec_Call) RunAndReturn(run func(int64, ...pg.QOpt) error) *ORM_CancelSpec_Call

type ORM_CountJobProposalsByStatus_Call

type ORM_CountJobProposalsByStatus_Call struct {
	*mock.Call
}

ORM_CountJobProposalsByStatus_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CountJobProposalsByStatus'

func (*ORM_CountJobProposalsByStatus_Call) Return

func (*ORM_CountJobProposalsByStatus_Call) Run

func (*ORM_CountJobProposalsByStatus_Call) RunAndReturn

type ORM_CountJobProposals_Call

type ORM_CountJobProposals_Call struct {
	*mock.Call
}

ORM_CountJobProposals_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CountJobProposals'

func (*ORM_CountJobProposals_Call) Return

func (*ORM_CountJobProposals_Call) Run

func (*ORM_CountJobProposals_Call) RunAndReturn

func (_c *ORM_CountJobProposals_Call) RunAndReturn(run func() (int64, error)) *ORM_CountJobProposals_Call

type ORM_CountManagers_Call

type ORM_CountManagers_Call struct {
	*mock.Call
}

ORM_CountManagers_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CountManagers'

func (*ORM_CountManagers_Call) Return

func (*ORM_CountManagers_Call) Run

func (_c *ORM_CountManagers_Call) Run(run func()) *ORM_CountManagers_Call

func (*ORM_CountManagers_Call) RunAndReturn

func (_c *ORM_CountManagers_Call) RunAndReturn(run func() (int64, error)) *ORM_CountManagers_Call

type ORM_CreateBatchChainConfig_Call

type ORM_CreateBatchChainConfig_Call struct {
	*mock.Call
}

ORM_CreateBatchChainConfig_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateBatchChainConfig'

func (*ORM_CreateBatchChainConfig_Call) Return

func (*ORM_CreateBatchChainConfig_Call) Run

func (*ORM_CreateBatchChainConfig_Call) RunAndReturn

type ORM_CreateChainConfig_Call

type ORM_CreateChainConfig_Call struct {
	*mock.Call
}

ORM_CreateChainConfig_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateChainConfig'

func (*ORM_CreateChainConfig_Call) Return

func (*ORM_CreateChainConfig_Call) Run

func (*ORM_CreateChainConfig_Call) RunAndReturn

type ORM_CreateJobProposal_Call

type ORM_CreateJobProposal_Call struct {
	*mock.Call
}

ORM_CreateJobProposal_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateJobProposal'

func (*ORM_CreateJobProposal_Call) Return

func (*ORM_CreateJobProposal_Call) Run

func (*ORM_CreateJobProposal_Call) RunAndReturn

type ORM_CreateManager_Call

type ORM_CreateManager_Call struct {
	*mock.Call
}

ORM_CreateManager_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateManager'

func (*ORM_CreateManager_Call) Return

func (*ORM_CreateManager_Call) Run

func (_c *ORM_CreateManager_Call) Run(run func(ms *feeds.FeedsManager, qopts ...pg.QOpt)) *ORM_CreateManager_Call

func (*ORM_CreateManager_Call) RunAndReturn

func (_c *ORM_CreateManager_Call) RunAndReturn(run func(*feeds.FeedsManager, ...pg.QOpt) (int64, error)) *ORM_CreateManager_Call

type ORM_CreateSpec_Call

type ORM_CreateSpec_Call struct {
	*mock.Call
}

ORM_CreateSpec_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateSpec'

func (*ORM_CreateSpec_Call) Return

func (_c *ORM_CreateSpec_Call) Return(_a0 int64, _a1 error) *ORM_CreateSpec_Call

func (*ORM_CreateSpec_Call) Run

func (_c *ORM_CreateSpec_Call) Run(run func(spec feeds.JobProposalSpec, qopts ...pg.QOpt)) *ORM_CreateSpec_Call

func (*ORM_CreateSpec_Call) RunAndReturn

func (_c *ORM_CreateSpec_Call) RunAndReturn(run func(feeds.JobProposalSpec, ...pg.QOpt) (int64, error)) *ORM_CreateSpec_Call

type ORM_DeleteChainConfig_Call

type ORM_DeleteChainConfig_Call struct {
	*mock.Call
}

ORM_DeleteChainConfig_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteChainConfig'

func (*ORM_DeleteChainConfig_Call) Return

func (*ORM_DeleteChainConfig_Call) Run

func (*ORM_DeleteChainConfig_Call) RunAndReturn

func (_c *ORM_DeleteChainConfig_Call) RunAndReturn(run func(int64) (int64, error)) *ORM_DeleteChainConfig_Call

type ORM_DeleteProposal_Call

type ORM_DeleteProposal_Call struct {
	*mock.Call
}

ORM_DeleteProposal_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteProposal'

func (*ORM_DeleteProposal_Call) Return

func (*ORM_DeleteProposal_Call) Run

func (_c *ORM_DeleteProposal_Call) Run(run func(id int64, qopts ...pg.QOpt)) *ORM_DeleteProposal_Call

func (*ORM_DeleteProposal_Call) RunAndReturn

func (_c *ORM_DeleteProposal_Call) RunAndReturn(run func(int64, ...pg.QOpt) error) *ORM_DeleteProposal_Call

type ORM_ExistsSpecByJobProposalIDAndVersion_Call

type ORM_ExistsSpecByJobProposalIDAndVersion_Call struct {
	*mock.Call
}

ORM_ExistsSpecByJobProposalIDAndVersion_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ExistsSpecByJobProposalIDAndVersion'

func (*ORM_ExistsSpecByJobProposalIDAndVersion_Call) Return

func (*ORM_ExistsSpecByJobProposalIDAndVersion_Call) Run

func (*ORM_ExistsSpecByJobProposalIDAndVersion_Call) RunAndReturn

type ORM_Expecter

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

func (*ORM_Expecter) ApproveSpec

func (_e *ORM_Expecter) ApproveSpec(id interface{}, externalJobID interface{}, qopts ...interface{}) *ORM_ApproveSpec_Call

ApproveSpec is a helper method to define mock.On call

  • id int64
  • externalJobID uuid.UUID
  • qopts ...pg.QOpt

func (*ORM_Expecter) CancelSpec

func (_e *ORM_Expecter) CancelSpec(id interface{}, qopts ...interface{}) *ORM_CancelSpec_Call

CancelSpec is a helper method to define mock.On call

  • id int64
  • qopts ...pg.QOpt

func (*ORM_Expecter) CountJobProposals

func (_e *ORM_Expecter) CountJobProposals() *ORM_CountJobProposals_Call

CountJobProposals is a helper method to define mock.On call

func (*ORM_Expecter) CountJobProposalsByStatus

func (_e *ORM_Expecter) CountJobProposalsByStatus() *ORM_CountJobProposalsByStatus_Call

CountJobProposalsByStatus is a helper method to define mock.On call

func (*ORM_Expecter) CountManagers

func (_e *ORM_Expecter) CountManagers() *ORM_CountManagers_Call

CountManagers is a helper method to define mock.On call

func (*ORM_Expecter) CreateBatchChainConfig

func (_e *ORM_Expecter) CreateBatchChainConfig(cfgs interface{}, qopts ...interface{}) *ORM_CreateBatchChainConfig_Call

CreateBatchChainConfig is a helper method to define mock.On call

  • cfgs []feeds.ChainConfig
  • qopts ...pg.QOpt

func (*ORM_Expecter) CreateChainConfig

func (_e *ORM_Expecter) CreateChainConfig(cfg interface{}, qopts ...interface{}) *ORM_CreateChainConfig_Call

CreateChainConfig is a helper method to define mock.On call

  • cfg feeds.ChainConfig
  • qopts ...pg.QOpt

func (*ORM_Expecter) CreateJobProposal

func (_e *ORM_Expecter) CreateJobProposal(jp interface{}) *ORM_CreateJobProposal_Call

CreateJobProposal is a helper method to define mock.On call

  • jp *feeds.JobProposal

func (*ORM_Expecter) CreateManager

func (_e *ORM_Expecter) CreateManager(ms interface{}, qopts ...interface{}) *ORM_CreateManager_Call

CreateManager is a helper method to define mock.On call

  • ms *feeds.FeedsManager
  • qopts ...pg.QOpt

func (*ORM_Expecter) CreateSpec

func (_e *ORM_Expecter) CreateSpec(spec interface{}, qopts ...interface{}) *ORM_CreateSpec_Call

CreateSpec is a helper method to define mock.On call

  • spec feeds.JobProposalSpec
  • qopts ...pg.QOpt

func (*ORM_Expecter) DeleteChainConfig

func (_e *ORM_Expecter) DeleteChainConfig(id interface{}) *ORM_DeleteChainConfig_Call

DeleteChainConfig is a helper method to define mock.On call

  • id int64

func (*ORM_Expecter) DeleteProposal

func (_e *ORM_Expecter) DeleteProposal(id interface{}, qopts ...interface{}) *ORM_DeleteProposal_Call

DeleteProposal is a helper method to define mock.On call

  • id int64
  • qopts ...pg.QOpt

func (*ORM_Expecter) ExistsSpecByJobProposalIDAndVersion

func (_e *ORM_Expecter) ExistsSpecByJobProposalIDAndVersion(jpID interface{}, version interface{}, qopts ...interface{}) *ORM_ExistsSpecByJobProposalIDAndVersion_Call

ExistsSpecByJobProposalIDAndVersion is a helper method to define mock.On call

  • jpID int64
  • version int32
  • qopts ...pg.QOpt

func (*ORM_Expecter) GetApprovedSpec

func (_e *ORM_Expecter) GetApprovedSpec(jpID interface{}, qopts ...interface{}) *ORM_GetApprovedSpec_Call

GetApprovedSpec is a helper method to define mock.On call

  • jpID int64
  • qopts ...pg.QOpt

func (*ORM_Expecter) GetChainConfig

func (_e *ORM_Expecter) GetChainConfig(id interface{}) *ORM_GetChainConfig_Call

GetChainConfig is a helper method to define mock.On call

  • id int64

func (*ORM_Expecter) GetJobProposal

func (_e *ORM_Expecter) GetJobProposal(id interface{}, qopts ...interface{}) *ORM_GetJobProposal_Call

GetJobProposal is a helper method to define mock.On call

  • id int64
  • qopts ...pg.QOpt

func (*ORM_Expecter) GetJobProposalByRemoteUUID

func (_e *ORM_Expecter) GetJobProposalByRemoteUUID(_a0 interface{}) *ORM_GetJobProposalByRemoteUUID_Call

GetJobProposalByRemoteUUID is a helper method to define mock.On call

  • _a0 uuid.UUID

func (*ORM_Expecter) GetLatestSpec

func (_e *ORM_Expecter) GetLatestSpec(jpID interface{}) *ORM_GetLatestSpec_Call

GetLatestSpec is a helper method to define mock.On call

  • jpID int64

func (*ORM_Expecter) GetManager

func (_e *ORM_Expecter) GetManager(id interface{}) *ORM_GetManager_Call

GetManager is a helper method to define mock.On call

  • id int64

func (*ORM_Expecter) GetSpec

func (_e *ORM_Expecter) GetSpec(id interface{}, qopts ...interface{}) *ORM_GetSpec_Call

GetSpec is a helper method to define mock.On call

  • id int64
  • qopts ...pg.QOpt

func (*ORM_Expecter) IsJobManaged

func (_e *ORM_Expecter) IsJobManaged(jobID interface{}, qopts ...interface{}) *ORM_IsJobManaged_Call

IsJobManaged is a helper method to define mock.On call

  • jobID int64
  • qopts ...pg.QOpt

func (*ORM_Expecter) ListChainConfigsByManagerIDs

func (_e *ORM_Expecter) ListChainConfigsByManagerIDs(mgrIDs interface{}) *ORM_ListChainConfigsByManagerIDs_Call

ListChainConfigsByManagerIDs is a helper method to define mock.On call

  • mgrIDs []int64

func (*ORM_Expecter) ListJobProposals

func (_e *ORM_Expecter) ListJobProposals() *ORM_ListJobProposals_Call

ListJobProposals is a helper method to define mock.On call

func (*ORM_Expecter) ListJobProposalsByManagersIDs

func (_e *ORM_Expecter) ListJobProposalsByManagersIDs(ids interface{}, qopts ...interface{}) *ORM_ListJobProposalsByManagersIDs_Call

ListJobProposalsByManagersIDs is a helper method to define mock.On call

  • ids []int64
  • qopts ...pg.QOpt

func (*ORM_Expecter) ListManagers

func (_e *ORM_Expecter) ListManagers() *ORM_ListManagers_Call

ListManagers is a helper method to define mock.On call

func (*ORM_Expecter) ListManagersByIDs

func (_e *ORM_Expecter) ListManagersByIDs(ids interface{}) *ORM_ListManagersByIDs_Call

ListManagersByIDs is a helper method to define mock.On call

  • ids []int64

func (*ORM_Expecter) ListSpecsByJobProposalIDs

func (_e *ORM_Expecter) ListSpecsByJobProposalIDs(ids interface{}, qopts ...interface{}) *ORM_ListSpecsByJobProposalIDs_Call

ListSpecsByJobProposalIDs is a helper method to define mock.On call

  • ids []int64
  • qopts ...pg.QOpt

func (*ORM_Expecter) RejectSpec

func (_e *ORM_Expecter) RejectSpec(id interface{}, qopts ...interface{}) *ORM_RejectSpec_Call

RejectSpec is a helper method to define mock.On call

  • id int64
  • qopts ...pg.QOpt

func (*ORM_Expecter) RevokeSpec

func (_e *ORM_Expecter) RevokeSpec(id interface{}, qopts ...interface{}) *ORM_RevokeSpec_Call

RevokeSpec is a helper method to define mock.On call

  • id int64
  • qopts ...pg.QOpt

func (*ORM_Expecter) UpdateChainConfig

func (_e *ORM_Expecter) UpdateChainConfig(cfg interface{}) *ORM_UpdateChainConfig_Call

UpdateChainConfig is a helper method to define mock.On call

  • cfg feeds.ChainConfig

func (*ORM_Expecter) UpdateJobProposalStatus

func (_e *ORM_Expecter) UpdateJobProposalStatus(id interface{}, status interface{}, qopts ...interface{}) *ORM_UpdateJobProposalStatus_Call

UpdateJobProposalStatus is a helper method to define mock.On call

  • id int64
  • status feeds.JobProposalStatus
  • qopts ...pg.QOpt

func (*ORM_Expecter) UpdateManager

func (_e *ORM_Expecter) UpdateManager(mgr interface{}, qopts ...interface{}) *ORM_UpdateManager_Call

UpdateManager is a helper method to define mock.On call

  • mgr feeds.FeedsManager
  • qopts ...pg.QOpt

func (*ORM_Expecter) UpdateSpecDefinition

func (_e *ORM_Expecter) UpdateSpecDefinition(id interface{}, spec interface{}, qopts ...interface{}) *ORM_UpdateSpecDefinition_Call

UpdateSpecDefinition is a helper method to define mock.On call

  • id int64
  • spec string
  • qopts ...pg.QOpt

func (*ORM_Expecter) UpsertJobProposal

func (_e *ORM_Expecter) UpsertJobProposal(jp interface{}, qopts ...interface{}) *ORM_UpsertJobProposal_Call

UpsertJobProposal is a helper method to define mock.On call

  • jp *feeds.JobProposal
  • qopts ...pg.QOpt

type ORM_GetApprovedSpec_Call

type ORM_GetApprovedSpec_Call struct {
	*mock.Call
}

ORM_GetApprovedSpec_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetApprovedSpec'

func (*ORM_GetApprovedSpec_Call) Return

func (*ORM_GetApprovedSpec_Call) Run

func (_c *ORM_GetApprovedSpec_Call) Run(run func(jpID int64, qopts ...pg.QOpt)) *ORM_GetApprovedSpec_Call

func (*ORM_GetApprovedSpec_Call) RunAndReturn

type ORM_GetChainConfig_Call

type ORM_GetChainConfig_Call struct {
	*mock.Call
}

ORM_GetChainConfig_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetChainConfig'

func (*ORM_GetChainConfig_Call) Return

func (*ORM_GetChainConfig_Call) Run

func (_c *ORM_GetChainConfig_Call) Run(run func(id int64)) *ORM_GetChainConfig_Call

func (*ORM_GetChainConfig_Call) RunAndReturn

type ORM_GetJobProposalByRemoteUUID_Call

type ORM_GetJobProposalByRemoteUUID_Call struct {
	*mock.Call
}

ORM_GetJobProposalByRemoteUUID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetJobProposalByRemoteUUID'

func (*ORM_GetJobProposalByRemoteUUID_Call) Return

func (*ORM_GetJobProposalByRemoteUUID_Call) Run

func (*ORM_GetJobProposalByRemoteUUID_Call) RunAndReturn

type ORM_GetJobProposal_Call

type ORM_GetJobProposal_Call struct {
	*mock.Call
}

ORM_GetJobProposal_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetJobProposal'

func (*ORM_GetJobProposal_Call) Return

func (*ORM_GetJobProposal_Call) Run

func (_c *ORM_GetJobProposal_Call) Run(run func(id int64, qopts ...pg.QOpt)) *ORM_GetJobProposal_Call

func (*ORM_GetJobProposal_Call) RunAndReturn

func (_c *ORM_GetJobProposal_Call) RunAndReturn(run func(int64, ...pg.QOpt) (*feeds.JobProposal, error)) *ORM_GetJobProposal_Call

type ORM_GetLatestSpec_Call

type ORM_GetLatestSpec_Call struct {
	*mock.Call
}

ORM_GetLatestSpec_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLatestSpec'

func (*ORM_GetLatestSpec_Call) Return

func (*ORM_GetLatestSpec_Call) Run

func (_c *ORM_GetLatestSpec_Call) Run(run func(jpID int64)) *ORM_GetLatestSpec_Call

func (*ORM_GetLatestSpec_Call) RunAndReturn

type ORM_GetManager_Call

type ORM_GetManager_Call struct {
	*mock.Call
}

ORM_GetManager_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetManager'

func (*ORM_GetManager_Call) Return

func (*ORM_GetManager_Call) Run

func (_c *ORM_GetManager_Call) Run(run func(id int64)) *ORM_GetManager_Call

func (*ORM_GetManager_Call) RunAndReturn

func (_c *ORM_GetManager_Call) RunAndReturn(run func(int64) (*feeds.FeedsManager, error)) *ORM_GetManager_Call

type ORM_GetSpec_Call

type ORM_GetSpec_Call struct {
	*mock.Call
}

ORM_GetSpec_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetSpec'

func (*ORM_GetSpec_Call) Return

func (*ORM_GetSpec_Call) Run

func (_c *ORM_GetSpec_Call) Run(run func(id int64, qopts ...pg.QOpt)) *ORM_GetSpec_Call

func (*ORM_GetSpec_Call) RunAndReturn

func (_c *ORM_GetSpec_Call) RunAndReturn(run func(int64, ...pg.QOpt) (*feeds.JobProposalSpec, error)) *ORM_GetSpec_Call

type ORM_IsJobManaged_Call

type ORM_IsJobManaged_Call struct {
	*mock.Call
}

ORM_IsJobManaged_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsJobManaged'

func (*ORM_IsJobManaged_Call) Return

func (_c *ORM_IsJobManaged_Call) Return(_a0 bool, _a1 error) *ORM_IsJobManaged_Call

func (*ORM_IsJobManaged_Call) Run

func (_c *ORM_IsJobManaged_Call) Run(run func(jobID int64, qopts ...pg.QOpt)) *ORM_IsJobManaged_Call

func (*ORM_IsJobManaged_Call) RunAndReturn

func (_c *ORM_IsJobManaged_Call) RunAndReturn(run func(int64, ...pg.QOpt) (bool, error)) *ORM_IsJobManaged_Call

type ORM_ListChainConfigsByManagerIDs_Call

type ORM_ListChainConfigsByManagerIDs_Call struct {
	*mock.Call
}

ORM_ListChainConfigsByManagerIDs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListChainConfigsByManagerIDs'

func (*ORM_ListChainConfigsByManagerIDs_Call) Return

func (*ORM_ListChainConfigsByManagerIDs_Call) Run

func (*ORM_ListChainConfigsByManagerIDs_Call) RunAndReturn

type ORM_ListJobProposalsByManagersIDs_Call

type ORM_ListJobProposalsByManagersIDs_Call struct {
	*mock.Call
}

ORM_ListJobProposalsByManagersIDs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListJobProposalsByManagersIDs'

func (*ORM_ListJobProposalsByManagersIDs_Call) Return

func (*ORM_ListJobProposalsByManagersIDs_Call) Run

func (*ORM_ListJobProposalsByManagersIDs_Call) RunAndReturn

type ORM_ListJobProposals_Call

type ORM_ListJobProposals_Call struct {
	*mock.Call
}

ORM_ListJobProposals_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListJobProposals'

func (*ORM_ListJobProposals_Call) Return

func (*ORM_ListJobProposals_Call) Run

func (*ORM_ListJobProposals_Call) RunAndReturn

func (_c *ORM_ListJobProposals_Call) RunAndReturn(run func() ([]feeds.JobProposal, error)) *ORM_ListJobProposals_Call

type ORM_ListManagersByIDs_Call

type ORM_ListManagersByIDs_Call struct {
	*mock.Call
}

ORM_ListManagersByIDs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListManagersByIDs'

func (*ORM_ListManagersByIDs_Call) Return

func (*ORM_ListManagersByIDs_Call) Run

func (*ORM_ListManagersByIDs_Call) RunAndReturn

type ORM_ListManagers_Call

type ORM_ListManagers_Call struct {
	*mock.Call
}

ORM_ListManagers_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListManagers'

func (*ORM_ListManagers_Call) Return

func (*ORM_ListManagers_Call) Run

func (_c *ORM_ListManagers_Call) Run(run func()) *ORM_ListManagers_Call

func (*ORM_ListManagers_Call) RunAndReturn

func (_c *ORM_ListManagers_Call) RunAndReturn(run func() ([]feeds.FeedsManager, error)) *ORM_ListManagers_Call

type ORM_ListSpecsByJobProposalIDs_Call

type ORM_ListSpecsByJobProposalIDs_Call struct {
	*mock.Call
}

ORM_ListSpecsByJobProposalIDs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListSpecsByJobProposalIDs'

func (*ORM_ListSpecsByJobProposalIDs_Call) Return

func (*ORM_ListSpecsByJobProposalIDs_Call) Run

func (*ORM_ListSpecsByJobProposalIDs_Call) RunAndReturn

type ORM_RejectSpec_Call

type ORM_RejectSpec_Call struct {
	*mock.Call
}

ORM_RejectSpec_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RejectSpec'

func (*ORM_RejectSpec_Call) Return

func (*ORM_RejectSpec_Call) Run

func (_c *ORM_RejectSpec_Call) Run(run func(id int64, qopts ...pg.QOpt)) *ORM_RejectSpec_Call

func (*ORM_RejectSpec_Call) RunAndReturn

func (_c *ORM_RejectSpec_Call) RunAndReturn(run func(int64, ...pg.QOpt) error) *ORM_RejectSpec_Call

type ORM_RevokeSpec_Call

type ORM_RevokeSpec_Call struct {
	*mock.Call
}

ORM_RevokeSpec_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RevokeSpec'

func (*ORM_RevokeSpec_Call) Return

func (*ORM_RevokeSpec_Call) Run

func (_c *ORM_RevokeSpec_Call) Run(run func(id int64, qopts ...pg.QOpt)) *ORM_RevokeSpec_Call

func (*ORM_RevokeSpec_Call) RunAndReturn

func (_c *ORM_RevokeSpec_Call) RunAndReturn(run func(int64, ...pg.QOpt) error) *ORM_RevokeSpec_Call

type ORM_UpdateChainConfig_Call

type ORM_UpdateChainConfig_Call struct {
	*mock.Call
}

ORM_UpdateChainConfig_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateChainConfig'

func (*ORM_UpdateChainConfig_Call) Return

func (*ORM_UpdateChainConfig_Call) Run

func (*ORM_UpdateChainConfig_Call) RunAndReturn

type ORM_UpdateJobProposalStatus_Call

type ORM_UpdateJobProposalStatus_Call struct {
	*mock.Call
}

ORM_UpdateJobProposalStatus_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateJobProposalStatus'

func (*ORM_UpdateJobProposalStatus_Call) Return

func (*ORM_UpdateJobProposalStatus_Call) Run

func (*ORM_UpdateJobProposalStatus_Call) RunAndReturn

type ORM_UpdateManager_Call

type ORM_UpdateManager_Call struct {
	*mock.Call
}

ORM_UpdateManager_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateManager'

func (*ORM_UpdateManager_Call) Return

func (*ORM_UpdateManager_Call) Run

func (_c *ORM_UpdateManager_Call) Run(run func(mgr feeds.FeedsManager, qopts ...pg.QOpt)) *ORM_UpdateManager_Call

func (*ORM_UpdateManager_Call) RunAndReturn

func (_c *ORM_UpdateManager_Call) RunAndReturn(run func(feeds.FeedsManager, ...pg.QOpt) error) *ORM_UpdateManager_Call

type ORM_UpdateSpecDefinition_Call

type ORM_UpdateSpecDefinition_Call struct {
	*mock.Call
}

ORM_UpdateSpecDefinition_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateSpecDefinition'

func (*ORM_UpdateSpecDefinition_Call) Return

func (*ORM_UpdateSpecDefinition_Call) Run

func (_c *ORM_UpdateSpecDefinition_Call) Run(run func(id int64, spec string, qopts ...pg.QOpt)) *ORM_UpdateSpecDefinition_Call

func (*ORM_UpdateSpecDefinition_Call) RunAndReturn

type ORM_UpsertJobProposal_Call

type ORM_UpsertJobProposal_Call struct {
	*mock.Call
}

ORM_UpsertJobProposal_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpsertJobProposal'

func (*ORM_UpsertJobProposal_Call) Return

func (*ORM_UpsertJobProposal_Call) Run

func (*ORM_UpsertJobProposal_Call) RunAndReturn

type Service

type Service struct {
	mock.Mock
}

Service is an autogenerated mock type for the Service type

func NewService

func NewService(t mockConstructorTestingTNewService) *Service

NewService creates a new instance of Service. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*Service) ApproveSpec

func (_m *Service) ApproveSpec(ctx context.Context, id int64, force bool) error

ApproveSpec provides a mock function with given fields: ctx, id, force

func (*Service) CancelSpec

func (_m *Service) CancelSpec(ctx context.Context, id int64) error

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

func (*Service) Close

func (_m *Service) Close() error

Close provides a mock function with given fields:

func (*Service) CountJobProposalsByStatus

func (_m *Service) CountJobProposalsByStatus() (*feeds.JobProposalCounts, error)

CountJobProposalsByStatus provides a mock function with given fields:

func (*Service) CountManagers

func (_m *Service) CountManagers() (int64, error)

CountManagers provides a mock function with given fields:

func (*Service) CreateChainConfig

func (_m *Service) CreateChainConfig(ctx context.Context, cfg feeds.ChainConfig) (int64, error)

CreateChainConfig provides a mock function with given fields: ctx, cfg

func (*Service) DeleteChainConfig

func (_m *Service) DeleteChainConfig(ctx context.Context, id int64) (int64, error)

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

func (*Service) DeleteJob

func (_m *Service) DeleteJob(ctx context.Context, args *feeds.DeleteJobArgs) (int64, error)

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

func (*Service) GetChainConfig

func (_m *Service) GetChainConfig(id int64) (*feeds.ChainConfig, error)

GetChainConfig provides a mock function with given fields: id

func (*Service) GetJobProposal

func (_m *Service) GetJobProposal(id int64) (*feeds.JobProposal, error)

GetJobProposal provides a mock function with given fields: id

func (*Service) GetManager

func (_m *Service) GetManager(id int64) (*feeds.FeedsManager, error)

GetManager provides a mock function with given fields: id

func (*Service) GetSpec

func (_m *Service) GetSpec(id int64) (*feeds.JobProposalSpec, error)

GetSpec provides a mock function with given fields: id

func (*Service) IsJobManaged

func (_m *Service) IsJobManaged(ctx context.Context, jobID int64) (bool, error)

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

func (*Service) ListChainConfigsByManagerIDs

func (_m *Service) ListChainConfigsByManagerIDs(mgrIDs []int64) ([]feeds.ChainConfig, error)

ListChainConfigsByManagerIDs provides a mock function with given fields: mgrIDs

func (*Service) ListJobProposals

func (_m *Service) ListJobProposals() ([]feeds.JobProposal, error)

ListJobProposals provides a mock function with given fields:

func (*Service) ListJobProposalsByManagersIDs

func (_m *Service) ListJobProposalsByManagersIDs(ids []int64) ([]feeds.JobProposal, error)

ListJobProposalsByManagersIDs provides a mock function with given fields: ids

func (*Service) ListManagers

func (_m *Service) ListManagers() ([]feeds.FeedsManager, error)

ListManagers provides a mock function with given fields:

func (*Service) ListManagersByIDs

func (_m *Service) ListManagersByIDs(ids []int64) ([]feeds.FeedsManager, error)

ListManagersByIDs provides a mock function with given fields: ids

func (*Service) ListSpecsByJobProposalIDs

func (_m *Service) ListSpecsByJobProposalIDs(ids []int64) ([]feeds.JobProposalSpec, error)

ListSpecsByJobProposalIDs provides a mock function with given fields: ids

func (*Service) ProposeJob

func (_m *Service) ProposeJob(ctx context.Context, args *feeds.ProposeJobArgs) (int64, error)

ProposeJob provides a mock function with given fields: ctx, args

func (*Service) RegisterManager

func (_m *Service) RegisterManager(ctx context.Context, params feeds.RegisterManagerParams) (int64, error)

RegisterManager provides a mock function with given fields: ctx, params

func (*Service) RejectSpec

func (_m *Service) RejectSpec(ctx context.Context, id int64) error

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

func (*Service) RevokeJob

func (_m *Service) RevokeJob(ctx context.Context, args *feeds.RevokeJobArgs) (int64, error)

RevokeJob provides a mock function with given fields: ctx, args

func (*Service) Start

func (_m *Service) Start(ctx context.Context) error

Start provides a mock function with given fields: ctx

func (*Service) SyncNodeInfo

func (_m *Service) SyncNodeInfo(ctx context.Context, id int64) error

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

func (*Service) Unsafe_SetConnectionsManager

func (_m *Service) Unsafe_SetConnectionsManager(_a0 feeds.ConnectionsManager)

Unsafe_SetConnectionsManager provides a mock function with given fields: _a0

func (*Service) UpdateChainConfig

func (_m *Service) UpdateChainConfig(ctx context.Context, cfg feeds.ChainConfig) (int64, error)

UpdateChainConfig provides a mock function with given fields: ctx, cfg

func (*Service) UpdateManager

func (_m *Service) UpdateManager(ctx context.Context, mgr feeds.FeedsManager) error

UpdateManager provides a mock function with given fields: ctx, mgr

func (*Service) UpdateSpecDefinition

func (_m *Service) UpdateSpecDefinition(ctx context.Context, id int64, spec string) error

UpdateSpecDefinition provides a mock function with given fields: ctx, id, spec

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL