Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for ListPodsFromDisk (0.3 sec)

  1. pkg/kubelet/userns/userns_manager.go

    // since Go maps never free memory.
    const mapReInitializeThreshold = 1000
    
    type userNsPodsManager interface {
    	HandlerSupportsUserNamespaces(runtimeHandler string) (bool, error)
    	GetPodDir(podUID types.UID) string
    	ListPodsFromDisk() ([]types.UID, error)
    	GetKubeletMappings() (uint32, uint32, error)
    	GetMaxPods() int
    }
    
    type UsernsManager struct {
    	used    *allocator.AllocationBitmap
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet_getters.go

    func (kl *Kubelet) GetPodDir(podUID types.UID) string {
    	return kl.getPodDir(podUID)
    }
    
    // ListPodsFromDisk gets a list of pods that have data directories.
    func (kl *Kubelet) ListPodsFromDisk() ([]types.UID, error) {
    	return kl.listPodsFromDisk()
    }
    
    // HandlerSupportsUserNamespaces checks whether the specified handler supports
    // user namespaces.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 09 00:48:07 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  3. pkg/kubelet/userns/userns_manager_test.go

    }
    
    func (m *testUserNsPodsManager) GetPodDir(podUID types.UID) string {
    	if m.podDir == "" {
    		return "/tmp/non-existant-dir.This-is-not-used-in-tests"
    	}
    	return m.podDir
    }
    
    func (m *testUserNsPodsManager) ListPodsFromDisk() ([]types.UID, error) {
    	if len(m.podList) == 0 {
    		return nil, nil
    	}
    	return m.podList, nil
    }
    
    func (m *testUserNsPodsManager) HandlerSupportsUserNamespaces(runtimeHandler string) (bool, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 14:24:16 UTC 2024
    - 14.6K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet_volumes.go

    	allPods := sets.New[string]()
    	for _, pod := range pods {
    		allPods.Insert(string(pod.UID))
    	}
    	for _, pod := range runningPods {
    		allPods.Insert(string(pod.ID))
    	}
    
    	found, err := kl.listPodsFromDisk()
    	if err != nil {
    		return err
    	}
    
    	orphanRemovalErrors := []error{}
    	orphanVolumeErrors := []error{}
    	var totalPods, errorPods int
    
    	for _, uid := range found {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  5. pkg/kubelet/kubelet_pods.go

    		return 0, 0, fmt.Errorf("mismatched subuids and subgids for user %q", kubeletUser)
    	}
    	return parseGetSubIdsOutput(string(outUids))
    }
    
    // Get a list of pods that have data directories.
    func (kl *Kubelet) listPodsFromDisk() ([]types.UID, error) {
    	podInfos, err := os.ReadDir(kl.getPodsDir())
    	if err != nil {
    		return nil, err
    	}
    	pods := []types.UID{}
    	for i := range podInfos {
    		if podInfos[i].IsDir() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
Back to top