- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for GetCgroupCPUAndMemoryStats (0.39 sec)
-
pkg/kubelet/server/stats/testing/mock_stats_provider.go
} // GetCgroupCPUAndMemoryStats indicates an expected call of GetCgroupCPUAndMemoryStats. func (mr *MockProviderMockRecorder) GetCgroupCPUAndMemoryStats(cgroupName, updateStats any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetCgroupCPUAndMemoryStats", reflect.TypeOf((*MockProvider)(nil).GetCgroupCPUAndMemoryStats), cgroupName, updateStats) } // GetCgroupStats mocks base method.
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/server/stats/summary_test.go
mockStatsProvider.EXPECT().GetCgroupCPUAndMemoryStats("/", false).Return(cgroupStatsMap["/"].cs, nil) mockStatsProvider.EXPECT().GetCgroupCPUAndMemoryStats("/runtime", false).Return(cgroupStatsMap["/runtime"].cs, nil) mockStatsProvider.EXPECT().GetCgroupCPUAndMemoryStats("/misc", false).Return(cgroupStatsMap["/misc"].cs, nil) mockStatsProvider.EXPECT().GetCgroupCPUAndMemoryStats("/kubelet", false).Return(cgroupStatsMap["/kubelet"].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/provider.go
n := cadvisorInfoToNetworkStats(info) return s, n, nil } // GetCgroupCPUAndMemoryStats returns the CPU and memory stats of the cgroup with the cgroupName. Note that // this function doesn't generate filesystem stats. func (p *Provider) GetCgroupCPUAndMemoryStats(cgroupName string, updateStats bool) (*statsapi.ContainerStats, error) { info, err := getCgroupInfo(p.cadvisor, cgroupName, updateStats)
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/handler.go
// with the specified cgroupName. GetCgroupStats(cgroupName string, updateStats bool) (*statsapi.ContainerStats, *statsapi.NetworkStats, error) // GetCgroupCPUAndMemoryStats returns the CPU and memory stats of the cgroup with the specified cgroupName. GetCgroupCPUAndMemoryStats(cgroupName string, updateStats bool) (*statsapi.ContainerStats, error) // RootFsStats returns the stats of the node root filesystem.
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/server/stats/summary_sys_containers.go
} for sys, cont := range systemContainers { // skip if cgroup name is undefined (not all system containers are required) if cont.name == "" { continue } s, err := sp.provider.GetCgroupCPUAndMemoryStats(cont.name, cont.forceStatsUpdate) if err != nil { klog.ErrorS(err, "Failed to get system container stats", "containerName", cont.name) continue } s.Name = sys
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 24 19:47:49 UTC 2021 - 3.5K bytes - Viewed (0) -
pkg/kubelet/server/stats/summary.go
node, err := sp.provider.GetNode() if err != nil { return nil, fmt.Errorf("failed to get node info: %v", err) } nodeConfig := sp.provider.GetNodeConfig() 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 {
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/stats/provider_test.go
mockCadvisor.EXPECT().ContainerInfoV2(cgroupName, options).Return(containerInfoMap, nil) provider := newStatsProvider(mockCadvisor, mockPodManager, mockRuntimeCache, fakeContainerStatsProvider{}) cs, err := provider.GetCgroupCPUAndMemoryStats(cgroupName, updateStats) assert.NoError(err) checkCPUStats(t, "", containerInfoSeed, cs.CPU) checkMemoryStats(t, "", containerInfoSeed, containerInfo, cs.Memory) assert.Equal(cgroupName, cs.Name)
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/kubelet.go
return kl.StatsProvider.GetCgroupStats(cgroupName, updateStats) } // GetCgroupCPUAndMemoryStats is delegated to StatsProvider, which implements stats.Provider interface func (kl *Kubelet) GetCgroupCPUAndMemoryStats(cgroupName string, updateStats bool) (*statsapi.ContainerStats, error) { return kl.StatsProvider.GetCgroupCPUAndMemoryStats(cgroupName, updateStats) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
pkg/kubelet/server/server_test.go
func (*fakeKubelet) GetCgroupStats(cgroupName string, updateStats bool) (*statsapi.ContainerStats, *statsapi.NetworkStats, error) { return nil, nil, nil } func (*fakeKubelet) GetCgroupCPUAndMemoryStats(cgroupName string, updateStats bool) (*statsapi.ContainerStats, error) { return nil, nil } type fakeAuth struct { authenticateFunc func(*http.Request) (*authenticator.Response, bool, error)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 51.5K bytes - Viewed (0)