Versions in this module Expand all Collapse all v2 v2.4.0 Nov 13, 2024 v2.3.0 Nov 13, 2024 v2.1.1 Nov 13, 2024 v2.1.0 Nov 11, 2024 Changes in this version + func CmpCheckName(a, b Check) int + type BlockHeaderFeederSpec struct + BatchBlockhashStoreAddress ethkey.EIP55Address + BlockhashStoreAddress ethkey.EIP55Address + CoordinatorV1Address *ethkey.EIP55Address + CoordinatorV2Address *ethkey.EIP55Address + CoordinatorV2PlusAddress *ethkey.EIP55Address + CreatedAt time.Time + EVMChainID *big.Big + FromAddresses []ethkey.EIP55Address + GetBlockhashesBatchSize uint16 + LookbackBlocks int32 + PollPeriod time.Duration + RunTimeout time.Duration + StoreBlockhashesBatchSize uint16 + UpdatedAt time.Time + WaitBlocks int32 + func NewBlockHeaderFeederSpec(spec *job.BlockHeaderFeederSpec) *BlockHeaderFeederSpec + type BlockhashStoreSpec struct + BlockhashStoreAddress ethkey.EIP55Address + CoordinatorV1Address *ethkey.EIP55Address + CoordinatorV2Address *ethkey.EIP55Address + CoordinatorV2PlusAddress *ethkey.EIP55Address + CreatedAt time.Time + EVMChainID *big.Big + FromAddresses []ethkey.EIP55Address + HeartbeatPeriod time.Duration + LookbackBlocks int32 + PollPeriod time.Duration + RunTimeout time.Duration + TrustedBlockhashStoreAddress *ethkey.EIP55Address + TrustedBlockhashStoreBatchSize int32 + 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 struct + Config string + Enabled bool + type Check struct + Name string + Output string + Status string + func (c Check) GetName() string + type CosmosChainResource struct + func NewCosmosChainResource(chain types.ChainStatus) CosmosChainResource + func (r CosmosChainResource) GetName() string + type CosmosKeyResource struct + PubKey string + func NewCosmosKeyResource(key cosmoskey.Key) *CosmosKeyResource + func NewCosmosKeyResources(keys []cosmoskey.Key) []CosmosKeyResource + func (CosmosKeyResource) GetName() string + type CosmosMsgResource struct + ChainID string + ContractID string + State string + TxHash *string + func NewCosmosMsgResource(id string, chainID string, contractID string) CosmosMsgResource + func (CosmosMsgResource) GetName() string + type CosmosNodeResource struct + func NewCosmosNodeResource(node types.NodeStatus) CosmosNodeResource + func (r CosmosNodeResource) 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 *big.Big + Initiator string + MinContractPayment *commonassets.Link + MinIncomingConfirmations clnull.Uint32 + Requesters models.AddressCollection + UpdatedAt time.Time + func NewDirectRequestSpec(spec *job.DirectRequestSpec) *DirectRequestSpec + type ETHKeyResource struct + Address string + CreatedAt time.Time + Disabled bool + EVMChainID big.Big + EthBalance *assets.Eth + LinkBalance *commonassets.Link + MaxGasPriceWei *big.Big + 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 types.ChainStatus) EVMChainResource + func (r EVMChainResource) GetName() string + type EVMForwarderResource struct + Address common.Address + CreatedAt time.Time + EVMChainID big.Big + UpdatedAt time.Time + func NewEVMForwarderResource(fwd forwarders.Forwarder) EVMForwarderResource + func (r EVMForwarderResource) GetName() string + type EVMNodeResource struct + func NewEVMNodeResource(node types.NodeStatus) EVMNodeResource + func (r EVMNodeResource) GetName() string + type EthTxResource struct + Data hexutil.Bytes + EVMChainID big.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.Tx) EthTxResource + func NewEthTxResourceFromAttempt(txa txmgr.TxAttempt) 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 *big.Big + IdleTimerDisabled bool + IdleTimerPeriod string + MinPayment *commonassets.Link + PollTimerDisabled bool + PollTimerPeriod string + Threshold float32 + UpdatedAt time.Time + func NewFluxMonitorSpec(spec *job.FluxMonitorSpec) *FluxMonitorSpec + type GatewaySpec struct + CreatedAt time.Time + GatewayConfig map[string]interface{} + UpdatedAt time.Time + func NewGatewaySpec(spec *job.GatewaySpec) *GatewaySpec + type JAID struct + ID string + func NewJAID(id string) JAID + func NewJAIDInt32(id int32) JAID + func NewJAIDInt64(id int64) JAID + func NewPrefixedJAID(id string, chainID string) 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 + BlockHeaderFeederSpec *BlockHeaderFeederSpec + BlockhashStoreSpec *BlockhashStoreSpec + BootstrapSpec *BootstrapSpec + CronSpec *CronSpec + DirectRequestSpec *DirectRequestSpec + Errors []JobError + ExternalJobID uuid.UUID + FluxMonitorSpec *FluxMonitorSpec + ForwardingAllowed bool + GasLimit clnull.Uint32 + GatewaySpec *GatewaySpec + KeeperSpec *KeeperSpec + MaxTaskDuration models.Interval + Name string + OffChainReporting2Spec *OffChainReporting2Spec + OffChainReportingSpec *OffChainReportingSpec + PipelineSpec PipelineSpec + SchemaVersion uint32 + StreamID *uint32 + Type JobSpecType + VRFSpec *VRFSpec + WebhookSpec *WebhookSpec + func NewJobResource(j job.Job) *JobResource + func (r JobResource) GetName() string + type JobSpecType string + const BlockHeaderFeederJobSpec + const BlockhashStoreJobSpec + const BootstrapJobSpec + const CronJobSpec + const DirectRequestJobSpec + const FluxMonitorJobSpec + const GatewayJobSpec + const KeeperJobSpec + const OffChainReportingJobSpec + const VRFJobSpec + const WebhookJobSpec + func (t JobSpecType) String() string + type KeeperSpec struct + ContractAddress ethkey.EIP55Address + CreatedAt time.Time + EVMChainID *big.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 *commonassets.Link) NewETHKeyOption + func SetETHKeyMaxGasPriceWei(maxGasPriceWei *big.Big) NewETHKeyOption + type NodeResource struct + ChainID string + Config string + Name string + State string + 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 + CollectTelemetry bool + 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 + CollectTelemetry bool + ContractAddress ethkey.EIP55Address + ContractConfigConfirmations uint16 + ContractConfigTrackerPollInterval models.Interval + ContractConfigTrackerSubscribeInterval models.Interval + ContractTransmitterTransmitTimeout *models.Interval + CreatedAt time.Time + DatabaseTimeout *models.Interval + EVMChainID *big.Big + EncryptedOCRKeyBundleID *models.Sha256Hash + IsBootstrapPeer bool + ObservationGracePeriod *models.Interval + ObservationTimeout models.Interval + 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 types.ChainStatus) SolanaChainResource + func (r SolanaChainResource) GetName() string + 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 + func NewSolanaNodeResource(node types.NodeStatus) SolanaNodeResource + func (r SolanaNodeResource) GetName() string + type StarkNetChainResource struct + func NewStarkNetChainResource(chain types.ChainStatus) StarkNetChainResource + func (r StarkNetChainResource) GetName() string + type StarkNetKeyResource struct + StarkKey string + func NewStarkNetKeyResource(key starkkey.Key) *StarkNetKeyResource + func NewStarkNetKeyResources(keys []starkkey.Key) []StarkNetKeyResource + func (StarkNetKeyResource) GetName() string + type StarkNetNodeResource struct + func NewStarkNetNodeResource(node types.NodeStatus) 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 commonconfig.Duration + BackoffMaxDelay commonconfig.Duration + BatchCoordinatorAddress *ethkey.EIP55Address + BatchFulfillmentEnabled bool + BatchFulfillmentGasMultiplier float64 + ChunkSize uint32 + CoordinatorAddress ethkey.EIP55Address + CreatedAt time.Time + CustomRevertsPipelineEnabled *bool + EVMChainID *big.Big + FromAddresses []ethkey.EIP55Address + GasLanePrice *assets.Wei + MinIncomingConfirmations uint32 + PollPeriod commonconfig.Duration + PublicKey secp256k1.PublicKey + RequestTimeout commonconfig.Duration + RequestedConfsDelay int64 + UpdatedAt time.Time + VRFOwnerAddress *ethkey.EIP55Address + 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