- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 33 for upload (0.14 sec)
-
cmd/object-api-multipart_test.go
// Test Case - 10. // Case with valid UploadID, existing bucket name. // But using the bucket name from which NewMultipartUpload is not constructed from. {bucketName: "unused-bucket", objName: object, uploadID: uploadID, PartID: 1, expectedError: fmt.Errorf("%s", "Invalid upload id "+uploadID)}, // Test Case - 11. // Case with valid UploadID, existing bucket name.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 09:42:21 UTC 2024 - 88.8K bytes - Viewed (0) -
cmd/erasure-healing_test.go
t.Fatalf("Failed to make a bucket - %v", err) } // Upload a multipart object in the second pool z := objLayer.(*erasureServerPools) set := z.serverPools[1] res, err := set.NewMultipartUpload(ctx, bucket, object, opts) if err != nil { t.Fatalf("Failed to create a multipart upload - %v", err) } uploadID := res.UploadID var uploadedParts []CompletePart
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 49K bytes - Viewed (0) -
cmd/test-utils_test.go
queryValues.Set("uploadId", uploadID) queryValues.Set("partNumber", partNumber) return makeTestTargetURL(endPoint, bucketName, objectName, queryValues) } // return URL for aborting multipart upload. func getAbortMultipartUploadURL(endPoint, bucketName, objectName, uploadID string) string { queryValue := url.Values{} queryValue.Set("uploadId", uploadID) return makeTestTargetURL(endPoint, bucketName, objectName, queryValue)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 01 22:13:18 UTC 2024 - 77K bytes - Viewed (0) -
docs/bucket/notifications/README.md
```py python rabbit.py ``` Open another terminal and upload a JPEG image into `images` bucket. ``` mc cp myphoto.jpg myminio/images ``` You should receive the following event notification via RabbitMQ once the upload completes. ```py python rabbit.py
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 84K bytes - Viewed (0) -
cmd/erasure-server-pool.go
} z.mpCache.Range(func(_ string, mp MultipartInfo) bool { poolResult.Uploads = append(poolResult.Uploads, mp) return true }) sort.Slice(poolResult.Uploads, func(i int, j int) bool { return poolResult.Uploads[i].Initiated.Before(poolResult.Uploads[j].Initiated) }) return poolResult, nil } if z.SinglePool() {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 29 22:40:36 UTC 2024 - 89.8K bytes - Viewed (0) -
cmd/api-errors.go
HTTPStatusCode: http.StatusNotFound, }, ErrNoSuchUpload: { Code: "NoSuchUpload", Description: "The specified multipart upload does not exist. The upload ID may be invalid, or the upload may have been aborted or completed.", HTTPStatusCode: http.StatusNotFound, }, ErrInvalidVersionID: { Code: "InvalidArgument",
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 01 22:13:18 UTC 2024 - 92.1K bytes - Viewed (0) -
cmd/bucket-handlers.go
} // ListMultipartUploadsHandler - GET Bucket (List Multipart uploads) // ------------------------- // This operation lists in-progress multipart uploads. An in-progress // multipart upload is a multipart upload that has been initiated, // using the Initiate Multipart Upload request, but has not yet been // completed or aborted. This operation returns at most 1,000 multipart // uploads in the response.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 12 12:24:04 UTC 2024 - 63.4K bytes - Viewed (0) -
cmd/batch-handlers.go
if err != nil { return err } defer func() { if err != nil { // block and abort remote upload upon failure. attempts := 1 for attempts <= 3 { aerr := api.AbortMultipartUpload(ctx, tgtBucket, tgtObject, res.UploadID, ObjectOptions{}) if aerr == nil { return } batchLogIf(ctx,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 18 15:32:09 UTC 2024 - 62.2K bytes - Viewed (0) -
cmd/sts-handlers_test.go
svcClient := s.getUserClient(c, cr.AccessKey, cr.SecretKey, "") // 1. Check S3 access for service account ListObjects() c.mustListObjects(ctx, svcClient, bucket) // 2. Check S3 access for upload c.mustUpload(ctx, svcClient, bucket) // 3. Check S3 access for download c.mustDownload(ctx, svcClient, bucket) } func (s *TestSuiteIAM) TestSTSWithDenyDeleteVersion(c *check) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 10 23:40:37 UTC 2024 - 97.1K bytes - Viewed (0) -
cmd/erasure-object.go
switch size := data.Size(); { case size == 0: buffer = make([]byte, 1) // Allocate at least a byte to reach EOF case size >= fi.Erasure.BlockSize: buffer = globalBytePoolCap.Load().Get() defer globalBytePoolCap.Load().Put(buffer) case size < fi.Erasure.BlockSize: // No need to allocate fully blockSizeV1 buffer if the incoming data is smaller.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 78.8K bytes - Viewed (0)