presenters

package
v1.7.2-beta2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 15, 2022 License: MIT Imports: 45 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BlockhashStoreSpec added in v1.2.0 

type BlockhashStoreSpec struct {
	CoordinatorV1Address  *ethkey.EIP55Address `json:"coordinatorV1Address"`
	CoordinatorV2Address  *ethkey.EIP55Address `json:"coordinatorV2Address"`
	WaitBlocks            int32                `json:"waitBlocks"`
	LookbackBlocks        int32                `json:"lookbackBlocks"`
	BlockhashStoreAddress ethkey.EIP55Address  `json:"blockhashStoreAddress"`
	PollPeriod            time.Duration        `json:"pollPeriod"`
	RunTimeout            time.Duration        `json:"runTimeout"`
	EVMChainID            *utils.Big           `json:"evmChainID"`
	FromAddress           *ethkey.EIP55Address `json:"fromAddress"`
	CreatedAt             time.Time            `json:"createdAt"`
	UpdatedAt             time.Time            `json:"updatedAt"`
}

BlockhashStoreSpec defines the job parameters for a blockhash store feeder job.

func NewBlockhashStoreSpec added in v1.2.0 

func NewBlockhashStoreSpec(spec *job.BlockhashStoreSpec) *BlockhashStoreSpec

NewBlockhashStoreSpec creates a new BlockhashStoreSpec for the given parameters.

type BootstrapSpec added in v1.2.0 

