Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for limitedReadBodyWithRecordMetric (0.36 sec)

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

    		if err != nil {
    			scope.err(err, w, req)
    			return
    		}
    
    		options := &metav1.DeleteOptions{}
    		if allowsOptions {
    			body, err := limitedReadBodyWithRecordMetric(ctx, req, scope.MaxRequestBodyBytes, scope.Resource.GroupResource().String(), requestmetrics.Delete)
    			if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 01 10:00:32 UTC 2023
    - 11.4K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/update.go

    		outputMediaType, _, err := negotiation.NegotiateOutputMediaType(req, scope.Serializer, scope)
    		if err != nil {
    			scope.err(err, w, req)
    			return
    		}
    
    		body, err := limitedReadBodyWithRecordMetric(ctx, req, scope.MaxRequestBodyBytes, scope.Resource.GroupResource().String(), requestmetrics.Update)
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 01 20:19:46 UTC 2023
    - 11.5K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/create.go

    		}
    
    		gv := scope.Kind.GroupVersion()
    		s, err := negotiation.NegotiateInputSerializer(req, false, scope.Serializer)
    		if err != nil {
    			scope.err(err, w, req)
    			return
    		}
    
    		body, err := limitedReadBodyWithRecordMetric(ctx, req, scope.MaxRequestBodyBytes, scope.Resource.GroupResource().String(), requestmetrics.Create)
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 01 20:19:46 UTC 2023
    - 10.1K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/rest.go

    	if err != nil {
    		return nil, err
    	}
    	if lr.N <= 0 {
    		return nil, errors.NewRequestEntityTooLargeError(fmt.Sprintf("limit is %d", limit))
    	}
    	return data, nil
    }
    
    func limitedReadBodyWithRecordMetric(ctx context.Context, req *http.Request, limit int64, resourceGroup string, verb requestmetrics.RequestBodyVerb) ([]byte, error) {
    	readBody, err := limitedReadBody(req, limit)
    	if err == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 21:44:00 UTC 2023
    - 17K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/patch.go

    		outputMediaType, _, err := negotiation.NegotiateOutputMediaType(req, scope.Serializer, scope)
    		if err != nil {
    			scope.err(err, w, req)
    			return
    		}
    
    		patchBytes, err := limitedReadBodyWithRecordMetric(ctx, req, scope.MaxRequestBodyBytes, scope.Resource.GroupResource().String(), requestmetrics.Patch)
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 28.5K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/rest_test.go

    			defer legacyregistry.Reset()
    
    			req, err := http.NewRequest("POST", "/", tc.requestBody)
    			if err != nil {
    				t.Errorf("err not expected: got %v", err)
    			}
    			_, err = limitedReadBodyWithRecordMetric(context.Background(), req, tc.limit, "resource.group", metrics.Create)
    			if tc.expectedErr {
    				if err == nil {
    					t.Errorf("err expected: got nil")
    				}
    				return
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 41.8K bytes
    - Viewed (0)
Back to top