go-expanse

Jul 4, 2021

Changes in this version

type CallMsg

+ AccessList types.AccessList

Feb 4, 2020

Changes in this version

type FilterQuery

+ BlockHash *common.Hash

Jun 4, 2017

Changes in this version

+ var NotFound = errors.New("not found")

+ type CallMsg struct

+ Data []byte

+ From common.Address

+ Gas *big.Int

+ GasPrice *big.Int

+ To *common.Address

+ Value *big.Int

+ type ChainReader interface

+ BlockByHash func(ctx context.Context, hash common.Hash) (*types.Block, error)

+ BlockByNumber func(ctx context.Context, number *big.Int) (*types.Block, error)

+ HeaderByHash func(ctx context.Context, hash common.Hash) (*types.Header, error)

+ HeaderByNumber func(ctx context.Context, number *big.Int) (*types.Header, error)

+ SubscribeNewHead func(ctx context.Context, ch chan<- *types.Header) (Subscription, error)

+ TransactionCount func(ctx context.Context, blockHash common.Hash) (uint, error)

+ TransactionInBlock func(ctx context.Context, blockHash common.Hash, index uint) (*types.Transaction, error)

+ type ChainStateReader interface

+ BalanceAt func(ctx context.Context, account common.Address, blockNumber *big.Int) (*big.Int, error)

+ CodeAt func(ctx context.Context, account common.Address, blockNumber *big.Int) ([]byte, error)

+ NonceAt func(ctx context.Context, account common.Address, blockNumber *big.Int) (uint64, error)

+ StorageAt func(ctx context.Context, account common.Address, key common.Hash, ...) ([]byte, error)

+ type ChainSyncReader interface

+ SyncProgress func(ctx context.Context) (*SyncProgress, error)

+ type ContractCaller interface

+ CallContract func(ctx context.Context, call CallMsg, blockNumber *big.Int) ([]byte, error)

+ type FilterQuery struct

+ Addresses []common.Address

+ FromBlock *big.Int

+ ToBlock *big.Int

+ Topics [][]common.Hash

+ type GasEstimator interface

+ EstimateGas func(ctx context.Context, call CallMsg) (usedGas *big.Int, err error)

+ type GasPricer interface

+ SuggestGasPrice func(ctx context.Context) (*big.Int, error)

+ type LogFilterer interface

+ FilterLogs func(ctx context.Context, q FilterQuery) ([]types.Log, error)

+ SubscribeFilterLogs func(ctx context.Context, q FilterQuery, ch chan<- types.Log) (Subscription, error)

+ type PendingContractCaller interface

+ PendingCallContract func(ctx context.Context, call CallMsg) ([]byte, error)

+ type PendingStateEventer interface

+ SubscribePendingTransactions func(ctx context.Context, ch chan<- *types.Transaction) (Subscription, error)

+ type PendingStateReader interface

+ PendingBalanceAt func(ctx context.Context, account common.Address) (*big.Int, error)

+ PendingCodeAt func(ctx context.Context, account common.Address) ([]byte, error)

+ PendingNonceAt func(ctx context.Context, account common.Address) (uint64, error)

+ PendingStorageAt func(ctx context.Context, account common.Address, key common.Hash) ([]byte, error)

+ PendingTransactionCount func(ctx context.Context) (uint, error)

+ type Subscription interface

+ Err func() <-chan error

+ Unsubscribe func()

+ type SyncProgress struct

+ CurrentBlock uint64

+ HighestBlock uint64

+ KnownStates uint64

+ PulledStates uint64

+ StartingBlock uint64

+ type TransactionReader interface

+ TransactionByHash func(ctx context.Context, txHash common.Hash) (tx *types.Transaction, isPending bool, err error)

+ TransactionReceipt func(ctx context.Context, txHash common.Hash) (*types.Receipt, error)

+ type TransactionSender interface

+ SendTransaction func(ctx context.Context, tx *types.Transaction) error

Dec 21, 2014

Changes in this version

+ const NetVersion

+ const P2PVersion

+ const ProtocolVersion

+ func PastPeers() []string

+ type BlockPool struct

+ BlocksProcessed int

+ ChainLength int

+ func NewBlockPool(eth *Ethereum) *BlockPool

+ func (self *BlockPool) Add(b *types.Block, peer *Peer)

+ func (self *BlockPool) AddHash(hash []byte, peer *Peer)

+ func (self *BlockPool) AddNew(b *types.Block, peer *Peer)

+ func (self *BlockPool) Blocks() (blocks types.Blocks)

+ func (self *BlockPool) DistributeHashes()

+ func (self *BlockPool) FetchHashes(peer *Peer) bool

+ func (self *BlockPool) HasCommonHash(hash []byte) bool

+ func (self *BlockPool) HasLatestHash() bool

+ func (self *BlockPool) Len() int

+ func (self *BlockPool) Remove(hash []byte)

+ func (self *BlockPool) Reset()

