Versions in this module Expand all Collapse all v0 v0.0.3 May 11, 2021 v0.0.2 May 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 DirectRequestSpec struct + ContractAddress models.EIP55Address + CreatedAt time.Time + Initiator string + OnChainJobSpecID string + UpdatedAt time.Time + func NewDirectRequestSpec(spec *job.DirectRequestSpec) *DirectRequestSpec + type ETHKeyResource struct + Address string + CreatedAt time.Time + DeletedAt gorm.DeletedAt + EthBalance *assets.Eth + IsFunding bool + LastUsed *time.Time + LinkBalance *assets.Link + NextNonce int64 + UpdatedAt time.Time + func NewETHKeyResource(k models.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 FluxMonitorSpec struct + AbsoluteThreshold float32 + ContractAddress models.EIP55Address + CreatedAt time.Time + IdleTimerDisabled bool + IdleTimerPeriod string + MinPayment *assets.Link + PollTimerDisabled bool + PollTimerPeriod string + Precision int32 + 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 + DirectRequestSpec *DirectRequestSpec + Errors []JobError + FluxMonitorSpec *FluxMonitorSpec + KeeperSpec *KeeperSpec + MaxTaskDuration models.Interval + Name string + OffChainReportingSpec *OffChainReportingSpec + PipelineSpec PipelineSpec + SchemaVersion uint32 + Type JobSpecType + func NewJobResource(j job.Job) *JobResource + func NewJobResources(js []job.Job) []JobResource + func (r JobResource) GetName() string + type JobSpecType string + const DirectRequestJobSpec + const FluxMonitorJobSpec + const KeeperJobSpec + const OffChainReportingJobSpec + func (t JobSpecType) String() string + type KeeperSpec struct + ContractAddress models.EIP55Address + CreatedAt time.Time + FromAddress models.EIP55Address + UpdatedAt time.Time + func NewKeeperSpec(spec *job.KeeperSpec) *KeeperSpec + type LogResource struct + Level string + SqlEnabled bool + func (r LogResource) GetName() string + 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 models.EIP55Address + ContractConfigConfirmations uint16 + ContractConfigTrackerPollInterval models.Interval + ContractConfigTrackerSubscribeInterval models.Interval + CreatedAt time.Time + EncryptedOCRKeyBundleID *models.Sha256Hash + IsBootstrapPeer bool + ObservationTimeout models.Interval + P2PBootstrapPeers pq.StringArray + P2PPeerID *models.PeerID + TransmitterAddress *models.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 UserResource struct + CreatedAt time.Time + Email string + func NewUserResource(u models.User) *UserResource + func (r UserResource) GetName() string