kubernetes/pkg/kubelet/pod/pod_manager.go

type Manager …

type basicManager …

// NewBasicPodManager returns a functional Manager.
func NewBasicPodManager() Manager { … }

// SetPods set the internal pods based on the new pods.
func (pm *basicManager) SetPods(newPods []*v1.Pod) { … }

func (pm *basicManager) AddPod(pod *v1.Pod) { … }

func (pm *basicManager) UpdatePod(pod *v1.Pod) { … }

// updateMetrics updates the metrics surfaced by the pod manager.
// oldPod or newPod may be nil to signify creation or deletion.
func updateMetrics(oldPod, newPod *v1.Pod) { … }

// updatePodsInternal replaces the given pods in the current state of the
// manager, updating the various indices. The caller is assumed to hold the
// lock.
func (pm *basicManager) updatePodsInternal(pods ...*v1.Pod) { … }

func (pm *basicManager) RemovePod(pod *v1.Pod) { … }

func (pm *basicManager) GetPods() []*v1.Pod { … }

func (pm *basicManager) GetPodsAndMirrorPods() (allPods []*v1.Pod, allMirrorPods []*v1.Pod, orphanedMirrorPodFullnames []string) { … }

func (pm *basicManager) GetPodByUID(uid types.UID) (*v1.Pod, bool) { … }

func (pm *basicManager) GetPodByName(namespace, name string) (*v1.Pod, bool) { … }

func (pm *basicManager) GetPodByFullName(podFullName string) (*v1.Pod, bool) { … }

func (pm *basicManager) TranslatePodUID(uid types.UID) kubetypes.ResolvedPodUID { … }

func (pm *basicManager) GetUIDTranslations() (podToMirror map[kubetypes.ResolvedPodUID]kubetypes.MirrorPodUID,
	mirrorToPod map[kubetypes.MirrorPodUID]kubetypes.ResolvedPodUID) { … }

// IsMirrorPodOf returns true if pod and mirrorPod are associated with each other.
func IsMirrorPodOf(mirrorPod, pod *v1.Pod) bool { … }

func podsMapToPods(UIDMap map[kubetypes.ResolvedPodUID]*v1.Pod) []*v1.Pod { … }

func mirrorPodsMapToMirrorPods(UIDMap map[kubetypes.MirrorPodUID]*v1.Pod) []*v1.Pod { … }

func (pm *basicManager) GetMirrorPodByPod(pod *v1.Pod) (*v1.Pod, bool) { … }

func (pm *basicManager) GetPodByMirrorPod(mirrorPod *v1.Pod) (*v1.Pod, bool) { … }

func (pm *basicManager) GetPodAndMirrorPod(aPod *v1.Pod) (pod, mirrorPod *v1.Pod, wasMirror bool) { … }