Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

les

package

Go to main page

Versions in this module

v1

v1.0.3

Sep 9, 2024

v1.0.2

May 3, 2024

v1.0.1

Apr 30, 2024

Changes in this version

+ const AnnounceMsg

+ const BlockBodiesMsg

+ const BlockHeadersMsg

+ const CodeMsg

+ const ErrDecode

+ const ErrExtraStatusMsg

+ const ErrForkIDRejected

+ 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 GetHelperTrieProofsMsg

+ const GetProofsV2Msg

+ const GetReceiptsMsg

+ const GetTxStatusMsg

+ const HelperTrieProofsMsg

+ const MaxBodyFetch

+ const MaxCodeFetch

+ const MaxHeaderFetch

+ const MaxHelperTrieProofsFetch

+ const MaxProofsFetch

+ const MaxReceiptFetch

+ const MaxTxSend

+ const MaxTxStatus

+ const MsgBlockBodies

+ const MsgBlockHeaders

+ const MsgCode

+ const MsgHelperTrieProofs

+ const MsgProofsV2

+ const MsgReceipts

+ const MsgTxStatus

+ const NetworkId

+ const ProofsV2Msg

+ const ProtocolMaxMsgSize

+ const ReceiptsMsg

+ const ResumeMsg

+ const SendTxV2Msg

+ const StatusMsg

+ const StopMsg

+ const TxStatusMsg

+ var AdvertiseProtocolVersions = []uint

+ var ClientProtocolVersions = []uint

+ var Les3 = map[uint64]RequestType

+ var ProtocolLengths = map[uint]uint64

+ var ServerProtocolVersions = []uint

+ func NewFuzzerPeer(version int) (p *clientPeer, closer func())

+ type BlockRequest light.BlockRequest

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

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

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

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

+ type BloomReq struct

+ BitIdx uint64

+ BloomTrieNum uint64

+ FromLevel uint64

+ SectionIndex uint64

+ type BloomRequest light.BloomRequest

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

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

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

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

+ type ChtRequest light.ChtRequest

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

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

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

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

+ type CodeData []struct

+ type CodeReq struct

+ AccKey []byte

+ BHash common.Hash

+ type CodeRequest light.CodeRequest

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

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

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

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

+ type DebugAPI struct

+ func NewDebugAPI(server *LesServer) *DebugAPI

+ func (api *DebugAPI) FreezeClient(node string) error

+ type Decoder interface

+ Decode func(val interface{}) error

+ type GetBlockBodiesPacket struct

+ Hashes []common.Hash

+ ReqID uint64

+ type GetBlockHeadersData struct

+ Amount uint64

+ Origin hashOrNumber

+ Reverse bool

+ Skip uint64

+ type GetBlockHeadersPacket struct

+ Query GetBlockHeadersData

+ ReqID uint64

+ type GetCodePacket struct

+ ReqID uint64

+ Reqs []CodeReq

+ type GetHelperTrieProofsPacket struct

+ ReqID uint64

+ Reqs []HelperTrieReq

+ type GetProofsPacket struct

+ ReqID uint64

+ Reqs []ProofReq

+ type GetReceiptsPacket struct

+ Hashes []common.Hash

+ ReqID uint64

+ type GetTxStatusPacket struct

+ Hashes []common.Hash

+ ReqID uint64

+ 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) BlockByHash(ctx context.Context, hash common.Hash) (*types.Block, error)

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

+ func (b *LesApiBackend) BlockByNumberOrHash(ctx context.Context, blockNrOrHash rpc.BlockNumberOrHash) (*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.Header

+ func (b *LesApiBackend) CurrentHeader() *types.Header

+ func (b *LesApiBackend) Engine() consensus.Engine

+ func (b *LesApiBackend) ExtRPCEnabled() bool

+ func (b *LesApiBackend) FeeHistory(ctx context.Context, blockCount uint64, lastBlock rpc.BlockNumber, ...) (firstBlock *big.Int, reward [][]*big.Int, baseFee []*big.Int, ...)

+ func (b *LesApiBackend) GetBody(ctx context.Context, hash common.Hash, number rpc.BlockNumber) (*types.Body, 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, number uint64) ([][]*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(ctx context.Context, hash common.Hash) *big.Int

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

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

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

+ func (b *LesApiBackend) HeaderByNumberOrHash(ctx context.Context, blockNrOrHash rpc.BlockNumberOrHash) (*types.Header, error)

+ func (b *LesApiBackend) PendingBlockAndReceipts() (*types.Block, types.Receipts)

+ func (b *LesApiBackend) ProtocolVersion() int

+ func (b *LesApiBackend) RPCEVMTimeout() time.Duration

+ func (b *LesApiBackend) RPCGasCap() uint64

+ func (b *LesApiBackend) RPCTxFeeCap() float64

+ 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, number rpc.BlockNumber) (*state.StateDB, *types.Header, error)

+ func (b *LesApiBackend) StateAndHeaderByNumberOrHash(ctx context.Context, blockNrOrHash rpc.BlockNumberOrHash) (*state.StateDB, *types.Header, error)

+ func (b *LesApiBackend) StateAtBlock(ctx context.Context, block *types.Block, reexec uint64, base *state.StateDB, ...) (*state.StateDB, tracers.StateReleaseFunc, error)

+ func (b *LesApiBackend) StateAtTransaction(ctx context.Context, block *types.Block, txIndex int, reexec uint64) (*core.Message, vm.BlockContext, *state.StateDB, tracers.StateReleaseFunc, ...)

+ 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) SubscribePendingLogsEvent(ch chan<- []*types.Log) event.Subscription

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

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

