Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for enqueueByDays (0.12 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
    			}
    		}
    
    		send := func(result healEntryResult) bool {
    			select {
    			case <-ctx.Done():
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  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 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  3. 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() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  4. 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
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool.go

    				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
    						}
    					}
    				}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  6. 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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
Back to top