Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for NewBasicPodManager (0.22 sec)

  1. pkg/kubelet/volumemanager/volume_manager_test.go

    			tmpDir, err := utiltesting.MkTmpdir("volumeManagerTest")
    			if err != nil {
    				t.Fatalf("can't make a temp dir: %v", err)
    			}
    			defer os.RemoveAll(tmpDir)
    			podManager := kubepod.NewBasicPodManager()
    
    			node, pod, pv, claim := createObjects(test.pvMode, test.podMode)
    			kubeClient := fake.NewSimpleClientset(node, pod, pv, claim)
    
    			manager := newTestVolumeManager(t, tmpDir, podManager, kubeClient, node)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  2. pkg/kubelet/pod/pod_manager.go

    	mirrorPodByFullName map[string]*v1.Pod
    
    	// Mirror pod UID to pod UID map.
    	translationByUID map[kubetypes.MirrorPodUID]kubetypes.ResolvedPodUID
    }
    
    // NewBasicPodManager returns a functional Manager.
    func NewBasicPodManager() Manager {
    	pm := &basicManager{}
    	pm.SetPods(nil)
    	return pm
    }
    
    // Set the internal pods based on the new pods.
    func (pm *basicManager) SetPods(newPods []*v1.Pod) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:00 UTC 2024
    - 11.9K bytes
    - Viewed (0)
Back to top