- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for enqueueNoncurrentVersions (0.54 sec)
-
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) -
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)