Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 20 for ClientTrace (0.27 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. src/net/http/clientserver_test.go

    			if v, ok := header[h]; ok {
    				t.Errorf("%s is %q; must not be sent", h, v)
    			}
    		}
    	}
    
    	var respCounter uint8
    	trace := &httptrace.ClientTrace{
    		Got1xxResponse: func(code int, header textproto.MIMEHeader) error {
    			switch respCounter {
    			case 0:
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 46.6K bytes
    - Viewed (0)
  10. 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)
Back to top