Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for NewBasicPodManager (0.27 sec)

  1. pkg/kubelet/prober/common_test.go

    	case liveness:
    		pod.Spec.Containers[0].LivenessProbe = &probeSpec
    	case startup:
    		pod.Spec.Containers[0].StartupProbe = &probeSpec
    	}
    }
    
    func newTestManager() *manager {
    	podManager := kubepod.NewBasicPodManager()
    	podStartupLatencyTracker := kubeletutil.NewPodStartupLatencyTracker()
    	// Add test pod to pod manager, so that status manager can get the pod from pod manager if needed.
    	podManager.AddPod(getTestPod())
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 12 16:57:26 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  2. pkg/kubelet/pod/pod_manager_test.go

    )
    
    // Stub out mirror client for testing purpose.
    func newTestManager() (*basicManager, *podtest.FakeMirrorClient) {
    	fakeMirrorClient := podtest.NewFakeMirrorClient()
    	manager := NewBasicPodManager().(*basicManager)
    	return manager, fakeMirrorClient
    }
    
    // Tests that pods/maps are properly set after the pod update, and the basic
    // methods work correctly.
    func TestGetSetPods(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 12 16:57:27 UTC 2023
    - 5.4K bytes
    - Viewed (0)
  3. 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)
  4. pkg/kubelet/prober/scale_test.go

    			testRootDir := ""
    			if tempDir, err := os.MkdirTemp("", "kubelet_test."); err != nil {
    				t.Fatalf("can't make a temp rootdir: %v", err)
    			} else {
    				testRootDir = tempDir
    			}
    			podManager := kubepod.NewBasicPodManager()
    			podStartupLatencyTracker := kubeletutil.NewPodStartupLatencyTracker()
    			m := NewManager(
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Aug 16 16:33:01 UTC 2023
    - 8.2K bytes
    - Viewed (0)
Back to top