Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 76 for NewQuantity (0.2 sec)

  1. pkg/kubelet/kuberuntime/kuberuntime_container_windows.go

    			cpuLimit = resource.NewMilliQuantity(cpuLimitValue, resource.DecimalSI)
    		}
    
    		if runtimeStatusResources.MemoryLimitInBytes > 0 {
    			memLimit = resource.NewQuantity(runtimeStatusResources.MemoryLimitInBytes, resource.BinarySI)
    		}
    
    		if cpuLimit != nil || memLimit != nil {
    			cStatusResources = &kubecontainer.ContainerResources{
    				CPULimit:    cpuLimit,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 8K bytes
    - Viewed (0)
  2. pkg/volume/csi/nodeinfomanager/nodeinfomanager_test.go

    						v1.ResourceName(util.GetCSIAttachLimitKey("com.example.csi/driver1")): *resource.NewQuantity(10, resource.DecimalSI),
    					},
    					Allocatable: v1.ResourceList{
    						v1.ResourceCPU: *resource.NewScaledQuantity(4, -3),
    						v1.ResourceName(util.GetCSIAttachLimitKey("com.example.csi/driver1")): *resource.NewQuantity(10, resource.DecimalSI),
    					},
    				},
    			},
    			expectedCSINode: &storage.CSINode{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Dec 17 02:02:59 UTC 2022
    - 34.3K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apimachinery/pkg/api/resource/quantity.go

    func NewDecimalQuantity(b inf.Dec, format Format) *Quantity {
    	return &Quantity{
    		d:      infDecAmount{&b},
    		Format: format,
    	}
    }
    
    // NewQuantity returns a new Quantity representing the given
    // value in the given format.
    func NewQuantity(value int64, format Format) *Quantity {
    	return &Quantity{
    		i:      int64Amount{value: value},
    		Format: format,
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 21:48:10 UTC 2024
    - 23.8K bytes
    - Viewed (0)
  4. 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])
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 12 11:25:36 UTC 2023
    - 8.7K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apimachinery/pkg/api/resource/quantity_test.go

    			t.Errorf("Round trip failed on %v", q)
    		}
    		if e, a := item.value, q2.MilliValue(); e != a {
    			t.Errorf("Expected %v, got %v", e, a)
    		}
    	}
    
    	for _, item := range table {
    		q := NewQuantity(0, item.format)
    		q.SetMilli(item.value)
    		if e, a := item.expect, q.String(); e != a {
    			t.Errorf("Set: Expected %v, got %v; %#v", e, a, q)
    		}
    	}
    }
    
    func TestNewSet(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 21:48:10 UTC 2024
    - 49.4K bytes
    - Viewed (0)
  6. pkg/kubelet/eviction/eviction_manager.go

    func (m *managerImpl) emptyDirLimitEviction(podStats statsapi.PodStats, pod *v1.Pod) bool {
    	podVolumeUsed := make(map[string]*resource.Quantity)
    	for _, volume := range podStats.VolumeStats {
    		podVolumeUsed[volume.Name] = resource.NewQuantity(int64(*volume.UsedBytes), resource.BinarySI)
    	}
    	for i := range pod.Spec.Volumes {
    		source := &pod.Spec.Volumes[i].VolumeSource
    		if source.EmptyDir != nil {
    			size := source.EmptyDir.SizeLimit
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 27 18:55:56 UTC 2024
    - 24.6K bytes
    - Viewed (0)
  7. pkg/kubelet/kuberuntime/kuberuntime_container_test.go

    				StartedAt: time.Unix(0, startedAt),
    				Resources: &kubecontainer.ContainerResources{
    					CPULimit:    resource.NewMilliQuantity(250, resource.DecimalSI),
    					MemoryLimit: resource.NewQuantity(524288000, resource.BinarySI),
    				},
    			},
    			skipOnWindows: true,
    		},
    		"container reporting cpu only": {
    			input: &runtimeapi.ContainerStatus{
    				Id:        cid.ID,
    				Metadata:  meta,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 28K bytes
    - Viewed (0)
  8. pkg/kubelet/cm/node_container_manager_linux.go

    	evictionReservation := hardEvictionReservation(cm.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])
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 10:18:16 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apimachinery/pkg/apis/meta/fuzzer/fuzzer.go

    	"k8s.io/apimachinery/pkg/util/sets"
    )
    
    func genericFuzzerFuncs(codecs runtimeserializer.CodecFactory) []interface{} {
    	return []interface{}{
    		func(q *resource.Quantity, c fuzz.Continue) {
    			*q = *resource.NewQuantity(c.Int63n(1000), resource.DecimalExponent)
    		},
    		func(j *int, c fuzz.Continue) {
    			*j = int(c.Int31())
    		},
    		func(j **int, c fuzz.Continue) {
    			if c.RandBool() {
    				i := int(c.Int31())
    				*j = &i
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 03 15:12:26 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/quota/v1/generic/evaluator.go

    }
    
    // Usage returns the resource usage for the specified object
    func (o *objectCountEvaluator) Usage(object runtime.Object) (corev1.ResourceList, error) {
    	quantity := resource.NewQuantity(1, resource.DecimalSI)
    	resourceList := corev1.ResourceList{}
    	for _, resourceName := range o.resourceNames {
    		resourceList[resourceName] = *quantity
    	}
    	return resourceList, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 05 00:02:47 UTC 2023
    - 11.7K bytes
    - Viewed (0)
Back to top