- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for pod18 (0.05 sec)
-
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_test.go
}, }, }) s.assertEvent(t, s.podXdsName("pod1")) s.assertWaypointAddressForPod(t, "pod1", "10.0.0.1") // label pod1 to use a different waypoint than the namespace specifies s.labelPod(t, "pod1", testNS, map[string]string{constants.AmbientUseWaypointLabel: "waypoint-sa1"}) s.assertEvent(t, s.podXdsName("pod1")) // assert that we're using the correct waypoint for pod1 s.assertWaypointAddressForPod(t, "pod1", "10.0.0.2")
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
Pod: newNamedPod("1", "test1", "pod1", false), UpdateType: kubetypes.SyncPodUpdate, }) drainAllWorkers(podWorkers) // should observe pod terminating pod1 = podWorkers.podSyncStatuses[types.UID("1")] if !pod1.IsTerminationRequested() || !pod1.IsTerminated() { t.Fatalf("unexpected pod state: %#v", pod1) } } func TestStaticPodExclusion(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
assertEndpointsEvent([]string{"172.0.1.1"}, []string{"pod1"}) assertEndpointsEvent([]string{"172.0.1.1"}, []string{"pod1"}) fx.Clear() // Add the pod, expect the endpoints update for both addPod("pod2", "172.0.1.2") assertEndpointsEvent([]string{"172.0.1.1", "172.0.1.2"}, []string{"pod1", "pod2"}) assertEndpointsEvent([]string{"172.0.1.1", "172.0.1.2"}, []string{"pod1", "pod2"})
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
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" esController.podStore.Add(pod2)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/manager_test.go
as.Nil(err) err = testManager.Allocate(pod2, &pod2.Spec.Containers[0]) as.Nil(err) // when pod is in activePods, GetDeviceRunContainerOptions should return runContainerOpts, err := testManager.GetDeviceRunContainerOptions(pod1, &pod1.Spec.Containers[0]) as.Nil(err) as.Equal(len(runContainerOpts.Devices), 3) as.Equal(len(runContainerOpts.Mounts), 2)
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/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) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
Labels: labels, ResourceVersion: rv, }, } } pod1 := makePod(map[string]string{"foo": "true", "bar": "true"}, "1001") pod2 := makePod(map[string]string{"foo": "true"}, "1002") pod3 := makePod(map[string]string{}, "1003") pod4 := makePod(map[string]string{}, "1004") pod1DeletedAt2 := pod1.DeepCopyObject().(*examplev1.Pod) pod1DeletedAt2.ResourceVersion = "1002"
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/registry/core/pod/strategy_test.go
{ in: &api.Pod{ ObjectMeta: metav1.ObjectMeta{ Namespace: "ns", Name: "pod1", }, Spec: api.PodSpec{ NodeName: "node1", }, }, info: &client.ConnectionInfo{}, opts: &api.PodPortForwardOptions{}, expectedURL: &url.URL{Host: ":", Path: "/portForward/ns/pod1"}, }, { in: &api.Pod{ ObjectMeta: metav1.ObjectMeta{ Namespace: "ns",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 76.2K bytes - Viewed (0) -
pkg/controller/disruption/disruption_test.go
"notthere": {Time: currentTime}, // Should be removed, pod deleted. } 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)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 50K bytes - Viewed (0) -
pkg/scheduler/internal/cache/cache_test.go
&st.MakeNode().Name("test-node-4").Capacity(resourceList2).Taints(taints).Images(imageStatus2).Node, }, pods: []*v1.Pod{ { ObjectMeta: metav1.ObjectMeta{ Name: "pod1", UID: types.UID("pod1"), }, Spec: v1.PodSpec{ NodeName: "test-node-1", Containers: []v1.Container{ { Resources: v1.ResourceRequirements{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 17 01:38:03 UTC 2023 - 63.8K bytes - Viewed (0)