type BootstrapSpec struct {
	ContractID                             string                 `json:"contractID"`
	Relay                                  relay.Network          `json:"relay"`
	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 added in v1.2.0 

func NewBootstrapSpec(spec *job.BootstrapSpec) *BootstrapSpec

NewBootstrapSpec initializes a new BootstrapSpec from a job.BootstrapSpec

type BridgeResource added in v0.10.5 

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 added in v0.10.5 

func NewBridgeResource(b bridges.BridgeType) *BridgeResource

NewBridgeResource constructs a new BridgeResource

func (BridgeResource) GetName added in v0.10.5 

func (r BridgeResource) GetName() string

GetName implements the api2go EntityNamer interface

type CSAKeyResource added in v0.10.8 

type CSAKeyResource struct {
	JAID
	PubKey  string `json:"publicKey"`
	Version int    `json:"version"`
}

CSAKeyResource represents a CSA key JSONAPI resource.

func NewCSAKeyResource added in v0.10.11 

func NewCSAKeyResource(key csakey.KeyV2) *CSAKeyResource

func NewCSAKeyResources added in v0.10.11 

func NewCSAKeyResources(keys []csakey.KeyV2) []CSAKeyResource

func (CSAKeyResource) GetName added in v0.10.8 

func (CSAKeyResource) GetName() string

GetName implements the api2go EntityNamer interface

type ChainResource added in v1.0.0 

type ChainResource[C chains.Config] interface {
	IsEnabled() bool
	GetConfig() C
	jsonapi.EntityNamer
}

type Check added in v0.10.8 

type Check struct {
	JAID
	Name   string          `json:"name"`
	Status services.Status `json:"status"`
	Output string          `json:"output"`
}

func (Check) GetName added in v0.10.8 

func (c Check) GetName() string

type CronSpec added in v0.10.5 

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 added in v0.10.5 

func NewCronSpec(spec *job.CronSpec) *CronSpec

NewCronSpec generates a new CronSpec from a job.CronSpec

type DKGEncryptKeyResource added in v1.7.0 

type DKGEncryptKeyResource struct {
	JAID
	PublicKey string `json:"publicKey"`
}

DKGEncryptKeyResource is just that.

func NewDKGEncryptKeyResource added in v1.7.0 

func NewDKGEncryptKeyResource(key dkgencryptkey.Key) *DKGEncryptKeyResource

NewDKGEncryptKeyResource creates a new DKGEncryptKeyResource from the given DKG sign key.

func NewDKGEncryptKeyResources added in v1.7.0 

func NewDKGEncryptKeyResources(keys []dkgencryptkey.Key) (resources []DKGEncryptKeyResource)

NewDKGEncryptKeyResources creates many DKGEncryptKeyResource objects from the given DKG sign keys.

func (DKGEncryptKeyResource) GetName added in v1.7.0 

func (DKGEncryptKeyResource) GetName() string

GetName implements jsonapi.EntityNamer

type DKGSignKeyResource added in v1.6.0 

type DKGSignKeyResource struct {
	JAID
	PublicKey string `json:"publicKey"`
}

DKGSignKeyResource is just that.

func NewDKGSignKeyResource added in v1.6.0 

func NewDKGSignKeyResource(key dkgsignkey.Key) *DKGSignKeyResource

NewDKGSignKeyResource creates a new DKGSignKeyResource from the given DKG sign key.

func NewDKGSignKeyResources added in v1.6.0 

func NewDKGSignKeyResources(keys []dkgsignkey.Key) (resources []DKGSignKeyResource)

NewDKGSignKeyResources creates many DKGSignKeyResource objects from the given DKG sign keys.

func (DKGSignKeyResource) GetName added in v1.6.0 

func (DKGSignKeyResource) GetName() string

GetName implements jsonapi.EntityNamer

type DirectRequestSpec 

type DirectRequestSpec struct {
	ContractAddress             ethkey.EIP55Address      `json:"contractAddress"`
	MinIncomingConfirmations    clnull.Uint32            `json:"minIncomingConfirmations"`
	MinIncomingConfirmationsEnv bool                     `json:"minIncomingConfirmationsEnv,omitempty"`
	MinContractPayment          *assets.Link             `json:"minContractPaymentLinkJuels"`
	Requesters                  models.AddressCollection `json:"requesters"`
	Initiator                   string                   `json:"initiator"`
	CreatedAt                   time.Time                `json:"createdAt"`
	UpdatedAt                   time.Time                `json:"updatedAt"`
	EVMChainID                  *utils.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 added in v0.10.5 

type ETHKeyResource struct {
	JAID
	EVMChainID     utils.Big    `json:"evmChainID"`
	Address        string       `json:"address"`
	EthBalance     *assets.Eth  `json:"ethBalance"`
	LinkBalance    *assets.Link `json:"linkBalance"`
	IsFunding      bool         `json:"isFunding"`
	CreatedAt      time.Time    `json:"createdAt"`
	UpdatedAt      time.Time    `json:"updatedAt"`
	MaxGasPriceWei utils.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 added in v0.10.5 

func NewETHKeyResource(k ethkey.KeyV2, state ethkey.State, opts ...NewETHKeyOption) (*ETHKeyResource, error)

NewETHKeyResource constructs a new ETHKeyResource from a Key.

Use the functional options to inject the ETH and LINK balances

func (ETHKeyResource) GetName added in v0.10.5 

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 added in v1.2.0 

type EVMChainResource struct {
	// contains filtered or unexported fields
}

EVMChainResource is an EVM chain JSONAPI resource.

func NewEVMChainResource added in v1.2.0 

func NewEVMChainResource(chain evmtypes.DBChain) EVMChainResource

NewEVMChainResource returns a new EVMChainResource for chain.

func (EVMChainResource) GetConfig added in v1.5.0 

func (r EVMChainResource) GetConfig() C

func (EVMChainResource) GetName added in v1.2.0 

func (r EVMChainResource) GetName() string

GetName implements the api2go EntityNamer interface

func (EVMChainResource) IsEnabled added in v1.5.0 

func (r EVMChainResource) IsEnabled() bool

type EVMForwarderResource added in v1.3.0 

type EVMForwarderResource struct {
	JAID
	Address    common.Address `json:"address"`
	EVMChainID utils.Big      `json:"evmChainId"`
	CreatedAt  time.Time      `json:"createdAt"`
	UpdatedAt  time.Time      `json:"updatedAt"`
}

EVMForwarderResource is an EVM forwarder JSONAPI resource.

func NewEVMForwarderResource added in v1.3.0 

func NewEVMForwarderResource(fwd forwarders.Forwarder) EVMForwarderResource

NewEVMForwarderResource returns a new EVMForwarderResource for chain.

func (EVMForwarderResource) GetName added in v1.3.0 

func (r EVMForwarderResource) GetName() string

GetName implements the api2go EntityNamer interface

type EVMNodeResource added in v1.2.0 

type EVMNodeResource struct {
	JAID
	Name       string      `json:"name"`
	EVMChainID utils.Big   `json:"evmChainID"`
	WSURL      null.String `json:"wsURL"`
	HTTPURL    null.String `json:"httpURL"`
	State      string      `json:"state"`
	CreatedAt  time.Time   `json:"createdAt"`
	UpdatedAt  time.Time   `json:"updatedAt"`
}

EVMNodeResource is an EVM node JSONAPI resource.

func NewEVMNodeResource added in v1.2.0 

func NewEVMNodeResource(node evmtypes.Node) EVMNodeResource

NewEVMNodeResource returns a new EVMNodeResource for node.

func (EVMNodeResource) GetName added in v1.2.0 

func (r EVMNodeResource) GetName() string

GetName implements the api2go EntityNamer interface

type EthTxResource added in v0.10.5 

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 utils.Big       `json:"evmChainID"`
}

EthTxResource represents a Ethereum Transaction JSONAPI resource.

func NewEthTxResource added in v0.10.5 

func NewEthTxResource(tx txmgr.EthTx) 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 added in v0.10.5 

func NewEthTxResourceFromAttempt(txa txmgr.EthTxAttempt) EthTxResource

func (EthTxResource) GetName added in v0.10.5 

func (EthTxResource) GetName() string

GetName implements the api2go EntityNamer interface

type ExternalInitiatorAuthentication added in v0.10.11 

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 added in v0.10.11 

func NewExternalInitiatorAuthentication(
	ei bridges.ExternalInitiator,
	eia auth.Token,
) *ExternalInitiatorAuthentication

NewExternalInitiatorAuthentication creates an instance of ExternalInitiatorAuthentication.

func (*ExternalInitiatorAuthentication) GetID added in v0.10.11 

func (ei *ExternalInitiatorAuthentication) GetID() string

GetID returns the jsonapi ID.

func (*ExternalInitiatorAuthentication) GetName added in v0.10.11 

func (*ExternalInitiatorAuthentication) GetName() string

GetName returns the collection name for jsonapi.

func (*ExternalInitiatorAuthentication) SetID added in v0.10.11 

func (ei *ExternalInitiatorAuthentication) SetID(name string) error

SetID is used to conform to the UnmarshallIdentifier interface for deserializing from jsonapi documents.

type ExternalInitiatorResource added in v0.10.11 

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 added in v0.10.11 

func NewExternalInitiatorResource(ei bridges.ExternalInitiator) ExternalInitiatorResource

func (ExternalInitiatorResource) GetName added in v0.10.11 

func (ExternalInitiatorResource) GetName() string

GetName returns the collection name for jsonapi.

type FeatureResource added in v1.0.0 

type FeatureResource struct {
	JAID
	Enabled bool `json:"enabled"`
}

FeatureResource represents a Feature JSONAPI resource.

func NewFeatureResource added in v1.0.0 

func NewFeatureResource(name string, enabled bool) *FeatureResource

NewFeedsManagerResource constructs a new FeedsManagerResource.

func (FeatureResource) GetName added in v1.0.0 

func (r FeatureResource) GetName() string

GetName implements the api2go EntityNamer interface

type FluxMonitorSpec 

type FluxMonitorSpec struct {
	ContractAddress     ethkey.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          *assets.Link        `json:"minPayment"`
	CreatedAt           time.Time           `json:"createdAt"`
	UpdatedAt           time.Time           `json:"updatedAt"`
	EVMChainID          *utils.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 JAID 

type JAID struct {
	ID string `json:"-"`
}

JAID represents a JSON API ID. It implements the api2go MarshalIdentifier and UnmarshalIdentitier interface.

func NewJAID added in v0.10.5 

func NewJAID(id string) JAID

func NewJAIDInt32 

func NewJAIDInt32(id int32) JAID

NewJAIDInt32 converts an int32 into a JAID

func NewJAIDInt64 added in v0.10.5 

func NewJAIDInt64(id int64) JAID

NewJAIDInt64 converts an int64 into a JAID

func (JAID) GetID 

func (jaid JAID) GetID() string

GetID implements the api2go MarshalIdentifier interface.

func (*JAID) SetID 

func (jaid *JAID) SetID(value string) error

SetID implements the api2go UnmarshalIdentitier interface.

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 

func NewJobError(e job.SpecError) JobError

type JobResource 

type JobResource struct {
	JAID
	Name                   string                  `json:"name"`
	Type                   JobSpecType             `json:"type"`
	SchemaVersion          uint32                  `json:"schemaVersion"`
	GasLimit               clnull.Uint32           `json:"gasLimit"`
	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"`
	BootstrapSpec          *BootstrapSpec          `json:"bootstrapSpec"`
	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 the 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"
	BootstrapJobSpec         JobSpecType = "bootstrap"
)

func (JobSpecType) String 

func (t JobSpecType) String() string

type KeeperSpec 

type KeeperSpec struct {
	ContractAddress ethkey.EIP55Address `json:"contractAddress"`
	FromAddress     ethkey.EIP55Address `json:"fromAddress"`
	CreatedAt       time.Time           `json:"createdAt"`
	UpdatedAt       time.Time           `json:"updatedAt"`
	EVMChainID      *utils.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 added in v0.10.5 

type NewETHKeyOption func(*ETHKeyResource) error

NewETHKeyOption defines a functional option which allows customisation of the EthKeyResource

func SetETHKeyEthBalance added in v0.10.5 

func SetETHKeyEthBalance(ethBalance *assets.Eth) NewETHKeyOption

func SetETHKeyLinkBalance added in v0.10.5 

func SetETHKeyLinkBalance(linkBalance *assets.Link) NewETHKeyOption

func SetETHKeyMaxGasPriceWei added in v1.1.0 

func SetETHKeyMaxGasPriceWei(maxGasPriceWei utils.Big) NewETHKeyOption

type OCR2KeysBundleResource added in v1.2.0 

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 added in v1.2.0 

func NewOCR2KeysBundleResource(key ocr2key.KeyBundle) *OCR2KeysBundleResource

func NewOCR2KeysBundleResources added in v1.2.0 

func NewOCR2KeysBundleResources(keys []ocr2key.KeyBundle) []OCR2KeysBundleResource

func (OCR2KeysBundleResource) GetName added in v1.2.0 

func (r OCR2KeysBundleResource) GetName() string

GetName implements the api2go EntityNamer interface

type OCRKeysBundleResource added in v0.10.6 

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 added in v0.10.6 

func NewOCRKeysBundleResource(key ocrkey.KeyV2) *OCRKeysBundleResource

func NewOCRKeysBundleResources added in v0.10.6 

func NewOCRKeysBundleResources(keys []ocrkey.KeyV2) []OCRKeysBundleResource

func (OCRKeysBundleResource) GetName added in v0.10.6 

func (r OCRKeysBundleResource) GetName() string

GetName implements the api2go EntityNamer interface

type OffChainReporting2Spec added in v1.2.0 

type OffChainReporting2Spec struct {
	ContractID                        string                 `json:"contractID"`
	Relay                             relay.Network          `json:"relay"`
	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"`
}

OffChainReporting2Spec defines the spec details of a OffChainReporting2 Job

func NewOffChainReporting2Spec added in v1.2.0 

func NewOffChainReporting2Spec(spec *job.OCR2OracleSpec) *OffChainReporting2Spec

NewOffChainReporting2Spec initializes a new OffChainReportingSpec from a job.OCR2OracleSpec

type OffChainReportingSpec 

type OffChainReportingSpec struct {
	ContractAddress                           ethkey.EIP55Address  `json:"contractAddress"`
	P2PBootstrapPeers                         pq.StringArray       `json:"p2pBootstrapPeers"`
	P2PV2Bootstrappers                        pq.StringArray       `json:"p2pv2Bootstrappers"`
	IsBootstrapPeer                           bool                 `json:"isBootstrapPeer"`
	EncryptedOCRKeyBundleID                   *models.Sha256Hash   `json:"keyBundleID"`
	TransmitterAddress                        *ethkey.EIP55Address `json:"transmitterAddress"`
	ObservationTimeout                        models.Interval      `json:"observationTimeout"`
	ObservationTimeoutEnv                     bool                 `json:"observationTimeoutEnv,omitempty"`
	BlockchainTimeout                         models.Interval      `json:"blockchainTimeout"`
	BlockchainTimeoutEnv                      bool                 `json:"blockchainTimeoutEnv,omitempty"`
	ContractConfigTrackerSubscribeInterval    models.Interval      `json:"contractConfigTrackerSubscribeInterval"`
	ContractConfigTrackerSubscribeIntervalEnv bool                 `json:"contractConfigTrackerSubscribeIntervalEnv,omitempty"`
	ContractConfigTrackerPollInterval         models.Interval      `json:"contractConfigTrackerPollInterval"`
	ContractConfigTrackerPollIntervalEnv      bool                 `json:"contractConfigTrackerPollIntervalEnv,omitempty"`
	ContractConfigConfirmations               uint16               `json:"contractConfigConfirmations"`
	ContractConfigConfirmationsEnv            bool                 `json:"contractConfigConfirmationsEnv,omitempty"`
	CreatedAt                                 time.Time            `json:"createdAt"`
	UpdatedAt                                 time.Time            `json:"updatedAt"`
	EVMChainID                                *utils.Big           `json:"evmChainID"`
	DatabaseTimeout                           *models.Interval     `json:"databaseTimeout"`
	DatabaseTimeoutEnv                        bool                 `json:"databaseTimeoutEnv,omitempty"`
	ObservationGracePeriod                    *models.Interval     `json:"observationGracePeriod"`
	ObservationGracePeriodEnv                 bool                 `json:"observationGracePeriodEnv,omitempty"`
	ContractTransmitterTransmitTimeout        *models.Interval     `json:"contractTransmitterTransmitTimeout"`
	ContractTransmitterTransmitTimeoutEnv     bool                 `json:"contractTransmitterTransmitTimeoutEnv,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 added in v0.10.5 

type P2PKeyResource struct {
	JAID
	PeerID string `json:"peerId"`
	PubKey string `json:"publicKey"`
}

P2PKeyResource represents a P2P key JSONAPI resource.

func NewP2PKeyResource added in v0.10.5 

func NewP2PKeyResource(key p2pkey.KeyV2) *P2PKeyResource

func NewP2PKeyResources added in v0.10.5 

func NewP2PKeyResources(keys []p2pkey.KeyV2) []P2PKeyResource

func (P2PKeyResource) GetName added in v0.10.5 

func (P2PKeyResource) GetName() string

GetName implements the api2go EntityNamer interface

type PipelineRunResource added in v0.10.11 

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       pipeline.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 added in v0.10.11 

func NewPipelineRunResource(pr pipeline.Run, lggr logger.Logger) PipelineRunResource

func NewPipelineRunResources added in v0.10.11 

func NewPipelineRunResources(prs []pipeline.Run, lggr logger.Logger) []PipelineRunResource

func (PipelineRunResource) GetName added in v0.10.11 

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 added in v0.10.11 

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 added in v0.10.11 

func NewPipelineTaskRunResource(tr pipeline.TaskRun) PipelineTaskRunResource

func (PipelineTaskRunResource) GetName added in v0.10.11 

func (r PipelineTaskRunResource) GetName() string

GetName implements the api2go EntityNamer interface

type RegistrationSettings added in v1.1.0 

type RegistrationSettings struct {
	JAID
	Settings protocol.CredentialCreation `json:"settings"`
}

RegistrationSettings represents an enrollment settings object

func NewRegistrationSettings added in v1.1.0 

func NewRegistrationSettings(settings protocol.CredentialCreation) *RegistrationSettings

NewRegistrationSettings creates a new structure to enroll a new hardware key for authentication

func (RegistrationSettings) GetName added in v1.1.0 

func (r RegistrationSettings) GetName() string

GetName implements the api2go EntityNamer interface

type ServiceLogConfigResource added in v0.10.6 

type ServiceLogConfigResource struct {
	JAID
	ServiceName     []string `json:"serviceName"`
	LogLevel        []string `json:"logLevel"`
	DefaultLogLevel string   `json:"defaultLogLevel"`
}

func (ServiceLogConfigResource) GetName added in v0.10.6 

func (r ServiceLogConfigResource) GetName() string

GetName implements the api2go EntityNamer interface

type SolanaChainResource added in v1.4.0 

type SolanaChainResource struct {
	// contains filtered or unexported fields
}

SolanaChainResource is an Solana chain JSONAPI resource.

func NewSolanaChainResource added in v1.4.0 

func NewSolanaChainResource(chain solana.DBChain) SolanaChainResource

NewSolanaChainResource returns a new SolanaChainResource for chain.

func (SolanaChainResource) GetConfig added in v1.5.0 

func (r SolanaChainResource) GetConfig() C

func (SolanaChainResource) GetName added in v1.4.0 

func (r SolanaChainResource) GetName() string

GetName implements the api2go EntityNamer interface

func (SolanaChainResource) IsEnabled added in v1.5.0 

func (r SolanaChainResource) IsEnabled() bool

type SolanaKeyResource added in v1.2.0 

type SolanaKeyResource struct {
	JAID
	PubKey string `json:"publicKey"`
}

SolanaKeyResource represents a Solana key JSONAPI resource.

func NewSolanaKeyResource added in v1.2.0 

func NewSolanaKeyResource(key solkey.Key) *SolanaKeyResource

func NewSolanaKeyResources added in v1.2.0 

func NewSolanaKeyResources(keys []solkey.Key) []SolanaKeyResource

func (SolanaKeyResource) GetName added in v1.2.0 

func (SolanaKeyResource) GetName() string

GetName implements the api2go EntityNamer interface

type SolanaMsgResource added in v1.4.0 

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 added in v1.4.0 

func NewSolanaMsgResource(id string, chainID string) SolanaMsgResource

NewSolanaMsgResource returns a new partial SolanaMsgResource.

func (SolanaMsgResource) GetName added in v1.4.0 

func (SolanaMsgResource) GetName() string

GetName implements the api2go EntityNamer interface

type SolanaNodeResource added in v1.4.0 

type SolanaNodeResource struct {
	JAID
	Name          string    `json:"name"`
	SolanaChainID string    `json:"solanaChainID"`
	SolanaURL     string    `json:"solanaURL"`
	CreatedAt     time.Time `json:"createdAt"`
	UpdatedAt     time.Time `json:"updatedAt"`
}

SolanaNodeResource is a Solana node JSONAPI resource.

func NewSolanaNodeResource added in v1.4.0 

func NewSolanaNodeResource(node db.Node) SolanaNodeResource

NewSolanaNodeResource returns a new SolanaNodeResource for node.

func (SolanaNodeResource) GetName added in v1.4.0 

func (r SolanaNodeResource) GetName() string

GetName implements the api2go EntityNamer interface

type StarkNetChainResource added in v1.7.0 

type StarkNetChainResource struct {
	// contains filtered or unexported fields
}

StarkNetChainResource is an StarkNet chain JSONAPI resource.

func NewStarkNetChainResource added in v1.7.0 

func NewStarkNetChainResource(chain starknet.DBChain) StarkNetChainResource

NewStarkNetChainResource returns a new StarkNetChainResource for chain.

func (StarkNetChainResource) GetConfig added in v1.7.0 

func (r StarkNetChainResource) GetConfig() C

func (StarkNetChainResource) GetName added in v1.7.0 

func (r StarkNetChainResource) GetName() string

GetName implements the api2go EntityNamer interface

func (StarkNetChainResource) IsEnabled added in v1.7.0 

func (r StarkNetChainResource) IsEnabled() bool

type StarkNetKeyResource added in v1.6.0 

type StarkNetKeyResource struct {
	JAID
	PubKey string `json:"publicKey"`
}

StarkNetKeyResource represents a Solana key JSONAPI resource.

func NewStarkNetKeyResource added in v1.6.0 

func NewStarkNetKeyResource(key starkkey.Key) *StarkNetKeyResource

func NewStarkNetKeyResources added in v1.6.0 

func NewStarkNetKeyResources(keys []starkkey.Key) []StarkNetKeyResource

func (StarkNetKeyResource) GetName added in v1.6.0 

func (StarkNetKeyResource) GetName() string

GetName implements the api2go EntityNamer interface

type StarkNetNodeResource added in v1.7.0 

type StarkNetNodeResource struct {
	JAID
	Name      string    `json:"name"`
	ChainID   string    `json:"chainID"`
	URL       string    `json:"url"`
	CreatedAt time.Time `json:"createdAt"`
	UpdatedAt time.Time `json:"updatedAt"`
}

StarkNetNodeResource is a StarkNet node JSONAPI resource.

func NewStarkNetNodeResource added in v1.7.0 

func NewStarkNetNodeResource(node db.Node) StarkNetNodeResource

NewStarkNetNodeResource returns a new StarkNetNodeResource for node.

func (StarkNetNodeResource) GetName added in v1.7.0 

func (r StarkNetNodeResource) GetName() string

GetName implements the api2go EntityNamer interface

type TerraChainResource added in v1.2.0 

type TerraChainResource struct {
	// contains filtered or unexported fields
}

TerraChainResource is an Terra chain JSONAPI resource.

func NewTerraChainResource added in v1.2.0 

func NewTerraChainResource(chain types.DBChain) TerraChainResource

NewTerraChainResource returns a new TerraChainResource for chain.

func (TerraChainResource) GetConfig added in v1.5.0 

func (r TerraChainResource) GetConfig() C

func (TerraChainResource) GetName added in v1.2.0 

func (r TerraChainResource) GetName() string

GetName implements the api2go EntityNamer interface

func (TerraChainResource) IsEnabled added in v1.5.0 

func (r TerraChainResource) IsEnabled() bool

type TerraKeyResource added in v1.2.0 

type TerraKeyResource struct {
	JAID
	PubKey string `json:"publicKey"`
}

TerraKeyResource represents a Terra key JSONAPI resource.

func NewTerraKeyResource added in v1.2.0 

func NewTerraKeyResource(key terrakey.Key) *TerraKeyResource

func NewTerraKeyResources added in v1.2.0 

func NewTerraKeyResources(keys []terrakey.Key) []TerraKeyResource

func (TerraKeyResource) GetName added in v1.2.0 

func (TerraKeyResource) GetName() string

GetName implements the api2go EntityNamer interface

type TerraMsgResource added in v1.3.0 

type TerraMsgResource struct {
	JAID
	ChainID    string
	ContractID string
	State      string
	TxHash     *string
}

TerraMsgResource repesents a Terra message JSONAPI resource.

func NewTerraMsgResource added in v1.3.0 

func NewTerraMsgResource(id int64, chainID string, contractID string) TerraMsgResource

NewTerraMsgResource returns a new partial TerraMsgResource.

func (TerraMsgResource) GetName added in v1.3.0 

func (TerraMsgResource) GetName() string

GetName implements the api2go EntityNamer interface

type TerraNodeResource added in v1.2.0 

type TerraNodeResource struct {
	JAID
	Name          string    `json:"name"`
	TerraChainID  string    `json:"terraChainID"`
	TendermintURL string    `json:"tendermintURL"`
	CreatedAt     time.Time `json:"createdAt"`
	UpdatedAt     time.Time `json:"updatedAt"`
}

TerraNodeResource is a Terra node JSONAPI resource.

func NewTerraNodeResource added in v1.2.0 

func NewTerraNodeResource(node db.Node) TerraNodeResource

NewTerraNodeResource returns a new TerraNodeResource for node.

func (TerraNodeResource) GetName added in v1.2.0 

func (r TerraNodeResource) GetName() string

GetName implements the api2go EntityNamer interface

type UserResource added in v0.10.5 

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 added in v0.10.5 

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 added in v1.7.0 

func NewUserResources(users []sessions.User) []UserResource

func (UserResource) GetName added in v0.10.5 

func (r UserResource) GetName() string

GetName implements the api2go EntityNamer interface

type VRFKeyResource added in v0.10.9 

type VRFKeyResource struct {
	JAID
	Compressed   string `json:"compressed"`
	Uncompressed string `json:"uncompressed"`
	Hash         string `json:"hash"`
}

func NewVRFKeyResource added in v0.10.9 

func NewVRFKeyResource(key vrfkey.KeyV2, lggr logger.Logger) *VRFKeyResource

func NewVRFKeyResources added in v0.10.9 

func NewVRFKeyResources(keys []vrfkey.KeyV2, lggr logger.Logger) []VRFKeyResource

func (VRFKeyResource) GetName added in v0.10.9 

func (VRFKeyResource) GetName() string

GetName implements the api2go EntityNamer interface

type VRFSpec added in v0.10.8 

type VRFSpec struct {
	BatchCoordinatorAddress       *ethkey.EIP55Address  `json:"batchCoordinatorAddress"`
	BatchFulfillmentEnabled       bool                  `json:"batchFulfillmentEnabled"`
	BatchFulfillmentGasMultiplier float64               `json:"batchFulfillmentGasMultiplier"`
	CoordinatorAddress            ethkey.EIP55Address   `json:"coordinatorAddress"`
	PublicKey                     secp256k1.PublicKey   `json:"publicKey"`
	FromAddresses                 []ethkey.EIP55Address `json:"fromAddresses"`
	PollPeriod                    models.Duration       `json:"pollPeriod"`
	MinIncomingConfirmations      uint32                `json:"confirmations"`
	CreatedAt                     time.Time             `json:"createdAt"`
	UpdatedAt                     time.Time             `json:"updatedAt"`
	EVMChainID                    *utils.Big            `json:"evmChainID"`
	ChunkSize                     uint32                `json:"chunkSize"`
	RequestTimeout                models.Duration       `json:"requestTimeout"`
	BackoffInitialDelay           models.Duration       `json:"backoffInitialDelay"`
	BackoffMaxDelay               models.Duration       `json:"backoffMaxDelay"`
	MaxGasPriceGWei               *uint32               `json:"maxGasPriceGWei"`
}

func NewVRFSpec added in v0.10.8 

func NewVRFSpec(spec *job.VRFSpec) *VRFSpec

type WebhookSpec added in v0.10.8 

type WebhookSpec struct {
	CreatedAt time.Time `json:"createdAt"`
	UpdatedAt time.Time `json:"updatedAt"`
}

WebhookSpec defines the spec details of a Webhook Job

func NewWebhookSpec added in v0.10.8 

func NewWebhookSpec(spec *job.WebhookSpec) *WebhookSpec

NewWebhookSpec generates a new WebhookSpec from a job.WebhookSpec

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.