Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for CompletePart (0.18 sec)

  1. cmd/object-api-multipart_test.go

    	}{
    		// Test cases with invalid bucket names (Test number 1-4).
    		{".test", "", "", []CompletePart{}, "", BucketNameInvalid{Bucket: ".test"}, false},
    		{"Test", "", "", []CompletePart{}, "", BucketNameInvalid{Bucket: "Test"}, false},
    		{"---", "", "", []CompletePart{}, "", BucketNameInvalid{Bucket: "---"}, false},
    		{"ad", "", "", []CompletePart{}, "", BucketNameInvalid{Bucket: "ad"}, false},
    		// Test cases for listing uploadID with single part.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 77.1K bytes
    - Viewed (0)
  2. cmd/object-api-utils_test.go

    	testCases := []struct {
    		parts          []CompletePart
    		expectedResult string
    		expectedErr    string
    	}{
    		// Wrong MD5 hash string, returns md5um of hash
    		{[]CompletePart{{ETag: "wrong-md5-hash-string"}}, "0deb8cb07527b4b2669c861cb9653607-1", ""},
    
    		// Single CompletePart with valid MD5 hash string.
    		{[]CompletePart{{ETag: "cf1f738a5924e645913c984e0fe3d708"}}, "10dc1617fbcf0bd0858048cb96e6bd77-1", ""},
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 23.4K bytes
    - Viewed (0)
  3. cmd/erasure-healing_test.go

    	}
    
    	var uploadedParts []CompletePart
    	for _, partID := range []int{2, 1} {
    		pInfo, err1 := objLayer.PutObjectPart(ctx, bucket, object, res.UploadID, partID, mustGetPutObjReader(t, bytes.NewReader(data), int64(len(data)), "", ""), opts)
    		if err1 != nil {
    			t.Fatalf("Failed to upload a part - %v", err1)
    		}
    		uploadedParts = append(uploadedParts, CompletePart{
    			PartNumber: pInfo.PartNumber,
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  4. cmd/object-api-datatypes.go

    	// Checksum values
    	ChecksumCRC32  string
    	ChecksumCRC32C string
    	ChecksumSHA1   string
    	ChecksumSHA256 string
    }
    
    // CompletePart - represents the part that was completed, this is sent by the client
    // during CompleteMultipartUpload request.
    type CompletePart struct {
    	// Part number identifying the part. This is a positive integer between 1 and
    	// 10,000
    	PartNumber int
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  5. cmd/object-handlers_test.go

    	inputParts := []struct {
    		parts []CompletePart
    	}{
    		// inputParts - 0.
    		// Case for replicating ETag mismatch.
    		{
    			[]CompletePart{
    				{ETag: "abcd", PartNumber: 1},
    			},
    		},
    		// inputParts - 1.
    		// should error out with part too small.
    		{
    			[]CompletePart{
    				{ETag: "e2fc714c4727ee9395f324cd2e7f331f", PartNumber: 1},
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 161.9K bytes
    - Viewed (0)
  6. cmd/erasure-server-pool-rebalance.go

    		if err != nil {
    			return fmt.Errorf("rebalanceObject: NewMultipartUpload() %w", err)
    		}
    		defer z.AbortMultipartUpload(ctx, bucket, oi.Name, res.UploadID, ObjectOptions{NoAuditLog: true})
    
    		parts := make([]CompletePart, len(oi.Parts))
    		for i, part := range oi.Parts {
    			hr, err := hash.NewReader(ctx, io.LimitReader(gr, part.Size), part.Size, "", "", part.ActualSize)
    			if err != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 03 15:45:54 UTC 2024
    - 27.3K bytes
    - Viewed (0)
  7. cmd/object-api-datatypes_gen.go

    			if err != nil {
    				err = msgp.WrapError(err, "Parts")
    				return
    			}
    			if cap(z.Parts) >= int(zb0002) {
    				z.Parts = (z.Parts)[:zb0002]
    			} else {
    				z.Parts = make([]CompletePart, zb0002)
    			}
    			for za0001 := range z.Parts {
    				bts, err = z.Parts[za0001].UnmarshalMsg(bts)
    				if err != nil {
    					err = msgp.WrapError(err, "Parts", za0001)
    					return
    				}
    			}
    		default:
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 70.1K bytes
    - Viewed (0)
  8. cmd/object-api-interface.go

    	AbortMultipartUpload(ctx context.Context, bucket, object, uploadID string, opts ObjectOptions) error
    	CompleteMultipartUpload(ctx context.Context, bucket, object, uploadID string, uploadedParts []CompletePart, opts ObjectOptions) (objInfo ObjectInfo, err error)
    
    	GetDisks(poolIdx, setIdx int) ([]StorageAPI, error) // return the disks belonging to pool and set.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon May 06 20:27:52 UTC 2024
    - 17K bytes
    - Viewed (0)
  9. cmd/erasure-server-pool-decom.go

    		if err != nil {
    			return fmt.Errorf("decommissionObject: NewMultipartUpload() %w", err)
    		}
    		defer z.AbortMultipartUpload(ctx, bucket, objInfo.Name, res.UploadID, ObjectOptions{NoAuditLog: true})
    		parts := make([]CompletePart, len(objInfo.Parts))
    		for i, part := range objInfo.Parts {
    			hr, err := hash.NewReader(ctx, io.LimitReader(gr, part.Size), part.Size, "", "", part.ActualSize)
    			if err != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 06 14:30:43 UTC 2024
    - 41.5K bytes
    - Viewed (1)
  10. cmd/object-api-putobject_test.go

    	if err != nil {
    		// Failed to upload object part, abort.
    		t.Fatalf("%s : %s", instanceType, err.Error())
    	}
    
    	// Complete multipart.
    	parts := []CompletePart{
    		{ETag: etag1, PartNumber: 1},
    		{ETag: etag2, PartNumber: 2},
    	}
    	_, err = obj.CompleteMultipartUpload(context.Background(), bucket, object, uploadID, parts, ObjectOptions{})
    	if err != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 25.8K bytes
    - Viewed (0)
Back to top