adapters

package
v0.8.11 Latest Latest
Warning

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

 Go to latest Published: Jul 27, 2020 License: MIT Imports: 34 Imported by: 0

Documentation

Overview

Package adapters contain the core adapters used by the Chainlink node.

Bridge

The Bridge adapter is used to send and receive data to and from external adapters. The adapter will POST to the target adapter URL with an "id" field for the TaskRunID and a "data" field. For example: 

{"id": "b8004e2989e24e1d8e4449afad2eb480", "data": {}}

Compare

The Compare adapter is used to compare the previous task's result against a specified value. Just like an `if` statement, the compare adapter will save `true` or `false` in the task run's result. 

{ "type": "Compare", "params": {"operator": "eq", "value": "Hello" }}

HTTPGet

The HTTPGet adapter is used to grab the JSON data from the given URL. 

{ "type": "HTTPGet", "params": {"get": "https://some-api-example.net/api" }}

NOTE: For security, since the URL is untrusted, HTTPGet imposes some restrictions on which IPs may be fetched. Local network and multicast IPs are disallowed by default and attempting to connect will result in an error.

HTTPPost

Sends a POST request to the specified URL and will return the response. 

{ "type": "HTTPPost", "params": {"post": "https://weiwatchers.com/api" }}

NOTE: For security, since the URL is untrusted, HTTPPost imposes some restrictions on which IPs may be fetched. Local network and multicast IPs are disallowed by default and attempting to connect will result in an error.

HTTPGetWithUnrestrictedNetworkAccess

Identical to HTTPGet except there are no IP restrictions. Use with caution.

HTTPPostWithUnrestrictedNetworkAccess

Identical to HTTPPost except there are no IP restrictions. Use with caution.

JSONParse

The JSONParse adapter will obtain the value(s) for the given field(s). 

{ "type": "JSONParse", "params": {"path": ["someField"] }}

EthBool

The EthBool adapter will take the given values and format them for the Ethereum blockchain in boolean value. 

{ "type": "EthBool" }

EthBytes32

The EthBytes32 adapter will take the given values and format them for the Ethereum blockchain. 

{ "type": "EthBytes32" }

EthInt256

The EthInt256 adapter will take a given signed 256 bit integer and format it to hex for the Ethereum blockchain. 

{ "type": "EthInt256" }

EthUint256

The EthUint256 adapter will take a given 256 bit integer and format it in hex for the Ethereum blockchain. 

{ "type": "EthUint256" }

EthTx

The EthTx adapter will write the data to the given address and functionSelector. 

{
  "type": "EthTx", "params": {
    "address": "0x0000000000000000000000000000000000000000",
    "functionSelector": "0xffffffff"
  }
}

Multiplier

The Multiplier adapter multiplies the given input value times another specified value. 

{ "type": "Multiply", "params": {"times": 100 }}

Quotient

The Quotient adapter gives the result of x / y where x is a specified value (dividend) and y is the input value (result). This can be useful for inverting outputs, e.g. if you have a USD/ETH conversion rate and you want to flip it to ETH/USD you can use this adapter with a dividend of 1 to get 1 / result.

value. 

{ "type": "Quotient", "params": {"dividend": 1 }}

Random

Random adapter generates proofs of randomness verifiable against a public key 

WARNING: The Random apdater's output is NOT the randomness you are looking
WARNING: for! The node must send the output onchain for verification by the
WARNING: method VRFCoordinator.sol#fulfillRandomnessRequest, which will
WARNING: pass the actual random output back to the consuming contract.
WARNING: Don't use the output of this adapter in any other way, unless you
WARNING: thoroughly understand the cryptography in use here, and the exact
WARNING: security guarantees it provides. See notes in VRFCoordinator.sol
WARNING: for more info.

