- Sort Score
- Num 10 results
- Language All
Results 1 - 2 of 2 for enqueueNoncurrentVersions (0.09 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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,Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 33.7K bytes - Click Count (0) -
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) }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 45.5K bytes - Click Count (0)