Versions in this module Expand all Collapse all v0 v0.9.0 Oct 19, 2020 Changes in this version + const PexChannel + func NewAddrBook(filePath string, routabilityStrict bool) *addrBook + func RegisterPexMessage(cdc *amino.Codec) + type AddrBook interface + AddAddress func(addr *p2p.NetAddress, src *p2p.NetAddress) error + AddOurAddress func(*p2p.NetAddress) + AddPrivateIDs func([]string) + Empty func() bool + GetSelection func() []*p2p.NetAddress + GetSelectionWithBias func(biasTowardsNewAddrs int) []*p2p.NetAddress + HasAddress func(*p2p.NetAddress) bool + IsGood func(*p2p.NetAddress) bool + MarkAttempt func(*p2p.NetAddress) + MarkBad func(*p2p.NetAddress) + MarkGood func(p2p.ID) + NeedMoreAddrs func() bool + OurAddress func(*p2p.NetAddress) bool + PickAddress func(biasTowardsNewAddrs int) *p2p.NetAddress + RemoveAddress func(*p2p.NetAddress) + Save func() + Size func() int + type ErrAddrBookInvalidAddr struct + Addr *p2p.NetAddress + AddrErr error + func (err ErrAddrBookInvalidAddr) Error() string + type ErrAddrBookNilAddr struct + Addr *p2p.NetAddress + Src *p2p.NetAddress + func (err ErrAddrBookNilAddr) Error() string + type ErrAddrBookNonRoutable struct + Addr *p2p.NetAddress + func (err ErrAddrBookNonRoutable) Error() string + type ErrAddrBookPrivate struct + Addr *p2p.NetAddress + func (err ErrAddrBookPrivate) Error() string + func (err ErrAddrBookPrivate) PrivateAddr() bool + type ErrAddrBookPrivateSrc struct + Src *p2p.NetAddress + func (err ErrAddrBookPrivateSrc) Error() string + func (err ErrAddrBookPrivateSrc) PrivateAddr() bool + type ErrAddrBookSelf struct + Addr *p2p.NetAddress + func (err ErrAddrBookSelf) Error() string + type PEXReactor struct + func NewPEXReactor(b AddrBook, config *PEXReactorConfig) *PEXReactor + func (r *PEXReactor) AddPeer(p Peer) + func (r *PEXReactor) AttemptsToDial(addr *p2p.NetAddress) int + 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 + SeedDisconnectWaitPeriod time.Duration + SeedMode bool + Seeds []string + type Peer = p2p.Peer + type PexMessage interface
Go to main page