Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for NewMultipartUpload (0.07 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.4K bytes
    - Viewed (0)
  2. 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{
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
  3. cmd/batch-handlers.go

    	}
    	if r.Target.Type == BatchJobReplicateResourceS3 || r.Source.Type == BatchJobReplicateResourceS3 {
    		opts.VersionID = ""
    	}
    	var uploadedParts []CompletePart
    	res, err := api.NewMultipartUpload(context.Background(), tgtBucket, tgtObject, opts)
    	if err != nil {
    		return err
    	}
    
    	defer func() {
    		if err != nil {
    			// block and abort remote upload upon failure.
    			attempts := 1
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.5K bytes
    - Viewed (0)
  4. cmd/erasure-object.go

    		}
    		pReader := NewPutObjReader(hashReader)
    		_, err = er.PutObject(ctx, bucket, object, pReader, ropts)
    		return setRestoreHeaderFn(oi, toObjectErr(err, bucket, object))
    	}
    
    	res, err := er.NewMultipartUpload(ctx, bucket, object, ropts)
    	if err != nil {
    		return setRestoreHeaderFn(oi, err)
    	}
    
    	var uploadedParts []CompletePart
    	var rs *HTTPRangeSpec
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  5. cmd/xl-storage.go

    		// this is currently used by
    		// - emphemeral objects such as objects created during listObjects() calls
    		ok := volume == minioMetaMultipartBucket // - newMultipartUpload() call must be synced to drives.
    		return s.writeAll(ctx, volume, pathJoin(path, xlStorageFormatFile), buf, ok, "")
    	}
    
    	buf, err := s.ReadAll(ctx, volume, pathJoin(path, xlStorageFormatFile))
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jun 13 11:33:47 UTC 2025
    - 91.7K bytes
    - Viewed (0)
Back to top