protocol

Jun 2, 2022

Changes in this version

+ const MaxSkeletonHeadersAmount

Jan 27, 2022

Changes in this version

+ var ErrCommonAncestorNotFound = errors.New("header is nil")

+ var ErrConnectionClosed = errors.New("connection closed")

+ var ErrForkNotFound = errors.New("fork not found")

+ var ErrLoadLocalGenesisFailed = errors.New("failed to read local genesis")

+ var ErrMismatchGenesis = errors.New("genesis does not match")

+ var ErrPopTimeout = errors.New("timeout")

+ func GenerateNewBlocks(t *testing.T, chain blockchainShim, num int) []*types.Block

+ func NewMockBlockchain(headers []*types.Header) *mockBlockchain

+ func NewMockSubscription() *mockSubscription

+ func NewRandomChain(t *testing.T, height int) blockchainShim

+ func SetupSyncerNetwork(t *testing.T, chain blockchainShim, peerChains []blockchainShim) (syncer *Syncer, peerSyncers []*Syncer)

+ func TryPopBlock(t *testing.T, syncer *Syncer, peerID peer.ID, timeout time.Duration) (*types.Block, bool)

+ func WaitUntilPeerConnected(t *testing.T, syncer *Syncer, numPeer int, timeout time.Duration)

+ func WaitUntilProcessedAllEvents(t *testing.T, syncer *Syncer, timeout time.Duration)

+ func WaitUntilProgressionUpdated(t *testing.T, syncer *Syncer, timeout time.Duration, target uint64)

+ type Status struct

+ Difficulty *big.Int

+ Hash types.Hash

+ Number uint64

+ func GetCurrentStatus(b blockchainShim) *Status

+ func HeaderToStatus(h *types.Header) *Status

+ func (s *Status) Copy() *Status

+ type SyncPeer struct

+ func (s *SyncPeer) IsClosed() bool

+ func (s *SyncPeer) Number() uint64

+ type Syncer struct

+ func CreateSyncer(t *testing.T, blockchain blockchainShim, serverCfg *func(c *network.Config)) *Syncer

+ func NewSyncer(logger hclog.Logger, server *network.Server, blockchain blockchainShim) *Syncer

+ func (s *Syncer) AddPeer(peerID peer.ID) error

+ func (s *Syncer) BestPeer() *SyncPeer

+ func (s *Syncer) Broadcast(b *types.Block)

+ func (s *Syncer) BulkSyncWithPeer(p *SyncPeer, newBlockHandler func(block *types.Block)) error

+ func (s *Syncer) DeletePeer(peerID peer.ID) error

+ func (s *Syncer) GetSyncProgression() *progress.Progression

+ func (s *Syncer) Start()

+ func (s *Syncer) WatchSyncWithPeer(p *SyncPeer, handler func(b *types.Block) bool)