- Sort Score
- Num 10 results
- Language All
Results 1 - 8 of 8 for ParseConfig (0.05 seconds)
-
internal/bucket/replication/replication_test.go
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 32.4K bytes - Click Count (0) -
cmd/bucket-metadata.go
b.versioningConfig, err = versioning.ParseConfig(bytes.NewReader(b.VersioningConfigXML)) if err != nil { return err } } if len(b.QuotaConfigJSON) != 0 { b.quotaConfig, err = parseBucketQuota(b.Name, b.QuotaConfigJSON) if err != nil { return err } } if len(b.ReplicationConfigXML) != 0 { b.replicationConfig, err = replication.ParseConfig(bytes.NewReader(b.ReplicationConfigXML))
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 18.2K bytes - Click Count (0) -
cmd/bucket-replication-handlers.go
} if versioned := globalBucketVersioningSys.Enabled(bucket); !versioned { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrReplicationNeedsVersioningError), r.URL) return } replicationConfig, err := replication.ParseConfig(io.LimitReader(r.Body, r.ContentLength)) if err != nil { apiErr := errorCodes.ToAPIErr(ErrMalformedXML) apiErr.Description = err.Error() writeErrorResponse(ctx, w, apiErr, r.URL) return }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Aug 15 12:04:40 GMT 2024 - 23.3K bytes - Click Count (0) -
cmd/admin-bucket-handlers.go
if fileName == bucketVersioningConfig { reader, err := file.Open() if err != nil { rpt.SetStatus(bucket, fileName, err) continue } v, err := versioning.ParseConfig(io.LimitReader(reader, maxBucketVersioningConfigSize)) if err != nil { rpt.SetStatus(bucket, fileName, err) continue } if _, ok := bucketMap[bucket]; !ok {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 33.3K bytes - Click Count (0) -
cmd/admin-handlers-site-replication.go
case madmin.SRIAMItemPolicy: if item.Policy == nil { err = globalSiteReplicationSys.PeerAddPolicyHandler(ctx, item.Name, nil, item.UpdatedAt) } else { policy, perr := policy.ParseConfig(bytes.NewReader(item.Policy)) if perr != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, perr), r.URL) return } if policy.IsEmpty() {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 19.4K bytes - Click Count (0) -
cmd/kms-handlers_test.go
if err != nil { t.Fatal(err) } testKMSPolicyName := "testKMSPolicy" if p != "" { p = `{"Version":"2012-10-17","Statement":[` + p + `]}` policyData, err := policy.ParseConfig(strings.NewReader(p)) if err != nil { t.Fatal(err) } _, err = globalIAMSys.SetPolicy(ctx, testKMSPolicyName, *policyData) if err != nil { t.Fatal(err) }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 22.3K bytes - Click Count (0) -
internal/event/config_test.go
{reader2, "us-east-1", targetList2, false}, } for i, testCase := range testCases { if _, err := testCase.reader.Seek(0, 0); err != nil { panic(err) } _, err := ParseConfig(testCase.reader, testCase.region, testCase.targetList) expectErr := (err != nil) if expectErr != testCase.expectErr { t.Fatalf("test %v: error: expected: %v, got: %v", i+1, testCase.expectErr, expectErr) }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 28.9K bytes - Click Count (0) -
cmd/sts-handlers.go
if len(form) == 0 { return nil } sessionPolicyStr := form.Get(stsPolicy) if len(sessionPolicyStr) == 0 { return nil } sessionPolicy, err := policy.ParseConfig(bytes.NewReader([]byte(sessionPolicyStr))) if err != nil { return err } // Version in policy must not be empty if sessionPolicy.Version == "" {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 36.6K bytes - Click Count (0)