- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 16 for newMultipartUpload (0.18 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
cmd/object-api-multipart_test.go
opts := ObjectOptions{} _, err := obj.NewMultipartUpload(context.Background(), "--", object, opts) if err == nil { t.Fatalf("%s: Expected to fail since bucket name is invalid.", instanceType) } errMsg := "Bucket not found: minio-bucket" // operation expected to fail since the bucket on which NewMultipartUpload is being initiated doesn't exist. _, err = obj.NewMultipartUpload(context.Background(), bucket, object, opts)Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 89.4K bytes - Click Count (0) -
cmd/erasure-multipart-conditional_test.go
xhttp.IfNoneMatch: "*", }, CheckPrecondFn: func(oi ObjectInfo) bool { // Precondition fails if object exists (ETag is not empty) return oi.ETag != "" }, } _, err := obj.NewMultipartUpload(ctx, bucket, object, opts) if !isErrReadQuorum(err) { t.Errorf("Expected read quorum error when if-none-match is used with quorum failure, got: %v", err) } })
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Oct 24 04:05:31 GMT 2025 - 6.9K bytes - Click Count (0) -
cmd/benchmark-utils_test.go
textData := generateBytesData(objSize) // generate md5sum for the generated data. // md5sum of the data to written is required as input for NewMultipartUpload. res, err := obj.NewMultipartUpload(b.Context(), bucket, object, ObjectOptions{}) if err != nil { b.Fatal(err) } sha256hex := "" var textPartData []byte
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 8.1K bytes - Click Count (0) -
cmd/erasure-multipart.go
ChecksumType: userDefined[hash.MinIOMultipartChecksumType], }, nil } // NewMultipartUpload - initialize a new multipart upload, returns a // unique id. The unique id returned here is of UUID form, for each // subsequent request each UUID is unique. // // Implements S3 compatible initiate multipart API.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Oct 24 04:05:31 GMT 2025 - 47.1K bytes - Click Count (0) -
cmd/erasure-healing_test.go
if err != nil { t.Fatalf("Failed to make a bucket - %v", err) } // Create an object with multiple parts uploaded in decreasing // part number. res, err := objLayer.NewMultipartUpload(ctx, bucket, object, opts) if err != nil { t.Fatalf("Failed to create a multipart upload - %v", err) } var uploadedParts []CompletePart for _, partID := range []int{2, 1} {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 48.5K bytes - Click Count (0) -
cmd/object_api_suite_test.go
var opts ObjectOptions err := obj.MakeBucket(context.Background(), "bucket", MakeBucketOptions{}) if err != nil { 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.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 34.5K bytes - Click Count (0) -
cmd/erasure-metadata-utils.go
} // 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. func shuffleDisksAndPartsMetadataByIndex(disks []StorageAPI, metaArr []FileInfo, fi FileInfo) (shuffledDisks []StorageAPI, shuffledPartsMetadata []FileInfo) { shuffledDisks = make([]StorageAPI, len(disks))
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 11.7K bytes - Click Count (0) -
cmd/erasure-server-pool.go
// if none are found falls back to most available space pool, this function is // designed to be only used by PutObject, CopyObject (newObject creation) and NewMultipartUpload. func (z *erasureServerPools) getPoolIdx(ctx context.Context, bucket, object string, size int64) (idx int, err error) { pinfo, _, err := z.getPoolInfoExistingWithOpts(ctx, bucket, object, ObjectOptions{
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 89.2K bytes - Click Count (0) -
cmd/erasure-sets.go
} // Initiate a new multipart upload on a hashedSet based on object name. func (s *erasureSets) NewMultipartUpload(ctx context.Context, bucket, object string, opts ObjectOptions) (res *NewMultipartUploadResult, err error) { set := s.getHashedSet(object) return set.NewMultipartUpload(ctx, bucket, object, opts) } // PutObjectPart - writes part of an object to hashedSet based on the object name.Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 37K bytes - Click Count (1) -
cmd/api-router.go
// CompleteMultipartUpload router.Methods(http.MethodPost).Path("/{object:.+}"). HandlerFunc(s3APIMiddleware(api.CompleteMultipartUploadHandler)). Queries("uploadId", "{uploadId:.*}") // NewMultipartUpload router.Methods(http.MethodPost).Path("/{object:.+}"). HandlerFunc(s3APIMiddleware(api.NewMultipartUploadHandler)). Queries("uploads", "") // AbortMultipartUpload
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Oct 24 04:05:19 GMT 2025 - 23.3K bytes - Click Count (0)