- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 812 for Req (0.9 sec)
-
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/helpers.go
if lazy.req != nil { accept := lazy.req.Header.Get("Accept") return accept } return "unknown" } // lazyAPIGroup implements String() string and it will // lazily get Group from request info. type lazyAPIGroup struct { req *http.Request } func (lazy *lazyAPIGroup) String() string { if lazy.req != nil { ctx := lazy.req.Context() requestInfo, ok := apirequest.RequestInfoFrom(ctx) if ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Sep 03 15:25:35 UTC 2023 - 4.9K bytes - Viewed (0) -
src/cmd/go/internal/auth/auth.go
package auth import "net/http" // AddCredentials fills in the user's credentials for req, if any. // The return value reports whether any matching credentials were found. func AddCredentials(req *http.Request) (added bool) { host := req.Host if host == "" { host = req.URL.Hostname() } // TODO(golang.org/issue/26232): Support arbitrary user-provided credentials. netrcOnce.Do(readNetrc)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Oct 25 13:22:22 UTC 2022 - 767 bytes - Viewed (0) -
src/net/http/triv.go
ctr.mu.Lock() defer ctr.mu.Unlock() return strconv.Itoa(ctr.n) } func (ctr *Counter) ServeHTTP(w http.ResponseWriter, req *http.Request) { ctr.mu.Lock() defer ctr.mu.Unlock() switch req.Method { case "GET": ctr.n++ case "POST": var buf strings.Builder io.Copy(&buf, req.Body) body := buf.String() if n, err := strconv.Atoi(body); err != nil { fmt.Fprintf(w, "bad POST: %v\nbody: [%v]\n", err, body)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 3.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/filters/webhook_duration.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 watchVerbs.Has(requestInfo.Verb) { handler.ServeHTTP(w, req) return } req = req.WithContext(request.WithLatencyTrackers(ctx))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 05 21:12:12 UTC 2024 - 2.1K bytes - Viewed (0) -
pilot/pkg/xds/lds.go
return true } // Otherwise, only handle full pushes (skip endpoint-only updates) if !req.Full { return false } default: if !req.Full { // LDS only handles full push return false } } // If none set, we will always push if len(req.ConfigsUpdated) == 0 { return true } for config := range req.ConfigsUpdated { if !skippedLdsConfigs[proxy.Type].Contains(config.Kind) { return true }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 15:58:06 UTC 2024 - 3.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/create.go
return func(w http.ResponseWriter, req *http.Request) { ctx := req.Context() // For performance tracking purposes. ctx, span := tracing.Start(ctx, "Create", traceFields(req)...) defer span.End(500 * time.Millisecond) namespace, name, err := scope.Namer.Name(req) if err != nil { if includeName { // name was required, return 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 - 10.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/watch_termination.go
// that it is shutting down. ctx = apirequest.WithServerShutdownSignal(req.Context(), termination) req = req.WithContext(ctx) defer wg.Done() handler.ServeHTTP(w, req) })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 27 15:49:49 UTC 2023 - 2K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/ioctl_zos.go
} // IoctlSetTermios performs an ioctl on fd with a *Termios. // // The req value is expected to be TCSETS, TCSETSW, or TCSETSF func IoctlSetTermios(fd int, req int, value *Termios) error { if (req != TCSETS) && (req != TCSETSW) && (req != TCSETSF) { return ENOSYS } err := Tcsetattr(fd, int(req), value) runtime.KeepAlive(value) return err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:33 UTC 2023 - 2K bytes - Viewed (0) -
src/net/http/client.go
req := ireq // req is either the original request, or a modified fork if rt == nil { req.closeBody() return nil, alwaysFalse, errors.New("http: no Client.Transport or DefaultTransport") } if req.URL == nil { req.closeBody() return nil, alwaysFalse, errors.New("http: nil Request.URL") } if req.RequestURI != "" { req.closeBody()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 06:06:11 UTC 2024 - 33.7K bytes - Viewed (0) -
pkg/registry/core/serviceaccount/storage/token.go
// Default unset spec audiences to API server audiences based on server config if len(req.Spec.Audiences) == 0 { req.Spec.Audiences = r.auds } // Populate metadata fields if not set if len(req.Name) == 0 { req.Name = svcacct.Name } if len(req.Namespace) == 0 { req.Namespace = svcacct.Namespace } // Save current time before building the token, to make sure the expiration
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 05 10:24:31 UTC 2024 - 10K bytes - Viewed (0)