Documentation
¶
Index ¶
- Constants
- Variables
- func CreateNodeKeysBundle(nodes []*ChainlinkClient, chainName string, chainId string) ([]NodeKeysBundle, []*CLNodesWithKeys, error)
- func MarshallTemplate(jobSpec interface{}, name, templateString string) (string, error)
- func ObservationSourceSpecBridge(bta *BridgeTypeAttributes) string
- func ObservationSourceSpecHTTP(url string) string
- func VerifyStatusCode(actStatusCd, expStatusCd int) error
- func VerifyStatusCodeWithResponse(res *resty.Response, expStatusCd int) error
- type BlockHeaderFeederJobSpec
- type BlockhashStoreJobSpec
- type BridgeType
- type BridgeTypeAttributes
- type BridgeTypeData
- type Bridges
- type CLNodesWithKeys
- type CSAKey
- type CSAKeyAttributes
- type CSAKeyData
- type CSAKeys
- type ChainlinkClient
- func (c *ChainlinkClient) CreateBridge(bta *BridgeTypeAttributes) (*http.Response, error)
- func (c *ChainlinkClient) CreateCSAKey() (*CSAKey, *http.Response, error)
- func (c *ChainlinkClient) CreateCosmosChain(chain *CosmosChainAttributes) (*CosmosChainCreate, *http.Response, error)
- func (c *ChainlinkClient) CreateCosmosNode(node *CosmosNodeAttributes) (*CosmosNodeCreate, *http.Response, error)
- func (c *ChainlinkClient) CreateEI(eia *EIAttributes) (*EIKeyCreate, *http.Response, error)
- func (c *ChainlinkClient) CreateJob(spec JobSpec) (*Job, *resty.Response, error)
- func (c *ChainlinkClient) CreateJobRaw(spec string) (*Job, *http.Response, error)
- func (c *ChainlinkClient) CreateOCR2Key(chain string) (*OCR2Key, *http.Response, error)
- func (c *ChainlinkClient) CreateOCRKey() (*OCRKey, *http.Response, error)
- func (c *ChainlinkClient) CreateP2PKey() (*P2PKey, *http.Response, error)
- func (c *ChainlinkClient) CreateSolanaChain(chain *SolanaChainAttributes) (*SolanaChainCreate, *http.Response, error)
- func (c *ChainlinkClient) CreateSolanaNode(node *SolanaNodeAttributes) (*SolanaNodeCreate, *http.Response, error)
- func (c *ChainlinkClient) CreateSpec(spec string) (*Spec, *http.Response, error)
- func (c *ChainlinkClient) CreateStarkNetChain(chain *StarkNetChainAttributes) (*StarkNetChainCreate, *http.Response, error)
- func (c *ChainlinkClient) CreateStarkNetNode(node *StarkNetNodeAttributes) (*StarkNetNodeCreate, *http.Response, error)
- func (c *ChainlinkClient) CreateTxKey(chain string, chainId string) (*TxKey, *http.Response, error)
- func (c *ChainlinkClient) DeleteBridge(name string) (*http.Response, error)
- func (c *ChainlinkClient) DeleteEI(name string) (*http.Response, error)
- func (c *ChainlinkClient) DeleteJob(id string) (*http.Response, error)
- func (c *ChainlinkClient) DeleteOCR2Key(id string) (*http.Response, error)
- func (c *ChainlinkClient) DeleteOCRKey(id string) (*http.Response, error)
- func (c *ChainlinkClient) DeleteP2PKey(id int) (*http.Response, error)
- func (c *ChainlinkClient) DeleteSpec(id string) (*http.Response, error)
- func (c *ChainlinkClient) DeleteTxKey(chain string, id string) (*http.Response, error)
- func (c *ChainlinkClient) EthAddresses() ([]string, error)
- func (c *ChainlinkClient) EthAddressesForChain(chainId string) ([]string, error)
- func (c *ChainlinkClient) ExportEVMKeys() ([]*ExportedEVMKey, error)
- func (c *ChainlinkClient) ExportEVMKeysForChain(chainid string) ([]*ExportedEVMKey, error)
- func (c *ChainlinkClient) ExportVRFKey(keyId string) (*VRFExportKey, *http.Response, error)
- func (c *ChainlinkClient) GetConfig() Config
- func (c *ChainlinkClient) GetForwarders() (*Forwarders, *http.Response, error)
- func (c *ChainlinkClient) Health() (*HealthResponse, *http.Response, error)
- func (c *ChainlinkClient) ImportVRFKey(vrfExportKey *VRFExportKey) (*VRFKey, *http.Response, error)
- func (c *ChainlinkClient) InternalIP() string
- func (c *ChainlinkClient) MustCreateBridge(bta *BridgeTypeAttributes) error
- func (c *ChainlinkClient) MustCreateJob(spec JobSpec) (*Job, error)
- func (c *ChainlinkClient) MustCreateVRFKey() (*VRFKey, error)
- func (c *ChainlinkClient) MustDeleteJob(id string) error
- func (c *ChainlinkClient) MustReadCSAKeys() (*CSAKeys, *resty.Response, error)
- func (c *ChainlinkClient) MustReadETHKeys() (*ETHKeys, error)
- func (c *ChainlinkClient) MustReadOCR2Keys() (*OCR2Keys, error)
- func (c *ChainlinkClient) MustReadOCRKeys() (*OCRKeys, error)
- func (c *ChainlinkClient) MustReadP2PKeys() (*P2PKeys, error)
- func (c *ChainlinkClient) MustReadRunsByJob(jobID string) (*JobRunsResponse, error)
- func (c *ChainlinkClient) MustReadTransactionAttempts() (*TransactionsData, error)
- func (c *ChainlinkClient) MustSendNativeToken(amount *big.Int, fromAddress, toAddress string) (TransactionData, error)
- func (c *ChainlinkClient) PrimaryEthAddress() (string, error)
- func (c *ChainlinkClient) PrimaryEthAddressForChain(chainId string) (string, error)
- func (c *ChainlinkClient) Profile(profileTime time.Duration, profileFunction func(*ChainlinkClient)) (*ChainlinkProfileResults, error)
- func (c *ChainlinkClient) ReadBridge(name string) (*BridgeType, *http.Response, error)
- func (c *ChainlinkClient) ReadBridges() (*Bridges, *resty.Response, error)
- func (c *ChainlinkClient) ReadCSAKeys() (*CSAKeys, *resty.Response, error)
- func (c *ChainlinkClient) ReadEIs() (*EIKeys, *http.Response, error)
- func (c *ChainlinkClient) ReadETHKeyAtIndex(keyIndex int) (*ETHKeyData, error)
- func (c *ChainlinkClient) ReadJob(id string) (*Response, *http.Response, error)
- func (c *ChainlinkClient) ReadJobs() (*ResponseSlice, *http.Response, error)
- func (c *ChainlinkClient) ReadOCR2Keys() (*OCR2Keys, *http.Response, error)
- func (c *ChainlinkClient) ReadPrimaryETHKey(chainId string) (*ETHKeyData, error)
- func (c *ChainlinkClient) ReadRunsByJob(jobID string) (*JobRunsResponse, *http.Response, error)
- func (c *ChainlinkClient) ReadSpec(id string) (*Response, *http.Response, error)
- func (c *ChainlinkClient) ReadTransactions() (*TransactionsData, *http.Response, error)
- func (c *ChainlinkClient) ReadTxKeys(chain string) (*TxKeys, *http.Response, error)
- func (c *ChainlinkClient) ReadVRFKeys() (*VRFKeys, *http.Response, error)
- func (c *ChainlinkClient) SetPageSize(size int)
- func (c *ChainlinkClient) TrackForwarder(chainID *big.Int, address common.Address) (*Forwarder, *http.Response, error)
- func (c *ChainlinkClient) URL() string
- func (c *ChainlinkClient) UpdateEthKeyMaxGasPriceGWei(keyId string, gWei int) (*ETHKey, *http.Response, error)
- type ChainlinkProfileResult
- type ChainlinkProfileResults
- type Config
- type CosmosChain
- type CosmosChainAttributes
- type CosmosChainConfig
- type CosmosChainCreate
- type CosmosNode
- type CosmosNodeAttributes
- type CosmosNodeCreate
- type CronJobSpec
- type DecodeLogTaskRun
- type DirectRequestJobSpec
- type DirectRequestTxPipelineSpec
- type EIAttributes
- type EIKey
- type EIKeyCreate
- type EIKeys
- type EIServiceConfig
- type ETHKey
- type ETHKeyAttributes
- type ETHKeyData
- type ETHKeys
- type ExportedEVMKey
- type FluxMonitorJobSpec
- type Forwarder
- type ForwarderAttributes
- type ForwarderData
- type Forwarders
- type HealthResponse
- type Job
- type JobData
- type JobForm
- type JobRunsResponse
- type JobSpec
- type KeeperJobSpec
- type NodeKeysBundle
- type OCR2Key
- type OCR2KeyAttributes
- type OCR2KeyData
- type OCR2Keys
- type OCRBootstrapJobSpec
- type OCRKey
- type OCRKeyAttributes
- type OCRKeyData
- type OCRKeys
- type OCRTaskJobSpec
- type P2PData
- type P2PKey
- type P2PKeyAttributes
- type P2PKeyData
- type P2PKeys
- type PipelineSpec
- type Response
- type ResponseSlice
- type RunInputs
- type RunsAttributesResponse
- type RunsMetaResponse
- type RunsResponseData
- type SendEtherRequest
- type Session
- type SingleTransactionDataWrapper
- type SolanaChain
- type SolanaChainAttributes
- type SolanaChainConfig
- type SolanaChainCreate
- type SolanaNode
- type SolanaNodeAttributes
- type SolanaNodeCreate
- type Spec
- type SpecData
- type SpecForm
- type StarkNetChain
- type StarkNetChainAttributes
- type StarkNetChainConfig
- type StarkNetChainCreate
- type StarkNetNode
- type StarkNetNodeAttributes
- type StarkNetNodeCreate
- type TaskRun
- type TransactionAttributes
- type TransactionData
- type TransactionsData
- type TransactionsMetaData
- type TxKey
- type TxKeyAttributes
- type TxKeyData
- type TxKeys
- type VRFExportKey
- type VRFJobSpec
- type VRFKey
- type VRFKeyAttributes
- type VRFKeyData
- type VRFKeys
- type VRFTxPipelineSpec
- type VRFV2JobSpec
- type VRFV2PlusJobSpec
- type VRFV2PlusTxPipelineSpec
- type VRFV2TxPipelineSpec
- type WebhookJobSpec
Constants ¶
const ( // ChainlinkKeyPassword used to encrypt exported keys ChainlinkKeyPassword string = "twochains" // NodeURL string for logging NodeURL string = "Node URL" )
Variables ¶
var ( // OneLINK representation of a single LINK token OneLINK = big.NewFloat(1e18) )
Functions ¶
func CreateNodeKeysBundle ¶
func CreateNodeKeysBundle(nodes []*ChainlinkClient, chainName string, chainId string) ([]NodeKeysBundle, []*CLNodesWithKeys, error)
func MarshallTemplate ¶
marshallTemplate Helper to marshall templates
func ObservationSourceSpecBridge ¶
func ObservationSourceSpecBridge(bta *BridgeTypeAttributes) string
ObservationSourceSpecBridge creates a bridge task spec for json data
func ObservationSourceSpecHTTP ¶
ObservationSourceSpecHTTP creates a http GET task spec for json data
func VerifyStatusCode ¶
VerifyStatusCode verifies the status code of the response. Favor VerifyStatusCodeWithResponse over this for better errors
func VerifyStatusCodeWithResponse ¶
VerifyStatusCodeWithResponse verifies the status code of the response and returns the response as part of the error. Favor this over VerifyStatusCode
Types ¶
type BlockHeaderFeederJobSpec ¶
type BlockHeaderFeederJobSpec struct {
Name string `toml:"name"`
CoordinatorV2Address string `toml:"coordinatorV2Address"`
CoordinatorV2PlusAddress string `toml:"coordinatorV2PlusAddress"`
BlockhashStoreAddress string `toml:"blockhashStoreAddress"`
BatchBlockhashStoreAddress string `toml:"batchBlockhashStoreAddress"`
ExternalJobID string `toml:"externalJobID"`
FromAddresses []string `toml:"fromAddresses"`
EVMChainID string `toml:"evmChainID"`
ForwardingAllowed bool `toml:"forwardingAllowed"`
PollPeriod time.Duration `toml:"pollPeriod"`
RunTimeout time.Duration `toml:"runTimeout"`
WaitBlocks int `toml:"waitBlocks"`
LookbackBlocks int `toml:"lookbackBlocks"`
}
BlockHeaderFeederJobSpec represents a blockheaderfeeder job
func (*BlockHeaderFeederJobSpec) String ¶
func (b *BlockHeaderFeederJobSpec) String() (string, error)
String representation of the job
func (*BlockHeaderFeederJobSpec) Type ¶
func (b *BlockHeaderFeederJobSpec) Type() string
Type returns the type of the job
type BlockhashStoreJobSpec ¶
type BlockhashStoreJobSpec struct {
Name string `toml:"name"`
CoordinatorV2Address string `toml:"coordinatorV2Address"`
CoordinatorV2PlusAddress string `toml:"coordinatorV2PlusAddress"`
BlockhashStoreAddress string `toml:"blockhashStoreAddress"`
ExternalJobID string `toml:"externalJobID"`
FromAddresses []string `toml:"fromAddresses"`
EVMChainID string `toml:"evmChainID"`
ForwardingAllowed bool `toml:"forwardingAllowed"`
PollPeriod time.Duration `toml:"pollPeriod"`
RunTimeout time.Duration `toml:"runTimeout"`
WaitBlocks int `toml:"waitBlocks"`
LookbackBlocks int `toml:"lookbackBlocks"`
}
BlockhashStoreJobSpec represents a blockhashstore job
func (*BlockhashStoreJobSpec) String ¶
func (b *BlockhashStoreJobSpec) String() (string, error)
String representation of the job
func (*BlockhashStoreJobSpec) Type ¶
func (b *BlockhashStoreJobSpec) Type() string
Type returns the type of the job
type BridgeType ¶
type BridgeType struct {
Data BridgeTypeData `json:"data"`
}
BridgeType is the model that represents the bridge when read or created on a Chainlink node
type BridgeTypeAttributes ¶
type BridgeTypeAttributes struct {
Name string `json:"name"`
URL string `json:"url"`
RequestData string `json:"requestData,omitempty"`
}
BridgeTypeAttributes is the model that represents the bridge when read or created on a Chainlink node
type BridgeTypeData ¶
type BridgeTypeData struct {
Attributes BridgeTypeAttributes `json:"attributes"`
}
BridgeTypeData is the model that represents the bridge when read or created on a Chainlink node
type Bridges ¶
type Bridges struct {
Data []BridgeTypeData `json:"data"`
}
Bridges is the model that represents the bridges when read on a Chainlink node
type CLNodesWithKeys ¶
type CLNodesWithKeys struct {
Node *ChainlinkClient
KeysBundle NodeKeysBundle
}
type CSAKey ¶
type CSAKey struct {
Data CSAKeyData `json:"data"`
}
CSAKey is the model that represents the created CSA key when created
type CSAKeyAttributes ¶
CSAKeyAttributes is the model that represents the attributes of a CSA Key
type CSAKeyData ¶
type CSAKeyData struct {
Type string `json:"type"`
ID string `json:"id"`
Attributes CSAKeyAttributes `json:"attributes"`
}
CSAKeyData is the model that represents the created CSA key when read
type CSAKeys ¶
type CSAKeys struct {
Data []CSAKeyData `json:"data"`
}
CSAKeys is the model that represents the created CSA keys when read
type ChainlinkClient ¶
type ChainlinkClient struct {
APIClient *resty.Client
Config *Config
// contains filtered or unexported fields
}
func NewChainlinkClient ¶
func NewChainlinkClient(c *Config) (*ChainlinkClient, error)
NewChainlinkClient creates a new Chainlink model using a provided config
func (*ChainlinkClient) CreateBridge ¶
func (c *ChainlinkClient) CreateBridge(bta *BridgeTypeAttributes) (*http.Response, error)
func (*ChainlinkClient) CreateCSAKey ¶
func (c *ChainlinkClient) CreateCSAKey() (*CSAKey, *http.Response, error)
CreateCSAKey creates a CSA key on the Chainlink node, only 1 CSA key per noe
func (*ChainlinkClient) CreateCosmosChain ¶
func (c *ChainlinkClient) CreateCosmosChain(chain *CosmosChainAttributes) (*CosmosChainCreate, *http.Response, error)
CreateCosmosChain creates a cosmos chain
func (*ChainlinkClient) CreateCosmosNode ¶
func (c *ChainlinkClient) CreateCosmosNode(node *CosmosNodeAttributes) (*CosmosNodeCreate, *http.Response, error)
CreateCosmosNode creates a cosmos node
func (*ChainlinkClient) CreateEI ¶
func (c *ChainlinkClient) CreateEI(eia *EIAttributes) (*EIKeyCreate, *http.Response, error)
CreateEI creates an EI on the Chainlink node based on the provided attributes and returns the respective secrets
func (*ChainlinkClient) CreateJob ¶
func (c *ChainlinkClient) CreateJob(spec JobSpec) (*Job, *resty.Response, error)
CreateJob creates a Chainlink job based on the provided spec struct
func (*ChainlinkClient) CreateJobRaw ¶
CreateJobRaw creates a Chainlink job based on the provided spec string
func (*ChainlinkClient) CreateOCR2Key ¶
CreateOCR2Key creates an OCR2Key on the Chainlink node
func (*ChainlinkClient) CreateOCRKey ¶
func (c *ChainlinkClient) CreateOCRKey() (*OCRKey, *http.Response, error)
CreateOCRKey creates an OCRKey on the Chainlink node
func (*ChainlinkClient) CreateP2PKey ¶
func (c *ChainlinkClient) CreateP2PKey() (*P2PKey, *http.Response, error)
CreateP2PKey creates an P2PKey on the Chainlink node
func (*ChainlinkClient) CreateSolanaChain ¶
func (c *ChainlinkClient) CreateSolanaChain(chain *SolanaChainAttributes) (*SolanaChainCreate, *http.Response, error)
CreateSolanaChain creates a solana chain
func (*ChainlinkClient) CreateSolanaNode ¶
func (c *ChainlinkClient) CreateSolanaNode(node *SolanaNodeAttributes) (*SolanaNodeCreate, *http.Response, error)
CreateSolanaNode creates a solana node
func (*ChainlinkClient) CreateSpec ¶
CreateSpec creates a job spec on the Chainlink node
func (*ChainlinkClient) CreateStarkNetChain ¶
func (c *ChainlinkClient) CreateStarkNetChain(chain *StarkNetChainAttributes) (*StarkNetChainCreate, *http.Response, error)
CreateStarkNetChain creates a starknet chain
func (*ChainlinkClient) CreateStarkNetNode ¶
func (c *ChainlinkClient) CreateStarkNetNode(node *StarkNetNodeAttributes) (*StarkNetNodeCreate, *http.Response, error)
CreateStarkNetNode creates a starknet node
func (*ChainlinkClient) CreateTxKey ¶
CreateTxKey creates a tx key on the Chainlink node
func (*ChainlinkClient) DeleteBridge ¶
func (c *ChainlinkClient) DeleteBridge(name string) (*http.Response, error)
DeleteBridge deletes a bridge on the Chainlink node based on the provided name
func (*ChainlinkClient) DeleteEI ¶
func (c *ChainlinkClient) DeleteEI(name string) (*http.Response, error)
DeleteEI deletes an external initiator in the Chainlink node based on the provided name
func (*ChainlinkClient) DeleteJob ¶
func (c *ChainlinkClient) DeleteJob(id string) (*http.Response, error)
DeleteJob deletes a job with a provided ID from the Chainlink node
func (*ChainlinkClient) DeleteOCR2Key ¶
func (c *ChainlinkClient) DeleteOCR2Key(id string) (*http.Response, error)
DeleteOCR2Key deletes an OCR2Key based on the provided ID
func (*ChainlinkClient) DeleteOCRKey ¶
func (c *ChainlinkClient) DeleteOCRKey(id string) (*http.Response, error)
DeleteOCRKey deletes an OCRKey based on the provided ID
func (*ChainlinkClient) DeleteP2PKey ¶
func (c *ChainlinkClient) DeleteP2PKey(id int) (*http.Response, error)
DeleteP2PKey deletes a P2PKey on the Chainlink node based on the provided ID
func (*ChainlinkClient) DeleteSpec ¶
func (c *ChainlinkClient) DeleteSpec(id string) (*http.Response, error)
DeleteSpec deletes a job spec with the provided ID from the Chainlink node
func (*ChainlinkClient) DeleteTxKey ¶
DeleteTxKey deletes an tx key based on the provided ID
func (*ChainlinkClient) EthAddresses ¶
func (c *ChainlinkClient) EthAddresses() ([]string, error)
EthAddresses returns the ETH addresses for the Chainlink node
func (*ChainlinkClient) EthAddressesForChain ¶
func (c *ChainlinkClient) EthAddressesForChain(chainId string) ([]string, error)
EthAddresses returns the ETH addresses of the Chainlink node for a specific chain id
func (*ChainlinkClient) ExportEVMKeys ¶
func (c *ChainlinkClient) ExportEVMKeys() ([]*ExportedEVMKey, error)
ExportEVMKeys exports Chainlink private EVM keys
func (*ChainlinkClient) ExportEVMKeysForChain ¶
func (c *ChainlinkClient) ExportEVMKeysForChain(chainid string) ([]*ExportedEVMKey, error)
ExportEVMKeysForChain exports Chainlink private EVM keys for a particular chain
func (*ChainlinkClient) ExportVRFKey ¶
func (c *ChainlinkClient) ExportVRFKey(keyId string) (*VRFExportKey, *http.Response, error)
ExportVRFKey exports a vrf key by key id
func (*ChainlinkClient) GetConfig ¶
func (c *ChainlinkClient) GetConfig() Config
func (*ChainlinkClient) GetForwarders ¶
func (c *ChainlinkClient) GetForwarders() (*Forwarders, *http.Response, error)
GetForwarders get list of tracked forwarders
func (*ChainlinkClient) Health ¶
func (c *ChainlinkClient) Health() (*HealthResponse, *http.Response, error)
Health returns all statuses health info
func (*ChainlinkClient) ImportVRFKey ¶
func (c *ChainlinkClient) ImportVRFKey(vrfExportKey *VRFExportKey) (*VRFKey, *http.Response, error)
ImportVRFKey import vrf key
func (*ChainlinkClient) InternalIP ¶
func (c *ChainlinkClient) InternalIP() string
InternalIP retrieves the inter-cluster IP of the Chainlink node, for use with inter-node communications
func (*ChainlinkClient) MustCreateBridge ¶
func (c *ChainlinkClient) MustCreateBridge(bta *BridgeTypeAttributes) error
MustCreateBridge creates a bridge on the Chainlink node based on the provided attributes and returns error if the request is unsuccessful
func (*ChainlinkClient) MustCreateJob ¶
func (c *ChainlinkClient) MustCreateJob(spec JobSpec) (*Job, error)
MustCreateJob creates a Chainlink job based on the provided spec struct and returns error if the request is unsuccessful
func (*ChainlinkClient) MustCreateVRFKey ¶
func (c *ChainlinkClient) MustCreateVRFKey() (*VRFKey, error)
MustCreateVRFKey creates a VRF key on the Chainlink node and returns error if the request is unsuccessful
func (*ChainlinkClient) MustDeleteJob ¶
func (c *ChainlinkClient) MustDeleteJob(id string) error
MustDeleteJob deletes a job with a provided ID from the Chainlink node and returns error if the request is unsuccessful
func (*ChainlinkClient) MustReadCSAKeys ¶
func (c *ChainlinkClient) MustReadCSAKeys() (*CSAKeys, *resty.Response, error)
func (*ChainlinkClient) MustReadETHKeys ¶
func (c *ChainlinkClient) MustReadETHKeys() (*ETHKeys, error)
MustReadETHKeys reads all ETH keys from the Chainlink node and returns error if the request is unsuccessful
func (*ChainlinkClient) MustReadOCR2Keys ¶
func (c *ChainlinkClient) MustReadOCR2Keys() (*OCR2Keys, error)
MustReadOCR2Keys reads all OCR2Keys from the Chainlink node returns err if response not 200
func (*ChainlinkClient) MustReadOCRKeys ¶
func (c *ChainlinkClient) MustReadOCRKeys() (*OCRKeys, error)
MustReadOCRKeys reads all OCRKeys from the Chainlink node and returns error if the request is unsuccessful
func (*ChainlinkClient) MustReadP2PKeys ¶
func (c *ChainlinkClient) MustReadP2PKeys() (*P2PKeys, error)
MustReadP2PKeys reads all P2PKeys from the Chainlink node and returns error if the request is unsuccessful
func (*ChainlinkClient) MustReadRunsByJob ¶
func (c *ChainlinkClient) MustReadRunsByJob(jobID string) (*JobRunsResponse, error)
MustReadRunsByJob attempts to read all runs for a job and returns error if the request is unsuccessful
func (*ChainlinkClient) MustReadTransactionAttempts ¶
func (c *ChainlinkClient) MustReadTransactionAttempts() (*TransactionsData, error)
MustReadTransactionAttempts reads all transaction attempts on the Chainlink node and returns error if the request is unsuccessful
func (*ChainlinkClient) MustSendNativeToken ¶
func (c *ChainlinkClient) MustSendNativeToken(amount *big.Int, fromAddress, toAddress string) (TransactionData, error)
MustSendNativeToken sends native token (ETH usually) of a specified amount from one of its addresses to the target address and returns error if the request is unsuccessful WARNING: The txdata object that Chainlink sends back is almost always blank.
func (*ChainlinkClient) PrimaryEthAddress ¶
func (c *ChainlinkClient) PrimaryEthAddress() (string, error)
PrimaryEthAddress returns the primary ETH address for the Chainlink node
func (*ChainlinkClient) PrimaryEthAddressForChain ¶
func (c *ChainlinkClient) PrimaryEthAddressForChain(chainId string) (string, error)
PrimaryEthAddressForChain returns the primary ETH address for the Chainlink node for mentioned chain
func (*ChainlinkClient) Profile ¶
func (c *ChainlinkClient) Profile(profileTime time.Duration, profileFunction func(*ChainlinkClient)) (*ChainlinkProfileResults, error)
Profile starts a profile session on the Chainlink node for a pre-determined length, then runs the provided function to profile it.
func (*ChainlinkClient) ReadBridge ¶
func (c *ChainlinkClient) ReadBridge(name string) (*BridgeType, *http.Response, error)
ReadBridge reads a bridge from the Chainlink node based on the provided name
func (*ChainlinkClient) ReadBridges ¶
func (c *ChainlinkClient) ReadBridges() (*Bridges, *resty.Response, error)
ReadBridges reads bridges from the Chainlink node
func (*ChainlinkClient) ReadCSAKeys ¶
func (c *ChainlinkClient) ReadCSAKeys() (*CSAKeys, *resty.Response, error)
ReadCSAKeys reads CSA keys from the Chainlink node
func (*ChainlinkClient) ReadEIs ¶
func (c *ChainlinkClient) ReadEIs() (*EIKeys, *http.Response, error)
ReadEIs reads all of the configured EIs from the Chainlink node
func (*ChainlinkClient) ReadETHKeyAtIndex ¶
func (c *ChainlinkClient) ReadETHKeyAtIndex(keyIndex int) (*ETHKeyData, error)
ReadETHKeyAtIndex reads updated information about the Chainlink's ETH key at given index
func (*ChainlinkClient) ReadJobs ¶
func (c *ChainlinkClient) ReadJobs() (*ResponseSlice, *http.Response, error)
ReadJobs reads all jobs from the Chainlink node
func (*ChainlinkClient) ReadOCR2Keys ¶
func (c *ChainlinkClient) ReadOCR2Keys() (*OCR2Keys, *http.Response, error)
ReadOCR2Keys reads all OCR2Keys from the Chainlink node
func (*ChainlinkClient) ReadPrimaryETHKey ¶
func (c *ChainlinkClient) ReadPrimaryETHKey(chainId string) (*ETHKeyData, error)
ReadPrimaryETHKey reads updated information about the Chainlink's primary ETH key
func (*ChainlinkClient) ReadRunsByJob ¶
func (c *ChainlinkClient) ReadRunsByJob(jobID string) (*JobRunsResponse, *http.Response, error)
ReadRunsByJob reads all runs for a job
func (*ChainlinkClient) ReadSpec ¶
ReadSpec reads a job spec with the provided ID on the Chainlink node
func (*ChainlinkClient) ReadTransactions ¶
func (c *ChainlinkClient) ReadTransactions() (*TransactionsData, *http.Response, error)
ReadTransactions reads all transactions made by the Chainlink node
func (*ChainlinkClient) ReadTxKeys ¶
ReadTxKeys reads all tx keys from the Chainlink node
func (*ChainlinkClient) ReadVRFKeys ¶
func (c *ChainlinkClient) ReadVRFKeys() (*VRFKeys, *http.Response, error)
ReadVRFKeys reads all VRF keys from the Chainlink node
func (*ChainlinkClient) SetPageSize ¶
func (c *ChainlinkClient) SetPageSize(size int)
SetPageSize globally sets the page
func (*ChainlinkClient) TrackForwarder ¶
func (c *ChainlinkClient) TrackForwarder(chainID *big.Int, address common.Address) (*Forwarder, *http.Response, error)
TrackForwarder track forwarder address in db.
func (*ChainlinkClient) URL ¶
func (c *ChainlinkClient) URL() string
URL Chainlink instance http url
func (*ChainlinkClient) UpdateEthKeyMaxGasPriceGWei ¶
func (c *ChainlinkClient) UpdateEthKeyMaxGasPriceGWei(keyId string, gWei int) (*ETHKey, *http.Response, error)
UpdateEthKeyMaxGasPriceGWei updates the maxGasPriceGWei for an eth key
type ChainlinkProfileResult ¶
ChainlinkProfileResult contains the result of a single PPROF run
type ChainlinkProfileResults ¶
type ChainlinkProfileResults struct {
Reports []*ChainlinkProfileResult
ScheduledProfileSeconds int // How long the profile was scheduled to last
ActualRunSeconds int // How long the target function to profile actually took to execute
NodeIndex int
}
ChainlinkProfileResults holds the results of asking the Chainlink node to run a PPROF session
func NewBlankChainlinkProfileResults ¶
func NewBlankChainlinkProfileResults() *ChainlinkProfileResults
NewBlankChainlinkProfileResults returns all the standard types of profile results with blank data
type Config ¶
type Config struct {
URL string `toml:",omitempty"`
Email string `toml:",omitempty"`
Password string `toml:",omitempty"`
InternalIP string `toml:",omitempty"`
Headers map[string]string `toml:",omitempty"`
HTTPTimeout *time.Duration `toml:"-"`
}
Config represents the variables needed to connect to a Chainlink node
type CosmosChain ¶
type CosmosChain struct {
Attributes CosmosChainAttributes `json:"attributes"`
}
CosmosChain is the model that represents the terra chain when read
type CosmosChainAttributes ¶
type CosmosChainAttributes struct {
ChainID string `json:"chainID"`
Config CosmosChainConfig `json:"config"`
}
CosmosChainAttributes is the model that represents the terra chain
type CosmosChainConfig ¶
type CosmosChainConfig struct {
BlockRate null.String
BlocksUntilTxTimeout null.Int
ConfirmPollPeriod null.String
FallbackGasPriceULuna null.String
GasLimitMultiplier null.Float
MaxMsgsPerBatch null.Int
}
type CosmosChainCreate ¶
type CosmosChainCreate struct {
Data CosmosChain `json:"data"`
}
CosmosChainCreate is the model that represents the terra chain when created
type CosmosNode ¶
type CosmosNode struct {
Attributes CosmosNodeAttributes `json:"attributes"`
}
CosmosNode is the model that represents the terra node when read
type CosmosNodeAttributes ¶
type CosmosNodeAttributes struct {
Name string `json:"name"`
CosmosChainID string `json:"cosmosChainId"`
TendermintURL string `json:"tendermintURL" db:"tendermint_url"`
}
CosmosNodeAttributes is the model that represents the terra noded
type CosmosNodeCreate ¶
type CosmosNodeCreate struct {
Data CosmosNode `json:"data"`
}
CosmosNodeCreate is the model that represents the terra node when created
type CronJobSpec ¶
type CronJobSpec struct {
Schedule string `toml:"schedule"` // CRON job style schedule string
ObservationSource string `toml:"observationSource"` // List of commands for the Chainlink node
}
CronJobSpec represents a cron job spec
func (*CronJobSpec) String ¶
func (c *CronJobSpec) String() (string, error)
String representation of the job
type DecodeLogTaskRun ¶
type DecodeLogTaskRun struct {
Fee int `json:"fee"`
JobID []int `json:"jobID"`
KeyHash []int `json:"keyHash"`
RequestID []byte `json:"requestID"`
Sender string `json:"sender"`
}
DecodeLogTaskRun is "ethabidecodelog" task run info, also used for "RequestID" tracing in perf tests
type DirectRequestJobSpec ¶
type DirectRequestJobSpec struct {
Name string `toml:"name"`
ContractAddress string `toml:"contractAddress"`
EVMChainID string `toml:"evmChainID"`
ExternalJobID string `toml:"externalJobID"`
MinIncomingConfirmations string `toml:"minIncomingConfirmations"`
ObservationSource string `toml:"observationSource"` // List of commands for the Chainlink node
}
DirectRequestJobSpec represents a direct request spec
func (*DirectRequestJobSpec) String ¶
func (d *DirectRequestJobSpec) String() (string, error)
String representation of the pipeline
func (*DirectRequestJobSpec) Type ¶
func (d *DirectRequestJobSpec) Type() string
Type returns the type of the pipeline
type DirectRequestTxPipelineSpec ¶
type DirectRequestTxPipelineSpec struct {
BridgeTypeAttributes BridgeTypeAttributes
DataPath string
}
DirectRequestTxPipelineSpec oracle request with tx callback
func (*DirectRequestTxPipelineSpec) String ¶
func (d *DirectRequestTxPipelineSpec) String() (string, error)
String representation of the pipeline
func (*DirectRequestTxPipelineSpec) Type ¶
func (d *DirectRequestTxPipelineSpec) Type() string
Type returns the type of the pipeline
type EIAttributes ¶
type EIAttributes struct {
Name string `json:"name,omitempty"`
URL string `json:"url,omitempty"`
IncomingAccessKey string `json:"incomingAccessKey,omitempty"`
AccessKey string `json:"accessKey,omitempty"`
Secret string `json:"incomingSecret,omitempty"`
OutgoingToken string `json:"outgoingToken,omitempty"`
OutgoingSecret string `json:"outgoingSecret,omitempty"`
}
EIAttributes is the model that represents the EI keys when created and read
type EIKey ¶
type EIKey struct {
Attributes EIAttributes `json:"attributes"`
}
EIKey is the model that represents the EI configs when read
type EIKeyCreate ¶
type EIKeyCreate struct {
Data EIKey `json:"data"`
}
EIKeyCreate is the model that represents the EI config when created
type EIKeys ¶
type EIKeys struct {
Data []EIKey `json:"data"`
}
EIKeys is the model that represents the EI configs when read
type EIServiceConfig ¶
type EIServiceConfig struct {
URL string
}
EIServiceConfig represents External Initiator service config
type ETHKey ¶
type ETHKey struct {
Data ETHKeyData `json:"data"`
}
ETHKey is the model that represents the created ETH keys when read
type ETHKeyAttributes ¶
type ETHKeyAttributes struct {
Address string `json:"address"`
ETHBalance string `json:"ethBalance"`
ChainID string `json:"evmChainID"`
}
ETHKeyAttributes is the model that represents the created ETH keys when read
type ETHKeyData ¶
type ETHKeyData struct {
Attributes ETHKeyAttributes `json:"attributes"`
}
ETHKeyData is the model that represents the created ETH keys when read
type ETHKeys ¶
type ETHKeys struct {
Data []ETHKeyData `json:"data"`
}
ETHKeys is the model that represents the created ETH keys when read
type ExportedEVMKey ¶
type ExportedEVMKey struct {
Address string `json:"address"`
Crypto struct {
Cipher string `json:"cipher"`
CipherText string `json:"ciphertext"`
CipherParams struct {
Iv string `json:"iv"`
} `json:"cipherparams"`
Kdf string `json:"kdf"`
KDFParams struct {
DkLen int `json:"dklen"`
N int `json:"n"`
P int `json:"p"`
R int `json:"r"`
Salt string `json:"salt"`
} `json:"kdfparams"`
Mac string `json:"mac"`
} `json:"crypto"`
ID string `json:"id"`
Version int `json:"version"`
}
ExportedEVMKey holds all details needed to recreate a private key of the Chainlink node
type FluxMonitorJobSpec ¶
type FluxMonitorJobSpec struct {
Name string `toml:"name"`
ContractAddress string `toml:"contractAddress"` // Address of the Flux Monitor script
EVMChainID string `toml:"evmChainID"` // Not optional
Precision int `toml:"precision"` // Optional
Threshold float32 `toml:"threshold"` // Optional
AbsoluteThreshold float32 `toml:"absoluteThreshold"` // Optional
IdleTimerPeriod time.Duration `toml:"idleTimerPeriod"` // Optional
IdleTimerDisabled bool `toml:"idleTimerDisabled"` // Optional
PollTimerPeriod time.Duration `toml:"pollTimerPeriod"` // Optional
PollTimerDisabled bool `toml:"pollTimerDisabled"` // Optional
MaxTaskDuration time.Duration `toml:"maxTaskDuration"` // Optional
ObservationSource string `toml:"observationSource"` // List of commands for the Chainlink node
}
FluxMonitorJobSpec represents a flux monitor spec
func (*FluxMonitorJobSpec) String ¶
func (f *FluxMonitorJobSpec) String() (string, error)
String representation of the job
func (*FluxMonitorJobSpec) Type ¶
func (f *FluxMonitorJobSpec) Type() string
Type returns the type of the job
type Forwarder ¶
type Forwarder struct {
Data ForwarderData `json:"data"`
}
Forwarder the model that represents the created Forwarder when created
type ForwarderAttributes ¶
type ForwarderAttributes struct {
Address string `json:"address"`
ChainID string `json:"evmChainId"`
CreatedAt time.Time `json:"createdAt"`
UpdatedAt time.Time `json:"updatedAt"`
}
ForwarderAttributes is the model that represents attributes of a Forwarder
type ForwarderData ¶
type ForwarderData struct {
Type string `json:"type"`
ID string `json:"id"`
Attributes ForwarderAttributes `json:"attributes"`
}
ForwarderData is the model that represents the created Forwarder when read
type Forwarders ¶
type Forwarders struct {
Data []ForwarderData `json:"data"`
}
Forwarders is the model that represents the created Forwarders when read
type HealthResponse ¶
type HealthResponse struct {
Data []struct {
Type string `json:"type"`
ID string `json:"id"`
Attributes struct {
Name string `json:"name"`
Status string `json:"status"`
Output string `json:"output"`
} `json:"attributes"`
} `json:"data"`
}
HealthResponse is the generic model for services health statuses
type JobData ¶
type JobData struct {
ID string `json:"id"`
}
JobData contains the ID for a given job
type JobForm ¶
type JobForm struct {
TOML string `json:"toml"`
}
JobForm is the form used when creating a v2 job spec, containing the TOML of the v2 job
type JobRunsResponse ¶
type JobRunsResponse struct {
Data []RunsResponseData `json:"data"`
Meta RunsMetaResponse `json:"meta"`
}
JobRunsResponse job runs
type JobSpec ¶
type JobSpec interface {
Type() string
// String Returns TOML representation of the job
String() (string, error)
}
JobSpec represents the different possible job types that Chainlink nodes can handle
type KeeperJobSpec ¶
type KeeperJobSpec struct {
Name string `toml:"name"`
ContractAddress string `toml:"contractAddress"`
FromAddress string `toml:"fromAddress"` // Hex representation of the from address
EVMChainID string `toml:"evmChainID"` // Not optional
MinIncomingConfirmations int `toml:"minIncomingConfirmations"`
}
KeeperJobSpec represents a V2 keeper spec
func (*KeeperJobSpec) String ¶
func (k *KeeperJobSpec) String() (string, error)
String representation of the job
type NodeKeysBundle ¶
type OCR2Key ¶
type OCR2Key struct {
Data OCR2KeyData `json:"data"`
}
OCR2Key is the model that represents the created OCR2 keys when read
type OCR2KeyAttributes ¶
type OCR2KeyAttributes struct {
ChainType string `json:"chainType"`
ConfigPublicKey string `json:"configPublicKey"`
OffChainPublicKey string `json:"offchainPublicKey"`
OnChainPublicKey string `json:"onchainPublicKey"`
}
OCR2KeyAttributes is the model that represents the created OCR2 keys when read
type OCR2KeyData ¶
type OCR2KeyData struct {
Type string `json:"type"`
Attributes OCR2KeyAttributes `json:"attributes"`
ID string `json:"id"`
}
OCR2KeyData is the model that represents the created OCR2 keys when read
type OCR2Keys ¶
type OCR2Keys struct {
Data []OCR2KeyData `json:"data"`
}
OCR2Keys is the model that represents the created OCR2 keys when read
type OCRBootstrapJobSpec ¶
type OCRBootstrapJobSpec struct {
Name string `toml:"name"`
BlockChainTimeout time.Duration `toml:"blockchainTimeout"` // Optional
ContractConfirmations int `toml:"contractConfigConfirmations"` // Optional
TrackerPollInterval time.Duration `toml:"contractConfigTrackerPollInterval"` // Optional
TrackerSubscribeInterval time.Duration `toml:"contractConfigTrackerSubscribeInterval"` // Optional
ContractAddress string `toml:"contractAddress"` // Address of the OCR contract
EVMChainID string `toml:"evmChainID"`
IsBootstrapPeer bool `toml:"isBootstrapPeer"` // Typically true
P2PPeerID string `toml:"p2pPeerID"` // This node's P2P ID
}
OCRBootstrapJobSpec represents the spec for bootstrapping an OCR job, given to one node that then must be linked back to by others by OCRTaskJobSpecs
func (*OCRBootstrapJobSpec) String ¶
func (o *OCRBootstrapJobSpec) String() (string, error)
String representation of the job
func (*OCRBootstrapJobSpec) Type ¶
func (o *OCRBootstrapJobSpec) Type() string
Type returns the type of the job
type OCRKey ¶
type OCRKey struct {
Data OCRKeyData `json:"data"`
}
OCRKey is the model that represents the created OCR keys when read
type OCRKeyAttributes ¶
type OCRKeyAttributes struct {
ConfigPublicKey string `json:"configPublicKey"`
OffChainPublicKey string `json:"offChainPublicKey"`
OnChainSigningAddress string `json:"onChainSigningAddress"`
}
OCRKeyAttributes is the model that represents the created OCR keys when read
type OCRKeyData ¶
type OCRKeyData struct {
Attributes OCRKeyAttributes `json:"attributes"`
ID string `json:"id"`
}
OCRKeyData is the model that represents the created OCR keys when read
type OCRKeys ¶
type OCRKeys struct {
Data []OCRKeyData `json:"data"`
}
OCRKeys is the model that represents the created OCR keys when read
type OCRTaskJobSpec ¶
type OCRTaskJobSpec struct {
Name string `toml:"name"`
BlockChainTimeout time.Duration `toml:"blockchainTimeout"` // Optional
ContractConfirmations int `toml:"contractConfigConfirmations"` // Optional
TrackerPollInterval time.Duration `toml:"contractConfigTrackerPollInterval"` // Optional
TrackerSubscribeInterval time.Duration `toml:"contractConfigTrackerSubscribeInterval"` // Optional
ForwardingAllowed bool `toml:"forwardingAllowed"` // Optional, by default false
ContractAddress string `toml:"contractAddress"` // Address of the OCR contract
EVMChainID string `toml:"evmChainID"`
P2PBootstrapPeers []*ChainlinkClient `toml:"p2pBootstrapPeers"` // P2P ID of the bootstrap node
IsBootstrapPeer bool `toml:"isBootstrapPeer"` // Typically false
P2PPeerID string `toml:"p2pPeerID"` // This node's P2P ID
KeyBundleID string `toml:"keyBundleID"` // ID of this node's OCR key bundle
MonitoringEndpoint string `toml:"monitoringEndpoint"` // Typically "chain.link:4321"
TransmitterAddress string `toml:"transmitterAddress"` // ETH address this node will use to transmit its answer
ObservationSource string `toml:"observationSource"` // List of commands for the Chainlink node
}
OCRTaskJobSpec represents an OCR job that is given to other nodes, meant to communicate with the bootstrap node, and provide their answers
func (*OCRTaskJobSpec) String ¶
func (o *OCRTaskJobSpec) String() (string, error)
String representation of the job
func (*OCRTaskJobSpec) Type ¶
func (o *OCRTaskJobSpec) Type() string
Type returns the type of the job
type P2PData ¶
P2PData holds the remote ip and the peer id and port
func (*P2PData) P2PV2Bootstrapper ¶
type P2PKey ¶
type P2PKey struct {
Data P2PKeyData `json:"data"`
}
P2PKey is the model that represents the created P2P keys when read
type P2PKeyAttributes ¶
type P2PKeyAttributes struct {
ID int `json:"id"`
PeerID string `json:"peerId"`
PublicKey string `json:"publicKey"`
}
P2PKeyAttributes is the model that represents the created P2P keys when read
type P2PKeyData ¶
type P2PKeyData struct {
Attributes P2PKeyAttributes `json:"attributes"`
}
P2PKeyData is the model that represents the created P2P keys when read
type P2PKeys ¶
type P2PKeys struct {
Data []P2PKeyData `json:"data"`
}
P2PKeys is the model that represents the created P2P keys when read
type PipelineSpec ¶
type PipelineSpec struct {
BridgeTypeAttributes BridgeTypeAttributes
DataPath string
}
PipelineSpec common API call pipeline
func (*PipelineSpec) String ¶
func (d *PipelineSpec) String() (string, error)
String representation of the pipeline
type Response ¶
type Response struct {
Data map[string]interface{}
}
Response is the generic model that can be used for all Chainlink API responses
type ResponseSlice ¶
type ResponseSlice struct {
Data []map[string]interface{}
}
ResponseSlice is the generic model that can be used for all Chainlink API responses that are an slice
type RunsAttributesResponse ¶
type RunsAttributesResponse struct {
Meta interface{} `json:"meta"`
Errors []interface{} `json:"errors"`
Inputs RunInputs `json:"inputs"`
TaskRuns []TaskRun `json:"taskRuns"`
CreatedAt time.Time `json:"createdAt"`
FinishedAt time.Time `json:"finishedAt"`
}
RunsAttributesResponse runs attributes
type RunsMetaResponse ¶
type RunsMetaResponse struct {
Count int `json:"count"`
}
RunsMetaResponse runs meta
type RunsResponseData ¶
type RunsResponseData struct {
Type string `json:"type"`
ID string `json:"id"`
Attributes RunsAttributesResponse `json:"attributes"`
}
RunsResponseData runs response data
type SendEtherRequest ¶
type SingleTransactionDataWrapper ¶
type SingleTransactionDataWrapper struct {
Data TransactionData `json:"data"`
}
type SolanaChain ¶
type SolanaChain struct {
Attributes SolanaChainAttributes `json:"attributes"`
}
SolanaChain is the model that represents the solana chain when read
type SolanaChainAttributes ¶
type SolanaChainAttributes struct {
ChainID string `json:"chainID"`
Config SolanaChainConfig `json:"config"`
}
SolanaChainAttributes is the model that represents the solana chain
type SolanaChainConfig ¶
type SolanaChainConfig struct {
BlockRate null.String
ConfirmPollPeriod null.String
OCR2CachePollPeriod null.String
OCR2CacheTTL null.String
TxTimeout null.String
SkipPreflight null.Bool
Commitment null.String
}
type SolanaChainCreate ¶
type SolanaChainCreate struct {
Data SolanaChain `json:"data"`
}
SolanaChainCreate is the model that represents the solana chain when created
type SolanaNode ¶
type SolanaNode struct {
Attributes SolanaNodeAttributes `json:"attributes"`
}
SolanaNode is the model that represents the solana node when read
type SolanaNodeAttributes ¶
type SolanaNodeAttributes struct {
Name string `json:"name"`
SolanaChainID string `json:"solanaChainId" db:"solana_chain_id"`
SolanaURL string `json:"solanaURL" db:"solana_url"`
}
SolanaNodeAttributes is the model that represents the solana noded
type SolanaNodeCreate ¶
type SolanaNodeCreate struct {
Data SolanaNode `json:"data"`
}
SolanaNodeCreate is the model that represents the solana node when created
type Spec ¶
type Spec struct {
Data SpecData `json:"data"`
}
Spec represents a job specification that contains information about the job spec
type SpecData ¶
type SpecData struct {
ID string `json:"id"`
}
SpecData contains the ID of the job spec
type SpecForm ¶
type SpecForm struct {
TOML string `json:"toml"`
}
SpecForm is the form used when creating a v2 job spec, containing the TOML of the v2 job
type StarkNetChain ¶
type StarkNetChain struct {
Attributes StarkNetChainAttributes `json:"attributes"`
}
StarkNetChain is the model that represents the starknet chain when read
type StarkNetChainAttributes ¶
type StarkNetChainAttributes struct {
Type string `json:"type"`
ChainID string `json:"chainID"`
Config StarkNetChainConfig `json:"config"`
}
StarkNetChainAttributes is the model that represents the starknet chain
type StarkNetChainConfig ¶
type StarkNetChainConfig struct {
OCR2CachePollPeriod null.String
OCR2CacheTTL null.String
RequestTimeout null.String
TxTimeout null.Bool
TxSendFrequency null.String
TxMaxBatchSize null.String
}
type StarkNetChainCreate ¶
type StarkNetChainCreate struct {
Data StarkNetChain `json:"data"`
}
StarkNetChainCreate is the model that represents the starknet chain when created
type StarkNetNode ¶
type StarkNetNode struct {
Attributes StarkNetNodeAttributes `json:"attributes"`
}
StarkNetNode is the model that represents the starknet node when read
type StarkNetNodeAttributes ¶
type StarkNetNodeAttributes struct {
Name string `json:"name"`
ChainID string `json:"chainId"`
Url string `json:"url"`
}
StarkNetNodeAttributes is the model that represents the starknet node
type StarkNetNodeCreate ¶
type StarkNetNodeCreate struct {
Data StarkNetNode `json:"data"`
}
StarkNetNodeCreate is the model that represents the starknet node when created
type TaskRun ¶
type TaskRun struct {
Type string `json:"type"`
CreatedAt time.Time `json:"createdAt"`
FinishedAt time.Time `json:"finishedAt"`
Output string `json:"output"`
Error interface{} `json:"error"`
DotID string `json:"dotId"`
}
TaskRun is pipeline task run info
type TransactionAttributes ¶
type TransactionAttributes struct {
State string `json:"state"`
Data string `json:"data"`
From string `json:"from"`
To string `json:"to"`
Value string `json:"value"`
ChainID string `json:"evmChainID"`
GasLimit string `json:"gasLimit"`
GasPrice string `json:"gasPrice"`
Hash string `json:"hash"`
RawHex string `json:"rawHex"`
Nonce string `json:"nonce"`
SentAt string `json:"sentAt"`
}
type TransactionData ¶
type TransactionData struct {
Type string `json:"type"`
ID string `json:"id"`
Attributes TransactionAttributes `json:"attributes"`
}
type TransactionsData ¶
type TransactionsData struct {
Data []TransactionData `json:"data"`
Meta TransactionsMetaData `json:"meta"`
}
type TransactionsMetaData ¶
type TransactionsMetaData struct {
Count int `json:"count"`
}
type TxKey ¶
type TxKey struct {
Data TxKeyData `json:"data"`
}
TxKey is the model that represents the created keys when read
type TxKeyAttributes ¶
type TxKeyAttributes struct {
PublicKey string `json:"publicKey"`
Address string `json:"address"`
StarkKey string `json:"starkPubKey,omitempty"`
}
TxKeyAttributes is the model that represents the created keys when read
type TxKeyData ¶
type TxKeyData struct {
Type string `json:"type"`
ID string `json:"id"`
Attributes TxKeyAttributes `json:"attributes"`
}
TxKeyData is the model that represents the created keys when read
type TxKeys ¶
type TxKeys struct {
Data []TxKeyData `json:"data"`
}
TxKeys is the model that represents the created keys when read
type VRFExportKey ¶
type VRFExportKey struct {
PublicKey string `json:"PublicKey"`
VrfKey struct {
Address string `json:"address"`
Crypto struct {
Cipher string `json:"cipher"`
Ciphertext string `json:"ciphertext"`
Cipherparams struct {
Iv string `json:"iv"`
} `json:"cipherparams"`
Kdf string `json:"kdf"`
Kdfparams struct {
Dklen int `json:"dklen"`
N int `json:"n"`
P int `json:"p"`
R int `json:"r"`
Salt string `json:"salt"`
} `json:"kdfparams"`
Mac string `json:"mac"`
} `json:"crypto"`
Version int `json:"version"`
} `json:"vrf_key"`
}
VRFExportKey is the model that represents the exported VRF key
type VRFJobSpec ¶
type VRFJobSpec struct {
Name string `toml:"name"`
CoordinatorAddress string `toml:"coordinatorAddress"` // Address of the VRF CoordinatorV2 contract
PublicKey string `toml:"publicKey"` // Public key of the proving key
EVMChainID string `toml:"evmChainID"`
ExternalJobID string `toml:"externalJobID"`
ObservationSource string `toml:"observationSource"` // List of commands for the Chainlink node
MinIncomingConfirmations int `toml:"minIncomingConfirmations"`
}
VRFJobSpec represents a VRF job
func (*VRFJobSpec) String ¶
func (v *VRFJobSpec) String() (string, error)
String representation of the job
type VRFKey ¶
type VRFKey struct {
Data VRFKeyData `json:"data"`
}
VRFKey is the model that represents the created VRF key when read
type VRFKeyAttributes ¶
type VRFKeyAttributes struct {
Compressed string `json:"compressed"`
Uncompressed string `json:"uncompressed"`
Hash string `json:"hash"`
CreatedAt time.Time `json:"createdAt"`
UpdatedAt time.Time `json:"updatedAt"`
DeletedAt interface{} `json:"deletedAt"`
}
VRFKeyAttributes is the model that represents the created VRF key attributes when read
type VRFKeyData ¶
type VRFKeyData struct {
Type string `json:"type"`
ID string `json:"id"`
Attributes VRFKeyAttributes `json:"attributes"`
}
VRFKeyData is the model that represents the created VRF key's data when read
type VRFKeys ¶
type VRFKeys struct {
Data []VRFKey `json:"data"`
}
VRFKeys is the model that represents the created VRF keys when read
type VRFTxPipelineSpec ¶
type VRFTxPipelineSpec struct {
Address string
}
VRFTxPipelineSpec VRF request with tx callback
func (*VRFTxPipelineSpec) String ¶
func (d *VRFTxPipelineSpec) String() (string, error)
String representation of the pipeline
func (*VRFTxPipelineSpec) Type ¶
func (d *VRFTxPipelineSpec) Type() string
Type returns the type of the pipeline
type VRFV2JobSpec ¶
type VRFV2JobSpec struct {
Name string `toml:"name"`
CoordinatorAddress string `toml:"coordinatorAddress"` // Address of the VRF CoordinatorV2 contract
BatchCoordinatorAddress string `toml:"batchCoordinatorAddress"`
PublicKey string `toml:"publicKey"` // Public key of the proving key
ExternalJobID string `toml:"externalJobID"`
ObservationSource string `toml:"observationSource"` // List of commands for the Chainlink node
MinIncomingConfirmations int `toml:"minIncomingConfirmations"`
FromAddresses []string `toml:"fromAddresses"`
EVMChainID string `toml:"evmChainID"`
UseVRFOwner bool `toml:"useVRFOwner"`
VRFOwner string `toml:"vrfOwnerAddress"`
ForwardingAllowed bool `toml:"forwardingAllowed"`
CustomRevertsPipelineEnabled bool `toml:"customRevertsPipelineEnabled"`
PollPeriod time.Duration `toml:"pollPeriod"`
RequestTimeout time.Duration `toml:"requestTimeout"`
BatchFulfillmentEnabled bool `toml:"batchFulfillmentEnabled"`
BatchFulfillmentGasMultiplier float64 `toml:"batchFulfillmentGasMultiplier"`
BackOffInitialDelay time.Duration `toml:"backOffInitialDelay"`
BackOffMaxDelay time.Duration `toml:"backOffMaxDelay"`
}
VRFV2JobSpec represents a VRFV2 job
func (*VRFV2JobSpec) String ¶
func (v *VRFV2JobSpec) String() (string, error)
String representation of the job
type VRFV2PlusJobSpec ¶
type VRFV2PlusJobSpec struct {
Name string `toml:"name"`
CoordinatorAddress string `toml:"coordinatorAddress"` // Address of the VRF CoordinatorV2 contract
BatchCoordinatorAddress string `toml:"batchCoordinatorAddress"`
PublicKey string `toml:"publicKey"` // Public key of the proving key
ExternalJobID string `toml:"externalJobID"`
ObservationSource string `toml:"observationSource"` // List of commands for the Chainlink node
MinIncomingConfirmations int `toml:"minIncomingConfirmations"`
FromAddresses []string `toml:"fromAddresses"`
EVMChainID string `toml:"evmChainID"`
ForwardingAllowed bool `toml:"forwardingAllowed"`
BatchFulfillmentEnabled bool `toml:"batchFulfillmentEnabled"`
BatchFulfillmentGasMultiplier float64 `toml:"batchFulfillmentGasMultiplier"`
BackOffInitialDelay time.Duration `toml:"backOffInitialDelay"`
BackOffMaxDelay time.Duration `toml:"backOffMaxDelay"`
PollPeriod time.Duration `toml:"pollPeriod"`
RequestTimeout time.Duration `toml:"requestTimeout"`
}
VRFV2PlusJobSpec represents a VRFV2 job
func (*VRFV2PlusJobSpec) String ¶
func (v *VRFV2PlusJobSpec) String() (string, error)
String representation of the job
func (*VRFV2PlusJobSpec) Type ¶
func (v *VRFV2PlusJobSpec) Type() string
Type returns the type of the job
type VRFV2PlusTxPipelineSpec ¶
type VRFV2PlusTxPipelineSpec struct {
Address string
EstimateGasMultiplier float64
FromAddress string
SimulationBlock *string // can be nil, "latest" or "pending".
}
VRFV2TxPipelineSpec VRFv2 request with tx callback
func (*VRFV2PlusTxPipelineSpec) String ¶
func (d *VRFV2PlusTxPipelineSpec) String() (string, error)
String representation of the pipeline
func (*VRFV2PlusTxPipelineSpec) Type ¶
func (d *VRFV2PlusTxPipelineSpec) Type() string
Type returns the type of the pipeline
type VRFV2TxPipelineSpec ¶
type VRFV2TxPipelineSpec struct {
Address string
EstimateGasMultiplier float64
FromAddress string
SimulationBlock *string // can be nil, "latest" or "pending".
}
VRFV2TxPipelineSpec VRFv2 request with tx callback
func (*VRFV2TxPipelineSpec) String ¶
func (d *VRFV2TxPipelineSpec) String() (string, error)
String representation of the pipeline
func (*VRFV2TxPipelineSpec) Type ¶
func (d *VRFV2TxPipelineSpec) Type() string
Type returns the type of the pipeline
type WebhookJobSpec ¶
type WebhookJobSpec struct {
Name string `toml:"name"`
Initiator string `toml:"initiator"` // External initiator name
InitiatorSpec string `toml:"initiatorSpec"` // External initiator spec object in stringified form
ObservationSource string `toml:"observationSource"` // List of commands for the Chainlink node
}
WebhookJobSpec reprsents a webhook job
func (*WebhookJobSpec) String ¶
func (w *WebhookJobSpec) String() (string, error)
String representation of the job
func (*WebhookJobSpec) Type ¶
func (w *WebhookJobSpec) Type() string
Type returns the type of the job