Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for ListPodCPUAndMemoryStats (0.31 sec)

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

    }
    
    // ListPodCPUAndMemoryStats mocks base method.
    func (m *MockProvider) ListPodCPUAndMemoryStats(ctx context.Context) ([]v1alpha1.PodStats, error) {
    	m.ctrl.T.Helper()
    	ret := m.ctrl.Call(m, "ListPodCPUAndMemoryStats", ctx)
    	ret0, _ := ret[0].([]v1alpha1.PodStats)
    	ret1, _ := ret[1].(error)
    	return ret0, ret1
    }
    
    // ListPodCPUAndMemoryStats indicates an expected call of ListPodCPUAndMemoryStats.
    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/provider.go

    type containerStatsProvider interface {
    	ListPodStats(ctx context.Context) ([]statsapi.PodStats, error)
    	ListPodStatsAndUpdateCPUNanoCoreUsage(ctx context.Context) ([]statsapi.PodStats, error)
    	ListPodCPUAndMemoryStats(ctx context.Context) ([]statsapi.PodStats, error)
    	ImageFsStats(ctx context.Context) (*statsapi.FsStats, *statsapi.FsStats, error)
    	ImageFsDevice(ctx context.Context) (string, 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)
  3. pkg/kubelet/server/stats/summary.go

    	rootStats, err := sp.provider.GetCgroupCPUAndMemoryStats("/", false)
    	if err != nil {
    		return nil, fmt.Errorf("failed to get root cgroup stats: %v", err)
    	}
    
    	podStats, err := sp.provider.ListPodCPUAndMemoryStats(ctx)
    	if err != nil {
    		return nil, fmt.Errorf("failed to list pod stats: %v", err)
    	}
    
    	nodeStats := statsapi.NodeStats{
    		NodeName:         node.Name,
    		CPU:              rootStats.CPU,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 18:46:33 UTC 2023
    - 5.1K bytes
    - Viewed (0)
  4. pkg/kubelet/server/stats/handler.go

    	ListPodStats(ctx context.Context) ([]statsapi.PodStats, error)
    	// ListPodStatsAndUpdateCPUNanoCoreUsage updates the cpu nano core usage for
    	// the containers and returns the stats for all the pod-managed containers.
    	ListPodCPUAndMemoryStats(ctx context.Context) ([]statsapi.PodStats, error)
    	// ListPodStatsAndUpdateCPUNanoCoreUsage returns the stats of all the
    	// containers managed by pods and force update the cpu usageNanoCores.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Dec 14 21:31:38 UTC 2023
    - 6.8K bytes
    - Viewed (0)
  5. pkg/kubelet/stats/cadvisor_stats_provider.go

    func (p *cadvisorStatsProvider) ListPodStatsAndUpdateCPUNanoCoreUsage(ctx context.Context) ([]statsapi.PodStats, error) {
    	return p.ListPodStats(ctx)
    }
    
    // ListPodCPUAndMemoryStats returns the cpu and memory stats of all the pod-managed containers.
    func (p *cadvisorStatsProvider) ListPodCPUAndMemoryStats(_ context.Context) ([]statsapi.PodStats, error) {
    	infos, err := getCadvisorContainerInfo(p.cadvisor)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Nov 16 13:34:22 UTC 2023
    - 18.9K bytes
    - Viewed (0)
  6. 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().ListPodCPUAndMemoryStats(ctx).Return(podStats, nil)
    	mockStatsProvider.EXPECT().GetCgroupCPUAndMemoryStats("/", false).Return(cgroupStatsMap["/"].cs, 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)
  7. pkg/kubelet/stats/cri_stats_provider.go

    		summarySandboxStats = append(summarySandboxStats, *ps)
    	}
    	return summarySandboxStats, nil
    }
    
    // ListPodCPUAndMemoryStats returns the CPU and Memory stats of all the pod-managed containers.
    func (p *criStatsProvider) ListPodCPUAndMemoryStats(ctx context.Context) ([]statsapi.PodStats, error) {
    	// sandboxIDToPodStats is a temporary map from sandbox ID to its pod stats.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 18:46:33 UTC 2023
    - 35.1K bytes
    - Viewed (0)
  8. pkg/kubelet/stats/provider_test.go

    }
    
    func (p fakeContainerStatsProvider) ListPodStatsAndUpdateCPUNanoCoreUsage(context.Context) ([]statsapi.PodStats, error) {
    	return nil, fmt.Errorf("not implemented")
    }
    
    func (p fakeContainerStatsProvider) ListPodCPUAndMemoryStats(context.Context) ([]statsapi.PodStats, error) {
    	return nil, fmt.Errorf("not implemented")
    }
    
    func (p fakeContainerStatsProvider) ImageFsStats(context.Context) (*statsapi.FsStats, *statsapi.FsStats, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 20K bytes
    - Viewed (0)
  9. pkg/kubelet/stats/cadvisor_stats_provider_test.go

    	}
    
    	resourceAnalyzer := &fakeResourceAnalyzer{podVolumeStats: volumeStats}
    
    	p := NewCadvisorStatsProvider(mockCadvisor, resourceAnalyzer, nil, nil, nil, nil, NewFakeHostStatsProvider())
    	pods, err := p.ListPodCPUAndMemoryStats(ctx)
    	assert.NoError(t, err)
    
    	assert.Equal(t, 3, 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)
  10. pkg/kubelet/kubelet.go

    	return kl.StatsProvider.ListPodStats(ctx)
    }
    
    // ListPodCPUAndMemoryStats is delegated to StatsProvider, which implements stats.Provider interface
    func (kl *Kubelet) ListPodCPUAndMemoryStats(ctx context.Context) ([]statsapi.PodStats, error) {
    	return kl.StatsProvider.ListPodCPUAndMemoryStats(ctx)
    }
    
    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