- Sort Score
- Result 10 results
- Languages All
Results 11 - 19 of 19 for activePods (0.36 sec)
-
pkg/controller/job/indexed_job_utils.go
// not covered by `activePods`, `succeededIndexes` or `failedIndexes`. // In cases of PodReplacementPolicy as Failed we will include `terminatingPods` in this list. func firstPendingIndexes(jobCtx *syncJobCtx, count, completions int) []int { if count == 0 { return nil } active := getIndexes(jobCtx.activePods) result := make([]int, 0, count)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 21 00:44:53 UTC 2023 - 17.5K bytes - Viewed (0) -
pkg/kubelet/eviction/eviction_manager.go
if len(activePods) == 0 { klog.ErrorS(nil, "Eviction manager: eviction thresholds have been met, but no pods are active to evict") return nil, nil } // rank the running pods for eviction for the specified resource rank(activePods, statsFunc) klog.InfoS("Eviction manager: pods ranked for eviction", "pods", klog.KObjSlice(activePods))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 27 18:55:56 UTC 2024 - 24.6K bytes - Viewed (0) -
pkg/scheduler/metrics/metrics.go
} // GetGather returns the gatherer. It used by test case outside current package. func GetGather() metrics.Gatherer { return legacyregistry.DefaultGatherer } // 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
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 08:22:53 UTC 2024 - 11.1K bytes - Viewed (0) -
pkg/kubelet/nodeshutdown/nodeshutdown_manager_linux.go
return fmt.Errorf("node is shutting down") } return nil } func (m *managerImpl) processShutdownEvent() error { m.logger.V(1).Info("Shutdown manager processing shutdown event") activePods := m.getPods() defer func() { m.dbusCon.ReleaseInhibitLock(m.inhibitLock) m.logger.V(1).Info("Shutdown manager completed processing shutdown event, node will shutdown shortly") }()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 09 08:02:40 UTC 2022 - 15.5K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/topology_hints_test.go
healthyDevices: make(map[string]sets.Set[string]), allocatedDevices: make(map[string]sets.Set[string]), podDevices: newPodDevices(), sourcesReady: &sourcesReadyStub{}, activePods: func() []*v1.Pod { return []*v1.Pod{tc.pod} }, numaNodes: []int{0, 1}, } for r := range tc.devices { m.allDevices[r] = make(DeviceInstances) m.healthyDevices[r] = sets.New[string]()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 13:02:15 UTC 2023 - 47.5K bytes - Viewed (0) -
pkg/controller/controller_utils.go
} return false } // ActivePods type allows custom sorting of pods so a controller can pick the best ones to delete. type ActivePods []*v1.Pod func (s ActivePods) Len() int { return len(s) } func (s ActivePods) Swap(i, j int) { s[i], s[j] = s[j], s[i] } func (s ActivePods) Less(i, j int) bool { // 1. Unassigned < assigned
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 12 15:34:44 UTC 2024 - 47.6K bytes - Viewed (0) -
istioctl/pkg/kubeinject/kubeinject.go
options := metav1.ListOptions{LabelSelector: selector} sortBy := func(pods []*corev1.Pod) sort.Interface { return sort.Reverse(podutils.ActivePods(pods)) } podList, err := client.Pods(namespace).List(context.TODO(), options) if err != nil { return nil, err } pods := make([]*corev1.Pod, 0, len(podList.Items)) for i := range podList.Items {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 29 02:29:02 UTC 2024 - 21.6K bytes - Viewed (0) -
pkg/controller/controller_utils_test.go
for i := 0; i < 20; i++ { idx := rand.Perm(numPods) randomizedPods := make([]*v1.Pod, numPods) for j := 0; j < numPods; j++ { randomizedPods[j] = &test.pods[idx[j]] } sort.Sort(ActivePods(randomizedPods)) gotOrder := make([]string, len(randomizedPods)) for i := range randomizedPods { gotOrder[i] = randomizedPods[i].Name }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 39.4K bytes - Viewed (0) -
pkg/kubelet/metrics/metrics.go
RunningPodsKey = "running_pods" RunningContainersKey = "running_containers" DesiredPodCountKey = "desired_pods" ActivePodCountKey = "active_pods" MirrorPodCountKey = "mirror_pods" WorkingPodCountKey = "working_pods" OrphanedRuntimePodTotalKey = "orphaned_runtime_pods_total"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 22 15:13:25 UTC 2024 - 45.6K bytes - Viewed (0)