- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for ParseConfig (0.21 sec)
-
internal/event/config.go
rulesMap := make(RulesMap) for _, queue := range conf.QueueList { rulesMap.Add(queue.ToRulesMap()) } return rulesMap } // ParseConfig - parses data in reader to notification configuration. func ParseConfig(reader io.Reader, region string, targetList *TargetList) (*Config, error) { var config Config if err := xml.NewDecoder(reader).Decode(&config); err != nil { return nil, err
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Nov 16 17:28:29 GMT 2021 - 8.4K bytes - Viewed (0) -
internal/bucket/replication/replication.go
RoleArn string `xml:"Role" json:"Role"` } // Maximum 2MiB size per replication config. const maxReplicationConfigSize = 2 << 20 // ParseConfig parses ReplicationConfiguration from xml func ParseConfig(reader io.Reader) (*Config, error) { config := Config{} if err := xml.NewDecoder(io.LimitReader(reader, maxReplicationConfigSize)).Decode(&config); err != nil { return nil, err }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 8.9K bytes - Viewed (0) -
cmd/bucket-versioning-handler.go
if s3Error := checkRequestAuthType(ctx, r, policy.PutBucketVersioningAction, bucket, ""); s3Error != ErrNone { 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() {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 5K bytes - Viewed (0) -
internal/bucket/versioning/versioning.go
// prefixes or if ExcludeFolders is true. func (v Versioning) PrefixesExcluded() bool { return len(v.ExcludedPrefixes) > 0 || v.ExcludeFolders } // ParseConfig - parses data in given reader to VersioningConfiguration. func ParseConfig(reader io.Reader) (*Versioning, error) { var v Versioning if err := xml.NewDecoder(reader).Decode(&v); err != nil { return nil, err } if err := v.Validate(); err != nil {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 4.6K bytes - Viewed (0) -
cni/pkg/plugin/plugin.go
K8S_POD_NAMESPACE types.UnmarshallableString // nolint: revive, stylecheck K8S_POD_INFRA_CONTAINER_ID types.UnmarshallableString // nolint: revive, stylecheck } // parseConfig parses the supplied configuration (and prevResult) from stdin. func parseConfig(stdin []byte) (*Config, error) { conf := Config{} if err := json.Unmarshal(stdin, &conf); err != nil { return nil, fmt.Errorf("failed to parse network configuration: %v", err)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 10.4K bytes - Viewed (0) -
cmd/sts-handlers.go
if len(sessionPolicyStr) > 2048 { writeSTSErrorResponse(ctx, w, ErrSTSInvalidParameterValue, errSessionPolicyTooLarge) return } if len(sessionPolicyStr) > 0 { sessionPolicy, err := policy.ParseConfig(bytes.NewReader([]byte(sessionPolicyStr))) if err != nil { writeSTSErrorResponse(ctx, w, ErrSTSInvalidParameterValue, err) return } // Version in policy must not be empty
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 18:36:18 GMT 2024 - 34.7K bytes - Viewed (2) -
internal/bucket/replication/replication_test.go
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 32.5K bytes - Viewed (0) -
cni/pkg/plugin/plugin_test.go
} } func testCmdAddExpectFail(t *testing.T, stdinData string, objects ...runtime.Object) *mockInterceptRuleMgr { args := buildCmdArgs(stdinData, testPodName, testNSName) conf, err := parseConfig(args.StdinData) if err != nil { t.Fatalf("config parse failed with error: %v", err) } // Create a kube client client := kube.NewFakeClient(objects...) mockRedir := &mockInterceptRuleMgr{}
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 17.5K bytes - Viewed (0) -
internal/bucket/versioning/versioning_test.go
excludeFolders: true, }, } for i, tc := range testcases { var v *Versioning var err error v, err = ParseConfig(strings.NewReader(tc.input)) if tc.err != err { t.Fatalf("Test %d: expected %v but got %v", i+1, tc.err, err) } if err != nil { if tc.err == nil { t.Fatalf("Test %d: failed due to %v", i+1, err)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun May 08 05:06:44 GMT 2022 - 8.8K bytes - Viewed (0) -
cmd/bucket-notification-handlers.go
// PutBucketNotification always needs a Content-Length. if r.ContentLength <= 0 { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrMissingContentLength), r.URL) return } config, err := event.ParseConfig(io.LimitReader(r.Body, r.ContentLength), globalSite.Region, globalEventNotifier.targetList) if err != nil { apiErr := errorCodes.ToAPIErr(ErrMalformedXML) if event.IsEventError(err) { apiErr = toAPIError(ctx, err)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 5.1K bytes - Viewed (0)