Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

peer

package module

Go to main page

Versions in this module

v1

deprecated

v1.0.5

Jan 6, 2026

v1.0.4

Jan 6, 2026

v1.0.3

Jan 6, 2026

v1.0.2

Jan 6, 2026

v1.0.1

Jan 5, 2026

v1.0.0

Jan 5, 2026

Changes in this version

+ const MaxProtocolVersion

+ func UseLogger(logger slog.Logger)

+ type AddrFunc func(remoteAddr *wire.NetAddress) *wire.NetAddress

+ type Config struct

+ DisableRelayTx bool

+ HostToNetAddress HostToNetAddrFunc

+ IdleTimeout time.Duration

+ Listeners MessageListeners

+ Net wire.CurrencyNet

+ NewestBlock HashFunc

+ ProtocolVersion uint32

+ Proxy string

+ Services wire.ServiceFlag

+ UserAgentComments []string

+ UserAgentName string

+ UserAgentVersion string

+ type HashFunc func() (hash *chainhash.Hash, height int64, err error)

+ type HostToNetAddrFunc func(host string, port uint16, services wire.ServiceFlag) (*wire.NetAddress, error)

+ type MessageListeners struct

+ OnAddr func(p *Peer, msg *wire.MsgAddr)

+ OnBlock func(p *Peer, msg *wire.MsgBlock, buf []byte)

+ OnCFHeaders func(p *Peer, msg *wire.MsgCFHeaders)

+ OnCFTypes func(p *Peer, msg *wire.MsgCFTypes)

+ OnCFilter func(p *Peer, msg *wire.MsgCFilter)

+ OnCFilterV2 func(p *Peer, msg *wire.MsgCFilterV2)

+ OnCFiltersV2 func(p *Peer, msg *wire.MsgCFiltersV2)

+ OnFeeFilter func(p *Peer, msg *wire.MsgFeeFilter)

+ OnGetAddr func(p *Peer, msg *wire.MsgGetAddr)

+ OnGetBlocks func(p *Peer, msg *wire.MsgGetBlocks)

+ OnGetCFHeaders func(p *Peer, msg *wire.MsgGetCFHeaders)

+ OnGetCFTypes func(p *Peer, msg *wire.MsgGetCFTypes)

+ OnGetCFilter func(p *Peer, msg *wire.MsgGetCFilter)

+ OnGetCFilterV2 func(p *Peer, msg *wire.MsgGetCFilterV2)

+ OnGetCFiltersV2 func(p *Peer, msg *wire.MsgGetCFsV2)

+ OnGetData func(p *Peer, msg *wire.MsgGetData)

+ OnGetHeaders func(p *Peer, msg *wire.MsgGetHeaders)

+ OnGetInitState func(p *Peer, msg *wire.MsgGetInitState)

+ OnGetMiningState func(p *Peer, msg *wire.MsgGetMiningState)

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

+ OnInitState func(p *Peer, msg *wire.MsgInitState)

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

+ OnMemPool func(p *Peer, msg *wire.MsgMemPool)

+ OnMiningState func(p *Peer, msg *wire.MsgMiningState)

+ OnMixCiphertexts func(p *Peer, msg *wire.MsgMixCiphertexts)

+ OnMixConfirm func(p *Peer, msg *wire.MsgMixConfirm)

+ OnMixDCNet func(p *Peer, msg *wire.MsgMixDCNet)

+ OnMixFactoredPoly func(p *Peer, msg *wire.MsgMixFactoredPoly)

+ OnMixKeyExchange func(p *Peer, msg *wire.MsgMixKeyExchange)

+ OnMixPairReq func(p *Peer, msg *wire.MsgMixPairReq)

+ OnMixSecrets func(p *Peer, msg *wire.MsgMixSecrets)

+ OnMixSlotReserve func(p *Peer, msg *wire.MsgMixSlotReserve)

+ OnNotFound func(p *Peer, msg *wire.MsgNotFound)

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

+ OnPong func(p *Peer, msg *wire.MsgPong)

+ OnRead func(p *Peer, bytesRead int, msg wire.Message, err error)

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

+ OnSendHeaders func(p *Peer, msg *wire.MsgSendHeaders)

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

+ OnVerAck func(p *Peer, msg *wire.MsgVerAck)

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

+ OnWrite func(p *Peer, bytesWritten int, msg wire.Message, err error)

+ type Peer struct

+ func NewInboundPeer(cfg *Config) *Peer

+ func NewOutboundPeer(cfg *Config, addr string) (*Peer, error)

+ func (p *Peer) AddKnownInventory(invVect *wire.InvVect)

+ func (p *Peer) Addr() string

+ func (p *Peer) AssociateConnection(conn net.Conn)

+ func (p *Peer) BytesReceived() uint64

+ func (p *Peer) BytesSent() uint64

+ func (p *Peer) Connected() bool

+ func (p *Peer) Disconnect()

+ func (p *Peer) ID() int32

+ func (p *Peer) Inbound() bool

+ func (p *Peer) IsKnownInventory(invVect *wire.InvVect) bool

+ func (p *Peer) LastBlock() int64

+ func (p *Peer) LastPingMicros() int64

+ func (p *Peer) LastPingNonce() uint64

+ func (p *Peer) LastPingTime() time.Time

+ func (p *Peer) LastRecv() time.Time

+ func (p *Peer) LastSend() time.Time

+ func (p *Peer) LocalAddr() net.Addr

+ func (p *Peer) NA() *wire.NetAddress

+ func (p *Peer) ProtocolVersion() uint32

+ func (p *Peer) PushAddrMsg(addresses []*wire.NetAddress) ([]*wire.NetAddress, error)

+ func (p *Peer) PushGetBlocksMsg(locator []chainhash.Hash, stopHash *chainhash.Hash) error

+ func (p *Peer) PushGetHeadersMsg(locator []chainhash.Hash, stopHash *chainhash.Hash) error

+ func (p *Peer) QueueInventory(invVect *wire.InvVect)

+ func (p *Peer) QueueInventoryImmediate(invVect *wire.InvVect)

+ func (p *Peer) QueueMessage(msg wire.Message, doneChan chan<- struct{})

+ func (p *Peer) Services() wire.ServiceFlag

+ func (p *Peer) StartingHeight() int64

+ func (p *Peer) StatsSnapshot() *StatsSnap

+ func (p *Peer) String() string

+ func (p *Peer) TimeConnected() time.Time

+ func (p *Peer) TimeOffset() int64

+ func (p *Peer) UpdateLastBlockHeight(newHeight int64)

+ func (p *Peer) UserAgent() string

+ func (p *Peer) VerAckReceived() bool

+ func (p *Peer) VersionKnown() bool

+ func (p *Peer) WaitForDisconnect()

+ func (p *Peer) WantsHeaders() bool

+ type StatsSnap struct

+ Addr string

+ BytesRecv uint64

+ BytesSent uint64

+ ConnTime time.Time

+ ID int32

+ Inbound bool

+ LastBlock int64

+ LastPingMicros int64

+ LastPingNonce uint64

+ LastPingTime time.Time

+ LastRecv time.Time

+ LastSend time.Time

+ Services wire.ServiceFlag

+ StartingHeight int64

+ TimeOffset int64

+ UserAgent string

+ Version uint32

Other modules containing this package

github.com/monetarium/node