Versions in this module Expand all Collapse all v1 v1.10.17 Oct 18, 2021 Changes in this version + 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 + IsConnectionActive bool type JobProposal + Multiaddrs pq.StringArray + ProposedAt time.Time + func (jp *JobProposal) CanEditSpec() bool type JobProposalStatus + const JobProposalStatusCancelled type ORM + CancelJobProposal func(ctx context.Context, id int64) error + GetJobProposalByRemoteUUID func(ctx context.Context, uuid uuid.UUID) (*JobProposal, error) + IsJobManaged func(ctx context.Context, jobID int64) (bool, error) + UpdateManager func(ctx context.Context, mgr FeedsManager) error + UpsertJobProposal func(ctx context.Context, jp *JobProposal) (int64, error) type Service + CancelJobProposal func(ctx context.Context, id int64) error + IsJobManaged func(ctx context.Context, jobID int64) (bool, error) + ProposeJob func(jp *JobProposal) (int64, error) + Unsafe_SetConnectionsManager func(ConnectionsManager) + UpdateFeedsManager func(ctx context.Context, mgr FeedsManager) error v1.10.16 Oct 18, 2021 Changes in this version + const JobTypeFluxMonitor + const JobTypeOffchainReporting + var ErrOCRDisabled = errors.New("ocr is disabled") + func NewORM(db *gorm.DB) *orm + func NewService(orm ORM, txm postgres.TransactionManager, jobSpawner job.Spawner, ...) *service + type Config interface + ChainID func() *big.Int + DefaultHTTPTimeout func() models.Duration + Dev func() bool + FeatureOffchainReporting func() bool + OCRBlockchainTimeout func(override time.Duration) time.Duration + OCRContractConfirmations func(override uint16) uint16 + OCRContractPollInterval func(override time.Duration) time.Duration + OCRContractSubscribeInterval func(override time.Duration) time.Duration + OCRContractTransmitterTransmitTimeout func() time.Duration + OCRDatabaseTimeout func() time.Duration + OCRObservationGracePeriod func() time.Duration + OCRObservationTimeout func(override time.Duration) time.Duration + type FeedsManager struct + CreatedAt time.Time + ID int64 + IsOCRBootstrapPeer bool + JobTypes pq.StringArray + Name string + OCRBootstrapPeerMultiaddr null.String + PublicKey crypto.PublicKey + URI string + UpdatedAt time.Time + func (FeedsManager) TableName() string + type JobProposal struct + CreatedAt time.Time + ExternalJobID uuid.NullUUID + FeedsManagerID int64 + ID int64 + RemoteUUID uuid.UUID + Spec string + Status JobProposalStatus + UpdatedAt time.Time + type JobProposalStatus string + const JobProposalStatusApproved + const JobProposalStatusPending + const JobProposalStatusRejected + type ORM interface + ApproveJobProposal func(ctx context.Context, id int64, externalJobID uuid.UUID, ...) error + CountJobProposals func() (int64, error) + CountManagers func() (int64, error) + CreateJobProposal func(ctx context.Context, jp *JobProposal) (int64, error) + CreateManager func(ctx context.Context, ms *FeedsManager) (int64, error) + GetJobProposal func(ctx context.Context, id int64) (*JobProposal, error) + GetManager func(ctx context.Context, id int64) (*FeedsManager, error) + ListJobProposals func(ctx context.Context) ([]JobProposal, error) + ListManagers func(ctx context.Context) ([]FeedsManager, error) + UpdateJobProposalSpec func(ctx context.Context, id int64, spec string) error + UpdateJobProposalStatus func(ctx context.Context, id int64, status JobProposalStatus) error + type RPCHandlers struct + func NewRPCHandlers(svc Service, feedsManagerID int64) *RPCHandlers + func (h *RPCHandlers) ProposeJob(ctx context.Context, req *pb.ProposeJobRequest) (*pb.ProposeJobResponse, error) + type Service interface + ApproveJobProposal func(ctx context.Context, id int64) error + Close func() error + CountManagers func() (int64, error) + CreateJobProposal func(jp *JobProposal) (int64, error) + GetJobProposal func(id int64) (*JobProposal, error) + GetManager func(id int64) (*FeedsManager, error) + ListJobProposals func() ([]JobProposal, error) + ListManagers func() ([]FeedsManager, error) + RegisterManager func(ms *FeedsManager) (int64, error) + RejectJobProposal func(ctx context.Context, id int64) error + Start func() error + SyncNodeInfo func(id int64) error + Unsafe_SetFMSClient func(pb.FeedsManagerClient) + UpdateJobProposalSpec func(ctx context.Context, id int64, spec string) error