- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for GetPodCgroupRoot (0.19 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)