Versions in this module Expand all Collapse all v0 v0.0.2 Mar 12, 2021 Changes in this version + var ErrNoSuchKeyBundle = errors.New("no such key bundle exists") + var ErrNoSuchPeerID = errors.New("no such peer id exists") + var ErrNoSuchTransmitterAddress = errors.New("no such transmitter address exists") + var ErrViolatesForeignKeyConstraint = errors.New("violates foreign key constraint") + func GetORMAdvisoryLockClassID(oi ORM) int32 + func GetORMClaimedJobIDs(oi ORM) (ids []int32) + func NewORM(db *gorm.DB, config *storm.Config, pipelineORM pipeline.ORM, ...) *orm + func NewSpawner(orm ORM, config Config, jobTypeDelegates map[Type]Delegate) *spawner + func SetORMClaimedJobs(oi ORM, jobs []SpecDB) + type Config interface + DatabaseMaximumTxDuration func() time.Duration + DatabaseURL func() string + JobPipelineParallelism func() uint8 + TriggerFallbackDBPollInterval func() time.Duration + type Delegate interface + JobType func() Type + ServicesForSpec func(spec SpecDB) ([]Service, error) + type DirectRequestSpec struct + ContractAddress models.EIP55Address + CreatedAt time.Time + OnChainJobSpecID gethCommon.Hash + UpdatedAt time.Time + func (DirectRequestSpec) TableName() string + type FluxMonitorSpec struct + AbsoluteThreshold float32 + ContractAddress models.EIP55Address + CreatedAt time.Time + IdleTimerDisabled bool + IdleTimerPeriod time.Duration + PollTimerDisabled bool + PollTimerPeriod time.Duration + Precision int32 + Threshold float32 + UpdatedAt time.Time + type IDEmbed struct + ID int32 + func (id *IDEmbed) SetID(value string) error + func (id IDEmbed) GetID() string + type ORM interface + CheckForDeletedJobs func(ctx context.Context) (deletedJobIDs []int32, err error) + ClaimUnclaimedJobs func(ctx context.Context) ([]SpecDB, error) + Close func() error + CreateJob func(ctx context.Context, jobSpec *SpecDB, taskDAG pipeline.TaskDAG) error + DeleteJob func(ctx context.Context, id int32) error + FindJob func(id int32) (SpecDB, error) + JobsV2 func() ([]SpecDB, error) + ListenForDeletedJobs func() (postgres.Subscription, error) + ListenForNewJobs func() (postgres.Subscription, error) + PipelineRunsByJobID func(jobID int32, offset, size int) ([]pipeline.Run, int, error) + RecordError func(ctx context.Context, jobID int32, description string) + UnclaimJob func(ctx context.Context, id int32) error + type OffchainReportingOracleSpec struct + BlockchainTimeout models.Interval + ContractAddress models.EIP55Address + ContractConfigConfirmations uint16 + ContractConfigTrackerPollInterval models.Interval + ContractConfigTrackerSubscribeInterval models.Interval + CreatedAt time.Time + EncryptedOCRKeyBundleID *models.Sha256Hash + IsBootstrapPeer bool + ObservationTimeout models.Interval + P2PBootstrapPeers pq.StringArray + P2PPeerID *models.PeerID + TransmitterAddress *models.EIP55Address + UpdatedAt time.Time + func (OffchainReportingOracleSpec) TableName() string + func (s *OffchainReportingOracleSpec) BeforeCreate(db *gorm.DB) error + func (s *OffchainReportingOracleSpec) BeforeSave(db *gorm.DB) error + func (s *OffchainReportingOracleSpec) SetID(value string) error + func (s OffchainReportingOracleSpec) GetID() string + type PipelineRun struct + ID int64 + func (pr *PipelineRun) SetID(value string) error + func (pr PipelineRun) GetID() string + type Service interface + Close func() error + Start func() error + type Spawner interface + Close func() error + CreateJob func(ctx context.Context, spec SpecDB, name null.String) (int32, error) + DeleteJob func(ctx context.Context, jobID int32) error + Start func() error + type SpecDB struct + DirectRequestSpec *DirectRequestSpec + DirectRequestSpecID *int32 + FluxMonitorSpec *FluxMonitorSpec + FluxMonitorSpecID *int32 + JobSpecErrors []SpecError + MaxTaskDuration models.Interval + Name null.String + OffchainreportingOracleSpec *OffchainReportingOracleSpec + OffchainreportingOracleSpecID *int32 + Pipeline pipeline.TaskDAG + PipelineSpec *pipeline.Spec + PipelineSpecID int32 + SchemaVersion uint32 + Type Type + func GetORMClaimedJobs(oi ORM) (claimedJobs []SpecDB) + func (SpecDB) TableName() string + type SpecError struct + CreatedAt time.Time + Description string + ID int64 + JobID int32 + Occurrences uint + UpdatedAt time.Time + func (SpecError) TableName() string + type Type string + const DirectRequest + const FluxMonitor + const OffchainReporting + func (t Type) String() string
Go to main page