Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for GetCgroupStats (0.38 sec)

  1. pkg/kubelet/server/stats/summary_test.go

    	mockStatsProvider.EXPECT().RlimitStats().Return(rlimitStats, nil)
    	mockStatsProvider.EXPECT().GetCgroupStats("/", true).Return(cgroupStatsMap["/"].cs, cgroupStatsMap["/"].ns, nil)
    	mockStatsProvider.EXPECT().GetCgroupStats("/runtime", false).Return(cgroupStatsMap["/runtime"].cs, cgroupStatsMap["/runtime"].ns, nil)
    	mockStatsProvider.EXPECT().GetCgroupStats("/misc", false).Return(cgroupStatsMap["/misc"].cs, cgroupStatsMap["/misc"].ns, 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)
  2. pkg/kubelet/server/stats/testing/mock_stats_provider.go

    	return ret0, ret1, ret2
    }
    
    // GetCgroupStats indicates an expected call of GetCgroupStats.
    func (mr *MockProviderMockRecorder) GetCgroupStats(cgroupName, updateStats any) *gomock.Call {
    	mr.mock.ctrl.T.Helper()
    	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetCgroupStats", reflect.TypeOf((*MockProvider)(nil).GetCgroupStats), cgroupName, updateStats)
    }
    
    // GetNode 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)
  3. pkg/kubelet/stats/provider.go

    func (p *Provider) RlimitStats() (*statsapi.RlimitStats, error) {
    	return pidlimit.Stats()
    }
    
    // GetCgroupStats returns the stats of the cgroup with the cgroupName. Note that
    // this function doesn't generate filesystem stats.
    func (p *Provider) GetCgroupStats(cgroupName string, updateStats bool) (*statsapi.ContainerStats, *statsapi.NetworkStats, 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)
  4. pkg/kubelet/server/stats/handler.go

    	ImageFsStats(ctx context.Context) (imageFs *statsapi.FsStats, containerFs *statsapi.FsStats, callErr error)
    	// The following stats are provided by cAdvisor.
    	//
    	// GetCgroupStats returns the stats and the networking usage of the cgroup
    	// with the specified cgroupName.
    	GetCgroupStats(cgroupName string, updateStats bool) (*statsapi.ContainerStats, *statsapi.NetworkStats, error)
    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.GetCgroupStats(cont.name, cont.forceStatsUpdate)
    		if err != nil {
    			klog.ErrorS(err, "Failed to get system container stats", "containerName", cont.name)
    			continue
    		}
    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_windows_test.go

    	mockStatsProvider.EXPECT().RootFsStats().Return(rootFsStats, nil).AnyTimes()
    	mockStatsProvider.EXPECT().RlimitStats().Return(nil, nil).AnyTimes()
    	mockStatsProvider.EXPECT().GetCgroupStats("/", true).Return(cgroupStatsMap["/"].cs, cgroupStatsMap["/"].ns, nil).AnyTimes()
    
    	kubeletCreationTime := metav1.Now()
    	systemBootTime := metav1.Now()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  7. 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, networkStats, err := sp.provider.GetCgroupStats("/", updateStats)
    	if err != nil {
    		return nil, fmt.Errorf("failed to get root cgroup stats: %v", err)
    	}
    	rootFsStats, err := sp.provider.RootFsStats()
    	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)
  8. pkg/kubelet/stats/helper.go

    		return nil, fmt.Errorf("unexpected number of containers: %v", len(infoMap))
    	}
    	info := infoMap[containerName]
    	return &info, nil
    }
    
    // getCgroupStats returns the latest stats of the container having the
    // specified containerName from cadvisor.
    func getCgroupStats(cadvisor cadvisor.Interface, containerName string, updateStats bool) (*cadvisorapiv2.ContainerStats, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 17 23:40:02 UTC 2023
    - 14.8K bytes
    - Viewed (0)
  9. pkg/kubelet/stats/provider_test.go

    	mockCadvisor.EXPECT().ContainerInfoV2(cgroupName, options).Return(containerInfoMap, nil)
    
    	provider := newStatsProvider(mockCadvisor, mockPodManager, mockRuntimeCache, fakeContainerStatsProvider{})
    	cs, ns, err := provider.GetCgroupStats(cgroupName, updateStats)
    	assert.NoError(err)
    
    	checkCPUStats(t, "", containerInfoSeed, cs.CPU)
    	checkMemoryStats(t, "", containerInfoSeed, containerInfo, cs.Memory)
    	checkNetworkStats(t, "", containerInfoSeed, ns)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 20K bytes
    - Viewed (0)
  10. pkg/kubelet/kubelet.go

    	return kl.StatsProvider.ImageFsStats(ctx)
    }
    
    // GetCgroupStats is delegated to StatsProvider, which implements stats.Provider interface
    func (kl *Kubelet) GetCgroupStats(cgroupName string, updateStats bool) (*statsapi.ContainerStats, *statsapi.NetworkStats, error) {
    	return kl.StatsProvider.GetCgroupStats(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)
Back to top