Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 17 of 17 for ToObjectInfo (0.23 sec)

  1. cmd/global-heal.go

    			}
    		}
    
    		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
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 15K bytes
    - Viewed (1)
  2. cmd/erasure-server-pool.go

    				if err != nil {
    					return
    				}
    				if opts.Filter != nil {
    					if opts.Filter(fi) {
    						if !send(fi.ToObjectInfo(bucket, fi.Name, vcfg != nil && vcfg.Versioned(fi.Name))) {
    							return
    						}
    					}
    				} else {
    					if !send(fi.ToObjectInfo(bucket, fi.Name, vcfg != nil && vcfg.Versioned(fi.Name))) {
    						return
    					}
    				}
    				continue
    			}
    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)
  3. cmd/erasure-server-pool-decom.go

    		set := set
    
    		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
    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)
  4. cmd/erasure-server-pool-rebalance.go

    		set := set
    
    		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)
    			if evt.Action.Delete() {
    				globalExpiryState.enqueueByDays(objInfo, evt, lcEventSrc_Rebal)
    				return true
    			}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
  5. cmd/erasure-healing.go

    			latestMeta.Erasure.ParityBlocks, latestMeta.Erasure.BlockSize)
    		if err != nil {
    			return result, err
    		}
    	}
    
    	result.ObjectSize, err = latestMeta.ToObjectInfo(bucket, object, true).GetActualSize()
    	if err != nil {
    		return result, err
    	}
    
    	// Loop to find number of disks with valid data, per-drive
    	// data state and a list of outdated disks on which data needs
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  6. cmd/erasure-multipart.go

    			break
    		}
    	}
    
    	// we are adding a new version to this object under the namespace lock, so this is the latest version.
    	fi.IsLatest = true
    
    	// Success, return object info.
    	return fi.ToObjectInfo(bucket, object, opts.Versioned || opts.VersionSuspended), nil
    }
    
    // AbortMultipartUpload - aborts an ongoing multipart operation
    // signified by the input uploadID. This is an atomic operation
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K 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()
    		}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
Back to top