net/http.Request.Context (method)
106 uses
net/http (current package)
client.go#L348: oldCtx := req.Context()
client.go#L364: if oldCtx := req.Context(); timeBeforeContextDeadline(deadline, oldCtx) {
h2_bundle.go#L6816: ctx := req.Context()
h2_bundle.go#L6993: case <-req.Context().Done():
h2_bundle.go#L6994: return nil, req.Context().Err()
h2_bundle.go#L7591: cs.trace = httptrace.ContextClientTrace(req.Context())
h2_bundle.go#L7638: ctx := req.Context()
h2_bundle.go#L8116: trace := httptrace.ContextClientTrace(req.Context())
h2_bundle.go#L9212: trace := httptrace.ContextClientTrace(req.Context())
h2_bundle.go#L9220: trace := httptrace.ContextClientTrace(req.Context())
request.go#L336: func (r *Request) Context() context.Context {
request.go#L548: trace := httptrace.ContextClientTrace(r.Context())
server.go#L3147: s, _ := r.Context().Value(ServerContextKey).(*Server)
server.go#L3299: ctx, cancelCtx = context.WithTimeout(r.Context(), h.dt)
transport.go#L504: ctx := req.Context()
transport.go#L1327: ctx := req.Context()
transport.go#L1382: case <-req.Context().Done():
transport.go#L1383: return nil, req.Context().Err()
transport.go#L1396: case <-req.Context().Done():
transport.go#L1397: return nil, req.Context().Err()
transport.go#L2094: trace := httptrace.ContextClientTrace(rc.req.Context())
transport.go#L2217: case <-rc.req.Context().Done():
transport.go#L2219: pc.t.cancelRequest(rc.cancelKey, rc.req.Context().Err())
transport.go#L2605: ctxDoneChan := req.Context().Done()
transport.go#L2656: canceled = pc.t.cancelRequest(req.cancelKey, req.Context().Err())
transport.go#L2668: if logf, ok := tr.Request.Context().Value(tLogKey{}).(func(string, ...interface{})); ok {
net/http/httputil
reverseproxy.go#L218: ctx := req.Context()
reverseproxy.go#L376: if req.Context().Value(http.ServerContextKey) != nil {
reverseproxy.go#L568: case <-req.Context().Done():
github.com/aws/aws-sdk-go/aws/signer/v4
request_context_go1.7.go#L12: return r.Context()
github.com/prometheus/client_golang/prometheus/promhttp
instrument_client.go#L215: r = r.WithContext(httptrace.WithClientTrace(r.Context(), trace))
go.opencensus.io/plugin/ochttp
client_stats.go#L36: ctx, _ := tag.New(req.Context(),
route.go#L38: ctx, _ := tag.New(r.Context(), addRoute...)
route.go#L52: if a, ok := r.Context().Value(addedTagsKey{}).(*addedTags); ok {
server.go#L91: r = r.WithContext(context.WithValue(r.Context(), addedTagsKey{}, &tags))
server.go#L105: ctx := r.Context()
server.go#L150: ctx, _ := tag.New(r.Context(),
trace.go#L59: ctx, span := trace.StartSpan(req.Context(), name,
golang.org/x/net/http2
transport.go#L314: ctx := req.Context()
transport.go#L490: case <-req.Context().Done():
transport.go#L491: return nil, req.Context().Err()
transport.go#L1088: cs.trace = httptrace.ContextClientTrace(req.Context())
transport.go#L1135: ctx := req.Context()
transport.go#L1613: trace := httptrace.ContextClientTrace(req.Context())
transport.go#L2708: trace := httptrace.ContextClientTrace(req.Context())
transport.go#L2716: trace := httptrace.ContextClientTrace(req.Context())
golang.org/x/pkgsite/cmd/prober
main.go#L275: statuses := runProbes(r.Context())
main.go#L297: statuses := runProbes(r.Context())
golang.org/x/pkgsite/internal/frontend
404.go#L52: ctx := r.Context()
badge.go#L43: s.servePage(r.Context(), w, "badge.tmpl", page)
details.go#L27: defer middleware.ElapsedStat(r.Context(), "serveDetails")()
details.go#L50: ctx := r.Context()
fetch.go#L114: status, responseText := s.fetchAndPoll(r.Context(), ds, urlInfo.modulePath, urlInfo.fullPath, urlInfo.requestedVersion)
paginate.go#L80: log.Errorf(r.Context(), "strconv.Atoi(%q) for page: %v", a, err)
playground.go#L43: log.Errorf(r.Context(), "ERROR playground proxy error: %v", err)
search.go#L236: ctx := r.Context()
server.go#L131: log.Infof(r.Context(), "Request made to %q", r.URL.Path)
server.go#L196: return detailsTTLForPath(r.Context(), r.URL.Path, r.FormValue("tab"))
server.go#L238: s.servePage(r.Context(), w, templateName, s.newBasePage(r, title))
server.go#L285: s.servePage(r.Context(), w, "license_policy.tmpl", page)
server.go#L294: Experiments: experiment.FromContext(r.Context()),
server.go#L322: log.Errorf(r.Context(), "Error copying panic template to ResponseWriter: %v", err)
server.go#L345: ds := s.getDataSource(r.Context())
server.go#L353: ctx := r.Context()
server.go#L410: buf, err := s.renderErrorPage(r.Context(), status, template, page)
server.go#L412: log.Errorf(r.Context(), "s.renderErrorPage(w, %d, %v): %v", status, page, err)
server.go#L419: log.Errorf(r.Context(), "Error copying template %q buffer to ResponseWriter: %v", template, err)
styleguide.go#L34: ctx := r.Context()
golang.org/x/pkgsite/internal/middleware
caching.go#L141: ctx := r.Context()
experiment.go#L105: return r.WithContext(experiment.NewContext(r.Context(), exps...))
iapheader.go#L26: if err := validateIAPToken(r.Context(), token, audience); err != nil {
panic.go#L20: log.Errorf(r.Context(), "middleware.Panic: %v", e)
quota.go#L74: ctx := r.Context()
requestlog.go#L75: h.delegate.ServeHTTP(w2, r.WithContext(log.NewContextWithTraceID(r.Context(), traceID)))
stats.go#L25: ctx := context.WithValue(r.Context(), statsKey{}, sw.stats.Other)
timeout.go#L18: ctx, cancel := context.WithTimeout(r.Context(), d)
golang.org/x/pkgsite/internal/worker
pages.go#L47: g, ctx := errgroup.WithContext(r.Context())
pages.go#L130: g, ctx := errgroup.WithContext(r.Context())
server.go#L130: log.Infof(r.Context(), "Request made to %q", r.URL.Path)
server.go#L229: n, err := s.db.UpdateSearchDocumentsImportedByCount(r.Context())
server.go#L253: ctx := r.Context()
server.go#L280: log.Infof(r.Context(), "doFetch of %s returned %d; returning that code to retry task", r.URL.Path, code)
server.go#L285: log.Infof(r.Context(), "doFetch of %s returned code %d; returning OK to avoid retry", r.URL.Path, code)
server.go#L289: log.Info(r.Context(), msg)
server.go#L297: ctx := r.Context()
server.go#L367: ctx := r.Context()
server.go#L406: ctx := r.Context()
server.go#L409: span := trace.FromContext(r.Context())
server.go#L440: recordEnqueue(r.Context(), m.Status)
server.go#L463: log.Errorf(r.Context(), "handleHTMLPage", err)
server.go#L474: vm, err := s.db.GetVersionMap(r.Context(), stdlib.ModulePath, "master")
server.go#L479: if _, err := s.queue.ScheduleFetch(r.Context(), stdlib.ModulePath, "master", "", false); err != nil {
server.go#L483: return s.db.DeletePseudoversionsExcept(r.Context(), stdlib.ModulePath, vm.ResolvedVersion)
server.go#L487: msg, err := s.doPopulateStdLib(r.Context(), r.FormValue("suffix"))
server.go#L492: log.Infof(r.Context(), "handlePopulateStdLib: %s", msg)
server.go#L523: if err := s.db.UpdateModuleVersionStatesForReprocessingLatestOnly(r.Context(), appVersion); err != nil {
server.go#L537: if err := s.db.UpdateModuleVersionStatesWithStatus(r.Context(), code, appVersion); err != nil {
server.go#L547: if err := s.db.UpdateModuleVersionStatesForReprocessingReleaseVersionsOnly(r.Context(), appVersion); err != nil {
server.go#L555: if err := s.db.UpdateModuleVersionStatesForReprocessing(r.Context(), appVersion); err != nil {
server.go#L566: if err := s.cache.Clear(r.Context()); err != nil {
server.go#L579: if err := s.db.DeleteModule(r.Context(), modulePath, version); err != nil {
server.go#L600: ctx := r.Context()
server.go#L727: log.Errorf(r.Context(), "parsing query parameter %q: %v", name, err)
server.go#L752: ctx := r.Context()
google.golang.org/grpc/internal/transport
handler_server.go#L333: ctx := ht.req.Context()
handler_server.go#L347: case <-ht.req.Context().Done():
 |
The pages are generated with Golds v0.3.2-preview. (GOOS=darwin GOARCH=amd64)
Golds is a Go 101 project developed by Tapir Liu.
PR and bug reports are welcome and can be submitted to the issue list.
Please follow @Go100and1 (reachable from the left QR code) to get the latest news of Golds. |