- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for PodList (0.13 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/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) -
staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go
// initialRV is used to initate the watcher at the beginning of the world. podList := example.PodList{} options := storage.ListOptions{ Predicate: storage.Everything, Recursive: true, } if err := store.GetList(ctx, "/pods", options, &podList); err != nil { t.Fatalf("Failed to list pods: %v", err) } initialRV := podList.ResourceVersion options = storage.ListOptions{ ResourceVersion: initialRV,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 63.8K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_test.go
func newPodList(store cache.Store, count int, status v1.PodPhase, labelMap map[string]string, rs *apps.ReplicaSet, name string) *v1.PodList { pods := []v1.Pod{} var trueVar = true controllerReference := metav1.OwnerReference{UID: rs.UID, APIVersion: "v1beta1", Kind: "ReplicaSet", Name: rs.Name, Controller: &trueVar} for i := 0; i < count; i++ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 69.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_test.go
a := &ambientTestServer{ t: t, clusterID: clusterID, network: networkID, index: idx.(*index), fx: up, pc: clienttest.NewDirectClient[*corev1.Pod, corev1.Pod, *corev1.PodList](t, cl), sc: clienttest.NewDirectClient[*corev1.Service, corev1.Service, *corev1.ServiceList](t, cl), ns: clienttest.NewWriter[*corev1.Namespace](t, cl),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 01:04:50 UTC 2024 - 70.2K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go
podItems := []v1.Pod{} for _, pod := range tt.pods { podItems = append(podItems, *pod) } cs := clientsetfake.NewSimpleClientset(&v1.PodList{Items: podItems}) informerFactory := informers.NewSharedInformerFactory(cs, 0) podInformer := informerFactory.Core().V1().Pods().Informer() podInformer.GetStore().Add(tt.pod) for i := range tt.pods {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 82.8K bytes - Viewed (0)