Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for ListCheckpoints (0.28 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)
Back to top