- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 20 for ClientTrace (0.27 sec)
-
src/net/http/httputil/reverseproxy.go
// sends it to another server, proxying the response back to the // client. // // 1xx responses are forwarded to the client if the underlying // transport supports ClientTrace.Got1xxResponse. type ReverseProxy struct { // Rewrite must be a function which modifies // the request into a new request to be sent // using Transport. Its response is then copied
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 27 23:37:42 UTC 2024 - 24.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/timeout_test.go
newServerRequest := func(tr *panicOnNonReuseTransport) *http.Request { req, _ := http.NewRequest("GET", fmt.Sprintf("https://127.0.0.1:%d", ts.Listener.Addr().(*net.TCPAddr).Port), nil) trace := &httptrace.ClientTrace{ GotConn: tr.GotConn, } return req.WithContext(httptrace.WithClientTrace(req.Context(), trace)) } // client clientCACertPool := x509.NewCertPool() clientCACertPool.AppendCertsFromPEM(tsCrt)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 18.4K bytes - Viewed (0) -
src/net/http/transport.go
// exception is HTTP status code 101 (Switching Protocols), which is // considered a terminal status and returned by [Transport.RoundTrip]. To see the // ignored 1xx responses, use the httptrace trace package's // ClientTrace.Got1xxResponse. // // Transport only retries a request upon encountering a network error // if the connection has been already been used successfully and if the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 91K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/internal/stdlib/manifest.go
}, "net/http/httptrace": { {"ClientTrace", Type, 7}, {"ClientTrace.ConnectDone", Field, 7}, {"ClientTrace.ConnectStart", Field, 7}, {"ClientTrace.DNSDone", Field, 7}, {"ClientTrace.DNSStart", Field, 7}, {"ClientTrace.GetConn", Field, 7}, {"ClientTrace.Got100Continue", Field, 7}, {"ClientTrace.Got1xxResponse", Field, 11}, {"ClientTrace.GotConn", Field, 7},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 02:20:05 UTC 2024 - 534.2K bytes - Viewed (0) -
src/net/http/httputil/reverseproxy_test.go
// seeing a 1xx response. ctx, cancel := context.WithCancel(context.Background()) defer cancel() ctx = httptrace.WithClientTrace(ctx, &httptrace.ClientTrace{ Got1xxResponse: func(code int, header textproto.MIMEHeader) error { cancel() return nil }, }) req, _ := http.NewRequestWithContext(ctx, "GET", "http://go.dev/", nil)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 54.6K bytes - Viewed (0) -
src/net/http/h2_bundle.go
} func http2traceWroteHeaders(trace *httptrace.ClientTrace) { if trace != nil && trace.WroteHeaders != nil { trace.WroteHeaders() } } func http2traceGot100Continue(trace *httptrace.ClientTrace) { if trace != nil && trace.Got100Continue != nil { trace.Got100Continue() } } func http2traceWait100Continue(trace *httptrace.ClientTrace) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 364.1K bytes - Viewed (0) -
src/net/http/transfer.go
if t.Method == "GET" || t.Method == "HEAD" { return false } return true } return false } func (t *transferWriter) writeHeader(w io.Writer, trace *httptrace.ClientTrace) error { if t.Close && !hasToken(t.Header.get("Connection"), "close") { if _, err := io.WriteString(w, "Connection: close\r\n"); err != nil { return err } if trace != nil && trace.WroteHeaderField != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 22:14:00 UTC 2024 - 31.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/genericapiserver_graceful_termination_test.go
var cancel context.CancelFunc ctx, cancel = context.WithTimeout(req.Context(), timeout) defer cancel() req = req.WithContext(ctx) } // setup trace trace := &httptrace.ClientTrace{ GotConn: func(connInfo httptrace.GotConnInfo) { callback(connInfo) }, } req = req.WithContext(httptrace.WithClientTrace(req.Context(), trace)) response, err := client.Do(req)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 38.3K bytes - Viewed (0) -
src/net/http/clientserver_test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 46.6K bytes - Viewed (0) -
src/net/http/serve_test.go
} return false } return true }) conns := 0 var info httptrace.GotConnInfo ctx := httptrace.WithClientTrace(context.Background(), &httptrace.ClientTrace{ GotConn: func(v httptrace.GotConnInfo) { conns++ info = v }, }) req, err := NewRequestWithContext(ctx, "GET", cst.ts.URL, nil) if err != nil { t.Fatal(err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 202K bytes - Viewed (0)