Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 43 for PodList (0.24 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. pkg/kubelet/userns/userns_manager_switch_test.go

    	testUserNsPodsManager := &testUserNsPodsManager{
    		podDir: t.TempDir(),
    		// List the same pods we will record, so the second time we create the userns
    		// manager, it will find these pods on disk with userns data.
    		podList: pods,
    	}
    	m, err := MakeUserNsManager(testUserNsPodsManager)
    	require.NoError(t, err)
    
    	// Record the pods on disk.
    	for _, podUID := range pods {
    		pod := v1.Pod{ObjectMeta: metav1.ObjectMeta{UID: podUID}}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 5K bytes
    - Viewed (0)
  3. istioctl/pkg/completion/completion.go

    	client, err := ctx.CLIClient()
    	if err != nil {
    		return nil, err
    	}
    	ns := ctx.NamespaceOrDefault(ctx.Namespace())
    	podList, err := client.Kube().CoreV1().Pods(ns).List(context.Background(), metav1.ListOptions{})
    	if err != nil {
    		return nil, err
    	}
    
    	var podsName []string
    	for _, pod := range podList.Items {
    		if toComplete == "" || strings.HasPrefix(pod.Name, toComplete) {
    			podsName = append(podsName, pod.Name)
    		}
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Apr 13 05:23:38 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go

    	backingStorage := &dummyStorage{
    		getListFn: func(_ context.Context, _ string, _ storage.ListOptions, listObj runtime.Object) error {
    			podList := listObj.(*example.PodList)
    			var err error
    			switch listCalls {
    			case 0:
    				podList.ListMeta = metav1.ListMeta{ResourceVersion: "1"}
    			case 1:
    				podList.ListMeta = metav1.ListMeta{ResourceVersion: "10"}
    			default:
    				err = fmt.Errorf("unexpected list call")
    			}
    			listCalls++
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 82.9K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. staging/src/k8s.io/apiserver/pkg/storage/testing/store_tests.go

    	result3 := example.PodList{}
    	if err := store.GetList(ctx, "/pods", options, &result3); err != nil {
    		t.Fatalf("failed to list objects: %v", err)
    	}
    
    	options.ResourceVersion = result3.ResourceVersion
    	options.ResourceVersionMatch = metav1.ResourceVersionMatchExact
    
    	result4 := example.PodList{}
    	if err := store.GetList(ctx, "/pods", options, &result4); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 12:45:33 UTC 2024
    - 91.4K bytes
    - Viewed (0)
  10. 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)
Back to top