Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for enqueueByDays (0.25 sec)

  1. cmd/global-heal.go

    				applyExpiryOnTransitionedObject(ctx, newObjectLayerFn(), objInfo, evt, lcEventSrc_Heal)
    				return false
    			case evt.Action.Delete():
    				globalExpiryState.enqueueByDays(objInfo, evt, lcEventSrc_Heal)
    				return true
    			default:
    				return false
    			}
    		}
    
    		// Collect updates to tracker from concurrent healEntry calls
    		results := make(chan healEntryResult, 1000)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Apr 08 09:22:13 GMT 2024
    - 14.2K bytes
    - Viewed (1)
  2. cmd/bucket-lifecycle.go

    		return
    	}
    	select {
    	case <-GlobalContext.Done():
    	case wrkr <- task:
    	default:
    		es.stats.missedFreeVersTasks.Add(1)
    	}
    }
    
    // enqueueByDays enqueues object versions expired by days for expiry.
    func (es *expiryState) enqueueByDays(oi ObjectInfo, event lifecycle.Event, src lcEventSrc) {
    	task := expiryTask{objInfo: oi, event: event, src: src}
    	wrkr := es.getWorkerCh(task.OpHash())
    	if wrkr == nil {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  3. cmd/metacache-server-pool.go

    		if o.Lifecycle != nil {
    			evt := evalActionFromLifecycle(ctx, *o.Lifecycle, o.Retention, o.Replication.Config, objInfo)
    			if evt.Action.Delete() {
    				globalExpiryState.enqueueByDays(objInfo, evt, lcEventSrc_s3ListObjects)
    				if !evt.Action.DeleteRestored() {
    					continue
    				} // queue version for replication upon expired restored copies if needed.
    			}
    		}
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 12.8K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool-decom.go

    				applyExpiryOnTransitionedObject(ctx, z, objInfo, evt, lcEventSrc_Decom)
    				return false
    			case evt.Action.Delete():
    				globalExpiryState.enqueueByDays(objInfo, evt, lcEventSrc_Decom)
    				return true
    			default:
    				return false
    			}
    		}
    
    		decommissionEntry := func(entry metaCacheEntry) {
    			defer wk.Give()
    
    			if entry.isDir() {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 40.4K bytes
    - Viewed (1)
  5. cmd/erasure-server-pool-rebalance.go

    			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
    			}
    
    			return false
    		}
    
    		rebalanceEntry := func(entry metaCacheEntry) {
    			defer wk.Give()
    
    			if entry.isDir() {
    				return
    			}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 26.5K bytes
    - Viewed (0)
  6. cmd/erasure-server-pool.go

    		if err == nil {
    			if opts.Lifecycle != nil {
    				evt := evalActionFromLifecycle(ctx, *opts.Lifecycle, opts.Retention, opts.Replication.Config, objInfo)
    				if evt.Action.Delete() {
    					globalExpiryState.enqueueByDays(objInfo, evt, lcEventSrc_s3ListObjects)
    					if !evt.Action.DeleteRestored() {
    						// Skip entry if ILM action was DeleteVersionAction or DeleteAction
    						return loi, nil
    					}
    				}
    			}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 77.8K bytes
    - Viewed (0)
  7. cmd/data-scanner.go

    }
    
    // Apply object, object version, restored object or restored object version action on the given object
    func applyExpiryRule(event lifecycle.Event, src lcEventSrc, obj ObjectInfo) bool {
    	globalExpiryState.enqueueByDays(obj, event, src)
    	return true
    }
    
    // Perform actions (removal or transitioning of objects), return true the action is successfully performed
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Apr 15 09:40:19 GMT 2024
    - 46.9K bytes
    - Viewed (0)
Back to top