Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for NewNodeStartupLatencyTracker (0.25 sec)

  1. pkg/kubelet/util/node_startup_latency_tracker.go

    	firstRegistrationAttemptTime time.Time
    	firstRegisteredNewNodeTime   time.Time
    	firstNodeReadyTime           time.Time
    
    	// For testability
    	clock clock.Clock
    }
    
    func NewNodeStartupLatencyTracker() NodeStartupLatencyTracker {
    	bootTime, err := GetBootTime()
    	if err != nil {
    		bootTime = time.Time{}
    	}
    	return &basicNodeStartupLatencyTracker{
    		bootTime:         bootTime,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Sep 11 05:54:25 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  2. pkg/kubemark/hollow_kubelet.go

    		HostUtil:                  hostutil.NewFakeHostUtil(nil),
    		PodStartupLatencyTracker:  kubeletutil.NewPodStartupLatencyTracker(),
    		NodeStartupLatencyTracker: kubeletutil.NewNodeStartupLatencyTracker(),
    		TracerProvider:            noopoteltrace.NewTracerProvider(),
    		Recorder:                  &record.FakeRecorder{}, // With real recorder we attempt to read /dev/kmsg.
    	}
    
    	return &HollowKubelet{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 17:10:54 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  3. cmd/kubelet/app/server.go

    		kubeDeps.PodStartupLatencyTracker = kubeletutil.NewPodStartupLatencyTracker()
    	}
    
    	if kubeDeps.NodeStartupLatencyTracker == nil {
    		kubeDeps.NodeStartupLatencyTracker = kubeletutil.NewNodeStartupLatencyTracker()
    	}
    
    	// TODO(vmarmol): Do this through container config.
    	oomAdjuster := kubeDeps.OOMAdjuster
    	if err := oomAdjuster.ApplyOOMScoreAdj(0, int(s.OOMScoreAdj)); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:34 UTC 2024
    - 53.9K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet_test.go

    	kubelet.statusManager = status.NewManager(fakeKubeClient, kubelet.podManager, &statustest.FakePodDeletionSafetyProvider{}, podStartupLatencyTracker, kubelet.getRootDir())
    	kubelet.nodeStartupLatencyTracker = kubeletutil.NewNodeStartupLatencyTracker()
    
    	kubelet.containerRuntime = fakeRuntime
    	kubelet.runtimeCache = containertest.NewFakeRuntimeCache(kubelet.containerRuntime)
    	kubelet.reasonCache = NewReasonCache()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
Back to top