Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for GetPodCgroupRoot (0.19 sec)

  1. pkg/kubelet/server/stats/testing/mock_stats_provider.go

    }
    
    // GetPodCgroupRoot mocks base method.
    func (m *MockProvider) GetPodCgroupRoot() string {
    	m.ctrl.T.Helper()
    	ret := m.ctrl.Call(m, "GetPodCgroupRoot")
    	ret0, _ := ret[0].(string)
    	return ret0
    }
    
    // GetPodCgroupRoot indicates an expected call of GetPodCgroupRoot.
    func (mr *MockProviderMockRecorder) GetPodCgroupRoot() *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)
  2. pkg/kubelet/server/stats/summary_test.go

    	mockStatsProvider := statstest.NewMockProvider(mockCtrl)
    
    	mockStatsProvider.EXPECT().GetNode().Return(node, nil)
    	mockStatsProvider.EXPECT().GetNodeConfig().Return(nodeConfig)
    	mockStatsProvider.EXPECT().GetPodCgroupRoot().Return(cgroupRoot)
    	mockStatsProvider.EXPECT().ListPodStats(ctx).Return(podStats, nil).AnyTimes()
    	mockStatsProvider.EXPECT().ListPodStatsAndUpdateCPUNanoCoreUsage(ctx).Return(podStats, 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)
  3. pkg/kubelet/cm/container_manager.go

    	UpdatePluginResources(*schedulerframework.NodeInfo, *lifecycle.PodAdmitAttributes) error
    
    	InternalContainerLifecycle() InternalContainerLifecycle
    
    	// GetPodCgroupRoot returns the cgroup which contains all pods.
    	GetPodCgroupRoot() string
    
    	// GetPluginRegistrationHandler returns a plugin registration handler
    	// The pluginwatcher's Handlers allow to have a single module for handling
    	// registration.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:22:13 UTC 2024
    - 9K bytes
    - Viewed (0)
  4. pkg/kubelet/server/stats/summary_windows_test.go

    	mockStatsProvider := statstest.NewMockProvider(mockCtrl)
    	mockStatsProvider.EXPECT().GetNode().Return(node, nil).AnyTimes()
    	mockStatsProvider.EXPECT().GetNodeConfig().Return(nodeConfig).AnyTimes()
    	mockStatsProvider.EXPECT().GetPodCgroupRoot().Return(cgroupRoot).AnyTimes()
    	mockStatsProvider.EXPECT().ListPodStats(ctx).Return(podStats, nil).AnyTimes()
    	mockStatsProvider.EXPECT().ListPodStatsAndUpdateCPUNanoCoreUsage(ctx).Return(podStats, 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)
  5. pkg/kubelet/kubelet_getters.go

    func (kl *Kubelet) GetNodeConfig() cm.NodeConfig {
    	return kl.containerManager.GetNodeConfig()
    }
    
    // GetPodCgroupRoot returns the listeral cgroupfs value for the cgroup containing all pods
    func (kl *Kubelet) GetPodCgroupRoot() string {
    	return kl.containerManager.GetPodCgroupRoot()
    }
    
    // GetHostIPs returns host IPs or nil in case of error.
    func (kl *Kubelet) GetHostIPs() ([]net.IP, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 09 00:48:07 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  6. pkg/kubelet/cm/container_manager_linux.go

    }
    
    func (cm *containerManagerImpl) GetNodeConfig() NodeConfig {
    	cm.RLock()
    	defer cm.RUnlock()
    	return cm.NodeConfig
    }
    
    // GetPodCgroupRoot returns the literal cgroupfs value for the cgroup containing all pods.
    func (cm *containerManagerImpl) GetPodCgroupRoot() string {
    	return cm.cgroupManager.Name(cm.cgroupRoot)
    }
    
    func (cm *containerManagerImpl) GetMountedSubsystems() *CgroupSubsystems {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 10:18:16 UTC 2024
    - 35.1K bytes
    - Viewed (0)
  7. pkg/kubelet/server/server_test.go

    // Unused functions
    func (*fakeKubelet) GetNode() (*v1.Node, error)                       { return nil, nil }
    func (*fakeKubelet) GetNodeConfig() cm.NodeConfig                     { return cm.NodeConfig{} }
    func (*fakeKubelet) GetPodCgroupRoot() string                         { return "" }
    func (*fakeKubelet) GetPodByCgroupfs(cgroupfs string) (*v1.Pod, bool) { return nil, false }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 51.5K bytes
    - Viewed (0)
  8. pkg/kubelet/kubelet.go

    		MaxPodGracePeriodSeconds: int64(kubeCfg.EvictionMaxPodGracePeriod),
    		Thresholds:               thresholds,
    		KernelMemcgNotification:  kernelMemcgNotification,
    		PodCgroupRoot:            kubeDeps.ContainerManager.GetPodCgroupRoot(),
    	}
    
    	var serviceLister corelisters.ServiceLister
    	var serviceHasSynced cache.InformerSynced
    	if kubeDeps.KubeClient != nil {
    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