| /dports/sysutils/kubectl/kubernetes-1.22.2/pkg/kubelet/pod/ |
| H A D | pod_manager_test.go | 76 podManager, _ := newTestManager()
77 podManager.SetPods(updates)
80 actualPods := podManager.GetPods()
103 mirrorPod.UID, staticPod.UID, podManager.mirrorPodByUID)
107 actualPod, ok := podManager.GetPodByFullName("bar_default")
111 actualPod, ok = podManager.GetPodByName("default", "bar")
151 podManager, _ := newTestManager()
152 podManager.SetPods(updates)
154 podManager.DeletePod(staticPod)
156 actualPods := podManager.GetPods()
[all …]
|
| /dports/sysutils/kubectl/kubernetes-1.22.2/pkg/kubelet/stats/ |
| H A D | provider.go | 40 podManager kubepod.Manager,
47 …return newStatsProvider(cadvisor, podManager, runtimeCache, newCRIStatsProvider(cadvisor, resource…
56 podManager kubepod.Manager,
62 …return newStatsProvider(cadvisor, podManager, runtimeCache, newCadvisorStatsProvider(cadvisor, res…
69 podManager kubepod.Manager,
75 podManager: podManager,
84 podManager kubepod.Manager member
169 podUID = types.UID(p.podManager.TranslatePodUID(podUID))
|
| /dports/sysutils/kubectl/kubernetes-1.22.2/pkg/kubelet/volumemanager/ |
| H A D | volume_manager_test.go | 92 …podManager := kubepod.NewBasicPodManager(podtest.NewFakeMirrorClient(), secret.NewFakeManager(), c…
97 manager := newTestVolumeManager(t, tmpDir, podManager, kubeClient)
102 podManager.SetPods([]*v1.Pod{pod})
148 …podManager := kubepod.NewBasicPodManager(podtest.NewFakeMirrorClient(), secret.NewFakeManager(), c…
157 manager := newTestVolumeManager(t, tmpDir, podManager, kubeClient)
162 podManager.SetPods([]*v1.Pod{pod})
193 …podManager := kubepod.NewBasicPodManager(podtest.NewFakeMirrorClient(), secret.NewFakeManager(), c…
245 manager := newTestVolumeManager(t, tmpDir, podManager, kubeClient)
250 podManager.SetPods([]*v1.Pod{pod})
286 func newTestVolumeManager(t *testing.T, tmpDir string, podManager kubepod.Manager, kubeClient clien…
[all …]
|
| H A D | volume_manager.go | 174 podManager pod.Manager,
209 podManager,
|
| /dports/sysutils/kubectl/kubernetes-1.22.2/pkg/kubelet/ |
| H A D | runonce_test.go | 67 podManager := kubepod.NewBasicPodManager(
80 statusManager: status.NewManager(nil, podManager, &statustest.FakePodDeletionSafetyProvider{}),
81 podManager: podManager,
104 kb.podManager,
153 podManager.SetPods(pods)
|
| H A D | kubelet_volumes_test.go | 78 kubelet.podManager.SetPods([]*v1.Pod{pod})
192 kubelet.podManager.SetPods(pods)
236 kubelet.podManager.SetPods([]*v1.Pod{pod})
292 kubelet.podManager.SetPods([]*v1.Pod{pod})
320 kubelet.podManager.SetPods([]*v1.Pod{})
393 kubelet.podManager.SetPods([]*v1.Pod{pod})
474 kubelet.podManager.SetPods([]*v1.Pod{pod})
508 kubelet.podManager.SetPods([]*v1.Pod{})
|
| H A D | kubelet.go | 713 klet.podManager,
722 klet.podManager,
802 klet.podManager,
923 podManager kubepod.Manager member
1870 allPods := kl.podManager.GetPods()
2157 pod, ok := kl.podManager.GetPodByUID(update.PodUID)
2199 existingPods := kl.podManager.GetPods()
2204 kl.podManager.AddPod(pod)
2239 kl.podManager.UpdatePod(pod)
2254 kl.podManager.DeletePod(pod)
[all …]
|
| H A D | kubelet_test.go | 268 kubelet.podManager,
341 kubelet.podManager,
418 kubelet.podManager.SetPods(pods)
1222 kl.podManager.SetPods(pods)
1254 kl.podManager.SetPods(pods)
1389 kubelet.podManager.SetPods(pods)
1449 kubelet.podManager.SetPods(pods)
1544 kubelet.podManager.SetPods(pods)
1577 kl.podManager.SetPods(pods)
1595 kl.podManager.SetPods(pods)
[all …]
|
| H A D | kubelet_getters.go | 170 pods := kl.podManager.GetPods()
204 return kl.podManager.GetPodByFullName(podFullName)
210 return kl.podManager.GetPodByName(namespace, name)
218 return kl.podManager.GetPodByUID(podUID)
|
| H A D | runonce.go | 130 if err := kl.podManager.CreateMirrorPod(pod); err != nil {
133 mirrorPod, _ := kl.podManager.GetMirrorPodByPod(pod)
|
| H A D | kubelet_pods.go | 103 allPods := kl.podManager.GetPods()
1006 mirrorPods := kl.podManager.GetOrphanedMirrorPodNames()
1009 _, err := kl.podManager.DeleteMirrorPod(podFullname, nil)
1042 allPods, mirrorPods := kl.podManager.GetPodsAndMirrorPods()
1247 if mirrorPod, ok := kl.podManager.GetMirrorPodByPod(pod); ok {
1816 podUID = types.UID(kl.podManager.TranslatePodUID(podUID))
1880 podUID = types.UID(kl.podManager.TranslatePodUID(podUID))
|
| /dports/sysutils/kubectl/kubernetes-1.22.2/pkg/kubelet/status/ |
| H A D | status_manager_test.go | 85 podManager.AddPod(getTestPod())
320 syncer.podManager.AddPod(pod)
523 m.podManager.AddPod(staticPod)
541 m.podManager.AddPod(mirrorPod)
560 m.podManager.AddPod(mirrorPod)
674 m.podManager.AddPod(pod)
758 m.podManager.AddPod(pod)
822 m.podManager.AddPod(mirrorPod)
826 m.podManager.AddPod(staticPod)
902 m.podManager.AddPod(pod)
[all …]
|
| H A D | status_manager.go | 64 podManager kubepod.Manager member
123 podManager: podManager,
186 status, ok := m.podStatuses[types.UID(m.podManager.TranslatePodUID(uid))]
207 pod, ok := m.podManager.GetPodByUID(podUID)
268 pod, ok := m.podManager.GetPodByUID(podUID)
398 } else if mirrorPod, ok := m.podManager.GetMirrorPodByPod(pod); ok {
539 podToMirror, mirrorToPod := m.podManager.GetUIDTranslations()
608 translatedUID := m.podManager.TranslatePodUID(pod.UID)
661 pod, ok := m.podManager.GetPodByUID(uid)
686 pod, ok := m.podManager.GetPodByUID(uid)
[all …]
|
| /dports/sysutils/kubectl/kubernetes-1.22.2/pkg/kubelet/prober/ |
| H A D | common_test.go | 107 podManager := kubepod.NewBasicPodManager(nil, nil, nil)
109 podManager.AddPod(getTestPod())
111 status.NewManager(&fake.Clientset{}, podManager, &statustest.FakePodDeletionSafetyProvider{}),
|
| /dports/sysutils/kubectl/kubernetes-1.22.2/pkg/kubelet/volumemanager/populator/ |
| H A D | desired_state_of_world_populator.go | 91 podManager pod.Manager,
104 podManager: podManager,
124 podManager pod.Manager member
202 for _, pod := range dswp.podManager.GetPods() {
215 pod, podExists := dswp.podManager.GetPodByUID(volumeToMount.Pod.UID)
266 if _, podExists := dswp.podManager.GetPodByUID(types.UID(podName)); !podExists {
|
| H A D | desired_state_of_world_populator_test.go | 227 podGet, exist := dswp.podManager.GetPodByName(pod.Namespace, pod.Name)
232 dswp.podManager.DeletePod(pod)
279 podGet, exist := dswp.podManager.GetPodByName(pod.Namespace, pod.Name)
341 podGet, exist := dswp.podManager.GetPodByName(pod.Namespace, pod.Name)
346 dswp.podManager.DeletePod(pod)
1403 podManager: fakePodManager,
|