Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 109 for uploadIds (0.23 sec)

  1. cmd/object-api-multipart_test.go

    			Uploads: []MultipartInfo{
    				{
    					Object:   objectNames[0],
    					UploadID: uploadIDs[4],
    				},
    				{
    					Object:   objectNames[1],
    					UploadID: uploadIDs[5],
    				},
    				{
    					Object:   objectNames[2],
    					UploadID: uploadIDs[6],
    				},
    				{
    					Object:   objectNames[3],
    					UploadID: uploadIDs[7],
    				},
    				{
    					Object:   objectNames[4],
    					UploadID: uploadIDs[8],
    				},
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 77.1K bytes
    - Viewed (0)
  2. cmd/erasure-multipart.go

    		break
    	}
    
    	for i := range uploadIDs {
    		uploadIDs[i] = strings.TrimSuffix(uploadIDs[i], SlashSeparator)
    	}
    
    	// S3 spec says uploadIDs should be sorted based on initiated time, we need
    	// to read the metadata entry.
    	var uploads []MultipartInfo
    
    	populatedUploadIDs := set.NewStringSet()
    
    	for _, uploadID := range uploadIDs {
    		if populatedUploadIDs.Contains(uploadID) {
    			continue
    		}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 42.4K bytes
    - Viewed (0)
  3. cmd/object-handlers_test.go

    			testUploads.Lock()
    			testUploads.uploads = append(testUploads.uploads, multipartResponse.UploadID)
    			testUploads.Unlock()
    		}()
    	}
    	// Wait till all go routines finishes execution.
    	wg.Wait()
    	// Validate the upload ID by an attempt to list parts using it.
    	for _, uploadID := range testUploads.uploads {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Mar 10 21:09:36 GMT 2024
    - 160K bytes
    - Viewed (0)
  4. cmd/post-policy_test.go

    	credentials := globalActiveCred
    
    	curTime := UTCNow()
    	curTimePlus5Min := curTime.Add(time.Minute * 5)
    
    	// bucketnames[0].
    	// objectNames[0].
    	// uploadIds [0].
    	// Create bucket before initiating NewMultipartUpload.
    	err := obj.MakeBucket(context.Background(), bucketName, MakeBucketOptions{})
    	if err != nil {
    		// Failed to create newbucket, abort.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 16:45:54 GMT 2024
    - 29.6K bytes
    - Viewed (0)
  5. cmd/object-api-datatypes.go

    	ChecksumAlgorithm string
    }
    
    // Lookup - returns if uploadID is valid
    func (lm ListMultipartsInfo) Lookup(uploadID string) bool {
    	for _, upload := range lm.Uploads {
    		if upload.UploadID == uploadID {
    			return true
    		}
    	}
    	return false
    }
    
    // ListMultipartsInfo - represents bucket resources for incomplete multipart uploads.
    type ListMultipartsInfo struct {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 20.8K bytes
    - Viewed (0)
  6. cmd/server_test.go

    	err = decoder.Decode(newResponse)
    	c.Assert(err, nil)
    	c.Assert(len(newResponse.UploadID) > 0, true)
    	// uploadID to be used for rest of the multipart operations on the object.
    	uploadID := newResponse.UploadID
    
    	// content for the part to be uploaded.
    	buffer1 := bytes.NewReader([]byte("hello world"))
    	// HTTP request for the part to be uploaded.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 108K bytes
    - Viewed (0)
  7. cmd/api-response.go

    		}
    	}
    	listMultipartUploadsResponse.Uploads = make([]Upload, len(multipartsInfo.Uploads))
    	for index, upload := range multipartsInfo.Uploads {
    		newUpload := Upload{}
    		newUpload.UploadID = upload.UploadID
    		newUpload.Key = s3EncodeName(upload.Object, encodingType)
    		newUpload.Initiated = amztime.ISO8601Format(upload.Initiated.UTC())
    		listMultipartUploadsResponse.Uploads[index] = newUpload
    	}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 33.3K bytes
    - Viewed (2)
  8. cmd/api-resources.go

    	}
    	return
    }
    
    // Parse bucket url queries for ?uploads
    func getBucketMultipartResources(values url.Values) (prefix, keyMarker, uploadIDMarker, delimiter string, maxUploads int, encodingType string, errCode APIErrorCode) {
    	errCode = ErrNone
    
    	if values.Get("max-uploads") != "" {
    		var err error
    		if maxUploads, err = strconv.Atoi(values.Get("max-uploads")); err != nil {
    			errCode = ErrInvalidMaxUploads
    			return
    		}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed Jun 07 18:25:26 GMT 2023
    - 4.3K bytes
    - Viewed (0)
  9. cmd/test-utils_test.go

    	queryValue := url.Values{}
    	queryValue.Set("uploadId", uploadID)
    	return makeTestTargetURL(endPoint, bucketName, objectName, queryValue)
    }
    
    // return URL for a listing pending multipart uploads.
    func getListMultipartURL(endPoint, bucketName string) string {
    	queryValue := url.Values{}
    	queryValue.Set("uploads", "")
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:06:57 GMT 2024
    - 75.7K bytes
    - Viewed (0)
  10. cmd/erasure-sets.go

    	set := s.getHashedSet(object)
    	return set.PutObjectPart(ctx, bucket, object, uploadID, partID, data, opts)
    }
    
    // GetMultipartInfo - return multipart metadata info uploaded at hashedSet.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 37.5K bytes
    - Viewed (5)
Back to top