Documentation
¶
Index ¶
- Constants
- type BlockchainReactor
- func (r *BlockchainReactor) AddPeer(peer p2p.Peer)
- func (r *BlockchainReactor) GetChannels() []*p2p.ChannelDescriptor
- func (r *BlockchainReactor) Receive(chID byte, peer p2p.Peer, msgBytes []byte)
- func (r *BlockchainReactor) ReceiveEnvelope(e p2p.Envelope)
- 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
- type Metrics
- type PeerByID
- type Routine
Constants ¶
const ( // BlockchainChannel is a channel for blocks and status updates (`BlockStore` height) BlockchainChannel = byte(0x40) )
const ( // MetricsSubsystem is a subsystem shared by all metrics exposed by this // package. MetricsSubsystem = "blockchain" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BlockchainReactor ¶ added in v0.33.2
type BlockchainReactor struct {
p2p.BaseReactor
// contains filtered or unexported fields
}
BlockchainReactor handles fast sync protocol.
func NewBlockchainReactor ¶ added in v0.33.2
func NewBlockchainReactor( state state.State, blockApplier blockApplier, store blockStore, fastSync bool) *BlockchainReactor
NewBlockchainReactor creates a new reactor instance.
func (*BlockchainReactor) AddPeer ¶ added in v0.33.2
func (r *BlockchainReactor) AddPeer(peer p2p.Peer)
AddPeer implements Reactor interface
func (*BlockchainReactor) GetChannels ¶ added in v0.33.2
func (r *BlockchainReactor) GetChannels() []*p2p.ChannelDescriptor
GetChannels implements Reactor
func (*BlockchainReactor) Receive ¶ added in v0.33.2
func (r *BlockchainReactor) Receive(chID byte, peer p2p.Peer, msgBytes []byte)
func (*BlockchainReactor) ReceiveEnvelope ¶ added in v0.34.23
func (r *BlockchainReactor) ReceiveEnvelope(e p2p.Envelope)
Receive implements Reactor by handling different message types.
func (*BlockchainReactor) RemovePeer ¶ added in v0.33.2
func (r *BlockchainReactor) RemovePeer(peer p2p.Peer, reason interface{})
RemovePeer implements Reactor interface.
func (*BlockchainReactor) SetLogger ¶ added in v0.33.2
func (r *BlockchainReactor) SetLogger(logger log.Logger)
SetLogger sets the logger of the reactor.
func (*BlockchainReactor) SetSwitch ¶ added in v0.33.2
func (r *BlockchainReactor) SetSwitch(sw *p2p.Switch)
SetSwitch implements Reactor interface.
func (*BlockchainReactor) Start ¶ added in v0.33.2
func (r *BlockchainReactor) Start() error
Start implements cmn.Service interface
func (*BlockchainReactor) Stop ¶ added in v0.33.2
func (r *BlockchainReactor) Stop() error
Stop implements cmn.Service interface.
func (*BlockchainReactor) SwitchToFastSync ¶ added in v0.34.0
func (r *BlockchainReactor) SwitchToFastSync(state state.State) error
SwitchToFastSync is called by the state sync reactor when switching to fast sync.
func (*BlockchainReactor) SyncHeight ¶ added in v0.33.2
func (r *BlockchainReactor) SyncHeight() int64
SyncHeight returns the height to which the BlockchainReactor has synced.
type Metrics ¶ added in v0.32.4
type Metrics struct {
// events_in
EventsIn metrics.Counter
// events_in
EventsHandled metrics.Counter
// events_out
EventsOut metrics.Counter
// errors_in
ErrorsIn metrics.Counter
// errors_handled
ErrorsHandled metrics.Counter
// errors_out
ErrorsOut metrics.Counter
// events_shed
EventsShed metrics.Counter
// events_sent
EventsSent metrics.Counter
// errors_sent
ErrorsSent metrics.Counter
// errors_shed
ErrorsShed metrics.Counter
}
Metrics contains metrics exposed by this package.
func PrometheusMetrics ¶ added in v0.32.4
PrometheusMetrics returns metrics for in and out events, errors, etc. handled by routines. Can we burn in the routine name here?
type Routine ¶ added in v0.32.4
type Routine struct {
// contains filtered or unexported fields
}
Routine is a structure that models a finite state machine as serialized stream of events processed by a handle function. This Routine structure handles the concurrency and messaging guarantees. Events are sent via `send` are handled by the `handle` function to produce an iterator `next()`. Calling `stop()` on a routine will conclude processing of all sent events and produce `final()` event representing the terminal state.
Source Files