- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for pendingPod (3.63 sec)
-
pkg/scheduler/metrics/metrics.go
} // ActivePods returns the pending pods metrics with the label active func ActivePods() metrics.GaugeMetric { return pendingPods.With(metrics.Labels{"queue": "active"}) } // BackoffPods returns the pending pods metrics with the label backoff func BackoffPods() metrics.GaugeMetric { return pendingPods.With(metrics.Labels{"queue": "backoff"}) } // UnschedulablePods returns the pending pods metrics with the label unschedulable
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 08:22:53 UTC 2024 - 11.1K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/main/java/org/gradle/model/internal/registry/ModelGraph.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 7.8K bytes - Viewed (0) -
pkg/proxy/endpointslicecache.go
appliedData, appliedOk := cache.trackerByServiceMap[serviceKey].applied[sliceKey] pendingData, pendingOk := cache.trackerByServiceMap[serviceKey].pending[sliceKey] // If there's already a pending value, return whether or not this would // change that. if pendingOk { return !reflect.DeepEqual(esData, pendingData) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 21:07:21 UTC 2024 - 11.7K bytes - Viewed (1) -
pkg/scheduler/internal/queue/scheduling_queue.go
var pendingPodsSummary = "activeQ:%v; backoffQ:%v; unschedulablePods:%v" // PendingPods returns all the pending pods in the queue; accompanied by a debugging string // recording showing the number of pods in each queue respectively. // This function is used for debugging purposes in the scheduler cache dumper and comparer. func (p *PriorityQueue) PendingPods() ([]*v1.Pod, string) { p.lock.RLock() defer p.lock.RUnlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0) -
pkg/controller/job/job_controller_test.go
pods = append(pods, newPod) } return pods } func setPodsStatuses(podIndexer cache.Indexer, job *batch.Job, pendingPods, activePods, succeededPods, failedPods, terminatingPods, readyPods int) { for _, pod := range newPodList(pendingPods, v1.PodPending, job) { podIndexer.Add(pod) } running := newPodList(activePods, v1.PodRunning, job) for i, p := range running { if i >= readyPods {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0) -
pkg/scheduler/scheduler_test.go
// the specific pod from the given priority queue. It returns the found pod in the priority queue. func getPodFromPriorityQueue(queue *internalqueue.PriorityQueue, pod *v1.Pod) *v1.Pod { podList, _ := queue.PendingPods() if len(podList) == 0 { return nil } queryPodKey, err := cache.MetaNamespaceKeyFunc(pod) if err != nil { return nil } for _, foundPod := range podList {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 42K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue_test.go
t.Fatalf("unexpected error from AddUnschedulableIfNotPresent: %v", err) } expectedSet := makeSet([]*v1.Pod{medPriorityPodInfo.Pod, unschedulablePodInfo.Pod, highPriorityPodInfo.Pod}) gotPods, gotSummary := q.PendingPods() if diff := cmp.Diff(expectedSet, makeSet(gotPods)); diff != "" { t.Errorf("Unexpected list of pending Pods (-want, +got):\n%s", diff) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0)