+ func (self *BlockPool) Start()

+ func (self *BlockPool) Stop()

+ type Caps byte

+ const CapChainTy

+ const CapDefault

+ const CapPeerDiscTy

+ const CapTxTy

+ func (c Caps) IsCap(cap Caps) bool

+ func (c Caps) String() string

+ type ChainSyncEvent struct

+ InSync bool

+ type DiscReason byte

+ const DiscBadPeer

+ const DiscBadProto

+ const DiscConnDup

+ const DiscGenesisErr

+ const DiscProtoErr

+ const DiscQuitting

+ const DiscReTcpSysErr

+ const DiscRequested

+ const DiscTooManyPeers

+ func (d DiscReason) String() string

+ type Ethereum struct

+ Addr net.Addr

+ MaxPeers int

+ Mining bool

+ Nonce uint64

+ Port string

+ RpcServer *rpc.JsonRpcServer

+ func New(db ethutil.Database, clientIdentity wire.ClientIdentity, ...) (*Ethereum, error)

+ func (s *Ethereum) AddPeer(conn net.Conn)

+ func (s *Ethereum) BlockManager() *core.BlockManager

+ func (s *Ethereum) BlockPool() *BlockPool

+ func (s *Ethereum) Broadcast(msgType wire.MsgType, data []interface{})

+ func (s *Ethereum) BroadcastMsg(msg *wire.Msg)

+ func (s *Ethereum) ChainManager() *core.ChainManager

+ func (s *Ethereum) ClientIdentity() wire.ClientIdentity

+ func (s *Ethereum) ConnectToPeer(addr string) error

+ func (s *Ethereum) EventMux() *event.TypeMux

+ func (s *Ethereum) HighestTDPeer() (td *big.Int)

+ func (s *Ethereum) InOutPeers() []*Peer

+ func (s *Ethereum) InboundPeers() []*Peer

+ func (s *Ethereum) IsListening() bool

+ func (s *Ethereum) IsMining() bool

+ func (s *Ethereum) IsUpToDate() bool

+ func (s *Ethereum) KeyManager() *crypto.KeyManager

+ func (s *Ethereum) OutboundPeers() []*Peer

+ func (s *Ethereum) PeerCount() int

+ func (s *Ethereum) Peers() *list.List

+ func (s *Ethereum) ProcessPeerList(addrs []string)

+ func (s *Ethereum) PushPeer(peer *Peer)

+ func (s *Ethereum) RemovePeer(p *Peer)

+ func (s *Ethereum) Seed()

+ func (s *Ethereum) ServerCaps() Caps

+ func (s *Ethereum) Start(seed bool)

+ func (s *Ethereum) Stop()

+ func (s *Ethereum) TxPool() *core.TxPool

+ func (s *Ethereum) WaitForShutdown()

+ func (self *Ethereum) BlacklistPeer(peer *Peer)

+ func (self *Ethereum) Db() ethutil.Database

+ func (self *Ethereum) GetFilter(id int) *core.Filter

+ func (self *Ethereum) InstallFilter(filter *core.Filter) (id int)

+ func (self *Ethereum) UninstallFilter(id int)

+ type NAT interface

+ AddPortMapping func(protocol string, externalPort, internalPort int, description string, ...) (mappedExternalPort int, err error)

+ DeletePortMapping func(protocol string, externalPort, internalPort int) (err error)

+ GetExternalAddress func() (addr net.IP, err error)

+ func Discover() (nat NAT, err error)

+ func NewNatPMP(gateway net.IP) (nat NAT)

+ type Peer struct

+ func NewOutboundPeer(addr string, ethereum *Ethereum, caps Caps) *Peer

+ func NewPeer(conn net.Conn, ethereum *Ethereum, inbound bool) *Peer

+ func (p *Peer) Connected() *int32

+ func (p *Peer) HandleInbound()

+ func (p *Peer) HandleOutbound()

+ func (p *Peer) Host() []byte

+ func (p *Peer) Inbound() bool

+ func (p *Peer) LastPong() int64

+ func (p *Peer) LastSend() time.Time

+ func (p *Peer) PingTime() string

+ func (p *Peer) Port() uint16

+ func (p *Peer) QueueMessage(msg *wire.Msg)

+ func (p *Peer) RlpData() []interface{}

+ func (p *Peer) SetVersion(version string)

+ func (p *Peer) Start()

+ func (p *Peer) Stop()

+ func (p *Peer) StopWithReason(reason DiscReason)

+ func (p *Peer) String() string

+ func (p *Peer) Version() string

+ func (self *Peer) Caps() *ethutil.Value

+ func (self *Peer) Connect(addr string) (conn net.Conn, err error)

+ func (self *Peer) FetchBlocks(hashes [][]byte)

+ func (self *Peer) FetchHashes() bool

+ func (self *Peer) FetchingHashes() bool

+ func (self *Peer) IsCap(cap string) bool

+ type PeerListEvent struct

+ Peers *list.List