Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 482 for pod6 (0.07 sec)

  1. pkg/controller/controller_utils_test.go

    	}
    
    	type test struct {
    		name         string
    		pods         []podData
    		wantPodNames []string
    	}
    
    	tests := []test{
    		{
    			name: "Filters active pods",
    			pods: []podData{
    				{podName: "pod-1", podPhase: v1.PodSucceeded},
    				{podName: "pod-2", podPhase: v1.PodFailed},
    				{podName: "pod-3"},
    				{podName: "pod-4"},
    				{podName: "pod-5"},
    			},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 39.4K bytes
    - Viewed (0)
  2. pkg/kubelet/preemption/preemption_test.go

    	if f.errDuringPodKilling {
    		f.killedPods = []*v1.Pod{}
    		return fmt.Errorf("problem killing pod %v", pod)
    	}
    	f.killedPods = append(f.killedPods, pod)
    	return nil
    }
    
    type fakePodProvider struct {
    	pods []*v1.Pod
    }
    
    func newFakePodProvider() *fakePodProvider {
    	return &fakePodProvider{pods: []*v1.Pod{}}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jul 24 10:04:08 UTC 2022
    - 19.2K bytes
    - Viewed (0)
  3. pkg/controller/podautoscaler/replica_calculator.go

    			ignoredPods.Insert(pod.Name)
    			continue
    		}
    		// Pending pods are ignored.
    		if pod.Status.Phase == v1.PodPending {
    			unreadyPods.Insert(pod.Name)
    			continue
    		}
    		// Pods missing metrics.
    		metric, found := metrics[pod.Name]
    		if !found {
    			missingPods.Insert(pod.Name)
    			continue
    		}
    		// Unready pods are ignored.
    		if resource == v1.ResourceCPU {
    			var unready bool
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Aug 19 03:31:34 UTC 2023
    - 20.1K bytes
    - Viewed (0)
  4. staging/src/k8s.io/api/apps/v1beta2/types_swagger_doc_generated.go

    	"podManagementPolicy":                  "podManagementPolicy controls how pods are created during initial scale up, when replacing pods on nodes, or when scaling down. The default policy is `OrderedReady`, where pods are created in increasing order (pod-0, then pod-1, etc) and the controller will wait until each pod is ready before continuing. When scaling...
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 10 05:34:30 UTC 2023
    - 34.3K bytes
    - Viewed (0)
  5. cmd/kubeadm/app/util/marshal_test.go

    	}
    
    	pod2, ok := obj2.(*corev1.Pod)
    	if !ok {
    		t.Fatal("did not get a Pod")
    	}
    
    	if pod2.Name != pod.Name {
    		t.Errorf("expected %q, got %q", pod.Name, pod2.Name)
    	}
    
    	if pod2.Namespace != pod.Namespace {
    		t.Errorf("expected %q, got %q", pod.Namespace, pod2.Namespace)
    	}
    
    	if !reflect.DeepEqual(pod2.Labels, pod.Labels) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 29 05:14:21 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  6. staging/src/k8s.io/api/autoscaling/v2beta1/types_swagger_doc_generated.go

    	"targetAverageValue":       "targetAverageValue is the target value of the average of the resource metric across all relevant pods, as a raw value (instead of as a percentage of the request), similar to the \"pods\" metric source type.",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 27 23:13:24 UTC 2023
    - 20.4K bytes
    - Viewed (0)
  7. pkg/scheduler/internal/cache/cache.go

    	key, err := framework.GetPodKey(pod)
    	if err != nil {
    		return err
    	}
    
    	cache.mu.Lock()
    	defer cache.mu.Unlock()
    
    	currState, ok := cache.podStates[key]
    	if ok && currState.pod.Spec.NodeName != pod.Spec.NodeName {
    		return fmt.Errorf("pod %v(%v) was assumed on %v but assigned to %v", key, klog.KObj(pod), pod.Spec.NodeName, currState.pod.Spec.NodeName)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 24 09:56:48 UTC 2023
    - 24.9K bytes
    - Viewed (0)
  8. staging/src/k8s.io/api/autoscaling/v1/types_swagger_doc_generated.go

    	"targetAverageValue":       "targetAverageValue is the target value of the average of the resource metric across all relevant pods, as a raw value (instead of as a percentage of the request), similar to the \"pods\" metric source type.",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 27 23:13:24 UTC 2023
    - 21.4K bytes
    - Viewed (0)
  9. pkg/controller/tainteviction/taint_eviction.go

    		getPodsAssignedToNode: func(nodeName string) ([]*v1.Pod, error) {
    			objs, err := podIndexer.ByIndex("spec.nodeName", nodeName)
    			if err != nil {
    				return nil, err
    			}
    			pods := make([]*v1.Pod, 0, len(objs))
    			for _, obj := range objs {
    				pod, ok := obj.(*v1.Pod)
    				if !ok {
    					continue
    				}
    				pods = append(pods, pod)
    			}
    			return pods, nil
    		},
    		taintedNodes: make(map[string][]v1.Taint),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  10. cni/pkg/repair/repair_test.go

    			c := &Controller{cfg: tt.config}
    			assert.Equal(t, c.matchesFilter(tt.pod), tt.want)
    		})
    	}
    }
    
    func fakeClient(pods ...*corev1.Pod) kube.Client {
    	var csPods []runtime.Object
    
    	for _, pod := range pods {
    		csPods = append(csPods, pod.DeepCopy())
    	}
    	return kube.NewFakeClient(csPods...)
    }
    
    func makePodLabelMap(pods []*corev1.Pod) (podmap map[string]string) {
    	podmap = map[string]string{}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Oct 24 03:31:28 UTC 2023
    - 10.6K bytes
    - Viewed (0)
Back to top