Versions in this module Expand all Collapse all v1 v1.16.3 Oct 23, 2019 Changes in this version + const MilliCPUToCPU + const MinQuotaPeriod + const MinShares + const QuotaPeriod — linux/amd64 + const SharesPerCPU + var RootCgroupName = CgroupName([]string{}) + func EnsureDockerInContainer(dockerAPIVersion *utilversion.Version, oomScoreAdj int, manager *fs.Manager) error — linux/amd64 + func GetKubeletContainer(kubeletCgroups string) (string, error) + func GetPodCgroupNameSuffix(podUID types.UID) string + func GetRuntimeContainer(containerRuntime, runtimeCgroups string) (string, error) + func HugePageLimits(resourceList v1.ResourceList) map[int64]int64 — linux/amd64 + func IsSystemdStyleName(name string) bool + func MilliCPUToQuota(milliCPU int64, period int64) (quota int64) — linux/amd64 + func MilliCPUToQuota(milliCPU, period int64) int64 — darwin/amd64, js/wasm, windows/amd64 + func MilliCPUToShares(milliCPU int64) int64 — darwin/amd64, js/wasm, windows/amd64 + func MilliCPUToShares(milliCPU int64) uint64 — linux/amd64 + func NewFakeInternalContainerLifecycle() *fakeInternalContainerLifecycle + func NodeAllocatableRoot(cgroupRoot, cgroupDriver string) string + func ParseQOSReserved(m map[string]string) (*map[v1.ResourceName]int64, error) + type ActivePodsFunc func() []*v1.Pod + type CgroupConfig struct + Name CgroupName + ResourceParameters *ResourceConfig + type CgroupManager interface + CgroupName func(name string) CgroupName + Create func(*CgroupConfig) error + Destroy func(*CgroupConfig) error + Exists func(name CgroupName) bool + GetResourceStats func(name CgroupName) (*ResourceStats, error) + Name func(name CgroupName) string + Pids func(name CgroupName) []int + ReduceCPULimits func(cgroupName CgroupName) error + Update func(*CgroupConfig) error + func NewCgroupManager(_ interface{}) CgroupManager + func NewCgroupManager(cs *CgroupSubsystems, cgroupDriver string) CgroupManager + type CgroupName []string + func NewCgroupName(base CgroupName, components ...string) CgroupName + func ParseCgroupfsToCgroupName(name string) CgroupName + func ParseSystemdToCgroupName(name string) CgroupName + func (cgroupName CgroupName) ToCgroupfs() string + func (cgroupName CgroupName) ToSystemd() string + type CgroupSubsystems struct + MountPoints map[string]string + Mounts []interface{} + Mounts []libcontainercgroups.Mount + func GetCgroupSubsystems() (*CgroupSubsystems, error) + type ContainerManager interface + GetCapacity func() v1.ResourceList + GetDevicePluginResourceCapacity func() (v1.ResourceList, v1.ResourceList, []string) + GetDevices func(podUID, containerName string) []*podresourcesapi.ContainerDevices + GetMountedSubsystems func() *CgroupSubsystems + GetNodeAllocatableReservation func() v1.ResourceList + GetNodeConfig func() NodeConfig + GetPluginRegistrationHandler func() cache.PluginHandler + GetPodCgroupRoot func() string + GetQOSContainersInfo func() QOSContainersInfo + GetResources func(pod *v1.Pod, container *v1.Container) (*kubecontainer.RunContainerOptions, error) + GetTopologyPodAdmitHandler func() topologymanager.Manager + InternalContainerLifecycle func() InternalContainerLifecycle + NewPodContainerManager func() PodContainerManager + ShouldResetExtendedResourceCapacity func() bool + Start func(*v1.Node, ActivePodsFunc, config.SourcesReady, status.PodStatusProvider, ...) error + Status func() Status + SystemCgroupsLimit func() v1.ResourceList + UpdatePluginResources func(*schedulernodeinfo.NodeInfo, *lifecycle.PodAdmitAttributes) error + UpdateQOSCgroups func() error + func NewContainerManager(_ mount.Interface, _ cadvisor.Interface, _ NodeConfig, failSwapOn bool, ...) (ContainerManager, error) + func NewContainerManager(mountUtil mount.Interface, cadvisorInterface cadvisor.Interface, ...) (ContainerManager, error) + func NewStubContainerManager() ContainerManager + func NewStubContainerManagerWithExtendedResource(shouldResetExtendedResourceCapacity bool) ContainerManager + type InternalContainerLifecycle interface + PostStopContainer func(containerID string) error + PreStartContainer func(pod *v1.Pod, container *v1.Container, containerID string) error + PreStopContainer func(containerID string) error + type KernelTunableBehavior string — linux/amd64 + const KernelTunableError + const KernelTunableModify + const KernelTunableWarn + type MemoryStats struct + Usage int64 + type NodeAllocatableConfig struct + EnforceNodeAllocatable sets.String + HardEvictionThresholds []evictionapi.Threshold + KubeReserved v1.ResourceList + KubeReservedCgroupName string + SystemReserved v1.ResourceList + SystemReservedCgroupName string + type NodeConfig struct + CPUCFSQuotaPeriod time.Duration + CgroupDriver string + CgroupRoot string + CgroupsPerQOS bool + ContainerRuntime string + EnforceCPULimits bool + ExperimentalCPUManagerPolicy string + ExperimentalCPUManagerReconcilePeriod time.Duration + ExperimentalPodPidsLimit int64 + ExperimentalTopologyManagerPolicy string + KubeletCgroupsName string + KubeletRootDir string + ProtectKernelDefaults bool + QOSReserved map[v1.ResourceName]int64 + RuntimeCgroupsName string + SystemCgroupsName string + type PodContainerManager interface + Destroy func(name CgroupName) error + EnsureExists func(*v1.Pod) error + Exists func(*v1.Pod) bool + GetAllPodsFromCgroups func() (map[types.UID]CgroupName, error) + GetPodContainerName func(*v1.Pod) (CgroupName, string) + IsPodCgroup func(cgroupfs string) (bool, types.UID) + ReduceCPULimits func(name CgroupName) error + type QOSContainerManager interface — linux/amd64 + GetQOSContainersInfo func() QOSContainersInfo + Start func(func() v1.ResourceList, ActivePodsFunc) error + UpdateCgroups func() error + func NewQOSContainerManager(subsystems *CgroupSubsystems, cgroupRoot CgroupName, nodeConfig NodeConfig, ...) (QOSContainerManager, error) + type QOSContainersInfo struct + BestEffort CgroupName + Burstable CgroupName + Guaranteed CgroupName + type ResourceConfig struct + CpuPeriod *uint64 + CpuQuota *int64 + CpuShares *uint64 + HugePageLimit map[int64]int64 + Memory *int64 + PidsLimit *int64 + func ResourceConfigForPod(pod *v1.Pod, enforceCPULimit bool, cpuPeriod uint64) *ResourceConfig + func ResourceConfigForPod(pod *v1.Pod, enforceCPULimits bool, cpuPeriod uint64) *ResourceConfig + type ResourceStats struct + MemoryStats *MemoryStats + type Status struct + SoftRequirements error