Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for Parts (0.24 sec)

  1. cmd/erasure-server-pool-decom.go

    			return fmt.Errorf("decommissionObject: NewMultipartUpload() %w", err)
    		}
    		defer z.AbortMultipartUpload(ctx, bucket, objInfo.Name, res.UploadID, ObjectOptions{NoAuditLog: true})
    		parts := make([]CompletePart, len(objInfo.Parts))
    		for i, part := range objInfo.Parts {
    			hr, err := hash.NewReader(ctx, io.LimitReader(gr, part.Size), part.Size, "", "", part.ActualSize)
    			if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 15:18:21 GMT 2024
    - 41.5K bytes
    - Viewed (1)
  2. cmd/erasure-object.go

    	}
    
    	var healOnce sync.Once
    
    	for ; partIndex <= lastPartIndex; partIndex++ {
    		if length == totalBytesRead {
    			break
    		}
    
    		partNumber := fi.Parts[partIndex].Number
    
    		// Save the current part name and size.
    		partSize := fi.Parts[partIndex].Size
    
    		partLength := partSize - partOffset
    		// partLength should be adjusted so that we don't write more data than what was requested.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  3. cmd/test-utils_test.go

    	signature := hex.EncodeToString(sumHMAC(signingKey, []byte(stringToSign)))
    
    	// final Authorization header
    	parts := []string{
    		"AWS4-HMAC-SHA256" + " Credential=" + accessKey + SlashSeparator + scope,
    		"SignedHeaders=" + signedHeaders,
    		"Signature=" + signature,
    	}
    	auth := strings.Join(parts, ", ")
    	req.Header.Set("Authorization", auth)
    
    	return signature, nil
    }
    
    // Returns new HTTP request object.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K bytes
    - Viewed (0)
  4. cmd/object-handlers.go

    					ChecksumSHA1:   objInfo.Parts[i].Checksums["SHA1"],
    					ChecksumSHA256: objInfo.Parts[i].Checksums["SHA256"],
    					ChecksumCRC32:  objInfo.Parts[i].Checksums["CRC32"],
    					ChecksumCRC32C: objInfo.Parts[i].Checksums["CRC32C"],
    					PartNumber:     objInfo.Parts[i].Number,
    					Size:           objInfo.Parts[i].Size,
    				})
    			}
    		}
    
    		if OA.ObjectParts.NextPartNumberMarker != partsLength {
    			OA.ObjectParts.IsTruncated = true
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 20:15:54 GMT 2024
    - 125.2K bytes
    - Viewed (0)
  5. cmd/api-errors.go

    		Description:    "You must specify at least one part",
    		HTTPStatusCode: http.StatusBadRequest,
    	},
    	ErrInvalidPartOrder: {
    		Code:           "InvalidPartOrder",
    		Description:    "The list of parts was not in ascending order. The parts list must be specified in order by part number.",
    		HTTPStatusCode: http.StatusBadRequest,
    	},
    	ErrInvalidObjectState: {
    		Code:           "InvalidObjectState",
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 91.4K bytes
    - Viewed (7)
  6. cmd/object-api-errors.go

    	Bucket   string
    	Object   string
    	UploadID string
    }
    
    func (e InvalidUploadID) Error() string {
    	return "Invalid upload id " + e.UploadID
    }
    
    // InvalidPart One or more of the specified parts could not be found
    type InvalidPart struct {
    	PartNumber int
    	ExpETag    string
    	GotETag    string
    }
    
    func (e InvalidPart) Error() string {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 21.3K bytes
    - Viewed (0)
  7. cmd/bucket-replication.go

    			}
    		}
    	}()
    
    	var (
    		hr    *hash.Reader
    		pInfo minio.ObjectPart
    	)
    
    	var objectSize int64
    	for _, partInfo := range objInfo.Parts {
    		if crypto.SSEC.IsEncrypted(objInfo.UserDefined) {
    			hr, err = hash.NewReader(ctx, io.LimitReader(r, partInfo.Size), partInfo.Size, "", "", partInfo.ActualSize)
    		} else {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
  8. cmd/erasure-server-pool.go

    		return MultipartInfo{}, err
    	}
    	return MultipartInfo{}, InvalidUploadID{
    		Bucket:   bucket,
    		Object:   object,
    		UploadID: uploadID,
    	}
    }
    
    // ListObjectParts - lists all uploaded parts to an object in hashedSet.
    func (z *erasureServerPools) ListObjectParts(ctx context.Context, bucket, object, uploadID string, partNumberMarker int, maxParts int, opts ObjectOptions) (ListPartsInfo, error) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  9. cmd/object-api-interface.go

    	ObjectAttributes    map[string]struct{} // Attribute tags defined by the users for the GetObjectAttributes request
    	MaxParts            int                 // used in GetObjectAttributes. Signals how many parts we should return
    	PartNumberMarker    int                 // used in GetObjectAttributes. Signals the part number after which results should be returned
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 17K bytes
    - Viewed (0)
  10. cmd/erasure-sets.go

    	set := s.getHashedSet(object)
    	return set.GetMultipartInfo(ctx, bucket, object, uploadID, opts)
    }
    
    // ListObjectParts - lists all uploaded parts to an object in hashedSet.
    func (s *erasureSets) ListObjectParts(ctx context.Context, bucket, object, uploadID string, partNumberMarker int, maxParts int, opts ObjectOptions) (result ListPartsInfo, err error) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 37.7K bytes
    - Viewed (5)
Back to top