- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for ListCheckpoints (0.13 sec)
-
pkg/kubelet/cm/devicemanager/manager.go
// has been recreated. func (m *ManagerImpl) ShouldResetExtendedResourceCapacity() bool { checkpoints, err := m.checkpointManager.ListCheckpoints() if err != nil { return false } return len(checkpoints) == 0 } func (m *ManagerImpl) setPodPendingAdmission(pod *v1.Pod) { m.mutex.Lock() defer m.mutex.Unlock()
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
err = testManager.writeCheckpoint() 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)