Versions in this module Expand all Collapse all v1 v1.0.0 May 26, 2022 Changes in this version + type BlockProposeMsg struct + RawBlock []byte + func (bp *BlockProposeMsg) BroadcastFilterTargetPeers(ps *peers.PeerSet) []string + func (bp *BlockProposeMsg) BroadcastMarkSendRecord(ps *peers.PeerSet, peers []string) + func (bp *BlockProposeMsg) GetProposeBlock() (*types.Block, error) + func (bp *BlockProposeMsg) String() string + type BlockVerificationMsg struct + PubKey []byte + Signature []byte + SourceHash bc.Hash + TargetHash bc.Hash + func (b *BlockVerificationMsg) BroadcastFilterTargetPeers(ps *peers.PeerSet) []string + func (b *BlockVerificationMsg) BroadcastMarkSendRecord(ps *peers.PeerSet, peers []string) + func (b *BlockVerificationMsg) String() string + type BroadcastMsg struct + func NewBroadcastMsg(msg ConsensusMessage, transChan byte) *BroadcastMsg + func (b *BroadcastMsg) FilterTargetPeers(ps *peers.PeerSet) []string + func (b *BroadcastMsg) GetChan() byte + func (b *BroadcastMsg) GetMsg() interface{} + func (b *BroadcastMsg) MarkSendRecord(ps *peers.PeerSet, peers []string) + func (b *BroadcastMsg) MsgString() string + type Chain interface + BestBlockHeight func() uint64 + GetHeaderByHash func(*bc.Hash) (*types.BlockHeader, error) + ProcessBlock func(*types.Block) (bool, error) + ProcessBlockVerification func(*casper.ValidCasperSignMsg) error + type ConsensusMessage interface + BroadcastFilterTargetPeers func(ps *peers.PeerSet) []string + BroadcastMarkSendRecord func(ps *peers.PeerSet, peers []string) + String func() string + func NewBlockProposeMsg(block *types.Block) (ConsensusMessage, error) + func NewBlockVerificationMsg(sourceHash, targetHash bc.Hash, pubKey, signature []byte) ConsensusMessage + type ConsensusReactor struct + func NewConsensusReactor(manager *Manager) *ConsensusReactor + func (cr *ConsensusReactor) AddPeer(peer *p2p.Peer) error + func (cr *ConsensusReactor) GetChannels() []*connection.ChannelDescriptor + func (cr *ConsensusReactor) OnStart() error + func (cr *ConsensusReactor) OnStop() + func (cr *ConsensusReactor) Receive(chID byte, src *p2p.Peer, msgBytes []byte) + func (cr *ConsensusReactor) RemovePeer(peer *p2p.Peer, reason interface{}) + type Manager struct + func NewManager(sw Switch, chain Chain, peers Peers, dispatcher *event.Dispatcher) *Manager + func (m *Manager) Start() error + func (m *Manager) Stop() + type Peers interface + AddPeer func(peer peers.BasePeer) + BroadcastMsg func(bm peers.BroadcastMsg) error + GetPeer func(id string) *peers.Peer + MarkBlock func(peerID string, hash *bc.Hash) + MarkBlockVerification func(peerID string, signature []byte) + ProcessIllegal func(peerID string, level byte, reason string) + RemovePeer func(peerID string) + SetStatus func(peerID string, height uint64, hash *bc.Hash) + type Switch interface + AddReactor func(name string, reactor p2p.Reactor) p2p.Reactor
Go to main page