- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 43 for PodList (0.24 sec)
-
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/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/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) -
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) -
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) -
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) -
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) -
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) -
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)