Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 19 of 19 for activePods (0.17 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
Back to top