WARNING: This system guarantees that the oracle cannot independently
WARNING: concoct a random output to suit itself, but it does not protect
WARNING: against collusion between the oracle and the provider of the seed
WARNING: the oracle uses to generate the randomness. It also does not
WARNING: protect against the oracle simply refusing to respond to a
WARNING: randomness request, if it doesn't like the output it would be
WARNING: required to provide. Solutions to these limitations are planned.

Here is an example of a Random task specification. For an example of a full jobspec using this, see ../internal/testdata/randomness_job.json. 

{
  "type": "Random",
  "params": {
  	"publicKey":
      "0x79be667ef9dcbbac55a06295ce870b07029bfcdb2dce28d959f2815b16f8179800"
  }
}

The publicKey must be the concatenation of its hex representation of its the secp256k1 point's x-ordinate as a uint256, followed by 00 if the y-ordinate is even, or 01 if it's odd. (Note that this is NOT an RFC 5480 section 2.2 public-key representation. DO NOT prefix with 0x02, 0x03 or 0x04.)

The chainlink node must know the corresponding secret key. Such a key pair can be created with the `chainlink local vrf create` command, and exported to a keystore with `vrf export <keystore-path>`.

E.g. `chainlink local vrf create -p <password-file>` will log the public key under the field "public id".

To see the public keys which have already been imported, use the command `chainlink local vrf list`. See `chainlink local vrf help` for more key-manipulation commands.

The adapter output should be passed via EthTx to VRFCoordinator.sol's method fulfillRandomnessRequest.

A "random" task must be initiated by a "randomnesslog" initiator which explicitly specifies which ethereum address the logs will be emitted from, such as

{"initiators": [{"type": "randomnesslog","address": "0xvrfCoordinatorAddr"}]}

This prevents the node from responding to potentially hostile log requests from other contracts, which could be crafted to prematurely reveal the random output if someone learns a prospective input seed prior to its use in the VRF.

EthTxABIEncode

The EthTxABIEncode adapter serializes the contents of a json object as transaction data calling an arbitrary function of a smart contract. See https://solidity.readthedocs.io/en/v0.5.11/abi-spec.html#formal-specification-of-the-encoding for the serialization format. We currently support all types that solidity contracts as of solc v0.5.11 can decode, i.e. address, bool, bytes1, ..., bytes32, int8, ..., int256, uint8, ..., uint256, arrays (e.g. address[2]), bytes (variable length), string (variable length), and slices (e.g. uint256[] or address[2][]).

The ABI of the function to be called is specified in the functionABI field, using the ABI JSON format used by solc and vyper. For example, 

{
  "type": "EthTxABIEncode",
  "functionABI": {
    "name": "example"
    "inputs": [
      {"name": "x", "type": "uint256"},
      {"name": "y", "type": "bool[2][]"}
      {"name": "z", "type": "string"}
    ]
  },
  "address": "0xdeadbeefdeadbeefdeadbeefdeadbeefdeadbeef"
}

will encode a transaction to a function example(uint256 x, bool[2][] y, string z) for a contract at address 0xdeadbeefdeadbeefdeadbeefdeadbeefdeadbeef.

Upon use, the json input to an EthTxABIEncode task is expected to have a corresponding map of argument names to compatible data in its `result` field such as 

{
  "result": {
    "x": "680564733841876926926749227234810109236",
    "y": [[true, false], [false, false]],
    "z": "hello world! привет мир!"
  }
}

which will result in a call to `example(uint256,bool[2][],string)` at address 0xdeadbeefdeadbeefdeadbeefdeadbeefdeadbeef, with arguments 

example(
  680564733841876926926749227234810109236,
  [[true, false], [false, false]],
  "hello world! привет мир!"
)

The result from EthTxABIEncode is the hash of the resulting transaction, if it was successfully transmitted, or an error if not.

ABI types must be represented in JSON as follows: 

address:
  - a hexstring containing at most 20 bytes, e.g.
    "0xdeadbeefdeadbeefdeadbeefdeadbeefdeadbeef"
bool:
  - true or false
