- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 79 for body (0.15 sec)
-
cmd/bucket-encryption-handlers.go
writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } // Parse bucket encryption xml encConfig, err := validateBucketSSEConfig(io.LimitReader(r.Body, maxBucketSSEConfigSize)) if err != nil { apiErr := APIError{ Code: "MalformedXML", Description: fmt.Sprintf("%s (%s)", errorCodes[ErrMalformedXML].Description, err),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.4K bytes - Viewed (0) -
cmd/update.go
} } defer xhttp.DrainBody(resp.Body) if resp.StatusCode != http.StatusOK { return content, AdminError{ Code: AdminUpdateUnexpectedFailure, Message: fmt.Sprintf("Error downloading URL %s. Response: %v", u, resp.Status), StatusCode: resp.StatusCode, } } contentBytes, err := io.ReadAll(resp.Body) if err != nil { return content, AdminError{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 18.7K bytes - Viewed (0) -
istioctl/pkg/internaldebug/internal-debug_test.go
NegotiatedSerializer: resource.UnstructuredPlusDefaultContentConfig().NegotiatedSerializer, Resp: &http.Response{ StatusCode: http.StatusOK, Header: cmdtesting.DefaultHeader(), Body: cmdtesting.ObjBody(codec, cmdtesting.NewInternalType("", "", "foo")), }, } return tf }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 08:28:50 GMT 2024 - 4.5K bytes - Viewed (0) -
cmd/bucket-policy-handlers.go
if r.ContentLength > maxBucketPolicySize { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrPolicyTooLarge), r.URL) return } bucketPolicyBytes, err := io.ReadAll(io.LimitReader(r.Body, r.ContentLength)) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } bucketPolicy, err := policy.ParseBucketPolicyConfig(bytes.NewReader(bucketPolicyBytes), bucket)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.1K bytes - Viewed (0) -
cmd/admin-router.go
} return gz }() // Set of handler options as bit flags type hFlag uint8 const ( // this flag disables gzip compression of responses noGZFlag = 1 << iota // this flag enables tracing body and headers instead of just headers traceAllFlag // pass this flag to skip checking if object layer is available noObjLayerFlag ) // Has checks if the given flag is enabled in `h`.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 21:09:36 GMT 2024 - 25.5K bytes - Viewed (0) -
cmd/api-errors.go
Code: "InvalidStorageClass", Description: "Invalid storage class.", HTTPStatusCode: http.StatusBadRequest, }, ErrInvalidRequestBody: { Code: "InvalidArgument", Description: "Body shouldn't be set for this request.", HTTPStatusCode: http.StatusBadRequest, }, ErrInvalidMaxUploads: { Code: "InvalidArgument",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 91.4K bytes - Viewed (7) -
internal/http/response-recorder.go
lrw.headerBytesWritten += n } } // blobBody returns a dummy body placeholder for blob (binary stream) var blobBody = []byte("<BLOB>") // gzippedBody returns a dummy body placeholder for gzipped content var gzippedBody = []byte("<GZIP>") // Body - Return response body. func (lrw *ResponseRecorder) Body() []byte { if lrw.Header().Get("Content-Encoding") == "gzip" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 02 00:13:19 GMT 2023 - 4.9K bytes - Viewed (0) -
cmd/object-handlers.go
End: -1, } opts.NoLock = true return getObjectNInfo(ctx, bucket, object, rs, r.Header, opts) }, actualSize, ) defer objectRSC.Close() s3Select, err := s3select.NewS3Select(r.Body) if err != nil { if serr, ok := err.(s3select.SelectError); ok { encodedErrorResponse := encodeResponse(APIErrorResponse{ Code: serr.ErrorCode(), Message: serr.ErrorMessage(),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0) -
cmd/admin-handlers-site-replication.go
if err := parseJSONBody(ctx, r.Body, &sites, cred.SecretKey); err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } opts := getSRAddOptions(r) status, err := globalSiteReplicationSys.AddPeerClusters(ctx, sites, opts) if err != nil { adminLogIf(ctx, err) writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } body, err := json.Marshal(status)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 09:40:39 GMT 2024 - 19.4K bytes - Viewed (0) -
cmd/streaming-signature-v4.go
for _, key := range trailers { req.Trailer.Add(key, "") } } else { req.Trailer = nil } return &s3ChunkedReader{ trailers: req.Trailer, reader: bufio.NewReader(req.Body), cred: cred, seedSignature: seedSignature, seedDate: seedDate, region: region, chunkSHA256Writer: sha256.New(), buffer: make([]byte, 64*1024),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 18.2K bytes - Viewed (0)