- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 76 for NewQuantity (0.2 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)