Versions in this module Expand all Collapse all v1 v1.0.0 Sep 1, 2023 Changes in this version + const BlockchainChannel + const MetricsSubsystem + type BlockchainReactor struct + func NewBlockchainReactor(state state.State, blockApplier blockApplier, store blockStore, fastSync bool) *BlockchainReactor + func (r *BlockchainReactor) AddPeer(peer p2p.Peer) + func (r *BlockchainReactor) GetChannels() []*p2p.ChannelDescriptor + func (r *BlockchainReactor) Receive(chID byte, src p2p.Peer, msgBytes []byte) + func (r *BlockchainReactor) RemovePeer(peer p2p.Peer, reason interface{}) + func (r *BlockchainReactor) SetLogger(logger log.Logger) + func (r *BlockchainReactor) SetSwitch(sw *p2p.Switch) + func (r *BlockchainReactor) Start() error + func (r *BlockchainReactor) Stop() error + func (r *BlockchainReactor) SwitchToFastSync(state state.State) error + func (r *BlockchainReactor) SyncHeight() int64 + type Event queue.Item + type Metrics struct + ErrorsHandled metrics.Counter + ErrorsIn metrics.Counter + ErrorsOut metrics.Counter + ErrorsSent metrics.Counter + ErrorsShed metrics.Counter + EventsHandled metrics.Counter + EventsIn metrics.Counter + EventsOut metrics.Counter + EventsSent metrics.Counter + EventsShed metrics.Counter + func NopMetrics() *Metrics + func PrometheusMetrics(namespace string, labelsAndValues ...string) *Metrics + type PeerByID []p2p.ID + func (peers PeerByID) Len() int + func (peers PeerByID) Less(i, j int) bool + func (peers PeerByID) Swap(i, j int) + type Routine struct
Go to main page