chainsync

Documentation

Index

• type P2PSyncManager
  • func NewP2PSyncManager(chain *rt.ChainRTO, ports *p2p.ChainsPortIndex, address string) (*P2PSyncManager, error)
  • func (syncManager *P2PSyncManager) OnBlock(_ *peer.Peer, msg *wire.MsgBlock, blockActualMMR chainhash.Hash, buf []byte)
  • func (syncManager *P2PSyncManager) OnGetBlocks(p *peer.Peer, msg *wire.MsgGetBlocks)
  • func (syncManager *P2PSyncManager) OnGetData(p *peer.Peer, msg *wire.MsgGetData)
  • func (syncManager *P2PSyncManager) OnGetHeaders(p *peer.Peer, msg *wire.MsgGetHeaders)
  • func (syncManager *P2PSyncManager) OnHeaders(p *peer.Peer, msg *wire.MsgHeaders)
  • func (syncManager *P2PSyncManager) OnInv(p *peer.Peer, msg *wire.MsgInv)
  • func (syncManager *P2PSyncManager) OnMemPool(p *peer.Peer, msg *wire.MsgMemPool)
  • func (syncManager *P2PSyncManager) OnTx(p *peer.Peer, msg *wire.MsgTx)
  • func (syncManager *P2PSyncManager) OnVerAck(p *peer.Peer, msg *wire.MsgVerAck)
  • func (syncManager *P2PSyncManager) OnVersion(p *peer.Peer, msg *wire.MsgVersion) *wire.MsgReject
  • func (syncManager *P2PSyncManager) Run(ctx context.Context)

Types

type P2PSyncManager

type P2PSyncManager struct {
	// contains filtered or unexported fields
}

func NewP2PSyncManager

func NewP2PSyncManager(chain *rt.ChainRTO, ports *p2p.ChainsPortIndex, address string) (*P2PSyncManager, error)

func (*P2PSyncManager) OnBlock

func (syncManager *P2PSyncManager) OnBlock(_ *peer.Peer, msg *wire.MsgBlock, blockActualMMR chainhash.Hash, buf []byte)

func (*P2PSyncManager) OnGetBlocks

func (syncManager *P2PSyncManager) OnGetBlocks(p *peer.Peer, msg *wire.MsgGetBlocks)

func (*P2PSyncManager) OnGetData

func (syncManager *P2PSyncManager) OnGetData(p *peer.Peer, msg *wire.MsgGetData)

func (*P2PSyncManager) OnGetHeaders

func (syncManager *P2PSyncManager) OnGetHeaders(p *peer.Peer, msg *wire.MsgGetHeaders)

func (*P2PSyncManager) OnHeaders

func (syncManager *P2PSyncManager) OnHeaders(p *peer.Peer, msg *wire.MsgHeaders)

func (*P2PSyncManager) OnInv

func (syncManager *P2PSyncManager) OnInv(p *peer.Peer, msg *wire.MsgInv)

func (*P2PSyncManager) OnMemPool

func (syncManager *P2PSyncManager) OnMemPool(p *peer.Peer, msg *wire.MsgMemPool)

func (*P2PSyncManager) OnTx

func (syncManager *P2PSyncManager) OnTx(p *peer.Peer, msg *wire.MsgTx)

func (*P2PSyncManager) OnVerAck

func (syncManager *P2PSyncManager) OnVerAck(p *peer.Peer, msg *wire.MsgVerAck)

func (*P2PSyncManager) OnVersion

func (syncManager *P2PSyncManager) OnVersion(p *peer.Peer, msg *wire.MsgVersion) *wire.MsgReject

func (*P2PSyncManager) Run

func (syncManager *P2PSyncManager) Run(ctx context.Context)