- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 273 for podMap (0.29 sec)
-
pkg/controller/deployment/deployment_controller.go
controllerRef := metav1.GetControllerOf(pod) if controllerRef == nil { continue } // Only append if we care about this UID. if _, ok := podMap[controllerRef.UID]; ok { podMap[controllerRef.UID] = append(podMap[controllerRef.UID], pod) } } return podMap, nil } // syncDeployment will sync the deployment with the given key. // This function is not meant to be invoked concurrently with the same key.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.2K bytes - Viewed (0) -
pkg/controller/deployment/deployment_controller_test.go
} if got, want := len(podMap[rs1.UID]), 2; got != want { t.Errorf("len(podMap[rs1]) = %v, want %v", got, want) } expect := map[string]struct{}{"rs1-pod": {}, "pod4": {}} for _, pod := range podMap[rs1.UID] { if _, ok := expect[pod.Name]; !ok { t.Errorf("unexpected pod name for rs1: %s", pod.Name) } } if got, want := len(podMap[rs2.UID]), 1; got != want { t.Errorf("len(podMap[rs2]) = %v, want %v", got, want)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.5K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/desired_state_of_world.go
}}) } } return volumesToAttach } // Construct a list of v1.Pod objects from the given pod map func getPodsFromMap(podMap map[types.UniquePodName]pod) []*v1.Pod { pods := make([]*v1.Pod, 0, len(podMap)) for _, pod := range podMap { pods = append(pods, pod.podObj) } return pods } func (dsw *desiredStateOfWorld) GetPodToAdd() map[types.UniquePodName]PodToAdd { dsw.RLock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 13.5K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/actual_state_of_world.go
podObj.mounter = mounter } asw.attachedVolumes[volumeName].mountedPods[podName] = podObj podMap, ok := asw.foundDuringReconstruction[opts.VolumeName] if !ok { podMap = map[volumetypes.UniquePodName]types.UID{} } podMap[opts.PodName] = opts.PodUID asw.foundDuringReconstruction[opts.VolumeName] = podMap return true, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 45.8K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods_test.go
EnableServiceLinks: tc.enableServiceLinks, }, } podIP := "" if len(tc.podIPs) > 0 { podIP = tc.podIPs[0] } if tc.staticPod { testPod.Annotations[kubetypes.ConfigSourceAnnotationKey] = "file" } result, err := kl.makeEnvironmentVariables(testPod, tc.container, podIP, tc.podIPs) select { case e := <-fakeRecorder.Events:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 198.8K bytes - Viewed (0) -
pkg/kubelet/metrics/collectors/resource_metrics_test.go
container_cpu_usage_seconds_total{container="container_a",namespace="namespace_a",pod="pod_a"} 10 1624396278302 container_cpu_usage_seconds_total{container="container_a",namespace="namespace_b",pod="pod_b"} 10 1624396278302 container_cpu_usage_seconds_total{container="container_b",namespace="namespace_a",pod="pod_a"} 10 1624396278302 # HELP container_memory_working_set_bytes [STABLE] Current working set of the container in bytes
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 15.3K bytes - Viewed (1) -
pkg/kube/krt/join_test.go
} sec.Create(se) 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{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 09 19:55:53 UTC 2024 - 6.1K bytes - Viewed (0) -
pkg/kube/krt/collection_test.go
Labels: map[string]string{"app": "foo"}, }, Status: corev1.PodStatus{PodIP: "2.3.4.5"}, } pc.CreateOrUpdateStatus(pod) pc.CreateOrUpdateStatus(pod2) assert.EventuallyEqual(t, fetcherSorted(SimpleEndpoints), []SimpleEndpoint{ {pod2.Name, svc.Name, pod2.Namespace, pod2.Status.PodIP}, {pod.Name, svc.Name, pod.Namespace, pod.Status.PodIP}, }) } type PodSizeCount struct { Named MatchingSizes int
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 04:22:19 UTC 2024 - 14.6K bytes - Viewed (0) -
pkg/kube/krt/index_test.go
ObjectMeta: metav1.ObjectMeta{ Name: "name", Namespace: "namespace", }, Status: corev1.PodStatus{PodIP: "1.2.3.4"}, } pc.CreateOrUpdateStatus(pod) tt.WaitUnordered("add/namespace/name") assert.Equal(t, fetchSorted("1.2.3.4"), []SimplePod{{NewNamed(pod), Labeled{}, "1.2.3.4"}}) pod.Status.PodIP = "1.2.3.5" pc.UpdateStatus(pod) tt.WaitUnordered("update/namespace/name")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 09 19:55:53 UTC 2024 - 4.5K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
ObjectMeta: metav1.ObjectMeta{ Name: "test", Namespace: "test", }, Spec: corev1.PodSpec{ NodeName: NodeName, }, Status: corev1.PodStatus{ PodIPs: []corev1.PodIP{}, PodIP: "", }, } ns := &corev1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: "test"}} client := kube.NewFakeClient(ns, pod) fs := &fakeServer{} server := &meshDataplane{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 22.2K bytes - Viewed (0)