- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for UploadID (0.04 sec)
-
cmd/erasure-multipart.go
if !opts.NoAuditLog { auditObjectErasureSet(ctx, "GetMultipartInfo", object, &er) } result := MultipartInfo{ Bucket: bucket, Object: object, UploadID: uploadID, } fi, _, err := er.checkUploadIDExists(ctx, bucket, object, uploadID, false) if err != nil {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Sep 07 16:13:09 UTC 2025 - 47.3K bytes - Viewed (0) -
cmd/object-api-multipart_test.go
} uploadID := res.UploadID abortTestCases := []struct { bucketName string objName string uploadID string expectedErrType error }{ {"--", object, uploadID, BucketNameInvalid{}}, {"foo", object, uploadID, BucketNotFound{}}, {bucket, object, "foo-foo", InvalidUploadID{}}, {bucket, object, uploadID, nil}, }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 89.4K bytes - Viewed (0) -
cmd/object-api-datatypes.go
// ChecksumAlgorithm if set ChecksumAlgorithm string // ChecksumType if set ChecksumType string } // Lookup - returns if uploadID is valid func (lm ListMultipartsInfo) Lookup(uploadID string) bool { for _, upload := range lm.Uploads { if upload.UploadID == uploadID { return true } } return false } // ListMultipartsInfo - represents bucket resources for incomplete multipart uploads.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 21.2K bytes - Viewed (0) -
cmd/erasure-server-pool.go
Object: object, UploadID: uploadID, } } func (z *erasureServerPools) GetMultipartInfo(ctx context.Context, bucket, object, uploadID string, opts ObjectOptions) (MultipartInfo, error) { if err := checkListPartsArgs(ctx, bucket, object, uploadID); err != nil { return MultipartInfo{}, err } uploadIDLock := z.NewNSLock(bucket, pathJoin(object, uploadID))
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 89.1K bytes - Viewed (0) -
cmd/erasure-sets.go
set := s.getHashedSet(object) return set.PutObjectPart(ctx, bucket, object, uploadID, partID, data, opts) } // GetMultipartInfo - return multipart metadata info uploaded at hashedSet.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 37K bytes - Viewed (1) -
cmd/object_api_suite_test.go
t.Fatalf("%s: <ERROR> %s", instanceType, err) } res, err := obj.NewMultipartUpload(context.Background(), "bucket", "key", opts) if err != nil { t.Fatalf("%s: <ERROR> %s", instanceType, err) } uploadID := res.UploadID // Create a byte array of 5MiB. data := bytes.Repeat([]byte("0123456789abcdef"), 5*humanize.MiByte/16) completedParts := CompleteMultipartUpload{} for i := 1; i <= 10; i++ {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 34.5K bytes - Viewed (0) -
cmd/object-handlers_test.go
uploadID: uploadID, copySourceHeader: url.QueryEscape(SlashSeparator + bucketName + SlashSeparator + testObject), accessKey: credentials.AccessKey, secretKey: credentials.SecretKey, expectedRespStatus: http.StatusNotFound, }, // Test case - 4. // Test case with valid byte range. { bucketName: bucketName, uploadID: uploadID,
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 163.1K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
} if s3Error := checkRequestAuthType(ctx, r, policy.GetObjectAction, srcBucket, srcObject); s3Error != ErrNone { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL) return } uploadID := r.Form.Get(xhttp.UploadID) partIDString := r.Form.Get(xhttp.PartNumber) partID, err := strconv.Atoi(partIDString) if err != nil || partID <= 0 { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrInvalidPart), r.URL)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Sep 07 16:13:09 UTC 2025 - 39.5K bytes - Viewed (0) -
cmd/erasure-healing_test.go
if err != nil { t.Fatalf("Failed to create a multipart upload - %v", err) } uploadID := res.UploadID var uploadedParts []CompletePart for _, partID := range []int{2, 1} { pInfo, err1 := set.PutObjectPart(ctx, bucket, object, uploadID, partID, mustGetPutObjReader(t, bytes.NewReader(data), int64(len(data)), "", ""), opts) if err1 != nil {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 48.5K bytes - Viewed (0) -
cmd/test-utils_test.go
} func getPutObjectPartURL(endPoint, bucketName, objectName, uploadID, partNumber string) string { queryValues := url.Values{} queryValues.Set("uploadId", uploadID) queryValues.Set("partNumber", partNumber) return makeTestTargetURL(endPoint, bucketName, objectName, queryValues) } func getCopyObjectPartURL(endPoint, bucketName, objectName, uploadID, partNumber string) string { queryValues := url.Values{}
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 77K bytes - Viewed (0)