Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 44 for uploadIds (0.16 sec)

  1. 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
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  2. 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.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  3. 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 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  4. 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
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 19:27:06 UTC 2024
    - 33.4K bytes
    - Viewed (0)
  5. 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.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
  6. docs/en/docs/tutorial/request-files.md

    # Request Files
    
    You can define files to be uploaded by the client using `File`.
    
    /// info
    
    To receive uploaded files, first install <a href="https://github.com/Kludex/python-multipart" class="external-link" target="_blank">`python-multipart`</a>.
    
    Make sure you create a [virtual environment](../virtual-environments.md){.internal-link target=_blank}, activate it, and then install it, for example:
    
    ```console
    $ pip install python-multipart
    ```
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  7. cmd/api-router.go

    			Queries("uploadId", "{uploadId:.*}")
    		// CompleteMultipartUpload
    		router.Methods(http.MethodPost).Path("/{object:.+}").
    			HandlerFunc(s3APIMiddleware(api.CompleteMultipartUploadHandler)).
    			Queries("uploadId", "{uploadId:.*}")
    		// NewMultipartUpload
    		router.Methods(http.MethodPost).Path("/{object:.+}").
    			HandlerFunc(s3APIMiddleware(api.NewMultipartUploadHandler)).
    			Queries("uploads", "")
    		// AbortMultipartUpload
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 15:25:16 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  8. internal/etag/etag.go

    // object that has been uploaded using the S3 multipart
    // API.
    // An S3 multipart ETag has a -<part-number> suffix.
    func (e ETag) IsMultipart() bool {
    	return len(e) > 16 && !e.IsEncrypted() && bytes.ContainsRune(e, '-')
    }
    
    // Parts returns the number of object parts that are
    // referenced by this ETag. It returns 1 if the object
    // has been uploaded using the S3 singlepart API.
    //
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 10 21:09:36 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  9. cmd/object-multipart-handlers.go

    	}
    
    	if s3Error := checkRequestAuthType(ctx, r, policy.GetObjectAction, srcBucket, srcObject); s3Error != ErrNone {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    		return
    	}
    
    	uploadID := r.Form.Get(xhttp.UploadID)
    	partIDString := r.Form.Get(xhttp.PartNumber)
    
    	partID, err := strconv.Atoi(partIDString)
    	if err != nil || partID <= 0 {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrInvalidPart), r.URL)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Aug 31 18:25:48 UTC 2024
    - 39.2K bytes
    - Viewed (0)
  10. cmd/object_api_suite_test.go

    		t.Fatalf("%s: <ERROR> %s", instanceType, err)
    	}
    	res, err := obj.NewMultipartUpload(context.Background(), "bucket", "key", opts)
    	if err != nil {
    		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++ {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 02 15:13:05 UTC 2024
    - 33.3K bytes
    - Viewed (0)
Back to top