p2p

Jul 19, 2023

Changes in this version

+ const HandleHistName

type Msg

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

type NodeInfo

+ ENR string

type Peer

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

+ func (p *Peer) IDV0() enode.IDv0

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

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

type PeerInfo

+ ENR string

+ Enode string

type Protocol

+ Attributes []enr.Entry

+ DialCandidates enode.Iterator

type Server

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

Jan 6, 2023

Changes in this version

type Peer

+ func (p *Peer) Fullname() string

Mar 31, 2022

Changes in this version

type Config

+ PIP7ChainID *big.Int

Oct 15, 2021

Changes in this version

type PeerEvent

+ LocalAddress string

+ RemoteAddress string

Jul 23, 2021

Changes in this version

type DiscReason

+ const DiscTooManyConsensusPeers

Dec 13, 2019

Changes in this version

type Config

+ BlsPublicKey bls.PublicKey

type NodeInfo

+ BlsPub string

Oct 21, 2019

Changes in this version

type Config

+ ChainID *big.Int

Jun 17, 2019

Changes in this version

+ func NewDialedTasks(maxPeers int, removeConsensusPeerFn removeConsensusPeerFn) *dialedTasks

+ func NewMockPeer(protos []Protocol) (func(), MsgWriter, *Peer, <-chan error)

+ func NewMockPeerNodeID(nodeId discover.NodeID, protos []Protocol) (func(), MsgReadWriter, *Peer, <-chan error)

+ func NewPeerByNodeID(nodeId1 discover.NodeID, nodeId2 discover.NodeID, protos []Protocol) (*Peer, MsgReadWriter, *Peer, MsgReadWriter)

type Config

+ MaxConsensusPeers int

type Peer

+ PingList *list.List

type Server

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

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

+ func (srv *Server) StartWatching(eventMux *event.TypeMux)

Sep 24, 2018

Changes in this version

+ 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) RlpData() interface{}

+ func (cap Cap) String() string

+ type Config struct

+ BootstrapNodes []*discover.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 []*discover.Node

+ TrustedNodes []*discover.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 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(*discover.Node) (net.Conn, error)

+ type NodeInfo struct

+ Enode string

+ ID string

+ IP string

+ ListenAddr string

+ Name string

+ Ports struct{ ... }

+ Protocols map[string]interface{}

+ type Peer struct

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

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

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

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

+ 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) RemoteAddr() net.Addr

+ func (p *Peer) String() string

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

+ Caps []string

+ ID string

+ Name string

+ Network struct{ ... }

+ Protocols map[string]interface{}

+ type Protocol struct

+ Length uint64

+ Name string

+ NodeInfo func() interface{}

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

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

+ Version uint

+ type Server struct

+ DiscV5 *discv5.Network

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

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

+ 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 *discover.Node)

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

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

+ func (srv *Server) SetupConn(fd net.Conn, flags connFlag, dialDest *discover.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 *discover.Node) (net.Conn, error)