synchro

Documentation

Index

• Constants
• type BlockHash
• type Sync
  • func New(p p2p.Service, bCache blockcache.BlockCache, bChain block.Chain) *Sync
  • func (s *Sync) BroadcastBlockInfo(block *block.Block)
  • func (s *Sync) Close()
  • func (s *Sync) IncomingBlock() <-chan *block.Block
  • func (s *Sync) IsCatchingUp() bool

Constants

const (
	BlockHashLeastNeighborNumber = 2
	BlockHashExpiredSeconds      = 60
	BlockHashMaxRequestRange     = 100
)

Constant of blockhash sync

Types

type BlockHash

type BlockHash struct {
	Hash   []byte
	Number int64
	PeerID []p2p.PeerID
}

BlockHash return the block hash with the Peers that have it.

type Sync

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

Sync is the synchronizer of blockchain. It includes requestHandler, heightSync, blockhashSync, blockSync.

func New

func New(p p2p.Service, bCache blockcache.BlockCache, bChain block.Chain) *Sync

New will return a new synchronizer of blockchain.

func (*Sync) BroadcastBlockInfo

func (s *Sync) BroadcastBlockInfo(block *block.Block)

BroadcastBlockInfo will broadcast new block information to neighbor nodes.

func (*Sync) Close

func (s *Sync) Close()

Close will close the synchronizer of blockchain.

func (*Sync) IncomingBlock

func (s *Sync) IncomingBlock() <-chan *block.Block

IncomingBlock will return the blocks from other nodes. Including passive request and active broadcast.

func (*Sync) IsCatchingUp

func (s *Sync) IsCatchingUp() bool

IsCatchingUp will return whether it is catching up with other nodes.