Documentation ¶
Index ¶
- type Config
- 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) 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) ApproveJobProposal(ctx context.Context, id int64, externalJobID uuid.UUID, ...) error
- func (_m *ORM) CancelJobProposal(ctx context.Context, id int64) 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) IsJobManaged(ctx context.Context, jobID int64) (bool, 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) CancelJobProposal(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) IsJobManaged(ctx context.Context, jobID int64) (bool, 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 ¶
Config is an autogenerated mock type for the Config type
func (*Config) DefaultHTTPTimeout ¶
DefaultHTTPTimeout provides a mock function with given fields:
func (*Config) FeatureOffchainReporting ¶
FeatureOffchainReporting provides a mock function with given fields:
func (*Config) OCRBlockchainTimeout ¶
OCRBlockchainTimeout provides a mock function with given fields:
func (*Config) OCRContractConfirmations ¶
OCRContractConfirmations provides a mock function with given fields:
func (*Config) OCRContractPollInterval ¶
OCRContractPollInterval provides a mock function with given fields:
func (*Config) OCRContractSubscribeInterval ¶
OCRContractSubscribeInterval provides a mock function with given fields:
func (*Config) OCRContractTransmitterTransmitTimeout ¶
OCRContractTransmitterTransmitTimeout provides a mock function with given fields:
func (*Config) OCRDatabaseTimeout ¶
OCRDatabaseTimeout provides a mock function with given fields:
func (*Config) OCRObservationGracePeriod ¶
OCRObservationGracePeriod provides a mock function with given fields:
func (*Config) OCRObservationTimeout ¶
OCRObservationTimeout provides a mock function with given fields:
type ConnectionsManager ¶ added in v1.10.17
ConnectionsManager is an autogenerated mock type for the ConnectionsManager type
func (*ConnectionsManager) Close ¶ added in v1.10.17
func (_m *ConnectionsManager) Close()
Close provides a mock function with given fields:
func (*ConnectionsManager) Connect ¶ added in v1.10.17
func (_m *ConnectionsManager) Connect(opts feeds.ConnectOpts)
Connect provides a mock function with given fields: opts
func (*ConnectionsManager) Disconnect ¶ added in v1.10.17
func (_m *ConnectionsManager) Disconnect(id int64) error
Disconnect provides a mock function with given fields: id
func (*ConnectionsManager) GetClient ¶ added in v1.10.17
func (_m *ConnectionsManager) GetClient(id int64) (proto.FeedsManagerClient, error)
GetClient provides a mock function with given fields: id
func (*ConnectionsManager) IsConnected ¶ added in v1.10.17
func (_m *ConnectionsManager) IsConnected(id int64) bool
IsConnected provides a mock function with given fields: id
type FeedsManagerClient ¶
FeedsManagerClient is an autogenerated mock type for the FeedsManagerClient type
func (*FeedsManagerClient) ApprovedJob ¶
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.10.17
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 ¶
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 ¶
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 ¶
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) CancelJobProposal ¶ added in v1.10.17
CancelJobProposal provides a mock function with given fields: ctx, id
func (*ORM) CountJobProposals ¶
CountJobProposals provides a mock function with given fields: ctx
func (*ORM) CountManagers ¶
CountManagers provides a mock function with given fields: ctx
func (*ORM) CreateJobProposal ¶
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 ¶
GetJobProposal provides a mock function with given fields: ctx, id
func (*ORM) GetJobProposalByRemoteUUID ¶ added in v1.10.17
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) IsJobManaged ¶ added in v1.10.17
IsJobManaged provides a mock function with given fields: ctx, jobID
func (*ORM) ListJobProposals ¶
ListJobProposals provides a mock function with given fields: ctx
func (*ORM) ListManagers ¶
ListManagers provides a mock function with given fields: ctx
func (*ORM) UpdateJobProposalSpec ¶
UpdateJobProposalSpec provides a mock function with given fields: ctx, id, spec
func (*ORM) UpdateJobProposalStatus ¶
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.10.17
UpdateManager provides a mock function with given fields: ctx, mgr
func (*ORM) UpsertJobProposal ¶ added in v1.10.17
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 ¶
ApproveJobProposal provides a mock function with given fields: ctx, id
func (*Service) CancelJobProposal ¶ added in v1.10.17
CancelJobProposal provides a mock function with given fields: ctx, id
func (*Service) CountManagers ¶
CountManagers provides a mock function with given fields:
func (*Service) CreateJobProposal ¶
func (_m *Service) CreateJobProposal(jp *feeds.JobProposal) (int64, error)
CreateJobProposal provides a mock function with given fields: jp
func (*Service) GetJobProposal ¶
func (_m *Service) GetJobProposal(id int64) (*feeds.JobProposal, error)
GetJobProposal provides a mock function with given fields: id
func (*Service) GetManager ¶
func (_m *Service) GetManager(id int64) (*feeds.FeedsManager, error)
GetManager provides a mock function with given fields: id
func (*Service) IsJobManaged ¶ added in v1.10.17
IsJobManaged provides a mock function with given fields: ctx, jobID
func (*Service) ListJobProposals ¶
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.10.17
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 ¶
RejectJobProposal provides a mock function with given fields: ctx, id
func (*Service) SyncNodeInfo ¶
SyncNodeInfo provides a mock function with given fields: id
func (*Service) Unsafe_SetConnectionsManager ¶ added in v1.10.17
func (_m *Service) Unsafe_SetConnectionsManager(_a0 feeds.ConnectionsManager)
Unsafe_SetConnectionsManager provides a mock function with given fields: _a0
func (*Service) UpdateFeedsManager ¶ added in v1.10.17
UpdateFeedsManager provides a mock function with given fields: ctx, mgr