Versions in this module Expand all Collapse all v0 v0.0.2 Mar 12, 2021 Changes in this version + const DataFormatBytes + var ErrInvalidABIEncoding = errors.New("invalid abi encoding") + 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") + 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 TaskTypeHTTPGetWithUnrestrictedNetworkAccess = models.MustNewTaskType("httpgetwithunrestrictednetworkaccess") + var TaskTypeHTTPPost = models.MustNewTaskType("httppost") + var TaskTypeHTTPPostWithUnrestrictedNetworkAccess = models.MustNewTaskType("httppostwithunrestrictednetworkaccess") + var TaskTypeJSONParse = models.MustNewTaskType("jsonparse") + var TaskTypeMultiply = models.MustNewTaskType("multiply") + var TaskTypeNoOp = models.MustNewTaskType("noop") + var TaskTypeNoOpPendOutgoing = models.MustNewTaskType("nooppendoutgoing") + var TaskTypeQuotient = models.MustNewTaskType("quotient") + var TaskTypeRandom = models.MustNewTaskType("random") + var TaskTypeResultCollect = models.MustNewTaskType("resultcollect") + var TaskTypeSleep = models.MustNewTaskType("sleep") + type BaseAdapter interface + Perform func(models.RunInput, *store.Store) models.RunOutput + TaskType func() models.TaskType + func FindNativeAdapterFor(task models.TaskSpec) BaseAdapter + type Bridge struct + Params models.JSON + func (ba *Bridge) Perform(input models.RunInput, store *store.Store) models.RunOutput + func (ba *Bridge) TaskType() models.TaskType + type Compare struct + Operator string + Value string + func (c *Compare) Perform(input models.RunInput, _ *store.Store) models.RunOutput + func (c *Compare) TaskType() models.TaskType + type Copy struct + CopyPath JSONPath + func (c *Copy) Perform(input models.RunInput, store *store.Store) models.RunOutput + func (c *Copy) TaskType() models.TaskType + type EthBool struct + func (*EthBool) Perform(input models.RunInput, _ *store.Store) models.RunOutput + func (e *EthBool) TaskType() models.TaskType + type EthBytes32 struct + func (*EthBytes32) Perform(input models.RunInput, _ *store.Store) models.RunOutput + func (e *EthBytes32) TaskType() models.TaskType + type EthInt256 struct + func (*EthInt256) Perform(input models.RunInput, _ *store.Store) models.RunOutput + func (e *EthInt256) TaskType() models.TaskType + type EthTx struct + ABIEncoding []string + DataFormat string + DataPrefix hexutil.Bytes + FromAddress common.Address + FromAddresses []common.Address + FunctionSelector models.FunctionSelector + GasLimit uint64 + MinRequiredOutgoingConfirmations uint64 + ToAddress common.Address + func (e *EthTx) Perform(input models.RunInput, store *strpkg.Store) models.RunOutput + func (e *EthTx) TaskType() models.TaskType + type EthUint256 struct + func (*EthUint256) Perform(input models.RunInput, _ *store.Store) models.RunOutput + func (e *EthUint256) TaskType() models.TaskType + type ExtendedPath []string + func (ep *ExtendedPath) UnmarshalJSON(input []byte) error + type HTTPGet struct + AllowUnrestrictedNetworkAccess bool + 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.RunInput, store *store.Store) models.RunOutput + func (hga *HTTPGet) TaskType() models.TaskType + type HTTPPost struct + AllowUnrestrictedNetworkAccess bool + Body *string + 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.RunInput, store *store.Store) models.RunOutput + func (hpa *HTTPPost) TaskType() models.TaskType + type JSONParse struct + Path JSONPath + func (jpa *JSONParse) Perform(input models.RunInput, _ *store.Store) models.RunOutput + func (jpa *JSONParse) TaskType() models.TaskType + type JSONPath []string + func (jp *JSONPath) UnmarshalJSON(b []byte) error + type Multiply struct + Times *decimal.Decimal + func (m *Multiply) Perform(input models.RunInput, _ *store.Store) models.RunOutput + func (m *Multiply) TaskType() models.TaskType + type NoOp struct + func (noa *NoOp) Perform(input models.RunInput, _ *store.Store) models.RunOutput + func (noa *NoOp) TaskType() models.TaskType + type NoOpPendOutgoing struct + func (noa *NoOpPendOutgoing) Perform(_ models.RunInput, _ *store.Store) models.RunOutput + func (noa *NoOpPendOutgoing) TaskType() models.TaskType + type PipelineAdapter struct + func For(task models.TaskSpec, config orm.ConfigReader, orm *orm.ORM) (*PipelineAdapter, error) + func (p PipelineAdapter) MinConfs() uint32 + func (p PipelineAdapter) MinPayment() *assets.Link + type QueryParameters url.Values + func (qp *QueryParameters) UnmarshalJSON(input []byte) error + 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 struct + PublicKey string + func (ra *Random) Perform(input models.RunInput, store *store.Store) models.RunOutput + func (ra *Random) TaskType() models.TaskType + type ResultCollect struct + func (r ResultCollect) Perform(input models.RunInput, store *store.Store) models.RunOutput + func (r ResultCollect) TaskType() models.TaskType + type Sleep struct + Until models.AnyTime + func (adapter *Sleep) Duration() time.Duration + func (adapter *Sleep) Perform(input models.RunInput, str *store.Store) models.RunOutput + func (adapter *Sleep) TaskType() models.TaskType
Go to main page