Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 123 for updateStats (0.54 sec)

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

    	stats = append(stats, sp.getSystemPodsCPUAndMemoryStats(nodeConfig, podStats, updateStats))
    	return stats
    }
    
    func (sp *summaryProviderImpl) GetSystemContainersCPUAndMemoryStats(nodeConfig cm.NodeConfig, podStats []statsapi.PodStats, updateStats bool) (stats []statsapi.ContainerStats) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 24 19:47:49 UTC 2021
    - 3K bytes
    - Viewed (0)
  2. pkg/kubelet/server/stats/testing/mock_summary_provider.go

    func (m *MockSummaryProvider) Get(ctx context.Context, updateStats bool) (*v1alpha1.Summary, error) {
    	m.ctrl.T.Helper()
    	ret := m.ctrl.Call(m, "Get", ctx, updateStats)
    	ret0, _ := ret[0].(*v1alpha1.Summary)
    	ret1, _ := ret[1].(error)
    	return ret0, ret1
    }
    
    // Get indicates an expected call of Get.
    func (mr *MockSummaryProviderMockRecorder) Get(ctx, updateStats any) *gomock.Call {
    	mr.mock.ctrl.T.Helper()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  3. pkg/kubelet/server/stats/summary_sys_containers.go

    	statsapi "k8s.io/kubelet/pkg/apis/stats/v1alpha1"
    	"k8s.io/kubernetes/pkg/kubelet/cm"
    )
    
    func (sp *summaryProviderImpl) GetSystemContainersStats(nodeConfig cm.NodeConfig, podStats []statsapi.PodStats, updateStats bool) (stats []statsapi.ContainerStats) {
    	systemContainers := map[string]struct {
    		name             string
    		forceStatsUpdate bool
    		startTime        metav1.Time
    	}{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 24 19:47:49 UTC 2021
    - 3.5K bytes
    - Viewed (0)
  4. pkg/kubelet/server/stats/summary.go

    )
    
    // SummaryProvider provides summaries of the stats from Kubelet.
    type SummaryProvider interface {
    	// Get provides a new Summary with the stats from Kubelet,
    	// and will update some stats if updateStats is true
    	Get(ctx context.Context, updateStats bool) (*statsapi.Summary, error)
    	// GetCPUAndMemoryStats provides a new Summary with the CPU and memory stats from Kubelet,
    	GetCPUAndMemoryStats(ctx context.Context) (*statsapi.Summary, error)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 18:46:33 UTC 2023
    - 5.1K bytes
    - Viewed (0)
  5. pkg/kubelet/stats/provider.go

    // this function doesn't generate filesystem stats.
    func (p *Provider) GetCgroupStats(cgroupName string, updateStats bool) (*statsapi.ContainerStats, *statsapi.NetworkStats, error) {
    	info, err := getCgroupInfo(p.cadvisor, cgroupName, updateStats)
    	if err != nil {
    		return nil, nil, fmt.Errorf("failed to get cgroup stats for %q: %v", cgroupName, err)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 13:56:22 UTC 2023
    - 7.4K bytes
    - Viewed (0)
  6. pkg/kubelet/server/stats/testing/mock_stats_provider.go

    	mr.mock.ctrl.T.Helper()
    	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetCgroupCPUAndMemoryStats", reflect.TypeOf((*MockProvider)(nil).GetCgroupCPUAndMemoryStats), cgroupName, updateStats)
    }
    
    // GetCgroupStats mocks base method.
    func (m *MockProvider) GetCgroupStats(cgroupName string, updateStats bool) (*v1alpha1.ContainerStats, *v1alpha1.NetworkStats, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  7. pkg/kubelet/stats/helper.go

    // getCgroupInfo returns the information of the container with the specified
    // containerName from cadvisor.
    func getCgroupInfo(cadvisor cadvisor.Interface, containerName string, updateStats bool) (*cadvisorapiv2.ContainerInfo, error) {
    	var maxAge *time.Duration
    	if updateStats {
    		age := 0 * time.Second
    		maxAge = &age
    	}
    	infoMap, err := cadvisor.ContainerInfoV2(containerName, cadvisorapiv2.RequestOptions{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 17 23:40:02 UTC 2023
    - 14.8K bytes
    - Viewed (0)
  8. 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)
  9. pkg/kubelet/stats/provider_test.go

    var (
    	timestamp    = time.Now()
    	creationTime = timestamp.Add(-5 * time.Minute)
    )
    
    func TestGetCgroupStats(t *testing.T) {
    	const (
    		cgroupName        = "test-cgroup-name"
    		containerInfoSeed = 1000
    		updateStats       = false
    	)
    
    	mockCtrl := gomock.NewController(t)
    	defer mockCtrl.Finish()
    
    	var (
    		mockCadvisor     = cadvisortest.NewMockInterface(mockCtrl)
    		mockPodManager   = new(kubepodtest.MockManager)
    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/eviction/eviction_manager.go

    	}
    
    	klog.V(3).InfoS("FileSystem detection", "DedicatedImageFs", m.dedicatedImageFs, "SplitImageFs", m.splitContainerImageFs)
    	activePods := podFunc()
    	updateStats := true
    	summary, err := m.summaryProvider.Get(ctx, updateStats)
    	if err != nil {
    		klog.ErrorS(err, "Eviction manager: failed to get summary stats")
    		return nil, nil
    	}
    
    	if m.clock.Since(m.thresholdsLastUpdated) > notifierRefreshInterval {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 27 18:55:56 UTC 2024
    - 24.6K bytes
    - Viewed (0)
Back to top