Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 24 for PodList (0.58 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. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. pkg/kubelet/server/server.go

    		response.WriteError(http.StatusBadRequest, err)
    		return
    	}
    }
    
    // encodePods creates an v1.PodList object from pods and returns the encoded
    // PodList.
    func encodePods(pods []*v1.Pod) (data []byte, err error) {
    	podList := new(v1.PodList)
    	for _, pod := range pods {
    		podList.Items = append(podList.Items, *pod)
    	}
    	// TODO: this needs to be parameterized to the kubelet, not hardcoded. Depends on Kubelet
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 40.1K bytes
    - Viewed (0)
  9. pkg/controller/podgc/gc_controller_test.go

    func setupNewSimpleClient(nodes []*v1.Node, pods []*v1.Pod) *fake.Clientset {
    	podList := &v1.PodList{}
    	for _, podItem := range pods {
    		podList.Items = append(podList.Items, *podItem)
    	}
    	nodeList := &v1.NodeList{}
    	for _, nodeItem := range nodes {
    		nodeList.Items = append(nodeList.Items, *nodeItem)
    	}
    	return fake.NewSimpleClientset(nodeList, podList)
    }
    
    func getDeletedPodNames(client *fake.Clientset) sets.Set[string] {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 08:16:48 UTC 2024
    - 29K bytes
    - Viewed (0)
  10. istioctl/pkg/kubeinject/kubeinject.go

    	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 {
    		pod := podList.Items[i]
    		pods = append(pods, &pod)
    	}
    	if len(pods) > 0 {
    		sort.Sort(sortBy(pods))
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Mar 29 02:29:02 UTC 2024
    - 21.6K bytes
    - Viewed (0)
Back to top