- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 75 for pod12 (0.12 sec)
-
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go
{ podWithOtherFinalizers("pod12"), nilOrphanOptions, orphanDeleteStrategy, false, []string{"foo.com/x", "bar.com/y", metav1.FinalizerOrphanDependents}, }, { podWithNoFinalizer("pod13"), nilOrphanOptions, defaultDeleteStrategy, true, []string{}, }, { podWithNoFinalizer("pod14"), nilOrphanOptions, orphanDeleteStrategy, false,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 101.8K bytes - Viewed (0) -
hack/testdata/sorted-pods/sorted-pod1.yaml
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 24 07:02:51 UTC 2024 - 355 bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_test.go
assertWaypoint(t, testNW, "10.0.0.2", s.podXdsName("pod1")) assertWaypoint(t, testNW, "10.0.0.1", s.podXdsName("pod2")) // Revert back s.labelPod(t, "pod1", testNS, map[string]string{}) s.assertEvent(t, s.podXdsName("pod1")) assertWaypoint(t, testNW, "10.0.0.1", s.podXdsName("pod1"), s.podXdsName("pod2")) } func TestWorkloadsForWaypointOrder(t *testing.T) {
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/controller/statefulset/stateful_set_test.go
set1 := newStatefulSet(3) set2 := newStatefulSet(3) set2.Name = "foo2" pod1 := newStatefulSetPod(set1, 0) pod2 := newStatefulSetPod(set2, 0) om.setsIndexer.Add(set1) om.setsIndexer.Add(set2) prev := *pod1 fakeResourceVersion(pod1) ssc.updatePod(logger, &prev, pod1) key, done := ssc.queue.Get() if key == "" || done { t.Error("failed to enqueue StatefulSet")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/pod_test.go
} createPod("128.0.0.1", "pod1") assert.Equal(t, c.pods.getPodKeys("128.0.0.1"), []types.NamespacedName{{Name: "pod1", Namespace: "ns"}}) events.WaitOrdered("pod1/add", "pod1/update") createPod("128.0.0.1", "pod2") events.WaitOrdered("pod2/add", "pod2/update") assert.Equal(t, sets.New(c.pods.getPodKeys("128.0.0.1")...), sets.New( types.NamespacedName{Name: "pod1", Namespace: "ns"},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 18:27:40 UTC 2024 - 12.3K bytes - Viewed (0) -
pilot/pkg/leaderelection/leaderelection_test.go
// First pod becomes the leader _, stop := createPerRevisionElection(t, "pod1", "foo", watcher, true, client) // A new pod is not the leader _, stop2 := createPerRevisionElection(t, "pod2", "foo", watcher, false, client) close(stop2) close(stop) t.Log("drop") // After leader is lost, we can take over _, stop3 := createPerRevisionElection(t, "pod2", "foo", watcher, true, client) // Other revisions are independent
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 04:22:19 UTC 2024 - 11.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_serviceentry_test.go
WorkloadType: workloadapi.WorkloadType_POD, WorkloadName: "pod1", }, }, }, }}) s.addPods(t, "140.140.0.11", "pod2", "sa1", map[string]string{"app": "other"}, nil, true, corev1.PodRunning) s.assertEvent(t, s.podXdsName("pod2")) s.assertWorkloads(t, "", workloadapi.WorkloadStatus_HEALTHY, "pod1", "pod2") s.addWorkloadEntries(t, "240.240.34.56", "name1", "sa1", map[string]string{"app": "a"})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 03:01:04 UTC 2024 - 12.9K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction_test.go
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"), newNode: addTaintsToNode(testutil.NewNode("node1"), "testTaint1", "taint1", []int{1}), expectedDeleteTimes: durationSlice{ {[]string{"pod1"}, 0}, {[]string{"pod2"}, time.Second}, }, }, {
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/kube/kclient/index_test.go
c.Kube().CoreV1().Pods("ns").Create(context.Background(), pod1, metav1.CreateOptions{}) assertIndex(k1, pod1) assertIndex(k2) // Create another pod; we ought to find it as well now. 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
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 04 03:49:30 UTC 2023 - 5.7K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/desired_state_of_world_test.go
Level: "s0:c3,c4", } seLinuxContainerContexts2 := []*v1.SELinuxOptions{&seLinux2} pod2 := pod.DeepCopy() pod2.Name = "pod2" pod2.UID = "pod2uid" pod2.Spec.SecurityContext.SELinuxOptions = &seLinux2 pod2Name := util.GetUniquePodName(pod2) // Act _, err = dsw.AddPodToVolume( pod2Name, pod2, volumeSpec, volumeSpec.Name(), "" /* volumeGidValue */, seLinuxContainerContexts2) // Assert if err == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 34K bytes - Viewed (0)