peer

package
v0.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 23, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source
const (
	MaxHeightBack = 20
)

Variables

This section is empty.

Functions

func SetBtcdLogLevel

func SetBtcdLogLevel()

Types

type Peer

type Peer struct {
	HandleError func(error)
	BlockSave   dbi.BlockSave
	TxSave      dbi.TxSave
	LastBlock   *chainhash.Hash
	HasExisting bool
	HeightBack  int64
	SyncDone    bool
	Mempool     bool
	// contains filtered or unexported fields
}

func NewConnection

func NewConnection(txSave dbi.TxSave, blockSave dbi.BlockSave) *Peer

func (*Peer) BroadcastTx

func (p *Peer) BroadcastTx(ctx context.Context, msgTx *wire.MsgTx) error

func (*Peer) Connect

func (p *Peer) Connect() error

func (*Peer) Disconnect

func (p *Peer) Disconnect()

func (*Peer) Error

func (p *Peer) Error(err error)

func (*Peer) OnBlock

func (p *Peer) OnBlock(_ *peer.Peer, msg *wire.MsgBlock, _ []byte)

func (*Peer) OnHeaders

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

func (*Peer) OnInv

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

func (*Peer) OnMerkleBlock

func (p *Peer) OnMerkleBlock(_ *peer.Peer, msg *wire.MsgMerkleBlock)

func (*Peer) OnPing

func (p *Peer) OnPing(_ *peer.Peer, msg *wire.MsgPing)

func (*Peer) OnReject

func (p *Peer) OnReject(_ *peer.Peer, msg *wire.MsgReject)

func (*Peer) OnTx

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

func (*Peer) OnVerAck

func (p *Peer) OnVerAck(_ *peer.Peer, _ *wire.MsgVerAck)

func (*Peer) OnVersion

func (p *Peer) OnVersion(_ *peer.Peer, msg *wire.MsgVersion)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL