Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 560 for podIps (0.12 sec)

  1. pkg/controller/tainteviction/taint_eviction_test.go

    		pods, err := c.CoreV1().Pods(corev1.NamespaceAll).List(ctx, metav1.ListOptions{
    			FieldSelector: selector.String(),
    			LabelSelector: labels.Everything().String(),
    		})
    		if err != nil {
    			return []*corev1.Pod{}, fmt.Errorf("failed to get Pods assigned to node %v", nodeName)
    		}
    		rPods := make([]*corev1.Pod, len(pods.Items))
    		for i := range pods.Items {
    			rPods[i] = &pods.Items[i]
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 14:24:16 UTC 2024
    - 31.3K bytes
    - Viewed (0)
  2. pkg/scheduler/metrics/metrics.go

    			Name:           "pending_pods",
    			Help:           "Number of pending pods, by the queue type. 'active' means number of pods in activeQ; 'backoff' means number of pods in backoffQ; 'unschedulable' means number of pods in unschedulablePods that the scheduler attempted to schedule and failed; 'gated' is the number of unschedulable pods that the scheduler never attempted to schedule because they are gated.",
    			StabilityLevel: metrics.STABLE,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 08:22:53 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  3. pkg/kubelet/preemption/preemption_test.go

    	return nil
    }
    
    type fakePodProvider struct {
    	pods []*v1.Pod
    }
    
    func newFakePodProvider() *fakePodProvider {
    	return &fakePodProvider{pods: []*v1.Pod{}}
    }
    
    func (f *fakePodProvider) setPods(pods []*v1.Pod) {
    	f.pods = pods
    }
    
    func (f *fakePodProvider) getPods() []*v1.Pod {
    	return f.pods
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jul 24 10:04:08 UTC 2022
    - 19.2K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/server/resourceconfig/helpers_test.go

    				extensionsapiv1beta1.SchemeGroupVersion.WithResource("daemonsets"):  false,
    				appsv1.SchemeGroupVersion.WithResource("deployments"):               true,
    				apiv1.SchemeGroupVersion.WithResource("pods"):                       true,
    			},
    			err: false,
    		},
    		{
    			name: "version-enabled-by-runtimeConfig-override",
    			runtimeConfig: map[string]string{
    				"apps/v1": "",
    			},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 23 18:36:33 UTC 2022
    - 25.2K bytes
    - Viewed (0)
  5. pkg/controller/volume/attachdetach/attach_detach_controller_test.go

    	}
    
    	adc := adcObj.(*attachDetachController)
    
    	pods, err := fakeKubeClient.CoreV1().Pods(v1.NamespaceAll).List(tCtx, metav1.ListOptions{})
    	if err != nil {
    		t.Fatalf("Run failed with error. Expected: <no error> Actual: %v", err)
    	}
    
    	for _, pod := range pods.Items {
    		podToAdd := pod
    		podInformer.GetIndexer().Add(&podToAdd)
    		podsNum++
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 11:00:37 UTC 2024
    - 24.2K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/endpoints/metrics/metrics_test.go

    		isMutating  bool
    		want        string
    	}{
    		{
    			desc: "list pods",
    			request: &http.Request{
    				Method: "GET",
    				URL: &url.URL{
    					RawPath: "/api/v1/pods",
    				},
    			},
    			requestInfo: &request.RequestInfo{
    				Verb:              "list",
    				APIGroup:          "",
    				APIVersion:        "v1",
    				Resource:          "pods",
    				IsResourceRequest: true,
    			},
    			isMutating: false,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 07:29:19 UTC 2023
    - 14.3K bytes
    - Viewed (0)
  7. cmd/kubeadm/app/util/config/cluster_test.go

    		nodeName         string
    		pods             []testresources.FakeStaticPod
    		clientSetup      func(*clientsetfake.Clientset)
    		expectedEndpoint string
    		expectedErr      bool
    	}{
    		{
    			name:        "no pods",
    			nodeName:    nodeName,
    			expectedErr: true,
    		},
    		{
    			name:     "exactly one pod with annotation",
    			nodeName: nodeName,
    			pods: []testresources.FakeStaticPod{
    				{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 14 13:07:56 UTC 2024
    - 26.7K bytes
    - Viewed (0)
  8. pkg/kubelet/config/http_test.go

    	if len(headerVal) != 1 || headerVal[0] != "Google" {
    		t.Errorf("Header missing expected entry %v. Got %v", header, fakeHandler.RequestReceived.Header)
    	}
    	if len(update.Pods) != 1 {
    		t.Errorf("Received wrong number of pods, expected one: %v", update.Pods)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 14 09:38:23 UTC 2022
    - 11.2K bytes
    - Viewed (0)
  9. pkg/quota/v1/evaluator/core/pods_test.go

    	}{
    		{
    			name: "nil case",
    		},
    		{
    			name: "all pods in running state",
    			objs: []runtime.Object{
    				makePod("p1", "", cpu1, api.PodRunning),
    				makePod("p2", "", cpu1, api.PodRunning),
    			},
    			want: corev1.ResourceList{
    				corev1.ResourcePods:               resource.MustParse("2"),
    				corev1.ResourceName("count/pods"): resource.MustParse("2"),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 41.6K bytes
    - Viewed (0)
  10. pkg/controller/resourcequota/resource_quota_controller_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    
    	pods := schema.GroupVersionResource{Group: "", Version: "v1", Resource: "pods"}
    	secrets := schema.GroupVersionResource{Group: "", Version: "v1", Resource: "secrets"}
    	deployments := schema.GroupVersionResource{Group: "apps", Version: "v1", Resource: "deployments"}
    	listersForResourceConfig := map[schema.GroupVersionResource]cache.GenericLister{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 12 16:29:33 UTC 2023
    - 42.6K bytes
    - Viewed (0)
Back to top