Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for newCadvisorStatsProvider (0.4 sec)

  1. pkg/kubelet/stats/provider.go

    		runtimeService, imageService, hostStatsProvider, podAndContainerStatsFromCRI))
    }
    
    // NewCadvisorStatsProvider returns a containerStatsProvider that provides both
    // the node and the container stats from cAdvisor.
    func NewCadvisorStatsProvider(
    	cadvisor cadvisor.Interface,
    	resourceAnalyzer stats.ResourceAnalyzer,
    	podManager PodManager,
    	runtimeCache kubecontainer.RuntimeCache,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 13:56:22 UTC 2023
    - 7.4K bytes
    - Viewed (0)
  2. 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)
  3. pkg/kubelet/stats/cadvisor_stats_provider.go

    	statusProvider status.PodStatusProvider
    	// hostStatsProvider is used to get pod host stat usage.
    	hostStatsProvider HostStatsProvider
    }
    
    // newCadvisorStatsProvider returns a containerStatsProvider that provides
    // container stats from cAdvisor.
    func newCadvisorStatsProvider(
    	cadvisor cadvisor.Interface,
    	resourceAnalyzer stats.ResourceAnalyzer,
    	imageService kubecontainer.ImageService,
    	statusProvider status.PodStatusProvider,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Nov 16 13:34:22 UTC 2023
    - 18.9K bytes
    - Viewed (0)
  4. 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)
  5. 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