Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 38 for UploadID (0.16 sec)

  1. cmd/object-api-multipart_test.go

    	}
    	uploadID := res.UploadID
    
    	abortTestCases := []struct {
    		bucketName      string
    		objName         string
    		uploadID        string
    		expectedErrType error
    	}{
    		{"--", object, uploadID, BucketNameInvalid{}},
    		{"foo", object, uploadID, BucketNotFound{}},
    		{bucket, object, "foo-foo", InvalidUploadID{}},
    		{bucket, object, uploadID, nil},
    	}
    
    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/object-api-input-checks.go

    	if err != nil {
    		return MalformedUploadID{
    			UploadID: uploadID,
    		}
    	}
    	return checkObjectArgs(ctx, bucket, object)
    }
    
    // Checks for PutObjectPart arguments validity, also validates if bucket exists.
    func checkPutObjectPartArgs(ctx context.Context, bucket, object, uploadID string) error {
    	return checkMultipartObjectArgs(ctx, bucket, object, uploadID)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  3. cmd/erasure-multipart.go

    	if !opts.NoAuditLog {
    		auditObjectErasureSet(ctx, "GetMultipartInfo", object, &er)
    	}
    
    	result := MultipartInfo{
    		Bucket:   bucket,
    		Object:   object,
    		UploadID: uploadID,
    	}
    
    	fi, _, err := er.checkUploadIDExists(ctx, bucket, object, uploadID, false)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  4. cmd/erasure-utils.go

    }
    
    // returns deploymentID from uploadID
    func getDeplIDFromUpload(uploadID string) (string, error) {
    	uploadBytes, err := base64.RawURLEncoding.DecodeString(uploadID)
    	if err != nil {
    		return "", fmt.Errorf("error parsing uploadID %s (%w)", uploadID, err)
    	}
    	slc := strings.SplitN(string(uploadBytes), ".", 2)
    	if len(slc) != 2 {
    		return "", fmt.Errorf("uploadID %s has incorrect format", uploadID)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jan 31 02:11:45 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  5. cmd/api-response.go

    	}
    }
    
    // generates InitiateMultipartUploadResponse for given bucket, key and uploadID.
    func generateInitiateMultipartUploadResponse(bucket, key, uploadID string) InitiateMultipartUploadResponse {
    	return InitiateMultipartUploadResponse{
    		Bucket:   bucket,
    		Key:      key,
    		UploadID: uploadID,
    	}
    }
    
    // generates CompleteMultipartUploadResponse for given bucket, key, location and ETag.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 19:27:06 UTC 2024
    - 33.4K bytes
    - Viewed (0)
  6. cmd/object-api-datatypes.go

    	UserDefined map[string]string
    
    	// ChecksumAlgorithm if set
    	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.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  7. cmd/warm-backend-gcs.go

    		err = BucketNotFound{
    			Bucket: bucket,
    		}
    		return err
    	case "storage: object doesn't exist":
    		if uploadID != "" {
    			err = InvalidUploadID{
    				UploadID: uploadID,
    			}
    		} else {
    			err = ObjectNotFound{
    				Bucket: bucket,
    				Object: object,
    			}
    		}
    		return err
    	}
    
    	googleAPIErr, ok := err.(*googleapi.Error)
    	if !ok {
    		// We don't interpret non MinIO errors. As minio errors will
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  8. cmd/api-router.go

    			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:.*}")
    		// ListObjectParts
    		router.Methods(http.MethodGet).Path("/{object:.+}").
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 15:25:16 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  9. cmd/erasure-server-pool.go

    		Object:   object,
    		UploadID: uploadID,
    	}
    }
    
    func (z *erasureServerPools) GetMultipartInfo(ctx context.Context, bucket, object, uploadID string, opts ObjectOptions) (MultipartInfo, error) {
    	if err := checkListPartsArgs(ctx, bucket, object, uploadID); err != nil {
    		return MultipartInfo{}, err
    	}
    
    	uploadIDLock := z.NewNSLock(bucket, pathJoin(object, uploadID))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  10. cmd/object-handlers_test.go

    			uploadID:         uploadID,
    			copySourceHeader: url.QueryEscape(SlashSeparator + bucketName + SlashSeparator + testObject),
    			accessKey:        credentials.AccessKey,
    			secretKey:        credentials.SecretKey,
    
    			expectedRespStatus: http.StatusNotFound,
    		},
    
    		// Test case - 4.
    		// Test case with valid byte range.
    		{
    			bucketName:       bucketName,
    			uploadID:         uploadID,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:10:44 UTC 2024
    - 163.2K bytes
    - Viewed (0)
Back to top