Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for enqueueByNewerNoncurrent (0.22 sec)

  1. cmd/bucket-lifecycle.go

    	}
    	select {
    	case <-GlobalContext.Done():
    	case wrkr <- task:
    	default:
    		es.stats.missedExpiryTasks.Add(1)
    	}
    }
    
    // enqueueByNewerNoncurrent enqueues object versions expired by
    // NewerNoncurrentVersions limit for expiry.
    func (es *expiryState) enqueueByNewerNoncurrent(bucket string, versions []ObjectToDelete, lcEvent lifecycle.Event) {
    	if len(versions) == 0 {
    		return
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  2. cmd/data-scanner.go

    		}
    
    		toDel = append(toDel, ObjectToDelete{
    			ObjectV: ObjectV{
    				ObjectName: obj.Name,
    				VersionID:  obj.VersionID,
    			},
    		})
    	}
    
    	if len(toDel) > 0 {
    		expState.enqueueByNewerNoncurrent(i.bucket, toDel, event)
    	}
    	return objectInfos, nil
    }
    
    // applyVersionActions will apply lifecycle checks on all versions of a scanned item. Returns versions that remain
    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