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) ExistsSpecByJobProposalIDAndVersion(jpID int64, version int32, qopts ...pg.QOpt) (bool, 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 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) 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) 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 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