net

Documentation

Index

• Constants
• func ConvertPeers(peers []string) map[string]*peer.AddrInfo
• type Discovery
  • func InitDhtDiscovery(host host.Host, peersInfo []peer.AddrInfo, chainCfg *types.Chain33Config, ...) *Discovery
  • func (d *Discovery) CloseFindLANPeers()
  • func (d *Discovery) FindLANPeers(host host.Host, serviceTag string) (<-chan peer.AddrInfo, error)
  • func (d *Discovery) FindLocalPeer(pid peer.ID) peer.AddrInfo
  • func (d *Discovery) FindLocalPeers(pids []peer.ID) []peer.AddrInfo
  • func (d *Discovery) FindNearestPeers(pid peer.ID, count int) []peer.ID
  • func (d *Discovery) FindPeers(RendezvousString string) (<-chan peer.AddrInfo, error)
  • func (d *Discovery) FindPeersConnectedToPeer(pid peer.ID) (<-chan *peer.AddrInfo, error)
  • func (d *Discovery) FindSpecialPeer(pid peer.ID) (*peer.AddrInfo, error)
  • func (d *Discovery) Remove(pid peer.ID)
  • func (d *Discovery) RoutingTableSize() int
  • func (d *Discovery) RoutingTale() []peer.ID
  • func (d *Discovery) UPdate(pid peer.ID) error

Constants

const DhtProtoID = "/ipfs/kad/%s/1.0.0/%d"

Functions

func ConvertPeers

func ConvertPeers(peers []string) map[string]*peer.AddrInfo

Types

type Discovery

type Discovery struct {
	// contains filtered or unexported fields
}

func InitDhtDiscovery

func InitDhtDiscovery(host host.Host, peersInfo []peer.AddrInfo, chainCfg *types.Chain33Config, subCfg *p2pty.P2PSubConfig) *Discovery

func (*Discovery) CloseFindLANPeers

func (d *Discovery) CloseFindLANPeers()

func (*Discovery) FindLANPeers

func (d *Discovery) FindLANPeers(host host.Host, serviceTag string) (<-chan peer.AddrInfo, error)

查找局域网内的其他节点

func (*Discovery) FindLocalPeer

func (d *Discovery) FindLocalPeer(pid peer.ID) peer.AddrInfo

根据pid 查找当前DHT内部的peer信息

func (*Discovery) FindLocalPeers

func (d *Discovery) FindLocalPeers(pids []peer.ID) []peer.AddrInfo

func (*Discovery) FindNearestPeers

func (d *Discovery) FindNearestPeers(pid peer.ID, count int) []peer.ID

func (*Discovery) FindPeers

func (d *Discovery) FindPeers(RendezvousString string) (<-chan peer.AddrInfo, error)

func (*Discovery) FindPeersConnectedToPeer

func (d *Discovery) FindPeersConnectedToPeer(pid peer.ID) (<-chan *peer.AddrInfo, error)

func (*Discovery) FindSpecialPeer

func (d *Discovery) FindSpecialPeer(pid peer.ID) (*peer.AddrInfo, error)

根据指定的peerID ,查找指定的peer,

func (*Discovery) Remove

func (d *Discovery) Remove(pid peer.ID)

func (*Discovery) RoutingTableSize

func (d *Discovery) RoutingTableSize() int

routingTable size

func (*Discovery) RoutingTale

func (d *Discovery) RoutingTale() []peer.ID

routingTable 路由表的节点信息

func (*Discovery) UPdate

func (d *Discovery) UPdate(pid peer.ID) error