const podCgroupNamePrefix … type podContainerManagerImpl … var _ … // Exists checks if the pod's cgroup already exists func (m *podContainerManagerImpl) Exists(pod *v1.Pod) bool { … } // EnsureExists takes a pod as argument and makes sure that // pod cgroup exists if qos cgroup hierarchy flag is enabled. // If the pod level container doesn't already exist it is created. func (m *podContainerManagerImpl) EnsureExists(pod *v1.Pod) error { … } // GetPodContainerName returns the CgroupName identifier, and its literal cgroupfs form on the host. func (m *podContainerManagerImpl) GetPodContainerName(pod *v1.Pod) (CgroupName, string) { … } func (m *podContainerManagerImpl) GetPodCgroupMemoryUsage(pod *v1.Pod) (uint64, error) { … } func (m *podContainerManagerImpl) GetPodCgroupConfig(pod *v1.Pod, resource v1.ResourceName) (*ResourceConfig, error) { … } func (m *podContainerManagerImpl) SetPodCgroupConfig(pod *v1.Pod, resourceConfig *ResourceConfig) error { … } // Kill one process ID func (m *podContainerManagerImpl) killOnePid(pid int) error { … } // Scan through the whole cgroup directory and kill all processes either // attached to the pod cgroup or to a container cgroup under the pod cgroup func (m *podContainerManagerImpl) tryKillingCgroupProcesses(podCgroup CgroupName) error { … } // Destroy destroys the pod container cgroup paths func (m *podContainerManagerImpl) Destroy(podCgroup CgroupName) error { … } // ReduceCPULimits reduces the CPU CFS values to the minimum amount of shares. func (m *podContainerManagerImpl) ReduceCPULimits(podCgroup CgroupName) error { … } // IsPodCgroup returns true if the literal cgroupfs name corresponds to a pod func (m *podContainerManagerImpl) IsPodCgroup(cgroupfs string) (bool, types.UID) { … } // GetAllPodsFromCgroups scans through all the subsystems of pod cgroups // Get list of pods whose cgroup still exist on the cgroup mounts func (m *podContainerManagerImpl) GetAllPodsFromCgroups() (map[types.UID]CgroupName, error) { … } type podContainerManagerNoop … var _ … func (m *podContainerManagerNoop) Exists(_ *v1.Pod) bool { … } func (m *podContainerManagerNoop) EnsureExists(_ *v1.Pod) error { … } func (m *podContainerManagerNoop) GetPodContainerName(_ *v1.Pod) (CgroupName, string) { … } func (m *podContainerManagerNoop) GetPodContainerNameForDriver(_ *v1.Pod) string { … } // Destroy destroys the pod container cgroup paths func (m *podContainerManagerNoop) Destroy(_ CgroupName) error { … } func (m *podContainerManagerNoop) ReduceCPULimits(_ CgroupName) error { … } func (m *podContainerManagerNoop) GetAllPodsFromCgroups() (map[types.UID]CgroupName, error) { … } func (m *podContainerManagerNoop) IsPodCgroup(cgroupfs string) (bool, types.UID) { … } func (m *podContainerManagerNoop) GetPodCgroupMemoryUsage(_ *v1.Pod) (uint64, error) { … } func (m *podContainerManagerNoop) GetPodCgroupConfig(_ *v1.Pod, _ v1.ResourceName) (*ResourceConfig, error) { … } func (m *podContainerManagerNoop) SetPodCgroupConfig(_ *v1.Pod, _ *ResourceConfig) error { … }
Codebase Browser
kubernetes