Versions in this module Expand all Collapse all v1 v1.10.17 Oct 18, 2021 Changes in this version type CSAKeyResource + Version int + type ChainResource struct + Config types.ChainCfg + CreatedAt time.Time + Enabled bool + UpdatedAt time.Time + func NewChainResource(chain types.Chain) ChainResource + func (r ChainResource) GetName() string type ETHKeyResource + EVMChainID utils.Big type EthTxResource + EVMChainID utils.Big + type FeatureResource struct + Enabled bool + func NewFeatureResource(name string, enabled bool) *FeatureResource + func (r FeatureResource) GetName() string type FeedsManagerResource + IsConnectionActive bool type JobProposalResource + Multiaddrs []string + ProposedAt time.Time + type NodeResource struct + CreatedAt time.Time + EVMChainID utils.Big + HTTPURL null.String + Name string + UpdatedAt time.Time + WSURL null.String + func NewNodeResource(node types.Node) NodeResource + func (r NodeResource) GetName() string type PipelineRunResource + AllErrors []*string + FatalErrors []*string type PipelineSpec + JobID int32 + type RegistrationSettings struct + Settings protocol.CredentialCreation + func NewRegistrationSettings(settings protocol.CredentialCreation) *RegistrationSettings + func (r RegistrationSettings) GetName() string v1.10.16 Oct 18, 2021 Changes in this version + type BridgeResource struct + Confirmations uint32 + CreatedAt time.Time + IncomingToken string + MinimumContractPayment *assets.Link + Name string + OutgoingToken string + URL string + func NewBridgeResource(b models.BridgeType) *BridgeResource + func (r BridgeResource) GetName() string + type CSAKeyResource struct + CreatedAt time.Time + PubKey string + UpdatedAt time.Time + func NewCSAKeyResource(key csakey.Key) *CSAKeyResource + func NewCSAKeyResources(keys []csakey.Key) []CSAKeyResource + func (CSAKeyResource) GetName() string + type Check struct + Name string + Output string + Status health.Status + func (c Check) GetName() string + type CronSpec struct + CreatedAt time.Time + CronSchedule string + UpdatedAt time.Time + func NewCronSpec(spec *job.CronSpec) *CronSpec + type DirectRequestSpec struct + ContractAddress ethkey.EIP55Address + CreatedAt time.Time + Initiator string + MinContractPayment *assets.Link + MinIncomingConfirmations clnull.Uint32 + Requesters models.AddressCollection + UpdatedAt time.Time + func NewDirectRequestSpec(spec *job.DirectRequestSpec) *DirectRequestSpec + type ETHKeyResource struct + Address string + CreatedAt time.Time + DeletedAt *time.Time + EthBalance *assets.Eth + IsFunding bool + LinkBalance *assets.Link + NextNonce int64 + UpdatedAt time.Time + func NewETHKeyResource(k ethkey.Key, opts ...NewETHKeyOption) (*ETHKeyResource, error) + func (r ETHKeyResource) GetName() string + type EthTxResource struct + Data hexutil.Bytes + 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 bulletprooftxmanager.EthTx) EthTxResource + func NewEthTxResourceFromAttempt(txa bulletprooftxmanager.EthTxAttempt) EthTxResource + func (EthTxResource) GetName() string + type ExplorerStatus struct + Status string + Url string + func NewExplorerStatus(statsPusher synchronization.StatsPusher) ExplorerStatus + type ExternalInitiatorAuthentication struct + AccessKey string + Name string + OutgoingSecret string + OutgoingToken string + Secret string + URL models.WebURL + func NewExternalInitiatorAuthentication(ei models.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 models.ExternalInitiator) ExternalInitiatorResource + func (ExternalInitiatorResource) GetName() string + type FeedsManagerResource struct + BootstrapPeerMultiaddr null.String + CreatedAt time.Time + IsBootstrapPeer bool + JobTypes []string + Name string + PublicKey crypto.PublicKey + URI string + func NewFeedsManagerResource(ms feeds.FeedsManager) *FeedsManagerResource + func NewFeedsManagerResources(mss []feeds.FeedsManager) []FeedsManagerResource + func (r FeedsManagerResource) GetName() string + type FluxMonitorSpec struct + AbsoluteThreshold float32 + ContractAddress ethkey.EIP55Address + CreatedAt time.Time + DrumbeatEnabled bool + DrumbeatRandomDelay *string + DrumbeatSchedule *string + 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 NewJAIDUint(id uint) 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 JobProposalResource struct + CreatedAt time.Time + ExternalJobID *string + FeedsManagerID string + Spec string + Status feeds.JobProposalStatus + func NewJobProposalResource(jp feeds.JobProposal) *JobProposalResource + func NewJobProposalResources(jps []feeds.JobProposal) []JobProposalResource + func (r JobProposalResource) GetName() string + type JobResource struct + CronSpec *CronSpec + DirectRequestSpec *DirectRequestSpec + Errors []JobError + ExternalJobID uuid.UUID + FluxMonitorSpec *FluxMonitorSpec + KeeperSpec *KeeperSpec + MaxTaskDuration models.Interval + Name string + OffChainReportingSpec *OffChainReportingSpec + PipelineSpec PipelineSpec + SchemaVersion uint32 + Type JobSpecType + VRFSpec *VRFSpec + WebhookSpec *WebhookSpec + func NewJobResource(j job.Job) *JobResource + func NewJobResources(js []job.Job) []JobResource + func (r JobResource) GetName() string + type JobSpecType string + 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 + FromAddress ethkey.EIP55Address + UpdatedAt time.Time + func NewKeeperSpec(spec *job.KeeperSpec) *KeeperSpec + type NewETHKeyOption func(*ETHKeyResource) error + func SetETHKeyEthBalance(ethBalance *assets.Eth) NewETHKeyOption + func SetETHKeyLinkBalance(linkBalance *assets.Link) NewETHKeyOption + type OCRKeysBundleResource struct + ConfigPublicKey ocrkey.ConfigPublicKey + CreatedAt time.Time + DeletedAt *time.Time + OffChainPublicKey ocrkey.OffChainPublicKey + OnChainSigningAddress ocrkey.OnChainSigningAddress + UpdatedAt time.Time + func NewOCRKeysBundleResource(bundle ocrkey.EncryptedKeyBundle) *OCRKeysBundleResource + func NewOCRKeysBundleResources(keys []ocrkey.EncryptedKeyBundle) []OCRKeysBundleResource + func (r OCRKeysBundleResource) GetName() string + type OffChainReportingSpec struct + BlockchainTimeout models.Interval + ContractAddress ethkey.EIP55Address + ContractConfigConfirmations uint16 + ContractConfigTrackerPollInterval models.Interval + ContractConfigTrackerSubscribeInterval models.Interval + CreatedAt time.Time + EncryptedOCRKeyBundleID *models.Sha256Hash + IsBootstrapPeer bool + ObservationTimeout models.Interval + P2PBootstrapPeers pq.StringArray + P2PPeerID *p2pkey.PeerID + TransmitterAddress *ethkey.EIP55Address + UpdatedAt time.Time + func NewOffChainReportingSpec(spec *job.OffchainReportingOracleSpec) *OffChainReportingSpec + type P2PKeyResource struct + CreatedAt time.Time + DeletedAt *time.Time + PeerID string + PubKey string + UpdatedAt time.Time + func NewP2PKeyResource(key p2pkey.EncryptedP2PKey) *P2PKeyResource + func NewP2PKeyResources(keys []p2pkey.EncryptedP2PKey) []P2PKeyResource + func (P2PKeyResource) GetName() string + type PipelineRunResource struct + CreatedAt time.Time + Errors []*string + FinishedAt time.Time + Inputs pipeline.JSONSerializable + Outputs []*string + PipelineSpec PipelineSpec + TaskRuns []PipelineTaskRunResource + func NewPipelineRunResource(pr pipeline.Run) PipelineRunResource + func NewPipelineRunResources(prs []pipeline.Run) []PipelineRunResource + func (r PipelineRunResource) GetName() string + type PipelineSpec struct + DotDAGSource string + ID int32 + func NewPipelineSpec(spec *pipeline.Spec) PipelineSpec + type PipelineTaskRunResource struct + CreatedAt time.Time + DotID string + Error *string + FinishedAt time.Time + Output *string + Type pipeline.TaskType + func NewPipelineTaskRunResource(tr pipeline.TaskRun) PipelineTaskRunResource + func (r PipelineTaskRunResource) GetName() string + type ServiceLogConfigResource struct + LogLevel []string + ServiceName []string + func (r ServiceLogConfigResource) GetName() string + type UserResource struct + CreatedAt time.Time + Email string + func NewUserResource(u models.User) *UserResource + func (r UserResource) GetName() string + type VRFKeyResource struct + Compressed string + CreatedAt time.Time + DeletedAt *time.Time + Hash string + Uncompressed string + UpdatedAt time.Time + func NewVRFKeyResource(key vrfkey.EncryptedVRFKey) *VRFKeyResource + func NewVRFKeyResources(keys []*vrfkey.EncryptedVRFKey) []VRFKeyResource + func (VRFKeyResource) GetName() string + type VRFSpec struct + Confirmations uint32 + CoordinatorAddress ethkey.EIP55Address + CreatedAt time.Time + PublicKey secp256k1.PublicKey + UpdatedAt time.Time + func NewVRFSpec(spec *job.VRFSpec) *VRFSpec + type WebhookSpec struct + CreatedAt time.Time + UpdatedAt time.Time + func NewWebhookSpec(spec *job.WebhookSpec) *WebhookSpec