Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for evalActionFromLifecycle (0.5 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
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 12.8K bytes
    - Viewed (0)
  2. 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) {
    			if got := evalActionFromLifecycle(context.TODO(), test.ilm, test.retention, nil, test.obj); got.Action != test.want {
    				t.Fatalf("Expected %v but got %v", test.want, got)
    			}
    		})
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 11:18:58 GMT 2024
    - 6.9K bytes
    - Viewed (0)
  3. 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
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 15K bytes
    - Viewed (1)
  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)
    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)
  5. cmd/data-scanner.go

    			return
    		}
    
    		rcfg, err = getReplicationConfig(ctx, i.bucket)
    		if err != nil {
    			scannerLogOnceIf(ctx, err, i.bucket)
    			return
    		}
    	}
    
    	lcEvt := evalActionFromLifecycle(ctx, *i.lifeCycle, lr, rcfg, oi)
    	if i.debug {
    		if versionID != "" {
    			console.Debugf(applyActionsLogPrefix+" lifecycle: %q (version-id=%s), Initial scan: %v\n", i.objectPath(), versionID, lcEvt.Action)
    		} else {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 11:18:58 GMT 2024
    - 47.6K 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
    		}
    
    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)
  7. cmd/erasure-object.go

    			// based on the latest objectInfo and see if the object still
    			// qualifies for deletion.
    			if gerr == nil {
    				var isErr bool
    				evt := evalActionFromLifecycle(ctx, *lc, rcfg, replcfg, goi)
    				switch evt.Action {
    				case lifecycle.DeleteAllVersionsAction, lifecycle.DelMarkerDeleteAllVersionsAction:
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  8. cmd/erasure-server-pool.go

    		//   }
    		// }
    		objInfo, err := z.GetObjectInfo(ctx, bucket, path.Dir(prefix), ObjectOptions{NoLock: true})
    		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() {
    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)
  9. cmd/object-handlers.go

    				return
    			}
    			replcfg, err := getReplicationConfig(ctx, bucket)
    			if err != nil {
    				writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    				return
    			}
    			event := evalActionFromLifecycle(ctx, *lc, rcfg, replcfg, objInfo)
    			if event.Action.Delete() {
    				// apply whatever the expiry rule is.
    				applyExpiryRule(event, lcEventSrc_s3GetObject, objInfo)
    				if !event.Action.DeleteRestored() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 20:15:54 GMT 2024
    - 125.2K bytes
    - Viewed (0)
Back to top