- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for GetNodeConfig (0.19 sec)
-
pkg/kubelet/server/stats/testing/mock_stats_provider.go
} // GetNodeConfig mocks base method. func (m *MockProvider) GetNodeConfig() cm.NodeConfig { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "GetNodeConfig") ret0, _ := ret[0].(cm.NodeConfig) return ret0 } // GetNodeConfig indicates an expected call of GetNodeConfig. func (mr *MockProviderMockRecorder) GetNodeConfig() *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/handler.go
// namespace. GetPodByName(namespace, name string) (*v1.Pod, bool) // GetNode returns the spec of the local node. GetNode() (*v1.Node, error) // GetNodeConfig returns the configuration of the local node. GetNodeConfig() cm.NodeConfig // ListVolumesForPod returns the stats of the volume used by the pod with // the podUID. ListVolumesForPod(podUID types.UID) (map[string]volume.Volume, bool)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 14 21:31:38 UTC 2023 - 6.8K bytes - Viewed (0) -
pkg/kubelet/server/stats/summary.go
// the following errors occur. node, err := sp.provider.GetNode() if err != nil { return nil, fmt.Errorf("failed to get node info: %v", err) } nodeConfig := sp.provider.GetNodeConfig() 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()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 18:46:33 UTC 2023 - 5.1K bytes - Viewed (0) -
pkg/kubelet/cm/fake_container_manager.go
defer cm.Unlock() cm.CalledFunctions = append(cm.CalledFunctions, "SystemCgroupsLimit") return v1.ResourceList{} } func (cm *FakeContainerManager) GetNodeConfig() NodeConfig { cm.Lock() defer cm.Unlock() cm.CalledFunctions = append(cm.CalledFunctions, "GetNodeConfig") return NodeConfig{} } func (cm *FakeContainerManager) GetMountedSubsystems() *CgroupSubsystems { cm.Lock() defer cm.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 17:33:04 UTC 2023 - 7.4K bytes - Viewed (0) -
pkg/kubelet/server/stats/summary_test.go
} mockCtrl := gomock.NewController(t) defer mockCtrl.Finish() 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()
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
// These cgroups include the system and Kubernetes services. SystemCgroupsLimit() v1.ResourceList // GetNodeConfig returns a NodeConfig that is being used by the container manager. GetNodeConfig() NodeConfig // Status returns internal Status. Status() Status // NewPodContainerManager is a factory method which returns a podContainerManager object
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
mockCtrl := gomock.NewController(t) defer mockCtrl.Finish() 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()
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/cm/container_manager_stub.go
klog.V(2).InfoS("Starting stub container manager") return nil } func (cm *containerManagerStub) SystemCgroupsLimit() v1.ResourceList { return v1.ResourceList{} } func (cm *containerManagerStub) GetNodeConfig() NodeConfig { return NodeConfig{} } func (cm *containerManagerStub) GetMountedSubsystems() *CgroupSubsystems { return &CgroupSubsystems{} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 15 02:26:59 UTC 2023 - 5.9K bytes - Viewed (0) -
pkg/kubelet/kubelet_getters.go
return n, nil } } return kl.initialNode(context.TODO()) } // GetNodeConfig returns the container manager node config. 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 {
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_windows.go
return cm, nil } func (cm *containerManagerImpl) SystemCgroupsLimit() v1.ResourceList { return v1.ResourceList{} } func (cm *containerManagerImpl) GetNodeConfig() NodeConfig { return NodeConfig{} } func (cm *containerManagerImpl) GetMountedSubsystems() *CgroupSubsystems { return &CgroupSubsystems{} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 11:25:36 UTC 2023 - 8.7K bytes - Viewed (0)