Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 27 for CompleteMultipartUpload (0.09 sec)

  1. cmd/object-api-datatypes.go

    	ChecksumCRC32C    string
    	ChecksumSHA1      string
    	ChecksumSHA256    string
    	ChecksumCRC64NVME string
    }
    
    // CompleteMultipartUpload - represents list of parts which are completed, this is sent by the
    // client during CompleteMultipartUpload request.
    type CompleteMultipartUpload struct {
    	Parts []CompletePart `xml:"Part"`
    }
    
    // NewMultipartUploadResult contains information about a newly created multipart upload.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 21.2K bytes
    - Viewed (0)
  2. cmd/erasure-multipart.go

    	}
    	return errors.New(part.Error)
    }
    
    // CompleteMultipartUpload - completes an ongoing multipart
    // transaction after receiving all the parts indicated by the client.
    // Returns an md5sum calculated by concatenating all the individual
    // md5sums of all the parts.
    //
    // Implements S3 compatible Complete multipart API.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:05:31 UTC 2025
    - 47.1K bytes
    - Viewed (0)
  3. cmd/object-api-input-checks.go

    func checkListPartsArgs(ctx context.Context, bucket, object, uploadID string) error {
    	return checkMultipartObjectArgs(ctx, bucket, object, uploadID)
    }
    
    // Checks for CompleteMultipartUpload arguments validity, also validates if bucket exists.
    func checkCompleteMultipartArgs(ctx context.Context, bucket, object, uploadID string) error {
    	return checkMultipartObjectArgs(ctx, bucket, object, uploadID)
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  4. cmd/object-multipart-handlers.go

    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Err), r.URL)
    		return
    	}
    
    	completeMultiPartUpload := objectAPI.CompleteMultipartUpload
    
    	versioned := globalBucketVersioningSys.PrefixEnabled(bucket, object)
    	suspended := globalBucketVersioningSys.PrefixSuspended(bucket, object)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 39.5K bytes
    - Viewed (0)
  5. internal/hash/checksum_test.go

    	part2Checksum := NewChecksumFromData(checksumType, part2Data)
    	part3Checksum := NewChecksumFromData(checksumType, part3Data)
    
    	// Combine the raw checksums (this is what happens in CompleteMultipartUpload)
    	var checksumCombined []byte
    	checksumCombined = append(checksumCombined, part1Checksum.Raw...)
    	checksumCombined = append(checksumCombined, part2Checksum.Raw...)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 22 14:15:21 UTC 2025
    - 7.1K bytes
    - Viewed (0)
  6. cmd/object-api-multipart_test.go

    		// Used to verify that the other remaining parts are deleted after
    		// a successful call to CompleteMultipartUpload.
    		{
    			[]CompletePart{
    				{ETag: validPartMD5, PartNumber: 6},
    			},
    		},
    	}
    	s3MD5 := getCompleteMultipartMD5(inputParts[3].parts)
    
    	// Test cases with sample input values for CompleteMultipartUpload.
    	testCases := []struct {
    		bucket   string
    		object   string
    		uploadID string
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.4K bytes
    - Viewed (0)
  7. cmd/erasure-multipart-conditional_test.go

    				xhttp.IfNoneMatch: "*",
    			},
    			CheckPrecondFn: func(oi ObjectInfo) bool {
    				return oi.ETag != ""
    			},
    		}
    
    		parts := []CompletePart{{PartNumber: 1, ETag: md5Hex}}
    		_, err := obj.CompleteMultipartUpload(ctx, bucket, object, res.UploadID, parts, opts)
    		if !isErrReadQuorum(err) {
    			t.Errorf("Expected read quorum error, got: %v", err)
    		}
    	})
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:05:31 UTC 2025
    - 6.9K bytes
    - Viewed (0)
  8. cmd/erasure-healing_test.go

    			t.Fatalf("Failed to upload a part - %v", err1)
    		}
    		uploadedParts = append(uploadedParts, CompletePart{
    			PartNumber: pInfo.PartNumber,
    			ETag:       pInfo.ETag,
    		})
    	}
    
    	_, err = objLayer.CompleteMultipartUpload(ctx, bucket, object, res.UploadID, uploadedParts, ObjectOptions{})
    	if err != nil {
    		t.Fatalf("Failed to complete multipart upload - got: %v", err)
    	}
    
    	cfgFile := pathJoin(bucketMetaPrefix, bucket, ".test.bin")
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 48.5K bytes
    - Viewed (0)
  9. cmd/erasure-sets.go

    }
    
    // CompleteMultipartUpload - completes a pending multipart transaction, on hashedSet based on object name.
    func (s *erasureSets) CompleteMultipartUpload(ctx context.Context, bucket, object, uploadID string, uploadedParts []CompletePart, opts ObjectOptions) (objInfo ObjectInfo, err error) {
    	set := s.getHashedSet(object)
    	return set.CompleteMultipartUpload(ctx, bucket, object, uploadID, uploadedParts, opts)
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37K bytes
    - Viewed (1)
  10. cmd/xl-storage-format-v1.go

    const (
    	DefaultBitrotAlgorithm = HighwayHash256S
    )
    
    // ObjectPartInfo Info of each part kept in the multipart metadata
    // file after CompleteMultipartUpload() is called.
    type ObjectPartInfo struct {
    	ETag       string            `json:"etag,omitempty" msg:"e"`
    	Number     int               `json:"number" msg:"n"`
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 8.4K bytes
    - Viewed (0)
Back to top