- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for queueTransitionTask (0.27 sec)
-
cmd/bucket-lifecycle.go
activeTasks atomic.Int64 missedImmediateTasks atomic.Int64 lastDayMu sync.RWMutex lastDayStats map[string]*lastDayTierStats } func (t *transitionState) queueTransitionTask(oi ObjectInfo, event lifecycle.Event, src lcEventSrc) { task := transitionTask{objInfo: oi, event: event, src: src} select { case <-t.ctx.Done(): case t.transitionCh <- task: default: switch src {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Oct 23 15:35:37 UTC 2024 - 33.7K bytes - Viewed (0) -
cmd/data-scanner.go
} return event } func applyTransitionRule(event lifecycle.Event, src lcEventSrc, obj ObjectInfo) bool { if obj.DeleteMarker || obj.IsDir { return false } globalTransitionState.queueTransitionTask(obj, event, src) return true } func applyExpiryOnTransitionedObject(ctx context.Context, objLayer ObjectLayer, obj ObjectInfo, lcEvent lifecycle.Event, src lcEventSrc) (ok bool) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 22 21:10:34 UTC 2024 - 48.4K bytes - Viewed (0)