- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 650 for Req (0.02 sec)
-
staging/src/k8s.io/apiserver/pkg/server/filters/wrap.go
runtime.HandleErrorWithContext(req.Context(), nil, "Timeout or abort while handling", "method", req.Method, "URI", req.RequestURI, "auditID", audit.GetAuditIDTruncated(req.Context())) return } http.Error(w, "This request caused apiserver to panic. Look in the logs for details.", http.StatusInternalServerError)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 3.3K bytes - Viewed (0) -
src/net/http/cgi/host.go
func (h *Handler) ServeHTTP(rw http.ResponseWriter, req *http.Request) { if len(req.TransferEncoding) > 0 && req.TransferEncoding[0] == "chunked" { rw.WriteHeader(http.StatusBadRequest) rw.Write([]byte("Chunked request bodies are not supported by CGI.")) return } root := strings.TrimRight(h.Root, "/") pathInfo := strings.TrimPrefix(req.URL.Path, root) port := "80" if req.TLS != nil { port = "443" }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 07 20:46:32 UTC 2024 - 10.4K bytes - Viewed (0) -
src/net/http/fcgi/child.go
// response implements http.ResponseWriter. type response struct { req *request header http.Header code int wroteHeader bool wroteCGIHeader bool w *bufWriter } func newResponse(c *child, req *request) *response { return &response{ req: req, header: http.Header{}, w: newWriter(c.conn, typeStdout, req.reqId), } } func (r *response) Header() http.Header {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 10.3K bytes - Viewed (0) -
cmd/auth-handler_test.go
req := mustNewRequest(method, urlStr, contentLength, body, t) req.Header.Set("Content-Md5", "invalid-digest") cred := globalActiveCred if err := signRequestV4(req, cred.AccessKey, cred.SecretKey); err != nil { t.Fatalf("Unable to initialized new signed http request %s", err) } return req }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 15.4K bytes - Viewed (0) -
src/net/http/httptest/httptest.go
if method == "" { method = "GET" } req, err := http.ReadRequest(bufio.NewReader(strings.NewReader(method + " " + target + " HTTP/1.0\r\n\r\n"))) if err != nil { panic("invalid NewRequest arguments; " + err.Error()) } req = req.WithContext(ctx) // HTTP/1.0 was used above to avoid needing a Host field. Change it to 1.1 here. req.Proto = "HTTP/1.1" req.ProtoMinor = 1 req.Close = false if body != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 11 18:09:14 UTC 2024 - 2.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/filters/request_deadline.go
return http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) { ctx := req.Context() requestInfo, ok := request.RequestInfoFrom(ctx) if !ok { handleError(w, req, http.StatusInternalServerError, nil, "no RequestInfo found in context, handler chain must be wrong") return } if longRunning(req, requestInfo) { handler.ServeHTTP(w, req) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 05 21:12:12 UTC 2024 - 6.6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/proxy/upgradeaware.go
if proxyRedirect { return } if h.Transport == nil || h.WrapTransport { h.Transport = h.defaultProxyTransport(req.URL, h.Transport) } // WithContext creates a shallow clone of the request with the same context. newReq := req.WithContext(req.Context()) newReq.Header = utilnet.CloneHeader(req.Header) if !h.UseRequestLocation { newReq.URL = &loc } if h.UseLocationHost {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 19.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/filters/impersonation.go
return http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) { impersonationRequests, err := buildImpersonationRequests(req.Header) if err != nil { klog.V(4).Infof("%v", err) responsewriters.InternalError(w, req, err) return } if len(impersonationRequests) == 0 { handler.ServeHTTP(w, req) return } ctx := req.Context() requestor, exists := request.UserFrom(ctx) if !exists {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 07 10:10:35 UTC 2023 - 9.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/update.go
return func(w http.ResponseWriter, req *http.Request) { ctx := req.Context() // For performance tracking purposes. ctx, span := tracing.Start(ctx, "Update", traceFields(req)...) defer span.End(500 * time.Millisecond) namespace, name, err := scope.Namer.Name(req) if err != nil { scope.err(err, w, req) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 20:19:46 UTC 2023 - 11.5K bytes - Viewed (0) -
internal/kms/kms.go
k.updateMetrics(err, time.Since(start)) return plaintext, err } // MAC generates the checksum of the given req.Message using the key // with the req.Name at the KMS. func (k *KMS) MAC(ctx context.Context, req *MACRequest) ([]byte, error) { if req.Name == "" { req.Name = k.DefaultKey } start := time.Now() mac, err := k.conn.MAC(ctx, req)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 07 23:55:37 UTC 2024 - 11.4K bytes - Viewed (0)