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 + type BlockhashStoreSpec struct + BlockhashStoreAddress ethkey.EIP55Address + CoordinatorV1Address *ethkey.EIP55Address + CoordinatorV2Address *ethkey.EIP55Address + CreatedAt time.Time + EVMChainID *utils.Big + FromAddresses []ethkey.EIP55Address + LookbackBlocks int32 + PollPeriod time.Duration + RunTimeout time.Duration + UpdatedAt time.Time + WaitBlocks int32 + func NewBlockhashStoreSpec(spec *job.BlockhashStoreSpec) *BlockhashStoreSpec + type BootstrapSpec struct + BlockchainTimeout models.Interval + ContractConfigConfirmations uint16 + ContractConfigTrackerPollInterval models.Interval + ContractConfigTrackerSubscribeInterval models.Interval + ContractID string + CreatedAt time.Time + Relay relay.Network + RelayConfig map[string]interface{} + UpdatedAt time.Time + func NewBootstrapSpec(spec *job.BootstrapSpec) *BootstrapSpec + type BridgeResource struct + Confirmations uint32 + CreatedAt time.Time + IncomingToken string + MinimumContractPayment *assets.Link + Name string + OutgoingToken string + URL string + func NewBridgeResource(b bridges.BridgeType) *BridgeResource + func (r BridgeResource) GetName() string + type CSAKeyResource struct + PubKey string + Version int + func NewCSAKeyResource(key csakey.KeyV2) *CSAKeyResource + func NewCSAKeyResources(keys []csakey.KeyV2) []CSAKeyResource + func (CSAKeyResource) GetName() string + type ChainResource interface + GetConfig func() C + IsEnabled func() bool + type Check struct + Name string + Output string + Status services.Status + func (c Check) GetName() string + type CronSpec struct + CreatedAt time.Time + CronSchedule string + UpdatedAt time.Time + func NewCronSpec(spec *job.CronSpec) *CronSpec + type DKGEncryptKeyResource struct + PublicKey string + func NewDKGEncryptKeyResource(key dkgencryptkey.Key) *DKGEncryptKeyResource + func NewDKGEncryptKeyResources(keys []dkgencryptkey.Key) (resources []DKGEncryptKeyResource) + func (DKGEncryptKeyResource) GetName() string + type DKGSignKeyResource struct + PublicKey string + func NewDKGSignKeyResource(key dkgsignkey.Key) *DKGSignKeyResource + func NewDKGSignKeyResources(keys []dkgsignkey.Key) (resources []DKGSignKeyResource) + func (DKGSignKeyResource) GetName() string + type DirectRequestSpec struct + ContractAddress ethkey.EIP55Address + CreatedAt time.Time + EVMChainID *utils.Big + Initiator string + MinContractPayment *assets.Link + MinIncomingConfirmations clnull.Uint32 + MinIncomingConfirmationsEnv bool + Requesters models.AddressCollection + UpdatedAt time.Time + func NewDirectRequestSpec(spec *job.DirectRequestSpec) *DirectRequestSpec + type ETHKeyResource struct + Address string + CreatedAt time.Time + Disabled bool + EVMChainID utils.Big + EthBalance *assets.Eth + LinkBalance *assets.Link + MaxGasPriceWei *utils.Big + NextNonce int64 + UpdatedAt time.Time + func NewETHKeyResource(k ethkey.KeyV2, state ethkey.State, opts ...NewETHKeyOption) *ETHKeyResource + func (r ETHKeyResource) GetName() string + type EVMChainResource struct + func NewEVMChainResource(chain evmtypes.DBChain) EVMChainResource + func (r EVMChainResource) GetConfig() C + func (r EVMChainResource) GetName() string + func (r EVMChainResource) IsEnabled() bool + type EVMForwarderResource struct + Address common.Address + CreatedAt time.Time + EVMChainID utils.Big + UpdatedAt time.Time + func NewEVMForwarderResource(fwd forwarders.Forwarder) EVMForwarderResource + func (r EVMForwarderResource) GetName() string + type EVMNodeResource struct + CreatedAt time.Time + EVMChainID utils.Big + HTTPURL null.String + Name string + State string + UpdatedAt time.Time + WSURL null.String + func NewEVMNodeResource(node evmtypes.Node) EVMNodeResource + func (r EVMNodeResource) GetName() string + type EthTxResource struct + Data hexutil.Bytes + EVMChainID utils.Big + From *common.Address + GasLimit string + GasPrice string + Hash common.Hash + Hex string + Nonce string + SentAt string + State string + To *common.Address + Value string + func NewEthTxResource(tx txmgr.EthTx) EthTxResource + func NewEthTxResourceFromAttempt(txa txmgr.EthTxAttempt) EthTxResource + func (EthTxResource) GetName() string + type ExternalInitiatorAuthentication struct + AccessKey string + Name string + OutgoingSecret string + OutgoingToken string + Secret string + URL models.WebURL + func NewExternalInitiatorAuthentication(ei bridges.ExternalInitiator, eia auth.Token) *ExternalInitiatorAuthentication + func (*ExternalInitiatorAuthentication) GetName() string + func (ei *ExternalInitiatorAuthentication) GetID() string + func (ei *ExternalInitiatorAuthentication) SetID(name string) error + type ExternalInitiatorResource struct + AccessKey string + CreatedAt time.Time + Name string + OutgoingToken string + URL *models.WebURL + UpdatedAt time.Time + func NewExternalInitiatorResource(ei bridges.ExternalInitiator) ExternalInitiatorResource + func (ExternalInitiatorResource) GetName() string + type FeatureResource struct + Enabled bool + func NewFeatureResource(name string, enabled bool) *FeatureResource + func (r FeatureResource) GetName() string + type FluxMonitorSpec struct + AbsoluteThreshold float32 + ContractAddress ethkey.EIP55Address + CreatedAt time.Time + DrumbeatEnabled bool + DrumbeatRandomDelay *string + DrumbeatSchedule *string + EVMChainID *utils.Big + IdleTimerDisabled bool + IdleTimerPeriod string + MinPayment *assets.Link + PollTimerDisabled bool + PollTimerPeriod string + Threshold float32 + UpdatedAt time.Time + func NewFluxMonitorSpec(spec *job.FluxMonitorSpec) *FluxMonitorSpec + type JAID struct + ID string + func NewJAID(id string) JAID + func NewJAIDInt32(id int32) JAID + func NewJAIDInt64(id int64) JAID + func (jaid *JAID) SetID(value string) error + func (jaid JAID) GetID() string + type JobError struct + CreatedAt time.Time + Description string + ID int64 + Occurrences uint + UpdatedAt time.Time + func NewJobError(e job.SpecError) JobError + type JobResource struct + BlockhashStoreSpec *BlockhashStoreSpec + BootstrapSpec *BootstrapSpec + CronSpec *CronSpec + DirectRequestSpec *DirectRequestSpec + Errors []JobError + ExternalJobID uuid.UUID + FluxMonitorSpec *FluxMonitorSpec + ForwardingAllowed bool + GasLimit clnull.Uint32 + KeeperSpec *KeeperSpec + MaxTaskDuration models.Interval + Name string + OffChainReporting2Spec *OffChainReporting2Spec + OffChainReportingSpec *OffChainReportingSpec + PipelineSpec PipelineSpec + SchemaVersion uint32 + Type JobSpecType + VRFSpec *VRFSpec + WebhookSpec *WebhookSpec + func NewJobResource(j job.Job) *JobResource + func (r JobResource) GetName() string + type JobSpecType string + const BlockhashStoreJobSpec + const BootstrapJobSpec + const CronJobSpec + const DirectRequestJobSpec + const FluxMonitorJobSpec + const KeeperJobSpec + const OffChainReportingJobSpec + const VRFJobSpec + const WebhookJobSpec + func (t JobSpecType) String() string + type KeeperSpec struct + ContractAddress ethkey.EIP55Address + CreatedAt time.Time + EVMChainID *utils.Big + FromAddress ethkey.EIP55Address + UpdatedAt time.Time + func NewKeeperSpec(spec *job.KeeperSpec) *KeeperSpec + type NewETHKeyOption func(*ETHKeyResource) + func SetETHKeyEthBalance(ethBalance *assets.Eth) NewETHKeyOption + func SetETHKeyLinkBalance(linkBalance *assets.Link) NewETHKeyOption + func SetETHKeyMaxGasPriceWei(maxGasPriceWei *utils.Big) NewETHKeyOption + type OCR2KeysBundleResource struct + ChainType string + ConfigPublicKey string + OffChainPublicKey string + OnchainPublicKey string + func NewOCR2KeysBundleResource(key ocr2key.KeyBundle) *OCR2KeysBundleResource + func NewOCR2KeysBundleResources(keys []ocr2key.KeyBundle) []OCR2KeysBundleResource + func (r OCR2KeysBundleResource) GetName() string + type OCRKeysBundleResource struct + ConfigPublicKey ocrkey.ConfigPublicKey + OffChainPublicKey ocrkey.OffChainPublicKey + OnChainSigningAddress ocrkey.OnChainSigningAddress + func NewOCRKeysBundleResource(key ocrkey.KeyV2) *OCRKeysBundleResource + func NewOCRKeysBundleResources(keys []ocrkey.KeyV2) []OCRKeysBundleResource + func (r OCRKeysBundleResource) GetName() string + type OffChainReporting2Spec struct + BlockchainTimeout models.Interval + ContractConfigConfirmations uint16 + ContractConfigTrackerPollInterval models.Interval + ContractID string + CreatedAt time.Time + OCRKeyBundleID null.String + ObservationTimeout models.Interval + P2PV2Bootstrappers pq.StringArray + Relay relay.Network + RelayConfig map[string]interface{} + TransmitterID null.String + UpdatedAt time.Time + func NewOffChainReporting2Spec(spec *job.OCR2OracleSpec) *OffChainReporting2Spec + type OffChainReportingSpec struct + BlockchainTimeout models.Interval + BlockchainTimeoutEnv bool + ContractAddress ethkey.EIP55Address + ContractConfigConfirmations uint16 + ContractConfigConfirmationsEnv bool + ContractConfigTrackerPollInterval models.Interval + ContractConfigTrackerPollIntervalEnv bool + ContractConfigTrackerSubscribeInterval models.Interval + ContractConfigTrackerSubscribeIntervalEnv bool + ContractTransmitterTransmitTimeout *models.Interval + ContractTransmitterTransmitTimeoutEnv bool + CreatedAt time.Time + DatabaseTimeout *models.Interval + DatabaseTimeoutEnv bool + EVMChainID *utils.Big + EncryptedOCRKeyBundleID *models.Sha256Hash + IsBootstrapPeer bool + ObservationGracePeriod *models.Interval + ObservationGracePeriodEnv bool + ObservationTimeout models.Interval + ObservationTimeoutEnv bool + P2PBootstrapPeers pq.StringArray + P2PV2Bootstrappers pq.StringArray + TransmitterAddress *ethkey.EIP55Address + UpdatedAt time.Time + func NewOffChainReportingSpec(spec *job.OCROracleSpec) *OffChainReportingSpec + type P2PKeyResource struct + PeerID string + PubKey string + func NewP2PKeyResource(key p2pkey.KeyV2) *P2PKeyResource + func NewP2PKeyResources(keys []p2pkey.KeyV2) []P2PKeyResource + func (P2PKeyResource) GetName() string + type PipelineRunResource struct + AllErrors []*string + CreatedAt time.Time + Errors []*string + FatalErrors []*string + FinishedAt null.Time + Inputs pipeline.JSONSerializable + Outputs []*string + PipelineSpec PipelineSpec + TaskRuns []PipelineTaskRunResource + func NewPipelineRunResource(pr pipeline.Run, lggr logger.Logger) PipelineRunResource + func NewPipelineRunResources(prs []pipeline.Run, lggr logger.Logger) []PipelineRunResource + func (r PipelineRunResource) GetName() string + type PipelineSpec struct + DotDAGSource string + ID int32 + JobID int32 + func NewPipelineSpec(spec *pipeline.Spec) PipelineSpec + type PipelineTaskRunResource struct + CreatedAt time.Time + DotID string + Error *string + FinishedAt null.Time + Output *string + Type pipeline.TaskType + func NewPipelineTaskRunResource(tr pipeline.TaskRun) PipelineTaskRunResource + func (r PipelineTaskRunResource) GetName() string + type RegistrationSettings struct + Settings protocol.CredentialCreation + func NewRegistrationSettings(settings protocol.CredentialCreation) *RegistrationSettings + func (r RegistrationSettings) GetName() string + type ServiceLogConfigResource struct + DefaultLogLevel string + LogLevel []string + ServiceName []string + func (r ServiceLogConfigResource) GetName() string + type SolanaChainResource struct + func NewSolanaChainResource(chain solana.DBChain) SolanaChainResource + func (r SolanaChainResource) GetConfig() C + func (r SolanaChainResource) GetName() string + func (r SolanaChainResource) IsEnabled() bool + type SolanaKeyResource struct + PubKey string + func NewSolanaKeyResource(key solkey.Key) *SolanaKeyResource + func NewSolanaKeyResources(keys []solkey.Key) []SolanaKeyResource + func (SolanaKeyResource) GetName() string + type SolanaMsgResource struct + Amount uint64 + ChainID string + From string + To string + func NewSolanaMsgResource(id string, chainID string) SolanaMsgResource + func (SolanaMsgResource) GetName() string + type SolanaNodeResource struct + CreatedAt time.Time + Name string + SolanaChainID string + SolanaURL string + UpdatedAt time.Time + func NewSolanaNodeResource(node db.Node) SolanaNodeResource + func (r SolanaNodeResource) GetName() string + type StarkNetChainResource struct + func NewStarkNetChainResource(chain starknet.DBChain) StarkNetChainResource + func (r StarkNetChainResource) GetConfig() C + func (r StarkNetChainResource) GetName() string + func (r StarkNetChainResource) IsEnabled() bool + type StarkNetKeyResource struct + AccountAddr string + StarkKey string + func NewStarkNetKeyResource(key starknet.Key) *StarkNetKeyResource + func NewStarkNetKeyResources(keys []starknet.Key) []StarkNetKeyResource + func (StarkNetKeyResource) GetName() string + type StarkNetNodeResource struct + ChainID string + CreatedAt time.Time + Name string + URL string + UpdatedAt time.Time + func NewStarkNetNodeResource(node db.Node) StarkNetNodeResource + func (r StarkNetNodeResource) GetName() string + type UserResource struct + CreatedAt time.Time + Email string + HasActiveApiToken string + Role sessions.UserRole + UpdatedAt time.Time + func NewUserResource(u sessions.User) *UserResource + func NewUserResources(users []sessions.User) []UserResource + func (r UserResource) GetName() string + type VRFKeyResource struct + Compressed string + Hash string + Uncompressed string + func NewVRFKeyResource(key vrfkey.KeyV2, lggr logger.Logger) *VRFKeyResource + func NewVRFKeyResources(keys []vrfkey.KeyV2, lggr logger.Logger) []VRFKeyResource + func (VRFKeyResource) GetName() string + type VRFSpec struct + BackoffInitialDelay models.Duration + BackoffMaxDelay models.Duration + BatchCoordinatorAddress *ethkey.EIP55Address + BatchFulfillmentEnabled bool + BatchFulfillmentGasMultiplier float64 + ChunkSize uint32 + CoordinatorAddress ethkey.EIP55Address + CreatedAt time.Time + EVMChainID *utils.Big + FromAddresses []ethkey.EIP55Address + GasLanePrice *assets.Wei + MinIncomingConfirmations uint32 + PollPeriod models.Duration + PublicKey secp256k1.PublicKey + RequestTimeout models.Duration + UpdatedAt time.Time + func NewVRFSpec(spec *job.VRFSpec) *VRFSpec + type WebhookSpec struct + CreatedAt time.Time + UpdatedAt time.Time + func NewWebhookSpec(spec *job.WebhookSpec) *WebhookSpec
Go to main page