- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 100 for body (0.15 sec)
-
internal/config/policy/plugin/config.go
func (o *AuthZPlugin) IsAllowed(args policy.Args) (bool, error) { if o == nil { return false, nil } // Access Management Plugin Input body := make(map[string]interface{}) body["input"] = args inputBytes, err := json.Marshal(body) if err != nil { return false, err } req, err := http.NewRequest(http.MethodPost, o.args.URL.String(), bytes.NewReader(inputBytes)) if err != nil {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Sep 14 21:50:16 GMT 2023 - 5.8K bytes - Viewed (0) -
cmd/bucket-policy-handlers_test.go
t.Fatalf("Case %d: Expected the response status to be `%d`, but instead found `%d`", i+1, testCase.expectedRespStatus, recV4.Code) } // read the response body. bucketPolicyReadBuf, err := io.ReadAll(recV4.Body) if err != nil { t.Fatalf("Test %d: %s: Failed parsing response body: <ERROR> %v", i+1, instanceType, err) } if recV4.Code != testCase.expectedRespStatus {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 32.7K bytes - Viewed (0) -
istioctl/pkg/admin/istiodconfig.go
var scopeInfos []*ScopeInfo resp, err := c.httpClient.Get(c.baseURL.String()) if err != nil { return nil, err } defer resp.Body.Close() if resp.StatusCode != http.StatusOK { return nil, fmt.Errorf("request not successful %s", resp.Status) } err = json.NewDecoder(resp.Body).Decode(&scopeInfos) if err != nil { return nil, fmt.Errorf("cannot deserialize response %s", err) } return scopeInfos, nil }
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 13.5K bytes - Viewed (0) -
cmd/admin-handlers_test.go
{mgmtBucket: "bucket", mgmtPrefix: "objprefix"}, } // Body is always valid - we do not test JSON decoding. body := `{"recursive": false, "dryRun": true, "remove": false, "scanMode": 0}` // Test all combinations! for pIdx, params := range qParamsArr { for vIdx, vars := range varsArr { _, err := extractHealInitParams(vars, params, bytes.NewReader([]byte(body))) isErrCase := false if pIdx < 4 || vIdx < 1 {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.8K bytes - Viewed (0) -
cmd/perf-tests.go
client := &http.Client{ Transport: globalRemoteTargetTransport, } resp, err := client.Do(req) if err != nil { result.Error = err.Error() return } defer xhttp.DrainBody(resp.Body) err = gob.NewDecoder(resp.Body).Decode(&result) // endpoint have been overwritten result.Endpoint = rp.String() if err != nil { result.Error = err.Error() } return
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Jan 28 18:04:17 GMT 2024 - 11.3K bytes - Viewed (0) -
istioctl/pkg/kubeinject/kubeinject.go
if err != nil { return nil, err } defer resp.Body.Close() body, err := io.ReadAll(resp.Body) if err != nil { return nil, err } var obj runtime.Object var ar *kube.AdmissionReview out, _, err := deserializer.Decode(body, nil, obj) if err != nil { return nil, fmt.Errorf("could not decode body: %v", err) } ar, err = kube.AdmissionReviewKubeToAdapter(out) if err != nil {
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Mar 29 02:29:02 GMT 2024 - 21.6K bytes - Viewed (0) -
cmd/admin-handlers-idp-config.go
// More than maxConfigSize bytes were available writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrAdminConfigTooLarge), r.URL) return } // Ensure body content type is opaque to ensure that request body has not // been interpreted as form data. contentType := r.Header.Get("Content-Type") if contentType != "application/octet-stream" {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 12.7K bytes - Viewed (0) -
cmd/generic-handlers.go
atomic.AddUint64(&globalHTTPStats.rejectedRequestsHeader, 1) return } // Restricting read data to a given maximum length r.Body = http.MaxBytesReader(w, r.Body, requestMaxBodySize) h.ServeHTTP(w, r) }) } // Reserved bucket. const ( minioReservedBucket = "minio" minioReservedBucketPath = SlashSeparator + minioReservedBucket
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 11 01:08:52 GMT 2024 - 20.7K bytes - Viewed (0) -
cmd/routers.go
// prefix. setBrowserRedirectMiddleware, // Adds 'crossdomain.xml' policy middleware to serve legacy flash clients. setCrossDomainPolicyMiddleware, // Limits all body and header sizes to a maximum fixed limit setRequestLimitMiddleware, // Validate all the incoming requests. setRequestValidityMiddleware, // Add upload forwarding middleware for site replication
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 3.6K bytes - Viewed (1) -
src/archive/tar/tar_test.go
} if (formats == FormatUnknown) && (err == nil) { t.Errorf("test %d, got nil-error, want non-nil error", i) } } } func Benchmark(b *testing.B) { type file struct { hdr *Header body []byte } vectors := []struct { label string files []file }{{ "USTAR", []file{{ &Header{Name: "bar", Mode: 0640, Size: int64(3)}, []byte("foo"), }, {
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Fri Mar 15 16:01:50 GMT 2024 - 24K bytes - Viewed (0)