p2p

May 27, 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 DiscReason

+ func (d DiscReason) Error() string

type Msg

+ ReceivedAt time.Time

type Server

+ MaxPendingPeers int

+ NodeDatabase string

+ 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

Feb 20, 2015

Changes in this version

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

+ func MakeName(name, version string) string

type Cap

+ func (cap Cap) String() string

type Msg

+ func (msg Msg) String() string

type Peer

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

+ func (p *Peer) Name() string

type Server

+ BootstrapNodes []*discover.Node

+ Name string

+ PrivateKey *ecdsa.PrivateKey

Dec 21, 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