- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 695 for pod3 (0.04 sec)
-
pkg/controller/tainteviction/taint_eviction_test.go
expectedDeleteTimes: durationSlice{ {[]string{"pod1"}, 0}, {[]string{"pod2"}, time.Second}, }, }, { description: "Evict all pods not matching all taints instantly", pods: []corev1.Pod{ *testutil.NewPod("pod1", "node1"), *addToleration(testutil.NewPod("pod2", "node1"), 1, 1), *addToleration(testutil.NewPod("pod3", "node1"), 1, -1), }, oldNode: testutil.NewNode("node1"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 31.3K bytes - Viewed (0) -
pkg/kubelet/pod_workers_test.go
// should observe both pods running but last pod shouldn't have synced pod1 = podWorkers.podSyncStatuses[types.UID("1-normal")] if pod1.IsTerminated() { t.Fatalf("unexpected pod state: %#v", pod1) } pod2 = podWorkers.podSyncStatuses[types.UID("2-static")] if pod2.IsTerminated() { t.Fatalf("unexpected pod state: %#v", pod2) } pod3 := podWorkers.podSyncStatuses[types.UID("3-static")]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
pkg/volume/util/nestedpendingoperations/nestedpendingoperations_test.go
} } /* Concurrent operations tests */ // "None" means volume, pod, and node names are all empty // "Volume" means volume name is set, but pod name and node name are empty // "Volume Pod" means volume and pod names are set, but the node name is empty // "Volume Node" means volume and node names are set, but the pod name is empty // The same volume, pod, and node names are used (where they are not empty). // Covered cases:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 26 01:29:17 UTC 2022 - 36.1K bytes - Viewed (0) -
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) -
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) -
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) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_interval_test.go
} } func TestCacheIntervalNextFromStore(t *testing.T) { getAttrsFunc := func(obj runtime.Object) (labels.Set, fields.Set, error) { pod, ok := obj.(*v1.Pod) if !ok { return nil, nil, fmt.Errorf("not a pod") } return labels.Set(pod.Labels), fields.Set{"spec.nodeName": pod.Spec.NodeName}, nil } const numEvents = 50 store := cache.NewIndexer(storeElementKey, storeElementIndexers(nil))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 11.6K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
// resources) pods[7].Status.Phase = v1.PodFailed kubelet.podWorkers.(*fakePodWorkers).terminationRequested = map[types.UID]bool{ pods[7].UID: true, } expected := []*v1.Pod{pods[2], pods[3], pods[4], pods[7]} kubelet.podManager.SetPods(pods) actual := kubelet.filterOutInactivePods(pods) assert.Equal(t, expected, actual) }
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/kubelet/cm/devicemanager/manager_test.go
}) pod2 := makePod(v1.ResourceList{ v1.ResourceName(res2.resourceName): res2.resourceQuantity, }) activePods := []*v1.Pod{pod1, pod2} podsStub.updateActivePods(activePods) err = testManager.Allocate(pod1, &pod1.Spec.Containers[0]) as.Nil(err) err = testManager.Allocate(pod2, &pod2.Spec.Containers[0]) as.Nil(err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 65K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/desired_state_of_world_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 35.9K bytes - Viewed (0)