Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for GetAllocateResourcesPodAdmitHandler (0.62 sec)

  1. pkg/kubelet/cm/fake_container_manager.go

    	return cm.shouldResetExtendedResourceCapacity
    }
    
    func (cm *FakeContainerManager) GetAllocateResourcesPodAdmitHandler() lifecycle.PodAdmitHandler {
    	cm.Lock()
    	defer cm.Unlock()
    	cm.CalledFunctions = append(cm.CalledFunctions, "GetAllocateResourcesPodAdmitHandler")
    	return topologymanager.NewFakeManager()
    }
    
    func (cm *FakeContainerManager) UpdateAllocatedDevices() {
    	cm.Lock()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 17:33:04 UTC 2023
    - 7.4K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/container_manager.go

    	// due to node recreation.
    	ShouldResetExtendedResourceCapacity() bool
    
    	// GetAllocateResourcesPodAdmitHandler returns an instance of a PodAdmitHandler responsible for allocating pod resources.
    	GetAllocateResourcesPodAdmitHandler() lifecycle.PodAdmitHandler
    
    	// GetNodeAllocatableAbsolute returns the absolute value of Node Allocatable which is primarily useful for enforcement.
    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/container_manager_stub.go

    	return nil
    }
    
    func (cm *containerManagerStub) ShouldResetExtendedResourceCapacity() bool {
    	return cm.shouldResetExtendedResourceCapacity
    }
    
    func (cm *containerManagerStub) GetAllocateResourcesPodAdmitHandler() lifecycle.PodAdmitHandler {
    	return topologymanager.NewFakeManager()
    }
    
    func (cm *containerManagerStub) UpdateAllocatedDevices() {
    	return
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 15 02:26:59 UTC 2023
    - 5.9K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/container_manager_windows.go

    	return nil
    }
    
    func (cm *containerManagerImpl) ShouldResetExtendedResourceCapacity() bool {
    	return cm.deviceManager.ShouldResetExtendedResourceCapacity()
    }
    
    func (cm *containerManagerImpl) GetAllocateResourcesPodAdmitHandler() lifecycle.PodAdmitHandler {
    	return &noopWindowsResourceAllocator{}
    }
    
    func (cm *containerManagerImpl) UpdateAllocatedDevices() {
    	return
    }
    
    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.go

    	return cm.deviceManager.UpdatePluginResources(node, attrs)
    }
    
    func (cm *containerManagerImpl) GetAllocateResourcesPodAdmitHandler() lifecycle.PodAdmitHandler {
    	return cm.topologyManager
    }
    
    func (cm *containerManagerImpl) SystemCgroupsLimit() v1.ResourceList {
    	cpuLimit := int64(0)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 10:18:16 UTC 2024
    - 35.1K bytes
    - Viewed (0)
  6. pkg/kubelet/kubelet.go

    	if err != nil {
    		return nil, err
    	}
    	klet.AddPodSyncLoopHandler(activeDeadlineHandler)
    	klet.AddPodSyncHandler(activeDeadlineHandler)
    
    	klet.admitHandlers.AddPodAdmitHandler(klet.containerManager.GetAllocateResourcesPodAdmitHandler())
    
    	criticalPodAdmissionHandler := preemption.NewCriticalPodAdmissionHandler(klet.GetActivePods, killPodNow(klet.podWorkers, kubeDeps.Recorder), kubeDeps.Recorder)
    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