Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. pkg/kubelet/metrics/collectors/volume_stats_test.go

    		}
    	)
    
    	mockCtrl := gomock.NewController(t)
    	defer mockCtrl.Finish()
    	mockStatsProvider := statstest.NewMockProvider(mockCtrl)
    
    	mockStatsProvider.EXPECT().ListPodStats(ctx).Return(podStats, nil).AnyTimes()
    	mockStatsProvider.EXPECT().ListPodStatsAndUpdateCPUNanoCoreUsage(ctx).Return(podStats, nil).AnyTimes()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  2. pkg/kubelet/server/stats/handler.go

    )
    
    // Provider hosts methods required by stats handlers.
    type Provider interface {
    	// The following stats are provided by either CRI or cAdvisor.
    	//
    	// ListPodStats returns the stats of all the containers managed by pods.
    	ListPodStats(ctx context.Context) ([]statsapi.PodStats, error)
    	// ListPodStatsAndUpdateCPUNanoCoreUsage updates the cpu nano core usage for
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Dec 14 21:31:38 UTC 2023
    - 6.8K bytes
    - Viewed (0)
  3. pkg/kubelet/server/stats/summary_windows_test.go

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

    func (collector *volumeStatsCollector) CollectWithStability(ch chan<- metrics.Metric) {
    	ctx := context.Background()
    	podStats, err := collector.statsProvider.ListPodStats(ctx)
    	if err != nil {
    		return
    	}
    	addGauge := func(desc *metrics.Desc, pvcRef *stats.PVCReference, v float64, lv ...string) {
    		lv = append([]string{pvcRef.Namespace, pvcRef.Name}, lv...)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  5. pkg/kubelet/server/stats/summary.go

    	}
    	var podStats []statsapi.PodStats
    	if updateStats {
    		podStats, err = sp.provider.ListPodStatsAndUpdateCPUNanoCoreUsage(ctx)
    	} else {
    		podStats, err = sp.provider.ListPodStats(ctx)
    	}
    	if err != nil {
    		return nil, fmt.Errorf("failed to list pod stats: %v", err)
    	}
    
    	rlimit, err := sp.provider.RlimitStats()
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 18:46:33 UTC 2023
    - 5.1K bytes
    - Viewed (0)
  6. pkg/kubelet/stats/provider.go

    	runtimeCache kubecontainer.RuntimeCache
    	containerStatsProvider
    }
    
    // containerStatsProvider is an interface that provides the stats of the
    // containers managed by pods.
    type containerStatsProvider interface {
    	ListPodStats(ctx context.Context) ([]statsapi.PodStats, error)
    	ListPodStatsAndUpdateCPUNanoCoreUsage(ctx context.Context) ([]statsapi.PodStats, error)
    	ListPodCPUAndMemoryStats(ctx context.Context) ([]statsapi.PodStats, error)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 13:56:22 UTC 2023
    - 7.4K bytes
    - Viewed (0)
Back to top