Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 15 of 15 for ActivePods (0.14 sec)

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