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