p2pManager

Documentation

Index

• type Peer
  • func NewPeer(protocolVersion int, options *config.P2POptions) *Peer
  • func (p *Peer) Connect()
  • func (p *Peer) HandleInv(payload []byte)
  • func (p *Peer) HandleMessage(command, payload []byte)
  • func (p *Peer) Init()
  • func (p *Peer) ProcessBlockNotify(blockHash string)
  • func (p *Peer) SendMessage(command, payload []byte)
  • func (p *Peer) SendVersion()
  • func (p *Peer) SetupMessageParser()

Types

type Peer

type Peer struct {
	Magic []byte

	Verack                bool
	ValidConnectionConfig bool

	NetworkServices   []byte
	EmptyNetAddress   []byte
	UserAgent         []byte
	BlockStartHeight  []byte
	RelayTransactions []byte

	InvCodes        map[string]uint32
	Commands        map[string][]byte
	Options         *config.P2POptions
	Conn            net.Conn
	ProtocolVersion int

	BlockNotifyCh chan string
}

func NewPeer

func NewPeer(protocolVersion int, options *config.P2POptions) *Peer

func (*Peer) Connect

func (p *Peer) Connect()

func (*Peer) HandleInv

func (p *Peer) HandleInv(payload []byte)

Parsing inv message https://en.bitcoin.it/wiki/Protocol_specification#inv

func (*Peer) HandleMessage

func (p *Peer) HandleMessage(command, payload []byte)

func (*Peer) Init

func (p *Peer) Init()

func (*Peer) ProcessBlockNotify

func (p *Peer) ProcessBlockNotify(blockHash string)

func (*Peer) SendMessage

func (p *Peer) SendMessage(command, payload []byte)

func (*Peer) SendVersion

func (p *Peer) SendVersion()

func (*Peer) SetupMessageParser

func (p *Peer) SetupMessageParser()