Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for ToObjectInfo (0.19 sec)

  1. cmd/erasure-object.go

    	if err != nil {
    		return oi, toObjectErr(err, srcBucket, srcObject)
    	}
    	if fi.Deleted {
    		if srcOpts.VersionID == "" {
    			return oi, toObjectErr(errFileNotFound, srcBucket, srcObject)
    		}
    		return fi.ToObjectInfo(srcBucket, srcObject, srcOpts.Versioned || srcOpts.VersionSuspended), toObjectErr(errMethodNotAllowed, srcBucket, srcObject)
    	}
    
    	filterOnlineDisksInplace(fi, metaArr, onlineDisks)
    
    	versionID := srcInfo.VersionID
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  2. cmd/batch-handlers.go

    			time.Sleep(delay + time.Duration(rnd.Float64()*float64(delay)))
    			continue
    		}
    
    		break
    	}
    
    	return nil
    }
    
    // toObjectInfo converts minio.ObjectInfo to ObjectInfo
    func toObjectInfo(bucket, object string, objInfo miniogo.ObjectInfo) ObjectInfo {
    	tags, _ := tags.MapToObjectTags(objInfo.UserTags)
    	oi := ObjectInfo{
    		Bucket:                    bucket,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  3. cmd/erasure-metadata.go

    		len(fi.Erasure.Distribution) == (dataBlocks+parityBlocks))
    	return ((dataBlocks >= parityBlocks) &&
    		(dataBlocks > 0) && (parityBlocks >= 0) &&
    		correctIndexes)
    }
    
    // ToObjectInfo - Converts metadata to object info.
    func (fi FileInfo) ToObjectInfo(bucket, object string, versioned bool) ObjectInfo {
    	object = decodeDirObject(object)
    	versionID := fi.VersionID
    	if versioned && versionID == "" {
    		versionID = nullVersionID
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 21.3K bytes
    - Viewed (0)
  4. cmd/data-scanner.go

    		for _, fi := range fivs {
    			objectInfos = append(objectInfos, fi.ToObjectInfo(i.bucket, i.objectPath(), versioned))
    		}
    		return objectInfos, nil
    	}
    
    	overflowVersions := fivs[lim+1:]
    	// Retain the current version + most recent lim noncurrent versions
    	for _, fi := range fivs[:lim+1] {
    		objectInfos = append(objectInfos, fi.ToObjectInfo(i.bucket, i.objectPath(), versioned))
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  5. cmd/global-heal.go

    		disks = disks[:expectedDisks]
    
    		filterLifecycle := func(bucket, object string, fi FileInfo) bool {
    			if lc == nil {
    				return false
    			}
    			versioned := vc != nil && vc.Versioned(object)
    			objInfo := fi.ToObjectInfo(bucket, object, versioned)
    
    			evt := evalActionFromLifecycle(ctx, *lc, lr, rcfg, objInfo)
    			switch {
    			case evt.Action.DeleteRestored(): // if restored copy has expired,delete it synchronously
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  6. cmd/encryption-v1.go

    	data := o.Checksum
    	if len(data) == 0 {
    		return nil
    	}
    	if part > 0 && !crypto.SSEC.IsEncrypted(o.UserDefined) {
    		// already decrypted in ToObjectInfo for multipart objects
    		for _, pi := range o.Parts {
    			if pi.Number == part {
    				return pi.Checksums
    			}
    		}
    	}
    	if _, encrypted := crypto.IsEncrypted(o.UserDefined); encrypted {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:06:08 UTC 2024
    - 37.2K bytes
    - Viewed (0)
  7. cmd/xl-storage.go

    					sizeS.tiers[tier] = st.add(oi.tierStats())
    				}
    			}
    		}
    
    		// apply tier sweep action on free versions
    		for _, freeVersion := range fivs.FreeVersions {
    			oi := freeVersion.ToObjectInfo(item.bucket, item.objectPath(), versioned)
    			done = globalScannerMetrics.time(scannerMetricTierObjSweep)
    			globalExpiryState.enqueueFreeVersion(oi)
    			done()
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
Back to top