adapters

package

Go to main page

Versions in this module

v0

v0.10.16-rc1

May 4, 2022

v0.10.16-rc0

Mar 18, 2022

v0.10.15

Oct 14, 2021

v0.10.14

Sep 7, 2021

v0.10.13

Aug 25, 2021

v0.10.12

Aug 16, 2021

v0.10.11

Aug 9, 2021

Changes in this version

type Random

+ Backend bind.ContractBackend

v0.10.10

Jul 26, 2021

v0.10.9

Jul 6, 2021

v0.10.8

Jun 21, 2021

v0.10.7

May 24, 2021

v0.10.6

May 10, 2021

v0.10.5

Apr 26, 2021

v0.10.4

Apr 12, 2021

Changes in this version

type Random

+ CoordinatorAddress models.EIP55Address

v0.10.3

Mar 22, 2021

v0.10.2

Mar 8, 2021

v0.10.1

Feb 25, 2021

v0.10.0

Feb 24, 2021

v0.9.10

Feb 1, 2021

v0.9.9

Jan 18, 2021

v0.9.8

Dec 16, 2020

v0.9.7

Dec 14, 2020

Changes in this version

+ var ErrInvalidABIEncoding = errors.New("invalid abi encoding")

+ var TaskTypeResultCollect = models.MustNewTaskType("resultcollect")

type EthTx

+ ABIEncoding []string

+ type ResultCollect struct

+ func (r ResultCollect) Perform(input models.RunInput, store *store.Store) models.RunOutput

+ func (r ResultCollect) TaskType() models.TaskType

v0.9.6

Nov 23, 2020

v0.9.5

Nov 12, 2020

v0.9.4

Nov 4, 2020

v0.9.3

Nov 2, 2020

v0.9.2

Oct 15, 2020

v0.9.0

Oct 12, 2020

v0.8.18

Oct 1, 2020

v0.8.17

Sep 28, 2020

v0.8.16

Sep 22, 2020

v0.8.15

Sep 15, 2020

v0.8.14

Sep 2, 2020

v0.8.13

Aug 26, 2020

v0.8.12

Aug 10, 2020

v0.8.11

Jul 27, 2020

Changes in this version

type EthTx

+ FromAddresses []common.Address

v0.8.10

Jul 14, 2020

v0.8.9

Jul 13, 2020

v0.8.8

Jun 29, 2020

v0.8.7

Jun 15, 2020

Changes in this version

type EthTx

+ FromAddress common.Address

+ MinRequiredOutgoingConfirmations uint64

+ ToAddress common.Address

v0.8.6

Jun 11, 2020

v0.8.5

Jun 1, 2020

Changes in this version

type BaseAdapter

+ func FindNativeAdapterFor(task models.TaskSpec) BaseAdapter

v0.8.4

May 18, 2020

Changes in this version

+ var TaskTypeNoOpPendOutgoing = models.MustNewTaskType("nooppendoutgoing")

+ type NoOpPendOutgoing struct

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

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

v0.8.3

May 4, 2020

v0.8.2

Apr 20, 2020

Changes in this version

+ var TaskTypeHTTPGetWithUnrestrictedNetworkAccess = models.MustNewTaskType("httpgetwithunrestrictednetworkaccess")

+ var TaskTypeHTTPPostWithUnrestrictedNetworkAccess = models.MustNewTaskType("httppostwithunrestrictednetworkaccess")

+ var TaskTypeQuotient = models.MustNewTaskType("quotient")

type BaseAdapter

+ TaskType func() models.TaskType

type Bridge

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

type Compare

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

type Copy

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

type EthBool

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

type EthBytes32

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

type EthInt256

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

type EthTx

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

type EthTxABIEncode

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

type EthUint256

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

type HTTPGet

+ AllowUnrestrictedNetworkAccess bool

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

type HTTPPost

+ AllowUnrestrictedNetworkAccess bool

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

+ type HTTPRequestConfig struct

+ type HTTPResponseTooLargeError struct

+ func (e *HTTPResponseTooLargeError) Error() string

type JSONParse

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

type Multiply

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

type NoOp

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

type NoOpPend

+ func (noa *NoOpPend) TaskType() models.TaskType

type PipelineAdapter

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

+ type Quotient struct

+ Dividend *big.Float

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

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

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

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

type Random

+ PublicKey string

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

+ type RemoteServerError struct

+ func (e *RemoteServerError) Error() string

type Sleep

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

type Wasm

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

v0.6.10

Nov 13, 2019

v0.6.9

Oct 3, 2019

Changes in this version

+ var TaskTypeEthTxABIEncode = models.MustNewTaskType("ethtxabiencode")

+ type EthTxABIEncode struct

+ Address common.Address

+ FunctionABI abi.Method

+ GasLimit uint64

+ GasPrice *models.Big

+ func (etx *EthTxABIEncode) Perform(input models.RunResult, store *strpkg.Store) models.RunResult

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

v0.6.8

Sep 19, 2019

v0.6.7

Sep 11, 2019

Changes in this version

+ var ErrOperatorNotSpecified = errors.New("Operator not specified")

+ var ErrResultNotNumber = errors.New("The result was not a number")

+ var ErrValueNotNumber = errors.New("The value was not a number")

+ var ErrValueNotSpecified = errors.New("Value not specified")