bytes<n> (where 1 <= n <= 32):
  - a hexstring containing exactly n bytes, e.g.
    "0xdeadbeef" for a bytes8
  - an array of numbers containing exactly n bytes, e.g.
    [1,2,3,4,5,6,7,8,9,10] for a bytes10
int<n> (where n ∈ {8, 16, 24, ..., 256}):
  - a decimal number, e.g. from "-128" to "127" for an int8
  - a positive hex number, e.g. "0xdeadbeef" for an int64
  - for n <= 48, a number, e.g. 4294967296 for an int40
    (for larger n, json numbers aren't suitable due to them commonly
    being interpreted as doubles which cannot represent all integers above
    2**53)
uint<n> (where n ∈ {8, 16, 24, ..., 256}):
  - a decimal number, e.g. from "0" to "255" for an uint8
  - a positive hex number, e.g. "0xdeadbeef" for an uint64
  - for n <= 48, a number, e.g. 4294967296 for an uint40
    (for larger n, json numbers aren't suitable due to them commonly
    being interpreted as doubles which cannot represent all integers above
    2**53)
arrays:
  - a json array of the appropriate length, e.g. ["0x1", "-1"] for int8[2]
==============
bytes:
  - a hexstring of variable length, e.g. "0xdeadbeefc0ffee"
  - an array of numbers of variable length, e.g.
    [1,2,1,2,1,2]
string:
  - a utf8 string, e.g. "hello world! привет мир!"
slice:
  - an array of variable length, e.g. ["0x1", "-2", 3] for
    an int128[]

Index

Constants

View Source 
const (
	// DataFormatBytes instructs the EthTx Adapter to treat the input value as a
	// bytes string, rather than a hexadecimal encoded bytes32
	DataFormatBytes = "bytes"
)

Variables

View Source 
var (
	// TaskTypeCopy is the identifier for the Copy adapter.
	TaskTypeCopy = models.MustNewTaskType("copy")
	// TaskTypeEthBool is the identifier for the EthBool adapter.
	TaskTypeEthBool = models.MustNewTaskType("ethbool")
	// TaskTypeEthBytes32 is the identifier for the EthBytes32 adapter.
	TaskTypeEthBytes32 = models.MustNewTaskType("ethbytes32")
	// TaskTypeEthInt256 is the identifier for the EthInt256 adapter.
	TaskTypeEthInt256 = models.MustNewTaskType("ethint256")
	// TaskTypeEthUint256 is the identifier for the EthUint256 adapter.
	TaskTypeEthUint256 = models.MustNewTaskType("ethuint256")
	// TaskTypeEthTx is the identifier for the EthTx adapter.
	TaskTypeEthTx = models.MustNewTaskType("ethtx")
	// TaskTypeEthTxABIEncode is the identifier for the EthTxABIEncode adapter.
	TaskTypeEthTxABIEncode = models.MustNewTaskType("ethtxabiencode")
	// TaskTypeHTTPGetWithUnrestrictedNetworkAccess is the identifier for the HTTPGet adapter, with local/private IP access enabled.
	TaskTypeHTTPGetWithUnrestrictedNetworkAccess = models.MustNewTaskType("httpgetwithunrestrictednetworkaccess")
	// TaskTypeHTTPPostWithUnrestrictedNetworkAccess is the identifier for the HTTPPost adapter, with local/private IP access enabled.
	TaskTypeHTTPPostWithUnrestrictedNetworkAccess = models.MustNewTaskType("httppostwithunrestrictednetworkaccess")
	// TaskTypeHTTPGet is the identifier for the HTTPGet adapter.
	TaskTypeHTTPGet = models.MustNewTaskType("httpget")
	// TaskTypeHTTPPost is the identifier for the HTTPPost adapter.
	TaskTypeHTTPPost = models.MustNewTaskType("httppost")
	// TaskTypeJSONParse is the identifier for the JSONParse adapter.
	TaskTypeJSONParse = models.MustNewTaskType("jsonparse")
	// TaskTypeMultiply is the identifier for the Multiply adapter.
	TaskTypeMultiply = models.MustNewTaskType("multiply")
	// TaskTypeNoOp is the identifier for the NoOp adapter.
	TaskTypeNoOp = models.MustNewTaskType("noop")
	// TaskTypeNoOpPendOutgoing is the identifier for the NoOpPendOutgoing adapter.
	TaskTypeNoOpPendOutgoing = models.MustNewTaskType("nooppendoutgoing")
	// TaskTypeSleep is the identifier for the Sleep adapter.
	TaskTypeSleep = models.MustNewTaskType("sleep")
	// TaskTypeWasm is the wasm interpereter adapter
	TaskTypeWasm = models.MustNewTaskType("wasm")
	// TaskTypeRandom is the identifier for the Random adapter.
	TaskTypeRandom = models.MustNewTaskType("random")
	// TaskTypeCompare is the identifier for the Compare adapter.
	TaskTypeCompare = models.MustNewTaskType("compare")
	// TaskTypeQuotient is the identifier for the Quotient adapter.
	TaskTypeQuotient = models.MustNewTaskType("quotient")
)
View Source 
var (
	ErrResultNotNumber      = errors.New("the result was not a number")
	ErrValueNotNumber       = errors.New("the value was not a number")
	ErrOperatorNotSpecified = errors.New("operator not specified")
	ErrValueNotSpecified    = errors.New("value not specified")
)

