Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for NewBadRequest (0.42 sec)

  1. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/get.go

    					err := runtime.Convert_Slice_string_To_bool(&exportStrings, &exportBool, nil)
    					if err != nil {
    						return nil, errors.NewBadRequest(fmt.Sprintf("the export parameter cannot be parsed: %v", err))
    					}
    					if exportBool {
    						return nil, errors.NewBadRequest("the export parameter, deprecated since v1.14, is no longer supported")
    					}
    				}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 16 10:22:16 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/patch.go

    				return nil, nil, errors.NewBadRequest(fmt.Sprintf("error decoding patch: %v", err))
    			}
    			for i, e := range strictErrors {
    				strictErrors[i] = fmt.Errorf("json patch %v", e)
    			}
    		}
    
    		patchObj, err := jsonpatch.DecodePatch(p.patchBytes)
    		if err != nil {
    			return nil, nil, errors.NewBadRequest(err.Error())
    		}
    		if len(patchObj) > maxJSONPatchOperations {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 28.5K bytes
    - Viewed (0)
  3. pkg/registry/core/serviceaccount/storage/token.go

    	req := obj.(*authenticationapi.TokenRequest)
    
    	// Get the namespace from the context (populated from the URL).
    	namespace, ok := genericapirequest.NamespaceFrom(ctx)
    	if !ok {
    		return nil, errors.NewBadRequest("namespace is required")
    	}
    
    	// require name/namespace in the body to match URL if specified
    	if len(req.Name) > 0 && req.Name != name {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 05 10:24:31 UTC 2024
    - 10K bytes
    - Viewed (0)
  4. pkg/registry/core/pod/strategy.go

    				return true
    			})
    			errStr := fmt.Sprintf("a container name must be specified for pod %s, choose one of: %s", pod.Name, containerNames)
    			return "", errors.NewBadRequest(errStr)
    		}
    	} else {
    		if !podHasContainerWithName(pod, container) {
    			return "", errors.NewBadRequest(fmt.Sprintf("container %s is not valid for pod %s", container, pod.Name))
    		}
    	}
    
    	return container, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 17:51:48 UTC 2024
    - 29.8K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/mutating/dispatcher.go

    	}
    	// Make the webhook request
    	client, err := invocation.Webhook.GetRESTClient(a.cm)
    	if err != nil {
    		return false, &webhookutil.ErrCallingWebhook{WebhookName: h.Name, Reason: fmt.Errorf("could not get REST client: %w", err), Status: apierrors.NewBadRequest("error getting REST client")}
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  6. pkg/registry/core/node/strategy.go

    	if !valid {
    		return nil, nil, errors.NewBadRequest(fmt.Sprintf("invalid node request %q", id))
    	}
    
    	info, err := connection.GetConnectionInfo(ctx, types.NodeName(name))
    	if err != nil {
    		return nil, nil, err
    	}
    
    	if err := isProxyableHostname(ctx, info.Hostname); err != nil {
    		return nil, nil, errors.NewBadRequest(err.Error())
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 13 23:06:39 UTC 2024
    - 9K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go

    	var withRev int64
    	// Uses continueRV if this is a continuation request.
    	if len(continueKey) > 0 {
    		if len(opts.ResourceVersion) > 0 && opts.ResourceVersion != "0" {
    			return withRev, apierrors.NewBadRequest("specifying resource version is not allowed when using continue")
    		}
    		// If continueRV > 0, the LIST request needs a specific resource version.
    		// continueRV==0 is invalid.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 11:56:42 UTC 2024
    - 35.2K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/endpoints/filters/request_deadline.go

    			return
    		}
    		if longRunning(req, requestInfo) {
    			handler.ServeHTTP(w, req)
    			return
    		}
    
    		userSpecifiedTimeout, ok, err := parseTimeout(req)
    		if err != nil {
    			statusErr := apierrors.NewBadRequest(err.Error())
    
    			klog.Errorf("Error - %s: %#v", err.Error(), req.RequestURI)
    
    			failed := failedErrorHandler(negotiatedSerializer, statusErr)
    			failWithAudit := withFailedRequestAudit(failed, statusErr, sink, policy)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 05 21:12:12 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  9. pkg/registry/core/pod/strategy_test.go

    				ObjectMeta: metav1.ObjectMeta{Name: fakePodName},
    				Spec:       api.PodSpec{},
    				Status:     api.PodStatus{},
    			},
    			opts:              &api.PodLogOptions{},
    			expectedErr:       errors.NewBadRequest("a container name must be specified for pod test"),
    			expectedTransport: nil,
    		},
    		{
    			name: "choice of two containers",
    			in: &api.Pod{
    				ObjectMeta: metav1.ObjectMeta{Name: fakePodName},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 76.2K bytes
    - Viewed (0)
  10. plugin/pkg/admission/runtimeclass/admission.go

    	pod, ok := attributes.GetObject().(*api.Pod)
    	if !ok {
    		return nil, nil, apierrors.NewBadRequest("Resource was marked with kind Pod but was unable to be converted")
    	}
    
    	if pod.Spec.RuntimeClassName == nil {
    		return pod, nil, nil
    	}
    
    	// get RuntimeClass object
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 05 05:53:38 UTC 2024
    - 8.9K bytes
    - Viewed (0)
Back to top