Versions in this module Expand all Collapse all v6 v6.4.0 May 18, 2020 Changes in this version + const MaxBounds + const MaxOutBounds + const MinBounds + type ConnManager struct + Done chan struct{} + func NewConnManager(host core.Host, discovery *net.Discovery, tracker *metrics.BandwidthCounter, ...) *ConnManager + func (s *ConnManager) AddNeighbors(pr *peer.AddrInfo) + func (s *ConnManager) BoundSize() (insize int, outsize int) + func (s *ConnManager) CheckDiraction(pid peer.ID) network.Direction + func (s *ConnManager) Close() + func (s *ConnManager) Delete(pid peer.ID) + func (s *ConnManager) FetchConnPeers() []peer.ID + func (s *ConnManager) FetchNearestPeers() []peer.ID + func (s *ConnManager) Get(pid peer.ID) *peer.AddrInfo + func (s *ConnManager) GetLatencyByPeer(pids []peer.ID) map[string]time.Duration + func (s *ConnManager) InBounds() []peer.ID + func (s *ConnManager) InboundSize() int + func (s *ConnManager) IsNeighbors(pid peer.ID) bool + func (s *ConnManager) MonitorAllPeers(seeds []string, host core.Host) + func (s *ConnManager) OutBounds() []peer.ID + func (s *ConnManager) OutboundSize() int + func (s *ConnManager) RecoredLatency(pid peer.ID, ttl time.Duration) + func (s *ConnManager) Size() int + type PeerInfoManager struct + func NewPeerInfoManager(cli queue.Client) *PeerInfoManager + func (p *PeerInfoManager) Add(pid string, info *types.Peer) + func (p *PeerInfoManager) Close() + func (p *PeerInfoManager) Copy(dest *types.Peer, source *types.P2PPeerInfo) + func (p *PeerInfoManager) FetchPeerInfosInMin() []*types.Peer + func (p *PeerInfoManager) GetPeerInfoInMin(key string) *types.Peer + func (p *PeerInfoManager) MonitorPeerInfos() Other modules containing this package github.com/33cn/chain33