Versions in this module Expand all Collapse all v0 v0.8.14 Sep 15, 2021 Changes in this version + const BlockchainChannel + var ChannelShims = map[p2p.ChannelID]*p2p.ChannelDescriptorShim + type BlockPool struct + func NewBlockPool(start int64, requestsCh chan<- BlockRequest, errorsCh chan<- peerError) *BlockPool + func (pool *BlockPool) AddBlock(peerID types.NodeID, block *types.Block, blockSize int) + func (pool *BlockPool) GetStatus() (height int64, numPending int32, lenRequesters int) + func (pool *BlockPool) IsCaughtUp() bool + func (pool *BlockPool) LastAdvance() time.Time + func (pool *BlockPool) MaxPeerHeight() int64 + func (pool *BlockPool) OnStart() error + func (pool *BlockPool) PeekTwoBlocks() (first *types.Block, second *types.Block) + func (pool *BlockPool) PopRequest() + func (pool *BlockPool) RedoRequest(height int64) types.NodeID + func (pool *BlockPool) RemovePeer(peerID types.NodeID) + func (pool *BlockPool) SetPeerRange(peerID types.NodeID, base int64, height int64) + type BlockRequest struct + Height int64 + PeerID types.NodeID + type Reactor struct + func NewReactor(logger log.Logger, state sm.State, blockExec *sm.BlockExecutor, ...) (*Reactor, error) + func (r *Reactor) GetMaxPeerBlockHeight() int64 + func (r *Reactor) GetRemainingSyncTime() time.Duration + func (r *Reactor) GetTotalSyncedTime() time.Duration + func (r *Reactor) OnStart() error + func (r *Reactor) OnStop() + func (r *Reactor) SwitchToFastSync(state sm.State) error