Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for PodList (0.24 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go

    		},
    		"normalFiltered": {
    			in:  &example.PodList{Items: []example.Pod{*podA, *podB}},
    			m:   matchPodName("foo"),
    			out: &example.PodList{Items: []example.Pod{*podB}},
    		},
    		"normalFilteredNoNamespace": {
    			in:      &example.PodList{Items: []example.Pod{*podA, *podB}},
    			m:       matchPodName("foo"),
    			out:     &example.PodList{Items: []example.Pod{*podB}},
    			context: noNamespaceContext,
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 101.8K bytes
    - Viewed (0)
  6. pkg/kubelet/kubelet_test.go

    	pods = []*v1.Pod{}
    	testKubelet.fakeRuntime.PodList = []*containertest.FakePod{{Pod: runningPod, NetnsPath: ""}}
    	syncAndVerifyPodDir(t, testKubelet, pods, []*v1.Pod{apiPod}, true)
    
    	// The pod is deleted and also not active on the node. The pod directory
    	// should be removed.
    	pods = []*v1.Pod{}
    	testKubelet.fakeRuntime.PodList = []*containertest.FakePod{}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  7. pkg/printers/internalversion/printers.go

    )
    
    func printPodList(podList *api.PodList, options printers.GenerateOptions) ([]metav1.TableRow, error) {
    	rows := make([]metav1.TableRow, 0, len(podList.Items))
    	for i := range podList.Items {
    		r, err := printPod(&podList.Items[i], options)
    		if err != nil {
    			return nil, err
    		}
    		rows = append(rows, r...)
    	}
    	return rows, nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 14:04:15 UTC 2024
    - 128.3K bytes
    - Viewed (0)
  8. pkg/kubelet/kubelet_pods_test.go

    	ctx := context.Background()
    	testKubelet := newTestKubelet(t, false /* controllerAttachDetachEnabled */)
    	defer testKubelet.Cleanup()
    	kubelet := testKubelet.kubelet
    	fakeRuntime := testKubelet.fakeRuntime
    	fakeRuntime.PodList = []*containertest.FakePod{}
    
    	podName := "podFoo"
    	podNamespace := "nsFoo"
    	containerName := "containerFoo"
    	output, err := kubelet.RunInContainer(
    		ctx,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
  9. pkg/printers/internalversion/printers_test.go

    		}
    	}
    }
    
    func TestPrintPodList(t *testing.T) {
    	tests := []struct {
    		pods   api.PodList
    		expect []metav1.TableRow
    	}{
    		// Test podList's pod: name, num of containers, restarts, container ready status
    		{
    			api.PodList{
    				Items: []api.Pod{
    					{
    						ObjectMeta: metav1.ObjectMeta{Name: "test1"},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 14:04:15 UTC 2024
    - 218.6K bytes
    - Viewed (0)
Back to top