Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for GetCgroupCPUAndMemoryStats (0.39 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
Back to top