Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for ResolvedPodUID (1.19 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
Back to top