Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for limitedReadBody (0.25 sec)

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

    			if err != nil {
    				span.AddEvent("limitedReadBody failed", attribute.Int("len", len(body)), attribute.String("err", err.Error()))
    				scope.err(err, w, req)
    				return
    			}
    			span.AddEvent("limitedReadBody succeeded", attribute.Int("len", len(body)))
    			if len(body) > 0 {
    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

    		if err != nil {
    			span.AddEvent("limitedReadBody failed", attribute.Int("len", len(body)), attribute.String("err", err.Error()))
    			scope.err(err, w, req)
    			return
    		}
    		span.AddEvent("limitedReadBody succeeded", attribute.Int("len", len(body)))
    
    		options := &metav1.UpdateOptions{}
    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

    		if err != nil {
    			span.AddEvent("limitedReadBody failed", attribute.Int("len", len(body)), attribute.String("err", err.Error()))
    			scope.err(err, w, req)
    			return
    		}
    		span.AddEvent("limitedReadBody succeeded", attribute.Int("len", len(body)))
    
    		options := &metav1.CreateOptions{}
    		values := req.URL.Query()
    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

    		}
    		return string(data)
    	default:
    		if len(data) > maxLength {
    			return hex.EncodeToString(data[:maxLength]) + " ..."
    		}
    		return hex.EncodeToString(data)
    	}
    }
    
    func limitedReadBody(req *http.Request, limit int64) ([]byte, error) {
    	defer req.Body.Close()
    	if limit <= 0 {
    		return ioutil.ReadAll(req.Body)
    	}
    	lr := &io.LimitedReader{
    		R: req.Body,
    		N: limit + 1,
    	}
    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

    		if err != nil {
    			span.AddEvent("limitedReadBody failed", attribute.Int("len", len(patchBytes)), attribute.String("err", err.Error()))
    			scope.err(err, w, req)
    			return
    		}
    		span.AddEvent("limitedReadBody succeeded", attribute.Int("len", len(patchBytes)))
    
    		options := &metav1.PatchOptions{}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 28.5K bytes
    - Viewed (0)
Back to top