- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 650 for Req (0.04 sec)
-
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) -
pilot/pkg/xds/workload.go
func (e WorkloadGenerator) GenerateDeltas( proxy *model.Proxy, req *model.PushRequest, w *model.WatchedResource, ) (model.Resources, model.DeletedResources, model.XdsLogDetails, bool, error) { updatedAddresses := model.ConfigNameOfKind(req.ConfigsUpdated, kind.Address) isReq := req.IsRequest() if len(updatedAddresses) == 0 && len(req.ConfigsUpdated) > 0 { // Nothing changed..
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 14:14:30 UTC 2024 - 8.7K bytes - Viewed (0) -
internal/kms/secret-key.go
if req.Name != s.keyID { return ErrNotSupported } return ErrKeyExists } // GenerateKey decrypts req.Ciphertext. The key name req.Name must match the key // name of the secretKey. // // The returned DEK is encrypted using AES-GCM and the ciphertext format is compatible // with KES and MinKMS.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 07 23:55:37 UTC 2024 - 8.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/metrics/metrics.go
func RecordRequestAbort(req *http.Request, requestInfo *request.RequestInfo) { if requestInfo == nil { requestInfo = &request.RequestInfo{Verb: req.Method, Path: req.URL.Path} } scope := CleanScope(requestInfo) reportedVerb := cleanVerb(CanonicalVerb(strings.ToUpper(req.Method), scope), "", req, requestInfo) resource := requestInfo.Resource
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 07:29:19 UTC 2023 - 35K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/httplog/httplog.go
return rl } return nil } func respLoggerFromRequest(req *http.Request) *respLogger { return respLoggerFromContext(req.Context()) } func newLoggedWithStartTime(req *http.Request, w http.ResponseWriter, startTime time.Time) *respLogger { logger := &respLogger{ startTime: startTime, req: req, userAgent: req.UserAgent(), w: w,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 07 10:10:35 UTC 2023 - 9.7K bytes - Viewed (0) -
pkg/apis/certificates/v1beta1/defaults_test.go
t.Fatal(err) } return csr } tests := map[string]struct { req *x509.CertificateRequest usages []capi.KeyUsage exp bool }{ "defaults for kubelet-serving": { req: newCSR(kubeletServerPEMOptions), usages: kubeletServerUsages, exp: true, }, "defaults without key encipherment for kubelet-serving": { req: newCSR(kubeletServerPEMOptions), usages: kubeletServerUsagesNoRSA,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 27 08:04:25 UTC 2022 - 16.9K bytes - Viewed (0)