Versions in this module Expand all Collapse all v0 v0.1.0 Sep 20, 2022 Changes in this version + type Downstream struct + func (d *Downstream) Contains(addr ma.Multiaddr) bool + func (d *Downstream) ContainsPeer(id peer.ID) bool + func (d *Downstream) Current() peer.ID + func (d *Downstream) Next() peer.ID + func (d *Downstream) PeerAddrs() []ma.Multiaddr + func (d *Downstream) Peers() []peer.ID + func (d *Downstream) String() string + type IdResponse struct + Addresses []string + ID string + type Notifiee struct + func (n *Notifiee) ClosedStream(net network.Network, s network.Stream) + func (n *Notifiee) Connected(net network.Network, conn network.Conn) + func (n *Notifiee) Disconnected(net network.Network, conn network.Conn) + func (n *Notifiee) Listen(net network.Network, addr ma.Multiaddr) + func (n *Notifiee) ListenClose(net network.Network, addr ma.Multiaddr) + func (n *Notifiee) OpenedStream(net network.Network, s network.Stream) + type PeerInfo struct + Addr ma.Multiaddr + HttpPort uint16 + ID peer.ID + IP string + func (pi *PeerInfo) String() string + type PeerManager struct + DownWants *WantMap + SentWants *WantMap + UpWants *WantMap + func New(host host.Host, ctx context.Context, addrs ...ma.Multiaddr) (*PeerManager, error) + func (pm *PeerManager) AddRefCid(ip net.IP, c cid.Cid) + func (pm *PeerManager) AddUpstreamPeerIP(addr ma.Multiaddr) error + func (pm *PeerManager) CidsForRefIp(ip net.IP) []cid.Cid + func (pm *PeerManager) ConnectAllDown() + func (pm *PeerManager) CurrentDownPeer() peer.ID + func (pm *PeerManager) DeleteRefCid(ip net.IP, c cid.Cid) + func (pm *PeerManager) DeleteUpstreamPeerIP(id peer.ID) + func (pm *PeerManager) DownPeerInfo(id peer.ID) (PeerInfo, bool) + func (pm *PeerManager) DownPeers() []ma.Multiaddr + func (pm *PeerManager) DownstreamForPeer(upPeer peer.ID) []peer.ID + func (pm *PeerManager) IpFromMultiaddr(addr ma.Multiaddr) (net.IP, error) + func (pm *PeerManager) IsDownstream(id peer.ID) bool + func (pm *PeerManager) RefsForCid(c cid.Cid) []net.IP + func (pm *PeerManager) UpPeers() []peer.ID + func (pm *PeerManager) UpstreamForPeer(id peer.ID) []peer.ID + func (pm *PeerManager) UpstreamIPForPeer(id peer.ID) (net.IP, bool) + func (pm *PeerManager) UpstreamPeersForIP(ip net.IP) []peer.ID + type WantMap struct + func NewWantMap() *WantMap + func (wm *WantMap) Add(p peer.ID, c cid.Cid) + func (wm *WantMap) AllCids() []cid.Cid + func (wm *WantMap) AllPeers() []peer.ID + func (wm *WantMap) CidsForPeer(id peer.ID) []cid.Cid + func (wm *WantMap) Clear() + func (wm *WantMap) Delete(p peer.ID, c cid.Cid) + func (wm *WantMap) DeleteCid(c cid.Cid) + func (wm *WantMap) DeletePeer(p peer.ID) + func (wm *WantMap) Merge(other *WantMap) *WantMap + func (wm *WantMap) PeersForCid(c cid.Cid) []peer.ID