Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for NewBasicPodManager (0.29 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/runonce_test.go

    		Capacity: 10,
    	}, nil).AnyTimes()
    	fakeSecretManager := secret.NewFakeManager()
    	fakeConfigMapManager := configmap.NewFakeManager()
    	clusterTrustBundleManager := &clustertrustbundle.NoopManager{}
    	podManager := kubepod.NewBasicPodManager()
    	fakeRuntime := &containertest.FakeRuntime{}
    	podStartupLatencyTracker := kubeletutil.NewPodStartupLatencyTracker()
    	basePath, err := utiltesting.MkTmpdir("kubelet")
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 06:59:54 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  3. pkg/kubelet/status/status_manager_test.go

    		pod, ok = m.podManager.GetMirrorPodByPod(pod)
    		if ok {
    			pod.Status = status.status
    		}
    	}
    	m.syncBatch(true)
    }
    
    func newTestManager(kubeClient clientset.Interface) *manager {
    	podManager := kubepod.NewBasicPodManager()
    	podManager.(mutablePodManager).AddPod(getTestPod())
    	podStartupLatencyTracker := util.NewPodStartupLatencyTracker()
    	testRootDir := ""
    	if tempDir, err := os.MkdirTemp("", "kubelet_test."); err != nil {
    		return nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 02 16:27:19 UTC 2024
    - 68.1K bytes
    - Viewed (0)
  4. pkg/kubelet/volumemanager/populator/desired_state_of_world_populator_test.go

    		return true, pvc, nil
    	})
    	fakeClient.AddReactor("get", "persistentvolumes", func(action core.Action) (bool, runtime.Object, error) {
    		return true, pv, nil
    	})
    
    	fakePodManager := kubepod.NewBasicPodManager()
    
    	seLinuxTranslator := util.NewFakeSELinuxLabelTranslator()
    	fakesDSW := cache.NewDesiredStateOfWorld(fakeVolumePluginMgr, seLinuxTranslator)
    	fakeASW := cache.NewActualStateOfWorld("fake", fakeVolumePluginMgr)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 51.4K bytes
    - Viewed (0)
  5. pkg/kubelet/kubelet_test.go

    	configMapManager := configmap.NewSimpleConfigMapManager(kubelet.kubeClient)
    	kubelet.configMapManager = configMapManager
    	kubelet.mirrorPodClient = fakeMirrorClient
    	kubelet.podManager = kubepod.NewBasicPodManager()
    	podStartupLatencyTracker := kubeletutil.NewPodStartupLatencyTracker()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  6. pkg/kubelet/kubelet.go

    	klet.startupManager = proberesults.NewManager()
    	klet.podCache = kubecontainer.NewCache()
    
    	klet.mirrorPodClient = kubepod.NewBasicMirrorClient(klet.kubeClient, string(nodeName), nodeLister)
    	klet.podManager = kubepod.NewBasicPodManager()
    
    	klet.statusManager = status.NewManager(klet.kubeClient, klet.podManager, klet, kubeDeps.PodStartupLatencyTracker, klet.getRootDir())
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
Back to top