Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NewBasicPodManager (0.49 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)
  3. pkg/kubelet/prober/worker_test.go

    				t.Fatalf("can't make a temp rootdir: %v", err)
    			} else {
    				testRootDir = tempDir
    			}
    			m.statusManager = status.NewManager(&fake.Clientset{}, kubepod.NewBasicPodManager(), &statustest.FakePodDeletionSafetyProvider{}, kubeletutil.NewPodStartupLatencyTracker(), testRootDir)
    			resultsManager(m, probeType).Remove(testContainerID)
    		}
    	}
    }
    
    func TestInitialDelay(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 07 23:48:10 UTC 2023
    - 16.1K bytes
    - Viewed (0)
Back to top