les

package

Go to main page

Versions in this module

v1

v1.7.2

Oct 14, 2017

v1.7.0

Sep 14, 2017

Changes in this version

type LesApiBackend

+ func (b *LesApiBackend) SubscribeTxPreEvent(ch chan<- core.TxPreEvent) event.Subscription

v1.6.7

Jul 11, 2017

v1.6.6

Jun 23, 2017

v1.6.5

Jun 1, 2017

v1.6.4

Jun 1, 2017

v1.6.3

Jun 1, 2017

v1.6.2

May 31, 2017

v1.6.1

May 4, 2017

v1.6.0

Apr 14, 2017

Changes in this version

+ var ErrNoPeers = errors.New("no suitable peers available")

v1.5.9

Feb 13, 2017

v1.5.8

Feb 1, 2017

v1.5.7

Jan 16, 2017

v1.5.6

Jan 9, 2017

v1.5.5

Dec 14, 2016

Changes in this version

type LesServer

+ func (s *LesServer) Synced()

v1.5.4

Nov 28, 2016

v1.5.3

Nov 24, 2016

v1.5.2

Nov 18, 2016

v1.5.1

Nov 16, 2016

v1.5.0

Nov 15, 2016

Changes in this version

+ const ErrHandshakeMissingKey

+ const GetProofsMsg

+ const MaxHeaderProofsFetch

+ const MsgProofs

+ const ProofsMsg

+ var ProtocolVersions = []uint

type BlockChain

+ GetBlockHashesFromHash func(hash common.Hash, max uint64) []common.Hash

+ GetTdByHash func(hash common.Hash) *big.Int

+ LastBlockHash func() common.Hash

+ Status func() (td *big.Int, currentBlock common.Hash, genesisBlock common.Hash)

type BlockRequest

+ func (self *BlockRequest) Valid(db ethdb.Database, msg *Msg) bool

type ChtRequest

+ func (self *ChtRequest) Valid(db ethdb.Database, msg *Msg) bool

type CodeRequest

+ func (self *CodeRequest) Valid(db ethdb.Database, msg *Msg) bool

type LesApiBackend

+ func (b *LesApiBackend) GetVMEnv(ctx context.Context, msg core.Message, state ethapi.State, ...) (vm.Environment, func() error, error)

type LesOdr

+ func (self *LesOdr) Deliver(peer *peer, msg *Msg) error

+ func (self *LesOdr) RegisterPeer(p *peer) error

+ func (self *LesOdr) UnregisterPeer(p *peer)

type LesOdrRequest

+ Valid func(ethdb.Database, *Msg) bool

type LightEthereum

+ NatSpec bool

+ PowTest bool

type ProtocolManager

+ SubProtocols []p2p.Protocol

+ func (self *ProtocolManager) NodeInfo() *eth.EthNodeInfo

type ReceiptsRequest

+ func (self *ReceiptsRequest) Valid(db ethdb.Database, msg *Msg) bool

type TrieRequest

+ func (self *TrieRequest) Valid(db ethdb.Database, msg *Msg) bool

v0

v0.3.1

Jul 28, 2020

v0.3.0

Sep 10, 2019

v0.2.0

Jul 20, 2019

Changes in this version

+ const MsgTxStatus

+ const ResumeMsg

+ const StopMsg

type BlockChain

+ StateCache func() state.Database

type BloomReq

+ SectionIndex uint64

type LesApiBackend

+ func (b *LesApiBackend) ExtRPCEnabled() bool

+ func (b *LesApiBackend) GetTransaction(ctx context.Context, txHash common.Hash) (*types.Transaction, common.Hash, uint64, uint64, error)

+ func (b *LesApiBackend) RPCGasCap() *big.Int

type LesServer

+ func (s *LesServer) APIs() []rpc.API

+ func (s *LesServer) SetContractBackend(backend bind.ContractBackend)

type LightEthereum

+ func (s *LightEthereum) SetContractBackend(backend bind.ContractBackend)

+ type PrivateLightAPI struct

+ func NewPrivateLightAPI(backend *lesCommons, reg *checkpointOracle) *PrivateLightAPI

+ func (api *PrivateLightAPI) GetCheckpoint(index uint64) ([3]string, error)

+ func (api *PrivateLightAPI) GetCheckpointContractAddress() (string, error)

+ func (api *PrivateLightAPI) LatestCheckpoint() ([4]string, error)

+ type TxStatusRequest light.TxStatusRequest

