job

package

Go to main page

Versions in this module

v1

v1.10.17

Oct 18, 2021

Changes in this version

+ func ExternalJobIDEncodeBytesToTopic(id uuid.UUID) common.Hash

+ func ExternalJobIDEncodeStringToTopic(id uuid.UUID) common.Hash

type DirectRequestSpec

+ EVMChainID *utils.Big

type FluxMonitorSpec

+ EVMChainID *utils.Big

+ type FluxMonitorSpecIntThreshold struct

+ AbsoluteThreshold int

+ ContractAddress ethkey.EIP55Address

+ DrumbeatEnabled bool

+ DrumbeatRandomDelay time.Duration

+ DrumbeatSchedule string

+ IdleTimerDisabled bool

+ IdleTimerPeriod time.Duration

+ MinPayment *assets.Link

+ PollTimerDisabled bool

+ PollTimerPeriod time.Duration

+ Threshold int

type KeeperSpec

+ EVMChainID *utils.Big

+ type OCRSpecConfig interface

+ OCRBlockchainTimeout func() time.Duration

+ OCRContractConfirmations func() uint16

+ OCRContractPollInterval func() time.Duration

+ OCRContractSubscribeInterval func() time.Duration

+ OCRObservationTimeout func() time.Duration

type ORM

+ FindJobByExternalJobID func(ctx context.Context, uuid uuid.UUID) (Job, error)

type OffchainReportingOracleSpec

+ EVMChainID *utils.Big

+ func LoadDynamicConfigVars(cfg OCRSpecConfig, os OffchainReportingOracleSpec) *OffchainReportingOracleSpec

type Spawner

+ StartService func(spec Job) error

type Type

+ func (t Type) SchemaVersion() uint32

type VRFSpec

+ EVMChainID *utils.Big

v1.10.16

Oct 18, 2021

Changes in this version

+ var ErrInvalidJobType = errors.New("invalid job type")

+ var ErrInvalidSchemaVersion = errors.New("invalid schema version")

+ var ErrNoPipelineSpec = errors.New("pipeline spec not specified")

+ 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, cfg 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

+ OCRBlockchainTimeout func(time.Duration) time.Duration

+ OCRContractConfirmations func(uint16) uint16

+ OCRContractPollInterval func(time.Duration) time.Duration

+ OCRContractSubscribeInterval func(time.Duration) time.Duration

+ OCRObservationTimeout func(time.Duration) time.Duration

+ 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

+ AfterJobCreated func(spec Job)

+ BeforeJobDeleted func(spec Job)

+ JobType func() Type

+ ServicesForSpec func(spec Job) ([]Service, error)

+ type DirectRequestSpec struct

+ ContractAddress ethkey.EIP55Address

+ CreatedAt time.Time

+ ID int32

+ MinContractPayment *assets.Link

+ MinIncomingConfirmations clnull.Uint32

+ Requesters models.AddressCollection

+ UpdatedAt time.Time

+ func (DirectRequestSpec) TableName() string

+ type ExternalInitiatorWebhookSpec struct

+ ExternalInitiator models.ExternalInitiator

+ ExternalInitiatorID int64

+ Spec models.JSON

+ WebhookSpec WebhookSpec

+ WebhookSpecID int32

+ type FluxMonitorSpec struct

+ AbsoluteThreshold float32

+ ContractAddress ethkey.EIP55Address

+ CreatedAt time.Time

+ DrumbeatEnabled bool

+ DrumbeatRandomDelay time.Duration

+ DrumbeatSchedule string

+ 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

+ 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 (j *Job) SetID(value string) error

+ func (j Job) ExternalIDEncodeBytesToTopic() common.Hash

+ func (j Job) ExternalIDEncodeStringToTopic() 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) AfterJobCreated(spec Job)

+ func (*NullDelegate) BeforeJobDeleted(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) (Job, error)

+ DeleteJob func(ctx context.Context, id int32) error

+ DismissError func(ctx context.Context, errorID int32) error

+ FindJob func(ctx context.Context, id int32) (Job, error)

+ FindJobIDsWithBridge func(name string) ([]int32, error)

+ FindJobTx func(id int32) (Job, error)

+ JobsV2 func(offset, limit int) ([]Job, int, error)

+ ListenForDeletedJobs func() (postgres.Subscription, error)

+ ListenForNewJobs func() (postgres.Subscription, error)

+ PipelineRuns func(offset, size int) ([]pipeline.Run, int, 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) (Job, 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 ValidateSpec(ts string) (Type, error)

+ func (t Type) RequiresPipelineSpec() bool

+ func (t Type) String() string

+ func (t Type) SupportsAsync() bool

+ 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

+ ExternalInitiatorWebhookSpecs []ExternalInitiatorWebhookSpec

+ ID int32

+ UpdatedAt time.Time

+ func (WebhookSpec) TableName() string

+ func (w *WebhookSpec) SetID(value string) error

+ func (w WebhookSpec) GetID() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL