- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for NewPodContainerManager (0.34 sec)
-
pkg/kubelet/cm/container_manager_stub.go
} func (m *podContainerManagerStub) SetPodCgroupConfig(_ *v1.Pod, _ v1.ResourceName, _ *ResourceConfig) error { return fmt.Errorf("not implemented") } func (cm *containerManagerStub) NewPodContainerManager() PodContainerManager { return &podContainerManagerStub{} } func (cm *containerManagerStub) GetResources(pod *v1.Pod, container *v1.Container) (*kubecontainer.RunContainerOptions, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 15 02:26:59 UTC 2023 - 5.9K bytes - Viewed (0) -
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/fake_container_manager.go
cm.Lock() defer cm.Unlock() cm.CalledFunctions = append(cm.CalledFunctions, "GetDevicePluginResourceCapacity") return nil, nil, []string{} } func (cm *FakeContainerManager) NewPodContainerManager() PodContainerManager { cm.Lock() defer cm.Unlock() cm.CalledFunctions = append(cm.CalledFunctions, "PodContainerManager") return cm.PodContainerManager }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 17:33:04 UTC 2023 - 7.4K 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)