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 + 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 NewResource(key csakey.Key) *CSAKeyResource + func NewResources(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 + MinIncomingConfirmations clnull.Uint32 + 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 models.EthTx) EthTxResource + func NewEthTxResourceFromAttempt(txa models.EthTxAttempt) EthTxResource + func (EthTxResource) GetName() string + type ExplorerStatus struct + Status string + Url string + func NewExplorerStatus(statsPusher synchronization.StatsPusher) ExplorerStatus + type FeedsManagerResource struct + CreatedAt time.Time + JobTypes []string + Name string + Network 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 + 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 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 PipelineSpec struct + DotDAGSource string + ID int32 + func NewPipelineSpec(spec *pipeline.Spec) PipelineSpec + 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
Go to main page