- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 26 for body (0.15 sec)
-
cmd/handler-utils_test.go
// Corrupted XML malformedReq := &http.Request{ Body: io.NopCloser(bytes.NewReader([]byte("<>"))), ContentLength: int64(len("<>")), } // Not an XML badRequest := &http.Request{ Body: io.NopCloser(bytes.NewReader([]byte("garbage"))), ContentLength: int64(len("garbage")), } // generates the input request with XML bucket configuration set to the request body.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 6.1K bytes - Viewed (0) -
internal/config/cache/cache.go
} resp, err := c.clnt.Do(req) if err != nil { return nil, err } defer xhttp.DrainBody(resp.Body) switch resp.StatusCode { case http.StatusNotFound: return nil, ErrKeyMissing case http.StatusOK: co := &ObjectInfo{} return co, co.DecodeMsg(msgp.NewReader(resp.Body)) default: return nil, ErrInvalidArgument } } // Set sets the cache object info
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.6K bytes - Viewed (0) -
internal/config/identity/openid/providercfg.go
} client := &http.Client{ Transport: transport, } resp, err := client.Do(req) if err != nil { return nil, err } defer xhttp.DrainBody(resp.Body) if resp.StatusCode != http.StatusOK { // uncomment this for debugging when needed. // reqBytes, _ := httputil.DumpRequest(req, false) // fmt.Println(string(reqBytes))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 4.6K bytes - Viewed (0) -
cni/pkg/log/uds.go
if req.Body == nil { return } defer req.Body.Close() data, err := io.ReadAll(req.Body) if err != nil { log.Errorf("Failed to read log report from cni plugin: %v", err) return } l.processLog(data) } func (l *UDSLogger) processLog(body []byte) { cniLogs := make([]string, 0) err := json.Unmarshal(body, &cniLogs) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Nov 29 01:05:12 GMT 2023 - 3.3K bytes - Viewed (0) -
docs/iam/access-manager-plugin.go
} func mainHandler(w http.ResponseWriter, r *http.Request) { body, err := io.ReadAll(r.Body) if err != nil { writeErrorResponse(w, err) return } var out bytes.Buffer json.Indent(&out, body, "", " ") fmt.Printf("Received JSON payload:\n%s\n", out.String()) reqMap := make(map[string]interface{}) err = json.Unmarshal(body, &reqMap) if err != nil { writeErrorResponse(w, err) return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 08 17:15:20 GMT 2024 - 2.7K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher.go
} }) return nil } func (s *CniPluginServer) handleAddEvent(w http.ResponseWriter, req *http.Request) { if req.Body == nil { log.Error("empty request body") http.Error(w, "empty request body", http.StatusBadRequest) return } defer req.Body.Close() data, err := io.ReadAll(req.Body) if err != nil { log.Errorf("Failed to read event report from cni plugin: %v", err)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 6.1K bytes - Viewed (0) -
internal/grid/trace.go
Time: start, Proto: "grid", Method: "REQ", Client: local, Headers: nil, Path: t.Subroute, Body: []byte(body), }, RespInfo: madmin.TraceResponseInfo{ Time: end, Headers: nil, StatusCode: status, Body: []byte(bytesOrLength(resp)), }, CallStats: madmin.TraceCallStats{ InputBytes: len(req), OutputBytes: len(resp),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 02 22:54:54 GMT 2024 - 4K bytes - Viewed (0) -
cmd/bucket-versioning-handler.go
writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL) return } v, err := versioning.ParseConfig(io.LimitReader(r.Body, maxBucketVersioningConfigSize)) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } if globalSiteReplicationSys.isEnabled() && !v.Enabled() { writeErrorResponse(ctx, w, APIError{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 5K bytes - Viewed (0) -
cmd/warm-backend-azure.go
if err != nil { return nil, azureToObjectError(err, az.Bucket, object) } rc := blob.Body(azblob.RetryReaderOptions{}) return rc, nil } func (az *warmBackendAzure) Remove(ctx context.Context, object string, rv remoteVersionID) error {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 05 16:44:08 GMT 2024 - 7.8K bytes - Viewed (1) -
cni/pkg/plugin/cnieventclient_test.go
testServer := httptest.NewServer(http.HandlerFunc(func(res http.ResponseWriter, req *http.Request) { defer req.Body.Close() data, err := io.ReadAll(req.Body) assert.NoError(t, err) var msg nodeagent.CNIPluginAddEvent err = json.Unmarshal(data, &msg) assert.NoError(t, err) assert.Equal(t, msg.PodName, testPod)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 4.2K bytes - Viewed (0)