wendy

Documentation

Index

• Constants
• type Reactor
  • func NewReactor(id p2p.ID) *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

const (
	WendyChannel = byte(0x99)
)

Types

type Reactor

type Reactor struct {
	p2p.BaseReactor
	// contains filtered or unexported fields
}

func NewReactor

func NewReactor(id p2p.ID) *Reactor

func (*Reactor) AddPeer

func (r *Reactor) AddPeer(peer p2p.Peer)

func (*Reactor) GetChannels

func (r *Reactor) GetChannels() []*conn.ChannelDescriptor

func (*Reactor) InitPeer

func (r *Reactor) InitPeer(peer p2p.Peer) p2p.Peer

func (*Reactor) OnNewTx

func (r *Reactor) OnNewTx(tx types.Tx)

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) Receive

func (r *Reactor) Receive(chID byte, peer p2p.Peer, msgBytes []byte)

func (*Reactor) RemovePeer

func (r *Reactor) RemovePeer(peer p2p.Peer, reason interface{})

func (*Reactor) WithLogger

func (r *Reactor) WithLogger(logger log.Logger) *Reactor