- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for enqueueByNewerNoncurrent (0.36 sec)
-
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 }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0) -
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
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 47.4K bytes - Viewed (0)