type net/http.Request
277 uses
net/http (current package)
client.go#L77: CheckRedirect func(req *Request, via []*Request) error
client.go#L141: RoundTrip(*Request) (*Response, error)
client.go#L174: func (c *Client) send(req *Request, deadline time.Time) (resp *Response, didTimeout func() bool, err error) {
client.go#L211: func send(ireq *Request, rt RoundTripper, deadline time.Time) (resp *Response, didTimeout func() bool, err error) {
client.go#L233: req = new(Request)
client.go#L320: func knownRoundTripperImpl(rt RoundTripper, req *Request) bool {
client.go#L351: func setRequestCancel(req *Request, rt RoundTripper, deadline time.Time) (stopTimer func(), didTimeout func() bool) {
client.go#L384: type canceler interface{ CancelRequest(*Request) }
client.go#L497: func (c *Client) checkRedirect(req *Request, via []*Request) error {
client.go#L507: func redirectBehavior(reqMethod string, resp *Response, ireq *Request) (redirectMethod string, shouldRedirect, includeBody bool) {
client.go#L586: func (c *Client) Do(req *Request) (*Response, error) {
client.go#L592: func (c *Client) do(req *Request) (retres *Response, reterr error) {
client.go#L607: reqs []*Request
client.go#L660: req = &Request{
client.go#L755: func (c *Client) makeHeadersCopier(ireq *Request) func(req *Request, stripSensitiveHeaders bool) {
client.go#L769: return func(req *Request, stripSensitiveHeaders bool) {
client.go#L819: func defaultCheckRedirect(req *Request, via []*Request) error {
filetransport.go#L53: func (t fileTransport) RoundTrip(req *Request) (resp *Response, err error) {
fs.go#L134: func dirList(w ResponseWriter, r *Request, f File) {
fs.go#L240: func ServeContent(w ResponseWriter, req *Request, name string, modtime time.Time, content io.ReadSeeker) {
fs.go#L269: func serveContent(w ResponseWriter, r *Request, name string, modtime time.Time, sizeFunc func() (int64, error), content io.ReadSeeker) {
fs.go#L478: func checkIfMatch(w ResponseWriter, r *Request) condResult {
fs.go#L508: func checkIfUnmodifiedSince(r *Request, modtime time.Time) condResult {
fs.go#L527: func checkIfNoneMatch(w ResponseWriter, r *Request) condResult {
fs.go#L557: func checkIfModifiedSince(r *Request, modtime time.Time) condResult {
fs.go#L578: func checkIfRange(w ResponseWriter, r *Request, modtime time.Time) condResult {
fs.go#L640: func checkPreconditions(w ResponseWriter, r *Request, modtime time.Time) (done bool, rangeHeader string) {
fs.go#L674: func serveFile(w ResponseWriter, r *Request, fs FileSystem, name string, redirect bool) {
fs.go#L777: func localRedirect(w ResponseWriter, r *Request, newPath string) {
fs.go#L806: func ServeFile(w ResponseWriter, r *Request, name string) {
fs.go#L840: func ServeFileFS(w ResponseWriter, r *Request, fsys fs.FS, name string) {
fs.go#L980: func (f *fileHandler) ServeHTTP(w ResponseWriter, r *Request) {
h2_bundle.go#L750: GetClientConn(req *Request, addr string) (*http2ClientConn, error)
h2_bundle.go#L779: func (p *http2clientConnPool) GetClientConn(req *Request, addr string) (*http2ClientConn, error) {
h2_bundle.go#L788: func (p *http2clientConnPool) getClientConn(req *Request, addr string, dialOnMiss bool) (*http2ClientConn, error) {
h2_bundle.go#L1009: func (p http2noDialClientConnPool) GetClientConn(req *Request, addr string) (*http2ClientConn, error) {
h2_bundle.go#L1017: func http2shouldRetryDial(call *http2dialCall, req *Request) bool {
h2_bundle.go#L4421: UpgradeRequest *Request
h2_bundle.go#L6178: func (sc *http2serverConn) upgradeRequest(req *Request) {
h2_bundle.go#L6287: func (sc *http2serverConn) newWriterAndRequest(st *http2stream, f *http2MetaHeadersFrame) (*http2responseWriter, *Request, error) {
h2_bundle.go#L6362: func (sc *http2serverConn) newWriterAndRequestNoBody(st *http2stream, rp http2requestParam) (*http2responseWriter, *Request, error) {
h2_bundle.go#L6417: req := &Request{
h2_bundle.go#L6437: func (sc *http2serverConn) newResponseWriter(st *http2stream, req *Request) *http2responseWriter {
h2_bundle.go#L6452: req *Request
h2_bundle.go#L6453: handler func(ResponseWriter, *Request)
h2_bundle.go#L6458: func (sc *http2serverConn) scheduleHandler(streamID uint32, rw *http2responseWriter, req *Request, handler func(ResponseWriter, *Request)) error {
h2_bundle.go#L6503: func (sc *http2serverConn) runHandler(rw *http2responseWriter, req *Request, handler func(ResponseWriter, *Request)) {
h2_bundle.go#L6533: func http2handleHeaderListTooLong(w ResponseWriter, r *Request) {
h2_bundle.go#L6699: req *Request
h2_bundle.go#L7401: return func(w ResponseWriter, r *Request) {
h2_bundle.go#L7759: func (t *http2unencryptedTransport) RoundTrip(req *Request) (*Response, error) {
h2_bundle.go#L8013: func (t *http2Transport) RoundTrip(req *Request) (*Response, error) {
h2_bundle.go#L8042: func (t *http2Transport) RoundTripOpt(req *Request, opt http2RoundTripOpt) (*Response, error) {
h2_bundle.go#L8130: func http2shouldRetryRequest(req *Request, err error) (*Request, error) {
h2_bundle.go#L8697: func http2commaSeparatedTrailers(req *Request) (string, error) {
h2_bundle.go#L8728: func http2checkConnHeaders(req *Request) error {
h2_bundle.go#L8744: func http2actualContentLength(req *Request) int64 {
h2_bundle.go#L8766: func (cc *http2ClientConn) RoundTrip(req *Request) (*Response, error) {
h2_bundle.go#L8770: func (cc *http2ClientConn) roundTrip(req *Request, streamf func(*http2clientStream)) (*Response, error) {
h2_bundle.go#L8899: func (cs *http2clientStream) doRequest(req *Request, streamf func(*http2clientStream)) {
h2_bundle.go#L8914: func (cs *http2clientStream) writeRequest(req *Request, streamf func(*http2clientStream)) (err error) {
h2_bundle.go#L9062: func (cs *http2clientStream) encodeAndWriteHeaders(req *Request) error {
h2_bundle.go#L9320: func (cs *http2clientStream) writeRequestBody(req *Request) (err error) {
h2_bundle.go#L9512: func (cc *http2ClientConn) encodeHeaders(req *Request, addGzipHeader bool, trailers string, contentLength int64) ([]byte, error) {
h2_bundle.go#L10810: func (rt http2erringRoundTripper) RoundTrip(*Request) (*Response, error) { return nil, rt.err }
h2_bundle.go#L10849: func http2isConnectionCloseRequest(req *Request) bool {
h2_bundle.go#L10871: func (rt http2noDialH2RoundTripper) RoundTrip(req *Request) (*Response, error) {
h2_bundle.go#L10894: func http2traceGetConn(req *Request, hostPort string) {
h2_bundle.go#L10902: func http2traceGotConn(req *Request, cc *http2ClientConn, reused bool) {
request.go#L113: type Request struct {
request.go#L352: func (r *Request) Context() context.Context {
request.go#L368: func (r *Request) WithContext(ctx context.Context) *Request {
request.go#L372: r2 := new(Request)
request.go#L386: func (r *Request) Clone(ctx context.Context) *Request {
request.go#L390: r2 := new(Request)
request.go#L417: func (r *Request) ProtoAtLeast(major, minor int) bool {
request.go#L423: func (r *Request) UserAgent() string {
request.go#L428: func (r *Request) Cookies() []*Cookie {
request.go#L434: func (r *Request) CookiesNamed(name string) []*Cookie {
request.go#L448: func (r *Request) Cookie(name string) (*Cookie, error) {
request.go#L464: func (r *Request) AddCookie(c *Cookie) {
request.go#L481: func (r *Request) Referer() string {
request.go#L497: func (r *Request) MultipartReader() (*multipart.Reader, error) {
request.go#L508: func (r *Request) multipartReader(allowMixed bool) (*multipart.Reader, error) {
request.go#L529: func (r *Request) isH2Upgrade() bool {
request.go#L561: func (r *Request) Write(w io.Writer) error {
request.go#L571: func (r *Request) WriteProxy(w io.Writer) error {
request.go#L582: func (r *Request) write(w io.Writer, usingProxy bool, extraHeaders Header, waitForContinue func() bool) (err error) {
request.go#L862: func NewRequest(method, url string, body io.Reader) (*Request, error) {
request.go#L889: func NewRequestWithContext(ctx context.Context, method, url string, body io.Reader) (*Request, error) {
request.go#L912: req := &Request{
request.go#L973: func (r *Request) BasicAuth() (username, password string, ok bool) {
request.go#L1022: func (r *Request) SetBasicAuth(username, password string) {
request.go#L1058: func ReadRequest(b *bufio.Reader) (*Request, error) {
request.go#L1079: func readRequest(b *bufio.Reader) (req *Request, err error) {
request.go#L1083: req = new(Request)
request.go#L1263: func parsePostForm(r *Request) (vs url.Values, err error) {
request.go#L1327: func (r *Request) ParseForm() error {
request.go#L1370: func (r *Request) ParseMultipartForm(maxMemory int64) error {
request.go#L1419: func (r *Request) FormValue(key string) string {
request.go#L1434: func (r *Request) PostFormValue(key string) string {
request.go#L1446: func (r *Request) FormFile(key string) (multipart.File, *multipart.FileHeader, error) {
request.go#L1469: func (r *Request) PathValue(name string) string {
request.go#L1478: func (r *Request) SetPathValue(name, value string) {
request.go#L1491: func (r *Request) patIndex(name string) int {
request.go#L1509: func (r *Request) expectsContinue() bool {
request.go#L1513: func (r *Request) wantsHttp10KeepAlive() bool {
request.go#L1520: func (r *Request) wantsClose() bool {
request.go#L1527: func (r *Request) closeBody() error {
request.go#L1534: func (r *Request) isReplayable() bool {
request.go#L1552: func (r *Request) outgoingLength() int64 {
request.go#L1579: func (r *Request) requiresHTTP1() bool {
response.go#L115: Request *Request
response.go#L154: func ReadResponse(r *bufio.Reader, req *Request) (*Response, error) {
roundtrip.go#L20: func badRoundTrip(*Transport, *Request) (*Response, error)
roundtrip.go#L29: func (t *Transport) RoundTrip(req *Request) (*Response, error) {
servemux121.go#L96: func (mux *serveMux121) handleFunc(pattern string, handler func(ResponseWriter, *Request)) {
servemux121.go#L104: func (mux *serveMux121) findHandler(r *Request) (h Handler, pattern string) {
server.go#L89: ServeHTTP(ResponseWriter, *Request)
server.go#L426: req *Request // request for this response
server.go#L1121: func http1ServerSupportsRequest(req *Request) bool {
server.go#L2157: func (h unencryptedHTTP2Request) ServeHTTP(rw ResponseWriter, req *Request) {
server.go#L2290: type HandlerFunc func(ResponseWriter, *Request)
server.go#L2293: func (f HandlerFunc) ServeHTTP(w ResponseWriter, r *Request) {
server.go#L2330: func NotFound(w ResponseWriter, r *Request) { Error(w, "404 page not found", StatusNotFound) }
server.go#L2346: return HandlerFunc(func(w ResponseWriter, r *Request) {
server.go#L2350: r2 := new(Request)
server.go#L2373: func Redirect(w ResponseWriter, r *Request, url string, code int) {
server.go#L2448: func (rh *redirectHandler) ServeHTTP(w ResponseWriter, r *Request) {
server.go#L2648: func (mux *ServeMux) Handler(r *Request) (h Handler, pattern string) {
server.go#L2660: func (mux *ServeMux) findHandler(r *Request) (h Handler, patStr string, _ *pattern, matches []string) {
server.go#L2706: return HandlerFunc(func(w ResponseWriter, r *Request) {
server.go#L2808: func (mux *ServeMux) ServeHTTP(w ResponseWriter, r *Request) {
server.go#L2842: func (mux *ServeMux) HandleFunc(pattern string, handler func(ResponseWriter, *Request)) {
server.go#L2862: func HandleFunc(pattern string, handler func(ResponseWriter, *Request)) {
server.go#L3292: func (sh serverHandler) ServeHTTP(rw ResponseWriter, req *Request) {
server.go#L3304: func badServeHTTP(serverHandler, ResponseWriter, *Request)
server.go#L3316: return HandlerFunc(func(w ResponseWriter, r *Request) {
server.go#L3318: r2 := new(Request)
server.go#L3647: func logf(r *Request, format string, args ...any) {
server.go#L3806: func (h *timeoutHandler) ServeHTTP(w ResponseWriter, r *Request) {
server.go#L3862: req *Request
server.go#L3935: func (globalOptionsHandler) ServeHTTP(w ResponseWriter, r *Request) {
server.go#L3963: func (h initALPNRequest) ServeHTTP(rw ResponseWriter, req *Request) {
server.go#L4058: return HandlerFunc(func(w ResponseWriter, r *Request) {
transfer.go#L84: case *Request:
transfer.go#L507: case *Request:
transfer.go#L587: case *Request:
transfer.go#L945: case *Request:
transport.go#L104: reqCanceler map[*Request]context.CancelCauseFunc
transport.go#L128: Proxy func(*Request) (*url.URL, error)
transport.go#L133: OnProxyConnectResponse func(ctx context.Context, proxyURL *url.URL, connectReq *Request, connectRes *Response) error
transport.go#L499: func ProxyFromEnvironment(req *Request) (*url.URL, error) {
transport.go#L505: func ProxyURL(fixedURL *url.URL) func(*Request) (*url.URL, error) {
transport.go#L506: return func(*Request) (*url.URL, error) {
transport.go#L515: *Request // original request, not to be mutated
transport.go#L543: func (t *Transport) useRegisteredProtocol(req *Request) bool {
transport.go#L557: func (t *Transport) alternateRoundTripper(req *Request) RoundTripper {
transport.go#L582: func (t *Transport) roundTrip(req *Request) (_ *Response, err error) {
transport.go#L743: func awaitLegacyCancel(ctx context.Context, cancel context.CancelCauseFunc, req *Request) {
transport.go#L773: func setupRewindBody(req *Request) *Request {
transport.go#L786: func rewindBody(req *Request) (rewound *Request, err error) {
transport.go#L808: func (pc *persistConn) shouldRetryRequest(req *Request, err error) bool {
transport.go#L913: func (t *Transport) prepareTransportCancel(req *Request, origCancel context.CancelCauseFunc) context.CancelCauseFunc {
transport.go#L928: t.reqCanceler = make(map[*Request]context.CancelCauseFunc)
transport.go#L941: func (t *Transport) CancelRequest(req *Request) {
transport.go#L1845: connectReq := &Request{
net/http/httputil
dump.go#L64: func outgoingLength(req *http.Request) int64 {
dump.go#L77: func DumpRequestOut(req *http.Request, body bool) ([]byte, error) {
dump.go#L100: reqSend = new(http.Request)
dump.go#L218: func DumpRequest(req *http.Request, body bool) ([]byte, error) {
persist.go#L44: pipereq map[*http.Request]uint
persist.go#L58: return &ServerConn{c: c, r: r, pipereq: make(map[*http.Request]uint)}
persist.go#L88: func (sc *ServerConn) Read() (*http.Request, error) {
persist.go#L89: var req *http.Request
persist.go#L175: func (sc *ServerConn) Write(req *http.Request, resp *http.Response) error {
persist.go#L237: pipereq map[*http.Request]uint
persist.go#L240: writeReq func(*http.Request, io.Writer) error
persist.go#L255: pipereq: make(map[*http.Request]uint),
persist.go#L256: writeReq: (*http.Request).Write,
persist.go#L267: cc.writeReq = (*http.Request).WriteProxy
persist.go#L299: func (cc *ClientConn) Write(req *http.Request) error {
persist.go#L363: func (cc *ClientConn) Read(req *http.Request) (resp *http.Response, err error) {
persist.go#L425: func (cc *ClientConn) Do(req *http.Request) (*http.Response, error) {
reverseproxy.go#L33: In *http.Request
reverseproxy.go#L39: Out *http.Request
reverseproxy.go#L155: Director func(*http.Request)
reverseproxy.go#L199: ErrorHandler func(http.ResponseWriter, *http.Request, error)
reverseproxy.go#L263: director := func(req *http.Request) {
reverseproxy.go#L269: func rewriteRequestURL(req *http.Request, target *url.URL) {
reverseproxy.go#L306: func (p *ReverseProxy) defaultErrorHandler(rw http.ResponseWriter, req *http.Request, err error) {
reverseproxy.go#L311: func (p *ReverseProxy) getErrorHandler() func(http.ResponseWriter, *http.Request, error) {
reverseproxy.go#L320: func (p *ReverseProxy) modifyResponse(rw http.ResponseWriter, res *http.Response, req *http.Request) bool {
reverseproxy.go#L332: func (p *ReverseProxy) ServeHTTP(rw http.ResponseWriter, req *http.Request) {
reverseproxy.go#L561: func shouldPanicOnCopyError(req *http.Request) bool {
reverseproxy.go#L737: func (p *ReverseProxy) handleUpgradeResponse(rw http.ResponseWriter, req *http.Request, res *http.Response) {
net/http/pprof
pprof.go#L110: func Cmdline(w http.ResponseWriter, r *http.Request) {
pprof.go#L116: func sleep(r *http.Request, d time.Duration) {
pprof.go#L123: func configureWriteDeadline(w http.ResponseWriter, r *http.Request, seconds float64) {
pprof.go#L144: func Profile(w http.ResponseWriter, r *http.Request) {
pprof.go#L170: func Trace(w http.ResponseWriter, r *http.Request) {
pprof.go#L196: func Symbol(w http.ResponseWriter, r *http.Request) {
pprof.go#L250: func (name handler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
pprof.go#L275: func (name handler) serveDeltaProfile(w http.ResponseWriter, r *http.Request, p *pprof.Profile, secStr string) {
pprof.go#L386: func Index(w http.ResponseWriter, r *http.Request) {
expvar
expvar.go#L358: func expvarHandler(w http.ResponseWriter, r *http.Request) {
go.pact.im/x/httpclient
httpclient.go#L12: Do(req *http.Request) (*http.Response, error)
go.pact.im/x/httpclient/mockhttpclient
mockhttpclient.go#L43: func (m *MockClient) Do(req *http.Request) (*http.Response, error) {
go.pact.im/x/httpdebug
httpdebug.go#L34: mux.HandleFunc("/debug/buildinfo", func(w http.ResponseWriter, _ *http.Request) {
httpdebug.go#L50: mux.HandleFunc("/debug/", func(w http.ResponseWriter, _ *http.Request) {
go.uber.org/zap
http_handler.go#L71: func (lvl AtomicLevel) ServeHTTP(w http.ResponseWriter, r *http.Request) {
http_handler.go#L102: func decodePutRequest(contentType string, r *http.Request) (zapcore.Level, error) {
http_handler.go#L109: func decodePutURL(r *http.Request) (zapcore.Level, error) {
golang.org/x/net/http2
client_conn_pool.go#L25: GetClientConn(req *http.Request, addr string) (*ClientConn, error)
client_conn_pool.go#L54: func (p *clientConnPool) GetClientConn(req *http.Request, addr string) (*ClientConn, error) {
client_conn_pool.go#L63: func (p *clientConnPool) getClientConn(req *http.Request, addr string, dialOnMiss bool) (*ClientConn, error) {
client_conn_pool.go#L284: func (p noDialClientConnPool) GetClientConn(req *http.Request, addr string) (*ClientConn, error) {
client_conn_pool.go#L292: func shouldRetryDial(call *dialCall, req *http.Request) bool {
server.go#L374: UpgradeRequest *http.Request
server.go#L2127: func (sc *serverConn) upgradeRequest(req *http.Request) {
server.go#L2236: func (sc *serverConn) newWriterAndRequest(st *stream, f *MetaHeadersFrame) (*responseWriter, *http.Request, error) {
server.go#L2305: func (sc *serverConn) newWriterAndRequestNoBody(st *stream, rp httpcommon.ServerRequestParam) (*responseWriter, *http.Request, error) {
server.go#L2323: req := (&http.Request{
server.go#L2341: func (sc *serverConn) newResponseWriter(st *stream, req *http.Request) *responseWriter {
server.go#L2356: req *http.Request
server.go#L2357: handler func(http.ResponseWriter, *http.Request)
server.go#L2362: func (sc *serverConn) scheduleHandler(streamID uint32, rw *responseWriter, req *http.Request, handler func(http.ResponseWriter, *http.Request)) error {
server.go#L2407: func (sc *serverConn) runHandler(rw *responseWriter, req *http.Request, handler func(http.ResponseWriter, *http.Request)) {
server.go#L2437: func handleHeaderListTooLong(w http.ResponseWriter, r *http.Request) {
server.go#L2603: req *http.Request
server.go#L3305: return func(w http.ResponseWriter, r *http.Request) {
transport.go#L337: func (t *unencryptedTransport) RoundTrip(req *http.Request) (*http.Response, error) {
transport.go#L591: func (t *Transport) RoundTrip(req *http.Request) (*http.Response, error) {
transport.go#L620: func (t *Transport) RoundTripOpt(req *http.Request, opt RoundTripOpt) (*http.Response, error) {
transport.go#L708: func shouldRetryRequest(req *http.Request, err error) (*http.Request, error) {
transport.go#L1292: func actualContentLength(req *http.Request) int64 {
transport.go#L1314: func (cc *ClientConn) RoundTrip(req *http.Request) (*http.Response, error) {
transport.go#L1318: func (cc *ClientConn) roundTrip(req *http.Request, streamf func(*clientStream)) (*http.Response, error) {
transport.go#L1429: func (cs *clientStream) doRequest(req *http.Request, streamf func(*clientStream)) {
transport.go#L1444: func (cs *clientStream) writeRequest(req *http.Request, streamf func(*clientStream)) (err error) {
transport.go#L1588: func (cs *clientStream) encodeAndWriteHeaders(req *http.Request) error {
transport.go#L1628: func encodeRequestHeaders(req *http.Request, addGzipHeader bool, peerMaxHeaderListSize uint64, headerf func(name, value string)) (httpcommon.EncodeHeadersResult, error) {
transport.go#L1858: func (cs *clientStream) writeRequestBody(req *http.Request) (err error) {
transport.go#L3129: func (rt erringRoundTripper) RoundTrip(*http.Request) (*http.Response, error) { return nil, rt.err }
transport.go#L3168: func isConnectionCloseRequest(req *http.Request) bool {
transport.go#L3190: func (rt noDialH2RoundTripper) RoundTrip(req *http.Request) (*http.Response, error) {
transport.go#L3213: func traceGetConn(req *http.Request, hostPort string) {
transport.go#L3221: func traceGotConn(req *http.Request, cc *ClientConn, reused bool) {
golang.org/x/net/trace
events.go#L45: func RenderEvents(w http.ResponseWriter, req *http.Request, sensitive bool) {
events.go#L104: func parseEventsArgs(req *http.Request) (fam string, b int, ok bool) {
trace.go#L105: var AuthRequest = func(req *http.Request) (any, sensitive bool) {
trace.go#L121: _, pat := http.DefaultServeMux.Handler(&http.Request{URL: &url.URL{Path: debugRequestsPath}})
trace.go#L151: func Traces(w http.ResponseWriter, req *http.Request) {
trace.go#L166: func Events(w http.ResponseWriter, req *http.Request) {
trace.go#L180: func Render(w io.Writer, req *http.Request, sensitive bool) {
trace.go#L288: func parseArgs(req *http.Request) (fam string, b int, ok bool) {
google.golang.org/grpc
server.go#L1106: func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request) {
google.golang.org/grpc/internal/resolver/delegatingresolver
delegatingresolver.go#L83: req := &http.Request{URL: &url.URL{
delegatingresolver.go#L215: req := &http.Request{URL: &url.URL{
google.golang.org/grpc/internal/transport
handler_server.go#L53: func NewServerHandlerTransport(w http.ResponseWriter, r *http.Request, stats []stats.Handler, bufferPool mem.BufferPool) (ServerTransport, error) {
handler_server.go#L147: req *http.Request
proxy.go#L64: req := &http.Request{
proxy.go#L110: func sendHTTPRequest(ctx context.Context, req *http.Request, conn net.Conn) error {