Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 36 for PodList (0.16 sec)

  1. pkg/controller/controller_utils_test.go

    	rc := newReplicationController(0)
    	podList := newPodList(nil, 7, v1.PodRunning, rc)
    	podList.Items[0].Status.Phase = v1.PodSucceeded
    	podList.Items[1].Status.Phase = v1.PodFailed
    	podList.Items[2].Status.Phase = v1.PodPending
    	podList.Items[2].SetDeletionTimestamp(&now)
    	podList.Items[3].Status.Phase = v1.PodRunning
    	podList.Items[3].SetDeletionTimestamp(&now)
    	var podPointers []*v1.Pod
    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. staging/src/k8s.io/apiserver/pkg/apis/example/v1/zz_generated.conversion.go

    	}); err != nil {
    		return err
    	}
    	if err := s.AddGeneratedConversionFunc((*PodList)(nil), (*example.PodList)(nil), func(a, b interface{}, scope conversion.Scope) error {
    		return Convert_v1_PodList_To_example_PodList(a.(*PodList), b.(*example.PodList), scope)
    	}); err != nil {
    		return err
    	}
    	if err := s.AddGeneratedConversionFunc((*example.PodList)(nil), (*PodList)(nil), func(a, b interface{}, scope conversion.Scope) error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 24 19:47:49 UTC 2021
    - 10.6K bytes
    - Viewed (0)
  3. pkg/controller/podautoscaler/replica_calculator.go

    	podList, err := c.podLister.Pods(namespace).List(selector)
    	if err != nil {
    		return 0, fmt.Errorf("unable to get pods while calculating replica count: %v", err)
    	}
    
    	if len(podList) == 0 {
    		return 0, fmt.Errorf("no pods returned by selector while calculating replica count")
    	}
    
    	readyPodCount := 0
    
    	for _, pod := range podList {
    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. cmd/kubeadm/app/util/config/cluster.go

    	if err != nil {
    		return "", errors.Wrap(err, "could not retrieve list of pods to determine api server endpoints")
    	}
    	if len(podList.Items) != 1 {
    		return "", errors.Errorf("API server pod for node name %q has %d entries, only one was expected", nodeName, len(podList.Items))
    	}
    	if apiServerEndpoint, ok := podList.Items[0].Annotations[constants.KubeAPIServerAdvertiseAddressEndpointAnnotationKey]; ok {
    		return apiServerEndpoint, nil
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 11:04:08 UTC 2024
    - 11K bytes
    - Viewed (0)
  5. src/cmd/covdata/tool_test.go

    	// data file and a counter file. If we get more than just this one
    	// pair, something went wrong.
    	podlist, err := pods.CollectPods([]string{outdir}, true)
    	if err != nil {
    		t.Fatal(err)
    	}
    	if len(podlist) != 1 {
    		t.Fatalf("expected 1 pod, got %d pods", len(podlist))
    	}
    	ncdfs := len(podlist[0].CounterDataFiles)
    	if ncdfs != 1 {
    		t.Fatalf("expected 1 counter data file, got %d", ncdfs)
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Mar 07 20:46:32 UTC 2024
    - 24.5K bytes
    - Viewed (0)
  6. staging/src/k8s.io/cli-runtime/pkg/resource/helper_test.go

    			},
    			Err: true,
    		},
    		{
    			name: "test3",
    			Resp: &http.Response{
    				StatusCode: http.StatusOK,
    				Header:     header(),
    				Body: objBody(&corev1.PodList{
    					Items: []corev1.Pod{{
    						ObjectMeta: metav1.ObjectMeta{Name: "foo"},
    					},
    					},
    				}),
    			},
    			Req: func(req *http.Request) bool {
    				if req.Method != "GET" {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 02 09:47:52 UTC 2023
    - 25.2K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/storage/etcd3/store_test.go

    			newListObjectFunc: func() runtime.Object { return &examplev1.PodList{} },
    		},
    		{
    			name:              "pick 500 pods out of 5000 pod",
    			objectNum:         5000,
    			expectNum:         500,
    			selector:          labels.SelectorFromSet(map[string]string{"foo": "bar"}),
    			newObjectFunc:     generateBigPod,
    			newListObjectFunc: func() runtime.Object { return &examplev1.PodList{} },
    		},
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 12:45:33 UTC 2024
    - 26.5K bytes
    - Viewed (0)
  8. pkg/kubelet/userns/userns_manager_test.go

    	}
    	return m.podDir
    }
    
    func (m *testUserNsPodsManager) ListPodsFromDisk() ([]types.UID, error) {
    	if len(m.podList) == 0 {
    		return nil, nil
    	}
    	return m.podList, nil
    }
    
    func (m *testUserNsPodsManager) HandlerSupportsUserNamespaces(runtimeHandler string) (bool, error) {
    	if runtimeHandler == "error" {
    		return false, errors.New("unknown runtime")
    	}
    	return m.userns, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 14:24:16 UTC 2024
    - 14.6K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/responsewriters/writers_test.go

    }
    
    func benchmarkItems(b *testing.B, file string, n int) *v1.PodList {
    	pod := v1.Pod{}
    	f, err := os.Open(file)
    	if err != nil {
    		b.Fatalf("Failed to open %q: %v", file, err)
    	}
    	defer f.Close()
    	err = json.NewDecoder(f).Decode(&pod)
    	if err != nil {
    		b.Fatalf("Failed to decode %q: %v", file, err)
    	}
    
    	list := &v1.PodList{
    		Items: make([]v1.Pod, n),
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  10. pkg/controller/tainteviction/taint_eviction_test.go

    			ctx, cancel := context.WithCancel(context.Background())
    			fakeClientset := fake.NewSimpleClientset(&corev1.PodList{Items: []corev1.Pod{*item.pod}})
    			controller, podIndexer, _ := setupNewController(ctx, fakeClientset)
    			controller.recorder = testutil.NewFakeRecorder()
    			go controller.Run(ctx)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 14:24:16 UTC 2024
    - 31.3K bytes
    - Viewed (0)
Back to top