mempool

Documentation

Index

• Constants
• type Reactor
  • func NewReactor(config *cfg.MempoolConfig, localPeerID p2p.ID) *Reactor
  • func (memR *Reactor) AddPeer(peer p2p.Peer)
  • func (memR *Reactor) GetChannels() []*p2p.ChannelDescriptor
  • func (memR *Reactor) OnStart() error
  • func (memR *Reactor) Receive(e p2p.Envelope)
  • func (memR *Reactor) RemovePeer(peer p2p.Peer, _ interface{})

Constants

const (
	MempoolChannel = byte(0x30)
)

Types

type Reactor

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

Reactor handles mempool tx broadcasting amongst peers. It maintains a map from peer ID to peer. Broadcasting is only outward to val network.

func NewReactor

func NewReactor(config *cfg.MempoolConfig, localPeerID p2p.ID) *Reactor

NewReactor returns a new Reactor with the given config.

func (*Reactor) AddPeer

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

AddPeer implements Reactor. It starts a broadcast routine ensuring all txs are forwarded to the given peer.

func (*Reactor) GetChannels

func (memR *Reactor) GetChannels() []*p2p.ChannelDescriptor

GetChannels implements Reactor by returning the list of channels for this reactor.

func (*Reactor) OnStart

func (memR *Reactor) OnStart() error

OnStart implements p2p.BaseReactor.

func (*Reactor) Receive

func (memR *Reactor) Receive(e p2p.Envelope)

Receive implements Reactor. It adds any received transactions to the mempool.

func (*Reactor) RemovePeer

func (memR *Reactor) RemovePeer(peer p2p.Peer, _ interface{})

RemovePeer implements Reactor.