Versions in this module Expand all Collapse all v0 v0.32.0 Sep 13, 2023 Changes in this version + const BlockchainChannel + func RegisterBlockchainMessages(cdc *amino.Codec) + type BlockPool struct + func NewBlockPool(start int64, requestsCh chan<- BlockRequest, errorsCh chan<- peerError) *BlockPool + func (pool *BlockPool) AddBlock(peerID p2p.ID, block *types.Block, blockSize int) + func (pool *BlockPool) GetStatus() (height int64, numPending int32, lenRequesters int) + func (pool *BlockPool) IsCaughtUp() bool + 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) p2p.ID + func (pool *BlockPool) RemovePeer(peerID p2p.ID) + func (pool *BlockPool) SetPeerRange(peerID p2p.ID, base int64, height int64) + type BlockRequest struct + Height int64 + PeerID p2p.ID + type BlockchainMessage interface + ValidateBasic func() error + type BlockchainReactor struct + func NewBlockchainReactor(state sm.State, blockExec *sm.BlockExecutor, store *store.BlockStore, ...) *BlockchainReactor + func (bcR *BlockchainReactor) AddPeer(peer p2p.Peer) + func (bcR *BlockchainReactor) BroadcastStatusRequest() error + func (bcR *BlockchainReactor) GetChannels() []*p2p.ChannelDescriptor + func (bcR *BlockchainReactor) OnStart() error + func (bcR *BlockchainReactor) OnStop() + func (bcR *BlockchainReactor) Receive(chID byte, src p2p.Peer, msgBytes []byte) + func (bcR *BlockchainReactor) RemovePeer(peer p2p.Peer, reason interface{}) + func (bcR *BlockchainReactor) SetLogger(l log.Logger)
Go to main page