Versions in this module Expand all Collapse all v0 v0.16.0 Feb 21, 2018 Changes in this version + const PexChannel + func NewAddrBook(filePath string, routabilityStrict bool) *addrBook + type AddrBook interface + AddAddress func(addr *p2p.NetAddress, src *p2p.NetAddress) error + AddOurAddress func(*p2p.NetAddress) + GetSelection func() []*p2p.NetAddress + ListOfKnownAddresses func() []*knownAddress + MarkAttempt func(*p2p.NetAddress) + MarkBad func(*p2p.NetAddress) + MarkGood func(*p2p.NetAddress) + NeedMoreAddrs func() bool + PickAddress func(newBias int) *p2p.NetAddress + RemoveAddress func(addr *p2p.NetAddress) + Save func() + type PEXReactor struct + func NewPEXReactor(b AddrBook, config *PEXReactorConfig) *PEXReactor + func (r *PEXReactor) AddPeer(p Peer) + func (r *PEXReactor) GetChannels() []*conn.ChannelDescriptor + func (r *PEXReactor) OnStart() error + func (r *PEXReactor) OnStop() + func (r *PEXReactor) Receive(chID byte, src Peer, msgBytes []byte) + func (r *PEXReactor) ReceiveAddrs(addrs []*p2p.NetAddress, src Peer) error + func (r *PEXReactor) RemovePeer(p Peer, reason interface{}) + func (r *PEXReactor) RequestAddrs(p Peer) + func (r *PEXReactor) SendAddrs(p Peer, netAddrs []*p2p.NetAddress) + func (r *PEXReactor) SetEnsurePeersPeriod(d time.Duration) + type PEXReactorConfig struct + SeedMode bool + Seeds []string + type Peer = p2p.Peer + type PexMessage interface + func DecodeMessage(bz []byte) (msgType byte, msg PexMessage, err error)
Go to main page