Documentation
¶
Index ¶
- type Config
- func (_m *Config) Chain() *chains.Chain
- func (_m *Config) ChainID() *big.Int
- func (_m *Config) DefaultHTTPTimeout() models.Duration
- func (_m *Config) Dev() bool
- func (_m *Config) FeatureOffchainReporting() bool
- func (_m *Config) OCRBlockchainTimeout() time.Duration
- func (_m *Config) OCRContractConfirmations() uint16
- func (_m *Config) OCRContractPollInterval() time.Duration
- func (_m *Config) OCRContractSubscribeInterval() time.Duration
- func (_m *Config) OCRContractTransmitterTransmitTimeout() time.Duration
- func (_m *Config) OCRDatabaseTimeout() time.Duration
- func (_m *Config) OCRObservationGracePeriod() time.Duration
- func (_m *Config) OCRObservationTimeout() time.Duration
- type ConnectionsManager
- type FeedsManagerClient
- func (_m *FeedsManagerClient) ApprovedJob(ctx context.Context, in *proto.ApprovedJobRequest) (*proto.ApprovedJobResponse, 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) ApproveJobProposal(ctx context.Context, id int64, externalJobID uuid.UUID, ...) error
- func (_m *ORM) CountJobProposals(ctx context.Context) (int64, error)
- func (_m *ORM) CountManagers(ctx context.Context) (int64, error)
- func (_m *ORM) CreateJobProposal(ctx context.Context, jp *feeds.JobProposal) (int64, error)
- func (_m *ORM) CreateManager(ctx context.Context, ms *feeds.FeedsManager) (int64, error)
- func (_m *ORM) GetJobProposal(ctx context.Context, id int64) (*feeds.JobProposal, error)
- func (_m *ORM) GetJobProposalByRemoteUUID(ctx context.Context, _a1 uuid.UUID) (*feeds.JobProposal, error)
- func (_m *ORM) GetManager(ctx context.Context, id int64) (*feeds.FeedsManager, error)
- func (_m *ORM) ListJobProposals(ctx context.Context) ([]feeds.JobProposal, error)
- func (_m *ORM) ListManagers(ctx context.Context) ([]feeds.FeedsManager, error)
- func (_m *ORM) UpdateJobProposalSpec(ctx context.Context, id int64, spec string) error
- func (_m *ORM) UpdateJobProposalStatus(ctx context.Context, id int64, status feeds.JobProposalStatus) error
- func (_m *ORM) UpdateManager(ctx context.Context, mgr feeds.FeedsManager) error
- func (_m *ORM) UpsertJobProposal(ctx context.Context, jp *feeds.JobProposal) (int64, error)
- type Service
- func (_m *Service) ApproveJobProposal(ctx context.Context, id int64) error
- func (_m *Service) Close() error
- func (_m *Service) CountManagers() (int64, error)
- func (_m *Service) CreateJobProposal(jp *feeds.JobProposal) (int64, error)
- func (_m *Service) GetJobProposal(id int64) (*feeds.JobProposal, error)
- func (_m *Service) GetManager(id int64) (*feeds.FeedsManager, error)
- func (_m *Service) ListJobProposals() ([]feeds.JobProposal, error)
- func (_m *Service) ListManagers() ([]feeds.FeedsManager, error)
- func (_m *Service) ProposeJob(jp *feeds.JobProposal) (int64, error)
- func (_m *Service) RegisterManager(ms *feeds.FeedsManager) (int64, error)
- func (_m *Service) RejectJobProposal(ctx context.Context, id int64) error
- func (_m *Service) Start() error
- func (_m *Service) SyncNodeInfo(id int64) error
- func (_m *Service) Unsafe_SetConnectionsManager(_a0 feeds.ConnectionsManager)
- func (_m *Service) UpdateFeedsManager(ctx context.Context, mgr feeds.FeedsManager) error
- func (_m *Service) UpdateJobProposalSpec(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 (*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) OCRBlockchainTimeout ¶ added in v0.10.11
OCRBlockchainTimeout provides a mock function with given fields:
func (*Config) OCRContractConfirmations ¶ added in v0.10.11
OCRContractConfirmations provides a mock function with given fields:
func (*Config) OCRContractPollInterval ¶ added in v0.10.11
OCRContractPollInterval provides a mock function with given fields:
func (*Config) OCRContractSubscribeInterval ¶ added in v0.10.11
OCRContractSubscribeInterval provides a mock function with given fields:
func (*Config) OCRContractTransmitterTransmitTimeout ¶ added in v0.10.11
OCRContractTransmitterTransmitTimeout provides a mock function with given fields:
func (*Config) OCRDatabaseTimeout ¶ added in v0.10.11
OCRDatabaseTimeout provides a mock function with given fields:
func (*Config) OCRObservationGracePeriod ¶ added in v0.10.11
OCRObservationGracePeriod provides a mock function with given fields:
func (*Config) OCRObservationTimeout ¶ added in v0.10.11
OCRObservationTimeout 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 (*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 (*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) 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 (*ORM) ApproveJobProposal ¶ added in v0.10.11
func (_m *ORM) ApproveJobProposal(ctx context.Context, id int64, externalJobID uuid.UUID, status feeds.JobProposalStatus) error
ApproveJobProposal provides a mock function with given fields: ctx, id, externalJobID, status
func (*ORM) CountJobProposals ¶ added in v0.10.9
CountJobProposals provides a mock function with given fields: ctx
func (*ORM) CountManagers ¶
CountManagers provides a mock function with given fields: ctx
func (*ORM) CreateJobProposal ¶ added in v0.10.9
CreateJobProposal provides a mock function with given fields: ctx, jp
func (*ORM) CreateManager ¶
CreateManager provides a mock function with given fields: ctx, ms
func (*ORM) GetJobProposal ¶ added in v0.10.9
GetJobProposal provides a mock function with given fields: ctx, id
func (*ORM) GetJobProposalByRemoteUUID ¶ added in v1.0.0
func (_m *ORM) GetJobProposalByRemoteUUID(ctx context.Context, _a1 uuid.UUID) (*feeds.JobProposal, error)
GetJobProposalByRemoteUUID provides a mock function with given fields: ctx, _a1
func (*ORM) GetManager ¶
GetManager provides a mock function with given fields: ctx, id
func (*ORM) ListJobProposals ¶ added in v0.10.9
ListJobProposals provides a mock function with given fields: ctx
func (*ORM) ListManagers ¶
ListManagers provides a mock function with given fields: ctx
func (*ORM) UpdateJobProposalSpec ¶ added in v0.10.11
UpdateJobProposalSpec provides a mock function with given fields: ctx, id, spec
func (*ORM) UpdateJobProposalStatus ¶ added in v0.10.11
func (_m *ORM) UpdateJobProposalStatus(ctx context.Context, id int64, status feeds.JobProposalStatus) error
UpdateJobProposalStatus provides a mock function with given fields: ctx, id, status
func (*ORM) UpdateManager ¶ added in v1.0.0
UpdateManager provides a mock function with given fields: ctx, mgr
func (*ORM) UpsertJobProposal ¶ added in v1.0.0
UpsertJobProposal provides a mock function with given fields: ctx, jp
type Service ¶
Service is an autogenerated mock type for the Service type
func (*Service) ApproveJobProposal ¶ added in v0.10.11
ApproveJobProposal provides a mock function with given fields: ctx, id
func (*Service) CountManagers ¶
CountManagers provides a mock function with given fields:
func (*Service) CreateJobProposal ¶ added in v0.10.9
func (_m *Service) CreateJobProposal(jp *feeds.JobProposal) (int64, error)
CreateJobProposal provides a mock function with given fields: jp
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) ListJobProposals ¶ added in v0.10.11
func (_m *Service) ListJobProposals() ([]feeds.JobProposal, error)
ListJobProposals provides a mock function with given fields:
func (*Service) ListManagers ¶
func (_m *Service) ListManagers() ([]feeds.FeedsManager, error)
ListManagers provides a mock function with given fields:
func (*Service) ProposeJob ¶ added in v1.0.0
func (_m *Service) ProposeJob(jp *feeds.JobProposal) (int64, error)
ProposeJob provides a mock function with given fields: jp
func (*Service) RegisterManager ¶
func (_m *Service) RegisterManager(ms *feeds.FeedsManager) (int64, error)
RegisterManager provides a mock function with given fields: ms
func (*Service) RejectJobProposal ¶ added in v0.10.11
RejectJobProposal 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: 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) UpdateFeedsManager ¶ added in v1.0.0
UpdateFeedsManager provides a mock function with given fields: ctx, mgr