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.0.0

Jan 14, 2021

Changes in this version

type Peer

+ func (p *Peer) IsTrusted() bool

v0

v0.10.2

Oct 12, 2020

v0.10.1

Oct 11, 2020

v0.10.0

Sep 16, 2020

v0.9.9

Jun 22, 2020

v0.9.8

Jun 2, 2020

v0.9.7

May 31, 2020

v0.9.6

May 20, 2020

v0.9.5

May 20, 2020

Changes in this version

+ const DefaultMaxPeers

+ const HistogramsAPIUsingFailureTimes

+ const HistogramsAPIUsingTimes

+ const HistogramsBCInsertBlcokUsingTimes

+ const HistogramsHandleUsingTimes

+ const HistogramsPMHandleMsgUsingTimes

+ const MetricsInboundTraffic

+ const MetricsOutboundTraffic

+ const MetricsSendMsgQPS

+ const MetricsSendMsgQPSFailure

+ const NodeIDBits

+ var DefaultConfig = &Config

+ var ErrPeerIsNotConnected = errors.New("peer is not connected")

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

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

+ func AddPeerToBlacklist(blacklist *Blacklist, peer *Peer) error

+ func CheckAddrInBlacklist(bl *Blacklist, addr net.Addr) bool

+ func ClearBlacklistDB(blacklist *Blacklist)

+ func Encode(msg Msg) ([]byte, error)

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

+ func MessageCacheInstance() *messageCache

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

+ func OpenDB(path string) (*blacklistDB, error)

+ func PrintInfo(r metrics.Registry, freq time.Duration)

+ func PrintInfo2(freq time.Duration)

+ func PublicBCInsertBlockUsingTime(start time.Time)

+ func PublicPMHandleMsgUsingTime(start time.Time)

+ func RegisterFilterCode(code uint64)

+ func RemoveAddrFromBlacklist(blacklist *Blacklist, addr net.Addr) bool

+ func RemoveFromBlacklist(blacklist *Blacklist, ip string, rudpPort int) bool

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

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

+ func UnregisterFilterCode(code uint64)

+ type Blacklist struct

+ Version uint64

+ func NewBlacklist(dbPath string) (*Blacklist, error)

+ func (bl *Blacklist) Check(hash common.Hash) (bool, error)

+ func (bl *Blacklist) Close() (err error)

+ func (bl *Blacklist) Start()

+ type BlacklistEvent struct

+ Enode *enode.Node

+ Hash common.Hash

+ ReceivedAt time.Time

+ Type BlacklistEventType

+ type BlacklistEventType string

+ const BlacklistEventAddPeer

+ const BlacklistEventClearDB

+ const BlacklistEventRemovePeer

+ type BlacklistItem struct

+ Enode string

+ IP string

+ RUDP int

+ ReceivedAt time.Time

+ func GetBlacklist(blacklist *Blacklist) []BlacklistItem

+ type Cap struct

+ Name string

+ Version uint

+ func (cap Cap) String() string

+ type Config struct

+ BlacklistDatabase string

+ BootstrapNodes []*enode.Node

+ DialRatio int

+ Dialer NodeDialer

+ DiscoverAddr string

+ EnableMsgEvents bool

+ ListenAddr string

+ LocalNet bool

+ MaxPeers int

+ MaxPendingPeers int

+ NAT nat.Interface

+ Name string

+ NatType enode.NATType

+ NetRestrict *netutil.Netlist

+ NoDial bool

+ NoDiscovery bool

+ NodeDatabase string

+ NodeType params.NodeType

+ PrivateKey *ecdsa.PrivateKey

+ ProtocolName string

+ Protocols []Protocol

+ StaticNodes []*enode.Node

+ TrustedNodes []*enode.Node

+ func NewDefaultConfig() Config

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

+ Code uint64

+ Payload io.Reader

+ ReceivedAt time.Time

+ Size uint32

+ func Decode(rw io.Reader) (msg Msg, err error)

+ func (msg *Msg) Hash() common.Hash

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

+ func (msg Msg) Discard() error

+ func (msg Msg) String() string

+ type MsgPipeRW struct

+ func (p *MsgPipeRW) Addr() common.Address

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

+ 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

+ Addr func() common.Address

+ WriteMsg func(Msg) error

+ type NodeDialer interface

+ Dial func(*enode.Node) (quic.Session, error)

+ type NodeID [NodeIDBits / 8]byte

+ func BytesID(b []byte) (NodeID, error)

+ func HexID(in string) (NodeID, error)

+ func MustBytesID(b []byte) NodeID

+ func MustHexID(in string) NodeID

+ func PubkeyID(pub *ecdsa.PublicKey) NodeID

+ func (id NodeID) Bytes() []byte

+ func (id NodeID) Pubkey() (*ecdsa.PublicKey, error)

+ func (n *NodeID) UnmarshalText(text []byte) error

+ func (n NodeID) GoString() string

+ func (n NodeID) MarshalText() ([]byte, error)

+ func (n NodeID) String() string

+ func (n NodeID) TerminalString() string

+ type NodeIP struct

+ type NodeInfo struct

+ ENR string

+ Enode string

+ ID string

+ IP string

+ ListenAddr string

+ Name string

+ Ports struct{ ... }

+ Protocols map[string]interface{}

+ type NodeStatus struct

+ Config *Config

+ Hosts []multiaddr.Multiaddr

+ ID []byte

+ NodeIp *NodeIP

+ 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() logging.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

+ Count int

+ Enode string

+ Error string

+ IP string

+ MsgCode *uint64

+ MsgSize *uint32

+ Peer enode.ID

+ Protocol string

+ Type PeerEventType

+ type PeerEventType string

+ const PeerEventTypeAdd

+ const PeerEventTypeDrop

+ const PeerEventTypeMsgRecv

+ const PeerEventTypeMsgSend

+ const PeerEventTypeReadChanCount

+ type PeerInfo struct

+ Caps []string

+ Enode string

+ ID string

+ Name string

+ Nat string

+ Network struct{ ... }

+ NodeType string

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

+ func (t RUDPDialer) Dial(dest *enode.Node) (quic.Session, error)

+ type Server struct

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

+ func (srv *Server) AddPeerToBlacklist(peer *Peer) error

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

+ func (srv *Server) ClearBlacklistDB()

+ func (srv *Server) GetBlacklist() []BlacklistItem

+ func (srv *Server) GetLocalIPs() []*net.IPNet

+ 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) RemovePeerFromBlacklist(ip string, rudpPort int) bool

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

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

+ func (srv *Server) SetupConn(session quic.Session, 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