+ func (r *TxStatusRequest) CanSend(peer *peer) bool

+ func (r *TxStatusRequest) GetCost(peer *peer) uint64

+ func (r *TxStatusRequest) Request(reqID uint64, peer *peer) error

+ func (r *TxStatusRequest) Validate(db ethdb.Database, msg *Msg) error

v0.1.0

Feb 16, 2019

Changes in this version

+ const AnnounceMsg

+ const BlockBodiesMsg

+ const BlockHeadersMsg

+ const CodeMsg

+ const ErrDecode

+ const ErrExtraStatusMsg

+ const ErrGenesisBlockMismatch

+ const ErrInvalidMsgCode

+ const ErrInvalidResponse

+ const ErrMissingKey

+ const ErrMsgTooLarge

+ const ErrNetworkIdMismatch

+ const ErrNoStatusMsg

+ const ErrProtocolVersionMismatch

+ const ErrRequestRejected

+ const ErrSuspendedPeer

+ const ErrTooManyTimeouts

+ const ErrUnexpectedResponse

+ const ErrUselessPeer

+ const GetBlockBodiesMsg

+ const GetBlockHeadersMsg

+ const GetCodeMsg

+ const GetHeaderProofsMsg

+ const GetHelperTrieProofsMsg

+ const GetProofsV1Msg

+ const GetProofsV2Msg

+ const GetReceiptsMsg

+ const GetTxStatusMsg

+ const HeaderProofsMsg

+ const HelperTrieProofsMsg

+ const MaxBodyFetch

+ const MaxCodeFetch

+ const MaxHeaderFetch

+ const MaxHelperTrieProofsFetch

+ const MaxProofsFetch

+ const MaxReceiptFetch

+ const MaxTxSend

+ const MaxTxStatus

+ const MsgBlockBodies

+ const MsgCode

+ const MsgHeaderProofs

+ const MsgHelperTrieProofs

+ const MsgProofsV1

+ const MsgProofsV2

+ const MsgReceipts

+ const NetworkId

+ const ProofsV1Msg

+ const ProofsV2Msg

+ const ProtocolMaxMsgSize

+ const ReceiptsMsg

+ const SendTxMsg

+ const SendTxV2Msg

+ const StatusMsg

+ const TxStatusMsg

+ var AdvertiseProtocolVersions = []uint

+ var ClientProtocolVersions = []uint

+ var ProtocolLengths = map[uint]uint64

+ var ServerProtocolVersions = []uint

+ type BlockChain interface

+ Config func() *params.ChainConfig

+ CurrentHeader func() *types.Header

+ Genesis func() *types.Block

+ GetAncestor func(hash common.Hash, number, ancestor uint64, maxNonCanonical *uint64) (common.Hash, uint64)

+ GetHeader func(hash common.Hash, number uint64) *types.Header

+ GetHeaderByHash func(hash common.Hash) *types.Header

+ GetHeaderByNumber func(number uint64) *types.Header

+ GetTd func(hash common.Hash, number uint64) *big.Int

+ HasHeader func(hash common.Hash, number uint64) bool

+ InsertHeaderChain func(chain []*types.Header, checkFreq int) (int, error)

+ Rollback func(chain []common.Hash)

+ State func() (*state.StateDB, error)

+ SubscribeChainHeadEvent func(ch chan<- core.ChainHeadEvent) event.Subscription

+ type BlockRequest light.BlockRequest

+ func (r *BlockRequest) CanSend(peer *peer) bool

+ func (r *BlockRequest) GetCost(peer *peer) uint64

+ func (r *BlockRequest) Request(reqID uint64, peer *peer) error

+ func (r *BlockRequest) Validate(db ethdb.Database, msg *Msg) error

+ type BloomReq struct

+ BitIdx uint64

+ BloomTrieNum uint64

+ FromLevel uint64

+ SectionIdx uint64

+ type BloomRequest light.BloomRequest

+ func (r *BloomRequest) CanSend(peer *peer) bool

+ func (r *BloomRequest) GetCost(peer *peer) uint64

+ func (r *BloomRequest) Request(reqID uint64, peer *peer) error

+ func (r *BloomRequest) Validate(db ethdb.Database, msg *Msg) error

+ type ChtReq struct

+ BlockNum uint64

+ ChtNum uint64

+ FromLevel uint

+ type ChtRequest light.ChtRequest

+ func (r *ChtRequest) CanSend(peer *peer) bool

+ func (r *ChtRequest) GetCost(peer *peer) uint64

