Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 20 for putObjectPart (0.09 sec)

  1. cmd/erasure-server-pool.go

    		return PartInfo{}, err
    	}
    
    	return z.PutObjectPart(ctx, destBucket, destObject, uploadID, partID,
    		srcInfo.PutObjReader, dstOpts)
    }
    
    // PutObjectPart - writes part of an object to hashedSet based on the object name.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  2. cmd/erasure-object_test.go

    	md5Hex := getMD5Hash(fiveMBBytes)
    	_, err = objLayer.PutObjectPart(ctx, "bucket1", "mpartObj1", res.UploadID, 1, mustGetPutObjReader(t, bytes.NewReader(fiveMBBytes), 5*humanize.MiByte, md5Hex, ""), opts)
    	if err != nil {
    		t.Fatal(err)
    	}
    	// PutObjectPart should succeed even if part already exists. ref: https://github.com/minio/minio/issues/1930
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool-rebalance.go

    			hr, err := hash.NewReader(ctx, io.LimitReader(gr, part.Size), part.Size, "", "", part.ActualSize)
    			if err != nil {
    				return fmt.Errorf("rebalanceObject: hash.NewReader() %w", err)
    			}
    			pi, err := z.PutObjectPart(ctx, bucket, oi.Name, res.UploadID,
    				part.Number,
    				NewPutObjReader(hr),
    				ObjectOptions{
    					PreserveETag: part.ETag, // Preserve original ETag to ensure same metadata.
    					IndexCB: func() []byte {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  4. cmd/object-api-interface.go

    		startOffset int64, length int64, srcInfo ObjectInfo, srcOpts, dstOpts ObjectOptions) (info PartInfo, err error)
    	PutObjectPart(ctx context.Context, bucket, object, uploadID string, partID int, data *PutObjReader, opts ObjectOptions) (info PartInfo, err error)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  5. cmd/api-router.go

    			HeadersRegexp(xhttp.AmzCopySource, ".*?(\\/|%2F).*?").
    			HandlerFunc(s3APIMiddleware(api.CopyObjectPartHandler)).
    			Queries("partNumber", "{partNumber:.*}", "uploadId", "{uploadId:.*}")
    		// PutObjectPart
    		router.Methods(http.MethodPut).Path("/{object:.+}").
    			HandlerFunc(s3APIMiddleware(api.PutObjectPartHandler, traceHdrsS3HFlag)).
    			Queries("partNumber", "{partNumber:.*}", "uploadId", "{uploadId:.*}")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 15:25:16 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  6. cmd/erasure-server-pool-decom.go

    			hr, err := hash.NewReader(ctx, io.LimitReader(gr, part.Size), part.Size, "", "", part.ActualSize)
    			if err != nil {
    				return fmt.Errorf("decommissionObject: hash.NewReader() %w", err)
    			}
    			pi, err := z.PutObjectPart(ctx, bucket, objInfo.Name, res.UploadID,
    				part.Number,
    				NewPutObjReader(hr),
    				ObjectOptions{
    					PreserveETag: part.ETag, // Preserve original ETag to ensure same metadata.
    					IndexCB: func() []byte {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  7. cmd/test-utils_test.go

    		case "PutObjectPart":
    			// Register PutObjectPart handler.
    			bucket.Methods(http.MethodPut).Path("/{object:.+}").HandlerFunc(api.PutObjectPartHandler).Queries("partNumber", "{partNumber:.*}", "uploadId", "{uploadId:.*}")
    		case "ListObjectParts":
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  8. cmd/batch-handlers.go

    		if err != nil {
    			return err
    		}
    		pReader := NewPutObjReader(hr)
    		opts.PreserveETag = ""
    		pInfo, err = api.PutObjectPart(ctx, tgtBucket, tgtObject, res.UploadID, i+1, pReader, opts)
    		if err != nil {
    			return err
    		}
    		if pInfo.Size != objInfo.Size {
    			return fmt.Errorf("Part size mismatch: got %d, want %d", pInfo.Size, objInfo.Size)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  9. cmd/erasure-object.go

    		hr, err := hash.NewReader(ctx, io.LimitReader(gr, partInfo.Size), partInfo.Size, "", "", partInfo.Size)
    		if err != nil {
    			return setRestoreHeaderFn(oi, err)
    		}
    		pInfo, err := er.PutObjectPart(ctx, bucket, object, res.UploadID, partInfo.Number, NewPutObjReader(hr), ObjectOptions{})
    		if err != nil {
    			return setRestoreHeaderFn(oi, err)
    		}
    		if pInfo.Size != partInfo.Size {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  10. cmd/bucket-replication.go

    			CustomHeader: cHeader,
    		}
    
    		var size int64
    		if isSSEC {
    			size = partInfo.Size
    		} else {
    			size = partInfo.ActualSize
    		}
    		objectSize += size
    		pInfo, err := c.PutObjectPart(ctx, bucket, object, uploadID, partInfo.Number, hr, size, popts)
    		if err != nil {
    			return err
    		}
    		if pInfo.Size != size {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
Back to top