Versions in this module Expand all Collapse all v0 v0.5.0 Jun 23, 2023 v0.4.0 Jun 22, 2023 v0.3.0 Jun 22, 2023 v0.2.0 Jun 22, 2023 Changes in this version + const JobTypeFluxMonitor + const JobTypeOffchainReporting + const JobTypeOffchainReporting2 + var ErrFeedsManagerDisabled = errors.New("feeds manager is disabled") + var ErrJobAlreadyExists = errors.New(...) + var ErrOCR2Disabled = errors.New("ocr2 is disabled") + var ErrOCRDisabled = errors.New("ocr is disabled") + var ErrSingleFeedsManager = errors.New("only a single feeds manager is supported") + func NewORM(db *sqlx.DB, lggr logger.Logger, cfg pg.QConfig) *orm + func NewService(orm ORM, jobORM job.ORM, db *sqlx.DB, jobSpawner job.Spawner, ...) *service + type ChainConfig struct + AccountAddress string + AdminAddress string + ChainID string + ChainType ChainType + CreatedAt time.Time + FeedsManagerID int64 + FluxMonitorConfig FluxMonitorConfig + ID int64 + OCR1Config OCR1Config + OCR2Config OCR2Config + UpdatedAt time.Time + type ChainType string + const ChainTypeEVM + const ChainTypeUnknown + func NewChainType(s string) (ChainType, error) + type Config interface + DefaultHTTPTimeout func() models.Duration + Dev func() bool + FeatureOffchainReporting func() bool + FeatureOffchainReporting2 func() bool + JobPipelineMaxSuccessfulRuns func() uint64 + JobPipelineResultWriteQueueDepth func() uint64 + type ConnectOpts struct + FeedsManagerID int64 + Handlers pb.NodeServiceServer + OnConnect func(pb.FeedsManagerClient) + Privkey []byte + Pubkey []byte + URI string + type ConnectionsManager interface + Close func() + Connect func(opts ConnectOpts) + Disconnect func(id int64) error + GetClient func(id int64) (pb.FeedsManagerClient, error) + IsConnected func(id int64) bool + type FeedsManager struct + CreatedAt time.Time + ID int64 + IsConnectionActive bool + Name string + PublicKey crypto.PublicKey + URI string + UpdatedAt time.Time + type FluxMonitorConfig struct + Enabled bool + func (c *FluxMonitorConfig) Scan(value interface{}) error + func (c FluxMonitorConfig) Value() (driver.Value, error) + type JobProposal struct + CreatedAt time.Time + ExternalJobID uuid.NullUUID + FeedsManagerID int64 + ID int64 + Multiaddrs pq.StringArray + Name null.String + PendingUpdate bool + RemoteUUID uuid.UUID + Status JobProposalStatus + UpdatedAt time.Time + type JobProposalCounts struct + Approved int64 + Cancelled int64 + Pending int64 + Rejected int64 + type JobProposalSpec struct + CreatedAt time.Time + Definition string + ID int64 + JobProposalID int64 + Status SpecStatus + StatusUpdatedAt time.Time + UpdatedAt time.Time + Version int32 + func (s *JobProposalSpec) CanEditDefinition() bool + type JobProposalStatus string + const JobProposalStatusApproved + const JobProposalStatusCancelled + const JobProposalStatusPending + const JobProposalStatusRejected + type NullService struct + func (ns NullService) ApproveJobProposal(ctx context.Context, id int64) error + func (ns NullService) ApproveSpec(ctx context.Context, id int64, force bool) error + func (ns NullService) CancelSpec(ctx context.Context, id int64) error + func (ns NullService) Close() error + func (ns NullService) CountJobProposalsByStatus() (*JobProposalCounts, error) + func (ns NullService) CountManagers() (int64, error) + func (ns NullService) CreateChainConfig(ctx context.Context, cfg ChainConfig) (int64, error) + func (ns NullService) CreateJobProposal(jp *JobProposal) (int64, error) + func (ns NullService) DeleteChainConfig(ctx context.Context, id int64) (int64, error) + func (ns NullService) GetChainConfig(id int64) (*ChainConfig, error) + func (ns NullService) GetJobProposal(id int64) (*JobProposal, error) + func (ns NullService) GetManager(id int64) (*FeedsManager, error) + func (ns NullService) GetSpec(id int64) (*JobProposalSpec, error) + func (ns NullService) IsJobManaged(ctx context.Context, jobID int64) (bool, error) + func (ns NullService) ListChainConfigsByManagerIDs(mgrIDs []int64) ([]ChainConfig, error) + func (ns NullService) ListJobProposals() ([]JobProposal, error) + func (ns NullService) ListJobProposalsByManagersIDs(ids []int64) ([]JobProposal, error) + func (ns NullService) ListManagers() ([]FeedsManager, error) + func (ns NullService) ListManagersByIDs(ids []int64) ([]FeedsManager, error) + func (ns NullService) ListSpecsByJobProposalIDs(ids []int64) ([]JobProposalSpec, error) + func (ns NullService) ProposeJob(ctx context.Context, args *ProposeJobArgs) (int64, error) + func (ns NullService) RegisterManager(ctx context.Context, params RegisterManagerParams) (int64, error) + func (ns NullService) RejectSpec(ctx context.Context, id int64) error + func (ns NullService) Start(ctx context.Context) error + func (ns NullService) SyncNodeInfo(ctx context.Context, id int64) error + func (ns NullService) Unsafe_SetConnectionsManager(_ ConnectionsManager) + func (ns NullService) UpdateChainConfig(ctx context.Context, cfg ChainConfig) (int64, error) + func (ns NullService) UpdateJobProposalSpec(ctx context.Context, id int64, spec string) error + func (ns NullService) UpdateManager(ctx context.Context, mgr FeedsManager) error + func (ns NullService) UpdateSpecDefinition(ctx context.Context, id int64, spec string) error + type OCR1Config struct + Enabled bool + IsBootstrap bool + KeyBundleID null.String + Multiaddr null.String + P2PPeerID null.String + func (c *OCR1Config) Scan(value interface{}) error + func (c OCR1Config) Value() (driver.Value, error) + type OCR2Config struct + Enabled bool + IsBootstrap bool + KeyBundleID null.String + Multiaddr null.String + P2PPeerID null.String + func (c *OCR2Config) Scan(value interface{}) error + func (c OCR2Config) Value() (driver.Value, error) + type ORM interface + ApproveSpec func(id int64, externalJobID uuid.UUID, qopts ...pg.QOpt) error + CancelSpec func(id int64, qopts ...pg.QOpt) error + CountJobProposals func() (int64, error) + CountJobProposalsByStatus func() (counts *JobProposalCounts, err error) + CountManagers func() (int64, error) + CreateBatchChainConfig func(cfgs []ChainConfig, qopts ...pg.QOpt) ([]int64, error) + CreateChainConfig func(cfg ChainConfig, qopts ...pg.QOpt) (int64, error) + CreateJobProposal func(jp *JobProposal) (int64, error) + CreateManager func(ms *FeedsManager, qopts ...pg.QOpt) (int64, error) + CreateSpec func(spec JobProposalSpec, qopts ...pg.QOpt) (int64, error) + DeleteChainConfig func(id int64) (int64, error) + ExistsSpecByJobProposalIDAndVersion func(jpID int64, version int32, qopts ...pg.QOpt) (exists bool, err error) + GetApprovedSpec func(jpID int64, qopts ...pg.QOpt) (*JobProposalSpec, error) + GetChainConfig func(id int64) (*ChainConfig, error) + GetJobProposal func(id int64, qopts ...pg.QOpt) (*JobProposal, error) + GetJobProposalByRemoteUUID func(uuid uuid.UUID) (*JobProposal, error) + GetLatestSpec func(jpID int64) (*JobProposalSpec, error) + GetManager func(id int64) (*FeedsManager, error) + GetSpec func(id int64, qopts ...pg.QOpt) (*JobProposalSpec, error) + IsJobManaged func(jobID int64, qopts ...pg.QOpt) (bool, error) + ListChainConfigsByManagerIDs func(mgrIDs []int64) ([]ChainConfig, error) + ListJobProposals func() (jps []JobProposal, err error) + ListJobProposalsByManagersIDs func(ids []int64, qopts ...pg.QOpt) ([]JobProposal, error) + ListManagers func() (mgrs []FeedsManager, err error) + ListManagersByIDs func(ids []int64) ([]FeedsManager, error) + ListSpecsByJobProposalIDs func(ids []int64, qopts ...pg.QOpt) ([]JobProposalSpec, error) + RejectSpec func(id int64, qopts ...pg.QOpt) error + UpdateChainConfig func(cfg ChainConfig) (int64, error) + UpdateJobProposalStatus func(id int64, status JobProposalStatus, qopts ...pg.QOpt) error + UpdateManager func(mgr FeedsManager, qopts ...pg.QOpt) error + UpdateSpecDefinition func(id int64, spec string, qopts ...pg.QOpt) error + UpsertJobProposal func(jp *JobProposal, qopts ...pg.QOpt) (int64, error) + type ProposeJobArgs struct + FeedsManagerID int64 + Multiaddrs pq.StringArray + RemoteUUID uuid.UUID + Spec string + Version int32 + type RPCHandlers struct + func NewRPCHandlers(svc Service, feedsManagerID int64) *RPCHandlers + func (h *RPCHandlers) ProposeJob(ctx context.Context, req *pb.ProposeJobRequest) (*pb.ProposeJobResponse, error) + type RegisterManagerParams struct + ChainConfigs []ChainConfig + Name string + PublicKey crypto.PublicKey + URI string + type Service interface + ApproveSpec func(ctx context.Context, id int64, force bool) error + CancelSpec func(ctx context.Context, id int64) error + Close func() error + CountJobProposalsByStatus func() (*JobProposalCounts, error) + CountManagers func() (int64, error) + CreateChainConfig func(ctx context.Context, cfg ChainConfig) (int64, error) + DeleteChainConfig func(ctx context.Context, id int64) (int64, error) + GetChainConfig func(id int64) (*ChainConfig, error) + GetJobProposal func(id int64) (*JobProposal, error) + GetManager func(id int64) (*FeedsManager, error) + GetSpec func(id int64) (*JobProposalSpec, error) + IsJobManaged func(ctx context.Context, jobID int64) (bool, error) + ListChainConfigsByManagerIDs func(mgrIDs []int64) ([]ChainConfig, error) + ListJobProposals func() ([]JobProposal, error) + ListJobProposalsByManagersIDs func(ids []int64) ([]JobProposal, error) + ListManagers func() ([]FeedsManager, error) + ListManagersByIDs func(ids []int64) ([]FeedsManager, error) + ListSpecsByJobProposalIDs func(ids []int64) ([]JobProposalSpec, error) + ProposeJob func(ctx context.Context, args *ProposeJobArgs) (int64, error) + RegisterManager func(ctx context.Context, params RegisterManagerParams) (int64, error) + RejectSpec func(ctx context.Context, id int64) error + Start func(ctx context.Context) error + SyncNodeInfo func(ctx context.Context, id int64) error + Unsafe_SetConnectionsManager func(ConnectionsManager) + UpdateChainConfig func(ctx context.Context, cfg ChainConfig) (int64, error) + UpdateManager func(ctx context.Context, mgr FeedsManager) error + UpdateSpecDefinition func(ctx context.Context, id int64, spec string) error + type SpecStatus string + const SpecStatusApproved + const SpecStatusCancelled + const SpecStatusPending + const SpecStatusRejected
Go to main page