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

v0

v0.2.1455559

Mar 25, 2022

v0.2.1455558

Mar 25, 2022

v0.2.1455557

Mar 25, 2022

v0.2.1455556

Mar 25, 2022

v0.2.1455555

Mar 25, 2022

Changes in this version

+ const HandleHistName

type Msg

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

type Peer

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

+ func (p *Peer) Fullname() string

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

type PeerInfo

+ ENR string

type Protocol

+ DialCandidates enode.Iterator

v0.1.4

Mar 6, 2020

Changes in this version

+ const MeteredPeerLimit

+ const MetricsInboundConnects

+ const MetricsInboundTraffic

+ const MetricsOutboundConnects

+ const MetricsOutboundTraffic

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

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

+ var PeerEgressRegistry = metrics.NewPrefixedChildRegistry(metrics.EphemeralRegistry, MetricsOutboundTraffic + "/")

+ var PeerIngressRegistry = metrics.NewPrefixedChildRegistry(metrics.EphemeralRegistry, MetricsInboundTraffic + "/")

+ 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

+ func SubscribeMeteredPeerEvent(ch chan<- MeteredPeerEvent) event.Subscription

+ type Cap struct

+ Name string

+ Version uint

+ func (cap Cap) String() string

+ type Config struct

+ BootstrapNodes []*enode.Node

+ BootstrapNodesV5 []*discv5.Node

+ DialRatio int

+ Dialer NodeDialer

+ 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 uint

+ 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 MeteredPeerEvent struct

+ Egress uint64

+ Elapsed time.Duration

+ ID enode.ID

+ IP net.IP

+ Ingress uint64

+ Type MeteredPeerEventType

+ type MeteredPeerEventType int

+ const PeerConnected

+ const PeerDisconnected

+ const PeerHandshakeFailed

+ 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

+ 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(*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 (p *Peer) Caps() []Cap

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

+ 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) 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

+ Enode string

+ ID string

+ Name string

+ Network struct{ ... }

+ Protocols map[string]interface{}

+ type Protocol struct

+ Attributes []enr.Entry

+ 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 *discv5.Network

+ 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

+ type TCPDialer struct

+ func (t TCPDialer) Dial(dest *enode.Node) (net.Conn, error)