reactor

Documentation

Index

• Constants
• type BlockchainReactor
  • func NewBlockchainReactor(quitCh chan<- int, poolId int64, restEndpoint string, ...) *BlockchainReactor
  • func (bcR *BlockchainReactor) AddPeer(peer p2p.Peer)
  • func (bcR *BlockchainReactor) GetChannels() []*p2p.ChannelDescriptor
  • func (bcR *BlockchainReactor) OnStart() error
  • func (bcR *BlockchainReactor) OnStop()
  • func (bcR *BlockchainReactor) Receive(chID byte, src p2p.Peer, msgBytes []byte)
  • func (bcR *BlockchainReactor) SetLogger(l log.Logger)

Constants

const (
	BlockchainChannel = byte(0x40)
	BlockDelta        = int64(30)
)

Types

type BlockchainReactor

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

func NewBlockchainReactor

func NewBlockchainReactor(quitCh chan<- int, poolId int64, restEndpoint string, startHeight, endHeight int64) *BlockchainReactor

func (*BlockchainReactor) AddPeer

func (bcR *BlockchainReactor) AddPeer(peer p2p.Peer)

func (*BlockchainReactor) GetChannels

func (bcR *BlockchainReactor) GetChannels() []*p2p.ChannelDescriptor

func (*BlockchainReactor) OnStart

func (bcR *BlockchainReactor) OnStart() error

func (*BlockchainReactor) OnStop

func (bcR *BlockchainReactor) OnStop()

func (*BlockchainReactor) Receive

func (bcR *BlockchainReactor) Receive(chID byte, src p2p.Peer, msgBytes []byte)

func (*BlockchainReactor) SetLogger

func (bcR *BlockchainReactor) SetLogger(l log.Logger)