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