p2p

package

Go to main page

Versions in this module

v1

v1.9.2

Aug 13, 2019

Changes in this version

+ const MeteredPeerLimit

+ const MetricsInboundConnects

+ const MetricsInboundTraffic

+ const MetricsOutboundConnects

+ const MetricsOutboundTraffic

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

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

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

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

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

+ ENR string

type Peer

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

type PeerEvent

+ LocalAddress string

+ RemoteAddress string

type PeerInfo

+ ENR string

+ Enode string

type Protocol

+ Attributes []enr.Entry

type Server

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

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

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

v1.8.8

May 14, 2018

Changes in this version

type Config

+ DialRatio int

+ EnableMsgEvents bool

+ Logger log.Logger

+ type NodeDialer interface

+ Dial func(*discover.Node) (net.Conn, error)

type Peer

+ func (p *Peer) Inbound() bool

+ type PeerEvent struct

+ Error string

+ MsgCode *uint64

+ MsgSize *uint32

+ Peer discover.NodeID

+ Protocol string

+ Type PeerEventType

+ type PeerEventType string

+ const PeerEventTypeAdd

+ const PeerEventTypeDrop

+ const PeerEventTypeMsgRecv

+ const PeerEventTypeMsgSend

type Server

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

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

+ type TCPDialer struct

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

v1.7.0

Sep 14, 2017

v1.6.0

Apr 14, 2017

Changes in this version

+ type Config struct

+ BootstrapNodes []*discover.Node

+ BootstrapNodesV5 []*discv5.Node

+ Dialer *net.Dialer

+ DiscoveryV5 bool

+ DiscoveryV5Addr string

+ ListenAddr string

+ MaxPeers int

+ MaxPendingPeers int

+ NAT nat.Interface

+ Name string

+ NetRestrict *netutil.Netlist

+ NoDial bool

+ NoDiscovery bool

+ NodeDatabase string

+ PrivateKey *ecdsa.PrivateKey

+ Protocols []Protocol

+ StaticNodes []*discover.Node

+ TrustedNodes []*discover.Node

type Peer

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

type Server

+ DiscV5 *discv5.Network

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

v1.4.5

May 24, 2016

Changes in this version

+ type NodeInfo struct

+ Enode string

+ ID string

+ IP string

+ ListenAddr string

+ Name string

+ Ports struct{ ... }

+ Protocols map[string]interface{}

type Peer

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

+ type PeerInfo struct

+ Caps []string

+ ID string

+ Name string

+ Network struct{ ... }

+ Protocols map[string]interface{}

type Protocol

+ NodeInfo func() interface{}

+ PeerInfo func(id discover.NodeID) interface{}

type Server

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

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

v1.2.3

Oct 21, 2015

v1.0.2

Aug 20, 2015

v0

v0.9.38

Jul 9, 2015

v0.9.26

May 28, 2015

Changes in this version

type Server

+ Discovery bool

v0.9.21

May 15, 2015

Changes in this version

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

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

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

type Cap

+ func (cap Cap) String() string

type DiscReason

+ func (d DiscReason) Error() string

type Msg

+ ReceivedAt time.Time

+ func (msg Msg) String() string

type Peer

+ func (p *Peer) ID() discover.NodeID

+ func (p *Peer) Name() string

type Server

+ BootstrapNodes []*discover.Node

+ MaxPendingPeers int

+ Name string

+ NodeDatabase string

+ PrivateKey *ecdsa.PrivateKey

+ StaticNodes []*discover.Node

+ TrustedNodes []*discover.Node

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

+ func (srv *Server) BroadcastLimited(protocol string, code uint64, limit func(float64) float64, data interface{}) error

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

v0.7.11

Dec 24, 2014

Changes in this version

+ 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

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

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

+ type Blacklist interface

+ Delete func([]byte) error

+ Exists func(pubkey []byte) (ok bool)

+ Get func([]byte) (bool, error)

+ Put func([]byte) error

+ type BlacklistMap struct

+ func NewBlacklist() *BlacklistMap

+ func (self *BlacklistMap) Delete(pubkey []byte) error

+ func (self *BlacklistMap) Exists(pubkey []byte) (ok bool)

+ func (self *BlacklistMap) Get(pubkey []byte) (bool, error)

+ func (self *BlacklistMap) Put(pubkey []byte) error

+ type Cap struct

+ Name string

+ Version uint

+ func (cap Cap) RlpData() interface{}

+ type ClientIdentity interface

+ Pubkey func() []byte

+ String func() string

+ type DiscReason byte

+ func (d DiscReason) String() string

+ type Msg struct

+ Code uint64

+ Payload io.Reader

+ Size uint32

+ func NewMsg(code uint64, params ...interface{}) Msg

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

+ func (msg Msg) Discard() error

+ type MsgPipeRW struct

+ func (p *MsgPipeRW) Close() error

+ func (p *MsgPipeRW) EncodeMsg(code uint64, data ...interface{}) 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

+ EncodeMsg func(code uint64, data ...interface{}) error

+ WriteMsg func(Msg) error

+ type NAT interface

+ AddPortMapping func(protocol string, extport, intport int, name string, lifetime time.Duration) error

+ DeletePortMapping func(protocol string, extport, intport int) error

+ GetExternalAddress func() (net.IP, error)

+ String func() string

+ func PMP(gateway net.IP) (nat NAT)

+ func UPNP() NAT

+ type Peer struct

+ func NewPeer(id ClientIdentity, caps []Cap) *Peer

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

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

+ func (p *Peer) Identity() ClientIdentity

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

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

+ func (p *Peer) String() string

+ type Protocol struct

+ Length uint64

+ Name string

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

+ Version uint

+ type Server struct

+ Blacklist Blacklist

+ Dialer *net.Dialer

+ Identity ClientIdentity

+ ListenAddr string

+ MaxPeers int

+ NAT NAT

+ NoDial bool

+ Protocols []Protocol

+ func (srv *Server) Broadcast(protocol string, code uint64, data ...interface{})

+ func (srv *Server) PeerCount() int

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

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

+ func (srv *Server) Stop()

+ func (srv *Server) SuggestPeer(ip net.IP, port int, nodeID []byte)

+ type SimpleClientIdentity struct

+ func NewSimpleClientIdentity(clientIdentifier string, version string, customIdentifier string, ...) *SimpleClientIdentity

+ func (c *SimpleClientIdentity) GetCustomIdentifier() string

+ func (c *SimpleClientIdentity) Pubkey() []byte

+ func (c *SimpleClientIdentity) SetCustomIdentifier(customIdentifier string)

+ func (c *SimpleClientIdentity) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL