Versions in this module Expand all Collapse all v0 v0.0.5 Dec 31, 2021 v0.0.4 Nov 21, 2021 v0.0.3 Oct 26, 2021 v0.0.2 Oct 11, 2021 Changes in this version + var ErrNoSuchKeyBundle = errors.New("no such key bundle exists") + var ErrNoSuchPeerID = errors.New("no such peer id exists") + var ErrNoSuchPublicKey = errors.New("no such public key 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 PreloadAllJobTypes(db *gorm.DB) *gorm.DB + func SetORMClaimedJobs(oi ORM, jobs []Job) + type Config interface + DatabaseMaximumTxDuration func() time.Duration + DatabaseURL func() url.URL + TriggerFallbackDBPollInterval func() time.Duration + type CronSpec struct + CreatedAt time.Time + CronSchedule string + ID int32 + UpdatedAt time.Time + func (CronSpec) TableName() string + func (s *CronSpec) BeforeCreate(db *gorm.DB) error + func (s *CronSpec) BeforeSave(db *gorm.DB) error + func (s *CronSpec) SetID(value string) error + func (s CronSpec) GetID() string + type Delegate interface + JobType func() Type + OnJobCreated func(spec Job) + OnJobDeleted func(spec Job) + ServicesForSpec func(spec Job) ([]Service, error) + type DirectRequestSpec struct + ContractAddress ethkey.EIP55Address + CreatedAt time.Time + ID int32 + MinIncomingConfirmations clnull.Uint32 + UpdatedAt time.Time + func (DirectRequestSpec) TableName() string + type FluxMonitorSpec struct + AbsoluteThreshold float32 + ContractAddress ethkey.EIP55Address + CreatedAt time.Time + ID int32 + IdleTimerDisabled bool + IdleTimerPeriod time.Duration + MinPayment *assets.Link + PollTimerDisabled bool + PollTimerPeriod time.Duration + Threshold float32 + UpdatedAt time.Time + type Job struct + CronSpec *CronSpec + CronSpecID *int32 + DirectRequestSpec *DirectRequestSpec + DirectRequestSpecID *int32 + ExternalInitiator *models.ExternalInitiator + ExternalJobID uuid.UUID + FluxMonitorSpec *FluxMonitorSpec + FluxMonitorSpecID *int32 + ID int32 + JobSpecErrors []SpecError + KeeperSpec *KeeperSpec + KeeperSpecID *int32 + MaxTaskDuration models.Interval + Name null.String + OffchainreportingOracleSpec *OffchainReportingOracleSpec + OffchainreportingOracleSpecID *int32 + Pipeline pipeline.Pipeline + PipelineSpec *pipeline.Spec + PipelineSpecID int32 + SchemaVersion uint32 + Type Type + VRFSpec *VRFSpec + VRFSpecID *int32 + WebhookSpec *WebhookSpec + WebhookSpecID *int32 + func GetORMClaimedJobs(oi ORM) (claimedJobs []Job) + func PopulateExternalInitiator(db *gorm.DB, jb Job) (Job, error) + func (j *Job) SetID(value string) error + func (j Job) ExternalIDToTopicHash() common.Hash + func (j Job) TableName() string + type KeeperSpec struct + ContractAddress ethkey.EIP55Address + CreatedAt time.Time + FromAddress ethkey.EIP55Address + ID int32 + UpdatedAt time.Time + type NullDelegate struct + Type Type + func (*NullDelegate) OnJobCreated(spec Job) + func (*NullDelegate) OnJobDeleted(spec Job) + func (n *NullDelegate) JobType() Type + func (n *NullDelegate) ServicesForSpec(spec Job) (s []Service, err error) + type ORM interface + CheckForDeletedJobs func(ctx context.Context) (deletedJobIDs []int32, err error) + ClaimUnclaimedJobs func(ctx context.Context) ([]Job, error) + Close func() error + CreateJob func(ctx context.Context, jobSpec *Job, pipeline pipeline.Pipeline) error + DeleteJob func(ctx context.Context, id int32) error + FindJob func(id int32) (Job, error) + FindJobIDsWithBridge func(name string) ([]int32, error) + JobsV2 func() ([]Job, 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 ethkey.EIP55Address + ContractConfigConfirmations uint16 + ContractConfigTrackerPollInterval models.Interval + ContractConfigTrackerSubscribeInterval models.Interval + CreatedAt time.Time + EncryptedOCRKeyBundleID *models.Sha256Hash + ID int32 + IsBootstrapPeer bool + ObservationTimeout models.Interval + P2PBootstrapPeers pq.StringArray + P2PPeerID *p2pkey.PeerID + TransmitterAddress *ethkey.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 + ActiveJobs func() map[int32]Job + CreateJob func(ctx context.Context, spec Job, name null.String) (int32, error) + DeleteJob func(ctx context.Context, jobID int32) error + 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 Cron + const DirectRequest + const FluxMonitor + const Keeper + const OffchainReporting + const VRF + const Webhook + func (t Type) HasPipelineSpec() bool + func (t Type) String() string + type VRFSpec struct + Confirmations uint32 + CoordinatorAddress ethkey.EIP55Address + CreatedAt time.Time + ID int32 + PublicKey secp256k1.PublicKey + UpdatedAt time.Time + type WebhookSpec struct + CreatedAt time.Time + ExternalInitiatorName null.String + ExternalInitiatorSpec *models.JSON + ID int32 + UpdatedAt time.Time + func (WebhookSpec) TableName() string + func (w *WebhookSpec) BeforeCreate(db *gorm.DB) error + func (w *WebhookSpec) BeforeSave(db *gorm.DB) error + func (w *WebhookSpec) SetID(value string) error + func (w WebhookSpec) GetID() string
Go to main page