Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 19 for NewMultipartUpload (0.23 sec)

  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)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 09:42:21 UTC 2024
    - 88.8K bytes
    - Viewed (0)
  2. cmd/erasure-multipart.go

    		ChecksumAlgo: userDefined[hash.MinIOMultipartChecksum],
    	}, 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.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  3. cmd/object-handlers_test.go

    	// that is without any other handler being registered,
    	// That's why NewMultipartUpload is initiated using ObjectLayer.
    	res, err := obj.NewMultipartUpload(context.Background(), bucketName, testObject, opts)
    	if err != nil {
    		// Failed to create NewMultipartUpload, abort.
    		t.Fatalf("MinIO %s : <ERROR>  %s", instanceType, err)
    	}
    	uploadID := res.UploadID
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:10:44 UTC 2024
    - 163.2K bytes
    - Viewed (0)
  4. internal/logger/reqinfo.go

    	UserAgent    string           // User Agent
    	DeploymentID string           // x-minio-deployment-id
    	RequestID    string           // x-amz-request-id
    	API          string           // API name - GetObject PutObject NewMultipartUpload etc.
    	BucketName   string           `json:",omitempty"` // Bucket name
    	ObjectName   string           `json:",omitempty"` // Object name
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 4.4K bytes
    - Viewed (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} {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  6. cmd/object-multipart-handlers.go

    		return
    	} else if checksumType.IsSet() && !checksumType.Is(hash.ChecksumTrailing) {
    		opts.WantChecksum = &hash.Checksum{Type: checksumType}
    	}
    
    	newMultipartUpload := objectAPI.NewMultipartUpload
    
    	res, err := newMultipartUpload(ctx, bucket, object, opts)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Aug 31 18:25:48 UTC 2024
    - 39.2K bytes
    - Viewed (0)
  7. 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.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 02 15:13:05 UTC 2024
    - 33.3K bytes
    - Viewed (0)
  8. 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))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  9. 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) {
    	idx, err = z.getPoolIdxExistingWithOpts(ctx, bucket, object, ObjectOptions{
    		SkipDecommissioned: true,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  10. cmd/erasure-server-pool-rebalance.go

    		return err
    	}
    
    	if oi.isMultipart() {
    		res, err := z.NewMultipartUpload(ctx, bucket, oi.Name, ObjectOptions{
    			VersionID:    oi.VersionID,
    			UserDefined:  oi.UserDefined,
    			NoAuditLog:   true,
    			DataMovement: true,
    			SrcPoolIdx:   poolIdx,
    		})
    		if err != nil {
    			return fmt.Errorf("rebalanceObject: NewMultipartUpload() %w", err)
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
Back to top