Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for CompletePart (0.28 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/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)
  3. 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)
  4. cmd/batch-handlers.go

    		tgtObject = pathJoin(r.Target.Prefix, srcObjInfo.Name)
    	}
    	if r.Target.Type == BatchJobReplicateResourceS3 || r.Source.Type == BatchJobReplicateResourceS3 {
    		opts.VersionID = ""
    	}
    	var uploadedParts []CompletePart
    	res, err := api.NewMultipartUpload(context.Background(), tgtBucket, tgtObject, opts)
    	if err != nil {
    		return err
    	}
    
    	defer func() {
    		if err != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jun 11 03:13:30 UTC 2024
    - 56K bytes
    - Viewed (0)
  5. cmd/erasure-object.go

    	}
    
    	res, err := er.NewMultipartUpload(ctx, bucket, object, ropts)
    	if err != nil {
    		return setRestoreHeaderFn(oi, err)
    	}
    
    	var uploadedParts []CompletePart
    	var rs *HTTPRangeSpec
    	// get reader from the warm backend - note that even in the case of encrypted objects, this stream is still encrypted.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 78.6K bytes
    - Viewed (0)
  6. cmd/test-utils_test.go

    		err = decoder.Decode(multipartResponse)
    		if err != nil {
    			t.Fatalf("Error decoding the recorded response Body")
    		}
    		upID := multipartResponse.UploadID
    
    		// Upload each part
    		var cp []CompletePart
    		cumulativeSum := int64(0)
    		for i, partLen := range partSizes {
    			partID := i + 1
    			partSrc := NewDummyDataGen(partLen, cumulativeSum)
    			cumulativeSum += partLen
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 76.9K bytes
    - Viewed (0)
  7. cmd/erasure-server-pool.go

    // CompleteMultipartUpload - completes a pending multipart transaction, on hashedSet based on object name.
    func (z *erasureServerPools) CompleteMultipartUpload(ctx context.Context, bucket, object, uploadID string, uploadedParts []CompletePart, opts ObjectOptions) (objInfo ObjectInfo, err error) {
    	if err = checkCompleteMultipartArgs(ctx, bucket, object, uploadID); err != nil {
    		return objInfo, err
    	}
    
    	if z.SinglePool() {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu May 30 11:58:12 UTC 2024
    - 82.5K bytes
    - Viewed (0)
Back to top