Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for AllocatedResources (0.22 sec)

  1. pkg/kubelet/kubelet_pods.go

    		// AllocatedResources values come from checkpoint. It is the source-of-truth.
    		found := false
    		status.AllocatedResources, found = kl.statusManager.GetContainerResourceAllocation(string(pod.UID), cName)
    		if !(container.Resources.Requests == nil && container.Resources.Limits == nil) && !found {
    			// Log error and fallback to AllocatedResources in oldStatus if it exists
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet.go

    // updateContainerResourceAllocation updates AllocatedResources values
    // (for cpu & memory) from checkpoint store
    func (kl *Kubelet) updateContainerResourceAllocation(pod *v1.Pod) {
    	for _, c := range pod.Spec.Containers {
    		allocatedResources, found := kl.statusManager.GetContainerResourceAllocation(string(pod.UID), c.Name)
    		if c.Resources.Requests != nil && found {
    			if _, ok := allocatedResources[v1.ResourceCPU]; ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  3. pkg/api/pod/util_test.go

    						{
    							Name:               "c1",
    							Image:              "image",
    							AllocatedResources: api.ResourceList{api.ResourceCPU: resource.MustParse("100m")},
    						},
    						{
    							Name:               "c2",
    							Image:              "image",
    							AllocatedResources: api.ResourceList{api.ResourceCPU: resource.MustParse("200m")},
    						},
    					},
    				},
    			},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 108.8K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet_test.go

    		if tc.existingPodAllocation != nil {
    			// when kubelet restarts, AllocatedResources has already existed before adding pod
    			err := kubelet.statusManager.SetPodAllocation(tc.existingPodAllocation)
    			if err != nil {
    				t.Fatalf("failed to set pod allocation: %v", err)
    			}
    		}
    		kubelet.HandlePodAdditions([]*v1.Pod{tc.pod})
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  5. pkg/kubelet/kubelet_pods_test.go

    						{
    							Name:               testContainerName,
    							Resources:          &v1.ResourceRequirements{Limits: CPU1AndMem1GAndStorage2G, Requests: CPU1AndMem1GAndStorage2G},
    							AllocatedResources: CPU1AndMem1GAndStorage2GAndCustomResource,
    						},
    					},
    					Resize: "InProgress",
    				},
    			},
    		},
    		{
    			name: "cpu/memory resource in ResourcesAllocated, resize should be null",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
  6. pkg/apis/core/zz_generated.deepcopy.go

    	if in.Started != nil {
    		in, out := &in.Started, &out.Started
    		*out = new(bool)
    		**out = **in
    	}
    	if in.AllocatedResources != nil {
    		in, out := &in.AllocatedResources, &out.AllocatedResources
    		*out = make(ResourceList, len(*in))
    		for key, val := range *in {
    			(*out)[key] = val.DeepCopy()
    		}
    	}
    	if in.Resources != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 181.5K bytes
    - Viewed (0)
  7. staging/src/k8s.io/api/core/v1/zz_generated.deepcopy.go

    	if in.Started != nil {
    		in, out := &in.Started, &out.Started
    		*out = new(bool)
    		**out = **in
    	}
    	if in.AllocatedResources != nil {
    		in, out := &in.AllocatedResources, &out.AllocatedResources
    		*out = make(ResourceList, len(*in))
    		for key, val := range *in {
    			(*out)[key] = val.DeepCopy()
    		}
    	}
    	if in.Resources != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 181.9K bytes
    - Viewed (0)
  8. pkg/volume/util/operationexecutor/operation_generator.go

    	if status, ok := pvc.Status.AllocatedResourceStatuses[v1.ResourceStorage]; ok {
    		resizeStatus = status
    	}
    
    	var allocatedSize *resource.Quantity
    	t, ok := pvc.Status.AllocatedResources[v1.ResourceStorage]
    	if ok {
    		allocatedSize = &t
    	}
    	var err error
    
    	if pvSize.Cmp(pvcSpecSize) < 0 {
    		// pv is not of requested size yet and hence will require expanding
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 101.4K bytes
    - Viewed (0)
  9. pkg/kubelet/eviction/helpers_test.go

    	}, nil)
    	testpod.Status = v1.PodStatus{
    		ContainerStatuses: []v1.ContainerStatus{
    			{
    				Name:               "testcontainer",
    				AllocatedResources: newResourceList("", "100Mi", ""),
    			},
    		},
    	}
    	testpodMemory := resource.MustParse("150Mi")
    	testpodStats := newPodMemoryStats(testpod, testpodMemory)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 15 23:14:12 UTC 2024
    - 106.7K bytes
    - Viewed (0)
Back to top