Documentation
¶
Index ¶
- Variables
- type Broadcaster
- type Config
- type HTTPClient
- type Ledger
- type Oracle
- func (o *Oracle) AddRequests(reqs map[uint64]*state.OracleRequest)
- func (o *Oracle) AddResponse(pub *keys.PublicKey, reqID uint64, txSig []byte)
- func (o *Oracle) CreateResponseTx(gasForResponse int64, vub uint32, resp *transaction.OracleResponse) (*transaction.Transaction, error)
- func (o *Oracle) Name() string
- func (o *Oracle) ProcessRequestsInternal(reqs map[uint64]*state.OracleRequest)
- func (o *Oracle) RemoveRequests(ids []uint64)
- func (o *Oracle) SetBroadcaster(b Broadcaster)
- func (o *Oracle) Shutdown()
- func (o *Oracle) Start()
- func (o *Oracle) UpdateNativeContract(script, resp []byte, h util.Uint160, verifyOffset int)
- func (o *Oracle) UpdateOracleNodes(oracleNodes keys.PublicKeys)
- type TxCallback
Constants ¶
This section is empty.
Variables ¶
var ErrResponseTooLarge = errors.New("too big response")
ErrResponseTooLarge is returned when a response exceeds the max allowed size.
var ErrRestrictedRedirect = errors.New("oracle request redirection error")
ErrRestrictedRedirect is returned when redirection to forbidden address occurs during Oracle response creation.
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 Ledger ResponseHandler Broadcaster OnTransaction TxCallback }
Config contains oracle module parameters.
type HTTPClient ¶
HTTPClient is an interface capable of doing oracle requests.
type Ledger ¶ added in v0.98.1
type Ledger interface { BlockHeight() uint32 FeePerByte() int64 GetBaseExecFee() int64 GetConfig() config.ProtocolConfiguration GetMaxVerificationGAS() int64 GetTestVM(t trigger.Type, tx *transaction.Transaction, b *block.Block) *interop.Context GetTransaction(util.Uint256) (*transaction.Transaction, uint32, error) }
Ledger is an interface to Blockchain sufficient for Oracle.
type Oracle ¶
type Oracle struct { Config // contains filtered or unexported fields }
Oracle represents an oracle module capable of talking with the external world.
func (*Oracle) AddRequests ¶
func (o *Oracle) AddRequests(reqs map[uint64]*state.OracleRequest)
AddRequests saves all requests in-fly for further processing.
func (*Oracle) AddResponse ¶
AddResponse handles an oracle response (transaction signature for some identified request) signed by the given key. sig is a response transaction signature.
func (*Oracle) CreateResponseTx ¶
func (o *Oracle) CreateResponseTx(gasForResponse int64, vub uint32, resp *transaction.OracleResponse) (*transaction.Transaction, error)
CreateResponseTx creates an unsigned oracle response transaction.
func (*Oracle) ProcessRequestsInternal ¶
func (o *Oracle) ProcessRequestsInternal(reqs map[uint64]*state.OracleRequest)
ProcessRequestsInternal processes the provided requests synchronously.
func (*Oracle) RemoveRequests ¶
RemoveRequests removes all data associated with requests which have been processed by oracle contract.
func (*Oracle) SetBroadcaster ¶
func (o *Oracle) SetBroadcaster(b Broadcaster)
SetBroadcaster sets callback to broadcast response.
func (*Oracle) Shutdown ¶
func (o *Oracle) Shutdown()
Shutdown shutdowns Oracle. It can only be called once, subsequent calls to Shutdown on the same instance are no-op. The instance that was stopped can not be started again by calling Start (use a new instance if needed).
func (*Oracle) Start ¶ added in v0.98.1
func (o *Oracle) Start()
Start runs the oracle service in a separate goroutine. The Oracle only starts once, subsequent calls to Start are no-op.
func (*Oracle) UpdateNativeContract ¶ added in v0.94.0
UpdateNativeContract updates native oracle contract info for tx verification.
func (*Oracle) UpdateOracleNodes ¶
func (o *Oracle) UpdateOracleNodes(oracleNodes keys.PublicKeys)
UpdateOracleNodes updates oracle nodes list.
type TxCallback ¶
type TxCallback = func(tx *transaction.Transaction) error
TxCallback executes on new transactions when they are ready to be pooled.