Versions in this module Expand all Collapse all v1 v1.0.1 Jul 9, 2024 Changes in this version + type BlockFetcher struct + func NewBlockFetcher(light bool, getHeader HeaderRetrievalFn, getBlock blockRetrievalFn, ...) *BlockFetcher + func (f *BlockFetcher) Enqueue(peer string, block *types.Block) error + func (f *BlockFetcher) FilterBodies(peer string, transactions [][]*types.Transaction, uncles [][]*types.Header, ...) ([][]*types.Transaction, [][]*types.Header) + func (f *BlockFetcher) FilterHeaders(peer string, headers []*types.Header, time time.Time) []*types.Header + func (f *BlockFetcher) Notify(peer string, hash common.Hash, number uint64, time time.Time, ...) error + func (f *BlockFetcher) Start() + func (f *BlockFetcher) Stop() + type HeaderRetrievalFn func(common.Hash) *types.Header + type TxFetcher struct + func NewTxFetcher(hasTx func(common.Hash) bool, addTxs func([]*types.Transaction) []error, ...) *TxFetcher + func NewTxFetcherForTests(hasTx func(common.Hash) bool, addTxs func([]*types.Transaction) []error, ...) *TxFetcher + func (f *TxFetcher) Drop(peer string) error + func (f *TxFetcher) Enqueue(peer string, txs []*types.Transaction, direct bool) error + func (f *TxFetcher) Notify(peer string, types []byte, sizes []uint32, hashes []common.Hash) error + func (f *TxFetcher) Start() + func (f *TxFetcher) Stop()
Go to main page