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.2.1-amis

Jan 31, 2018

v1.2.0

Jul 27, 2017

v1.1.0

Mar 23, 2017

v1.0.3

Mar 3, 2017

v1.0.2

Dec 20, 2016

Changes in this version

+ const NODE_NAME_LENGTH

+ const PERMISSIONED_CONFIG

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

+ 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

+ DataDir string

+ Dialer *net.Dialer

+ Discovery bool

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

+ 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 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) Info() *PeerInfo

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

+ func (p *Peer) Name() string

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

+ func (p *Peer) String() string

+ 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

+ func (srv *Server) AddPeer(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) Self() *discover.Node

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

+ func (srv *Server) Stop()

Incompatible versions in this module

v2.0.2-amis+incompatible

Feb 28, 2018