Functions

This section is empty.

Types

type BaseAdapter 

type BaseAdapter interface {
	TaskType() models.TaskType
	Perform(models.RunInput, *store.Store) models.RunOutput
}

BaseAdapter is the minimum interface required to create an adapter. Only core adapters have this minimum requirement.

func FindNativeAdapterFor added in v0.8.5 

func FindNativeAdapterFor(task models.TaskSpec) BaseAdapter

FindNativeAdapterFor find the native adapter for a given task

type Bridge 

type Bridge struct {
	models.BridgeType
	Params models.JSON
}

Bridge adapter is responsible for connecting the task pipeline to external adapters, allowing for custom computations to be executed and included in runs.

func (*Bridge) Perform 

func (ba *Bridge) Perform(input models.RunInput, store *store.Store) models.RunOutput

Perform sends a POST request containing the JSON of the input to the external adapter specified in the BridgeType.

It records the RunResult returned to it, and optionally marks the RunResult pending.

If the Perform is resumed with a pending RunResult, the RunResult is marked not pending and the RunResult is returned.

func (*Bridge) TaskType added in v0.8.2 

func (ba *Bridge) TaskType() models.TaskType

TaskType returns the bridges defined type.

type Compare added in v0.6.7 

type Compare struct {
	Operator string `json:"operator"`
	Value    string `json:"value"`
}

Compare adapter type takes an Operator and a Value field to compare to the previous task's Result.

func (*Compare) Perform added in v0.6.7 

func (c *Compare) Perform(input models.RunInput, _ *store.Store) models.RunOutput

Perform uses the Operator to check the run's result against the specified Value.

func (*Compare) TaskType added in v0.8.2 

func (c *Compare) TaskType() models.TaskType

TaskType returns the type of Adapter.

type Copy 

type Copy struct {
	CopyPath JSONPath `json:"copyPath"`
}

Copy obj keys refers to which value to copy inside `data`, each obj value refers to where to copy the value to inside `data`

func (*Copy) Perform 

func (c *Copy) Perform(input models.RunInput, store *store.Store) models.RunOutput

Perform returns the copied values from the desired mapping within the `data` JSON object

func (*Copy) TaskType added in v0.8.2 

func (c *Copy) TaskType() models.TaskType

TaskType returns the type of Adapter.

type EthBool 

type EthBool struct{}

EthBool holds no fields

func (*EthBool) Perform 

