- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 377 for Freq (0.05 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/roundtripper.go
// connection. func (s *SpdyRoundTripper) RoundTrip(req *http.Request) (*http.Response, error) { req = utilnet.CloneRequest(req) req.Header.Add(httpstream.HeaderConnection, httpstream.HeaderUpgrade) req.Header.Add(httpstream.HeaderUpgrade, HeaderSpdy31) conn, err := s.Dial(req) if err != nil { return nil, err } responseReader := bufio.NewReader(conn)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 23 22:33:38 UTC 2023 - 12.7K 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) -
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) -
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) -
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/authentication/request/x509/x509.go
*/ remaining := req.TLS.PeerCertificates[0].NotAfter.Sub(time.Now()) clientCertificateExpirationHistogram.WithContext(req.Context()).Observe(remaining.Seconds()) chains, err := req.TLS.PeerCertificates[0].Verify(optsCopy) if err != nil { return nil, false, fmt.Errorf( "verifying certificate %s failed: %w", certificateIdentifier(req.TLS.PeerCertificates[0]), err, ) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 18 01:31:22 UTC 2023 - 10.3K bytes - Viewed (0) -
pilot/pkg/xds/delta.go
func (s *DiscoveryServer) processDeltaRequest(req *discovery.DeltaDiscoveryRequest, con *Connection) error { stype := v3.GetShortType(req.TypeUrl) deltaLog.Debugf("ADS:%s: REQ %s resources sub:%d unsub:%d nonce:%s", stype, con.ID(), len(req.ResourceNamesSubscribe), len(req.ResourceNamesUnsubscribe), req.ResponseNonce) if req.TypeUrl == v3.HealthInfoType {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/rest.go
return func(w http.ResponseWriter, req *http.Request) { if isDryRun(req.URL) { scope.err(errors.NewBadRequest("dryRun is not supported"), w, req) return } namespace, name, err := scope.Namer.Name(req) if err != nil { scope.err(err, w, req) return } ctx := req.Context() ctx = request.WithNamespace(ctx, namespace)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 17K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/delete.go
return func(w http.ResponseWriter, req *http.Request) { ctx := req.Context() // For performance tracking purposes. ctx, span := tracing.Start(ctx, "Delete", 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: Wed Mar 01 10:00:32 UTC 2023 - 11.4K bytes - Viewed (0) -
internal/rest/client.go
// variable to mean explicitly zero. if req.GetBody != nil && req.ContentLength == 0 { req.Body = http.NoBody req.GetBody = func() (io.ReadCloser, error) { return http.NoBody, nil } } } if c.newAuthToken != nil { req.Header.Set("Authorization", "Bearer "+c.newAuthToken(u.RawQuery)) } req.Header.Set("X-Minio-Time", time.Now().UTC().Format(time.RFC3339))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 14.4K bytes - Viewed (0)