+ func (r *ChtRequest) Request(reqID uint64, peer *peer) error

+ func (r *ChtRequest) Validate(db ethdb.Database, msg *Msg) error

+ type ChtResp struct

+ Header *types.Header

+ Proof []rlp.RawValue

+ type CodeData []struct

+ type CodeReq struct

+ AccKey []byte

+ BHash common.Hash

+ type CodeRequest light.CodeRequest

+ func (r *CodeRequest) CanSend(peer *peer) bool

+ func (r *CodeRequest) GetCost(peer *peer) uint64

+ func (r *CodeRequest) Request(reqID uint64, peer *peer) error

+ func (r *CodeRequest) Validate(db ethdb.Database, msg *Msg) error

+ type HelperTrieReq struct

+ AuxReq uint

+ FromLevel uint

+ Key []byte

+ TrieIdx uint64

+ Type uint

+ type HelperTrieResps struct

+ AuxData [][]byte

+ Proofs light.NodeList

+ type LesApiBackend struct

+ func (b *LesApiBackend) AccountManager() *accounts.Manager

+ func (b *LesApiBackend) BlockByNumber(ctx context.Context, blockNr rpc.BlockNumber) (*types.Block, error)

+ func (b *LesApiBackend) BloomStatus() (uint64, uint64)

+ func (b *LesApiBackend) ChainConfig() *params.ChainConfig

+ func (b *LesApiBackend) ChainDb() ethdb.Database

+ func (b *LesApiBackend) CurrentBlock() *types.Block

+ func (b *LesApiBackend) Downloader() *downloader.Downloader

+ func (b *LesApiBackend) EventMux() *event.TypeMux

+ func (b *LesApiBackend) GetBlock(ctx context.Context, blockHash common.Hash) (*types.Block, error)

+ func (b *LesApiBackend) GetEVM(ctx context.Context, msg core.Message, state *state.StateDB, ...) (*vm.EVM, func() error, error)

+ func (b *LesApiBackend) GetLogs(ctx context.Context, hash common.Hash) ([][]*types.Log, error)

+ func (b *LesApiBackend) GetPoolNonce(ctx context.Context, addr common.Address) (uint64, error)

+ func (b *LesApiBackend) GetPoolTransaction(txHash common.Hash) *types.Transaction

+ func (b *LesApiBackend) GetPoolTransactions() (types.Transactions, error)

+ func (b *LesApiBackend) GetReceipts(ctx context.Context, hash common.Hash) (types.Receipts, error)

+ func (b *LesApiBackend) GetTd(hash common.Hash) *big.Int

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

+ func (b *LesApiBackend) HeaderByNumber(ctx context.Context, blockNr rpc.BlockNumber) (*types.Header, error)

+ func (b *LesApiBackend) ProtocolVersion() int

+ func (b *LesApiBackend) RemoveTx(txHash common.Hash)

+ func (b *LesApiBackend) SendTx(ctx context.Context, signedTx *types.Transaction) error

+ func (b *LesApiBackend) ServiceFilter(ctx context.Context, session *bloombits.MatcherSession)

+ func (b *LesApiBackend) SetHead(number uint64)

+ func (b *LesApiBackend) StateAndHeaderByNumber(ctx context.Context, blockNr rpc.BlockNumber) (*state.StateDB, *types.Header, error)

+ func (b *LesApiBackend) Stats() (pending int, queued int)

+ func (b *LesApiBackend) SubscribeChainEvent(ch chan<- core.ChainEvent) event.Subscription

+ func (b *LesApiBackend) SubscribeChainHeadEvent(ch chan<- core.ChainHeadEvent) event.Subscription

+ func (b *LesApiBackend) SubscribeChainSideEvent(ch chan<- core.ChainSideEvent) event.Subscription

+ func (b *LesApiBackend) SubscribeLogsEvent(ch chan<- []*types.Log) event.Subscription

+ func (b *LesApiBackend) SubscribeNewTxsEvent(ch chan<- core.NewTxsEvent) event.Subscription

+ func (b *LesApiBackend) SubscribeRemovedLogsEvent(ch chan<- core.RemovedLogsEvent) event.Subscription

+ func (b *LesApiBackend) SuggestPrice(ctx context.Context) (*big.Int, error)

+ func (b *LesApiBackend) TxPoolContent() (map[common.Address]types.Transactions, map[common.Address]types.Transactions)

+ type LesOdr struct

+ func NewLesOdr(db ethdb.Database, config *light.IndexerConfig, retriever *retrieveManager) *LesOdr

