p2p

Jul 4, 2018

Changes in this version

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

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

Apr 14, 2017

Changes in this version

type Config

+ NoDiscovery bool

type Peer

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

Feb 1, 2017

Changes in this version

type Config

+ NetRestrict *netutil.Netlist

Nov 16, 2016

Changes in this version

type Config

+ BootstrapNodesV5 []*discv5.Node

+ DiscoveryV5 bool

+ DiscoveryV5Addr string

type Server

+ DiscV5 *discv5.Network

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

Oct 6, 2016

Changes in this version

+ type Config struct

+ BootstrapNodes []*discover.Node

+ Dialer *net.Dialer

+ Discovery bool

+ ListenAddr string

+ MaxPeers int

+ MaxPendingPeers int

+ NAT nat.Interface

+ Name string

+ NoDial bool

+ NodeDatabase string

+ PrivateKey *ecdsa.PrivateKey

+ Protocols []Protocol

+ StaticNodes []*discover.Node

+ TrustedNodes []*discover.Node

Jan 5, 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

May 28, 2015

Changes in this version

type Server

+ Discovery bool

May 8, 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

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