- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for NewPodStartupLatencyTracker (0.29 sec)
-
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) -
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) -
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) -
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) -
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) -
pkg/kubelet/prober/worker_test.go
} 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) { ctx := context.Background() m := newTestManager()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 07 23:48:10 UTC 2023 - 16.1K bytes - Viewed (0) -
pkg/kubelet/status/status_manager_test.go
} 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 } else { testRootDir = tempDir }
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/kubelet_test.go
kubelet.configMapManager = configMapManager kubelet.mirrorPodClient = fakeMirrorClient kubelet.podManager = kubepod.NewBasicPodManager() podStartupLatencyTracker := kubeletutil.NewPodStartupLatencyTracker() kubelet.statusManager = status.NewManager(fakeKubeClient, kubelet.podManager, &statustest.FakePodDeletionSafetyProvider{}, podStartupLatencyTracker, kubelet.getRootDir())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0) -
cmd/kubelet/app/server.go
kubeDeps.KubeClient, ) if err != nil { return err } } if kubeDeps.PodStartupLatencyTracker == nil { kubeDeps.PodStartupLatencyTracker = kubeletutil.NewPodStartupLatencyTracker() } if kubeDeps.NodeStartupLatencyTracker == nil { kubeDeps.NodeStartupLatencyTracker = kubeletutil.NewNodeStartupLatencyTracker() } // TODO(vmarmol): Do this through container config.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:34 UTC 2024 - 53.9K bytes - Viewed (0)