- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 73 for PodList (0.11 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/lister_watcher_test.go
t.Fatalf("List failed: %v", err) } pl, ok := obj.(*example.PodList) if !ok { t.Fatalf("Expected PodList but got %v", pl) } if len(pl.Items) != 3 { t.Errorf("Expected PodList of length 3 but got %d", len(pl.Items)) } } func TestCacherListerWatcherPagination(t *testing.T) { prefix := "pods" fn := func() runtime.Object { return &example.PodList{} } server, store := newEtcdTestStorage(t, prefix)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 11:51:06 UTC 2024 - 3.6K bytes - Viewed (0) -
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) -
pkg/kubelet/config/common_test.go
Status: v1.PodStatus{ PodIP: "1.2.3.4", PodIPs: []v1.PodIP{ { IP: "1.2.3.4", }, }, }, } podList := &v1.PodList{ Items: []v1.Pod{*pod}, } json, err := runtime.Encode(clientscheme.Codecs.LegacyCodec(v1.SchemeGroupVersion), podList) if err != nil { t.Errorf("unexpected error: %v", err) } parsed, podListOut, err := tryDecodePodList(json, noDefault) if !parsed {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 18:40:48 UTC 2023 - 8.7K bytes - Viewed (0) -
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) -
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) -
istioctl/pkg/util/handlers/handlers.go
return []string{podName}, namespace, err } options := metav1.ListOptions{LabelSelector: selector} podList, err := client.Pods(namespace).List(context.TODO(), options) if err != nil { return []string{}, "", err } pods := []string{} for i := range podList.Items { pods = append(pods, podList.Items[i].Name) } return pods, namespace, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Feb 06 15:01:41 UTC 2024 - 6.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/util_test.go
storage := etcd3.New(server.V3Client, apitesting.TestCodec(codecs, examplev1.SchemeGroupVersion, example2v1.SchemeGroupVersion), func() runtime.Object { return &example.Pod{} }, func() runtime.Object { return &example.PodList{} }, prefix, "/pods", schema.GroupResource{Resource: "pods"}, identity.NewEncryptCheckTransformer(), etcd3.NewDefaultLeaseManagerConfig()) return server, storage } server, etcdStorage := newEtcdTestStorage(t, "")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 11 12:07:39 UTC 2024 - 6.3K bytes - Viewed (0) -
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) -
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) -
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)