- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for RootFsInfo (0.32 sec)
-
pkg/kubelet/stats/host_stats_provider.go
} // rootFsInfoToFsStats is a utility to convert rootFsInfo into statsapi.FsStats func rootFsInfoToFsStats(rootFsInfo *cadvisorapiv2.FsInfo) *statsapi.FsStats { return &statsapi.FsStats{ Time: metav1.NewTime(rootFsInfo.Timestamp), AvailableBytes: &rootFsInfo.Available, CapacityBytes: &rootFsInfo.Capacity, InodesFree: rootFsInfo.InodesFree, Inodes: rootFsInfo.Inodes, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 17:55:59 UTC 2024 - 6.6K bytes - Viewed (0) -
pkg/kubelet/stats/host_stats_provider_fake.go
return fakeMetricsProvidersToStats([]volume.MetricsProvider{metricsProvider}, rootFsInfo) } func (f *fakeHostStatsProvider) getPodEtcHostsStats(podUID types.UID, rootFsInfo *cadvisorapiv2.FsInfo) (*statsapi.FsStats, error) { return nil, fmt.Errorf("not implemented") } func fakeMetricsProvidersToStats(metricsProviders []volume.MetricsProvider, rootFsInfo *cadvisorapiv2.FsInfo) (*statsapi.FsStats, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 17:57:17 UTC 2024 - 3.9K bytes - Viewed (0) -
pkg/kubelet/cadvisor/testing/cadvisor_mock.go
} // RootFsInfo mocks base method. func (m *MockInterface) RootFsInfo() (v2.FsInfo, error) { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "RootFsInfo") ret0, _ := ret[0].(v2.FsInfo) ret1, _ := ret[1].(error) return ret0, ret1 } // RootFsInfo indicates an expected call of RootFsInfo. func (mr *MockInterfaceMockRecorder) RootFsInfo() *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 - 8.4K bytes - Viewed (0) -
pkg/kubelet/stats/cri_stats_provider_windows.go
if err != nil { return fmt.Errorf("make container stats: %w", err) } ps.Containers = append(ps.Containers, *cs) } return nil } func (p *criStatsProvider) makeWinContainerStats( stats *runtimeapi.WindowsContainerStats, container *runtimeapi.Container, rootFsInfo *cadvisorapiv2.FsInfo,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Feb 18 07:03:11 UTC 2024 - 10.4K bytes - Viewed (0) -
pkg/kubelet/stats/cri_stats_provider_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 54.5K bytes - Viewed (0) -
pkg/kubelet/stats/provider_test.go
rootFsInfo = getTestFsInfo(rootFsInfoSeed) containerInfo = getTestContainerInfo(containerInfoSeed, "test-pod", "test-ns", "test-container") containerInfoMap = map[string]cadvisorapiv2.ContainerInfo{"/": containerInfo} ) mockCadvisor.EXPECT().RootFsInfo().Return(rootFsInfo, nil)
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/cm/container_manager_linux_test.go
mockCadvisor := cadvisortest.NewMockInterface(mockCtrl) rootfs := cadvisorapiv2.FsInfo{ Capacity: 8000, } mockCadvisor.EXPECT().RootFsInfo().Return(rootfs, nil) mockCadvisorError := cadvisortest.NewMockInterface(mockCtrlError) mockCadvisorError.EXPECT().RootFsInfo().Return(cadvisorapiv2.FsInfo{}, errors.New("Unable to get rootfs data from cAdvisor interface")) cases := []struct { name string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 9.7K bytes - Viewed (0) -
pkg/kubelet/cm/container_manager_linux.go
if cm.cadvisorInterface != nil { rootfs, err := cm.cadvisorInterface.RootFsInfo() if err != nil { klog.ErrorS(err, "Unable to get rootfs data from cAdvisor interface") // If the rootfsinfo retrieval from cAdvisor fails for any reason, fallback to returning the capacity property with no ephemeral storage data return cm.capacity }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 35.1K bytes - Viewed (0) -
pkg/kubelet/runonce_test.go
cadvisor.EXPECT().ImagesFsInfo().Return(cadvisorapiv2.FsInfo{ Usage: 400, Capacity: 1000, Available: 600, }, nil).AnyTimes() cadvisor.EXPECT().RootFsInfo().Return(cadvisorapiv2.FsInfo{ Usage: 9, Capacity: 10, }, nil).AnyTimes() fakeSecretManager := secret.NewFakeManager() fakeConfigMapManager := configmap.NewFakeManager()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 06:59:54 UTC 2024 - 6.5K bytes - Viewed (0) -
pkg/kubelet/stats/cadvisor_stats_provider_test.go
mockCtrl := gomock.NewController(t) defer mockCtrl.Finish() mockCadvisor := cadvisortest.NewMockInterface(mockCtrl) mockCadvisor.EXPECT().ContainerInfoV2("/", options).Return(infos, nil) mockCadvisor.EXPECT().RootFsInfo().Return(rootfs, nil) mockCadvisor.EXPECT().ImagesFsInfo().Return(imagefs, nil) mockRuntime := containertest.NewMockRuntime(mockCtrl)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 30.2K bytes - Viewed (0)