- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 47 for mustParse (0.17 sec)
-
pkg/volume/util/util_test.go
Capacity: v1.ResourceList{ v1.ResourceName(v1.ResourceStorage): resource.MustParse("500M"), }, }, } timeout := CalculateTimeoutForVolume(50, 30, pv) if timeout != 50 { t.Errorf("Expected 50 for timeout but got %v", timeout) } pv.Spec.Capacity[v1.ResourceStorage] = resource.MustParse("2Gi") timeout = CalculateTimeoutForVolume(50, 30, pv) if timeout != 60 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 28.7K bytes - Viewed (0) -
cmd/kubeadm/app/phases/etcd/local.go
staticpodutil.NewVolumeMount(certsVolumeName, cfg.CertificatesDir+"/etcd", false), }, Resources: v1.ResourceRequirements{ Requests: v1.ResourceList{ v1.ResourceCPU: resource.MustParse("100m"), v1.ResourceMemory: resource.MustParse("100Mi"), }, }, // The etcd probe endpoints are explained here: // https://github.com/kubernetes/kubeadm/issues/3039
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 23 14:07:27 UTC 2024 - 13.8K bytes - Viewed (1) -
pkg/scheduler/testing/wrappers.go
func (n *NodeWrapper) Capacity(resources map[v1.ResourceName]string) *NodeWrapper { res := v1.ResourceList{ v1.ResourcePods: resource.MustParse("32"), } for name, value := range resources { res[name] = resource.MustParse(value) } n.Status.Capacity, n.Status.Allocatable = res, res return n } // Images sets the images of the inner node. Each entry in `images` corresponds
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 07:57:10 UTC 2024 - 42.1K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/desired_state_of_world_test.go
seLinuxTranslator := util.NewFakeSELinuxLabelTranslator() dsw := NewDesiredStateOfWorld(volumePluginMgr, seLinuxTranslator) quantity1Gi := resource.MustParse("1Gi") quantity2Gi := resource.MustParse("2Gi") quantity3Gi := resource.MustParse("3Gi") pod1 := &v1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "pod1", UID: "pod1uid", }, Spec: v1.PodSpec{ Containers: []v1.Container{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 34K bytes - Viewed (0) -
pkg/controller/testutil/test_utils.go
return &v1.Node{ ObjectMeta: metav1.ObjectMeta{Name: name}, Status: v1.NodeStatus{ Capacity: v1.ResourceList{ v1.ResourceName(v1.ResourceCPU): resource.MustParse("10"), v1.ResourceName(v1.ResourceMemory): resource.MustParse("10G"), }, }, } } // NewPod is a helper function for creating Pods for testing. func NewPod(name, host string) *v1.Pod { pod := &v1.Pod{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 15.6K bytes - Viewed (0) -
pkg/volume/csi/csi_client_test.go
volumePath: "/foo/bar", newSize: resource.MustParse("10Gi"), mustFail: false, }, { name: "with missing volume-id", volumePath: "/foo/bar", newSize: resource.MustParse("10Gi"), mustFail: true, }, { name: "with missing volume path", volID: "vol-1234", newSize: resource.MustParse("10Gi"), mustFail: true, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 33.9K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/framework_test.go
ObjectMeta: metav1.ObjectMeta{ Name: name, ResourceVersion: "1", }, Spec: v1.PersistentVolumeSpec{ Capacity: v1.ResourceList{ v1.ResourceName(v1.ResourceStorage): resource.MustParse(capacity), }, PersistentVolumeSource: v1.PersistentVolumeSource{ GCEPersistentDisk: &v1.GCEPersistentDiskVolumeSource{}, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 09:54:00 UTC 2023 - 38.3K bytes - Viewed (0) -
pkg/apis/resource/structured/namedresources/validation/validation_test.go
resources := &resourceapi.NamedResourcesResources{ Instances: instances, } return resources } func TestValidateResources(t *testing.T) { goodName := "foo" badName := "!@#$%^" quantity := resource.MustParse("1") scenarios := map[string]struct { resources *resourceapi.NamedResourcesResources wantFailures field.ErrorList }{ "empty": { resources: testResources(nil), }, "good": {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:13 UTC 2024 - 10.4K bytes - Viewed (0) -
cmd/kubemark/app/hollow_node.go
var containerManager cm.ContainerManager if config.ExtendedResources != nil { extendedResources := v1.ResourceList{} for k, v := range config.ExtendedResources { extendedResources[v1.ResourceName(k)] = resource.MustParse(v) } containerManager = cm.NewStubContainerManagerWithDevicePluginResource(extendedResources) } else { containerManager = cm.NewStubContainerManager() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 08:58:18 UTC 2024 - 11K bytes - Viewed (0) -
cmd/kube-proxy/app/server_test.go
OutputRoutingOptions: logsapi.OutputRoutingOptions{ InfoBufferSize: resource.QuantityValue{Quantity: resource.MustParse("0")}, }, }, Text: logsapi.TextOptions{ OutputRoutingOptions: logsapi.OutputRoutingOptions{ InfoBufferSize: resource.QuantityValue{Quantity: resource.MustParse("0")}, }, }, }, } for name, tc := range map[string]struct { config string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 32.3K bytes - Viewed (0)