func (*EthBool) Perform(input models.RunInput, _ *store.Store) models.RunOutput

Perform returns the abi encoding for a boolean

For example, after converting the result false to hex encoded Ethereum ABI, it would be: "0x0000000000000000000000000000000000000000000000000000000000000000"

func (*EthBool) TaskType added in v0.8.2 

func (e *EthBool) TaskType() models.TaskType

TaskType returns the type of Adapter.

type EthBytes32 

type EthBytes32 struct{}

EthBytes32 holds no fields.

func (*EthBytes32) Perform 

func (*EthBytes32) Perform(input models.RunInput, _ *store.Store) models.RunOutput

Perform returns the hex value of the first 32 bytes of a string so that it is in the proper format to be written to the blockchain.

For example, after converting the string "16800.01" to hex encoded Ethereum ABI, it would be: "0x31363830302e3031000000000000000000000000000000000000000000000000"

func (*EthBytes32) TaskType added in v0.8.2 

func (e *EthBytes32) TaskType() models.TaskType

TaskType returns the type of Adapter.

type EthInt256 

type EthInt256 struct{}

EthInt256 holds no fields

func (*EthInt256) Perform 

func (*EthInt256) Perform(input models.RunInput, _ *store.Store) models.RunOutput

Perform returns the hex value of a given string so that it is in the proper format to be written to the blockchain.

For example, after converting the string "-123.99" to hex encoded Ethereum ABI, it would be: "0xffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffff85"

func (*EthInt256) TaskType added in v0.8.2 

func (e *EthInt256) TaskType() models.TaskType

TaskType returns the type of Adapter.

type EthTx 

type EthTx struct {
	ToAddress common.Address `json:"address"`
	// NOTE: FromAddress is deprecated and kept for backwards compatibility, new job specs should use fromAddresses
	FromAddress      common.Address          `json:"fromAddress,omitempty"`
	FromAddresses    []common.Address        `json:"fromAddresses,omitempty"`
	FunctionSelector models.FunctionSelector `json:"functionSelector"`
	DataPrefix       hexutil.Bytes           `json:"dataPrefix"`
	DataFormat       string                  `json:"format"`
	GasLimit         uint64                  `json:"gasLimit,omitempty"`

	// GasPrice only needed for legacy tx manager
	GasPrice *utils.Big `json:"gasPrice" gorm:"type:numeric"`

	// MinRequiredOutgoingConfirmations only works with bulletprooftxmanager
	MinRequiredOutgoingConfirmations uint64 `json:"minRequiredOutgoingConfirmations,omitempty"`
}

EthTx holds the Address to send the result to and the FunctionSelector to execute.

func (*EthTx) Perform 

func (e *EthTx) Perform(input models.RunInput, store *strpkg.Store) models.RunOutput

Perform creates the run result for the transaction if the existing run result is not currently pending. Then it confirms the transaction was confirmed on the blockchain.

func (*EthTx) TaskType added in v0.8.2 

func (e *EthTx) TaskType() models.TaskType

TaskType returns the type of Adapter.

type EthTxABIEncode added in v0.6.9 

type EthTxABIEncode struct {
	// Ethereum address of the contract this task calls
	Address common.Address `json:"address"`
	// ABI of contract function this task calls
	FunctionABI abi.Method `json:"functionABI"`
	GasPrice    *utils.Big `json:"gasPrice" gorm:"type:numeric"`
	GasLimit    uint64     `json:"gasLimit"`
}

EthTxABIEncode holds the Address to send the result to and the FunctionABI to use for encoding arguments.

func (*EthTxABIEncode) Perform added in v0.6.9 

func (etx *EthTxABIEncode) Perform(input models.RunInput, store *strpkg.Store) models.RunOutput

Perform creates the run result for the transaction if the existing run result is not currently pending. Then it confirms the transaction was confirmed on the blockchain.

func (*EthTxABIEncode) TaskType added in v0.8.2 

