Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for enqueueNoncurrentVersions (0.54 sec)

  1. cmd/bucket-lifecycle.go

    		return
    	}
    	select {
    	case <-GlobalContext.Done():
    	case wrkr <- task:
    	default:
    		es.stats.missedExpiryTasks.Add(1)
    	}
    }
    
    func (es *expiryState) enqueueNoncurrentVersions(bucket string, versions []ObjectToDelete, events []lifecycle.Event) {
    	if len(versions) == 0 {
    		return
    	}
    
    	task := noncurrentVersionsTask{
    		bucket:   bucket,
    		versions: versions,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 33.7K bytes
    - Viewed (0)
  2. cmd/data-scanner.go

    		// expired or was a dangling object.
    		if fn != nil {
    			fn(oi, size, actualSz, sizeS)
    		}
    		cumulativeSize += size
    	}
    
    	if len(toDel) > 0 {
    		globalExpiryState.enqueueNoncurrentVersions(i.bucket, toDel, noncurrentEvents)
    	}
    	i.alertExcessiveVersions(remainingVersions, cumulativeSize)
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.5K bytes
    - Viewed (0)
Back to top