Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for NewPodStartupLatencyTracker (0.35 sec)

  1. pkg/kubelet/util/pod_startup_latency_tracker.go

    	// first time, when pod status changed into Running
    	observedRunningTime time.Time
    	// log, if pod latency was already Observed
    	metricRecorded bool
    }
    
    // NewPodStartupLatencyTracker creates an instance of PodStartupLatencyTracker
    func NewPodStartupLatencyTracker() PodStartupLatencyTracker {
    	return &basicPodStartupLatencyTracker{
    		pods:  map[types.UID]*perPodState{},
    		clock: clock.RealClock{},
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 15 06:09:49 UTC 2023
    - 5.5K bytes
    - Viewed (0)
  2. pkg/kubelet/prober/common_test.go

    	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())
    	testRootDir := ""
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 12 16:57:26 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  3. pkg/kubelet/runonce_test.go

    	clusterTrustBundleManager := &clustertrustbundle.NoopManager{}
    	podManager := kubepod.NewBasicPodManager()
    	fakeRuntime := &containertest.FakeRuntime{}
    	podStartupLatencyTracker := kubeletutil.NewPodStartupLatencyTracker()
    	basePath, err := utiltesting.MkTmpdir("kubelet")
    	if err != nil {
    		t.Fatalf("can't make a temp rootdir %v", err)
    	}
    	defer os.RemoveAll(basePath)
    	kb := &Kubelet{
    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/kubemark/hollow_kubelet.go

    		Mounter:                   &mount.FakeMounter{},
    		Subpather:                 &subpath.FakeSubpath{},
    		HostUtil:                  hostutil.NewFakeHostUtil(nil),
    		PodStartupLatencyTracker:  kubeletutil.NewPodStartupLatencyTracker(),
    		NodeStartupLatencyTracker: kubeletutil.NewNodeStartupLatencyTracker(),
    		TracerProvider:            noopoteltrace.NewTracerProvider(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 17:10:54 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  5. pkg/kubelet/prober/scale_test.go

    				t.Fatalf("can't make a temp rootdir: %v", err)
    			} else {
    				testRootDir = tempDir
    			}
    			podManager := kubepod.NewBasicPodManager()
    			podStartupLatencyTracker := kubeletutil.NewPodStartupLatencyTracker()
    			m := NewManager(
    				status.NewManager(&fake.Clientset{}, podManager, &statustest.FakePodDeletionSafetyProvider{}, podStartupLatencyTracker, testRootDir),
    				results.NewManager(),
    				results.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