fetcher

Documentation

Index

• type Fetcher
  • 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()

Types

type Fetcher

type Fetcher struct {
	// contains filtered or unexported fields
}

func New

func New(getBlock blockRetrievalFn, verifyHeader headerVerifierFn, broadcastBlock blockBroadcasterFn, chainHeight chainHeightFn, insertChain chainInsertFn, dropPeer peerDropFn) *Fetcher

func (*Fetcher) Enqueue

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

func (*Fetcher) FilterBodies

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

func (*Fetcher) FilterHeaders

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

func (*Fetcher) Notify

func (f *Fetcher) Notify(peer string, hash common.Hash, number uint64, time time.Time,
	headerFetcher headerRequesterFn, bodyFetcher bodyRequesterFn) error

func (*Fetcher) Start

func (f *Fetcher) Start()

func (*Fetcher) Stop

func (f *Fetcher) Stop()