- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for ShouldResetExtendedResourceCapacity (0.49 sec)
-
pkg/kubelet/cm/container_manager_stub.go
} func NewStubContainerManager() ContainerManager { return &containerManagerStub{shouldResetExtendedResourceCapacity: false} } func NewStubContainerManagerWithExtendedResource(shouldResetExtendedResourceCapacity bool) ContainerManager { return &containerManagerStub{shouldResetExtendedResourceCapacity: shouldResetExtendedResourceCapacity} }
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/fake_container_manager.go
return nil } func (cm *FakeContainerManager) ShouldResetExtendedResourceCapacity() bool { cm.Lock() defer cm.Unlock() cm.CalledFunctions = append(cm.CalledFunctions, "ShouldResetExtendedResourceCapacity") return cm.shouldResetExtendedResourceCapacity } func (cm *FakeContainerManager) GetAllocateResourcesPodAdmitHandler() lifecycle.PodAdmitHandler { 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) -
pkg/kubelet/cm/devicemanager/types.go
GetAllocatableDevices() ResourceDeviceInstances // ShouldResetExtendedResourceCapacity returns whether the extended resources should be reset or not, // depending on the checkpoint file availability. Absence of the checkpoint file strongly indicates // the node has been recreated. ShouldResetExtendedResourceCapacity() bool
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 13:02:15 UTC 2023 - 5K bytes - Viewed (0) -
pkg/kubelet/cm/container_manager_windows.go
} func (cm *containerManagerImpl) GetAllocatableDevices() []*podresourcesapi.ContainerDevices { return nil } func (cm *containerManagerImpl) ShouldResetExtendedResourceCapacity() bool { return cm.deviceManager.ShouldResetExtendedResourceCapacity() } func (cm *containerManagerImpl) GetAllocateResourcesPodAdmitHandler() lifecycle.PodAdmitHandler { return &noopWindowsResourceAllocator{} }
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.go
// registration. GetPluginRegistrationHandler() cache.PluginHandler // ShouldResetExtendedResourceCapacity returns whether or not the extended resources should be zeroed, // due to node recreation. ShouldResetExtendedResourceCapacity() bool // GetAllocateResourcesPodAdmitHandler returns an instance of a PodAdmitHandler responsible for allocating pod resources.
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_linux.go
containerDynamicResources = append(containerDynamicResources, &containerDynamicResource) } return containerDynamicResources } func (cm *containerManagerImpl) ShouldResetExtendedResourceCapacity() bool { return cm.deviceManager.ShouldResetExtendedResourceCapacity() } func (cm *containerManagerImpl) UpdateAllocatedDevices() { cm.deviceManager.UpdateAllocatedDevices() }
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/cm/devicemanager/manager.go
return m.podDevices.getContainerDevices(podUID, containerName) } // ShouldResetExtendedResourceCapacity returns whether the extended resources should be zeroed or not, // depending on whether the node has been recreated. Absence of the checkpoint file strongly indicates the node // has been recreated. func (m *ManagerImpl) ShouldResetExtendedResourceCapacity() bool { checkpoints, err := m.checkpointManager.ListCheckpoints()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 15 12:01:56 UTC 2024 - 43K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/manager_test.go
as.Nil(err) as.False(testManager.ShouldResetExtendedResourceCapacity()) // checkpoint is absent, representing node recreation ckpts, err := ckm.ListCheckpoints() as.Nil(err) for _, ckpt := range ckpts { err = ckm.RemoveCheckpoint(ckpt) as.Nil(err) } as.True(testManager.ShouldResetExtendedResourceCapacity()) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 65K bytes - Viewed (0) -
pkg/kubelet/kubelet_node_status.go
// Check with the device manager to see if node has been recreated, in which case extended resources should be zeroed until they are available if kl.containerManager.ShouldResetExtendedResourceCapacity() { for k := range node.Status.Capacity { if v1helper.IsExtendedResourceName(k) { klog.InfoS("Zero out resource capacity in existing node", "resourceName", k, "node", klog.KObj(node))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 31.1K bytes - Viewed (0) -
pkg/kubelet/kubelet_node_status_test.go
testKubelet.kubelet.kubeClient = nil // ensure only the heartbeat client is used testKubelet.kubelet.containerManager = cm.NewStubContainerManagerWithExtendedResource(true /* shouldResetExtendedResourceCapacity*/) testKubeletNoReset := newTestKubelet(t, false /* controllerAttachDetachEnabled */) defer testKubeletNoReset.Cleanup() extendedResourceName1 := v1.ResourceName("test.com/resource1")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 08 19:23:19 UTC 2024 - 115.8K bytes - Viewed (0)