oracle

package
v0.93.0 Latest Latest
Warning

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

Go to latest
Published: Feb 12, 2021 License: MIT Imports: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ErrResponseTooLarge = errors.New("too big response")

ErrResponseTooLarge is returned when response exceeds max allowed size.

Functions

This section is empty.

Types

type Broadcaster

type Broadcaster interface {
	SendResponse(priv *keys.PrivateKey, resp *transaction.OracleResponse, txSig []byte)
	Run()
	Shutdown()
}

Broadcaster broadcasts oracle responses.

type Config

type Config struct {
	Log             *zap.Logger
	Network         netmode.Magic
	MainCfg         config.OracleConfiguration
	Client          HTTPClient
	Chain           blockchainer.Blockchainer
	ResponseHandler Broadcaster
	OnTransaction   TxCallback
	URIValidator    URIValidator
	OracleScript    []byte
	OracleResponse  []byte
	OracleHash      util.Uint160
}

Config contains oracle module parameters.

type HTTPClient

type HTTPClient interface {
	Get(string) (*http.Response, error)
}

HTTPClient is an interface capable of doing oracle requests.

type Oracle

type Oracle struct {
	Config
	// contains filtered or unexported fields
}

Oracle represents oracle module capable of talking with the external world.

func NewOracle

func NewOracle(cfg Config) (*Oracle, error)

NewOracle returns new oracle instance.

func (*Oracle) AddRequests

func (o *Oracle) AddRequests(reqs map[uint64]*state.OracleRequest)

AddRequests saves all requests in-fly for further processing.

func (*Oracle) AddResponse

func (o *Oracle) AddResponse(pub *keys.PublicKey, reqID uint64, txSig []byte)

AddResponse processes oracle response from node pub. sig is response transaction signature.

func (*Oracle) CreateResponseTx

func (o *Oracle) CreateResponseTx(gasForResponse int64, height uint32, resp *transaction.OracleResponse) (*transaction.Transaction, error)

CreateResponseTx creates unsigned oracle response transaction.

func (*Oracle) ProcessRequestsInternal

func (o *Oracle) ProcessRequestsInternal(reqs map[uint64]*state.OracleRequest)

ProcessRequestsInternal processes provided requests synchronously.

func (*Oracle) RemoveRequests

func (o *Oracle) RemoveRequests(ids []uint64)

RemoveRequests removes all data associated with requests which have been processed by oracle contract.

func (*Oracle) Run

func (o *Oracle) Run()

Run runs must be executed in a separate goroutine.

func (*Oracle) SetBroadcaster

func (o *Oracle) SetBroadcaster(b Broadcaster)

SetBroadcaster sets callback to broadcast response.

func (*Oracle) SetOnTransaction

func (o *Oracle) SetOnTransaction(cb TxCallback)

SetOnTransaction sets callback to pool and broadcast tx.

func (*Oracle) Shutdown

func (o *Oracle) Shutdown()

Shutdown shutdowns Oracle.

func (*Oracle) UpdateOracleNodes

func (o *Oracle) UpdateOracleNodes(oracleNodes keys.PublicKeys)

UpdateOracleNodes updates oracle nodes list.

type TxCallback

type TxCallback = func(tx *transaction.Transaction)

TxCallback executes on new transactions when they are ready to be pooled.

type URIValidator

type URIValidator = func(*url.URL) error

URIValidator is used to check if provided URL is valid.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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