Versions in this module Expand all Collapse all v0 v0.1.2 Dec 17, 2020 v0.1.1 Dec 17, 2020 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) SetPeerHeight(peerID p2p.ID, height int64) + type BlockRequest struct + Height int64 + PeerID p2p.ID + type BlockStore struct + func NewBlockStore(db dbm.DB) *BlockStore + func (bs *BlockStore) Height() int64 + func (bs *BlockStore) LoadBlock(height int64) *types.Block + func (bs *BlockStore) LoadBlockCommit(height int64) *types.Commit + func (bs *BlockStore) LoadBlockMeta(height int64) *types.BlockMeta + func (bs *BlockStore) LoadBlockPart(height int64, index int) *types.Part + func (bs *BlockStore) LoadSeenCommit(height int64) *types.Commit + func (bs *BlockStore) SaveBlock(block *types.Block, blockParts *types.PartSet, seenCommit *types.Commit) + type BlockStoreStateJSON struct + Height int64 + func LoadBlockStoreStateJSON(db dbm.DB) BlockStoreStateJSON + func (bsj BlockStoreStateJSON) Save(db dbm.DB) + type BlockchainMessage interface + ValidateBasic func() error + type BlockchainReactor struct + func NewBlockchainReactor(state sm.State, blockExec *sm.BlockExecutor, store *BlockStore, fastSync bool) *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)