Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for evalActionFromLifecycle (0.09 sec)

  1. cmd/metacache-server-pool.go

    	if !o.Versioned && !o.V1 {
    		fi, err := obj.fileInfo(o.Bucket)
    		if err != nil {
    			return
    		}
    		objInfo := fi.ToObjectInfo(o.Bucket, obj.name, versioned)
    		if o.Lifecycle != nil {
    			act := evalActionFromLifecycle(ctx, *o.Lifecycle, o.Retention, o.Replication.Config, objInfo).Action
    			skip = act.Delete() && !act.DeleteRestored()
    		}
    	}
    
    	fiv, err := obj.fileInfoVersions(o.Bucket)
    	if err != nil {
    		return
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon May 26 07:06:43 UTC 2025
    - 12.9K bytes
    - Viewed (0)
  2. cmd/global-heal.go

    			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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 04 13:49:12 UTC 2025
    - 16.2K bytes
    - Viewed (0)
  3. cmd/data-scanner_test.go

    			obj:       delMarker,
    			want:      lifecycle.DelMarkerDeleteAllVersionsAction,
    		},
    	}
    
    	for i, test := range tests {
    		t.Run(fmt.Sprintf("TestEvalAction-%d", i), func(t *testing.T) {
    			gotEvent := evalActionFromLifecycle(t.Context(), test.ilm, *test.retention, nil, test.obj)
    			if gotEvent.Action != test.want {
    				t.Fatalf("Expected %v but got %v", test.want, gotEvent.Action)
    			}
    		})
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool-decom.go

    			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
    				applyExpiryOnTransitionedObject(ctx, z, objInfo, evt, lcEventSrc_Decom)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 42.1K bytes
    - Viewed (1)
  5. cmd/data-scanner.go

    	}
    
    	if len(toDel) > 0 {
    		globalExpiryState.enqueueNoncurrentVersions(i.bucket, toDel, noncurrentEvents)
    	}
    	i.alertExcessiveVersions(remainingVersions, cumulativeSize)
    }
    
    func evalActionFromLifecycle(ctx context.Context, lc lifecycle.Lifecycle, lr lock.Retention, rcfg *replication.Config, obj ObjectInfo) lifecycle.Event {
    	event := lc.Eval(obj.ToLifecycleOpts())
    	if serverDebugLog {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.5K bytes
    - Viewed (0)
  6. cmd/erasure-server-pool-rebalance.go

    			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
    			}
    			return false
    		}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Sep 04 20:47:24 UTC 2025
    - 28.9K bytes
    - Viewed (0)
Back to top