Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for NewMultipartUpload (0.11 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-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)
  3. 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)
  4. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  5. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  6. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
Back to top