fetcher

Documentation

Overview

Package fetcher contains the block announcement based synchronisation.

Index

• type Fetcher
  • func New(name string, getBlock blockRetrievalFn, verifyHeader headerVerifierFn, ...) *Fetcher
  • func (f *Fetcher) Enqueue(peer IPeer, block *types.Block) error
  • func (f *Fetcher) Notify(peer IPeer, hash common.Hash, number uint64, headerFetcher headerRequesterFn, ...)

Types

type Fetcher

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

Fetcher is responsible for accumulating block announcements from various peers and scheduling them for retrieval.

func New

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

New creates a block fetcher to retrieve blocks based on hash announcements.

func (*Fetcher) Enqueue

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

Notify announces the fetcher of the potential availability of a new block in the network.

func (*Fetcher) Notify

func (f *Fetcher) Notify(peer IPeer, hash common.Hash, number uint64,
	headerFetcher headerRequesterFn, bodyFetcher bodyRequesterFn)