Versions in this module Expand all Collapse all v1 v1.0.0 May 26, 2022 Changes in this version + type Chain interface + BestBlockHeader func() *types.BlockHeader + BestBlockHeight func() uint64 + GetBlockByHash func(*bc.Hash) (*types.Block, error) + GetBlockByHeight func(uint64) (*types.Block, error) + GetHeaderByHash func(*bc.Hash) (*types.BlockHeader, error) + GetHeaderByHeight func(uint64) (*types.BlockHeader, error) + InMainChain func(bc.Hash) bool + LastJustifiedHeader func() (*types.BlockHeader, error) + ProcessBlock func(*types.Block) (bool, error) + ValidateTx func(*types.Tx) (bool, error) + type Fetcher interface + type LocalStore interface + type Manager struct + func NewManager(config *cfg.Config, sw Switch, chain Chain, mempool Mempool, ...) (*Manager, error) + func (m *Manager) AddPeer(peer peers.BasePeer) + func (m *Manager) IsCaughtUp() bool + func (m *Manager) RemovePeer(peerID string) + func (m *Manager) SendStatus(peer peers.BasePeer) error + func (m *Manager) Start() error + func (m *Manager) Stop() + type Mempool interface + GetTransactions func() []*core.TxDesc + IsDust func(tx *types.Tx) bool + type MsgFetcher interface + type ProtocolReactor struct + func NewProtocolReactor(manager *Manager) *ProtocolReactor + func (pr *ProtocolReactor) AddPeer(peer *p2p.Peer) error + func (pr *ProtocolReactor) GetChannels() []*connection.ChannelDescriptor + func (pr *ProtocolReactor) OnStart() error + func (pr *ProtocolReactor) OnStop() + func (pr *ProtocolReactor) Receive(chID byte, src *p2p.Peer, msgBytes []byte) + func (pr *ProtocolReactor) RemovePeer(peer *p2p.Peer, reason interface{}) + type Switch interface + AddReactor func(name string, reactor p2p.Reactor) p2p.Reactor + DialPeerWithAddress func(addr *p2p.NetAddress) error + IsListening func() bool + Peers func() *p2p.PeerSet + Start func() error + Stop func() error
Go to main page