func (etx *EthTxABIEncode) TaskType() models.TaskType

TaskType returns the type of Adapter.

func (*EthTxABIEncode) UnmarshalJSON added in v0.6.9 

func (etx *EthTxABIEncode) UnmarshalJSON(data []byte) error

UnmarshalJSON for custom JSON unmarshal that is strict, i.e. doesn't accept spurious fields. (In particular, we wan't to ensure that we don't get spurious fields in the FunctionABI, so that users don't get any wrong ideas about what parts of the ABI we use for encoding data.)

type EthUint256 

type EthUint256 struct{}

EthUint256 holds no fields.

func (*EthUint256) Perform 

func (*EthUint256) Perform(input models.RunInput, _ *store.Store) models.RunOutput

Perform returns the hex value of a given string so that it is in the proper format to be written to the blockchain.

For example, after converting the string "123.99" to hex encoded Ethereum ABI, it would be: "0x000000000000000000000000000000000000000000000000000000000000007b"

func (*EthUint256) TaskType added in v0.8.2 

func (e *EthUint256) TaskType() models.TaskType

TaskType returns the type of Adapter.

type ExtendedPath 

type ExtendedPath []string

ExtendedPath is the path to append to a base URL

func (*ExtendedPath) UnmarshalJSON 

func (ep *ExtendedPath) UnmarshalJSON(input []byte) error

UnmarshalJSON implements the Unmarshaler interface

type HTTPGet 

type HTTPGet struct {
	URL                            models.WebURL   `json:"url"`
	GET                            models.WebURL   `json:"get"`
	Headers                        http.Header     `json:"headers"`
	QueryParams                    QueryParameters `json:"queryParams"`
	ExtendedPath                   ExtendedPath    `json:"extPath"`
	AllowUnrestrictedNetworkAccess bool            `json:"-"`
}

HTTPGet requires a URL which is used for a GET request when the adapter is called.

func (*HTTPGet) GetRequest 

func (hga *HTTPGet) GetRequest() (*http.Request, error)

GetRequest returns the HTTP request including query parameters and headers

func (*HTTPGet) GetURL 

func (hga *HTTPGet) GetURL() string

GetURL retrieves the GET field if set otherwise returns the URL field

func (*HTTPGet) Perform 

func (hga *HTTPGet) Perform(input models.RunInput, store *store.Store) models.RunOutput

Perform ensures that the adapter's URL responds to a GET request without errors and returns the response body as the "value" field of the result.

func (*HTTPGet) TaskType added in v0.8.2 

func (hga *HTTPGet) TaskType() models.TaskType

TaskType returns the type of Adapter.

type HTTPPost 

type HTTPPost struct {
	URL                            models.WebURL   `json:"url"`
	POST                           models.WebURL   `json:"post"`
	Headers                        http.Header     `json:"headers"`
	QueryParams                    QueryParameters `json:"queryParams"`
	Body                           *string         `json:"body,omitempty"`
	ExtendedPath                   ExtendedPath    `json:"extPath"`
	AllowUnrestrictedNetworkAccess bool            `json:"-"`
}

HTTPPost requires a URL which is used for a POST request when the adapter is called.

func (*HTTPPost) GetRequest 

func (hpa *HTTPPost) GetRequest(body string) (*http.Request, error)

GetRequest takes the request body and returns the HTTP request including query parameters and headers.

HTTPPost's Body parameter overrides the given argument if present.

func (*HTTPPost) GetURL 

func (hpa *HTTPPost) GetURL() string

GetURL retrieves the POST field if set otherwise returns the URL field

func (*HTTPPost) Perform 

func (hpa *HTTPPost) Perform(input models.RunInput, store *store.Store) models.RunOutput

Perform ensures that the adapter's URL responds to a POST request without errors and returns the response body as the "value" field of the result.

func (*HTTPPost) TaskType added in v0.8.2 

func (hpa *HTTPPost) TaskType() models.TaskType

