Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for allocatableResources (0.27 sec)

  1. pkg/controller/daemon/daemon_controller_test.go

    		NodeName: nodeName,
    		Containers: []v1.Container{{
    			Resources: v1.ResourceRequirements{
    				Requests: allocatableResources(memory, cpu),
    			},
    		}},
    	}
    }
    
    func resourceContainerSpec(memory, cpu string) v1.ResourceRequirements {
    	return v1.ResourceRequirements{
    		Requests: allocatableResources(memory, cpu),
    	}
    }
    
    func resourcePodSpecWithoutNodeName(memory, cpu string) v1.PodSpec {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 111.4K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/devicemanager/manager.go

    	var newAllocatableResource *schedulerframework.Resource
    	allocatableResource := node.Allocatable
    	if allocatableResource.ScalarResources == nil {
    		allocatableResource.ScalarResources = make(map[v1.ResourceName]int64)
    	}
    
    	m.mutex.Lock()
    	defer m.mutex.Unlock()
    	for resource, devices := range m.allocatedDevices {
    		needed := devices.Len()
    		quant, ok := allocatableResource.ScalarResources[v1.ResourceName(resource)]
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 15 12:01:56 UTC 2024
    - 43K bytes
    - Viewed (0)
  3. pkg/kubelet/cm/qos_container_manager_linux.go

    	qosMemoryRequests := m.getQoSMemoryRequests()
    
    	resources := m.getNodeAllocatable()
    	allocatableResource, ok := resources[v1.ResourceMemory]
    	if !ok {
    		klog.V(2).InfoS("Allocatable memory value could not be determined, not setting QoS memory limits")
    		return
    	}
    	allocatable := allocatableResource.Value()
    	if allocatable == 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 20:42:59 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/plugins/noderesources/resource_allocation.go

    		loggerV.Info("Listed internal info for allocatable resources, requested resources and score", "pod",
    			klog.KObj(pod), "node", klog.KObj(node), "resourceAllocationScorer", r.Name,
    			"allocatableResource", allocatable, "requestedResource", requested, "resourceScore", score,
    		)
    	}
    
    	return score, nil
    }
    
    // calculateResourceAllocatableRequest returns 2 parameters:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 20 14:53:43 UTC 2023
    - 5.3K bytes
    - Viewed (0)
  5. pkg/kubelet/cm/container_manager.go

    	// UpdatePluginResources calls Allocate of device plugin handler for potential
    	// requests for device plugin resources, and returns an error if fails.
    	// Otherwise, it updates allocatableResource in nodeInfo if necessary,
    	// to make sure it is at least equal to the pod's requested capacity for
    	// any registered device plugin resource
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:22:13 UTC 2024
    - 9K bytes
    - Viewed (0)
  6. pkg/kubelet/kubelet_test.go

    		// Maps from resourceName to the value we use to set node.allocatableResource[resourceName].
    		// A resource with invalid value (< 0) causes the function to return an error
    		// to emulate resource Allocation failure.
    		// Resources not contained in this map will have their node.allocatableResource
    		// quantity unchanged.
    		updateResourceMap := map[v1.ResourceName]resource.Quantity{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/types.go

    	podKeys := make([]string, len(n.Pods))
    	for i, p := range n.Pods {
    		podKeys[i] = p.Pod.Name
    	}
    	return fmt.Sprintf("&NodeInfo{Pods:%v, RequestedResource:%#v, NonZeroRequest: %#v, UsedPort: %#v, AllocatableResource:%#v}",
    		podKeys, n.Requested, n.NonZeroRequested, n.UsedPorts, n.Allocatable)
    }
    
    // AddPodInfo adds pod information to this NodeInfo.
    // Consider using this instead of AddPod if a PodInfo is already computed.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 19:28:17 UTC 2024
    - 36.7K bytes
    - Viewed (0)
Back to top