Documentation ¶
Index ¶
- type Config
- func (_m *Config) DatabaseDefaultQueryTimeout() time.Duration
- func (_m *Config) DefaultHTTPTimeout() models.Duration
- func (_m *Config) Dev() bool
- func (_m *Config) FeatureOffchainReporting() bool
- func (_m *Config) FeatureOffchainReporting2() bool
- func (_m *Config) JobPipelineMaxSuccessfulRuns() uint64
- func (_m *Config) JobPipelineResultWriteQueueDepth() uint64
- func (_m *Config) LogSQL() bool
- func (_m *Config) OCR2BlockchainTimeout() time.Duration
- func (_m *Config) OCR2ContractConfirmations() uint16
- func (_m *Config) OCR2ContractPollInterval() time.Duration
- func (_m *Config) OCR2ContractSubscribeInterval() time.Duration
- func (_m *Config) OCR2ContractTransmitterTransmitTimeout() time.Duration
- func (_m *Config) OCR2DatabaseTimeout() time.Duration
- func (_m *Config) OCR2KeyBundleID() (string, error)
- func (_m *Config) OCR2TraceLogging() bool
- type ConnectionsManager
- type FeedsManagerClient
- func (_m *FeedsManagerClient) ApprovedJob(ctx context.Context, in *proto.ApprovedJobRequest) (*proto.ApprovedJobResponse, error)
- func (_m *FeedsManagerClient) CancelledJob(ctx context.Context, in *proto.CancelledJobRequest) (*proto.CancelledJobResponse, error)
- func (_m *FeedsManagerClient) RejectedJob(ctx context.Context, in *proto.RejectedJobRequest) (*proto.RejectedJobResponse, error)
- func (_m *FeedsManagerClient) UpdateNode(ctx context.Context, in *proto.UpdateNodeRequest) (*proto.UpdateNodeResponse, error)
- type ORM
- func (_m *ORM) ApproveSpec(id int64, externalJobID uuid.UUID, qopts ...pg.QOpt) error
- func (_m *ORM) CancelSpec(id int64, qopts ...pg.QOpt) error
- func (_m *ORM) CountJobProposals() (int64, error)
- func (_m *ORM) CountJobProposalsByStatus() (*feeds.JobProposalCounts, error)
- func (_m *ORM) CountManagers() (int64, error)
- func (_m *ORM) CreateBatchChainConfig(cfgs []feeds.ChainConfig, qopts ...pg.QOpt) ([]int64, error)
- func (_m *ORM) CreateChainConfig(cfg feeds.ChainConfig, qopts ...pg.QOpt) (int64, error)
- func (_m *ORM) CreateJobProposal(jp *feeds.JobProposal) (int64, error)
- func (_m *ORM) CreateManager(ms *feeds.FeedsManager, qopts ...pg.QOpt) (int64, error)
- func (_m *ORM) CreateSpec(spec feeds.JobProposalSpec, qopts ...pg.QOpt) (int64, error)
- func (_m *ORM) DeleteChainConfig(id int64) (int64, error)
- func (_m *ORM) EXPECT() *ORM_Expecter
- func (_m *ORM) ExistsSpecByJobProposalIDAndVersion(jpID int64, version int32, qopts ...pg.QOpt) (bool, error)
- func (_m *ORM) GetApprovedSpec(jpID int64, qopts ...pg.QOpt) (*feeds.JobProposalSpec, error)
- func (_m *ORM) GetChainConfig(id int64) (*feeds.ChainConfig, error)
- func (_m *ORM) GetJobProposal(id int64, qopts ...pg.QOpt) (*feeds.JobProposal, error)
- func (_m *ORM) GetJobProposalByRemoteUUID(_a0 uuid.UUID) (*feeds.JobProposal, error)
- func (_m *ORM) GetLatestSpec(jpID int64) (*feeds.JobProposalSpec, error)
- func (_m *ORM) GetManager(id int64) (*feeds.FeedsManager, error)
- func (_m *ORM) GetSpec(id int64, qopts ...pg.QOpt) (*feeds.JobProposalSpec, error)
- func (_m *ORM) IsJobManaged(jobID int64, qopts ...pg.QOpt) (bool, error)
- func (_m *ORM) ListChainConfigsByManagerIDs(mgrIDs []int64) ([]feeds.ChainConfig, error)
- func (_m *ORM) ListJobProposals() ([]feeds.JobProposal, error)
- func (_m *ORM) ListJobProposalsByManagersIDs(ids []int64, qopts ...pg.QOpt) ([]feeds.JobProposal, error)
- func (_m *ORM) ListManagers() ([]feeds.FeedsManager, error)
- func (_m *ORM) ListManagersByIDs(ids []int64) ([]feeds.FeedsManager, error)
- func (_m *ORM) ListSpecsByJobProposalIDs(ids []int64, qopts ...pg.QOpt) ([]feeds.JobProposalSpec, error)
- func (_m *ORM) RejectSpec(id int64, qopts ...pg.QOpt) error
- func (_m *ORM) UpdateChainConfig(cfg feeds.ChainConfig) (int64, error)
- func (_m *ORM) UpdateJobProposalStatus(id int64, status feeds.JobProposalStatus, qopts ...pg.QOpt) error
- func (_m *ORM) UpdateManager(mgr feeds.FeedsManager, qopts ...pg.QOpt) error
- func (_m *ORM) UpdateSpecDefinition(id int64, spec string, qopts ...pg.QOpt) error
- func (_m *ORM) UpsertJobProposal(jp *feeds.JobProposal, qopts ...pg.QOpt) (int64, error)
- type ORM_ApproveSpec_Call
- func (_c *ORM_ApproveSpec_Call) Return(_a0 error) *ORM_ApproveSpec_Call
- func (_c *ORM_ApproveSpec_Call) Run(run func(id int64, externalJobID uuid.UUID, qopts ...pg.QOpt)) *ORM_ApproveSpec_Call
- func (_c *ORM_ApproveSpec_Call) RunAndReturn(run func(int64, uuid.UUID, ...pg.QOpt) error) *ORM_ApproveSpec_Call
- type ORM_CancelSpec_Call
- type ORM_CountJobProposalsByStatus_Call
- func (_c *ORM_CountJobProposalsByStatus_Call) Return(counts *feeds.JobProposalCounts, err error) *ORM_CountJobProposalsByStatus_Call
- func (_c *ORM_CountJobProposalsByStatus_Call) Run(run func()) *ORM_CountJobProposalsByStatus_Call
- func (_c *ORM_CountJobProposalsByStatus_Call) RunAndReturn(run func() (*feeds.JobProposalCounts, error)) *ORM_CountJobProposalsByStatus_Call
- type ORM_CountJobProposals_Call
- type ORM_CountManagers_Call
- type ORM_CreateBatchChainConfig_Call
- func (_c *ORM_CreateBatchChainConfig_Call) Return(_a0 []int64, _a1 error) *ORM_CreateBatchChainConfig_Call
- func (_c *ORM_CreateBatchChainConfig_Call) Run(run func(cfgs []feeds.ChainConfig, qopts ...pg.QOpt)) *ORM_CreateBatchChainConfig_Call
- func (_c *ORM_CreateBatchChainConfig_Call) RunAndReturn(run func([]feeds.ChainConfig, ...pg.QOpt) ([]int64, error)) *ORM_CreateBatchChainConfig_Call
- type ORM_CreateChainConfig_Call
- func (_c *ORM_CreateChainConfig_Call) Return(_a0 int64, _a1 error) *ORM_CreateChainConfig_Call
- func (_c *ORM_CreateChainConfig_Call) Run(run func(cfg feeds.ChainConfig, qopts ...pg.QOpt)) *ORM_CreateChainConfig_Call
- func (_c *ORM_CreateChainConfig_Call) RunAndReturn(run func(feeds.ChainConfig, ...pg.QOpt) (int64, error)) *ORM_CreateChainConfig_Call
- type ORM_CreateJobProposal_Call
- func (_c *ORM_CreateJobProposal_Call) Return(_a0 int64, _a1 error) *ORM_CreateJobProposal_Call
- func (_c *ORM_CreateJobProposal_Call) Run(run func(jp *feeds.JobProposal)) *ORM_CreateJobProposal_Call
- func (_c *ORM_CreateJobProposal_Call) RunAndReturn(run func(*feeds.JobProposal) (int64, error)) *ORM_CreateJobProposal_Call
- type ORM_CreateManager_Call
- func (_c *ORM_CreateManager_Call) Return(_a0 int64, _a1 error) *ORM_CreateManager_Call
- func (_c *ORM_CreateManager_Call) Run(run func(ms *feeds.FeedsManager, qopts ...pg.QOpt)) *ORM_CreateManager_Call
- func (_c *ORM_CreateManager_Call) RunAndReturn(run func(*feeds.FeedsManager, ...pg.QOpt) (int64, error)) *ORM_CreateManager_Call
- type ORM_CreateSpec_Call
- func (_c *ORM_CreateSpec_Call) Return(_a0 int64, _a1 error) *ORM_CreateSpec_Call
- func (_c *ORM_CreateSpec_Call) Run(run func(spec feeds.JobProposalSpec, qopts ...pg.QOpt)) *ORM_CreateSpec_Call
- func (_c *ORM_CreateSpec_Call) RunAndReturn(run func(feeds.JobProposalSpec, ...pg.QOpt) (int64, error)) *ORM_CreateSpec_Call
- type ORM_DeleteChainConfig_Call
- type ORM_ExistsSpecByJobProposalIDAndVersion_Call
- func (_c *ORM_ExistsSpecByJobProposalIDAndVersion_Call) Return(exists bool, err error) *ORM_ExistsSpecByJobProposalIDAndVersion_Call
- func (_c *ORM_ExistsSpecByJobProposalIDAndVersion_Call) Run(run func(jpID int64, version int32, qopts ...pg.QOpt)) *ORM_ExistsSpecByJobProposalIDAndVersion_Call
- func (_c *ORM_ExistsSpecByJobProposalIDAndVersion_Call) RunAndReturn(run func(int64, int32, ...pg.QOpt) (bool, error)) *ORM_ExistsSpecByJobProposalIDAndVersion_Call
- type ORM_Expecter
- func (_e *ORM_Expecter) ApproveSpec(id interface{}, externalJobID interface{}, qopts ...interface{}) *ORM_ApproveSpec_Call
- func (_e *ORM_Expecter) CancelSpec(id interface{}, qopts ...interface{}) *ORM_CancelSpec_Call
- func (_e *ORM_Expecter) CountJobProposals() *ORM_CountJobProposals_Call
- func (_e *ORM_Expecter) CountJobProposalsByStatus() *ORM_CountJobProposalsByStatus_Call
- func (_e *ORM_Expecter) CountManagers() *ORM_CountManagers_Call
- func (_e *ORM_Expecter) CreateBatchChainConfig(cfgs interface{}, qopts ...interface{}) *ORM_CreateBatchChainConfig_Call
- func (_e *ORM_Expecter) CreateChainConfig(cfg interface{}, qopts ...interface{}) *ORM_CreateChainConfig_Call
- func (_e *ORM_Expecter) CreateJobProposal(jp interface{}) *ORM_CreateJobProposal_Call
- func (_e *ORM_Expecter) CreateManager(ms interface{}, qopts ...interface{}) *ORM_CreateManager_Call
- func (_e *ORM_Expecter) CreateSpec(spec interface{}, qopts ...interface{}) *ORM_CreateSpec_Call
- func (_e *ORM_Expecter) DeleteChainConfig(id interface{}) *ORM_DeleteChainConfig_Call
- func (_e *ORM_Expecter) ExistsSpecByJobProposalIDAndVersion(jpID interface{}, version interface{}, qopts ...interface{}) *ORM_ExistsSpecByJobProposalIDAndVersion_Call
- func (_e *ORM_Expecter) GetApprovedSpec(jpID interface{}, qopts ...interface{}) *ORM_GetApprovedSpec_Call
- func (_e *ORM_Expecter) GetChainConfig(id interface{}) *ORM_GetChainConfig_Call
- func (_e *ORM_Expecter) GetJobProposal(id interface{}, qopts ...interface{}) *ORM_GetJobProposal_Call
- func (_e *ORM_Expecter) GetJobProposalByRemoteUUID(_a0 interface{}) *ORM_GetJobProposalByRemoteUUID_Call
- func (_e *ORM_Expecter) GetLatestSpec(jpID interface{}) *ORM_GetLatestSpec_Call
- func (_e *ORM_Expecter) GetManager(id interface{}) *ORM_GetManager_Call
- func (_e *ORM_Expecter) GetSpec(id interface{}, qopts ...interface{}) *ORM_GetSpec_Call
- func (_e *ORM_Expecter) IsJobManaged(jobID interface{}, qopts ...interface{}) *ORM_IsJobManaged_Call
- func (_e *ORM_Expecter) ListChainConfigsByManagerIDs(mgrIDs interface{}) *ORM_ListChainConfigsByManagerIDs_Call
- func (_e *ORM_Expecter) ListJobProposals() *ORM_ListJobProposals_Call
- func (_e *ORM_Expecter) ListJobProposalsByManagersIDs(ids interface{}, qopts ...interface{}) *ORM_ListJobProposalsByManagersIDs_Call
- func (_e *ORM_Expecter) ListManagers() *ORM_ListManagers_Call
- func (_e *ORM_Expecter) ListManagersByIDs(ids interface{}) *ORM_ListManagersByIDs_Call
- func (_e *ORM_Expecter) ListSpecsByJobProposalIDs(ids interface{}, qopts ...interface{}) *ORM_ListSpecsByJobProposalIDs_Call
- func (_e *ORM_Expecter) RejectSpec(id interface{}, qopts ...interface{}) *ORM_RejectSpec_Call
- func (_e *ORM_Expecter) UpdateChainConfig(cfg interface{}) *ORM_UpdateChainConfig_Call
- func (_e *ORM_Expecter) UpdateJobProposalStatus(id interface{}, status interface{}, qopts ...interface{}) *ORM_UpdateJobProposalStatus_Call
- func (_e *ORM_Expecter) UpdateManager(mgr interface{}, qopts ...interface{}) *ORM_UpdateManager_Call
- func (_e *ORM_Expecter) UpdateSpecDefinition(id interface{}, spec interface{}, qopts ...interface{}) *ORM_UpdateSpecDefinition_Call
- func (_e *ORM_Expecter) UpsertJobProposal(jp interface{}, qopts ...interface{}) *ORM_UpsertJobProposal_Call
- type ORM_GetApprovedSpec_Call
- func (_c *ORM_GetApprovedSpec_Call) Return(_a0 *feeds.JobProposalSpec, _a1 error) *ORM_GetApprovedSpec_Call
- func (_c *ORM_GetApprovedSpec_Call) Run(run func(jpID int64, qopts ...pg.QOpt)) *ORM_GetApprovedSpec_Call
- func (_c *ORM_GetApprovedSpec_Call) RunAndReturn(run func(int64, ...pg.QOpt) (*feeds.JobProposalSpec, error)) *ORM_GetApprovedSpec_Call
- type ORM_GetChainConfig_Call
- func (_c *ORM_GetChainConfig_Call) Return(_a0 *feeds.ChainConfig, _a1 error) *ORM_GetChainConfig_Call
- func (_c *ORM_GetChainConfig_Call) Run(run func(id int64)) *ORM_GetChainConfig_Call
- func (_c *ORM_GetChainConfig_Call) RunAndReturn(run func(int64) (*feeds.ChainConfig, error)) *ORM_GetChainConfig_Call
- type ORM_GetJobProposalByRemoteUUID_Call
- func (_c *ORM_GetJobProposalByRemoteUUID_Call) Return(_a0 *feeds.JobProposal, _a1 error) *ORM_GetJobProposalByRemoteUUID_Call
- func (_c *ORM_GetJobProposalByRemoteUUID_Call) Run(run func(_a0 uuid.UUID)) *ORM_GetJobProposalByRemoteUUID_Call
- func (_c *ORM_GetJobProposalByRemoteUUID_Call) RunAndReturn(run func(uuid.UUID) (*feeds.JobProposal, error)) *ORM_GetJobProposalByRemoteUUID_Call
- type ORM_GetJobProposal_Call
- func (_c *ORM_GetJobProposal_Call) Return(_a0 *feeds.JobProposal, _a1 error) *ORM_GetJobProposal_Call
- func (_c *ORM_GetJobProposal_Call) Run(run func(id int64, qopts ...pg.QOpt)) *ORM_GetJobProposal_Call
- func (_c *ORM_GetJobProposal_Call) RunAndReturn(run func(int64, ...pg.QOpt) (*feeds.JobProposal, error)) *ORM_GetJobProposal_Call
- type ORM_GetLatestSpec_Call
- func (_c *ORM_GetLatestSpec_Call) Return(_a0 *feeds.JobProposalSpec, _a1 error) *ORM_GetLatestSpec_Call
- func (_c *ORM_GetLatestSpec_Call) Run(run func(jpID int64)) *ORM_GetLatestSpec_Call
- func (_c *ORM_GetLatestSpec_Call) RunAndReturn(run func(int64) (*feeds.JobProposalSpec, error)) *ORM_GetLatestSpec_Call
- type ORM_GetManager_Call
- type ORM_GetSpec_Call
- type ORM_IsJobManaged_Call
- type ORM_ListChainConfigsByManagerIDs_Call
- func (_c *ORM_ListChainConfigsByManagerIDs_Call) Return(_a0 []feeds.ChainConfig, _a1 error) *ORM_ListChainConfigsByManagerIDs_Call
- func (_c *ORM_ListChainConfigsByManagerIDs_Call) Run(run func(mgrIDs []int64)) *ORM_ListChainConfigsByManagerIDs_Call
- func (_c *ORM_ListChainConfigsByManagerIDs_Call) RunAndReturn(run func([]int64) ([]feeds.ChainConfig, error)) *ORM_ListChainConfigsByManagerIDs_Call
- type ORM_ListJobProposalsByManagersIDs_Call
- func (_c *ORM_ListJobProposalsByManagersIDs_Call) Return(_a0 []feeds.JobProposal, _a1 error) *ORM_ListJobProposalsByManagersIDs_Call
- func (_c *ORM_ListJobProposalsByManagersIDs_Call) Run(run func(ids []int64, qopts ...pg.QOpt)) *ORM_ListJobProposalsByManagersIDs_Call
- func (_c *ORM_ListJobProposalsByManagersIDs_Call) RunAndReturn(run func([]int64, ...pg.QOpt) ([]feeds.JobProposal, error)) *ORM_ListJobProposalsByManagersIDs_Call
- type ORM_ListJobProposals_Call
- func (_c *ORM_ListJobProposals_Call) Return(jps []feeds.JobProposal, err error) *ORM_ListJobProposals_Call
- func (_c *ORM_ListJobProposals_Call) Run(run func()) *ORM_ListJobProposals_Call
- func (_c *ORM_ListJobProposals_Call) RunAndReturn(run func() ([]feeds.JobProposal, error)) *ORM_ListJobProposals_Call
- type ORM_ListManagersByIDs_Call
- func (_c *ORM_ListManagersByIDs_Call) Return(_a0 []feeds.FeedsManager, _a1 error) *ORM_ListManagersByIDs_Call
- func (_c *ORM_ListManagersByIDs_Call) Run(run func(ids []int64)) *ORM_ListManagersByIDs_Call
- func (_c *ORM_ListManagersByIDs_Call) RunAndReturn(run func([]int64) ([]feeds.FeedsManager, error)) *ORM_ListManagersByIDs_Call
- type ORM_ListManagers_Call
- type ORM_ListSpecsByJobProposalIDs_Call
- func (_c *ORM_ListSpecsByJobProposalIDs_Call) Return(_a0 []feeds.JobProposalSpec, _a1 error) *ORM_ListSpecsByJobProposalIDs_Call
- func (_c *ORM_ListSpecsByJobProposalIDs_Call) Run(run func(ids []int64, qopts ...pg.QOpt)) *ORM_ListSpecsByJobProposalIDs_Call
- func (_c *ORM_ListSpecsByJobProposalIDs_Call) RunAndReturn(run func([]int64, ...pg.QOpt) ([]feeds.JobProposalSpec, error)) *ORM_ListSpecsByJobProposalIDs_Call
- type ORM_RejectSpec_Call
- type ORM_UpdateChainConfig_Call
- func (_c *ORM_UpdateChainConfig_Call) Return(_a0 int64, _a1 error) *ORM_UpdateChainConfig_Call
- func (_c *ORM_UpdateChainConfig_Call) Run(run func(cfg feeds.ChainConfig)) *ORM_UpdateChainConfig_Call
- func (_c *ORM_UpdateChainConfig_Call) RunAndReturn(run func(feeds.ChainConfig) (int64, error)) *ORM_UpdateChainConfig_Call
- type ORM_UpdateJobProposalStatus_Call
- func (_c *ORM_UpdateJobProposalStatus_Call) Return(_a0 error) *ORM_UpdateJobProposalStatus_Call
- func (_c *ORM_UpdateJobProposalStatus_Call) Run(run func(id int64, status feeds.JobProposalStatus, qopts ...pg.QOpt)) *ORM_UpdateJobProposalStatus_Call
- func (_c *ORM_UpdateJobProposalStatus_Call) RunAndReturn(run func(int64, feeds.JobProposalStatus, ...pg.QOpt) error) *ORM_UpdateJobProposalStatus_Call
- type ORM_UpdateManager_Call
- func (_c *ORM_UpdateManager_Call) Return(_a0 error) *ORM_UpdateManager_Call
- func (_c *ORM_UpdateManager_Call) Run(run func(mgr feeds.FeedsManager, qopts ...pg.QOpt)) *ORM_UpdateManager_Call
- func (_c *ORM_UpdateManager_Call) RunAndReturn(run func(feeds.FeedsManager, ...pg.QOpt) error) *ORM_UpdateManager_Call
- type ORM_UpdateSpecDefinition_Call
- func (_c *ORM_UpdateSpecDefinition_Call) Return(_a0 error) *ORM_UpdateSpecDefinition_Call
- func (_c *ORM_UpdateSpecDefinition_Call) Run(run func(id int64, spec string, qopts ...pg.QOpt)) *ORM_UpdateSpecDefinition_Call
- func (_c *ORM_UpdateSpecDefinition_Call) RunAndReturn(run func(int64, string, ...pg.QOpt) error) *ORM_UpdateSpecDefinition_Call
- type ORM_UpsertJobProposal_Call
- func (_c *ORM_UpsertJobProposal_Call) Return(_a0 int64, _a1 error) *ORM_UpsertJobProposal_Call
- func (_c *ORM_UpsertJobProposal_Call) Run(run func(jp *feeds.JobProposal, qopts ...pg.QOpt)) *ORM_UpsertJobProposal_Call
- func (_c *ORM_UpsertJobProposal_Call) RunAndReturn(run func(*feeds.JobProposal, ...pg.QOpt) (int64, error)) *ORM_UpsertJobProposal_Call
- type Service
- func (_m *Service) ApproveSpec(ctx context.Context, id int64, force bool) error
- func (_m *Service) CancelSpec(ctx context.Context, id int64) error
- func (_m *Service) Close() error
- func (_m *Service) CountJobProposalsByStatus() (*feeds.JobProposalCounts, error)
- func (_m *Service) CountManagers() (int64, error)
- func (_m *Service) CreateChainConfig(ctx context.Context, cfg feeds.ChainConfig) (int64, error)
- func (_m *Service) DeleteChainConfig(ctx context.Context, id int64) (int64, error)
- func (_m *Service) GetChainConfig(id int64) (*feeds.ChainConfig, error)
- func (_m *Service) GetJobProposal(id int64) (*feeds.JobProposal, error)
- func (_m *Service) GetManager(id int64) (*feeds.FeedsManager, error)
- func (_m *Service) GetSpec(id int64) (*feeds.JobProposalSpec, error)
- func (_m *Service) IsJobManaged(ctx context.Context, jobID int64) (bool, error)
- func (_m *Service) ListChainConfigsByManagerIDs(mgrIDs []int64) ([]feeds.ChainConfig, error)
- func (_m *Service) ListJobProposals() ([]feeds.JobProposal, error)
- func (_m *Service) ListJobProposalsByManagersIDs(ids []int64) ([]feeds.JobProposal, error)
- func (_m *Service) ListManagers() ([]feeds.FeedsManager, error)
- func (_m *Service) ListManagersByIDs(ids []int64) ([]feeds.FeedsManager, error)
- func (_m *Service) ListSpecsByJobProposalIDs(ids []int64) ([]feeds.JobProposalSpec, error)
- func (_m *Service) ProposeJob(ctx context.Context, args *feeds.ProposeJobArgs) (int64, error)
- func (_m *Service) RegisterManager(ctx context.Context, params feeds.RegisterManagerParams) (int64, error)
- func (_m *Service) RejectSpec(ctx context.Context, id int64) error
- func (_m *Service) Start(ctx context.Context) error
- func (_m *Service) SyncNodeInfo(ctx context.Context, id int64) error
- func (_m *Service) Unsafe_SetConnectionsManager(_a0 feeds.ConnectionsManager)
- func (_m *Service) UpdateChainConfig(ctx context.Context, cfg feeds.ChainConfig) (int64, error)
- func (_m *Service) UpdateManager(ctx context.Context, mgr feeds.FeedsManager) error
- func (_m *Service) UpdateSpecDefinition(ctx context.Context, id int64, spec string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶ added in v0.10.10
Config is an autogenerated mock type for the Config type
func NewConfig ¶ added in v1.6.0
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 ¶ added in v1.10.0
DatabaseDefaultQueryTimeout provides a mock function with given fields:
func (*Config) DefaultHTTPTimeout ¶ added in v0.10.11
DefaultHTTPTimeout provides a mock function with given fields:
func (*Config) FeatureOffchainReporting ¶ added in v0.10.11
FeatureOffchainReporting provides a mock function with given fields:
func (*Config) FeatureOffchainReporting2 ¶ added in v1.13.0
FeatureOffchainReporting2 provides a mock function with given fields:
func (*Config) JobPipelineMaxSuccessfulRuns ¶ added in v1.13.0
JobPipelineMaxSuccessfulRuns provides a mock function with given fields:
func (*Config) JobPipelineResultWriteQueueDepth ¶ added in v1.13.0
JobPipelineResultWriteQueueDepth provides a mock function with given fields:
func (*Config) OCR2BlockchainTimeout ¶ added in v1.13.0
OCR2BlockchainTimeout provides a mock function with given fields:
func (*Config) OCR2ContractConfirmations ¶ added in v1.13.0
OCR2ContractConfirmations provides a mock function with given fields:
func (*Config) OCR2ContractPollInterval ¶ added in v1.13.0
OCR2ContractPollInterval provides a mock function with given fields:
func (*Config) OCR2ContractSubscribeInterval ¶ added in v1.13.0
OCR2ContractSubscribeInterval provides a mock function with given fields:
func (*Config) OCR2ContractTransmitterTransmitTimeout ¶ added in v1.13.0
OCR2ContractTransmitterTransmitTimeout provides a mock function with given fields:
func (*Config) OCR2DatabaseTimeout ¶ added in v1.13.0
OCR2DatabaseTimeout provides a mock function with given fields:
func (*Config) OCR2KeyBundleID ¶ added in v1.13.0
OCR2KeyBundleID provides a mock function with given fields:
func (*Config) OCR2TraceLogging ¶ added in v1.13.0
OCR2TraceLogging provides a mock function with given fields:
type ConnectionsManager ¶ added in v1.0.0
ConnectionsManager is an autogenerated mock type for the ConnectionsManager type
func NewConnectionsManager ¶ added in v1.6.0
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 ¶ added in v1.0.0
func (_m *ConnectionsManager) Close()
Close provides a mock function with given fields:
func (*ConnectionsManager) Connect ¶ added in v1.0.0
func (_m *ConnectionsManager) Connect(opts feeds.ConnectOpts)
Connect provides a mock function with given fields: opts
func (*ConnectionsManager) Disconnect ¶ added in v1.0.0
func (_m *ConnectionsManager) Disconnect(id int64) error
Disconnect provides a mock function with given fields: id
func (*ConnectionsManager) GetClient ¶ added in v1.0.0
func (_m *ConnectionsManager) GetClient(id int64) (proto.FeedsManagerClient, error)
GetClient provides a mock function with given fields: id
func (*ConnectionsManager) IsConnected ¶ added in v1.0.0
func (_m *ConnectionsManager) IsConnected(id int64) bool
IsConnected provides a mock function with given fields: id
type FeedsManagerClient ¶ added in v0.10.10
FeedsManagerClient is an autogenerated mock type for the FeedsManagerClient type
func NewFeedsManagerClient ¶ added in v1.6.0
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 ¶ added in v0.10.10
func (_m *FeedsManagerClient) ApprovedJob(ctx context.Context, in *proto.ApprovedJobRequest) (*proto.ApprovedJobResponse, error)
ApprovedJob provides a mock function with given fields: ctx, in
func (*FeedsManagerClient) CancelledJob ¶ added in v1.1.0
func (_m *FeedsManagerClient) CancelledJob(ctx context.Context, in *proto.CancelledJobRequest) (*proto.CancelledJobResponse, error)
CancelledJob provides a mock function with given fields: ctx, in
func (*FeedsManagerClient) RejectedJob ¶ added in v0.10.10
func (_m *FeedsManagerClient) RejectedJob(ctx context.Context, in *proto.RejectedJobRequest) (*proto.RejectedJobResponse, error)
RejectedJob provides a mock function with given fields: ctx, in
func (*FeedsManagerClient) UpdateNode ¶ added in v0.10.10
func (_m *FeedsManagerClient) UpdateNode(ctx context.Context, in *proto.UpdateNodeRequest) (*proto.UpdateNodeResponse, error)
UpdateNode provides a mock function with given fields: ctx, in
type ORM ¶
ORM is an autogenerated mock type for the ORM type
func NewORM ¶ added in v1.6.0
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 ¶ added in v1.2.0
ApproveSpec provides a mock function with given fields: id, externalJobID, qopts
func (*ORM) CancelSpec ¶ added in v1.2.0
CancelSpec provides a mock function with given fields: id, qopts
func (*ORM) CountJobProposals ¶ added in v0.10.9
CountJobProposals provides a mock function with given fields:
func (*ORM) CountJobProposalsByStatus ¶ added in v1.12.0
func (_m *ORM) CountJobProposalsByStatus() (*feeds.JobProposalCounts, error)
CountJobProposalsByStatus provides a mock function with given fields:
func (*ORM) CountManagers ¶
CountManagers provides a mock function with given fields:
func (*ORM) CreateBatchChainConfig ¶ added in v1.5.0
CreateBatchChainConfig provides a mock function with given fields: cfgs, qopts
func (*ORM) CreateChainConfig ¶ added in v1.5.0
CreateChainConfig provides a mock function with given fields: cfg, qopts
func (*ORM) CreateJobProposal ¶ added in v0.10.9
func (_m *ORM) CreateJobProposal(jp *feeds.JobProposal) (int64, error)
CreateJobProposal provides a mock function with given fields: jp
func (*ORM) CreateManager ¶
CreateManager provides a mock function with given fields: ms, qopts
func (*ORM) CreateSpec ¶ added in v1.2.0
CreateSpec provides a mock function with given fields: spec, qopts
func (*ORM) DeleteChainConfig ¶ added in v1.5.0
DeleteChainConfig provides a mock function with given fields: id
func (*ORM) EXPECT ¶ added in v1.13.0
func (_m *ORM) EXPECT() *ORM_Expecter
func (*ORM) ExistsSpecByJobProposalIDAndVersion ¶ added in v1.2.0
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 ¶ added in v1.13.0
GetApprovedSpec provides a mock function with given fields: jpID, qopts
func (*ORM) GetChainConfig ¶ added in v1.5.0
func (_m *ORM) GetChainConfig(id int64) (*feeds.ChainConfig, error)
GetChainConfig provides a mock function with given fields: id
func (*ORM) GetJobProposal ¶ added in v0.10.9
GetJobProposal provides a mock function with given fields: id, qopts
func (*ORM) GetJobProposalByRemoteUUID ¶ added in v1.0.0
GetJobProposalByRemoteUUID provides a mock function with given fields: _a0
func (*ORM) GetLatestSpec ¶ added in v1.5.0
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) IsJobManaged ¶ added in v1.1.0
IsJobManaged provides a mock function with given fields: jobID, qopts
func (*ORM) ListChainConfigsByManagerIDs ¶ added in v1.5.0
func (_m *ORM) ListChainConfigsByManagerIDs(mgrIDs []int64) ([]feeds.ChainConfig, error)
ListChainConfigsByManagerIDs provides a mock function with given fields: mgrIDs
func (*ORM) ListJobProposals ¶ added in v0.10.9
func (_m *ORM) ListJobProposals() ([]feeds.JobProposal, error)
ListJobProposals provides a mock function with given fields:
func (*ORM) ListJobProposalsByManagersIDs ¶ added in v1.2.0
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 ¶ added in v1.2.0
func (_m *ORM) ListManagersByIDs(ids []int64) ([]feeds.FeedsManager, error)
ListManagersByIDs provides a mock function with given fields: ids
func (*ORM) ListSpecsByJobProposalIDs ¶ added in v1.2.0
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 ¶ added in v1.2.0
RejectSpec provides a mock function with given fields: id, qopts
func (*ORM) UpdateChainConfig ¶ added in v1.5.0
func (_m *ORM) UpdateChainConfig(cfg feeds.ChainConfig) (int64, error)
UpdateChainConfig provides a mock function with given fields: cfg
func (*ORM) UpdateJobProposalStatus ¶ added in v0.10.11
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 ¶ added in v1.0.0
UpdateManager provides a mock function with given fields: mgr, qopts
func (*ORM) UpdateSpecDefinition ¶ added in v1.2.0
UpdateSpecDefinition provides a mock function with given fields: id, spec, qopts
func (*ORM) UpsertJobProposal ¶ added in v1.0.0
UpsertJobProposal provides a mock function with given fields: jp, qopts
type ORM_ApproveSpec_Call ¶ added in v1.13.0
ORM_ApproveSpec_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ApproveSpec'
func (*ORM_ApproveSpec_Call) Return ¶ added in v1.13.0
func (_c *ORM_ApproveSpec_Call) Return(_a0 error) *ORM_ApproveSpec_Call
func (*ORM_ApproveSpec_Call) Run ¶ added in v1.13.0
func (_c *ORM_ApproveSpec_Call) Run(run func(id int64, externalJobID uuid.UUID, qopts ...pg.QOpt)) *ORM_ApproveSpec_Call
func (*ORM_ApproveSpec_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ORM_ApproveSpec_Call) RunAndReturn(run func(int64, uuid.UUID, ...pg.QOpt) error) *ORM_ApproveSpec_Call
type ORM_CancelSpec_Call ¶ added in v1.13.0
ORM_CancelSpec_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CancelSpec'
func (*ORM_CancelSpec_Call) Return ¶ added in v1.13.0
func (_c *ORM_CancelSpec_Call) Return(_a0 error) *ORM_CancelSpec_Call
func (*ORM_CancelSpec_Call) Run ¶ added in v1.13.0
func (_c *ORM_CancelSpec_Call) Run(run func(id int64, qopts ...pg.QOpt)) *ORM_CancelSpec_Call
func (*ORM_CancelSpec_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ORM_CancelSpec_Call) RunAndReturn(run func(int64, ...pg.QOpt) error) *ORM_CancelSpec_Call
type ORM_CountJobProposalsByStatus_Call ¶ added in v1.13.0
ORM_CountJobProposalsByStatus_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CountJobProposalsByStatus'
func (*ORM_CountJobProposalsByStatus_Call) Return ¶ added in v1.13.0
func (_c *ORM_CountJobProposalsByStatus_Call) Return(counts *feeds.JobProposalCounts, err error) *ORM_CountJobProposalsByStatus_Call
func (*ORM_CountJobProposalsByStatus_Call) Run ¶ added in v1.13.0
func (_c *ORM_CountJobProposalsByStatus_Call) Run(run func()) *ORM_CountJobProposalsByStatus_Call
func (*ORM_CountJobProposalsByStatus_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ORM_CountJobProposalsByStatus_Call) RunAndReturn(run func() (*feeds.JobProposalCounts, error)) *ORM_CountJobProposalsByStatus_Call
type ORM_CountJobProposals_Call ¶ added in v1.13.0
ORM_CountJobProposals_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CountJobProposals'
func (*ORM_CountJobProposals_Call) Return ¶ added in v1.13.0
func (_c *ORM_CountJobProposals_Call) Return(_a0 int64, _a1 error) *ORM_CountJobProposals_Call
func (*ORM_CountJobProposals_Call) Run ¶ added in v1.13.0
func (_c *ORM_CountJobProposals_Call) Run(run func()) *ORM_CountJobProposals_Call
func (*ORM_CountJobProposals_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ORM_CountJobProposals_Call) RunAndReturn(run func() (int64, error)) *ORM_CountJobProposals_Call
type ORM_CountManagers_Call ¶ added in v1.13.0
ORM_CountManagers_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CountManagers'
func (*ORM_CountManagers_Call) Return ¶ added in v1.13.0
func (_c *ORM_CountManagers_Call) Return(_a0 int64, _a1 error) *ORM_CountManagers_Call
func (*ORM_CountManagers_Call) Run ¶ added in v1.13.0
func (_c *ORM_CountManagers_Call) Run(run func()) *ORM_CountManagers_Call
func (*ORM_CountManagers_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ORM_CountManagers_Call) RunAndReturn(run func() (int64, error)) *ORM_CountManagers_Call
type ORM_CreateBatchChainConfig_Call ¶ added in v1.13.0
ORM_CreateBatchChainConfig_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateBatchChainConfig'
func (*ORM_CreateBatchChainConfig_Call) Return ¶ added in v1.13.0
func (_c *ORM_CreateBatchChainConfig_Call) Return(_a0 []int64, _a1 error) *ORM_CreateBatchChainConfig_Call
func (*ORM_CreateBatchChainConfig_Call) Run ¶ added in v1.13.0
func (_c *ORM_CreateBatchChainConfig_Call) Run(run func(cfgs []feeds.ChainConfig, qopts ...pg.QOpt)) *ORM_CreateBatchChainConfig_Call
func (*ORM_CreateBatchChainConfig_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ORM_CreateBatchChainConfig_Call) RunAndReturn(run func([]feeds.ChainConfig, ...pg.QOpt) ([]int64, error)) *ORM_CreateBatchChainConfig_Call
type ORM_CreateChainConfig_Call ¶ added in v1.13.0
ORM_CreateChainConfig_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateChainConfig'
func (*ORM_CreateChainConfig_Call) Return ¶ added in v1.13.0
func (_c *ORM_CreateChainConfig_Call) Return(_a0 int64, _a1 error) *ORM_CreateChainConfig_Call
func (*ORM_CreateChainConfig_Call) Run ¶ added in v1.13.0
func (_c *ORM_CreateChainConfig_Call) Run(run func(cfg feeds.ChainConfig, qopts ...pg.QOpt)) *ORM_CreateChainConfig_Call
func (*ORM_CreateChainConfig_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ORM_CreateChainConfig_Call) RunAndReturn(run func(feeds.ChainConfig, ...pg.QOpt) (int64, error)) *ORM_CreateChainConfig_Call
type ORM_CreateJobProposal_Call ¶ added in v1.13.0
ORM_CreateJobProposal_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateJobProposal'
func (*ORM_CreateJobProposal_Call) Return ¶ added in v1.13.0
func (_c *ORM_CreateJobProposal_Call) Return(_a0 int64, _a1 error) *ORM_CreateJobProposal_Call
func (*ORM_CreateJobProposal_Call) Run ¶ added in v1.13.0
func (_c *ORM_CreateJobProposal_Call) Run(run func(jp *feeds.JobProposal)) *ORM_CreateJobProposal_Call
func (*ORM_CreateJobProposal_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ORM_CreateJobProposal_Call) RunAndReturn(run func(*feeds.JobProposal) (int64, error)) *ORM_CreateJobProposal_Call
type ORM_CreateManager_Call ¶ added in v1.13.0
ORM_CreateManager_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateManager'
func (*ORM_CreateManager_Call) Return ¶ added in v1.13.0
func (_c *ORM_CreateManager_Call) Return(_a0 int64, _a1 error) *ORM_CreateManager_Call
func (*ORM_CreateManager_Call) Run ¶ added in v1.13.0
func (_c *ORM_CreateManager_Call) Run(run func(ms *feeds.FeedsManager, qopts ...pg.QOpt)) *ORM_CreateManager_Call
func (*ORM_CreateManager_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ORM_CreateManager_Call) RunAndReturn(run func(*feeds.FeedsManager, ...pg.QOpt) (int64, error)) *ORM_CreateManager_Call
type ORM_CreateSpec_Call ¶ added in v1.13.0
ORM_CreateSpec_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateSpec'
func (*ORM_CreateSpec_Call) Return ¶ added in v1.13.0
func (_c *ORM_CreateSpec_Call) Return(_a0 int64, _a1 error) *ORM_CreateSpec_Call
func (*ORM_CreateSpec_Call) Run ¶ added in v1.13.0
func (_c *ORM_CreateSpec_Call) Run(run func(spec feeds.JobProposalSpec, qopts ...pg.QOpt)) *ORM_CreateSpec_Call
func (*ORM_CreateSpec_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ORM_CreateSpec_Call) RunAndReturn(run func(feeds.JobProposalSpec, ...pg.QOpt) (int64, error)) *ORM_CreateSpec_Call
type ORM_DeleteChainConfig_Call ¶ added in v1.13.0
ORM_DeleteChainConfig_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteChainConfig'
func (*ORM_DeleteChainConfig_Call) Return ¶ added in v1.13.0
func (_c *ORM_DeleteChainConfig_Call) Return(_a0 int64, _a1 error) *ORM_DeleteChainConfig_Call
func (*ORM_DeleteChainConfig_Call) Run ¶ added in v1.13.0
func (_c *ORM_DeleteChainConfig_Call) Run(run func(id int64)) *ORM_DeleteChainConfig_Call
func (*ORM_DeleteChainConfig_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ORM_DeleteChainConfig_Call) RunAndReturn(run func(int64) (int64, error)) *ORM_DeleteChainConfig_Call
type ORM_ExistsSpecByJobProposalIDAndVersion_Call ¶ added in v1.13.0
ORM_ExistsSpecByJobProposalIDAndVersion_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ExistsSpecByJobProposalIDAndVersion'
func (*ORM_ExistsSpecByJobProposalIDAndVersion_Call) Return ¶ added in v1.13.0
func (_c *ORM_ExistsSpecByJobProposalIDAndVersion_Call) Return(exists bool, err error) *ORM_ExistsSpecByJobProposalIDAndVersion_Call
func (*ORM_ExistsSpecByJobProposalIDAndVersion_Call) Run ¶ added in v1.13.0
func (_c *ORM_ExistsSpecByJobProposalIDAndVersion_Call) Run(run func(jpID int64, version int32, qopts ...pg.QOpt)) *ORM_ExistsSpecByJobProposalIDAndVersion_Call
func (*ORM_ExistsSpecByJobProposalIDAndVersion_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ORM_ExistsSpecByJobProposalIDAndVersion_Call) RunAndReturn(run func(int64, int32, ...pg.QOpt) (bool, error)) *ORM_ExistsSpecByJobProposalIDAndVersion_Call
type ORM_Expecter ¶ added in v1.13.0
type ORM_Expecter struct {
// contains filtered or unexported fields
}
func (*ORM_Expecter) ApproveSpec ¶ added in v1.13.0
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 ¶ added in v1.13.0
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 ¶ added in v1.13.0
func (_e *ORM_Expecter) CountJobProposals() *ORM_CountJobProposals_Call
CountJobProposals is a helper method to define mock.On call
func (*ORM_Expecter) CountJobProposalsByStatus ¶ added in v1.13.0
func (_e *ORM_Expecter) CountJobProposalsByStatus() *ORM_CountJobProposalsByStatus_Call
CountJobProposalsByStatus is a helper method to define mock.On call
func (*ORM_Expecter) CountManagers ¶ added in v1.13.0
func (_e *ORM_Expecter) CountManagers() *ORM_CountManagers_Call
CountManagers is a helper method to define mock.On call
func (*ORM_Expecter) CreateBatchChainConfig ¶ added in v1.13.0
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 ¶ added in v1.13.0
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 ¶ added in v1.13.0
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 ¶ added in v1.13.0
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 ¶ added in v1.13.0
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 ¶ added in v1.13.0
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) ExistsSpecByJobProposalIDAndVersion ¶ added in v1.13.0
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 ¶ added in v1.13.0
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 ¶ added in v1.13.0
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 ¶ added in v1.13.0
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 ¶ added in v1.13.0
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 ¶ added in v1.13.0
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 ¶ added in v1.13.0
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 ¶ added in v1.13.0
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 ¶ added in v1.13.0
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 ¶ added in v1.13.0
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 ¶ added in v1.13.0
func (_e *ORM_Expecter) ListJobProposals() *ORM_ListJobProposals_Call
ListJobProposals is a helper method to define mock.On call
func (*ORM_Expecter) ListJobProposalsByManagersIDs ¶ added in v1.13.0
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 ¶ added in v1.13.0
func (_e *ORM_Expecter) ListManagers() *ORM_ListManagers_Call
ListManagers is a helper method to define mock.On call
func (*ORM_Expecter) ListManagersByIDs ¶ added in v1.13.0
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 ¶ added in v1.13.0
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 ¶ added in v1.13.0
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) UpdateChainConfig ¶ added in v1.13.0
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 ¶ added in v1.13.0
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 ¶ added in v1.13.0
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 ¶ added in v1.13.0
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 ¶ added in v1.13.0
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 ¶ added in v1.13.0
ORM_GetApprovedSpec_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetApprovedSpec'
func (*ORM_GetApprovedSpec_Call) Return ¶ added in v1.13.0
func (_c *ORM_GetApprovedSpec_Call) Return(_a0 *feeds.JobProposalSpec, _a1 error) *ORM_GetApprovedSpec_Call
func (*ORM_GetApprovedSpec_Call) Run ¶ added in v1.13.0
func (_c *ORM_GetApprovedSpec_Call) Run(run func(jpID int64, qopts ...pg.QOpt)) *ORM_GetApprovedSpec_Call
func (*ORM_GetApprovedSpec_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ORM_GetApprovedSpec_Call) RunAndReturn(run func(int64, ...pg.QOpt) (*feeds.JobProposalSpec, error)) *ORM_GetApprovedSpec_Call
type ORM_GetChainConfig_Call ¶ added in v1.13.0
ORM_GetChainConfig_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetChainConfig'
func (*ORM_GetChainConfig_Call) Return ¶ added in v1.13.0
func (_c *ORM_GetChainConfig_Call) Return(_a0 *feeds.ChainConfig, _a1 error) *ORM_GetChainConfig_Call
func (*ORM_GetChainConfig_Call) Run ¶ added in v1.13.0
func (_c *ORM_GetChainConfig_Call) Run(run func(id int64)) *ORM_GetChainConfig_Call
func (*ORM_GetChainConfig_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ORM_GetChainConfig_Call) RunAndReturn(run func(int64) (*feeds.ChainConfig, error)) *ORM_GetChainConfig_Call
type ORM_GetJobProposalByRemoteUUID_Call ¶ added in v1.13.0
ORM_GetJobProposalByRemoteUUID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetJobProposalByRemoteUUID'
func (*ORM_GetJobProposalByRemoteUUID_Call) Return ¶ added in v1.13.0
func (_c *ORM_GetJobProposalByRemoteUUID_Call) Return(_a0 *feeds.JobProposal, _a1 error) *ORM_GetJobProposalByRemoteUUID_Call
func (*ORM_GetJobProposalByRemoteUUID_Call) Run ¶ added in v1.13.0
func (_c *ORM_GetJobProposalByRemoteUUID_Call) Run(run func(_a0 uuid.UUID)) *ORM_GetJobProposalByRemoteUUID_Call
func (*ORM_GetJobProposalByRemoteUUID_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ORM_GetJobProposalByRemoteUUID_Call) RunAndReturn(run func(uuid.UUID) (*feeds.JobProposal, error)) *ORM_GetJobProposalByRemoteUUID_Call
type ORM_GetJobProposal_Call ¶ added in v1.13.0
ORM_GetJobProposal_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetJobProposal'
func (*ORM_GetJobProposal_Call) Return ¶ added in v1.13.0
func (_c *ORM_GetJobProposal_Call) Return(_a0 *feeds.JobProposal, _a1 error) *ORM_GetJobProposal_Call
func (*ORM_GetJobProposal_Call) Run ¶ added in v1.13.0
func (_c *ORM_GetJobProposal_Call) Run(run func(id int64, qopts ...pg.QOpt)) *ORM_GetJobProposal_Call
func (*ORM_GetJobProposal_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ORM_GetJobProposal_Call) RunAndReturn(run func(int64, ...pg.QOpt) (*feeds.JobProposal, error)) *ORM_GetJobProposal_Call
type ORM_GetLatestSpec_Call ¶ added in v1.13.0
ORM_GetLatestSpec_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLatestSpec'
func (*ORM_GetLatestSpec_Call) Return ¶ added in v1.13.0
func (_c *ORM_GetLatestSpec_Call) Return(_a0 *feeds.JobProposalSpec, _a1 error) *ORM_GetLatestSpec_Call
func (*ORM_GetLatestSpec_Call) Run ¶ added in v1.13.0
func (_c *ORM_GetLatestSpec_Call) Run(run func(jpID int64)) *ORM_GetLatestSpec_Call
func (*ORM_GetLatestSpec_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ORM_GetLatestSpec_Call) RunAndReturn(run func(int64) (*feeds.JobProposalSpec, error)) *ORM_GetLatestSpec_Call
type ORM_GetManager_Call ¶ added in v1.13.0
ORM_GetManager_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetManager'
func (*ORM_GetManager_Call) Return ¶ added in v1.13.0
func (_c *ORM_GetManager_Call) Return(_a0 *feeds.FeedsManager, _a1 error) *ORM_GetManager_Call
func (*ORM_GetManager_Call) Run ¶ added in v1.13.0
func (_c *ORM_GetManager_Call) Run(run func(id int64)) *ORM_GetManager_Call
func (*ORM_GetManager_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ORM_GetManager_Call) RunAndReturn(run func(int64) (*feeds.FeedsManager, error)) *ORM_GetManager_Call
type ORM_GetSpec_Call ¶ added in v1.13.0
ORM_GetSpec_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetSpec'
func (*ORM_GetSpec_Call) Return ¶ added in v1.13.0
func (_c *ORM_GetSpec_Call) Return(_a0 *feeds.JobProposalSpec, _a1 error) *ORM_GetSpec_Call
func (*ORM_GetSpec_Call) Run ¶ added in v1.13.0
func (_c *ORM_GetSpec_Call) Run(run func(id int64, qopts ...pg.QOpt)) *ORM_GetSpec_Call
func (*ORM_GetSpec_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ORM_GetSpec_Call) RunAndReturn(run func(int64, ...pg.QOpt) (*feeds.JobProposalSpec, error)) *ORM_GetSpec_Call
type ORM_IsJobManaged_Call ¶ added in v1.13.0
ORM_IsJobManaged_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsJobManaged'
func (*ORM_IsJobManaged_Call) Return ¶ added in v1.13.0
func (_c *ORM_IsJobManaged_Call) Return(_a0 bool, _a1 error) *ORM_IsJobManaged_Call
func (*ORM_IsJobManaged_Call) Run ¶ added in v1.13.0
func (_c *ORM_IsJobManaged_Call) Run(run func(jobID int64, qopts ...pg.QOpt)) *ORM_IsJobManaged_Call
func (*ORM_IsJobManaged_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ORM_IsJobManaged_Call) RunAndReturn(run func(int64, ...pg.QOpt) (bool, error)) *ORM_IsJobManaged_Call
type ORM_ListChainConfigsByManagerIDs_Call ¶ added in v1.13.0
ORM_ListChainConfigsByManagerIDs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListChainConfigsByManagerIDs'
func (*ORM_ListChainConfigsByManagerIDs_Call) Return ¶ added in v1.13.0
func (_c *ORM_ListChainConfigsByManagerIDs_Call) Return(_a0 []feeds.ChainConfig, _a1 error) *ORM_ListChainConfigsByManagerIDs_Call
func (*ORM_ListChainConfigsByManagerIDs_Call) Run ¶ added in v1.13.0
func (_c *ORM_ListChainConfigsByManagerIDs_Call) Run(run func(mgrIDs []int64)) *ORM_ListChainConfigsByManagerIDs_Call
func (*ORM_ListChainConfigsByManagerIDs_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ORM_ListChainConfigsByManagerIDs_Call) RunAndReturn(run func([]int64) ([]feeds.ChainConfig, error)) *ORM_ListChainConfigsByManagerIDs_Call
type ORM_ListJobProposalsByManagersIDs_Call ¶ added in v1.13.0
ORM_ListJobProposalsByManagersIDs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListJobProposalsByManagersIDs'
func (*ORM_ListJobProposalsByManagersIDs_Call) Return ¶ added in v1.13.0
func (_c *ORM_ListJobProposalsByManagersIDs_Call) Return(_a0 []feeds.JobProposal, _a1 error) *ORM_ListJobProposalsByManagersIDs_Call
func (*ORM_ListJobProposalsByManagersIDs_Call) Run ¶ added in v1.13.0
func (_c *ORM_ListJobProposalsByManagersIDs_Call) Run(run func(ids []int64, qopts ...pg.QOpt)) *ORM_ListJobProposalsByManagersIDs_Call
func (*ORM_ListJobProposalsByManagersIDs_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ORM_ListJobProposalsByManagersIDs_Call) RunAndReturn(run func([]int64, ...pg.QOpt) ([]feeds.JobProposal, error)) *ORM_ListJobProposalsByManagersIDs_Call
type ORM_ListJobProposals_Call ¶ added in v1.13.0
ORM_ListJobProposals_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListJobProposals'
func (*ORM_ListJobProposals_Call) Return ¶ added in v1.13.0
func (_c *ORM_ListJobProposals_Call) Return(jps []feeds.JobProposal, err error) *ORM_ListJobProposals_Call
func (*ORM_ListJobProposals_Call) Run ¶ added in v1.13.0
func (_c *ORM_ListJobProposals_Call) Run(run func()) *ORM_ListJobProposals_Call
func (*ORM_ListJobProposals_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ORM_ListJobProposals_Call) RunAndReturn(run func() ([]feeds.JobProposal, error)) *ORM_ListJobProposals_Call
type ORM_ListManagersByIDs_Call ¶ added in v1.13.0
ORM_ListManagersByIDs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListManagersByIDs'
func (*ORM_ListManagersByIDs_Call) Return ¶ added in v1.13.0
func (_c *ORM_ListManagersByIDs_Call) Return(_a0 []feeds.FeedsManager, _a1 error) *ORM_ListManagersByIDs_Call
func (*ORM_ListManagersByIDs_Call) Run ¶ added in v1.13.0
func (_c *ORM_ListManagersByIDs_Call) Run(run func(ids []int64)) *ORM_ListManagersByIDs_Call
func (*ORM_ListManagersByIDs_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ORM_ListManagersByIDs_Call) RunAndReturn(run func([]int64) ([]feeds.FeedsManager, error)) *ORM_ListManagersByIDs_Call
type ORM_ListManagers_Call ¶ added in v1.13.0
ORM_ListManagers_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListManagers'
func (*ORM_ListManagers_Call) Return ¶ added in v1.13.0
func (_c *ORM_ListManagers_Call) Return(mgrs []feeds.FeedsManager, err error) *ORM_ListManagers_Call
func (*ORM_ListManagers_Call) Run ¶ added in v1.13.0
func (_c *ORM_ListManagers_Call) Run(run func()) *ORM_ListManagers_Call
func (*ORM_ListManagers_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ORM_ListManagers_Call) RunAndReturn(run func() ([]feeds.FeedsManager, error)) *ORM_ListManagers_Call
type ORM_ListSpecsByJobProposalIDs_Call ¶ added in v1.13.0
ORM_ListSpecsByJobProposalIDs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListSpecsByJobProposalIDs'
func (*ORM_ListSpecsByJobProposalIDs_Call) Return ¶ added in v1.13.0
func (_c *ORM_ListSpecsByJobProposalIDs_Call) Return(_a0 []feeds.JobProposalSpec, _a1 error) *ORM_ListSpecsByJobProposalIDs_Call
func (*ORM_ListSpecsByJobProposalIDs_Call) Run ¶ added in v1.13.0
func (_c *ORM_ListSpecsByJobProposalIDs_Call) Run(run func(ids []int64, qopts ...pg.QOpt)) *ORM_ListSpecsByJobProposalIDs_Call
func (*ORM_ListSpecsByJobProposalIDs_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ORM_ListSpecsByJobProposalIDs_Call) RunAndReturn(run func([]int64, ...pg.QOpt) ([]feeds.JobProposalSpec, error)) *ORM_ListSpecsByJobProposalIDs_Call
type ORM_RejectSpec_Call ¶ added in v1.13.0
ORM_RejectSpec_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RejectSpec'
func (*ORM_RejectSpec_Call) Return ¶ added in v1.13.0
func (_c *ORM_RejectSpec_Call) Return(_a0 error) *ORM_RejectSpec_Call
func (*ORM_RejectSpec_Call) Run ¶ added in v1.13.0
func (_c *ORM_RejectSpec_Call) Run(run func(id int64, qopts ...pg.QOpt)) *ORM_RejectSpec_Call
func (*ORM_RejectSpec_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ORM_RejectSpec_Call) RunAndReturn(run func(int64, ...pg.QOpt) error) *ORM_RejectSpec_Call
type ORM_UpdateChainConfig_Call ¶ added in v1.13.0
ORM_UpdateChainConfig_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateChainConfig'
func (*ORM_UpdateChainConfig_Call) Return ¶ added in v1.13.0
func (_c *ORM_UpdateChainConfig_Call) Return(_a0 int64, _a1 error) *ORM_UpdateChainConfig_Call
func (*ORM_UpdateChainConfig_Call) Run ¶ added in v1.13.0
func (_c *ORM_UpdateChainConfig_Call) Run(run func(cfg feeds.ChainConfig)) *ORM_UpdateChainConfig_Call
func (*ORM_UpdateChainConfig_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ORM_UpdateChainConfig_Call) RunAndReturn(run func(feeds.ChainConfig) (int64, error)) *ORM_UpdateChainConfig_Call
type ORM_UpdateJobProposalStatus_Call ¶ added in v1.13.0
ORM_UpdateJobProposalStatus_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateJobProposalStatus'
func (*ORM_UpdateJobProposalStatus_Call) Return ¶ added in v1.13.0
func (_c *ORM_UpdateJobProposalStatus_Call) Return(_a0 error) *ORM_UpdateJobProposalStatus_Call
func (*ORM_UpdateJobProposalStatus_Call) Run ¶ added in v1.13.0
func (_c *ORM_UpdateJobProposalStatus_Call) Run(run func(id int64, status feeds.JobProposalStatus, qopts ...pg.QOpt)) *ORM_UpdateJobProposalStatus_Call
func (*ORM_UpdateJobProposalStatus_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ORM_UpdateJobProposalStatus_Call) RunAndReturn(run func(int64, feeds.JobProposalStatus, ...pg.QOpt) error) *ORM_UpdateJobProposalStatus_Call
type ORM_UpdateManager_Call ¶ added in v1.13.0
ORM_UpdateManager_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateManager'
func (*ORM_UpdateManager_Call) Return ¶ added in v1.13.0
func (_c *ORM_UpdateManager_Call) Return(_a0 error) *ORM_UpdateManager_Call
func (*ORM_UpdateManager_Call) Run ¶ added in v1.13.0
func (_c *ORM_UpdateManager_Call) Run(run func(mgr feeds.FeedsManager, qopts ...pg.QOpt)) *ORM_UpdateManager_Call
func (*ORM_UpdateManager_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ORM_UpdateManager_Call) RunAndReturn(run func(feeds.FeedsManager, ...pg.QOpt) error) *ORM_UpdateManager_Call
type ORM_UpdateSpecDefinition_Call ¶ added in v1.13.0
ORM_UpdateSpecDefinition_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateSpecDefinition'
func (*ORM_UpdateSpecDefinition_Call) Return ¶ added in v1.13.0
func (_c *ORM_UpdateSpecDefinition_Call) Return(_a0 error) *ORM_UpdateSpecDefinition_Call
func (*ORM_UpdateSpecDefinition_Call) Run ¶ added in v1.13.0
func (_c *ORM_UpdateSpecDefinition_Call) Run(run func(id int64, spec string, qopts ...pg.QOpt)) *ORM_UpdateSpecDefinition_Call
func (*ORM_UpdateSpecDefinition_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ORM_UpdateSpecDefinition_Call) RunAndReturn(run func(int64, string, ...pg.QOpt) error) *ORM_UpdateSpecDefinition_Call
type ORM_UpsertJobProposal_Call ¶ added in v1.13.0
ORM_UpsertJobProposal_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpsertJobProposal'
func (*ORM_UpsertJobProposal_Call) Return ¶ added in v1.13.0
func (_c *ORM_UpsertJobProposal_Call) Return(_a0 int64, _a1 error) *ORM_UpsertJobProposal_Call
func (*ORM_UpsertJobProposal_Call) Run ¶ added in v1.13.0
func (_c *ORM_UpsertJobProposal_Call) Run(run func(jp *feeds.JobProposal, qopts ...pg.QOpt)) *ORM_UpsertJobProposal_Call
func (*ORM_UpsertJobProposal_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ORM_UpsertJobProposal_Call) RunAndReturn(run func(*feeds.JobProposal, ...pg.QOpt) (int64, error)) *ORM_UpsertJobProposal_Call
type Service ¶
Service is an autogenerated mock type for the Service type
func NewService ¶ added in v1.6.0
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 ¶ added in v1.2.0
ApproveSpec provides a mock function with given fields: ctx, id, force
func (*Service) CancelSpec ¶ added in v1.2.0
CancelSpec provides a mock function with given fields: ctx, id
func (*Service) CountJobProposalsByStatus ¶ added in v1.12.0
func (_m *Service) CountJobProposalsByStatus() (*feeds.JobProposalCounts, error)
CountJobProposalsByStatus provides a mock function with given fields:
func (*Service) CountManagers ¶
CountManagers provides a mock function with given fields:
func (*Service) CreateChainConfig ¶ added in v1.5.0
CreateChainConfig provides a mock function with given fields: ctx, cfg
func (*Service) DeleteChainConfig ¶ added in v1.5.0
DeleteChainConfig provides a mock function with given fields: ctx, id
func (*Service) GetChainConfig ¶ added in v1.5.0
func (_m *Service) GetChainConfig(id int64) (*feeds.ChainConfig, error)
GetChainConfig provides a mock function with given fields: id
func (*Service) GetJobProposal ¶ added in v0.10.11
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 ¶ added in v1.2.0
func (_m *Service) GetSpec(id int64) (*feeds.JobProposalSpec, error)
GetSpec provides a mock function with given fields: id
func (*Service) IsJobManaged ¶ added in v1.1.0
IsJobManaged provides a mock function with given fields: ctx, jobID
func (*Service) ListChainConfigsByManagerIDs ¶ added in v1.5.0
func (_m *Service) ListChainConfigsByManagerIDs(mgrIDs []int64) ([]feeds.ChainConfig, error)
ListChainConfigsByManagerIDs provides a mock function with given fields: mgrIDs
func (*Service) ListJobProposals ¶ added in v0.10.11
func (_m *Service) ListJobProposals() ([]feeds.JobProposal, error)
ListJobProposals provides a mock function with given fields:
func (*Service) ListJobProposalsByManagersIDs ¶ added in v1.2.0
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 ¶ added in v1.2.0
func (_m *Service) ListManagersByIDs(ids []int64) ([]feeds.FeedsManager, error)
ListManagersByIDs provides a mock function with given fields: ids
func (*Service) ListSpecsByJobProposalIDs ¶ added in v1.2.0
func (_m *Service) ListSpecsByJobProposalIDs(ids []int64) ([]feeds.JobProposalSpec, error)
ListSpecsByJobProposalIDs provides a mock function with given fields: ids
func (*Service) ProposeJob ¶ added in v1.0.0
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 ¶ added in v1.2.0
RejectSpec provides a mock function with given fields: ctx, id
func (*Service) SyncNodeInfo ¶ added in v0.10.10
SyncNodeInfo provides a mock function with given fields: ctx, id
func (*Service) Unsafe_SetConnectionsManager ¶ added in v1.0.0
func (_m *Service) Unsafe_SetConnectionsManager(_a0 feeds.ConnectionsManager)
Unsafe_SetConnectionsManager provides a mock function with given fields: _a0
func (*Service) UpdateChainConfig ¶ added in v1.5.0
UpdateChainConfig provides a mock function with given fields: ctx, cfg
func (*Service) UpdateManager ¶ added in v1.2.0
UpdateManager provides a mock function with given fields: ctx, mgr