- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for ListPodCPUAndMemoryStats (0.31 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)