Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for PodList (0.13 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/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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
Back to top