TaskType returns the type of Adapter.

type HTTPRequestConfig added in v0.8.2 

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

HTTPRequestConfig holds the configurable settings for an http request

type HTTPResponseTooLargeError added in v0.8.2 

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

func (*HTTPResponseTooLargeError) Error added in v0.8.2 

func (e *HTTPResponseTooLargeError) Error() string

type JSONParse 

type JSONParse struct {
	Path JSONPath `json:"path"`
}

JSONParse holds a path to the desired field in a JSON object, made up of an array of strings.

func (*JSONParse) Perform 

func (jpa *JSONParse) Perform(input models.RunInput, _ *store.Store) models.RunOutput

Perform returns the value associated to the desired field for a given JSON object.

For example, if the JSON data looks like this: 

{
  "data": [
    {"last": "1111"},
    {"last": "2222"}
  ]
}

Then ["0","last"] would be the path, and "1111" would be the returned value

func (*JSONParse) TaskType added in v0.8.2 

func (jpa *JSONParse) TaskType() models.TaskType

TaskType returns the type of Adapter.

type JSONPath 

type JSONPath []string

JSONPath is a path to a value in a JSON object

func (*JSONPath) UnmarshalJSON 

func (jp *JSONPath) UnmarshalJSON(b []byte) error

UnmarshalJSON implements the Unmarshaler interface

type Multiply 

type Multiply struct {
	Times *decimal.Decimal `json:"times,omitempty"`
}

Multiply holds the a number to multiply the given value by.

func (*Multiply) Perform 

func (ma *Multiply) Perform(input models.RunInput, _ *store.Store) models.RunOutput

Perform returns the input's "result" field, multiplied times the adapter's "times" field.

For example, if input value is "99.994" and the adapter's "times" is set to "100", the result's value will be "9999.4".

func (*Multiply) TaskType added in v0.8.2 

func (m *Multiply) TaskType() models.TaskType

TaskType returns the type of Adapter.

type NoOp 

type NoOp struct{}

NoOp adapter type holds no fields

func (*NoOp) Perform 

func (noa *NoOp) Perform(input models.RunInput, _ *store.Store) models.RunOutput

Perform returns the input

func (*NoOp) TaskType added in v0.8.2 

func (noa *NoOp) TaskType() models.TaskType

TaskType returns the type of Adapter.

type NoOpPendOutgoing added in v0.8.4 

type NoOpPendOutgoing struct{}

NoOpPendOutgoing adapter type holds no fields

func (*NoOpPendOutgoing) Perform added in v0.8.4 

func (noa *NoOpPendOutgoing) Perform(_ models.RunInput, _ *store.Store) models.RunOutput

Perform on this adapter type returns an empty RunResult with an added field for the status to indicate the task is Pending.

func (*NoOpPendOutgoing) TaskType added in v0.8.4 

func (noa *NoOpPendOutgoing) TaskType() models.TaskType

TaskType returns the type of Adapter.

type PipelineAdapter 

type PipelineAdapter struct {
	BaseAdapter
	// contains filtered or unexported fields
}

PipelineAdapter wraps a BaseAdapter with requirements for execution in the pipeline.

func For 

func For(task models.TaskSpec, config orm.ConfigReader, orm *orm.ORM) (*PipelineAdapter, error)

For determines the adapter type to use for a given task.

func (PipelineAdapter) MinConfs 

func (p PipelineAdapter) MinConfs() uint32

MinConfs returns the private attribute

func (PipelineAdapter) MinPayment added in v0.8.2 

func (p PipelineAdapter) MinPayment() *assets.Link

MinPayment returns the payment for this adapter (defaults to none)

type QueryParameters 

type QueryParameters url.Values

QueryParameters are the keys and values to append to the URL

func (*QueryParameters) UnmarshalJSON 

func (qp *QueryParameters) UnmarshalJSON(input []byte) error

UnmarshalJSON implements the Unmarshaler interface

