transport

Documentation

Index

• Variables
• type CallMsg
  • func (self CallMsg) CheckNonce() bool
  • func (self CallMsg) Data() []byte
  • func (self CallMsg) From() web3.Address
  • func (self CallMsg) Gas() uint64
  • func (self CallMsg) GasPrice() *big.Int
  • func (self CallMsg) Hash() web3.Hash
  • func (self CallMsg) Nonce() uint64
  • func (self CallMsg) To() *web3.Address
  • func (self CallMsg) Value() *big.Int
• type Codec
• type HTTP
  • func (h *HTTP) Call(method string, out interface{}, params ...interface{}) error
  • func (h *HTTP) Close() error
• type Local
  • func NewLocal(db schema.ChainDB, chainID uint64) *Local
  • func (self *Local) Call(method string, out interface{}, params ...interface{}) error
  • func (self *Local) CallEvm(msg *web3.CallMsg) (*web3.ExecutionResult, error)
  • func (self *Local) Close() error
  • func (self *Local) GetBalance(acct web3.Address) (amount *big.Int)
  • func (self *Local) SetBalance(acct web3.Address, amount *big.Int)
• type PubSubTransport
• type Transport
  • func NewTransport(url string) (Transport, error)

Variables

var ErrTimeout = fmt.Errorf("timeout")

ErrTimeout happens when the websocket requests times out

Types

type CallMsg

type CallMsg struct {
	// contains filtered or unexported fields
}

func (CallMsg) CheckNonce

func (self CallMsg) CheckNonce() bool

func (CallMsg) Data

func (self CallMsg) Data() []byte

func (CallMsg) From

func (self CallMsg) From() web3.Address

func (CallMsg) Gas

func (self CallMsg) Gas() uint64

func (CallMsg) GasPrice

func (self CallMsg) GasPrice() *big.Int

func (CallMsg) Hash

func (self CallMsg) Hash() web3.Hash

func (CallMsg) Nonce

func (self CallMsg) Nonce() uint64

func (CallMsg) To

func (self CallMsg) To() *web3.Address

func (CallMsg) Value

func (self CallMsg) Value() *big.Int

type Codec

type Codec interface {
	Read([]byte) ([]byte, error)
	Write([]byte) error
	Close() error
}

Codec is the codec to write and read messages

type HTTP

type HTTP struct {
	// contains filtered or unexported fields
}

HTTP is an http transport

func (*HTTP) Call

func (h *HTTP) Call(method string, out interface{}, params ...interface{}) error

Call implements the transport interface

func (*HTTP) Close

func (h *HTTP) Close() error

Close implements the transport interface

type Local

type Local struct {
	Executor    *executor.Executor
	BlockNumber uint64
	BlockHashes map[uint64]web3.Hash
	Receipts    map[web3.Hash]*web3.Receipt
	// contains filtered or unexported fields
}

func NewLocal

func NewLocal(db schema.ChainDB, chainID uint64) *Local

func (*Local) Call

func (self *Local) Call(method string, out interface{}, params ...interface{}) error

Call implements the transport interface

func (*Local) CallEvm

func (self *Local) CallEvm(msg *web3.CallMsg) (*web3.ExecutionResult, error)

func (*Local) Close

func (self *Local) Close() error

Close implements the transport interface

func (*Local) GetBalance

func (self *Local) GetBalance(acct web3.Address) (amount *big.Int)

func (*Local) SetBalance

func (self *Local) SetBalance(acct web3.Address, amount *big.Int)

type PubSubTransport

type PubSubTransport interface {
	// Subscribe starts a subscription to a new event
	Subscribe(method string, param interface{}, callback func(b []byte)) (func() error, error)
}

PubSubTransport is a transport that allows subscriptions

type Transport

type Transport interface {
	// Call makes a jsonrpc request
	Call(method string, out interface{}, params ...interface{}) error

	// Close closes the transport connection if necessary
	Close() error
}

Transport is an inteface for transport methods to send jsonrpc requests

func NewTransport

func NewTransport(url string) (Transport, error)

NewTransport creates a new transport object