Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 15 of 15 for listPodStats (0.17 sec)

  1. pkg/kubelet/stats/cadvisor_stats_provider_test.go

    	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))
    	indexPods := make(map[statsapi.PodReference]statsapi.PodStats, len(pods))
    	for _, pod := range pods {
    		indexPods[pod.PodRef] = pod
    	}
    
    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/stats/provider_test.go

    	return o.podVolumeStats, true
    }
    
    type fakeContainerStatsProvider struct {
    	device      string
    	imageFs     *statsapi.FsStats
    	containerFs *statsapi.FsStats
    }
    
    func (p fakeContainerStatsProvider) ListPodStats(context.Context) ([]statsapi.PodStats, error) {
    	return nil, fmt.Errorf("not implemented")
    }
    
    func (p fakeContainerStatsProvider) ListPodStatsAndUpdateCPUNanoCoreUsage(context.Context) ([]statsapi.PodStats, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 20K bytes
    - Viewed (0)
  3. pkg/kubelet/stats/cri_stats_provider_test.go

    		resourceAnalyzer,
    		mockPodManager,
    		mockRuntimeCache,
    		fakeRuntimeService,
    		fakeImageService,
    		NewFakeHostStatsProviderWithData(fakeStats, fakeOS),
    		false,
    	)
    
    	stats, err := provider.ListPodStats(ctx)
    	assert := assert.New(t)
    	assert.NoError(err)
    	assert.Equal(4, len(stats))
    
    	podStatsMap := make(map[statsapi.PodReference]statsapi.PodStats)
    	for _, s := range stats {
    		podStatsMap[s.PodRef] = s
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 14:24:16 UTC 2024
    - 54.5K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet.go

    	// Track node startup latencies
    	nodeStartupLatencyTracker util.NodeStartupLatencyTracker
    }
    
    // ListPodStats is delegated to StatsProvider, which implements stats.Provider interface
    func (kl *Kubelet) ListPodStats(ctx context.Context) ([]statsapi.PodStats, error) {
    	return kl.StatsProvider.ListPodStats(ctx)
    }
    
    // ListPodCPUAndMemoryStats is delegated to StatsProvider, which implements stats.Provider interface
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  5. pkg/kubelet/server/server_test.go

    	return map[string]volume.BlockVolume{}, true
    }
    func (*fakeKubelet) RootFsStats() (*statsapi.FsStats, error)                     { return nil, nil }
    func (*fakeKubelet) ListPodStats(_ context.Context) ([]statsapi.PodStats, error) { return nil, nil }
    func (*fakeKubelet) ListPodStatsAndUpdateCPUNanoCoreUsage(_ context.Context) ([]statsapi.PodStats, error) {
    	return nil, nil
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 51.5K bytes
    - Viewed (0)
Back to top