Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for RootFsStats (0.15 sec)

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

    	mockStatsProvider.EXPECT().ListPodStatsAndUpdateCPUNanoCoreUsage(ctx).Return(podStats, nil)
    	mockStatsProvider.EXPECT().ImageFsStats(ctx).Return(imageFsStats, imageFsStats, nil)
    	mockStatsProvider.EXPECT().RootFsStats().Return(rootFsStats, nil)
    	mockStatsProvider.EXPECT().RlimitStats().Return(rlimitStats, nil)
    	mockStatsProvider.EXPECT().GetCgroupStats("/", true).Return(cgroupStatsMap["/"].cs, cgroupStatsMap["/"].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/summary_windows_test.go

    	mockStatsProvider.EXPECT().ImageFsStats(ctx).Return(imageFsStats, imageFsStats, nil).AnyTimes()
    	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()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  3. pkg/kubelet/server/stats/testing/mock_stats_provider.go

    }
    
    // RootFsStats mocks base method.
    func (m *MockProvider) RootFsStats() (*v1alpha1.FsStats, error) {
    	m.ctrl.T.Helper()
    	ret := m.ctrl.Call(m, "RootFsStats")
    	ret0, _ := ret[0].(*v1alpha1.FsStats)
    	ret1, _ := ret[1].(error)
    	return ret0, ret1
    }
    
    // RootFsStats indicates an expected call of RootFsStats.
    func (mr *MockProviderMockRecorder) RootFsStats() *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
    - 11.8K bytes
    - Viewed (0)
  4. pkg/kubelet/server/stats/summary.go

    	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 {
    		return nil, fmt.Errorf("failed to get rootFs stats: %v", err)
    	}
    	imageFsStats, containerFsStats, err := sp.provider.ImageFsStats(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)
  5. pkg/kubelet/stats/provider.go

    	}
    	// Rootfs and imagefs doesn't make sense for raw cgroup.
    	s := cadvisorInfoToContainerCPUAndMemoryStats(cgroupName, info)
    	return s, nil
    }
    
    // RootFsStats returns the stats of the node root filesystem.
    func (p *Provider) RootFsStats() (*statsapi.FsStats, error) {
    	rootFsInfo, err := p.cadvisor.RootFsInfo()
    	if err != nil {
    		return nil, fmt.Errorf("failed to get rootFs info: %v", 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/handler.go

    	GetCgroupCPUAndMemoryStats(cgroupName string, updateStats bool) (*statsapi.ContainerStats, error)
    
    	// RootFsStats returns the stats of the node root filesystem.
    	RootFsStats() (*statsapi.FsStats, error)
    
    	// GetRequestedContainersInfo returns the information of the container with
    	// the containerName, and with the specified cAdvisor options.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Dec 14 21:31:38 UTC 2023
    - 6.8K bytes
    - Viewed (0)
  7. pkg/kubelet/stats/provider_test.go

    	mockCadvisor.EXPECT().ContainerInfoV2("/", options).Return(containerInfoMap, nil)
    
    	provider := newStatsProvider(mockCadvisor, mockPodManager, mockRuntimeCache, fakeContainerStatsProvider{})
    	stats, err := provider.RootFsStats()
    	assert.NoError(err)
    
    	checkFsStats(t, "", rootFsInfoSeed, stats)
    
    	assert.Equal(metav1.NewTime(containerInfo.Stats[0].Timestamp), stats.Time)
    	assert.Equal(rootFsInfo.Usage, *stats.UsedBytes)
    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.GetCgroupCPUAndMemoryStats(cgroupName, updateStats)
    }
    
    // RootFsStats is delegated to StatsProvider, which implements stats.Provider interface
    func (kl *Kubelet) RootFsStats() (*statsapi.FsStats, error) {
    	return kl.StatsProvider.RootFsStats()
    }
    
    // RlimitStats is delegated to StatsProvider, which implements stats.Provider interface
    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

    	return map[string]volume.Volume{}, true
    }
    func (*fakeKubelet) ListBlockVolumesForPod(podUID types.UID) (map[string]volume.BlockVolume, bool) {
    	return map[string]volume.BlockVolume{}, true
    }
    func (*fakeKubelet) RootFsStats() (*statsapi.FsStats, error)                     { return nil, nil }
    func (*fakeKubelet) ListPodStats(_ context.Context) ([]statsapi.PodStats, error) { return nil, nil }
    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