- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for ListCheckpoints (0.3 sec)
-
pkg/kubelet/checkpointmanager/checkpoint_manager.go
func (manager *impl) RemoveCheckpoint(checkpointKey string) error { manager.mutex.Lock() defer manager.mutex.Unlock() return manager.store.Delete(checkpointKey) } // ListCheckpoints returns the list of existing checkpoints. func (manager *impl) ListCheckpoints() ([]string, error) { manager.mutex.Lock() defer manager.mutex.Unlock() keys, err := manager.store.List() if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 24 13:51:34 UTC 2021 - 3.5K bytes - Viewed (0) -
pkg/kubelet/checkpointmanager/checkpoint_manager_test.go
assert.NoError(t, err) testStore.Write("key1", blob) err = manager.GetCheckpoint("key1", checkpoint1) assert.EqualError(t, err, "checkpoint is corrupted") // Test ListCheckpoints keys, err := manager.ListCheckpoints() assert.NoError(t, err) sort.Strings(keys) assert.Equal(t, keys, []string{"key1", "key2"}) // Test RemoveCheckpoints err = manager.RemoveCheckpoint("key1")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 12 06:41:04 UTC 2018 - 6.6K bytes - Viewed (0) -
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)