+ func (odr *LesOdr) BloomIndexer() *core.ChainIndexer

+ func (odr *LesOdr) BloomTrieIndexer() *core.ChainIndexer

+ func (odr *LesOdr) ChtIndexer() *core.ChainIndexer

+ func (odr *LesOdr) Database() ethdb.Database

+ func (odr *LesOdr) IndexerConfig() *light.IndexerConfig

+ func (odr *LesOdr) Retrieve(ctx context.Context, req light.OdrRequest) (err error)

+ func (odr *LesOdr) SetIndexers(chtIndexer, bloomTrieIndexer, bloomIndexer *core.ChainIndexer)

+ func (odr *LesOdr) Stop()

+ type LesOdrRequest interface

+ CanSend func(*peer) bool

+ GetCost func(*peer) uint64

+ Request func(uint64, *peer) error

+ Validate func(ethdb.Database, *Msg) error

+ func LesRequest(req light.OdrRequest) LesOdrRequest

+ type LesServer struct

+ func NewLesServer(eth *eth.Ethereum, config *eth.Config) (*LesServer, error)

+ func (s *LesServer) Protocols() []p2p.Protocol

+ func (s *LesServer) SetBloomBitsIndexer(bloomIndexer *core.ChainIndexer)

+ func (s *LesServer) Start(srvr *p2p.Server)

+ func (s *LesServer) Stop()

+ type LesTxRelay struct

+ func NewLesTxRelay(ps *peerSet, reqDist *requestDistributor) *LesTxRelay

+ func (self *LesTxRelay) Discard(hashes []common.Hash)

+ func (self *LesTxRelay) NewHead(head common.Hash, mined []common.Hash, rollback []common.Hash)

+ func (self *LesTxRelay) Send(txs types.Transactions)

+ type LightDummyAPI struct

+ func (s *LightDummyAPI) Coinbase() (common.Address, error)

+ func (s *LightDummyAPI) Etherbase() (common.Address, error)

+ func (s *LightDummyAPI) Hashrate() hexutil.Uint

+ func (s *LightDummyAPI) Mining() bool

+ type LightEthereum struct

+ ApiBackend *LesApiBackend

+ func New(ctx *node.ServiceContext, config *eth.Config) (*LightEthereum, error)

+ func (s *LightEthereum) APIs() []rpc.API

+ func (s *LightEthereum) BlockChain() *light.LightChain

+ func (s *LightEthereum) Downloader() *downloader.Downloader

+ func (s *LightEthereum) Engine() consensus.Engine

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

+ func (s *LightEthereum) LesVersion() int

+ func (s *LightEthereum) Protocols() []p2p.Protocol

+ func (s *LightEthereum) ResetWithGenesisBlock(gb *types.Block)

+ func (s *LightEthereum) Start(srvr *p2p.Server) error

+ func (s *LightEthereum) Stop() error

+ func (s *LightEthereum) TxPool() *light.TxPool

+ type Msg struct

+ MsgType int

+ Obj interface{}

+ ReqID uint64

+ type NodeInfo struct

+ CHT light.TrustedCheckpoint

+ Config *params.ChainConfig

+ Difficulty *big.Int

+ Genesis common.Hash

+ Head common.Hash

+ Network uint64

+ type ProofReq struct

+ AccKey []byte

+ BHash common.Hash

+ FromLevel uint

+ Key []byte

+ type ProtocolManager struct

+ func NewProtocolManager(chainConfig *params.ChainConfig, indexerConfig *light.IndexerConfig, ...) (*ProtocolManager, error)

+ func (pm *ProtocolManager) Start(maxPeers int)

+ func (pm *ProtocolManager) Stop()

+ type ReceiptsRequest light.ReceiptsRequest

+ func (r *ReceiptsRequest) CanSend(peer *peer) bool

+ func (r *ReceiptsRequest) GetCost(peer *peer) uint64

+ func (r *ReceiptsRequest) Request(reqID uint64, peer *peer) error

+ func (r *ReceiptsRequest) Validate(db ethdb.Database, msg *Msg) error

+ type RequestCostList []struct

+ type TrieRequest light.TrieRequest

+ func (r *TrieRequest) CanSend(peer *peer) bool

+ func (r *TrieRequest) GetCost(peer *peer) uint64

+ func (r *TrieRequest) Request(reqID uint64, peer *peer) error

+ func (r *TrieRequest) Validate(db ethdb.Database, msg *Msg) error

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