- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for NewPodContainerManager (0.26 sec)
-
pkg/kubelet/cm/container_manager.go
GetNodeConfig() NodeConfig // Status returns internal Status. Status() Status // NewPodContainerManager is a factory method which returns a podContainerManager object // Returns a noop implementation if qos cgroup hierarchy is not enabled NewPodContainerManager() PodContainerManager // GetMountedSubsystems returns the mounted cgroup subsystems on the node GetMountedSubsystems() *CgroupSubsystems
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:13 UTC 2024 - 9K bytes - Viewed (0) -
pkg/kubelet/cm/container_manager_windows.go
} func (cm *containerManagerImpl) GetDevicePluginResourceCapacity() (v1.ResourceList, v1.ResourceList, []string) { return cm.deviceManager.GetCapacity() } func (cm *containerManagerImpl) NewPodContainerManager() PodContainerManager { return &podContainerManagerStub{} } func (cm *containerManagerImpl) GetResources(pod *v1.Pod, container *v1.Container) (*kubecontainer.RunContainerOptions, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 11:25:36 UTC 2023 - 8.7K bytes - Viewed (0) -
pkg/kubelet/cm/container_manager_linux_test.go
}, NodeConfig: QosDisabled, }, }, } for _, c := range cases { c := c t.Run(c.name, func(t *testing.T) { t.Parallel() pcm := c.cm.NewPodContainerManager() if c.cm.NodeConfig.CgroupsPerQOS { assert.IsType(t, &podContainerManagerImpl{}, pcm) got := pcm.(*podContainerManagerImpl) assert.Equal(t, c.cm.subsystems, got.subsystems)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 9.7K bytes - Viewed (0) -
pkg/kubelet/cm/container_manager_linux.go
} return cm, nil } // NewPodContainerManager is a factory method returns a PodContainerManager object // If qosCgroups are enabled then it returns the general pod container manager // otherwise it returns a no-op manager which essentially does nothing func (cm *containerManagerImpl) NewPodContainerManager() PodContainerManager { if cm.NodeConfig.CgroupsPerQOS {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 35.1K bytes - Viewed (0) -
pkg/kubelet/kubelet_getters.go
} // GetPodByCgroupfs provides the pod that maps to the specified cgroup, as well // as whether the pod was found. func (kl *Kubelet) GetPodByCgroupfs(cgroupfs string) (*v1.Pod, bool) { pcm := kl.containerManager.NewPodContainerManager() if result, podUID := pcm.IsPodCgroup(cgroupfs); result { return kl.podManager.GetPodByUID(podUID) } return nil, false } // GetHostname Returns the hostname as the kubelet sees it.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 00:48:07 UTC 2024 - 17.9K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
} return hostname, hostDomain, nil } // GetPodCgroupParent gets pod cgroup parent from container manager. func (kl *Kubelet) GetPodCgroupParent(pod *v1.Pod) string { pcm := kl.containerManager.NewPodContainerManager() _, cgroupParent := pcm.GetPodContainerName(pod) return cgroupParent } // GenerateRunContainerOptions generates the RunContainerOptions, which can be used by
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_manager.go
return true } func (m *kubeGenericRuntimeManager) doPodResizeAction(pod *v1.Pod, podStatus *kubecontainer.PodStatus, podContainerChanges podActions, result kubecontainer.PodSyncResult) { pcm := m.containerManager.NewPodContainerManager() //TODO(vinaykul,InPlacePodVerticalScaling): Figure out best way to get enforceMemoryQoS value (parameter #4 below) in platform-agnostic way
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 22 02:01:31 UTC 2024 - 64.7K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
kl.configMapManager.RegisterPod(pod) } } // Create Cgroups for the pod and apply resource parameters // to them if cgroups-per-qos flag is enabled. pcm := kl.containerManager.NewPodContainerManager() // If pod has already been terminated then we need not create // or update the pod's cgroup // TODO: once context cancellation is added this check can be removed
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0)