- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 272 for Req (0.02 sec)
-
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/trace_util.go
attribute.Stringer("namespace", &lazyNamespace{req: req}), attribute.String("protocol", req.Proto), attribute.Stringer("resource", &lazyResource{req: req}), attribute.Stringer("scope", &lazyScope{req: req}), attribute.String("url", req.URL.Path), attribute.Stringer("user-agent", &lazyTruncatedUserAgent{req: req}), attribute.Stringer("verb", &lazyVerb{req: req}), }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Sep 03 15:25:35 UTC 2023 - 1.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/helpers_test.go
) func TestLazyTruncatedUserAgent(t *testing.T) { req := &http.Request{} req.Header = http.Header{} ua := "short-agent" req.Header.Set("User-Agent", ua) uaNotTruncated := &lazyTruncatedUserAgent{req} assert.Equal(t, ua, fmt.Sprintf("%v", uaNotTruncated)) ua = "" for i := 0; i < maxUserAgentLength*2; i++ { ua = ua + "a" } req.Header.Set("User-Agent", ua) uaTruncated := &lazyTruncatedUserAgent{req}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Sep 03 15:25:35 UTC 2023 - 5.4K bytes - Viewed (0) -
internal/handlers/forwarder.go
} } if xfPort := req.Header.Get(xForwardedPort); xfPort == "" { req.Header.Set(xForwardedPort, forwardedPort(req)) } if xfHost := req.Header.Get(xForwardedHost); xfHost == "" && req.Host != "" { req.Header.Set(xForwardedHost, req.Host) } } func forwardedPort(req *http.Request) string { if req == nil { return "" } if _, port, err := net.SplitHostPort(req.Host); err == nil && port != "" {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Apr 07 05:42:10 UTC 2023 - 5.6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/net/testing/http.go
func (h *HTTPProxyHandler) ServeHTTP(rw http.ResponseWriter, req *http.Request) { h.handlerDone.Add(1) defer h.handlerDone.Done() if h.hook != nil { if ok := h.hook(req); !ok { rw.WriteHeader(http.StatusInternalServerError) return } } b, err := httputil.DumpRequest(req, false) if err != nil { h.t.Logf("Failed to dump request, host=%s: %v", req.Host, err) } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 20 14:58:46 UTC 2023 - 3.8K bytes - Viewed (0) -
pilot/pkg/xds/adstest.go
} } func (a *AdsTest) fillInRequestDefaults(req *discovery.DiscoveryRequest) *discovery.DiscoveryRequest { if req == nil { req = &discovery.DiscoveryRequest{} } if req.TypeUrl == "" { req.TypeUrl = a.Type } if req.Node == nil { req.Node = &core.Node{ Id: a.ID, Metadata: a.metadata.ToStruct(), } } return req }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Feb 04 03:39:42 UTC 2024 - 6K bytes - Viewed (0) -
pilot/pkg/xds/deltaadstest.go
} func (a *DeltaAdsTest) fillInRequestDefaults(req *discovery.DeltaDiscoveryRequest) *discovery.DeltaDiscoveryRequest { if req == nil { req = &discovery.DeltaDiscoveryRequest{} } if req.TypeUrl == "" { req.TypeUrl = a.Type } if req.Node == nil { req.Node = &core.Node{ Id: a.ID, Metadata: a.metadata.ToStruct(), } } return req }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Feb 04 03:39:42 UTC 2024 - 6.9K bytes - Viewed (0) -
src/net/http/transport_internal_test.go
c, err := ln.Accept() if err != nil { t.Error(err) return } connc <- c }() tr := new(Transport) req, _ := NewRequest("GET", "http://"+ln.Addr().String(), nil) req = req.WithT(t) ctx, cancel := context.WithCancelCause(context.Background()) treq := &transportRequest{Request: req, ctx: ctx, cancel: cancel} cm := connectMethod{targetScheme: "http", targetAddr: ln.Addr().String()} pc, err := tr.getConn(treq, cm)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 15:57:17 UTC 2024 - 6.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/filters/authentication.go
} return http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) { authenticationStart := time.Now() if len(apiAuds) > 0 { req = req.WithContext(authenticator.WithAudiences(req.Context(), apiAuds)) } resp, ok, err := auth.AuthenticateRequest(req) authenticationFinish := time.Now() defer func() { metrics(req.Context(), resp, ok, err, apiAuds, authenticationStart, authenticationFinish) }()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 12 20:54:07 UTC 2023 - 6.4K bytes - Viewed (0) -
src/net/http/httputil/dump.go
reqURI := req.RequestURI if reqURI == "" { reqURI = req.URL.RequestURI() } fmt.Fprintf(&b, "%s %s HTTP/%d.%d\r\n", valueOrDefault(req.Method, "GET"), reqURI, req.ProtoMajor, req.ProtoMinor) absRequestURI := strings.HasPrefix(req.RequestURI, "http://") || strings.HasPrefix(req.RequestURI, "https://") if !absRequestURI { host := req.Host if host == "" && req.URL != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 9.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/fifo_list_test.go
) func TestFIFOWithEnqueueDequeueSingleRequest(t *testing.T) { req := &request{} list := newRequestFIFO() list.Enqueue(req) reqGot, ok := list.Dequeue() if !ok { t.Errorf("Expected true, but got: %t", ok) } if req != reqGot { t.Errorf("Expected dequued request: (%p), but got: (%p)", req, reqGot) } if list.Length() != 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 28 08:48:40 UTC 2022 - 7.8K bytes - Viewed (0)