- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for cpod3 (1.28 sec)
-
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_test.go
s.assertEvent(t, s.podXdsName("pod3")) s.clearEvents() // And remove it again s.addPods(t, "127.0.0.3", "pod3", "sa1", map[string]string{"app": "a"}, nil, true, corev1.PodRunning) s.assertAddresses(t, "", "pod1", "pod2", "pod3", "svc1") s.assertAddresses(t, s.addrXdsName("10.0.0.1"), "pod2", "svc1") s.assertEvent(t, s.podXdsName("pod3")) s.clearEvents() // Delete the service entirely
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/kubelet/pod_workers_test.go
} pod2 = podWorkers.podSyncStatuses[types.UID("2-static")] if pod2.IsTerminated() { t.Fatalf("unexpected pod state: %#v", pod2) } pod3 := podWorkers.podSyncStatuses[types.UID("3-static")] if pod3.IsTerminated() { t.Fatalf("unexpected pod state: %#v", pod3) } pod4 := podWorkers.podSyncStatuses[types.UID("4-static")] if pod4.IsTerminated() { t.Fatalf("unexpected pod state: %#v", pod4) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K 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) -
pkg/controller/replicaset/replica_set_test.go
now := metav1.Now() pendingDeletionRS.DeletionTimestamp = &now pod1 := newPod("pod1", someRS, v1.PodRunning, nil, true) pod2 := newPod("pod2", someRS, v1.PodRunning, nil, true) pod3 := newPod("pod3", relatedRS, v1.PodRunning, nil, true) pod4 := newPod("pod4", unrelatedRS, v1.PodRunning, nil, true) logger, _ := ktesting.NewTestContext(t) stopCh := make(chan struct{}) defer close(stopCh)
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/kubelet/cm/devicemanager/manager_test.go
newContainerAllocateResponse( withDevices(map[string]string{"/dev/r1dev4": "/dev/r1dev4"}), withMounts(map[string]string{"/home/r1lib1": "/usr/r1lib1"}), ), ) testManager.podDevices.insert("pod3", "con3", resourceName3, checkpoint.DevicesPerNUMA{nodeWithoutTopology: []string{"dev5"}}, newContainerAllocateResponse( withDevices(map[string]string{"/dev/r3dev5": "/dev/r3dev5"}),
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/disruption/disruption_test.go
} add(t, dc.pdbStore, pdb) pod1, _ := newPod(t, "p1") pod1.DeletionTimestamp = &metav1.Time{Time: dc.clock.Now()} pod2, _ := newPod(t, "p2") pod3, _ := newPod(t, "p3") add(t, dc.podStore, pod1) add(t, dc.podStore, pod2) add(t, dc.podStore, pod3) dc.sync(ctx, pdbName) ps.VerifyPdbStatus(t, pdbName, 0, 1, 1, 3, map[string]metav1.Time{"p3": {Time: currentTime.Add(-time.Minute)}}) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 50K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
} if !reflect.DeepEqual(expected, podServices[0]) { t.Fatalf("expected instance %v, got %v", expected, podServices[0]) } // 2. pod with `istio-locality` label, ignore node label. p = generatePod("129.0.0.2", "pod3", "nsa", "svcaccount", "node1", map[string]string{"app": "prod-app", "istio-locality": "region.zone"}, nil) addPods(t, controller, fx, p) // this can test get pod by proxy ip address
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/reconciler/reconciler_test.go
[]nodeWithPods{ {"node1", []string{"ns1/pod1"}}, {"node2", []string{"ns2/pod2"}}, {"node3", []string{"ns1/pod3"}}, }, []string{"Warning FailedAttachVolume Multi-Attach error for volume \"volume-name\" Volume is already used by pod(s) pod3 and 1 pod(s) in different namespaces"}, }, } for _, test := range tests { // Arrange t.Logf("Test %q starting", test.name)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 07:00:14 UTC 2024 - 72.8K bytes - Viewed (0)