Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for NewPodStartupLatencyTracker (0.29 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
Back to top