- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for NewBasicPodManager (0.17 sec)
-
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) -
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)