+ func (b *LesApiBackend) SyncProgress() ethereum.SyncProgress

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

+ func (b *LesApiBackend) TxPoolContentFrom(addr common.Address) (types.Transactions, types.Transactions)

+ func (b *LesApiBackend) UnprotectedAllowed() bool

+ type LesOdr struct

+ func NewLesOdr(db ethdb.Database, config *light.IndexerConfig, peers *serverPeerSet, ...) *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) RetrieveTxStatus(ctx context.Context, req *light.TxStatusRequest) error

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

+ func (odr *LesOdr) Stop()

+ type LesOdrRequest interface

+ CanSend func(*serverPeer) bool

+ GetCost func(*serverPeer) uint64

+ Request func(uint64, *serverPeer) error

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

+ func LesRequest(req light.OdrRequest) LesOdrRequest

+ type LesServer struct

+ func NewLesServer(node *node.Node, e ethBackend, config *ethconfig.Config) (*LesServer, error)

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

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

+ func (s *LesServer) Start() error

+ func (s *LesServer) Stop() error

+ type LightAPI struct

+ func NewLightAPI(backend *lesCommons) *LightAPI

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

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

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

+ 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(stack *node.Node, config *ethconfig.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) Merger() *consensus.Merger

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

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

+ func (s *LightEthereum) Start() error

+ func (s *LightEthereum) Stop() error

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

+ func (s *LightEthereum) VfluxRequest(n *enode.Node, reqs vflux.Requests) vflux.Replies

+ type LightServerAPI struct

+ func NewLightServerAPI(server *LesServer) *LightServerAPI

+ func (api *LightServerAPI) AddBalance(node string, amount int64) (balance [2]uint64, err error)

+ func (api *LightServerAPI) Benchmark(setups []map[string]interface{}, passCount, length int) ([]map[string]interface{}, error)

+ func (api *LightServerAPI) ClientInfo(nodes []string) map[enode.ID]map[string]interface{}

+ func (api *LightServerAPI) PriorityClientInfo(start, stop enode.ID, maxCount int) map[enode.ID]map[string]interface{}

+ func (api *LightServerAPI) ServerInfo() map[string]interface{}

+ func (api *LightServerAPI) SetClientParams(nodes []string, params map[string]interface{}) error

+ func (api *LightServerAPI) SetConnectedBias(bias time.Duration) error

+ func (api *LightServerAPI) SetDefaultParams(params map[string]interface{}) error

+ type Msg struct

+ MsgType int

+ Obj interface{}

+ ReqID uint64

+ type NodeInfo struct

+ CHT params.TrustedCheckpoint

+ Config *params.ChainConfig

+ Difficulty *big.Int

+ Genesis common.Hash

+ Head common.Hash

+ Network uint64

+ type PeerInfo struct

+ Difficulty *big.Int

+ Head string

+ Version int

+ type ProofReq struct

+ AccKey []byte

+ BHash common.Hash

+ FromLevel uint

+ Key []byte

+ type ReceiptsRequest light.ReceiptsRequest

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

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

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

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

+ type RequestCostList []requestCostListItem

+ type RequestType struct

+ Handle func(msg Decoder) (serve serveRequestFn, reqID, amount uint64, err error)

+ InPacketsMeter metrics.Meter

+ InTrafficMeter metrics.Meter

+ MaxCount uint64

+ Name string

+ OutPacketsMeter metrics.Meter

+ OutTrafficMeter metrics.Meter

+ ServingTimeMeter metrics.Timer

+ type SendTxPacket struct

+ ReqID uint64

+ Txs []*types.Transaction

+ type TrieRequest light.TrieRequest

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

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

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

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

+ type TxStatusRequest light.TxStatusRequest

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

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

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

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