Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for ListCheckpoints (0.3 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
Back to top