Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 16 for newMultipartUpload (0.18 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top