MCPcopy
hub / github.com/ipfs/kubo / FindProvidersAsync

Method FindProvidersAsync

routing/composer.go:67–70  ·  view source on GitHub ↗
(ctx context.Context, cid cid.Cid, count int)

Source from the content-addressed store, hash-verified

65}
66
67func (c *Composer) FindProvidersAsync(ctx context.Context, cid cid.Cid, count int) <-chan peer.AddrInfo {
68 log.Debug("composer: calling findProvidersAsync: ", cid)
69 return c.FindProvidersRouter.FindProvidersAsync(ctx, cid, count)
70}
71
72func (c *Composer) FindPeer(ctx context.Context, pid peer.ID) (peer.AddrInfo, error) {
73 log.Debug("composer: calling findPeer: ", pid)

Callers 4

routing.goFile · 0.80
FindProvidersMethod · 0.80
FindProvidersMethod · 0.80
RunDHTConnectivityFunction · 0.80

Calls

no outgoing calls

Tested by 1

RunDHTConnectivityFunction · 0.64