+ var TaskTypeCompare = models.MustNewTaskType("compare")

+ type Compare struct

+ Operator string

+ Value string

+ func (c *Compare) Perform(input models.RunResult, _ *store.Store) models.RunResult

v0.6.6

Sep 9, 2019

Changes in this version

type HTTPPost

+ Body *string

v0.6.4

Jul 24, 2019

Changes in this version

+ var TaskTypeRandom = models.MustNewTaskType("random")

+ func IsClientEmptyError(err error) bool

+ type Random struct

+ func (ra *Random) Perform(input models.RunResult, _ *store.Store) models.RunResult

v0.6.3

Jul 9, 2019

v0.6.2

Jun 27, 2019

v0.6.1

Jun 26, 2019

v0.6.0

Jun 25, 2019

Changes in this version

+ const DataFormatBytes

+ var TaskTypeCopy = models.MustNewTaskType("copy")

+ var TaskTypeEthBool = models.MustNewTaskType("ethbool")

+ var TaskTypeEthBytes32 = models.MustNewTaskType("ethbytes32")

+ var TaskTypeEthInt256 = models.MustNewTaskType("ethint256")

+ var TaskTypeEthTx = models.MustNewTaskType("ethtx")

+ var TaskTypeEthUint256 = models.MustNewTaskType("ethuint256")

+ var TaskTypeHTTPGet = models.MustNewTaskType("httpget")

+ var TaskTypeHTTPPost = models.MustNewTaskType("httppost")

+ var TaskTypeJSONParse = models.MustNewTaskType("jsonparse")

+ var TaskTypeMultiply = models.MustNewTaskType("multiply")

+ var TaskTypeNoOp = models.MustNewTaskType("noop")

+ var TaskTypeNoOpPend = models.MustNewTaskType("nooppend")

+ var TaskTypeSleep = models.MustNewTaskType("sleep")

+ var TaskTypeWasm = models.MustNewTaskType("wasm")

+ func IsClientRetriable(err error) bool

+ type BaseAdapter interface

+ Perform func(models.RunResult, *store.Store) models.RunResult

+ type Bridge struct

+ Params *models.JSON

+ func (ba *Bridge) Perform(input models.RunResult, store *store.Store) models.RunResult

+ type Copy struct

+ CopyPath JSONPath

+ func (c *Copy) Perform(input models.RunResult, store *store.Store) models.RunResult

+ type EthBool struct

+ func (*EthBool) Perform(input models.RunResult, _ *store.Store) models.RunResult

+ type EthBytes32 struct

+ func (*EthBytes32) Perform(input models.RunResult, _ *store.Store) models.RunResult

+ type EthInt256 struct

+ func (*EthInt256) Perform(input models.RunResult, _ *store.Store) models.RunResult

+ type EthTx struct

+ Address common.Address

+ DataFormat string

+ DataPrefix hexutil.Bytes

+ FunctionSelector models.FunctionSelector

+ GasLimit uint64

+ GasPrice *models.Big

+ func (etx *EthTx) Perform(input models.RunResult, store *strpkg.Store) models.RunResult

+ type EthUint256 struct

+ func (*EthUint256) Perform(input models.RunResult, _ *store.Store) models.RunResult

+ type ExtendedPath []string

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

+ type HTTPGet struct

+ ExtendedPath ExtendedPath

+ GET models.WebURL

+ Headers http.Header

+ QueryParams QueryParameters

+ URL models.WebURL

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

+ func (hga *HTTPGet) GetURL() string

+ func (hga *HTTPGet) Perform(input models.RunResult, store *store.Store) models.RunResult

+ type HTTPPost struct

+ ExtendedPath ExtendedPath

+ Headers http.Header

+ POST models.WebURL

+ QueryParams QueryParameters

+ URL models.WebURL

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

+ func (hpa *HTTPPost) GetURL() string

+ func (hpa *HTTPPost) Perform(input models.RunResult, store *store.Store) models.RunResult

+ type JSONParse struct

+ Path JSONPath

+ func (jpa *JSONParse) Perform(input models.RunResult, _ *store.Store) models.RunResult

+ type JSONPath []string

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

+ type Multiplier float64

+ func (m *Multiplier) UnmarshalJSON(input []byte) error

+ type Multiply struct

+ Times *Multiplier

+ func (ma *Multiply) Perform(input models.RunResult, _ *store.Store) models.RunResult

+ type NoOp struct

+ func (noa *NoOp) Perform(input models.RunResult, _ *store.Store) models.RunResult

+ type NoOpPend struct

+ func (noa *NoOpPend) Perform(input models.RunResult, _ *store.Store) models.RunResult

+ type PipelineAdapter struct

+ func For(task models.TaskSpec, store *store.Store) (*PipelineAdapter, error)

+ func (p PipelineAdapter) MinConfs() uint32

+ func (p PipelineAdapter) MinContractPayment() *assets.Link

+ type QueryParameters url.Values

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

+ type Sleep struct

+ Until models.AnyTime

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

+ func (adapter *Sleep) Perform(input models.RunResult, str *store.Store) models.RunResult

+ type Wasm struct

+ WasmT string

+ func (wasm *Wasm) Perform(input models.RunResult, _ *store.Store) models.RunResult

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL