Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  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

Go to main page

Versions in this module

v0

v0.3.3

Jun 14, 2019

v0.3.2

Jun 2, 2019

Changes in this version

type Config

+ MessageFunc MessageFunc

+ Port uint16

+ Sign func(data []byte) []byte

+ Target [16]byte

type PID

+ func (p PID) String() string

type Peer

+ func (p *Peer) QueueMessage(msg p2p.Message, doneChan chan<- error)

v0.3.2-e935

Jun 10, 2019

v0.3.1

Apr 12, 2019

v0.3.0

Mar 28, 2019

Changes in this version

type Peer

+ func (p *Peer) PK() *crypto.PublicKey

v0.2.2

Feb 19, 2019

Changes in this version

+ var ErrPeerDisconnected = errors.New("peer already disconnected")

+ func DisableLog()

+ func RandomUint64() uint64

+ func UseLogger(logger elalog.Logger)

+ type Config struct

+ Magic uint32

+ MakeEmptyMessage func(cmd string) (p2p.Message, error)

+ PID PID

+ PingInterval time.Duration

+ PingNonce func(pid PID) uint64

+ PongNonce func(pid PID) uint64

+ ProtocolVersion uint32

+ Services uint64

+ SignNonce func(nonce []byte) (signature [64]byte)

+ func (c *Config) AddMessageFunc(messageFunc MessageFunc)

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

+ type MessageFunc func(peer *Peer, msg p2p.Message)

+ type PID [33]byte

+ func (p PID) Equal(o PID) bool

+ type Peer struct

+ func NewInboundPeer(cfg *Config) *Peer

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

+ func (p *Peer) AddMessageFunc(messageFunc MessageFunc)

+ func (p *Peer) Addr() string

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

+ func (p *Peer) Connected() bool

+ func (p *Peer) Disconnect()

+ func (p *Peer) ID() uint64

+ func (p *Peer) InQuit() <-chan struct{}

+ func (p *Peer) Inbound() bool

+ func (p *Peer) LastPingMicros() int64

+ 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() *p2p.NetAddress

+ func (p *Peer) OutQuit() <-chan struct{}

+ func (p *Peer) PID() PID

+ func (p *Peer) ProtocolVersion() uint32

+ func (p *Peer) Quit() <-chan struct{}

+ func (p *Peer) SendMessage(msg p2p.Message, doneChan chan<- error)

+ func (p *Peer) Services() uint64

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

+ func (p *Peer) String() string

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

+ func (p *Peer) VerAckReceived() bool

+ func (p *Peer) VersionKnown() bool

+ func (p *Peer) WaitForDisconnect()

+ type StatsSnap struct

+ Addr string

+ ConnTime time.Time

+ ID uint64

+ Inbound bool

+ LastPingMicros int64

+ LastPingTime time.Time

+ LastRecv time.Time

+ LastSend time.Time

+ PID string

+ Services uint64

+ Version uint32