- Sort Score
- Num 10 results
- Language All
Results 1 - 3 of 3 for PendingTasks (0.15 seconds)
-
cmd/bucket-lifecycle.go
mu sync.RWMutex workers atomic.Pointer[[]chan expiryOp] ctx context.Context objAPI ObjectLayer stats expiryStats } // PendingTasks returns the number of pending ILM expiry tasks. func (es *expiryState) PendingTasks() int { w := es.workers.Load() if w == nil || len(*w) == 0 { return 0 } var tasks int for _, wrkr := range *w { tasks += len(wrkr) }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 33.7K bytes - Click Count (0) -
cmd/metrics-v3-ilm.go
if globalExpiryState != nil { m.Set(expiryPendingTasks, float64(globalExpiryState.PendingTasks())) } if globalTransitionState != nil { m.Set(transitionActiveTasks, float64(globalTransitionState.ActiveTasks())) m.Set(transitionPendingTasks, float64(globalTransitionState.PendingTasks())) m.Set(transitionMissedImmediateTasks, float64(globalTransitionState.MissedImmediateTasks())) }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu Jun 06 09:36:25 GMT 2024 - 2.3K bytes - Click Count (0) -
cmd/metrics-v2.go
} trMissedTasks := MetricV2{ Description: getTransitionMissedTasksMD(), } if globalExpiryState != nil { expPendingTasks.Value = float64(globalExpiryState.PendingTasks()) expMissedTasks.Value = float64(globalExpiryState.stats.MissedTasks()) expMissedFreeVersions.Value = float64(globalExpiryState.stats.MissedFreeVersTasks())Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 133.6K bytes - Click Count (0)