Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for CompleteMultipartUpload (0.54 sec)

  1. cmd/object-api-datatypes.go

    	ChecksumCRC32C    string
    	ChecksumSHA1      string
    	ChecksumSHA256    string
    	ChecksumCRC64NVME string
    }
    
    // CompleteMultipartUpload - represents list of parts which are completed, this is sent by the
    // client during CompleteMultipartUpload request.
    type CompleteMultipartUpload struct {
    	Parts []CompletePart `xml:"Part"`
    }
    
    // NewMultipartUploadResult contains information about a newly created multipart upload.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 21.2K bytes
    - Viewed (0)
  2. cmd/erasure-multipart.go

    	}
    	return errors.New(part.Error)
    }
    
    // CompleteMultipartUpload - completes an ongoing multipart
    // transaction after receiving all the parts indicated by the client.
    // Returns an md5sum calculated by concatenating all the individual
    // md5sums of all the parts.
    //
    // Implements S3 compatible Complete multipart API.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
  3. cmd/object-multipart-handlers.go

    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Err), r.URL)
    		return
    	}
    
    	completeMultiPartUpload := objectAPI.CompleteMultipartUpload
    
    	versioned := globalBucketVersioningSys.PrefixEnabled(bucket, object)
    	suspended := globalBucketVersioningSys.PrefixSuspended(bucket, object)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 39.5K bytes
    - Viewed (0)
  4. cmd/erasure-healing_test.go

    			t.Fatalf("Failed to upload a part - %v", err1)
    		}
    		uploadedParts = append(uploadedParts, CompletePart{
    			PartNumber: pInfo.PartNumber,
    			ETag:       pInfo.ETag,
    		})
    	}
    
    	_, err = objLayer.CompleteMultipartUpload(ctx, bucket, object, res.UploadID, uploadedParts, ObjectOptions{})
    	if err != nil {
    		t.Fatalf("Failed to complete multipart upload - got: %v", err)
    	}
    
    	cfgFile := pathJoin(bucketMetaPrefix, bucket, ".test.bin")
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 48.5K bytes
    - Viewed (0)
  5. cmd/erasure-sets.go

    }
    
    // CompleteMultipartUpload - completes a pending multipart transaction, on hashedSet based on object name.
    func (s *erasureSets) CompleteMultipartUpload(ctx context.Context, bucket, object, uploadID string, uploadedParts []CompletePart, opts ObjectOptions) (objInfo ObjectInfo, err error) {
    	set := s.getHashedSet(object)
    	return set.CompleteMultipartUpload(ctx, bucket, object, uploadID, uploadedParts, opts)
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37K bytes
    - Viewed (1)
  6. cmd/erasure-metadata-utils.go

    			return err
    		}, index)
    	}
    
    	return metadataArray, g.Wait()
    }
    
    // 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.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.7K bytes
    - Viewed (0)
  7. cmd/object-api-interface.go

    	Transition          TransitionOptions
    	Expiration          ExpirationOptions
    	LifecycleAuditEvent lcAuditEvent
    
    	WantChecksum *hash.Checksum // x-amz-checksum-XXX checksum sent to PutObject/ CompleteMultipartUpload.
    
    	WantServerSideChecksumType hash.ChecksumType // if set, we compute a server-side checksum of this type
    
    	NoDecryption                        bool      // indicates if the stream must be decrypted.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 17.5K bytes
    - Viewed (0)
  8. cmd/object_api_suite_test.go

    		t.Fatalf("%s: <ERROR> %s", instanceType, err)
    	}
    	uploadID := res.UploadID
    
    	// Create a byte array of 5MiB.
    	data := bytes.Repeat([]byte("0123456789abcdef"), 5*humanize.MiByte/16)
    	completedParts := CompleteMultipartUpload{}
    	for i := 1; i <= 10; i++ {
    		expectedETaghex := getMD5Hash(data)
    
    		var calcPartInfo PartInfo
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.5K bytes
    - Viewed (0)
  9. cmd/api-router.go

    		// ListObjectParts
    		router.Methods(http.MethodGet).Path("/{object:.+}").
    			HandlerFunc(s3APIMiddleware(api.ListObjectPartsHandler)).
    			Queries("uploadId", "{uploadId:.*}")
    		// CompleteMultipartUpload
    		router.Methods(http.MethodPost).Path("/{object:.+}").
    			HandlerFunc(s3APIMiddleware(api.CompleteMultipartUploadHandler)).
    			Queries("uploadId", "{uploadId:.*}")
    		// NewMultipartUpload
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed May 07 15:37:12 UTC 2025
    - 23.3K bytes
    - Viewed (0)
  10. cmd/erasure-server-pool-decom.go

    				ChecksumSHA1:   pi.ChecksumSHA1,
    			}
    		}
    		_, err = z.CompleteMultipartUpload(ctx, bucket, objInfo.Name, res.UploadID, parts, ObjectOptions{
    			SrcPoolIdx:   idx,
    			DataMovement: true,
    			MTime:        objInfo.ModTime,
    			NoAuditLog:   true,
    		})
    		if err != nil {
    			err = fmt.Errorf("decommissionObject: CompleteMultipartUpload() %w", err)
    		}
    		return err
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 42.1K bytes
    - Viewed (1)
Back to top