type Quotient added in v0.8.2 

type Quotient struct {
	Dividend *big.Float `json:"-"`
}

Quotient holds the Dividend.

func (Quotient) MarshalJSON added in v0.8.2 

func (q Quotient) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshal interface.

func (*Quotient) Perform added in v0.8.2 

func (q *Quotient) Perform(input models.RunInput, _ *store.Store) models.RunOutput

Perform returns result of dividend / divisor were divisor is the input's "result" field.

For example, if input value is "2.5", and the adapter's "dividend" value is "1", the result's value will be "0.4".

func (*Quotient) TaskType added in v0.8.2 

func (q *Quotient) TaskType() models.TaskType

TaskType returns the type of Adapter.

func (*Quotient) UnmarshalJSON added in v0.8.2 

func (q *Quotient) UnmarshalJSON(buf []byte) error

UnmarshalJSON implements the json.Unqrshal interface.

type Random added in v0.6.4 

type Random struct {
	// Compressed hex representation public key used in Random's VRF proofs
	//
	// This is just a hex string because Random is instantiated by json.Unmarshal.
	// (See adapters.For function.)
	PublicKey string `json:"publicKey"`
}

Random adapter type implements VRF calculation in its Perform method.

The VRFCoordinator.sol contract and its integration with the chainlink node will handle interaction with the Random adapter, but if you need to interact with it directly, its input to should be a JSON object with "seed" and "keyHash" fields containing the input seed as a hex-represented uint256, and the keccak256 hash of the UNCOMPRESSED REPRESENTATION(*) of the public key E.g., given the input 

{
  "seed":
    "0x0000000000000000000000000000000000000000000000000000000000000001",
  "keyHash":
    "0xc0a6c424ac7157ae408398df7e5f4552091a69125d5dfcb7b8c2659029395bdf",
}

the adapter will return a proof for the VRF output given seed 1, as long as the keccak256 hash of its public key matches the hash in the input. Otherwise, it will error.

The adapter returns the hex representation of a solidity bytes array which can be verified on-chain by VRF.sol#randomValueFromVRFProof. (I.e., it is the proof expected by that method, prepended by its length as a uint256.)

(*) I.e., the 64-byte concatenation of the point's x- and y- ordinates as uint256's

func (*Random) Perform added in v0.6.4 

func (ra *Random) Perform(input models.RunInput, store *store.Store) models.RunOutput

Perform returns the the proof for the VRF output given seed, or an error.

func (*Random) TaskType added in v0.8.2 

func (ra *Random) TaskType() models.TaskType

TaskType returns the type of Adapter.

type RemoteServerError added in v0.8.2 

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

func (*RemoteServerError) Error added in v0.8.2 

func (e *RemoteServerError) Error() string

type Sleep 

type Sleep struct {
	Until models.AnyTime `json:"until"`
}

Sleep adapter allows a job to do nothing for some amount of wall time.

func (*Sleep) Duration 

func (adapter *Sleep) Duration() time.Duration

Duration returns the amount of sleeping this task should be paused for.

func (*Sleep) Perform 

func (adapter *Sleep) Perform(input models.RunInput, str *store.Store) models.RunOutput

Perform returns the input RunResult after waiting for the specified Until parameter.

func (*Sleep) TaskType added in v0.8.2 

func (adapter *Sleep) TaskType() models.TaskType

TaskType returns the type of Adapter.

type Wasm 

type Wasm struct {
	WasmT string `json:"wasmt"`
}

Wasm represents a wasm binary encoded as base64 or wasm encoded as text (a lisp like language).

func (*Wasm) Perform 

func (wasm *Wasm) Perform(input models.RunInput, _ *store.Store) models.RunOutput

Perform ships the wasm representation to the SGX enclave where it is evaluated.

func (*Wasm) TaskType added in v0.8.2 

func (wasm *Wasm) TaskType() models.TaskType

TaskType returns the type of Adapter.

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.