Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for listPodStats (0.19 sec)

  1. pkg/kubelet/server/stats/testing/mock_stats_provider.go

    }
    
    // ListPodStats mocks base method.
    func (m *MockProvider) ListPodStats(ctx context.Context) ([]v1alpha1.PodStats, error) {
    	m.ctrl.T.Helper()
    	ret := m.ctrl.Call(m, "ListPodStats", ctx)
    	ret0, _ := ret[0].([]v1alpha1.PodStats)
    	ret1, _ := ret[1].(error)
    	return ret0, ret1
    }
    
    // ListPodStats indicates an expected call of ListPodStats.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  2. pkg/kubelet/stats/cadvisor_stats_provider.go

    		resourceAnalyzer:  resourceAnalyzer,
    		imageService:      imageService,
    		statusProvider:    statusProvider,
    		hostStatsProvider: hostStatsProvider,
    	}
    }
    
    // ListPodStats returns the stats of all the pod-managed containers.
    func (p *cadvisorStatsProvider) ListPodStats(_ context.Context) ([]statsapi.PodStats, error) {
    	// Gets node root filesystem information and image filesystem stats, which
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Nov 16 13:34:22 UTC 2023
    - 18.9K bytes
    - Viewed (0)
  3. pkg/kubelet/server/stats/summary_test.go

    	mockStatsProvider.EXPECT().GetNode().Return(node, nil)
    	mockStatsProvider.EXPECT().GetNodeConfig().Return(nodeConfig)
    	mockStatsProvider.EXPECT().GetPodCgroupRoot().Return(cgroupRoot)
    	mockStatsProvider.EXPECT().ListPodStats(ctx).Return(podStats, nil).AnyTimes()
    	mockStatsProvider.EXPECT().ListPodStatsAndUpdateCPUNanoCoreUsage(ctx).Return(podStats, nil)
    	mockStatsProvider.EXPECT().ImageFsStats(ctx).Return(imageFsStats, imageFsStats, nil)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 15.1K bytes
    - Viewed (0)
  4. pkg/kubelet/stats/cri_stats_provider.go

    		clock:                       clock.RealClock{},
    	}
    }
    
    // ListPodStats returns the stats of all the pod-managed containers.
    func (p *criStatsProvider) ListPodStats(ctx context.Context) ([]statsapi.PodStats, error) {
    	// Don't update CPU nano core usage.
    	return p.listPodStats(ctx, false)
    }
    
    // ListPodStatsAndUpdateCPUNanoCoreUsage updates the cpu nano core usage for
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 18:46:33 UTC 2023
    - 35.1K bytes
    - Viewed (0)
  5. 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)
  6. 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)
Back to top