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) IsAuthorized() bool
- func (o *Oracle) Name() string
- func (o *Oracle) ProcessRequestsInternal(reqs map[uint64]*state.OracleRequest)
- func (o *Oracle) RemoveRequests(ids []uint64)
- 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.Blockchain
GetMaxVerificationGAS() int64
GetTestVM(t trigger.Type, tx *transaction.Transaction, b *block.Block) (*interop.Context, error)
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) IsAuthorized ¶ added in v0.104.0
IsAuthorized returns whether Oracle service currently is authorized to collect signatures. It returns true iff designated Oracle node's account provided to the Oracle service in decrypted state.
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) 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.
Source Files
Directories