Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 41 for userDefined (0.14 sec)

  1. cmd/object-api-utils.go

    func (o *ObjectInfo) IsCompressed() bool {
    	_, ok := o.UserDefined[ReservedMetadataPrefix+"compression"]
    	return ok
    }
    
    // IsCompressedOK returns whether the object is compressed and can be decompressed.
    func (o *ObjectInfo) IsCompressedOK() (bool, error) {
    	scheme, ok := o.UserDefined[ReservedMetadataPrefix+"compression"]
    	if !ok {
    		return false, nil
    	}
    	switch scheme {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  2. cmd/erasure-object_test.go

    	metadata2 := make(map[string]string)
    	metadata2["x-amz-storage-class"] = storageclass.RRS
    	_, err = obj.PutObject(ctx, bucket, object2, mustGetPutObjReader(t, bytes.NewReader(data), int64(len(data)), "", ""), ObjectOptions{UserDefined: metadata2})
    	if err != nil {
    		t.Fatalf("Failed to putObject %v", err)
    	}
    
    	parts2, errs2 := readAllFileInfo(ctx, erasureDisks, "", bucket, object2, "", false, false)
    	parts2SC := globalStorageClass
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool-rebalance.go

    	if err != nil {
    		return err
    	}
    
    	if oi.isMultipart() {
    		res, err := z.NewMultipartUpload(ctx, bucket, oi.Name, ObjectOptions{
    			VersionID:    oi.VersionID,
    			UserDefined:  oi.UserDefined,
    			NoAuditLog:   true,
    			DataMovement: true,
    			SrcPoolIdx:   poolIdx,
    		})
    		if err != nil {
    			return fmt.Errorf("rebalanceObject: NewMultipartUpload() %w", err)
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  4. cmd/api-response.go

    		}
    		if tagErr == ErrNone {
    			content.UserTags = object.UserTags
    		}
    		if metaErr == ErrNone {
    			content.UserMetadata = &Metadata{}
    			switch kind, _ := crypto.IsEncrypted(object.UserDefined); kind {
    			case crypto.S3:
    				content.UserMetadata.Set(xhttp.AmzServerSideEncryption, xhttp.AmzEncryptionAES)
    			case crypto.S3KMS:
    				content.UserMetadata.Set(xhttp.AmzServerSideEncryption, xhttp.AmzEncryptionKMS)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 19:27:06 UTC 2024
    - 33.4K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool-decom.go

    	if err != nil {
    		return err
    	}
    
    	if objInfo.isMultipart() {
    		res, err := z.NewMultipartUpload(ctx, bucket, objInfo.Name, ObjectOptions{
    			VersionID:    objInfo.VersionID,
    			UserDefined:  objInfo.UserDefined,
    			NoAuditLog:   true,
    			SrcPoolIdx:   idx,
    			DataMovement: true,
    		})
    		if err != nil {
    			return fmt.Errorf("decommissionObject: NewMultipartUpload() %w", err)
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  6. cmd/object-api-putobject_test.go

    		objInfo, actualErr := obj.PutObject(context.Background(), testCase.bucketName, testCase.objName, in, ObjectOptions{UserDefined: testCase.inputMeta})
    		if actualErr != nil && testCase.expectedError == nil {
    			t.Errorf("Test %d: %s: Expected to pass, but failed with: error %s.", i, instanceType, actualErr.Error())
    			continue
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 25.8K bytes
    - Viewed (0)
  7. cmd/bucket-lifecycle.go

    		return ObjectOptions{
    			Versioned:        globalBucketVersioningSys.PrefixEnabled(bucket, object),
    			VersionSuspended: globalBucketVersioningSys.PrefixSuspended(bucket, object),
    			UserDefined:      meta,
    		}
    	}
    	for k, v := range objInfo.UserDefined {
    		meta[k] = v
    	}
    	if len(objInfo.UserTags) != 0 {
    		meta[xhttp.AmzObjectTagging] = objInfo.UserTags
    	}
    	// Set restore object status
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  8. cmd/object-api-interface.go

    	CheckDMReplicationReady bool // Is delete marker ready to be replicated - set only during HEAD
    	Tagging                 bool // Is only in GET/HEAD operations to return tagging metadata along with regular metadata and body.
    
    	UserDefined         map[string]string   // only set in case of POST/PUT operations
    	ObjectAttributes    map[string]struct{} // Attribute tags defined by the users for the GetObjectAttributes request
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  9. cmd/object-api-listobjects_test.go

    			int64(len(object.content)), hex.EncodeToString(md5Bytes[:]), ""), ObjectOptions{
    			Versioned:   globalBucketVersioningSys.PrefixEnabled(object.parentBucket, object.name),
    			UserDefined: object.meta,
    		})
    		if err != nil {
    			t.Fatalf("%s : %s", instanceType, err.Error())
    		}
    		if object.addDeleteMarker {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 01 11:07:40 UTC 2024
    - 73.1K bytes
    - Viewed (0)
  10. cmd/post-policy_test.go

    			if err != nil {
    				t.Error("Unexpected error: ", err)
    			}
    			for k, v := range testCase.expectedHeaders {
    				if objInfo.UserDefined[k] != v {
    					t.Errorf("Expected to have header %s with value %s, but found value `%s` instead", k, v, objInfo.UserDefined[k])
    				}
    			}
    		}
    	}
    
    	region := "us-east-1"
    	// Test cases for signature-V4.
    	testCasesV4BadData := []struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 30.2K bytes
    - Viewed (0)
Back to top