- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 22 for nodeConfig (0.15 sec)
-
pkg/kubelet/server/stats/summary_sys_containers.go
) func (sp *summaryProviderImpl) GetSystemContainersStats(nodeConfig cm.NodeConfig, podStats []statsapi.PodStats, updateStats bool) (stats []statsapi.ContainerStats) { systemContainers := map[string]struct { name string forceStatsUpdate bool startTime metav1.Time }{ statsapi.SystemContainerKubelet: {name: nodeConfig.KubeletCgroupsName, forceStatsUpdate: false, startTime: sp.kubeletCreationTime},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 24 19:47:49 UTC 2021 - 3.5K bytes - Viewed (0) -
pkg/kubelet/server/stats/summary_sys_containers_windows.go
) func (sp *summaryProviderImpl) GetSystemContainersStats(nodeConfig cm.NodeConfig, podStats []statsapi.PodStats, updateStats bool) (stats []statsapi.ContainerStats) { stats = append(stats, sp.getSystemPodsCPUAndMemoryStats(nodeConfig, podStats, updateStats)) return stats }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 24 19:47:49 UTC 2021 - 3K bytes - Viewed (0) -
pkg/kubelet/cm/container_manager_windows.go
evictionReservation := hardEvictionReservation(cm.nodeConfig.HardEvictionThresholds, cm.capacity) result := make(v1.ResourceList) for k := range cm.capacity { value := resource.NewQuantity(0, resource.DecimalSI) if cm.nodeConfig.SystemReserved != nil { value.Add(cm.nodeConfig.SystemReserved[k]) } if cm.nodeConfig.KubeReserved != nil { value.Add(cm.nodeConfig.KubeReserved[k]) } if evictionReservation != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 11:25:36 UTC 2023 - 8.7K bytes - Viewed (0) -
pkg/kubelet/cm/node_container_manager_linux_test.go
systemReserved: getResourceList("", "50Mi"), capacity: getResourceList("10", ""), expected: getResourceList("", "150Mi"), }, } for idx, tc := range cpuMemCases { nc := NodeConfig{ NodeAllocatableConfig: NodeAllocatableConfig{ KubeReserved: tc.kubeReserved, SystemReserved: tc.systemReserved, HardEvictionThresholds: []evictionapi.Threshold{ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 24 19:47:49 UTC 2021 - 12.1K bytes - Viewed (0) -
pkg/kubelet/cm/node_container_manager_linux.go
result := make(v1.ResourceList) for k, v := range capacity { value := v.DeepCopy() if cm.NodeConfig.SystemReserved != nil { value.Sub(cm.NodeConfig.SystemReserved[k]) } if cm.NodeConfig.KubeReserved != nil { value.Sub(cm.NodeConfig.KubeReserved[k]) } if value.Sign() < 0 { // Negative Allocatable resources don't make sense. value.Set(0) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 10.5K bytes - Viewed (0) -
pkg/kubelet/cm/container_manager_linux.go
cm.draManager, err = dra.NewManagerImpl(kubeClient, nodeConfig.KubeletRootDir, nodeConfig.NodeName) if err != nil { return nil, err } } // Initialize CPU manager cm.cpuManager, err = cpumanager.NewManager( nodeConfig.CPUManagerPolicy, nodeConfig.CPUManagerPolicyOptions, nodeConfig.CPUManagerReconcilePeriod, machineInfo, nodeConfig.NodeAllocatableConfig.ReservedSystemCPUs,
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/proxy/config/config.go
var _ NodeHandler = &NoopNodeHandler{} // NodeConfig tracks a set of node configurations. // It accepts "set", "add" and "remove" operations of node via channels, and invokes registered handlers on change. type NodeConfig struct { listerSynced cache.InformerSynced eventHandlers []NodeHandler logger klog.Logger } // NewNodeConfig creates a new NodeConfig.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 15.1K bytes - Viewed (0) -
pkg/kubelet/cm/container_manager_linux_test.go
info := QOSContainersInfo{ Guaranteed: CgroupName{"guaranteed"}, BestEffort: CgroupName{"besteffort"}, Burstable: CgroupName{"burstable"}, } QosEnabled := NodeConfig{ CgroupsPerQOS: true, } QosDisabled := NodeConfig{ CgroupsPerQOS: false, } cases := []struct { name string cm *containerManagerImpl }{ {
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/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) }
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/server/stats/summary_windows_test.go
podStats = []statsapi.PodStats{*getPodStats()} imageFsStats = getFsStats() rootFsStats = getFsStats() node = &v1.Node{ObjectMeta: metav1.ObjectMeta{Name: "test-node"}} nodeConfig = cm.NodeConfig{} cgroupRoot = "/kubepods" cgroupStatsMap = map[string]struct { cs *statsapi.ContainerStats ns *statsapi.NetworkStats }{ "/": {cs: getContainerStats()},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 4.4K bytes - Viewed (0)