Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for newCadvisorStatsProvider (0.23 sec)

  1. pkg/kubelet/stats/cadvisor_stats_provider_test.go

    	mockStatus.EXPECT().GetPodStatus(types.UID("UID"+pName3)).Return(v1.PodStatus{StartTime: &p3Time}, true)
    
    	resourceAnalyzer := &fakeResourceAnalyzer{podVolumeStats: volumeStats}
    
    	p := NewCadvisorStatsProvider(mockCadvisor, resourceAnalyzer, nil, nil, mockRuntime, mockStatus, NewFakeHostStatsProvider())
    	pods, err := p.ListPodStats(ctx)
    	assert.NoError(t, err)
    
    	assert.Equal(t, 4, len(pods))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet_test.go

    	kubelet.resourceAnalyzer = serverstats.NewResourceAnalyzer(kubelet, volumeStatsAggPeriod, kubelet.recorder)
    
    	fakeHostStatsProvider := stats.NewFakeHostStatsProvider()
    
    	kubelet.StatsProvider = stats.NewCadvisorStatsProvider(
    		kubelet.cadvisor,
    		kubelet.resourceAnalyzer,
    		kubelet.podManager,
    		kubelet.runtimeCache,
    		fakeRuntime,
    		kubelet.statusManager,
    		fakeHostStatsProvider,
    	)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  3. pkg/kubelet/kubelet.go

    		return getEtcHostsPath(klet.getPodDir(podUID))
    	}, podLogsDirectory)
    	if kubeDeps.useLegacyCadvisorStats {
    		klet.StatsProvider = stats.NewCadvisorStatsProvider(
    			klet.cadvisor,
    			klet.resourceAnalyzer,
    			klet.podManager,
    			klet.runtimeCache,
    			klet.containerRuntime,
    			klet.statusManager,
    			hostStatsProvider)
    	} else {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
Back to top