Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 28 of 28 for NewMilliQuantity (0.24 sec)

  1. pkg/kubelet/kuberuntime/kuberuntime_manager.go

    			container.Resources.Limits = v1.ResourceList{
    				v1.ResourceCPU:    *resource.NewMilliQuantity(cInfo.currentContainerResources.cpuLimit, resource.DecimalSI),
    				v1.ResourceMemory: *resource.NewQuantity(cInfo.desiredContainerResources.memoryLimit, resource.BinarySI),
    			}
    			container.Resources.Requests = v1.ResourceList{
    				v1.ResourceCPU:    *resource.NewMilliQuantity(cInfo.currentContainerResources.cpuRequest, resource.DecimalSI),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 22 02:01:31 UTC 2024
    - 64.7K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/noderesources/fit_test.go

    )
    
    func makeResources(milliCPU, memory, pods, extendedA, storage, hugePageA int64) v1.ResourceList {
    	return v1.ResourceList{
    		v1.ResourceCPU:              *resource.NewMilliQuantity(milliCPU, resource.DecimalSI),
    		v1.ResourceMemory:           *resource.NewQuantity(memory, resource.BinarySI),
    		v1.ResourcePods:             *resource.NewQuantity(pods, resource.DecimalSI),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 57.4K bytes
    - Viewed (0)
  3. pkg/kubelet/nodestatus/setters.go

    		info, err := machineInfoFunc()
    		if err != nil {
    			// TODO(roberthbailey): This is required for test-cmd.sh to pass.
    			// See if the test should be updated instead.
    			node.Status.Capacity[v1.ResourceCPU] = *resource.NewMilliQuantity(0, resource.DecimalSI)
    			node.Status.Capacity[v1.ResourceMemory] = resource.MustParse("0Gi")
    			node.Status.Capacity[v1.ResourcePods] = *resource.NewQuantity(int64(maxPods), resource.DecimalSI)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 12:12:04 UTC 2024
    - 30.5K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/container_manager_linux.go

    	// Sum up resources of all external containers.
    	for _, cont := range cm.systemContainers {
    		cpuLimit += cont.cpuMillicores
    	}
    
    	return v1.ResourceList{
    		v1.ResourceCPU: *resource.NewMilliQuantity(
    			cpuLimit,
    			resource.DecimalSI),
    	}
    }
    
    func isProcessRunningInHost(pid int) (bool, error) {
    	// Get init pid namespace.
    	initPidNs, err := os.Readlink("/proc/1/ns/pid")
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 10:18:16 UTC 2024
    - 35.1K bytes
    - Viewed (0)
  5. pkg/scheduler/schedule_one_test.go

    			Capacity: v1.ResourceList{
    				v1.ResourceCPU:    *resource.NewMilliQuantity(milliCPU, resource.DecimalSI),
    				v1.ResourceMemory: *resource.NewQuantity(memory, resource.BinarySI),
    				"pods":            *resource.NewQuantity(100, resource.DecimalSI),
    			},
    			Allocatable: v1.ResourceList{
    
    				v1.ResourceCPU:    *resource.NewMilliQuantity(milliCPU, resource.DecimalSI),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 128.1K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apimachinery/pkg/api/resource/quantity_test.go

    		{1000000, "invalidFormatDefaultsToExponent", "1e3", true},
    		{1024 * 1024, BinarySI, "1048576m", false}, // Format changes
    	}
    
    	for _, item := range table {
    		q := NewMilliQuantity(item.value, item.format)
    		if e, a := item.expect, q.String(); e != a {
    			t.Errorf("Expected %v, got %v; %#v", e, a, q)
    		}
    		if !item.exact {
    			continue
    		}
    		q2, err := ParseQuantity(q.String())
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 21:48:10 UTC 2024
    - 49.4K bytes
    - Viewed (0)
  7. pkg/kubelet/kubelet_test.go

    	nodes := []*v1.Node{
    		{ObjectMeta: metav1.ObjectMeta{Name: testKubeletHostname},
    			Status: v1.NodeStatus{Capacity: v1.ResourceList{}, Allocatable: v1.ResourceList{
    				v1.ResourceCPU:    *resource.NewMilliQuantity(10, resource.DecimalSI),
    				v1.ResourceMemory: *resource.NewQuantity(100, resource.BinarySI),
    				v1.ResourcePods:   *resource.NewQuantity(40, resource.DecimalSI),
    			}}},
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  8. pkg/apis/core/validation/validation_test.go

    			t.Errorf("expected success: %v", errs)
    		}
    	}
    
    	containerLimitCase := core.ResourceRequirements{
    		Limits: core.ResourceList{
    			core.ResourceEphemeralStorage: *resource.NewMilliQuantity(
    				int64(40000),
    				resource.BinarySI),
    		},
    	}
    	if errs := ValidateResourceRequirements(&containerLimitCase, nil, field.NewPath("resources"), PodValidationOptions{}); len(errs) != 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 857.7K bytes
    - Viewed (0)
Back to top