Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for RootFsInfo (0.32 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. pkg/kubelet/stats/cri_stats_provider_test.go

    	assert.Equal(rootFsInfo.Timestamp, actual.Logs.Time.Time)
    	assert.Equal(rootFsInfo.Available, *actual.Logs.AvailableBytes)
    	assert.Equal(rootFsInfo.Capacity, *actual.Logs.CapacityBytes)
    	assert.Equal(*rootFsInfo.InodesFree, *actual.Logs.InodesFree)
    	assert.Equal(*rootFsInfo.Inodes, *actual.Logs.Inodes)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 14:24:16 UTC 2024
    - 54.5K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top