MCPcopy Create free account
hub / github.com/Azure/peerd / NewReader

Function NewReader

pkg/discovery/content/reader/reader.go:288–297  ·  view source on GitHub ↗

NewReader creates a new remote reader.

(c pcontext.Context, router routing.Router, resolveRetries int, resolveTimeout time.Duration, metricsRecorder metrics.Metrics)

Source from the content-addressed store, hash-verified

286
287// NewReader creates a new remote reader.
288func NewReader(c pcontext.Context, router routing.Router, resolveRetries int, resolveTimeout time.Duration, metricsRecorder metrics.Metrics) Reader {
289 return &reader{
290 context: c.Copy(),
291 resolveTimeout: resolveTimeout,
292 router: router,
293 resolveRetries: resolveRetries,
294 defaultHttpClient: router.Net().HTTPClientFor(""),
295 metricsRecorder: metricsRecorder,
296 }
297}

Callers 8

OpenMethod · 0.92
TestPreadRemoteUpstreamFunction · 0.85
TestFstatRemoteFunction · 0.85
TestP2pRetriesFunction · 0.85
TestP2pSuccessFunction · 0.85
TestP2pPeerNotFoundFunction · 0.85
TestP2pNoInfiniteLoopsFunction · 0.85

Calls 3

CopyMethod · 0.80
HTTPClientForMethod · 0.65
NetMethod · 0.65

Tested by 7

TestPreadRemoteUpstreamFunction · 0.68
TestFstatRemoteFunction · 0.68
TestP2pRetriesFunction · 0.68
TestP2pSuccessFunction · 0.68
TestP2pPeerNotFoundFunction · 0.68
TestP2pNoInfiniteLoopsFunction · 0.68