Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 22 for nodeConfig (0.15 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top