Documentation ¶
Index ¶
- func CmpCheckName(a, b Check) int
- type BlockHeaderFeederSpec
- type BlockhashStoreSpec
- type BootstrapSpec
- type BridgeResource
- type CSAKeyResource
- type ChainResource
- type Check
- type CosmosChainResource
- type CosmosKeyResource
- type CosmosMsgResource
- type CosmosNodeResource
- type CronSpec
- type DKGEncryptKeyResource
- type DKGSignKeyResource
- type DirectRequestSpec
- type ETHKeyResource
- type EVMChainResource
- type EVMForwarderResource
- type EVMNodeResource
- type EthTxResource
- type ExternalInitiatorAuthentication
- type ExternalInitiatorResource
- type FeatureResource
- type FluxMonitorSpec
- type GatewaySpec
- type JAID
- type JobError
- type JobResource
- type JobSpecType
- type KeeperSpec
- type NewETHKeyOption
- type NodeResource
- type OCR2KeysBundleResource
- type OCRKeysBundleResource
- type OffChainReporting2Spec
- type OffChainReportingSpec
- type P2PKeyResource
- type PipelineRunResource
- type PipelineSpec
- type PipelineTaskRunResource
- type RegistrationSettings
- type ServiceLogConfigResource
- type SolanaChainResource
- type SolanaKeyResource
- type SolanaMsgResource
- type SolanaNodeResource
- type StandardCapabilitiesSpec
- type StarkNetChainResource
- type StarkNetKeyResource
- type StarkNetNodeResource
- type UserResource
- type VRFKeyResource
- type VRFSpec
- type WebhookSpec
- type WorkflowSpec
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CmpCheckName ¶ added in v2.9.0
Types ¶
type BlockHeaderFeederSpec ¶
type BlockHeaderFeederSpec struct { CoordinatorV1Address *types.EIP55Address `json:"coordinatorV1Address"` CoordinatorV2Address *types.EIP55Address `json:"coordinatorV2Address"` CoordinatorV2PlusAddress *types.EIP55Address `json:"coordinatorV2PlusAddress"` WaitBlocks int32 `json:"waitBlocks"` LookbackBlocks int32 `json:"lookbackBlocks"` BlockhashStoreAddress types.EIP55Address `json:"blockhashStoreAddress"` BatchBlockhashStoreAddress types.EIP55Address `json:"batchBlockhashStoreAddress"` PollPeriod time.Duration `json:"pollPeriod"` RunTimeout time.Duration `json:"runTimeout"` EVMChainID *big.Big `json:"evmChainID"` FromAddresses []types.EIP55Address `json:"fromAddresses"` GetBlockhashesBatchSize uint16 `json:"getBlockhashesBatchSize"` StoreBlockhashesBatchSize uint16 `json:"storeBlockhashesBatchSize"` CreatedAt time.Time `json:"createdAt"` UpdatedAt time.Time `json:"updatedAt"` }
BlockHeaderFeederSpec defines the job parameters for a blcok header feeder job.
func NewBlockHeaderFeederSpec ¶
func NewBlockHeaderFeederSpec(spec *job.BlockHeaderFeederSpec) *BlockHeaderFeederSpec
NewBlockHeaderFeederSpec creates a new BlockHeaderFeederSpec for the given parameters.
type BlockhashStoreSpec ¶
type BlockhashStoreSpec struct { CoordinatorV1Address *types.EIP55Address `json:"coordinatorV1Address"` CoordinatorV2Address *types.EIP55Address `json:"coordinatorV2Address"` CoordinatorV2PlusAddress *types.EIP55Address `json:"coordinatorV2PlusAddress"` WaitBlocks int32 `json:"waitBlocks"` LookbackBlocks int32 `json:"lookbackBlocks"` HeartbeatPeriod time.Duration `json:"heartbeatPeriod"` BlockhashStoreAddress types.EIP55Address `json:"blockhashStoreAddress"` TrustedBlockhashStoreAddress *types.EIP55Address `json:"trustedBlockhashStoreAddress"` TrustedBlockhashStoreBatchSize int32 `json:"trustedBlockhashStoreBatchSize"` PollPeriod time.Duration `json:"pollPeriod"` RunTimeout time.Duration `json:"runTimeout"` EVMChainID *big.Big `json:"evmChainID"` FromAddresses []types.EIP55Address `json:"fromAddresses"` CreatedAt time.Time `json:"createdAt"` UpdatedAt time.Time `json:"updatedAt"` }
BlockhashStoreSpec defines the job parameters for a blockhash store feeder job.
func NewBlockhashStoreSpec ¶
func NewBlockhashStoreSpec(spec *job.BlockhashStoreSpec) *BlockhashStoreSpec
NewBlockhashStoreSpec creates a new BlockhashStoreSpec for the given parameters.
type BootstrapSpec ¶
type BootstrapSpec struct { ContractID string `json:"contractID"` Relay string `json:"relay"` // RelayID.Network RelayConfig map[string]interface{} `json:"relayConfig"` BlockchainTimeout models.Interval `json:"blockchainTimeout"` ContractConfigTrackerSubscribeInterval models.Interval `json:"contractConfigTrackerSubscribeInterval"` ContractConfigTrackerPollInterval models.Interval `json:"contractConfigTrackerPollInterval"` ContractConfigConfirmations uint16 `json:"contractConfigConfirmations"` CreatedAt time.Time `json:"createdAt"` UpdatedAt time.Time `json:"updatedAt"` }
BootstrapSpec defines the spec details of a BootstrapSpec Job
func NewBootstrapSpec ¶
func NewBootstrapSpec(spec *job.BootstrapSpec) *BootstrapSpec
NewBootstrapSpec initializes a new BootstrapSpec from a job.BootstrapSpec
type BridgeResource ¶
type BridgeResource struct { JAID Name string `json:"name"` URL string `json:"url"` Confirmations uint32 `json:"confirmations"` // The IncomingToken is only provided when creating a Bridge IncomingToken string `json:"incomingToken,omitempty"` OutgoingToken string `json:"outgoingToken"` MinimumContractPayment *assets.Link `json:"minimumContractPayment"` CreatedAt time.Time `json:"createdAt"` }
BridgeResource represents a Bridge JSONAPI resource.
func NewBridgeResource ¶
func NewBridgeResource(b bridges.BridgeType) *BridgeResource
NewBridgeResource constructs a new BridgeResource
func (BridgeResource) GetName ¶
func (r BridgeResource) GetName() string
GetName implements the api2go EntityNamer interface
type CSAKeyResource ¶
CSAKeyResource represents a CSA key JSONAPI resource.
func NewCSAKeyResource ¶
func NewCSAKeyResource(key csakey.KeyV2) *CSAKeyResource
func NewCSAKeyResources ¶
func NewCSAKeyResources(keys []csakey.KeyV2) []CSAKeyResource
func (CSAKeyResource) GetName ¶
func (CSAKeyResource) GetName() string
GetName implements the api2go EntityNamer interface
type ChainResource ¶
type Check ¶
type CosmosChainResource ¶
type CosmosChainResource struct {
ChainResource
}
CosmosChainResource is an Cosmos chain JSONAPI resource.
func NewCosmosChainResource ¶
func NewCosmosChainResource(chain types.ChainStatus) CosmosChainResource
NewCosmosChainResource returns a new CosmosChainResource for chain.
func (CosmosChainResource) GetName ¶
func (r CosmosChainResource) GetName() string
GetName implements the api2go EntityNamer interface
type CosmosKeyResource ¶
CosmosKeyResource represents a Cosmos key JSONAPI resource.
func NewCosmosKeyResource ¶
func NewCosmosKeyResource(key cosmoskey.Key) *CosmosKeyResource
func NewCosmosKeyResources ¶
func NewCosmosKeyResources(keys []cosmoskey.Key) []CosmosKeyResource
func (CosmosKeyResource) GetName ¶
func (CosmosKeyResource) GetName() string
GetName implements the api2go EntityNamer interface
type CosmosMsgResource ¶
CosmosMsgResource repesents a Cosmos message JSONAPI resource.
func NewCosmosMsgResource ¶
func NewCosmosMsgResource(id string, chainID string, contractID string) CosmosMsgResource
NewCosmosMsgResource returns a new partial CosmosMsgResource.
func (CosmosMsgResource) GetName ¶
func (CosmosMsgResource) GetName() string
GetName implements the api2go EntityNamer interface
type CosmosNodeResource ¶
type CosmosNodeResource struct {
NodeResource
}
CosmosNodeResource is a Cosmos node JSONAPI resource.
func NewCosmosNodeResource ¶
func NewCosmosNodeResource(node types.NodeStatus) CosmosNodeResource
NewCosmosNodeResource returns a new CosmosNodeResource for node.
func (CosmosNodeResource) GetName ¶
func (r CosmosNodeResource) GetName() string
GetName implements the api2go EntityNamer interface
type CronSpec ¶
type CronSpec struct { CronSchedule string `json:"schedule" tom:"schedule"` CreatedAt time.Time `json:"createdAt"` UpdatedAt time.Time `json:"updatedAt"` }
CronSpec defines the spec details of a Cron Job
func NewCronSpec ¶
NewCronSpec generates a new CronSpec from a job.CronSpec
type DKGEncryptKeyResource ¶
DKGEncryptKeyResource is just that.
func NewDKGEncryptKeyResource ¶
func NewDKGEncryptKeyResource(key dkgencryptkey.Key) *DKGEncryptKeyResource
NewDKGEncryptKeyResource creates a new DKGEncryptKeyResource from the given DKG sign key.
func NewDKGEncryptKeyResources ¶
func NewDKGEncryptKeyResources(keys []dkgencryptkey.Key) (resources []DKGEncryptKeyResource)
NewDKGEncryptKeyResources creates many DKGEncryptKeyResource objects from the given DKG sign keys.
func (DKGEncryptKeyResource) GetName ¶
func (DKGEncryptKeyResource) GetName() string
GetName implements jsonapi.EntityNamer
type DKGSignKeyResource ¶
DKGSignKeyResource is just that.
func NewDKGSignKeyResource ¶
func NewDKGSignKeyResource(key dkgsignkey.Key) *DKGSignKeyResource
NewDKGSignKeyResource creates a new DKGSignKeyResource from the given DKG sign key.
func NewDKGSignKeyResources ¶
func NewDKGSignKeyResources(keys []dkgsignkey.Key) (resources []DKGSignKeyResource)
NewDKGSignKeyResources creates many DKGSignKeyResource objects from the given DKG sign keys.
func (DKGSignKeyResource) GetName ¶
func (DKGSignKeyResource) GetName() string
GetName implements jsonapi.EntityNamer
type DirectRequestSpec ¶
type DirectRequestSpec struct { ContractAddress types.EIP55Address `json:"contractAddress"` MinIncomingConfirmations clnull.Uint32 `json:"minIncomingConfirmations"` MinContractPayment *commonassets.Link `json:"minContractPaymentLinkJuels"` Requesters models.AddressCollection `json:"requesters"` Initiator string `json:"initiator"` CreatedAt time.Time `json:"createdAt"` UpdatedAt time.Time `json:"updatedAt"` EVMChainID *big.Big `json:"evmChainID"` }
DirectRequestSpec defines the spec details of a DirectRequest Job
func NewDirectRequestSpec ¶
func NewDirectRequestSpec(spec *job.DirectRequestSpec) *DirectRequestSpec
NewDirectRequestSpec initializes a new DirectRequestSpec from a job.DirectRequestSpec
type ETHKeyResource ¶
type ETHKeyResource struct { JAID EVMChainID big.Big `json:"evmChainID"` Address string `json:"address"` EthBalance *assets.Eth `json:"ethBalance"` LinkBalance *commonassets.Link `json:"linkBalance"` Disabled bool `json:"disabled"` CreatedAt time.Time `json:"createdAt"` UpdatedAt time.Time `json:"updatedAt"` MaxGasPriceWei *big.Big `json:"maxGasPriceWei"` }
ETHKeyResource represents a ETH key JSONAPI resource. It holds the hex representation of the address plus its ETH & LINK balances
func NewETHKeyResource ¶
func NewETHKeyResource(k ethkey.KeyV2, state ethkey.State, opts ...NewETHKeyOption) *ETHKeyResource
NewETHKeyResource constructs a new ETHKeyResource from a Key.
Use the functional options to inject the ETH and LINK balances
func (ETHKeyResource) GetName ¶
func (r ETHKeyResource) GetName() string
GetName implements the api2go EntityNamer interface
This is named as such for backwards compatibility with the operator ui TODO - Standardise this to ethKeys
type EVMChainResource ¶
type EVMChainResource struct {
ChainResource
}
EVMChainResource is an EVM chain JSONAPI resource.
func NewEVMChainResource ¶
func NewEVMChainResource(chain types.ChainStatus) EVMChainResource
NewEVMChainResource returns a new EVMChainResource for chain.
func (EVMChainResource) GetName ¶
func (r EVMChainResource) GetName() string
GetName implements the api2go EntityNamer interface
type EVMForwarderResource ¶
type EVMForwarderResource struct { JAID Address common.Address `json:"address"` EVMChainID big.Big `json:"evmChainId"` CreatedAt time.Time `json:"createdAt"` UpdatedAt time.Time `json:"updatedAt"` }
EVMForwarderResource is an EVM forwarder JSONAPI resource.
func NewEVMForwarderResource ¶
func NewEVMForwarderResource(fwd forwarders.Forwarder) EVMForwarderResource
NewEVMForwarderResource returns a new EVMForwarderResource for chain.
func (EVMForwarderResource) GetName ¶
func (r EVMForwarderResource) GetName() string
GetName implements the api2go EntityNamer interface
type EVMNodeResource ¶
type EVMNodeResource struct {
NodeResource
}
EVMNodeResource is an EVM node JSONAPI resource.
func NewEVMNodeResource ¶
func NewEVMNodeResource(node types.NodeStatus) EVMNodeResource
NewEVMNodeResource returns a new EVMNodeResource for node.
func (EVMNodeResource) GetName ¶
func (r EVMNodeResource) GetName() string
GetName implements the api2go EntityNamer interface
type EthTxResource ¶
type EthTxResource struct { JAID State string `json:"state"` Data hexutil.Bytes `json:"data"` From *common.Address `json:"from"` GasLimit string `json:"gasLimit"` GasPrice string `json:"gasPrice"` Hash common.Hash `json:"hash"` Hex string `json:"rawHex"` Nonce string `json:"nonce"` SentAt string `json:"sentAt"` To *common.Address `json:"to"` Value string `json:"value"` EVMChainID big.Big `json:"evmChainID"` }
EthTxResource represents a Ethereum Transaction JSONAPI resource.
func NewEthTxResource ¶
func NewEthTxResource(tx txmgr.Tx) EthTxResource
NewEthTxResource generates a EthTxResource from an Eth.Tx.
For backwards compatibility, there is no id set when initializing from an EthTx as the id being used was the EthTxAttempt Hash. This should really use it's proper id
func NewEthTxResourceFromAttempt ¶
func NewEthTxResourceFromAttempt(txa txmgr.TxAttempt) EthTxResource
func (EthTxResource) GetName ¶
func (EthTxResource) GetName() string
GetName implements the api2go EntityNamer interface
type ExternalInitiatorAuthentication ¶
type ExternalInitiatorAuthentication struct { Name string `json:"name,omitempty"` URL models.WebURL `json:"url,omitempty"` AccessKey string `json:"incomingAccessKey,omitempty"` Secret string `json:"incomingSecret,omitempty"` OutgoingToken string `json:"outgoingToken,omitempty"` OutgoingSecret string `json:"outgoingSecret,omitempty"` }
ExternalInitiatorAuthentication includes initiator and authentication details.
func NewExternalInitiatorAuthentication ¶
func NewExternalInitiatorAuthentication( ei bridges.ExternalInitiator, eia auth.Token, ) *ExternalInitiatorAuthentication
NewExternalInitiatorAuthentication creates an instance of ExternalInitiatorAuthentication.
func (*ExternalInitiatorAuthentication) GetID ¶
func (ei *ExternalInitiatorAuthentication) GetID() string
GetID returns the jsonapi ID.
func (*ExternalInitiatorAuthentication) GetName ¶
func (*ExternalInitiatorAuthentication) GetName() string
GetName returns the collection name for jsonapi.
func (*ExternalInitiatorAuthentication) SetID ¶
func (ei *ExternalInitiatorAuthentication) SetID(name string) error
SetID is used to conform to the UnmarshallIdentifier interface for deserializing from jsonapi documents.
type ExternalInitiatorResource ¶
type ExternalInitiatorResource struct { JAID Name string `json:"name"` URL *models.WebURL `json:"url"` AccessKey string `json:"accessKey"` OutgoingToken string `json:"outgoingToken"` CreatedAt time.Time `json:"createdAt"` UpdatedAt time.Time `json:"updatedAt"` }
func NewExternalInitiatorResource ¶
func NewExternalInitiatorResource(ei bridges.ExternalInitiator) ExternalInitiatorResource
func (ExternalInitiatorResource) GetName ¶
func (ExternalInitiatorResource) GetName() string
GetName returns the collection name for jsonapi.
type FeatureResource ¶
FeatureResource represents a Feature JSONAPI resource.
func NewFeatureResource ¶
func NewFeatureResource(name string, enabled bool) *FeatureResource
NewFeedsManagerResource constructs a new FeedsManagerResource.
func (FeatureResource) GetName ¶
func (r FeatureResource) GetName() string
GetName implements the api2go EntityNamer interface
type FluxMonitorSpec ¶
type FluxMonitorSpec struct { ContractAddress types.EIP55Address `json:"contractAddress"` Threshold float32 `json:"threshold"` AbsoluteThreshold float32 `json:"absoluteThreshold"` PollTimerPeriod string `json:"pollTimerPeriod"` PollTimerDisabled bool `json:"pollTimerDisabled"` IdleTimerPeriod string `json:"idleTimerPeriod"` IdleTimerDisabled bool `json:"idleTimerDisabled"` DrumbeatEnabled bool `json:"drumbeatEnabled"` DrumbeatSchedule *string `json:"drumbeatSchedule"` DrumbeatRandomDelay *string `json:"drumbeatRandomDelay"` MinPayment *commonassets.Link `json:"minPayment"` CreatedAt time.Time `json:"createdAt"` UpdatedAt time.Time `json:"updatedAt"` EVMChainID *big.Big `json:"evmChainID"` }
FluxMonitorSpec defines the spec details of a FluxMonitor Job
func NewFluxMonitorSpec ¶
func NewFluxMonitorSpec(spec *job.FluxMonitorSpec) *FluxMonitorSpec
NewFluxMonitorSpec initializes a new DirectFluxMonitorSpec from a job.FluxMonitorSpec
type GatewaySpec ¶ added in v2.3.0
type GatewaySpec struct { GatewayConfig map[string]interface{} `json:"gatewayConfig"` CreatedAt time.Time `json:"createdAt"` UpdatedAt time.Time `json:"updatedAt"` }
func NewGatewaySpec ¶ added in v2.3.0
func NewGatewaySpec(spec *job.GatewaySpec) *GatewaySpec
type JAID ¶
type JAID struct {
ID string `json:"-"`
}
JAID represents a JSON API ID. It implements the api2go MarshalIdentifier and UnmarshalIdentitier interface.
func NewPrefixedJAID ¶ added in v2.10.0
NewPrefixedJAID prefixes JAID with chain id in %s/%s format.
type JobError ¶
type JobError struct { ID int64 `json:"id"` Description string `json:"description"` Occurrences uint `json:"occurrences"` CreatedAt time.Time `json:"createdAt"` UpdatedAt time.Time `json:"updatedAt"` }
JobError represents errors on the job
func NewJobError ¶
type JobResource ¶
type JobResource struct { JAID Name string `json:"name"` StreamID *uint32 `json:"streamID,omitempty"` Type JobSpecType `json:"type"` SchemaVersion uint32 `json:"schemaVersion"` GasLimit clnull.Uint32 `json:"gasLimit"` ForwardingAllowed bool `json:"forwardingAllowed"` MaxTaskDuration models.Interval `json:"maxTaskDuration"` ExternalJobID uuid.UUID `json:"externalJobID"` DirectRequestSpec *DirectRequestSpec `json:"directRequestSpec"` FluxMonitorSpec *FluxMonitorSpec `json:"fluxMonitorSpec"` CronSpec *CronSpec `json:"cronSpec"` OffChainReportingSpec *OffChainReportingSpec `json:"offChainReportingOracleSpec"` OffChainReporting2Spec *OffChainReporting2Spec `json:"offChainReporting2OracleSpec"` KeeperSpec *KeeperSpec `json:"keeperSpec"` VRFSpec *VRFSpec `json:"vrfSpec"` WebhookSpec *WebhookSpec `json:"webhookSpec"` BlockhashStoreSpec *BlockhashStoreSpec `json:"blockhashStoreSpec"` BlockHeaderFeederSpec *BlockHeaderFeederSpec `json:"blockHeaderFeederSpec"` BootstrapSpec *BootstrapSpec `json:"bootstrapSpec"` GatewaySpec *GatewaySpec `json:"gatewaySpec"` WorkflowSpec *WorkflowSpec `json:"workflowSpec"` StandardCapabilitiesSpec *StandardCapabilitiesSpec `json:"standardCapabilitiesSpec"` PipelineSpec PipelineSpec `json:"pipelineSpec"` Errors []JobError `json:"errors"` }
JobResource represents a JobResource
func NewJobResource ¶
func NewJobResource(j job.Job) *JobResource
NewJobResource initializes a new JSONAPI job resource
func (JobResource) GetName ¶
func (r JobResource) GetName() string
GetName implements the api2go EntityNamer interface
type JobSpecType ¶
type JobSpecType string
JobSpecType defines the spec type of the job
const ( DirectRequestJobSpec JobSpecType = "directrequest" FluxMonitorJobSpec JobSpecType = "fluxmonitor" OffChainReportingJobSpec JobSpecType = "offchainreporting" KeeperJobSpec JobSpecType = "keeper" CronJobSpec JobSpecType = "cron" VRFJobSpec JobSpecType = "vrf" WebhookJobSpec JobSpecType = "webhook" BlockhashStoreJobSpec JobSpecType = "blockhashstore" BlockHeaderFeederJobSpec JobSpecType = "blockheaderfeeder" BootstrapJobSpec JobSpecType = "bootstrap" GatewayJobSpec JobSpecType = "gateway" WorkflowJobSpec JobSpecType = "workflow" StandardCapabilitiesJobSpec JobSpecType = "standardcapabilities" )
func (JobSpecType) String ¶
func (t JobSpecType) String() string
type KeeperSpec ¶
type KeeperSpec struct { ContractAddress types.EIP55Address `json:"contractAddress"` FromAddress types.EIP55Address `json:"fromAddress"` CreatedAt time.Time `json:"createdAt"` UpdatedAt time.Time `json:"updatedAt"` EVMChainID *big.Big `json:"evmChainID"` }
KeeperSpec defines the spec details of a Keeper Job
func NewKeeperSpec ¶
func NewKeeperSpec(spec *job.KeeperSpec) *KeeperSpec
NewKeeperSpec generates a new KeeperSpec from a job.KeeperSpec
type NewETHKeyOption ¶
type NewETHKeyOption func(*ETHKeyResource)
NewETHKeyOption defines a functional option which allows customisation of the EthKeyResource
func SetETHKeyEthBalance ¶
func SetETHKeyEthBalance(ethBalance *assets.Eth) NewETHKeyOption
func SetETHKeyLinkBalance ¶
func SetETHKeyLinkBalance(linkBalance *commonassets.Link) NewETHKeyOption
func SetETHKeyMaxGasPriceWei ¶
func SetETHKeyMaxGasPriceWei(maxGasPriceWei *big.Big) NewETHKeyOption
type NodeResource ¶ added in v2.1.0
type OCR2KeysBundleResource ¶
type OCR2KeysBundleResource struct { JAID ChainType string `json:"chainType"` OnchainPublicKey string `json:"onchainPublicKey"` OffChainPublicKey string `json:"offchainPublicKey"` ConfigPublicKey string `json:"configPublicKey"` }
OCR2KeysBundleResource represents a bundle of OCRs keys as JSONAPI resource
func NewOCR2KeysBundleResource ¶
func NewOCR2KeysBundleResource(key ocr2key.KeyBundle) *OCR2KeysBundleResource
func NewOCR2KeysBundleResources ¶
func NewOCR2KeysBundleResources(keys []ocr2key.KeyBundle) []OCR2KeysBundleResource
func (OCR2KeysBundleResource) GetName ¶
func (r OCR2KeysBundleResource) GetName() string
GetName implements the api2go EntityNamer interface
type OCRKeysBundleResource ¶
type OCRKeysBundleResource struct { JAID OnChainSigningAddress ocrkey.OnChainSigningAddress `json:"onChainSigningAddress"` OffChainPublicKey ocrkey.OffChainPublicKey `json:"offChainPublicKey"` ConfigPublicKey ocrkey.ConfigPublicKey `json:"configPublicKey"` }
OCRKeysBundleResource represents a bundle of OCRs keys as JSONAPI resource
func NewOCRKeysBundleResource ¶
func NewOCRKeysBundleResource(key ocrkey.KeyV2) *OCRKeysBundleResource
func NewOCRKeysBundleResources ¶
func NewOCRKeysBundleResources(keys []ocrkey.KeyV2) []OCRKeysBundleResource
func (OCRKeysBundleResource) GetName ¶
func (r OCRKeysBundleResource) GetName() string
GetName implements the api2go EntityNamer interface
type OffChainReporting2Spec ¶
type OffChainReporting2Spec struct { ContractID string `json:"contractID"` Relay string `json:"relay"` // RelayID.Network RelayConfig map[string]interface{} `json:"relayConfig"` P2PV2Bootstrappers pq.StringArray `json:"p2pv2Bootstrappers"` OCRKeyBundleID null.String `json:"ocrKeyBundleID"` TransmitterID null.String `json:"transmitterID"` ObservationTimeout models.Interval `json:"observationTimeout"` BlockchainTimeout models.Interval `json:"blockchainTimeout"` ContractConfigTrackerPollInterval models.Interval `json:"contractConfigTrackerPollInterval"` ContractConfigConfirmations uint16 `json:"contractConfigConfirmations"` CreatedAt time.Time `json:"createdAt"` UpdatedAt time.Time `json:"updatedAt"` CollectTelemetry bool `json:"collectTelemetry"` }
OffChainReporting2Spec defines the spec details of a OffChainReporting2 Job
func NewOffChainReporting2Spec ¶
func NewOffChainReporting2Spec(spec *job.OCR2OracleSpec) *OffChainReporting2Spec
NewOffChainReporting2Spec initializes a new OffChainReportingSpec from a job.OCR2OracleSpec
type OffChainReportingSpec ¶
type OffChainReportingSpec struct { ContractAddress types.EIP55Address `json:"contractAddress"` P2PV2Bootstrappers pq.StringArray `json:"p2pv2Bootstrappers"` IsBootstrapPeer bool `json:"isBootstrapPeer"` EncryptedOCRKeyBundleID *models.Sha256Hash `json:"keyBundleID"` TransmitterAddress *types.EIP55Address `json:"transmitterAddress"` ObservationTimeout models.Interval `json:"observationTimeout"` BlockchainTimeout models.Interval `json:"blockchainTimeout"` ContractConfigTrackerSubscribeInterval models.Interval `json:"contractConfigTrackerSubscribeInterval"` ContractConfigTrackerPollInterval models.Interval `json:"contractConfigTrackerPollInterval"` ContractConfigConfirmations uint16 `json:"contractConfigConfirmations"` CreatedAt time.Time `json:"createdAt"` UpdatedAt time.Time `json:"updatedAt"` EVMChainID *big.Big `json:"evmChainID"` DatabaseTimeout *models.Interval `json:"databaseTimeout"` ObservationGracePeriod *models.Interval `json:"observationGracePeriod"` ContractTransmitterTransmitTimeout *models.Interval `json:"contractTransmitterTransmitTimeout"` CollectTelemetry bool `json:"collectTelemetry,omitempty"` }
OffChainReportingSpec defines the spec details of a OffChainReporting Job
func NewOffChainReportingSpec ¶
func NewOffChainReportingSpec(spec *job.OCROracleSpec) *OffChainReportingSpec
NewOffChainReportingSpec initializes a new OffChainReportingSpec from a job.OCROracleSpec
type P2PKeyResource ¶
P2PKeyResource represents a P2P key JSONAPI resource.
func NewP2PKeyResource ¶
func NewP2PKeyResource(key p2pkey.KeyV2) *P2PKeyResource
func NewP2PKeyResources ¶
func NewP2PKeyResources(keys []p2pkey.KeyV2) []P2PKeyResource
func (P2PKeyResource) GetName ¶
func (P2PKeyResource) GetName() string
GetName implements the api2go EntityNamer interface
type PipelineRunResource ¶
type PipelineRunResource struct { JAID Outputs []*string `json:"outputs"` // XXX: Here for backwards compatibility, can be removed later // Deprecated: Errors Errors []*string `json:"errors"` AllErrors []*string `json:"allErrors"` FatalErrors []*string `json:"fatalErrors"` Inputs jsonserializable.JSONSerializable `json:"inputs"` TaskRuns []PipelineTaskRunResource `json:"taskRuns"` CreatedAt time.Time `json:"createdAt"` FinishedAt null.Time `json:"finishedAt"` PipelineSpec PipelineSpec `json:"pipelineSpec"` }
Corresponds with models.d.ts PipelineRun
func NewPipelineRunResource ¶
func NewPipelineRunResource(pr pipeline.Run, lggr logger.Logger) PipelineRunResource
func NewPipelineRunResources ¶
func NewPipelineRunResources(prs []pipeline.Run, lggr logger.Logger) []PipelineRunResource
func (PipelineRunResource) GetName ¶
func (r PipelineRunResource) GetName() string
GetName implements the api2go EntityNamer interface
type PipelineSpec ¶
type PipelineSpec struct { ID int32 `json:"id"` JobID int32 `json:"jobID"` DotDAGSource string `json:"dotDagSource"` }
PipelineSpec defines the spec details of the pipeline
func NewPipelineSpec ¶
func NewPipelineSpec(spec *pipeline.Spec) PipelineSpec
NewPipelineSpec generates a new PipelineSpec from a pipeline.Spec
type PipelineTaskRunResource ¶
type PipelineTaskRunResource struct { Type pipeline.TaskType `json:"type"` CreatedAt time.Time `json:"createdAt"` FinishedAt null.Time `json:"finishedAt"` Output *string `json:"output"` Error *string `json:"error"` DotID string `json:"dotId"` }
Corresponds with models.d.ts PipelineTaskRun
func NewPipelineTaskRunResource ¶
func NewPipelineTaskRunResource(tr pipeline.TaskRun) PipelineTaskRunResource
func (PipelineTaskRunResource) GetName ¶
func (r PipelineTaskRunResource) GetName() string
GetName implements the api2go EntityNamer interface
type RegistrationSettings ¶
type RegistrationSettings struct { JAID Settings protocol.CredentialCreation `json:"settings"` }
RegistrationSettings represents an enrollment settings object
func NewRegistrationSettings ¶
func NewRegistrationSettings(settings protocol.CredentialCreation) *RegistrationSettings
NewRegistrationSettings creates a new structure to enroll a new hardware key for authentication
func (RegistrationSettings) GetName ¶
func (r RegistrationSettings) GetName() string
GetName implements the api2go EntityNamer interface
type ServiceLogConfigResource ¶
type ServiceLogConfigResource struct { JAID ServiceName []string `json:"serviceName"` LogLevel []string `json:"logLevel"` DefaultLogLevel string `json:"defaultLogLevel"` }
func (ServiceLogConfigResource) GetName ¶
func (r ServiceLogConfigResource) GetName() string
GetName implements the api2go EntityNamer interface
type SolanaChainResource ¶
type SolanaChainResource struct {
ChainResource
}
SolanaChainResource is an Solana chain JSONAPI resource.
func NewSolanaChainResource ¶
func NewSolanaChainResource(chain types.ChainStatus) SolanaChainResource
NewSolanaChainResource returns a new SolanaChainResource for chain.
func (SolanaChainResource) GetName ¶
func (r SolanaChainResource) GetName() string
GetName implements the api2go EntityNamer interface
type SolanaKeyResource ¶
SolanaKeyResource represents a Solana key JSONAPI resource.
func NewSolanaKeyResource ¶
func NewSolanaKeyResource(key solkey.Key) *SolanaKeyResource
func NewSolanaKeyResources ¶
func NewSolanaKeyResources(keys []solkey.Key) []SolanaKeyResource
func (SolanaKeyResource) GetName ¶
func (SolanaKeyResource) GetName() string
GetName implements the api2go EntityNamer interface
type SolanaMsgResource ¶
type SolanaMsgResource struct { JAID ChainID string From string `json:"from"` To string `json:"to"` Amount uint64 `json:"amount"` }
SolanaMsgResource repesents a Solana message JSONAPI resource.
func NewSolanaMsgResource ¶
func NewSolanaMsgResource(id string, chainID string) SolanaMsgResource
NewSolanaMsgResource returns a new partial SolanaMsgResource.
func (SolanaMsgResource) GetName ¶
func (SolanaMsgResource) GetName() string
GetName implements the api2go EntityNamer interface
type SolanaNodeResource ¶
type SolanaNodeResource struct {
NodeResource
}
SolanaNodeResource is a Solana node JSONAPI resource.
func NewSolanaNodeResource ¶
func NewSolanaNodeResource(node types.NodeStatus) SolanaNodeResource
NewSolanaNodeResource returns a new SolanaNodeResource for node.
func (SolanaNodeResource) GetName ¶
func (r SolanaNodeResource) GetName() string
GetName implements the api2go EntityNamer interface
type StandardCapabilitiesSpec ¶ added in v2.13.0
type StandardCapabilitiesSpec struct { CreatedAt time.Time `json:"createdAt"` UpdatedAt time.Time `json:"updatedAt"` Command string `json:"command"` Config string `json:"config"` }
func NewStandardCapabilitiesSpec ¶ added in v2.13.0
func NewStandardCapabilitiesSpec(spec *job.StandardCapabilitiesSpec) *StandardCapabilitiesSpec
type StarkNetChainResource ¶
type StarkNetChainResource struct {
ChainResource
}
StarkNetChainResource is an StarkNet chain JSONAPI resource.
func NewStarkNetChainResource ¶
func NewStarkNetChainResource(chain types.ChainStatus) StarkNetChainResource
NewStarkNetChainResource returns a new StarkNetChainResource for chain.
func (StarkNetChainResource) GetName ¶
func (r StarkNetChainResource) GetName() string
GetName implements the api2go EntityNamer interface
type StarkNetKeyResource ¶
StarkNetKeyResource represents a StarkNet key JSONAPI resource.
func NewStarkNetKeyResource ¶
func NewStarkNetKeyResource(key starkkey.Key) *StarkNetKeyResource
func NewStarkNetKeyResources ¶
func NewStarkNetKeyResources(keys []starkkey.Key) []StarkNetKeyResource
func (StarkNetKeyResource) GetName ¶
func (StarkNetKeyResource) GetName() string
GetName implements the api2go EntityNamer interface
type StarkNetNodeResource ¶
type StarkNetNodeResource struct {
NodeResource
}
StarkNetNodeResource is a StarkNet node JSONAPI resource.
func NewStarkNetNodeResource ¶
func NewStarkNetNodeResource(node types.NodeStatus) StarkNetNodeResource
NewStarkNetNodeResource returns a new StarkNetNodeResource for node.
func (StarkNetNodeResource) GetName ¶
func (r StarkNetNodeResource) GetName() string
GetName implements the api2go EntityNamer interface
type UserResource ¶
type UserResource struct { JAID Email string `json:"email"` Role sessions.UserRole `json:"role"` HasActiveApiToken string `json:"hasActiveApiToken"` CreatedAt time.Time `json:"createdAt"` UpdatedAt time.Time `json:"updatedAt"` }
UserResource represents a User JSONAPI resource.
func NewUserResource ¶
func NewUserResource(u sessions.User) *UserResource
NewUserResource constructs a new UserResource.
A User does not have an ID primary key, so we must use the email
func NewUserResources ¶
func NewUserResources(users []sessions.User) []UserResource
func (UserResource) GetName ¶
func (r UserResource) GetName() string
GetName implements the api2go EntityNamer interface
type VRFKeyResource ¶
type VRFKeyResource struct { JAID Compressed string `json:"compressed"` Uncompressed string `json:"uncompressed"` Hash string `json:"hash"` }
func NewVRFKeyResource ¶
func NewVRFKeyResource(key vrfkey.KeyV2, lggr logger.Logger) *VRFKeyResource
func NewVRFKeyResources ¶
func NewVRFKeyResources(keys []vrfkey.KeyV2, lggr logger.Logger) []VRFKeyResource
func (VRFKeyResource) GetName ¶
func (VRFKeyResource) GetName() string
GetName implements the api2go EntityNamer interface
type VRFSpec ¶
type VRFSpec struct { BatchCoordinatorAddress *types.EIP55Address `json:"batchCoordinatorAddress"` BatchFulfillmentEnabled bool `json:"batchFulfillmentEnabled"` CustomRevertsPipelineEnabled *bool `json:"customRevertsPipelineEnabled,omitempty"` BatchFulfillmentGasMultiplier float64 `json:"batchFulfillmentGasMultiplier"` CoordinatorAddress types.EIP55Address `json:"coordinatorAddress"` PublicKey secp256k1.PublicKey `json:"publicKey"` FromAddresses []types.EIP55Address `json:"fromAddresses"` PollPeriod commonconfig.Duration `json:"pollPeriod"` MinIncomingConfirmations uint32 `json:"confirmations"` CreatedAt time.Time `json:"createdAt"` UpdatedAt time.Time `json:"updatedAt"` EVMChainID *big.Big `json:"evmChainID"` ChunkSize uint32 `json:"chunkSize"` RequestTimeout commonconfig.Duration `json:"requestTimeout"` BackoffInitialDelay commonconfig.Duration `json:"backoffInitialDelay"` BackoffMaxDelay commonconfig.Duration `json:"backoffMaxDelay"` GasLanePrice *assets.Wei `json:"gasLanePrice"` RequestedConfsDelay int64 `json:"requestedConfsDelay"` VRFOwnerAddress *types.EIP55Address `json:"vrfOwnerAddress,omitempty"` }
func NewVRFSpec ¶
type WebhookSpec ¶
type WebhookSpec struct { CreatedAt time.Time `json:"createdAt"` UpdatedAt time.Time `json:"updatedAt"` }
WebhookSpec defines the spec details of a Webhook Job
func NewWebhookSpec ¶
func NewWebhookSpec(spec *job.WebhookSpec) *WebhookSpec
NewWebhookSpec generates a new WebhookSpec from a job.WebhookSpec
type WorkflowSpec ¶ added in v2.12.0
type WorkflowSpec struct { Workflow string `json:"workflow"` WorkflowID string `json:"workflowId"` WorkflowOwner string `json:"workflowOwner"` WorkflowName string `json:"workflowName"` CreatedAt time.Time `json:"createdAt"` UpdatedAt time.Time `json:"updatedAt"` }
func NewWorkflowSpec ¶ added in v2.12.0
func NewWorkflowSpec(spec *job.WorkflowSpec) *WorkflowSpec
Source Files ¶
- bridges.go
- chain.go
- check.go
- cosmos_chain.go
- cosmos_key.go
- cosmos_msg.go
- csa_key.go
- dkgencrypt_key.go
- dkgsign_key.go
- eth_key.go
- eth_tx.go
- evm_chain.go
- evm_forwarder.go
- external_initiators.go
- features.go
- job.go
- jsonapi.go
- log.go
- ocr_keys.go
- p2p_key.go
- pipeline_run.go
- solana_chain.go
- solana_key.go
- solana_msg.go
- starknet_chain.go
- starknet_key.go
- user.go
- vrf_key.go
- webauthn.go