Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for NewPodContainerManager (0.34 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
Back to top