fetcher

Mar 20, 2020

Changes in this version

+ 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, hashes []common.Hash) error

+ func (f *TxFetcher) Start()

+ func (f *TxFetcher) Stop()

Jun 26, 2019

Changes in this version

+ type Fetcher struct

+ func New(getBlock blockRetrievalFn, verifyHeader headerVerifierFn, ...) *Fetcher

+ func (f *Fetcher) Enqueue(peer string, block *types.Block) error

+ func (f *Fetcher) FilterBodies(peer string, transactions [][]*types.Transaction, uncles [][]*types.Header, ...) ([][]*types.Transaction, [][]*types.Header)

+ func (f *Fetcher) FilterHeaders(peer string, headers []*types.Header, time time.Time) []*types.Header

+ func (f *Fetcher) Notify(peer string, hash common.Hash, number uint64, time time.Time, ...) error

+ func (f *Fetcher) Start()

+ func (f *Fetcher) Stop()