- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 28 for completeMultipartUpload (0.52 sec)
-
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"` Number int `json:"number"`
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 8.2K bytes - Viewed (0) -
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 Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 37.7K bytes - Viewed (0) -
cmd/erasure-metadata-utils.go
return err }, index) } return metadataArray, g.Wait() } // shuffleDisksAndPartsMetadataByIndex this function should be always used by GetObjectNInfo() // and CompleteMultipartUpload code path, it is not meant to be used with PutObject, // NewMultipartUpload metadata shuffling.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 11.7K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
ETag: pi.ETag, PartNumber: pi.PartNumber, } } _, err = z.CompleteMultipartUpload(ctx, bucket, oi.Name, res.UploadID, parts, ObjectOptions{ DataMovement: true, MTime: oi.ModTime, NoAuditLog: true, }) if err != nil { err = fmt.Errorf("rebalanceObject: CompleteMultipartUpload() %w", err) } return err }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 03 15:45:54 UTC 2024 - 27.3K bytes - Viewed (0) -
platforms/software/resources-s3/src/integTest/groovy/org/gradle/integtests/resource/s3/fixtures/S3Server.groovy
} expect(httpStub) } def stubCompleteMultipartUpload(String bucketName, String keyName, File file) { def requestXml = new StreamingMarkupBuilder().bind { CompleteMultipartUpload(xmlns: "http://s3.amazonaws.com/doc/2006-03-01/") { Part() { PartNumber(1) ETag(calculateEtag(file)) } } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 19:38:08 UTC 2023 - 22.4K bytes - Viewed (0) -
cmd/object_api_suite_test.go
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++ { expectedETaghex := getMD5Hash(data) var calcPartInfo PartInfo
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 33.4K bytes - Viewed (0) -
cmd/erasure-server-pool.go
return err } return InvalidUploadID{ Bucket: bucket, Object: object, UploadID: uploadID, } } // 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) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 30 11:58:12 UTC 2024 - 82.5K bytes - Viewed (0) -
cmd/object-handlers_test.go
// Complete multipart upload parts. completeUploads := &CompleteMultipartUpload{ Parts: testCase.parts, } completeBytes, err = xml.Marshal(completeUploads) if err != nil { t.Fatalf("Error XML encoding of parts: <ERROR> %s.", err) } // Indicating that all parts are uploaded and initiating CompleteMultipartUpload.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 161.9K bytes - Viewed (0) -
cmd/api-router.go
// ListObjectParts router.Methods(http.MethodGet).Path("/{object:.+}"). HandlerFunc(s3APIMiddleware(api.ListObjectPartsHandler)). Queries("uploadId", "{uploadId:.*}") // CompleteMultipartUpload router.Methods(http.MethodPost).Path("/{object:.+}"). HandlerFunc(s3APIMiddleware(api.CompleteMultipartUploadHandler)). Queries("uploadId", "{uploadId:.*}") // NewMultipartUpload
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 22.8K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
ChecksumSHA1: pi.ChecksumSHA1, } } _, err = z.CompleteMultipartUpload(ctx, bucket, objInfo.Name, res.UploadID, parts, ObjectOptions{ DataMovement: true, MTime: objInfo.ModTime, NoAuditLog: true, }) if err != nil { err = fmt.Errorf("decommissionObject: CompleteMultipartUpload() %w", err) } return err }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 06 14:30:43 UTC 2024 - 41.5K bytes - Viewed (1)