Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for NewPodContainerManager (0.48 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top