Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 453 for pod4 (0.06 sec)

  1. pkg/scheduler/scheduler_test.go

    			},
    			waitSchedulingPods: []*v1.Pod{
    				st.MakePod().Name("pod1").UID("pod1").SchedulerName(testSchedulerProfile1).Obj(),
    				st.MakePod().Name("pod2").UID("pod2").SchedulerName(testSchedulerProfile1).Obj(),
    				st.MakePod().Name("pod3").UID("pod3").SchedulerName(testSchedulerProfile1).Obj(),
    			},
    			expectPodNamesInWaitingPods: []string{"pod1", "pod2", "pod3"},
    		},
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 42K bytes
    - Viewed (0)
  2. pkg/kubelet/pod_workers_test.go

    		return status
    	}
    	withLabel := func(pod *v1.Pod, label, value string) *v1.Pod {
    		if pod.Labels == nil {
    			pod.Labels = make(map[string]string)
    		}
    		pod.Labels[label] = value
    		return pod
    	}
    	withDeletionTimestamp := func(pod *v1.Pod, ts time.Time, gracePeriod *int64) *v1.Pod {
    		pod.DeletionTimestamp = &metav1.Time{Time: ts}
    		pod.DeletionGracePeriodSeconds = gracePeriod
    		return pod
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 75.6K bytes
    - Viewed (0)
  3. pkg/controller/daemon/util/daemonset_util_test.go

    		tests := []struct {
    			pod         *v1.Pod
    			nodeName    string
    			expectedErr bool
    		}{
    			{
    				pod: &v1.Pod{
    					ObjectMeta: metav1.ObjectMeta{
    						Name:      "pod1",
    						Namespace: "default",
    					},
    					Spec: v1.PodSpec{
    						NodeName: "node-1",
    					},
    				},
    				nodeName: "node-1",
    			},
    			{
    				pod: &v1.Pod{
    					ObjectMeta: metav1.ObjectMeta{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 14.5K bytes
    - Viewed (0)
  4. pkg/controller/replicaset/replica_set_test.go

    			rs:               someRS,
    			pods:             []*v1.Pod{pod1, pod2, pod3, pod4},
    			expectedPodNames: []string{"pod1", "pod2", "pod3"},
    		},
    	}
    	for _, c := range testCases {
    		for _, r := range c.rss {
    			informers.Apps().V1().ReplicaSets().Informer().GetIndexer().Add(r)
    		}
    		for _, pod := range c.pods {
    			informers.Core().V1().Pods().Informer().GetIndexer().Add(pod)
    			manager.addPod(logger, pod)
    		}
    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. pkg/kubelet/util/manager/cache_based_manager_test.go

    	store.AddReference("ns1", "name1", "pod1")
    	store.AddReference("ns2", "name2", "pod2")
    	store.AddReference("ns1", "name1", "pod3")
    	store.AddReference("ns1", "name1", "pod4")
    	store.DeleteReference("ns1", "name1", "pod1")
    	store.DeleteReference("ns2", "name2", "pod2")
    	store.AddReference("ns3", "name3", "pod5")
    
    	// Adds don't issue Get requests.
    	actions := fakeClient.Actions()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go

    				Namespace:       "ns",
    				ResourceVersion: rv,
    			},
    		}
    	}
    	pod1 := makePod("pod", "1001")
    	pod2 := makePod("pod", "1002")
    	pod3 := makePod("pod", "1003")
    
    	cacher.watchCache.Add(pod1)
    	cacher.watchCache.Update(pod2)
    	cacher.watchCache.Delete(pod3)
    
    	// At this point, we already have dispatchedEvents fully propagated.
    
    	verifyEvents := func(w watch.Interface) {
    		var event watch.Event
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 82.9K bytes
    - Viewed (0)
  7. pkg/scheduler/schedule_one_test.go

    		st.MakeNode().Name("node3").UID("node3").Obj(),
    	}
    	pods := []*v1.Pod{
    		st.MakePod().Name("pod1").UID("pod1").SchedulerName("match-node3").Obj(),
    		st.MakePod().Name("pod2").UID("pod2").SchedulerName("match-node2").Obj(),
    		st.MakePod().Name("pod3").UID("pod3").SchedulerName("match-node2").Obj(),
    		st.MakePod().Name("pod4").UID("pod4").SchedulerName("match-node3").Obj(),
    	}
    	wantBindings := map[string]string{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 128.1K bytes
    - Viewed (0)
  8. pkg/kubelet/stats/cadvisor_stats_provider_test.go

    	assert.Len(t, filteredInfos, 5)
    	assert.Len(t, allInfos, 11)
    	for _, c := range []string{"/pod0-i", "/pod0-c0"} {
    		if _, found := filteredInfos[c]; !found {
    			t.Errorf("%q is expected to be in the output\n", c)
    		}
    	}
    
    	expectedInfoKeys := []string{"pod0-i-terminated-1", "pod0-c0-terminated-1", "pod0-i-terminated-2", "pod0-c0-terminated-2", "pod0-i", "pod0-c0"}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  9. pilot/pkg/serviceregistry/kube/controller/controller_test.go

    			},
    			wantAZ: map[*corev1.Pod]string{
    				pod1: "region1/zone1/",
    				pod2: "region2/zone2/",
    			},
    		},
    		{
    			name: "should return false if pod isn't in the cache",
    			wantAZ: map[*corev1.Pod]string{
    				pod1: "",
    				pod2: "",
    			},
    		},
    		{
    			name: "should return false if node isn't in the cache",
    			pods: []*corev1.Pod{pod1, pod2},
    			wantAZ: map[*corev1.Pod]string{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 85K bytes
    - Viewed (0)
  10. pkg/kube/kclient/index_test.go

    	c.Kube().CoreV1().Pods("ns").Create(context.Background(), pod2, metav1.CreateOptions{})
    	assertIndex(k1, pod1) // Original one must still persist
    	assertIndex(k2, pod2) // New one should be there, eventually
    
    	// Create another pod with the same SA; we ought to find multiple now.
    	c.Kube().CoreV1().Pods("ns").Create(context.Background(), pod3, metav1.CreateOptions{})
    	assertIndex(k1, pod1, pod3) // Original one must still persist
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 04 03:49:30 UTC 2023
    - 5.7K bytes
    - Viewed (0)
Back to top