- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for PendingTasks (0.12 sec)
-
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())) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jun 06 09:36:25 UTC 2024 - 2.3K bytes - Viewed (0) -
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) }
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/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())
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 131.9K bytes - Viewed (0)