- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for ResolvedPodUID (1.19 sec)
-
pkg/kubelet/pod/pod_manager.go
pm.translationByUID[mirrorPodUID] = kubetypes.ResolvedPodUID(p.UID) } } else { resolvedPodUID := kubetypes.ResolvedPodUID(pod.UID) updateMetrics(pm.podByUID[resolvedPodUID], pod) pm.podByUID[resolvedPodUID] = pod pm.podByFullName[podFullName] = pod if mirror, ok := pm.mirrorPodByFullName[podFullName]; ok { pm.translationByUID[kubetypes.MirrorPodUID(mirror.UID)] = resolvedPodUID } } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:00 UTC 2024 - 11.9K bytes - Viewed (0) -
pkg/kubelet/pod/testing/mock_manager.go
// GetUIDTranslations mocks base method. func (m *MockManager) GetUIDTranslations() (map[types0.ResolvedPodUID]types0.MirrorPodUID, map[types0.MirrorPodUID]types0.ResolvedPodUID) { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "GetUIDTranslations") ret0, _ := ret[0].(map[types0.ResolvedPodUID]types0.MirrorPodUID) ret1, _ := ret[1].(map[types0.MirrorPodUID]types0.ResolvedPodUID) return ret0, ret1 }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 8.8K bytes - Viewed (0) -
pkg/kubelet/status/testing/mock_pod_status_provider.go
// GetUIDTranslations mocks base method. func (m *MockPodManager) GetUIDTranslations() (map[types0.ResolvedPodUID]types0.MirrorPodUID, map[types0.MirrorPodUID]types0.ResolvedPodUID) { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "GetUIDTranslations") ret0, _ := ret[0].(map[types0.ResolvedPodUID]types0.MirrorPodUID) ret1, _ := ret[1].(map[types0.MirrorPodUID]types0.ResolvedPodUID) return ret0, ret1 }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 15.4K bytes - Viewed (0) -
pkg/kubelet/types/types.go
System v1.ResourceList // Kubernetes represents resources reserved for kubernetes system components. Kubernetes v1.ResourceList } // ResolvedPodUID is a pod UID which has been translated/resolved to the representation known to kubelets. type ResolvedPodUID types.UID // MirrorPodUID is a pod UID for a mirror pod.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 13:13:22 UTC 2024 - 3.5K bytes - Viewed (0) -
pkg/kubelet/pod/pod_manager_test.go
} } // Tests UID translation works as expected. Convert static pod UID for comparison only. if uid := podManager.TranslatePodUID(mirrorPod.UID); uid != kubetypes.ResolvedPodUID(staticPod.UID) { t.Errorf("unable to translate UID %q to the static POD's UID %q; %#v", mirrorPod.UID, staticPod.UID, podManager.mirrorPodByUID) } // Test the basic Get methods.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 12 16:57:27 UTC 2023 - 5.4K bytes - Viewed (0) -
pkg/kubelet/status/status_manager.go
type PodManager interface { GetPodByUID(types.UID) (*v1.Pod, bool) GetMirrorPodByPod(*v1.Pod) (*v1.Pod, bool) TranslatePodUID(uid types.UID) kubetypes.ResolvedPodUID GetUIDTranslations() (podToMirror map[kubetypes.ResolvedPodUID]kubetypes.MirrorPodUID, mirrorToPod map[kubetypes.MirrorPodUID]kubetypes.ResolvedPodUID) } // PodStatusProvider knows how to provide status for a pod. It is intended to be used by other components
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 44.3K bytes - Viewed (0) -
pkg/kubelet/stats/provider.go
// See pkg/k8s.io/kubernetes/pkg/kubelet/pod.Manager for method godoc. type PodManager interface { TranslatePodUID(uid types.UID) kubetypes.ResolvedPodUID } // NewCRIStatsProvider returns a Provider that provides the node stats // from cAdvisor and the container stats from CRI. func NewCRIStatsProvider( cadvisor cadvisor.Interface,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 13:56:22 UTC 2023 - 7.4K bytes - Viewed (0) -
pkg/kubelet/status/status_manager_test.go
m.podManager.(mutablePodManager).AddPod(mirrorPod) assert.True(t, kubetypes.IsMirrorPod(mirrorPod), "SetUp error: mirrorPod") assert.Equal(t, m.podManager.TranslatePodUID(mirrorPod.UID), kubetypes.ResolvedPodUID(staticPod.UID)) t.Logf("Should be able to get the mirror pod status from status manager") retrievedStatus, _ = m.GetPodStatus(mirrorPod.UID)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 68.1K bytes - Viewed (0)