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

p2p

package

Go to main page

Versions in this module

v1

v1.13.5

Feb 14, 2024

v1.13.4

Dec 16, 2023

v1.13.3

Nov 17, 2023

v1.13.2

Oct 31, 2023

v1.13.1

Oct 30, 2023

v1.12.3

Oct 30, 2023

Changes in this version

type Cap

+ func (cap Cap) Cmp(other Cap) int

type Config

+ DiscoveryV4 bool

v1.12.2

Oct 30, 2023

Changes in this version

+ const HandleHistName

+ var ErrPipeClosed = errors.New("p2p: read or write on closed message pipe")

+ var ErrShuttingDown = errors.New("shutting down")

+ func ExpectMsg(r MsgReader, code uint64, content interface{}) error

+ func MsgPipe() (*MsgPipeRW, *MsgPipeRW)

+ func Send(w MsgWriter, msgcode uint64, data interface{}) error

+ func SendItems(w MsgWriter, msgcode uint64, elems ...interface{}) error

+ type Cap struct

+ Name string

+ Version uint

+ func (cap Cap) String() string

+ type Config struct

+ BootstrapNodes []*enode.Node

+ BootstrapNodesV5 []*enode.Node

+ DialRatio int

+ Dialer NodeDialer

+ DiscAddr string

+ DiscoveryV5 bool

+ EnableMsgEvents bool

+ ListenAddr string

+ Logger log.Logger

+ MaxPeers int

+ MaxPendingPeers int

+ NAT nat.Interface

+ Name string

+ NetRestrict *netutil.Netlist

+ NoDial bool

+ NoDiscovery bool

+ NodeDatabase string

+ PrivateKey *ecdsa.PrivateKey

+ Protocols []Protocol

+ StaticNodes []*enode.Node

+ TrustedNodes []*enode.Node

+ type DiscReason uint8

+ const DiscAlreadyConnected

+ const DiscIncompatibleVersion

+ const DiscInvalidIdentity

+ const DiscNetworkError

+ const DiscProtocolError

+ const DiscQuitting

+ const DiscReadTimeout

+ const DiscRequested

+ const DiscSelf

+ const DiscSubprotocolError

+ const DiscTooManyPeers

+ const DiscUnexpectedIdentity

+ const DiscUselessPeer

+ func (d DiscReason) Error() string

+ func (d DiscReason) String() string

+ type Msg struct

+ Code uint64

+ Payload io.Reader

+ ReceivedAt time.Time

+ Size uint32

+ func (msg Msg) Decode(val interface{}) error

+ func (msg Msg) Discard() error

+ func (msg Msg) String() string

+ func (msg Msg) Time() time.Time

+ type MsgPipeRW struct

+ func (p *MsgPipeRW) Close() error

+ func (p *MsgPipeRW) ReadMsg() (Msg, error)

+ func (p *MsgPipeRW) WriteMsg(msg Msg) error

+ type MsgReadWriter interface

+ type MsgReader interface

+ ReadMsg func() (Msg, error)

+ type MsgWriter interface

+ WriteMsg func(Msg) error

+ type NodeDialer interface

+ Dial func(context.Context, *enode.Node) (net.Conn, error)

+ type NodeInfo struct

+ ENR string

+ Enode string

+ ID string

+ IP string

+ ListenAddr string

+ Name string

+ Ports struct{ ... }

+ Protocols map[string]interface{}

+ type Peer struct

+ func NewPeer(id enode.ID, name string, caps []Cap) *Peer

+ func NewPeerPipe(id enode.ID, name string, caps []Cap, pipe *MsgPipeRW) *Peer

+ func (p *Peer) Caps() []Cap

+ func (p *Peer) Disconnect(reason DiscReason)

+ func (p *Peer) Fullname() string

+ func (p *Peer) ID() enode.ID

+ func (p *Peer) Inbound() bool

+ func (p *Peer) Info() *PeerInfo

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

+ func (p *Peer) Log() log.Logger

+ func (p *Peer) Name() string

+ func (p *Peer) Node() *enode.Node

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

+ func (p *Peer) RunningCap(protocol string, versions []uint) bool

+ func (p *Peer) String() string

+ type PeerEvent struct

+ Error string

+ LocalAddress string

+ MsgCode *uint64

+ MsgSize *uint32

+ Peer enode.ID

+ Protocol string

+ RemoteAddress string

+ Type PeerEventType

+ type PeerEventType string

+ const PeerEventTypeAdd

+ const PeerEventTypeDrop

+ const PeerEventTypeMsgRecv

+ const PeerEventTypeMsgSend

+ type PeerInfo struct

+ Caps []string

+ ENR string

+ Enode string

+ ID string

+ Name string

+ Network struct{ ... }

+ Protocols map[string]interface{}

+ type Protocol struct

+ Attributes []enr.Entry

+ DialCandidates enode.Iterator

+ Length uint64

+ Name string

+ NodeInfo func() interface{}

+ PeerInfo func(id enode.ID) interface{}

+ Run func(peer *Peer, rw MsgReadWriter) error

+ Version uint

+ type Server struct

+ DiscV5 *discover.UDPv5

+ func (srv *Server) AddPeer(node *enode.Node)

+ func (srv *Server) AddTrustedPeer(node *enode.Node)

+ func (srv *Server) LocalNode() *enode.LocalNode

+ func (srv *Server) NodeInfo() *NodeInfo

+ func (srv *Server) PeerCount() int

+ func (srv *Server) Peers() []*Peer

+ func (srv *Server) PeersInfo() []*PeerInfo

+ func (srv *Server) RemovePeer(node *enode.Node)

+ func (srv *Server) RemoveTrustedPeer(node *enode.Node)

+ func (srv *Server) Self() *enode.Node

+ func (srv *Server) SetupConn(fd net.Conn, flags connFlag, dialDest *enode.Node) error

+ func (srv *Server) Start() (err error)

+ func (srv *Server) Stop()

+ func (srv *Server) SubscribeEvents(ch chan *PeerEvent) event.Subscription