reactors

Documentation

Index

• func Init()
• func SetCfg(c *config.Config)
• func SetLogger(l log.Logger)
• type KReactor
  • func NewKReactor() *KReactor
  • func (k *KReactor) Broadcast(msgBytes []byte)
  • func (k *KReactor) GetChannels() []*p2p.ChannelDescriptor
  • func (k *KReactor) Receive(chID byte, src p2p.Peer, msgBytes []byte)
  • func (k *KReactor) SetLogger(l log.Logger)

Functions

func Init

func Init()

func SetCfg

func SetCfg(c *config.Config)

func SetLogger

func SetLogger(l log.Logger)

Types

type KReactor

type KReactor struct {
	p2p.BaseReactor
	Name   string
	Prefix string
	ChId   byte
}

KReactor 处理大量的TX分发

func NewKReactor

func NewKReactor() *KReactor

NewKReactor

func (*KReactor) Broadcast

func (k *KReactor) Broadcast(msgBytes []byte)

广播所有的节点

func (*KReactor) GetChannels

func (k *KReactor) GetChannels() []*p2p.ChannelDescriptor

GetChannels implements Reactor. It returns the list of channels for this reactor.

func (*KReactor) Receive

func (k *KReactor) Receive(chID byte, src p2p.Peer, msgBytes []byte)

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

func (*KReactor) SetLogger

func (k *KReactor) SetLogger(l log.Logger)

SetLogger sets the Logger on the reactor and the underlying Mempool.