- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 615 for pod6 (0.13 sec)
-
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) -
pkg/controller/endpointslice/endpointslice_controller_test.go
} // Ensure SyncService correctly selects Pods. func TestSyncServicePodSelection(t *testing.T) { client, esController := newController(t, []string{"node-1"}, time.Duration(0)) ns := metav1.NamespaceDefault pod1 := newPod(1, ns, true, 0, false) esController.podStore.Add(pod1) // ensure this pod will not match the selector pod2 := newPod(2, ns, true, 0, false) pod2.Labels["foo"] = "boo"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/pod_test.go
createPod("128.0.0.2", "pod") assert.Equal(t, c.pods.getPodKeys("128.0.0.2"), []types.NamespacedName{{Name: "pod", Namespace: "ns"}}) assert.Equal(t, c.pods.getPodKeys("128.0.0.1"), nil) // A new pod is created with the old IP. We should get new-pod, not pod createPod("128.0.0.1", "new-pod") assert.Equal(t, c.pods.getPodKeys("128.0.0.1"), []types.NamespacedName{{Name: "new-pod", 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) -
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) -
pilot/pkg/xds/workload_test.go
ads.ExpectEmptyResponse() // Create pod, due to wildcard subscribe we should receive it createPod(s, "pod", "sa", "127.0.0.1", "not-node") expect(ads.ExpectResponse(), "Kubernetes//Pod/default/pod") // A new pod should push only that one createPod(s, "pod2", "sa", "127.0.0.2", "node") expect(ads.ExpectResponse(), "Kubernetes//Pod/default/pod2")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 15.9K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/actual_state_of_world_test.go
// Call MarkVolumeAsDetached() on a volume which mounted by pod(s) should be skipped func Test_MarkVolumeAsDetached_Negative_PodInVolume(t *testing.T) { // Arrange volumePluginMgr, plugin := volumetesting.GetTestVolumePluginMgr(t) devicePath := "fake/device/path" asw := NewActualStateOfWorld("mynode", volumePluginMgr) pod := &v1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "pod1", UID: "pod1uid", }, Spec: v1.PodSpec{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 46.3K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 87.7K bytes - Viewed (0) -
pkg/scheduler/schedule_one_test.go
ForgetFunc: func(pod *v1.Pod) { gotForgetPod = pod }, AssumeFunc: func(pod *v1.Pod) { gotAssumedPod = pod }, IsAssumedPodFunc: func(pod *v1.Pod) bool { if pod == nil || gotAssumedPod == nil { return false } return pod.UID == gotAssumedPod.UID }, } client := clientsetfake.NewSimpleClientset(item.sendPod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 128.1K 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/kube/krt/join_test.go
assert.EventuallyEqual(t, fetch, []SimpleEndpoint{ {pod.Name, se.Name, pod.Namespace, pod.Status.PodIP}, {pod2.Name, se.Name, pod2.Namespace, pod2.Status.PodIP}, {pod.Name, svc.Name, pod.Namespace, pod.Status.PodIP}, {pod2.Name, svc.Name, pod2.Namespace, pod2.Status.PodIP}, }) } func TestCollectionJoinSync(t *testing.T) { c := kube.NewFakeClient(&corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "name",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 09 19:55:53 UTC 2024 - 6.1K bytes - Viewed (0)