Documentation ¶
Index ¶
- Constants
- type Reactor
- func (r *Reactor) AddPeer(peer p2p.Peer)
- func (r *Reactor) GetChannels() []*conn.ChannelDescriptor
- func (r *Reactor) InitPeer(peer p2p.Peer) p2p.Peer
- func (r *Reactor) OnNewTx(tx types.Tx)
- func (r *Reactor) Receive(chID byte, peer p2p.Peer, msgBytes []byte)
- func (r *Reactor) RemovePeer(peer p2p.Peer, reason interface{})
- func (r *Reactor) WithLogger(logger log.Logger) *Reactor
Constants ¶
View Source
const (
WendyChannel = byte(0x99)
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Reactor ¶
type Reactor struct { p2p.BaseReactor // contains filtered or unexported fields }
func NewReactor ¶
func (*Reactor) GetChannels ¶
func (r *Reactor) GetChannels() []*conn.ChannelDescriptor
func (*Reactor) OnNewTx ¶
OnNewTx is a handler for a new incoming Tx. Since it is designed to react upon new Tx on the mempool, the signature satisfies the mempool.NotifyFunc.
func (*Reactor) RemovePeer ¶
Click to show internal directories.
Click to hide internal directories.