Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 144 for unmarshaled (0.13 sec)

  1. internal/config/crypto.go

    		metadata       encryptedObject
    	)
    	if _, err := io.ReadFull(ciphertext, metadataBuffer); err != nil {
    		return nil, err
    	}
    	json := jsoniter.ConfigCompatibleWithStandardLibrary
    	if err := json.Unmarshal(metadataBuffer, &metadata); err != nil {
    		return nil, err
    	}
    	if fips.Enabled && metadata.Algorithm != sio.AES_256_GCM {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 07 23:55:37 UTC 2024
    - 5K bytes
    - Viewed (0)
  2. internal/bucket/lifecycle/rule_test.go

    			expectedErr: errInvalidRuleDelMarkerExpiration,
    		},
    	}
    
    	for i, tc := range invalidTestCases {
    		t.Run(fmt.Sprintf("Test %d", i+1), func(t *testing.T) {
    			var rule Rule
    			err := xml.Unmarshal([]byte(tc.inputXML), &rule)
    			if err != nil {
    				t.Fatal(err)
    			}
    
    			if err := rule.Validate(); err != tc.expectedErr {
    				t.Fatalf("%d: Expected %v but got %v", i+1, tc.expectedErr, err)
    			}
    		})
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 01 01:11:10 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  3. internal/event/arn_test.go

    		{[]byte("<ARN>arn:minio:sqs:us-east-1:1:webhook</ARN>"), &ARN{TargetID{"1", "webhook"}, "us-east-1"}, false},
    	}
    
    	for i, testCase := range testCases {
    		arn := &ARN{}
    		err := xml.Unmarshal(testCase.data, &arn)
    		expectErr := (err != nil)
    
    		if expectErr != testCase.expectErr {
    			t.Fatalf("test %v: error: expected: %v, got: %v", i+1, testCase.expectErr, expectErr)
    		}
    
    		if !testCase.expectErr {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 3.8K bytes
    - Viewed (0)
  4. soft_delete.go

    	if n.Valid {
    		return json.Marshal(n.Time)
    	}
    	return json.Marshal(nil)
    }
    
    func (n *DeletedAt) UnmarshalJSON(b []byte) error {
    	if string(b) == "null" {
    		n.Valid = false
    		return nil
    	}
    	err := json.Unmarshal(b, &n.Time)
    	if err == nil {
    		n.Valid = true
    	}
    	return err
    }
    
    func (DeletedAt) QueryClauses(f *schema.Field) []clause.Interface {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Feb 01 06:40:55 UTC 2023
    - 4.5K bytes
    - Viewed (0)
  5. cmd/bucket-quota.go

    	return BucketUsageInfo{}
    }
    
    // parseBucketQuota parses BucketQuota from json
    func parseBucketQuota(bucket string, data []byte) (quotaCfg *madmin.BucketQuota, err error) {
    	quotaCfg = &madmin.BucketQuota{}
    	if err = json.Unmarshal(data, quotaCfg); err != nil {
    		return quotaCfg, err
    	}
    	if !quotaCfg.IsValid() {
    		if quotaCfg.Type == "fifo" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 00:34:56 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  6. internal/bucket/encryption/bucket-sse-config.go

    	// AWSKms is used with SSE-KMS
    	AWSKms Algorithm = "aws:kms"
    )
    
    // Algorithm - represents valid SSE algorithms supported; currently only AES256 is supported
    type Algorithm string
    
    // UnmarshalXML - Unmarshals XML tag to valid SSE algorithm
    func (alg *Algorithm) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
    	var s string
    	if err := d.DecodeElement(&s, &start); err != nil {
    		return err
    	}
    
    	switch s {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 25 00:44:15 UTC 2022
    - 4.9K bytes
    - Viewed (0)
  7. cmd/site-replication-utils_gen.go

    	o, err = z.TargetReplicationResyncStatus.MarshalMsg(o)
    	if err != nil {
    		err = msgp.WrapError(err, "TargetReplicationResyncStatus")
    		return
    	}
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *SiteResyncStatus) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, bts, err = msgp.ReadMapHeaderBytes(bts)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Nov 14 15:16:40 UTC 2022
    - 7.2K bytes
    - Viewed (0)
  8. cmd/metacache-walk_gen.go

    	o = msgp.AppendInt(o, z.Limit)
    	// string "DiskID"
    	o = append(o, 0xa6, 0x44, 0x69, 0x73, 0x6b, 0x49, 0x44)
    	o = msgp.AppendString(o, z.DiskID)
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *WalkDirOptions) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, bts, err = msgp.ReadMapHeaderBytes(bts)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 7K bytes
    - Viewed (0)
  9. cmd/data-usage.go

    			}
    			return DataUsageInfo{}, toObjectErr(err, minioMetaBucket, dataUsageObjNamePath)
    		}
    	}
    
    	var dataUsageInfo DataUsageInfo
    	json := jsoniter.ConfigCompatibleWithStandardLibrary
    	if err = json.Unmarshal(buf, &dataUsageInfo); err != nil {
    		return DataUsageInfo{}, err
    	}
    	// For forward compatibility reasons, we need to add this code.
    	if len(dataUsageInfo.BucketsUsage) == 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  10. cmd/bucket-targets.go

    	if len(cmetadata) != 0 {
    		if err := json.Unmarshal(cmetadata, &meta); err != nil {
    			return nil, err
    		}
    		if crypto.S3.IsEncrypted(meta) {
    			if data, err = decryptBucketMetadata(cdata, bucket, meta, kms.Context{
    				bucket:            bucket,
    				bucketTargetsFile: bucketTargetsFile,
    			}); err != nil {
    				return nil, err
    			}
    		}
    	}
    
    	if err = json.Unmarshal(data, &t); err != nil {
    		return nil, err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 20.9K bytes
    - Viewed (0)
Back to top