runners

Documentation

Index

• type HTTPGet
  • func (httpGet *HTTPGet) Perform(input models.RunResult) models.RunResult
• type HTTPPost
  • func (httpPost *HTTPPost) Perform(input models.RunResult) models.RunResult
• type IntegerData
• type JSONParse
  • func (jsonParse *JSONParse) Perform(input models.RunResult) models.RunResult
• type OracleParamAbi
• type RandomOrg
  • func (randomOrg *RandomOrg) Perform(input models.RunResult) models.RunResult
• type Runner
  • func For(task models.TaskSpec) (r Runner, err error)
• type SignedIntegerData

Types

type HTTPGet

type HTTPGet struct {
	URL models.WebURL `json:"url"`
}

func (*HTTPGet) Perform

func (httpGet *HTTPGet) Perform(input models.RunResult) models.RunResult

type HTTPPost

type HTTPPost struct {
	URL         models.WebURL `json:"url"`
	ContentType string        `json:"contentType"`
	Body        string        `json:"body"`
}

func (*HTTPPost) Perform

func (httpPost *HTTPPost) Perform(input models.RunResult) models.RunResult

type IntegerData

type IntegerData struct {
	Data           []interface{} `json:"data"`
	CompletionTime string        `json:"completionTime"`
}

type JSONParse

type JSONParse struct {
	Data []*OracleParamAbi `json:"data"`
}

func (*JSONParse) Perform

func (jsonParse *JSONParse) Perform(input models.RunResult) models.RunResult

type OracleParamAbi

type OracleParamAbi struct {
	Type    string            `json:"type"`
	Path    []string          `json:"path"`
	Decimal uint64            `json:"decimal"`
	SubType []*OracleParamAbi `json:"sub_type"`
}

type RandomOrg

type RandomOrg struct {
	Method      string `json:"method"`
	N           int    `json:"n"`
	Min         int    `json:"min"`
	Max         int    `json:"max"`
	Replacement bool   `json:"replacement"`
}

func (*RandomOrg) Perform

func (randomOrg *RandomOrg) Perform(input models.RunResult) models.RunResult

type Runner

type Runner interface {
	Perform(models.RunResult) models.RunResult
}

The Runner interface applies to all core runners. Each implementation must return a RunResult.

func For

func For(task models.TaskSpec) (r Runner, err error)

For determines the runner type to use for a given task

type SignedIntegerData

type SignedIntegerData struct {
	CompletionTime string `json:"completionTime"`
	HashedApiKey   string `json:"hashedApiKey"`
	SerialNumber   int    `json:"serialNumber"`
	Data           []int  `json:"data"`
	Signature      string `json:"signature"`
}